Empty function in PSU that will push data to SQS

Author: wildjames

SAMtemplates/functions/main.yaml

@@ -66,6 +66,7 @@ Resources:
       Environment:
         Variables:
           TABLE_NAME: !Ref PrescriptionStatusUpdatesTableName
+          NHS_NOTIFY_PRESCRIPTIONS_SQS_QUEUE_URL: !Ref NHSNotifyPrescriptionsSQSQueueUrl
           LOG_LEVEL: !Ref LogLevel
           ENVIRONMENT: !Ref Environment
           TEST_PRESCRIPTIONS_1: "None"

packages/updatePrescriptionStatus/src/updatePrescriptionStatus.ts

@@ -2,14 +2,19 @@
 import {APIGatewayProxyEvent, APIGatewayProxyResult} from "aws-lambda"
 import {Logger} from "@aws-lambda-powertools/logger"
 import {injectLambdaContext} from "@aws-lambda-powertools/logger/middleware"
+import {TransactionCanceledException} from "@aws-sdk/client-dynamodb"
+
 import middy from "@middy/core"
 import inputOutputLogger from "@middy/input-output-logger"
-import errorHandler from "@nhs/fhir-middy-error-handler"
 import httpHeaderNormalizer from "@middy/http-header-normalizer"
+
+import errorHandler from "@nhs/fhir-middy-error-handler"
 import {Bundle, BundleEntry, Task} from "fhir/r4"
+
+import {transactionBundle, validateEntry} from "./validation/content"
 import {getPreviousItem, persistDataItems} from "./utils/databaseClient"
 import {jobWithTimeout, hasTimedOut} from "./utils/timeoutUtils"
-import {transactionBundle, validateEntry} from "./validation/content"
+import {pushPrescriptionToNotificationSQS} from "./utils/sqsClient"
 import {
   accepted,
   badRequest,
@@ -19,7 +24,6 @@ import {
   serverError,
   timeoutResponse
 } from "./utils/responses"
-import {TransactionCanceledException} from "@aws-sdk/client-dynamodb"
 import {
   InterceptionResult,
   testPrescription1Intercept,
@@ -159,6 +163,10 @@ const lambdaHandler = async (event: APIGatewayProxyEvent): Promise<APIGatewayPro
     return response(500, responseEntries)
   }
 
+  // This prescription was handled successfully,
+  // so add a message to the notifications SQS
+  pushPrescriptionToNotificationSQS(dataItems)
+
   return response(201, responseEntries)
 }
 

packages/updatePrescriptionStatus/src/utils/sqsClient.ts

@@ -0,0 +1,8 @@
+import {Logger} from "@aws-lambda-powertools/logger"
+import {DataItem} from "../updatePrescriptionStatus"
+
+const sqsUrl = process.env.NHS_NOTIFY_PRESCRIPTIONS_SQS_QUEUE_URL
+
+export function pushPrescriptionToNotificationSQS(data: Array<DataItem>, logger: Logger) {
+  logger.info("Pushing data items up to the notifications SQS", {data, sqsUrl})
+}