@@ -198,8 +198,8 @@ def test_process_sqs_message_success(self, mock_datetime):
198198 mesh_message .read .assert_called_once ()
199199
200200 document_store .store_document .assert_called_once_with (
201- sender_id = 'TEST_SENDER ' ,
202- message_reference = 'ref_001 ' ,
201+ sender_id = 'TEST-SENDER ' ,
202+ message_reference = 'ref-001 ' ,
203203 mesh_message_id = 'test-message-123' ,
204204 content = create_fhir_content ()
205205 )
@@ -254,6 +254,7 @@ def test_process_sqs_message_invalid_fhir_content(self, mock_datetime):
254254 log = log ,
255255 mesh_client = config .mesh_client ,
256256 download_metric = config .download_metric ,
257+ duplicate_download_metric = config .duplicate_download_metric ,
257258 document_store = document_store ,
258259 event_publisher = event_publisher
259260 )
@@ -266,7 +267,7 @@ def test_process_sqs_message_invalid_fhir_content(self, mock_datetime):
266267
267268 processor .process_sqs_message (sqs_record )
268269
269- config .mesh_client .retrieve_message .assert_called_once_with ('test_message_123 ' )
270+ config .mesh_client .retrieve_message .assert_called_once_with ('test-message-123 ' )
270271
271272 mesh_message .read .assert_called_once ()
272273
@@ -299,9 +300,9 @@ def test_process_sqs_message_invalid_fhir_content(self, mock_datetime):
299300
300301 # Verify CloudEvent data payload
301302 event_data = published_event ['data' ]
302- assert event_data ['senderId' ] == 'TEST_SENDER '
303- assert event_data ['messageReference' ] == 'ref_001 '
304- assert event_data ['meshMessageId' ] == 'test_message_123 '
303+ assert event_data ['senderId' ] == 'TEST-SENDER '
304+ assert event_data ['messageReference' ] == 'ref-001 '
305+ assert event_data ['meshMessageId' ] == 'test-message-123 '
305306 assert event_data ['failureCode' ] == 'DL_CLIV_005'
306307 assert set (event_data .keys ()) == {'senderId' , 'messageReference' , 'meshMessageId' , 'failureCode' }
307308
0 commit comments