Skip to content

Commit f058ff2

Browse files
committed
feat(converter): usage of log_cisu_to_rs_converted_messages_ids
1 parent 98523b4 commit f058ff2

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

converter/converter/cisu/resources_info/resources_info_cisu_converter.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
from converter.cisu.resources_info.resources_info_cisu_helper import (
1010
enrich_rs_ri_with_rs_srs,
1111
get_latest_state,
12+
log_cisu_to_rs_converted_messages_ids,
1213
)
1314
from converter.repositories.message_repository import (
1415
get_last_rc_ri_by_case_id,
@@ -175,6 +176,7 @@ def from_cisu_to_rs(cls, edxl_json: Dict[str, Any]) -> List[Dict[str, Any]]:
175176
converted_messages.append(
176177
cls._build_rs_sr_from_resource(edxl_json, resource, case_id)
177178
)
179+
log_cisu_to_rs_converted_messages_ids(edxl_json, None, converted_messages)
178180
return converted_messages
179181

180182
# Known caseId — compare resources and emit only what changed
@@ -211,6 +213,9 @@ def from_cisu_to_rs(cls, edxl_json: Dict[str, Any]) -> List[Dict[str, Any]]:
211213
if not messages:
212214
logger.info("No resource changes detected for caseId %s.", case_id)
213215

216+
log_cisu_to_rs_converted_messages_ids(
217+
edxl_json, existing_message.payload, messages
218+
)
214219
return messages
215220

216221
@classmethod

0 commit comments

Comments
 (0)