feat(converter): usage of log_cisu_to_rs_converted_messages_ids

Author: EliNoden

converter/converter/cisu/resources_info/resources_info_cisu_converter.py

@@ -9,6 +9,7 @@
 from converter.cisu.resources_info.resources_info_cisu_helper import (
     enrich_rs_ri_with_rs_srs,
     get_latest_state,
+    log_cisu_to_rs_converted_messages_ids,
 )
 from converter.repositories.message_repository import (
     get_last_rc_ri_by_case_id,
@@ -175,6 +176,9 @@ def from_cisu_to_rs(cls, edxl_json: Dict[str, Any]) -> List[Dict[str, Any]]:
                 converted_messages.append(
                     cls._build_rs_sr_from_resource(edxl_json, resource, case_id)
                 )
+            log_cisu_to_rs_converted_messages_ids(
+                edxl_json, converted_messages[0], converted_messages[1:]
+            )
             return converted_messages
 
         # Known caseId — compare resources and emit only what changed
@@ -191,6 +195,7 @@ def from_cisu_to_rs(cls, edxl_json: Dict[str, Any]) -> List[Dict[str, Any]]:
         ]
 
         messages: List[Dict[str, Any]] = []
+        rs_ri = None
 
         if engaged_resources_updated:
             logger.info(
@@ -200,17 +205,20 @@ def from_cisu_to_rs(cls, edxl_json: Dict[str, Any]) -> List[Dict[str, Any]]:
             rs_ri = cls._build_rs_ri_from_cisu(edxl_json)
             messages.append(rs_ri)
 
+        rs_sr_messages: List[Dict[str, Any]] = []
         for resource in modified_status_resources:
             logger.info(
                 "Resource %s has a modified status — adding RS-SR to output.",
                 resource.get("resourceId"),
             )
             rs_sr = cls._build_rs_sr_from_resource(edxl_json, resource, case_id)
             messages.append(rs_sr)
+            rs_sr_messages.append(rs_sr)
 
         if not messages:
             logger.info("No resource changes detected for caseId %s.", case_id)
 
+        log_cisu_to_rs_converted_messages_ids(edxl_json, rs_ri, rs_sr_messages)
         return messages
 
     @classmethod