WIP

Author: nhsdevws

delta_backend/src/delta.py

@@ -75,15 +75,15 @@ def handler(event, context):
                     logger.info(f"Record from DPS skipped for {imms_id}")
                     return {"statusCode": 200, "body": f"Record from DPS skipped for {imms_id}"}
             else:
-                operation = OperationName.DELETE
+                operation = OperationName.DELETE_PHYSICAL
                 new_image = record["dynamodb"]["Keys"]
                 logger.info(f"Record to delta:{new_image}")
                 imms_id = new_image["PK"]["S"].split("#")[1]
                 response = delta_table.put_item(
                     Item={
                         "PK": str(uuid.uuid4()),
                         "ImmsID": imms_id,
-                        "Operation": OperationName.DELETE,
+                        "Operation": OperationName.DELETE_PHYSICAL,
                         "VaccineType": "default",
                         "SupplierSystem": "default",
                         "DateTimeStamp": approximate_creation_time.isoformat(),

delta_backend/tests/test_convert_to_flat_json.py

@@ -183,8 +183,8 @@ def test_handler_imms_convert_to_flat_json(self):
         """Test that the Imms field contains the correct flat JSON data for CREATE, UPDATE, and DELETE operations."""
         expected_action_flags = [
             {"Operation": OperationName.CREATE, "EXPECTED_ACTION_FLAG": ActionFlag.CREATE},
-            # {"Operation": OperationName.UPDATE, "EXPECTED_ACTION_FLAG": ActionFlag.UPDATE},
-            # {"Operation": OperationName.DELETE, "EXPECTED_ACTION_FLAG": ActionFlag..DELETE},
+            {"Operation": OperationName.UPDATE, "EXPECTED_ACTION_FLAG": ActionFlag.UPDATE},
+            {"Operation": OperationName.DELETE_PHYSICAL, "EXPECTED_ACTION_FLAG": ActionFlag.DELETE_PHYSICAL},
         ]
 
         for test_case in expected_action_flags: