test insert

Author: nhsdevws

lambdas/id_sync/src/ieds_db_operations.py

@@ -3,6 +3,7 @@
 from common.aws_dynamodb import get_dynamodb_table
 from common.clients import logger
 from exceptions.id_sync_exception import IdSyncException
+import json
 
 ieds_table = None
 
@@ -65,3 +66,22 @@ def ieds_update_patient_id(old_id: str, new_id: str) -> dict:
             exception=e
         )
         raise e
+
+
+def test_ieds_insert_patient(patient_id: str) -> dict:  # NOSONAR
+    """Test function for inserting patient ID."""
+    logger.info("insert to db...")
+    # write the patient id to table
+    result = get_ieds_table().put_item(Item={
+                    "PK": f"Patient#{patient_id}",
+                    "PatientPK": f"Patient#{patient_id}",
+                    "PatientSK": f"Patient#{patient_id}",
+                    "Resource": '{"resourceType": "Immunization", "contained": [{"resourceType": "Practitioner", "id": "Pract1", "name": [{"family": "iucds", "given": ["Russell"]}]}, {"resourceType": "Patient", "id": "Pat1", "identifier": [{"system": "https://fhir.nhs.uk/Id/nhs-number", "value": "9726629101"}], "name": [{"family": "VAREY", "given": ["DIANA"]}], "gender": "unknown", "birthDate": "2021-10-24", "address": [{"postalCode": "DN15 8EZ"}]}], "extension": [{"url": "https://fhir.hl7.org.uk/StructureDefinition/Extension-UKCore-VaccinationProcedure", "valueCodeableConcept": {"coding": [{"system": "http://snomed.info/sct", "code": "1303503001", "display": "Administration of vaccine product containing only Human orthopneumovirus antigen (procedure)"}]}}], "identifier": [{"system": "https://www.ieds.england.nhs.uk/", "value": "a7e06f66-339f-4b81-b2f6-016b88bfc422"}], "status": "completed", "vaccineCode": {"coding": [{"system": "http://snomed.info/sct", "code": "42605811000001100", "display": "Abrysvo vaccine powder and solvent for solution for injection 0.5ml vials (Pfizer Ltd) (product)"}]}, "patient": {"reference": "#Pat1"}, "occurrenceDateTime": "2025-05-27T14:53:26.271+00:00", "recorded": "2025-07-10T11:25:56.000+00:00", "primarySource": true, "manufacturer": {"display": "Pfizer"}, "location": {"identifier": {"value": "X8E5B", "system": "https://fhir.nhs.uk/Id/ods-organization-code"}}, "lotNumber": "RSVAPITEST", "expirationDate": "2025-06-01", "site": {"coding": [{"system": "http://snomed.info/sct", "code": "368208006", "display": "Left upper arm structure (body structure)"}]}, "route": {"coding": [{"system": "http://snomed.info/sct", "code": "78421000", "display": "Intramuscular route (qualifier value)"}]}, "doseQuantity": {"value": 0.5, "unit": "milliliter", "system": "http://unitsofmeasure.org", "code": "ml"}, "performer": [{"actor": {"reference": "#Pract1"}}, {"actor": {"type": "Organization", "display": "UNIVERSITY HOSPITAL OF WALES", "identifier": {"system": "https://fhir.nhs.uk/Id/ods-organization-code", "value": "B0C4P"}}}], "reasonCode": [{"coding": [{"code": "443684005", "display": "Disease outbreak (event)", "system": "http://snomed.info/sct"}]}], "protocolApplied": [{"targetDisease": [{"coding": [{"system": "http://snomed.info/sct", "code": "55735004", "display": "Disease caused by severe acute respiratory syndrome coronavirus 2 (disorder)"}]}], "doseNumberPositiveInt": 11}], "id": "088414ed-7d3d-40a5-9968-b3d2b9a266b2"}',
+                    "IdentifierPK": "https://www.ieds.england.nhs.uk/#a7e06f66-339f-4b81-b2f6-016b88bfc422",
+                    "Operation": "CREATE",
+                    "Version": "1",
+                    "SupplierSystem": "RAVS",
+                })
+
+    logger.info(f"Test result: {result}")
+    return result

lambdas/id_sync/src/record_processor.py

@@ -4,7 +4,7 @@
 from common.clients import logger
 from typing import Optional
 from pds_details import pds_get_patient_id
-from ieds_db_operations import ieds_check_exist, ieds_update_patient_id
+from ieds_db_operations import ieds_check_exist, ieds_update_patient_id, test_ieds_insert_patient
 import json
 import ast
 
@@ -47,6 +47,7 @@ def process_nhs_number(nhs_number: str) -> Optional[str]:
         # if patient NHS != id, update patient index of vax events to new number
         if patient_details_id != nhs_number and patient_details_id:
             logger.info(f"process_nhs_number. Update patient ID from {nhs_number} to {patient_details_id}")
+            test_ieds_insert_patient(patient_details_id)  # NOSONAR
             if ieds_check_exist(patient_details_id):
                 response = ieds_update_patient_id(patient_details_id, nhs_number)
             else:

lambdas/id_sync/tests/test_record_processor.py

@@ -23,6 +23,10 @@ def setUp(self):
         self.ieds_update_patient_id_patcher = patch('record_processor.ieds_update_patient_id')
         self.mock_ieds_update_patient_id = self.ieds_update_patient_id_patcher.start()
 
+        # mock out test_ieds_insert_patient
+        self.ieds_test_insert_patcher = patch('record_processor.test_ieds_insert_patient')  # TODO  TEST code
+        self.mock_ieds_test_insert = self.ieds_test_insert_patcher.start()
+
     def tearDown(self):
         patch.stopall()
 

terraform/id_sync_lambda.tf

@@ -297,7 +297,8 @@ resource "aws_lambda_function" "id_sync_lambda" {
     variables = {
       REDIS_HOST               = data.aws_elasticache_cluster.existing_redis.cache_nodes[0].address
       REDIS_PORT               = data.aws_elasticache_cluster.existing_redis.cache_nodes[0].port
-      IEDS_TABLE_NAME      = "imms-int-imms-events" # TODO test only aws_dynamodb_table.events-dynamodb-table.name
+    #   IEDS_TABLE_NAME      = "imms-int-imms-events" # TODO test only aws_dynamodb_table.events-dynamodb-table.name
+      IEDS_TABLE_NAME      = aws_dynamodb_table.events-dynamodb-table.name
       PDS_ENV              = var.pds_environment
       SPLUNK_FIREHOSE_NAME = module.splunk.firehose_stream_name
     }