From bb3261806337236e6143e6872ad72c7a3d3d2072 Mon Sep 17 00:00:00 2001
From: Alejo Thomas Ortega <alejo.ortega@decentraland.org>
Date: Wed, 31 Jul 2024 17:36:49 -0300
Subject: [PATCH] feat: add MessageAttributes for further filtering

---
 src/adapters/event-publisher.ts | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/src/adapters/event-publisher.ts b/src/adapters/event-publisher.ts
index f42d7f5..94980d7 100644
--- a/src/adapters/event-publisher.ts
+++ b/src/adapters/event-publisher.ts
@@ -14,7 +14,17 @@ export async function createEventPublisher({ config }: Pick<AppComponents, 'conf
     const { MessageId } = await client.send(
       new PublishCommand({
         TopicArn: snsArn,
-        Message: JSON.stringify(event)
+        Message: JSON.stringify(event),
+        MessageAttributes: {
+          type: {
+            DataType: 'String',
+            StringValue: event.type
+          },
+          subType: {
+            DataType: 'String',
+            StringValue: event.subType
+          }
+        }
       })
     )