diff --git a/queue_services/entity-emailer/src/entity_emailer/message_tracker/tracker.py b/queue_services/entity-emailer/src/entity_emailer/message_tracker/tracker.py index 4d12adb17c..f79cd0d74d 100644 --- a/queue_services/entity-emailer/src/entity_emailer/message_tracker/tracker.py +++ b/queue_services/entity-emailer/src/entity_emailer/message_tracker/tracker.py @@ -98,7 +98,7 @@ def get_message_context_properties(queue_msg: nats.aio.client.Msg): return create_message_context_properties(etype, message_id, None, None, False) if etype in ('dissolution', 'registration', 'changeOfRegistration', - 'restoration', 'specialResolution', 'correction') \ + 'restoration', 'specialResolution', 'correction', 'amalgamationApplication') \ and (option := email.get('option', None)) \ and (filing_id := email.get('filingId', None)): # option contains current status of filing - PAID or COMPLETED diff --git a/queue_services/entity-emailer/tests/unit/test_tracker.py b/queue_services/entity-emailer/tests/unit/test_tracker.py index f2d377d668..1e8fefd079 100644 --- a/queue_services/entity-emailer/tests/unit/test_tracker.py +++ b/queue_services/entity-emailer/tests/unit/test_tracker.py @@ -305,6 +305,22 @@ 'option': 'COMPLETED', 'filingId': '111222335' } + }), + ('amalgamationApplication_PAID_111222334', + { + 'email': { + 'type': 'amalgamationApplication', + 'option': 'PAID', + 'filingId': '111222334' + } + }), + ('amalgamationApplication_COMPLETED_111222335', + { + 'email': { + 'type': 'amalgamationApplication', + 'option': 'COMPLETED', + 'filingId': '111222335' + } }) ] )