update logic

Author: nhsdevws

lambdas/id_sync/src/record_processor.py

@@ -6,6 +6,7 @@
 import json
 from typing import Optional
 
+
 def process_record(event_record: AwsLambdaSqsEventRecord):
     record = AwsLambdaSqsEventRecord(event_record) if isinstance(event_record, dict) else event_record
     logger.info("Processing record: %s", record)
@@ -14,7 +15,37 @@ def process_record(event_record: AwsLambdaSqsEventRecord):
 
     exists = check_records_exist(id)
 
-    return f"hello world {record}"
+    if exists:
+        # get patient details from PDS
+        patient_details = get_pds_patient_details(id)
+
+        patient_details_id = patient_details.get("id")
+
+        # if patient NHS != id, update patient index of vax events to new number
+        if patient_details_id != id:
+            return update_patient_index(id, patient_details_id)
+        else:
+            return {"status": "success", "message": "No update required"}
+    else:
+        return {"status": "error", "message": f"No records found for ID: {id}"}
+
+
+def check_records_exist(id: str) -> bool:
+    # TODO: Implement logic to check if records exist in the database
+    logger.info(f"TODO Check if records exist for {id}")
+    return False
+
+
+def get_pds_patient_details(id: str) -> dict:
+    # TODO: Implement logic to retrieve patient details from PDS
+    logger.info(f"TODO Get patient details for {id}")
+    return {"id": id, "name": "Mr Man"}
+
+
+def update_patient_index(old_id: str, new_id: str):
+    # TODO: Implement logic to update patient index in Redis or other data store
+    logger.info(f"TODO Update patient index from {old_id} to {new_id}")
+    return {"status": "success", "message": f"Updated patient idx from {old_id} to {new_id}", "TODO": "Implement logic"}
 
 
 def get_id(event_body) -> Optional[str]:
@@ -26,34 +57,8 @@ def get_id(event_body) -> Optional[str]:
         else:
             data = event_body
         # Navigate through the nested structure
-        entries = data.get("entry", [])
-        if not entries:
-            logger.warning("No entries found in bundle")
-            return None
-
-        # Get the first entry's resource
-        first_entry = entries[0]
-        resource = first_entry.get("resource", {})
-        parameters = resource.get("parameter", [])
-
-        # Find the "additional-context" parameter
-        for param in parameters:
-            if param.get("name") == "additional-context":
-                parts = param.get("part", [])
-
-                # Find the "subject" part within additional-context
-                for part in parts:
-                    if part.get("name") == "subject":
-                        value_ref = part.get("valueReference", {})
-                        identifier = value_ref.get("identifier", {})
-                        subject_id = identifier.get("value")
-
-                        if subject_id:
-                            logger.info("Found subject identifier: %s", subject_id)
-                            return subject_id
-
-        logger.warning("Subject identifier not found in notification event")
-        return None
+        subject = data.get("subject")
+        return subject
 
     except (json.JSONDecodeError, KeyError, AttributeError) as e:
         logger.error("Error extracting subject identifier: %s", e)