chore: add logs when publishing events to SNS

decentraland · Jan 17, 2025 · 21326c7 · 21326c7
1 parent c9deda2
commit 21326c7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/consumer-server/src/adapters/sns.ts b/consumer-server/src/adapters/sns.ts
@@ -2,7 +2,8 @@ import { PublishCommand, SNSClient } from '@aws-sdk/client-sns'
 import { AppComponents, PublisherComponent } from '../types'
 import { AssetBundleConversionFinishedEvent, AssetBundleConversionManuallyQueuedEvent } from '@dcl/schemas'
 
-export async function createSnsComponent({ config }: Pick<AppComponents, 'config'>): Promise<PublisherComponent> {
+export async function createSnsComponent({ config, logs }: Pick<AppComponents, 'config' | 'logs'>): Promise<PublisherComponent> {
+  const logger = logs.getLogger('publisher')
   const snsArn = await config.requireString('AWS_SNS_ARN')
   const optionalEndpoint = await config.getString('AWS_SNS_ENDPOINT')
 
@@ -29,6 +30,9 @@ export async function createSnsComponent({ config }: Pick<AppComponents, 'config
     })
 
     await client.send(command)
+    logger.info('Published message to SNS', {
+      entityId: event.metadata.entityId,
+    })
   }
 
   return { publishMessage }

diff --git a/consumer-server/src/components.ts b/consumer-server/src/components.ts
@@ -57,7 +57,7 @@ export async function initComponents(): Promise<AppComponents> {
   const cdnS3 = s3Bucket ? new AWS.S3({}) : new MockAws.S3({})
 
   const runner = createRunnerComponent()
-  const publisher = await createSnsComponent({ config })
+  const publisher = await createSnsComponent({ config, logs })
 
   return {
     config,