debug messaging

scaffoldly · Apr 9, 2024 · 95cdd2b · 95cdd2b
1 parent 5cf2d42
commit 95cdd2b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/s3-poller.ts b/src/s3-poller.ts
@@ -148,9 +148,11 @@ export class MappedS3Event implements S3Event {
       const event = JSON.parse(body) as S3Event | S3TestEvent;
       if ("Records" in event && event.Records && event.Records.length) {
         acc = acc.concat(...event.Records);
+        return acc;
       }
 
       if ("Event" in event && event.Event && event.Event === "s3:TestEvent") {
+        console.log("!!! received test event", event);
         this.TestMessageReceiptHandle = receiptHandle;
       }
 

diff --git a/src/sqs-queue-poller.ts b/src/sqs-queue-poller.ts
@@ -71,6 +71,8 @@ export class SqsQueuePoller {
           this.queueArn
         );
 
+        console.log("!!! acking messages", receiptHandles);
+
         await Promise.all(
           receiptHandles.map(async (receiptHandle) => {
             await this.client.send(