Use SNS message, not event

Author: stevebux

lambdas/allocation/src/__tests__/allocator.test.ts

@@ -92,7 +92,7 @@ describe("allocator", () => {
         expect.objectContaining({
           input: {
             QueueUrl: mockQueueUrl,
-            MessageBody: JSON.stringify(snsEvent.Records[0]),
+            MessageBody: JSON.stringify(snsEvent.Records[0].Sns),
             MessageGroupId: expect.any(String),
           },
         }),
@@ -120,7 +120,7 @@ describe("allocator", () => {
         expect.objectContaining({
           input: {
             QueueUrl: mockQueueUrl,
-            MessageBody: JSON.stringify(snsEvent.Records[0]),
+            MessageBody: JSON.stringify(snsEvent.Records[0].Sns),
             MessageGroupId: expect.any(String),
           },
         }),
@@ -130,7 +130,7 @@ describe("allocator", () => {
         expect.objectContaining({
           input: {
             QueueUrl: mockQueueUrl,
-            MessageBody: JSON.stringify(snsEvent.Records[1]),
+            MessageBody: JSON.stringify(snsEvent.Records[1].Sns),
             MessageGroupId: expect.any(String),
           },
         }),
@@ -140,7 +140,7 @@ describe("allocator", () => {
         expect.objectContaining({
           input: {
             QueueUrl: mockQueueUrl,
-            MessageBody: JSON.stringify(snsEvent.Records[2]),
+            MessageBody: JSON.stringify(snsEvent.Records[2].Sns),
             MessageGroupId: expect.any(String),
           },
         }),

lambdas/allocation/src/allocator.ts

@@ -25,7 +25,7 @@ export default function createAllocator(deps: Deps): SNSHandler {
 function buildSendMessageCommand(snsRecord: SNSEventRecord, queueUrl: string) {
   return new SendMessageCommand({
     QueueUrl: queueUrl,
-    MessageBody: JSON.stringify(snsRecord),
+    MessageBody: JSON.stringify(snsRecord.Sns),
     // Using a random UUID here effectively means that the amendments queue is not FIFO for new pending
     // letters. Pragmatically this is OK because we shouldn't be getting updates from the supplier yet.
     MessageGroupId: randomUUID(),