logging and double parse

Author: nhsd-david-wass

lambdas/upsert-letter/src/handler/__tests__/upsert-handler.test.ts

@@ -222,9 +222,9 @@ describe("createUpsertLetterHandler", () => {
     };
 
     const evt: SQSEvent = createSQSEvent([
-      createSqsRecord("msg1", JSON.stringify(v2message)),
-      createSqsRecord("msg2", JSON.stringify(v1message)),
-      createSqsRecord("msg3", JSON.stringify(updateMessage)),
+      createSqsRecord("msg1", JSON.stringify(JSON.stringify(v2message))),
+      createSqsRecord("msg2", JSON.stringify(JSON.stringify(v1message))),
+      createSqsRecord("msg3", JSON.stringify(JSON.stringify(updateMessage))),
     ]);
 
     const result = await createUpsertLetterHandler(mockedDeps)(
@@ -288,7 +288,10 @@ describe("createUpsertLetterHandler", () => {
       supplierSpec: undefined,
     };
     const evt: SQSEvent = createSQSEvent([
-      createSqsRecord("unknown-supplier", JSON.stringify(message)),
+      createSqsRecord(
+        "unknown-supplier",
+        JSON.stringify(JSON.stringify(message)),
+      ),
     ]);
 
     await createUpsertLetterHandler(mockedDeps)(evt, {} as any, {} as any);
@@ -402,7 +405,7 @@ describe("createUpsertLetterHandler", () => {
       supplierSpec: { supplierId: "supplier1", specId: "spec1" },
     };
     const evt: SQSEvent = createSQSEvent([
-      createSqsRecord("bad-event", JSON.stringify(message)),
+      createSqsRecord("bad-event", JSON.stringify(JSON.stringify(message))),
     ]);
 
     const result = await createUpsertLetterHandler(mockedDeps)(

lambdas/upsert-letter/src/handler/upsert-handler.ts

@@ -175,7 +175,12 @@ export default function createUpsertLetterHandler(deps: Deps): SQSHandler {
       const tasks = event.Records.map(async (record) => {
         let supplier = "unknown";
         try {
-          const queueMessage = JSON.parse(record.body);
+          deps.logger.info({
+            description: "Received message from SQS",
+            messageId: record.messageId,
+            body: record.body,
+          });
+          const queueMessage = JSON.parse(JSON.parse(record.body));
 
           const { letterEvent, supplierSpec } = queueMessage;