CCM-13146 add extra e2e test

Author: Ian-Hodges

tests/playwright/constants/backend-constants.ts

@@ -2,6 +2,7 @@
 // Environment Configuration
 export const ENV = process.env.ENVIRONMENT || 'main';
 export const REGION = process.env.AWS_REGION || 'eu-west-2';
+export const { AWS_ACCOUNT_ID } = process.env;
 
 // Compound Scope Indicator
 export const CSI = `nhs-${ENV}-dl`;
@@ -15,9 +16,12 @@ export const TTL_POLL_LAMBDA_NAME = `${CSI}-ttl-poll`;
 export const TTL_QUEUE_NAME = `${CSI}-ttl-queue`;
 export const TTL_DLQ_NAME = `${CSI}-ttl-dlq`;
 
+// Queue Url Prefix
+export const SQS_URL_PREFIX = `https://sqs.${REGION}.amazonaws.com/${AWS_ACCOUNT_ID}/`;
+
 // Event Bus
-export const EVENT_BUS_ARN = `arn:aws:events:${REGION}:${process.env.AWS_ACCOUNT_ID}:event-bus/${CSI}`;
-export const EVENT_BUS_DLQ_URL = `https://sqs.${REGION}.amazonaws.com/${process.env.AWS_ACCOUNT_ID}/${CSI}-event-publisher-errors-queue`;
+export const EVENT_BUS_ARN = `arn:aws:events:${REGION}:${AWS_ACCOUNT_ID}:event-bus/${CSI}`;
+export const EVENT_BUS_DLQ_URL = `${SQS_URL_PREFIX}${CSI}-event-publisher-errors-queue`;
 
 // DynamoDB
 export const TTL_TABLE_NAME = `${CSI}-ttl`;

tests/playwright/digital-letters-component-tests/handle-ttl.component.spec.ts

@@ -3,9 +3,16 @@ import { ENV } from 'constants/backend-constants';
 import { getLogsFromCloudwatch } from 'helpers/cloudwatch-helpers';
 import { deleteTtl, putTtl } from 'helpers/dynamodb-helpers';
 import expectToPassEventually from 'helpers/expectations';
+import { expectMessageContainingString, purgeQueue } from 'helpers/sqs-helpers';
 import { v4 as uuidv4 } from 'uuid';
 
 test.describe('Digital Letters - Handle TTL', () => {
+  const handleTtlDlqName = `nhs-${ENV}-dl-ttl-handle-expiry-errors-queue`;
+
+  test.beforeAll(async () => {
+    await purgeQueue(handleTtlDlqName);
+  });
+
   const baseEvent = {
     profileversion: '1.0.0',
     profilepublished: '2025-10',
@@ -114,4 +121,34 @@ test.describe('Digital Letters - Handle TTL', () => {
       });
     });
   });
+
+  test('should send invalid item to dlq', async () => {
+    const letterId = uuidv4();
+    const messageUri = `https://example.com/ttl/resource/${letterId}`;
+
+    const eventWithNoMessageUri = {
+      ...baseEvent,
+      id: letterId,
+      data: {
+        ...baseEvent.data,
+        'digital-letter-id': letterId,
+      },
+    };
+
+    const ttlItem = {
+      PK: messageUri,
+      SK: 'TTL',
+      dateOfExpiry: '2023-12-31#0',
+      event: eventWithNoMessageUri,
+      ttl: Date.now() / 1000 + 3600,
+    };
+
+    const putResponseCode = await putTtl(ttlItem);
+    expect(putResponseCode).toBe(200);
+
+    const deleteResponseCode = await deleteTtl(messageUri);
+    expect(deleteResponseCode).toBe(200);
+
+    await expectMessageContainingString(handleTtlDlqName, letterId);
+  });
 });

tests/playwright/helpers/sqs-helpers.ts

@@ -0,0 +1,64 @@
+import {
+  DeleteMessageBatchCommand,
+  ReceiveMessageCommand,
+  ReceiveMessageCommandInput,
+} from '@aws-sdk/client-sqs';
+import { expect } from '@playwright/test';
+import { SQS_URL_PREFIX } from 'constants/backend-constants';
+import { sqsClient } from 'utils';
+import expectToPassEventually from 'helpers/expectations';
+
+function getQueueUrl(queueName: string) {
+  return `${SQS_URL_PREFIX}${queueName}`;
+}
+
+export async function expectMessageContainingString(
+  queueName: string,
+  searchTerm: string,
+) {
+  const input: ReceiveMessageCommandInput = {
+    QueueUrl: getQueueUrl(queueName),
+    MaxNumberOfMessages: 10,
+    WaitTimeSeconds: 1,
+    VisibilityTimeout: 2,
+  };
+
+  await expectToPassEventually(async () => {
+    const result = await sqsClient.send(new ReceiveMessageCommand(input));
+    const polledMessages = result.Messages || [];
+
+    expect(
+      polledMessages.find((m) => (m.Body ?? '').includes(searchTerm)),
+    ).toBeDefined();
+  });
+}
+
+export async function purgeQueue(queueName: string) {
+  const queueUrl = getQueueUrl(queueName);
+
+  for (;;) {
+    const result = await sqsClient.send(
+      new ReceiveMessageCommand({
+        QueueUrl: queueUrl,
+        MaxNumberOfMessages: 10,
+        WaitTimeSeconds: 1,
+      }),
+    );
+
+    const messages = result.Messages || [];
+
+    if (messages.length === 0) {
+      break;
+    }
+
+    await sqsClient.send(
+      new DeleteMessageBatchCommand({
+        QueueUrl: queueUrl,
+        Entries: messages.map((msg, index) => ({
+          Id: index.toString(),
+          ReceiptHandle: msg.ReceiptHandle!,
+        })),
+      }),
+    );
+  }
+}