fix async sns post-ingest publishing

Author: Phil Varner

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## [Unreleased] - TBD
+
+### Fixed
+
+- Post-ingest SNS topic was not being published to when deployed as a Lambda.
+
 ## [2.0.0] - 2023-06-26
 
 ### Removed

src/lambdas/ingest/index.js

@@ -67,7 +67,7 @@ export const handler = async (event, _context) => {
 
     if (postIngestTopicArn) {
       logger.debug('Publishing to post-ingest topic: %s', postIngestTopicArn)
-      publishResultsToSns(results, postIngestTopicArn)
+      await publishResultsToSns(results, postIngestTopicArn)
     } else {
       logger.debug('Skkipping post-ingest notification since no topic is configured')
     }

src/lib/ingest.js

@@ -187,11 +187,11 @@ function updateLinksWithinRecord(record) {
   return record
 }
 
-export function publishResultsToSns(results, topicArn) {
-  results.forEach(async (result) => {
+export async function publishResultsToSns(results, topicArn) {
+  await Promise.all(results.map(async (result) => {
     if (result.record && !result.error) {
       updateLinksWithinRecord(result.record)
     }
     await publishRecordToSns(topicArn, result.record, result.error)
-  })
+  }))
 }