add more logging in upsert lambda

Author: Vlasis-Perdikidis

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

@@ -5,7 +5,7 @@ import {
   SQSHandler,
   SQSRecord,
 } from "aws-lambda";
-import { InsertLetter, UpdateLetter } from "@internal/datastore";
+import { InsertLetter, Letter, UpdateLetter } from "@internal/datastore";
 import {
   $LetterRequestPreparedEvent,
   LetterRequestPreparedEvent,
@@ -26,7 +26,7 @@ type PreparedEvents = LetterRequestPreparedEventV2 | LetterRequestPreparedEvent;
 type UpsertOperation = {
   name: "Insert" | "Update";
   schemas: z.ZodSchema[];
-  handler: (request: unknown, deps: Deps) => Promise<void>;
+  handler: (request: unknown, deps: Deps) => Promise<Letter>;
 };
 
 // small envelope that must exist in all inputs
@@ -37,7 +37,7 @@ function getOperationFromType(type: string): UpsertOperation {
     return {
       name: "Insert",
       schemas: [$LetterRequestPreparedEventV2, $LetterRequestPreparedEvent],
-      handler: async (request, deps) => {
+      handler: async (request, deps): Promise<Letter> => {
         const preparedRequest = request as PreparedEvents;
         const supplierSpec: SupplierSpec = resolveSupplierForVariant(
           preparedRequest.data.letterVariantId,
@@ -47,19 +47,19 @@ function getOperationFromType(type: string): UpsertOperation {
           preparedRequest,
           supplierSpec.supplierId,
           supplierSpec.specId,
-          supplierSpec.specId, //use specId for now
+          supplierSpec.specId, // use specId for now
         );
-        await deps.letterRepo.putLetter(letterToInsert);
+        return deps.letterRepo.putLetter(letterToInsert);
       },
     };
   if (type.startsWith("uk.nhs.notify.supplier-api.letter"))
     return {
       name: "Update",
       schemas: [$LetterEvent],
-      handler: async (request, deps) => {
+      handler: async (request, deps): Promise<Letter> => {
         const supplierEvent = request as LetterEvent;
         const letterToUpdate: UpdateLetter = mapToUpdateLetter(supplierEvent);
-        await deps.letterRepo.updateLetterStatus(letterToUpdate);
+        return deps.letterRepo.updateLetterStatus(letterToUpdate);
       },
     };
   throw new Error(`Unknown operation from type=${type}`);
@@ -86,7 +86,7 @@ function mapToInsertLetter(
     subject: upsertRequest.subject,
     createdAt: now,
     updatedAt: now,
-    billingRef: billingRef,
+    billingRef,
   };
 }
 
@@ -108,7 +108,7 @@ function resolveSupplierForVariant(
 }
 
 function parseSNSNotification(record: SQSRecord) {
-  console.log("record in parseSNSNotificatino: ", record);
+  console.log("record in parseSNSNotificatino:", record);
   const notification = JSON.parse(record.body) as Partial<SNSMessage>;
   if (
     notification.Type !== "Notification" ||
@@ -137,7 +137,8 @@ async function runUpsert(
   for (const schema of operation.schemas) {
     const r = schema.safeParse(letterEvent);
     if (r.success) {
-      await operation.handler(r.data, deps);
+      const letterSchemaParseResponse = await operation.handler(r.data, deps);
+      console.log("operation handler response:", letterSchemaParseResponse);
       return;
     }
   }
@@ -150,11 +151,11 @@ export default function createUpsertLetterHandler(deps: Deps): SQSHandler {
     const batchItemFailures: SQSBatchItemFailure[] = [];
 
     const tasks = event.Records.map(async (record) => {
-      console.log("record in createUpsertLetterHandler: ", record);
+      console.log("record in createUpsertLetterHandler:", record);
       try {
         const message: string = parseSNSNotification(record);
 
-        console.log("message after parsing: ", message);
+        console.log("message after parsing:", message);
         const letterEvent: unknown = JSON.parse(message);
 
         const type = getType(letterEvent);