feat: also publish events to Events SNS topic (#497)

src/adapters/deployer/index.ts

@@ -40,12 +40,12 @@ export function createDeployerComponent(
 
  logger.info('Entity stored', { entityId: entity.entityId, entityType: entity.entityType })
 
+ const deploymentToSqs: DeploymentToSqs = {
+ entity,
+ contentServerUrls: servers
+ }
  // send sns
  if (components.sns.arn) {
- const deploymentToSqs: DeploymentToSqs = {
- entity,
- contentServerUrls: servers
- }
  const receipt = await sns
  .publish({
  TopicArn: components.sns.arn,
@@ -57,6 +57,19 @@ export function createDeployerComponent(
  SequenceNumber: receipt.SequenceNumber as any
  })
  }
+
+ if (components.sns.eventArn) {
+ const receipt = await sns
+ .publish({
+ TopicArn: components.sns.eventArn,
+ Message: JSON.stringify(deploymentToSqs)
+ })
+ .promise()
+ logger.info('Notification sent to events SNS', {
+ MessageId: receipt.MessageId as any,
+ SequenceNumber: receipt.SequenceNumber as any
+ })
+ }
  await markAsDeployed()
  })
  } else {

src/components.ts

@@ -34,6 +34,7 @@ export async function initComponents(): Promise<AppComponents> {
 
  const bucket = await config.getString('BUCKET')
  const snsArn = await config.getString('SNS_ARN')
+ const eventSnsArn = await config.getString('EVENTS_SNS_ARN')
 
  const storage = bucket
  ? await createAwsS3BasedFileSystemContentStorage({ fs, config }, bucket)
@@ -46,7 +47,8 @@ export async function initComponents(): Promise<AppComponents> {
  })
 
  const sns: SnsComponent = {
- arn: snsArn
+ arn: snsArn,
+ eventArn: eventSnsArn
  }
 
  const deployer = createDeployerComponent({ storage, downloadQueue, fetch, logs, metrics, sns })

src/types.ts

@@ -30,7 +30,7 @@ export type BaseComponents = {
  sns: SnsComponent
 }
 
-export type SnsComponent = { arn?: string }
+export type SnsComponent = { arn?: string; eventArn?: string }
 
 // components used in runtime
 export type AppComponents = BaseComponents & {