debug

Author: nhsdevws

lambdas/id_sync/src/record_processor.py

@@ -12,8 +12,9 @@
 def process_record(event_record):
 
     logger.info("process_record. Processing record: %s", event_record)
+    logger.info("process_record...1")
     body_text = event_record.get('body', '')
-
+    logger.info("process_record. Body text: %s", body_text)
     # convert body to json
     if isinstance(body_text, str):
         try:
@@ -28,7 +29,9 @@ def process_record(event_record):
                 return {"status": "error", "message": "Invalid body format"}
     else:
         body = body_text
+    logger.info("process_record. Parsed body: %s", body)
     nhs_number = body.get("subject")
+    logger.info("process_record. NHS number: %s", nhs_number)
     if nhs_number:
         return process_nhs_number(nhs_number)
     else:

lambdas/id_sync/tests/test_id_sync.py

@@ -25,18 +25,18 @@ def setUp(self):
         self.single_sqs_event = {
             'Records': [
                 {
-                    'body': '{"Records":[{"source":"aws:sqs","data":"test-data"}]}'
+                    'body': '{"source":"aws:sqs","data":"test-data"}'
                 }
             ]
         }
 
         self.multi_sqs_event = {
             'Records': [
                 {
-                    'body': ('{"Records":[{"source":"aws:sqs"],"data":"a"}'),
+                    'body': ('{"source":"aws:sqs","data":"a"}'),
                 },
                 {
-                    'body': ('{"Records":[{"source":"aws:sqs"],"data":"b"}'),
+                    'body': ('{"source":"aws:sqs","data":"b"}'),
                 }
             ]
         }