test: check records are sent to bs select and is extracted is updated… (#976)

* test: check records are sent to bs select and is extracted is updated to 1

* test: fix flag name IsExtracted

Author: abhinavqtnhs

tests/playwright-tests/src/api/dataService/cohortDistributionService.ts

@@ -0,0 +1,11 @@
+import { APIRequestContext } from '@playwright/test';
+import * as apiClient from '../apiClient';
+import { config } from '../../config/env';
+import { ApiResponse } from '../core/types';
+
+
+export const getRecordsFromCohortDistributionService = (
+  request: APIRequestContext
+): Promise<ApiResponse> => {
+  return apiClient.get(request, `${config.endpointCohortDistributionDataService}api/${config.cohortDistributionService}`);
+};

tests/playwright-tests/src/tests/e2e/epic3-highpriority-tests/epic3-high-priority-testsuite.spec.ts

@@ -1,8 +1,10 @@
 import { getRecordsFromExceptionService } from '../../../api/dataService/exceptionService';
+import { getRecordsFromBsSelectRetrieveCohort } from '../../../api/distributionService/bsSelectService';
 import { composeValidators, expectStatus, validateResponseByStatus } from '../../../api/responseValidators';
-import { test, testWithAmended } from '../../fixtures/test-fixtures';
+import { expect, test, testWithAmended } from '../../fixtures/test-fixtures';
 import { TestHooks } from '../../hooks/test-hooks';
 import { processFileViaStorage, validateSqlDatabaseFromAPI } from "../../steps/steps";
+import { getRecordsFromCohortDistributionService } from '../../../api/dataService/cohortDistributionService';
 
 
 test.describe('@regression @e2e @epic3-high-priority Tests', () => {
@@ -65,5 +67,28 @@ test.describe('@regression @e2e @epic3-high-priority Tests', () => {
 
     });
   });
+
+  test('@DTOSS-5560-01 - BS Select - Records are received where IsExtracted is set to 0', {
+    annotation: {
+      type: 'Requirement',
+      description: 'Tests - https://nhsd-jira.digital.nhs.uk/browse/DTOSS-3650',
+    },
+  }, async ({ request, testData }) => {
+
+    await test.step('Then processed ADD participant should be received using bs select get request where IsExtracted = 0', async () => {
+      await validateSqlDatabaseFromAPI(request, testData.checkInDatabase);
+      const ExpectedRowCount = 1;
+
+      const response = await getRecordsFromBsSelectRetrieveCohort(request, { rowCount: 10, screeningServiceId: 1 });
+      expect(response.data.length).toBe(ExpectedRowCount);
+
+    });
+
+    await test.step('And IsExtracted flag is set to 1', async () => {
+      const response = await getRecordsFromCohortDistributionService(request);
+      const firstRecord = response.data.find(() => true);
+      expect(firstRecord?.IsExtracted).toBe(1);
+    });
+  });
 });
 

tests/playwright-tests/src/tests/e2e/testFiles/@DTOSS-5560-01/ADD1_-_CAAS_BREAST_SCREENING_COHORT.json

@@ -0,0 +1,56 @@
+{
+  "validations": [
+    {
+      "validations": {
+        "apiEndpoint": "api/CohortDistributionDataService",
+        "NHSNumber": 9995518112,
+        "IsExtracted": 0
+      }
+    }
+  ],
+  "inputParticipantRecord": [
+    {
+      "record_type": "ADD",
+      "change_time_stamp": null,
+      "serial_change_number": 1,
+      "nhs_number": 9995518112,
+      "superseded_by_nhs_number": null,
+      "primary_care_provider": "F83043",
+      "primary_care_effective_from_date": "20130319",
+      "current_posting": "CH",
+      "current_posting_effective_from_date": "20130319",
+      "name_prefix": "A.ML",
+      "given_name": "NewTest1Updated",
+      "other_given_name": "Test",
+      "family_name": "Adani1",
+      "previous_family_name": "Test2",
+      "date_of_birth": "19700101",
+      "gender": 1,
+      "address_line_1": "247 SpaightSpaightSpTeeeeeeest Road",
+      "address_line_2": "Eastbourne",
+      "address_line_3": "Test",
+      "address_line_4": "Chelmsford",
+      "address_line_5": "United Kingdom",
+      "postcode": "AB43 8FJ",
+      "paf_key": "Z3S4Q5X9",
+      "address_effective_from_date": null,
+      "reason_for_removal": null,
+      "reason_for_removal_effective_from_date": null,
+      "date_of_death": null,
+      "death_status": null,
+      "home_telephone_number": "01619999999",
+      "home_telephone_effective_from_date": "20240501",
+      "mobile_telephone_number": "07888888888",
+      "mobile_telephone_effective_from_date": "20240501",
+      "email_address": "[email protected]",
+      "email_address_effective_from_date": null,
+      "preferred_language": "en",
+      "is_interpreter_required": false,
+      "invalid_flag": false,
+      "eligibility": true
+    }
+  ],
+  "nhsNumbers": [
+    "9995518112"
+  ]
+}