new envars for status update transformer

Author: masl2

infrastructure/terraform/components/api/module_lambda_letter_updates_transformer.tf

@@ -36,7 +36,9 @@ module "letter_updates_transformer" {
   log_subscription_role_arn = local.acct.log_subscription_role_arn
 
   lambda_env_vars = merge(local.common_lambda_env_vars, {
-    EVENTPUB_SNS_TOPIC_ARN = "${module.eventpub.sns_topic.arn}"
+    EVENTPUB_SNS_TOPIC_ARN = "${module.eventpub.sns_topic.arn}",
+    ACCOUNT_SHORT_NAME = var.group,
+    ENVIRONMENT = var.environment
   })
 }
 

internal/datastore/src/types.ts

@@ -47,6 +47,8 @@ export const LetterSchema = LetterSchemaBase.extend({
   updatedAt: z.string(),
   supplierStatus: z.string().describe("Secondary index PK"),
   supplierStatusSk: z.string().describe("Secondary index SK"),
+  source: z.string(),
+  subject: z.string(),
   ttl: z.int(),
 }).describe("Letter");
 

lambdas/letter-updates-transformer/src/env.ts

@@ -2,6 +2,8 @@ import { z } from "zod";
 
 const EnvVarsSchema = z.object({
   EVENTPUB_SNS_TOPIC_ARN: z.string(),
+  ACCOUNT_SHORT_NAME: z.string(),
+  ENVIRONMENT: z.string(),
 });
 
 export type EnvVars = z.infer<typeof EnvVarsSchema>;

lambdas/letter-updates-transformer/src/letter-updates-transformer.ts

@@ -13,6 +13,7 @@ import { LetterEvent } from "@nhsdigital/nhs-notify-event-schemas-supplier-api/s
 import mapLetterToCloudEvent from "./mappers/letter-mapper";
 import { Deps } from "./deps";
 import { LetterForEventPub, LetterSchemaForEventPub } from "./types";
+import { envVars } from "./env";
 
 // SNS PublishBatchCommand supports up to 10 messages per batch
 const BATCH_SIZE = 10;
@@ -30,7 +31,7 @@ export default function createHandler(deps: Deps): Handler<KinesisStreamEvent> {
           isChanged(record, "status") || isChanged(record, "reasonCode"),
       )
       .map((element) => extractNewLetter(element))
-      .map((element) => mapLetterToCloudEvent(element));
+      .map((element) => mapLetterToCloudEvent(element, envVars.ACCOUNT_SHORT_NAME, envVars.ENVIRONMENT));
 
     for (const batch of generateBatches(cloudEvents)) {
       deps.logger.info({

lambdas/letter-updates-transformer/src/mappers/__tests__/letter-mapper.test.ts

@@ -14,7 +14,9 @@ describe("letter-mapper", () => {
       reasonText: "Reason text",
       updatedAt: "2025-11-24T15:55:18.000Z",
     } as Letter;
-    const event = mapLetterToCloudEvent(letter);
+    const account = 'dev';
+    const environment = 'main';
+    const event = mapLetterToCloudEvent(letter, account, environment);
 
     // Check it conforms to the letter event schema - parse will throw an error if not
     $LetterEvent.parse(event);

lambdas/letter-updates-transformer/src/mappers/letter-mapper.ts

@@ -5,6 +5,8 @@ import { LetterForEventPub } from "../types";
 
 export default function mapLetterToCloudEvent(
   letter: LetterForEventPub,
+  account: string,
+  environment: string
 ): LetterEvent {
   const eventId = randomUUID();
   const dataschemaversion = eventSchemaPackage.version;
@@ -15,7 +17,7 @@ export default function mapLetterToCloudEvent(
     plane: "data",
     dataschema: `https://notify.nhs.uk/cloudevents/schemas/supplier-api/letter.${letter.status}.${dataschemaversion}.schema.json`,
     dataschemaversion,
-    source: "/data-plane/supplier-api/letters",
+    source: `/data-plane/supplier-api/${account}/${environment}/letters`,
     subject: `letter-origin/supplier-api/letter/${letter.id}`,
 
     data: {
@@ -28,6 +30,7 @@ export default function mapLetterToCloudEvent(
       reasonText: letter.reasonText,
       origin: {
         domain: "supplier-api",
+        //TODO CCM-12977: when event sourcing implements source and subject fields, these value come from the letter
         source: "/data-plane/supplier-api/letters",
         subject: `letter-origin/supplier-api/letter/${letter.id}`,
         event: eventId,