Merge pull request #881 from govuk-one-login/bau-strkyer-config

BAU: Stryker config

Author: edlouth

src/services/test/send-sqs-message.test.ts

@@ -42,6 +42,11 @@ describe('sendSqsMessage', () => {
 
     expect(SQSClient).toHaveBeenCalledWith({ region: 'eu-west-2' });
     expect(sendFn).toHaveBeenCalledWith(expect.any(SendMessageCommand));
+    expect(sendFn).toHaveBeenCalledWith(
+      expect.objectContaining({
+        input: { QueueUrl: queueUrl, MessageBody: messageBody },
+      }),
+    );
   });
 
   it('throws an error if sending the message fails', async () => {
@@ -80,6 +85,11 @@ describe('sendBatchSqsMessage', () => {
 
     expect(SQSClient).toHaveBeenCalledWith({ region: 'eu-west-2' });
     expect(sendFn).toHaveBeenCalledWith(expect.any(SendMessageBatchCommand));
+    expect(sendFn).toHaveBeenCalledWith(
+      expect.objectContaining({
+        input: { QueueUrl: queueUrl, Entries: entries },
+      }),
+    );
   });
 
   it('throws an error if sending the message fails', async () => {

src/services/test/validate-event.test.ts

@@ -5,6 +5,7 @@ import {
   validateEventIsNotStale,
   validateInterventionEvent,
   validateIfIdentityAcquired,
+  attemptToParseJson,
 } from '../validate-event';
 import logger from '../../commons/logger';
 import { addMetric } from '../../commons/metrics';
@@ -203,6 +204,46 @@ describe('event-validation', () => {
     });
   });
 
+  it('should throw an error if event is stale', async () => {
+    const staleEvent = {
+      timestamp: timestamp.seconds - 5000,
+      event_timestamp_ms: timestamp.milliseconds - 5000,
+      event_name: TriggerEventsEnum.TICF_ACCOUNT_INTERVENTION,
+      event_id: '123',
+      component_id: 'TICF_CRI',
+      user: { user_id: 'urn:fdc:gov.uk:2022:USER_ONE' },
+      extensions: {
+        intervention: {
+          intervention_code: '01' as InterventionCodeEnum1,
+          intervention_reason: 'something',
+          originating_component_id: 'CMS',
+          originator_reference_id: '1234567',
+          requester_id: '1234567',
+        },
+      },
+    };
+
+    await expect(async () => {
+      await validateEventIsNotStale(
+        EventsEnum.FRAUD_SUSPEND_ACCOUNT,
+        staleEvent,
+        {
+          blocked: false,
+          suspended: false,
+          resetPassword: false,
+          reproveIdentity: false,
+        },
+        dynamoDBResult,
+      );
+    }).rejects.toThrow(new ValidationError('Event received predates last applied event for this user.'));
+    expect(addMetric).toHaveBeenCalledWith(MetricNames.INTERVENTION_EVENT_STALE);
+    expect(sendAuditEvent).toHaveBeenCalledWith('AIS_EVENT_IGNORED_STALE', 'FRAUD_SUSPEND_ACCOUNT', staleEvent, {
+      stateResult: { blocked: false, reproveIdentity: false, resetPassword: false, suspended: false },
+      interventionName: 'AIS_NO_INTERVENTION',
+      nextAllowableInterventions: ['01', '03', '04', '05', '06'],
+    });
+  });
+
   it('should not throw if event is not stale', async () => {
     const nonStaleEvent = {
       timestamp: timestamp.seconds,
@@ -361,3 +402,16 @@ describe('event-validation', () => {
     expect(addMetric).toHaveBeenCalledWith(MetricNames.IDENTITY_NOT_SUFFICIENTLY_PROVED);
   });
 });
+
+describe('attemptToParseJson', () => {
+  it('should parse valid JSON', () => {
+    const jsonString = '{"key": "value"}';
+    const result = attemptToParseJson(jsonString);
+    expect(result).toEqual({ key: 'value' });
+  });
+
+  it('should return null for invalid JSON', () => {
+    const jsonString = '{"key": "value"';
+    expect(() => attemptToParseJson(jsonString)).toThrow('record body could not be parsed to valid JSON.');
+  });
+});

stryker.config.json

@@ -9,5 +9,8 @@
   ],
   "testRunner": "vitest",
   "testRunner_comment": "Take a look at https://stryker-mutator.io/docs/stryker-js/vitest-runner for information about the vitest plugin.",
-  "coverageAnalysis": "perTest"
-}
+  "coverageAnalysis": "perTest",
+  "ignorePatterns": [
+    "**/contract-testing/**"
+  ]
+}

vitest.config.ts

@@ -9,7 +9,7 @@ export default defineConfig({
       reporter: ['text', 'lcov'],
       reportsDirectory: './coverage',
     },
-    exclude: ['**/node_modules/**', 'src/contract-testing/**'],
+    exclude: ['**/node_modules/**', 'src/contract-testing/**', '.stryker-tmp/**'],
     env: {
       CLOUDWATCH_METRICS_NAMESPACE: 'test_namespace',
       METRIC_SERVICE_NAME: 'test',