fix: enrich trigger response

Author: GabrielVasilescu04

packages/uipath-platform/src/uipath/platform/resume_triggers/_protocol.py

@@ -23,6 +23,7 @@
 from uipath.platform.action_center import Task
 from uipath.platform.action_center.tasks import TaskStatus
 from uipath.platform.common._config import UiPathConfig
+from uipath.platform.connections import EventArguments
 from uipath.platform.common.interrupt_models import (
     CreateBatchTransform,
     CreateDeepRag,
@@ -406,9 +407,13 @@ async def read_trigger(self, trigger: UiPathResumeTrigger) -> Any | None:
             case UiPathResumeTriggerType.INBOX:
                 if trigger.integration_resume and trigger.integration_resume.inbox_id:
                     try:
-                        return await uipath.jobs.retrieve_inbox_payload_async(
+                        inbox_payload = await uipath.jobs.retrieve_inbox_payload_async(
                             trigger.integration_resume.inbox_id
                         )
+                        event_args = EventArguments.model_validate(inbox_payload)
+                        return await uipath.connections.retrieve_event_payload_async(
+                            event_args
+                        )
                     except Exception as e:
                         raise UiPathFaultedTriggerError(
                             ErrorCategory.SYSTEM,

packages/uipath-platform/tests/services/test_hitl.py

@@ -1,3 +1,4 @@
+import json
 import uuid
 from typing import Any
 from unittest.mock import AsyncMock, patch
@@ -518,18 +519,36 @@ async def test_read_inbox_trigger(
         base_url: str,
         setup_test_env: None,
     ) -> None:
-        """Test reading an Inbox trigger fetches the payload via GetPayload.
-
-        Orchestrator returns the stored payload directly (no envelope), so the
-        inbox reader must surface the response body as-is.
+        """Test reading an Inbox trigger fetches the IS metadata via GetPayload
+        and then enriches it via /elements_/v1/events/{processedEventId}.
         """
         inbox_id = str(uuid.uuid4())
-        payload_data = {"text": "hello from slack", "channel": "alerts"}
+        processed_event_id = "v2::pp::1777041494382::334071::e374ecd5d0f73c21"
+        inbox_metadata = {
+            "UiPathEventConnector": "uipath-slack",
+            "UiPathEvent": "NEW_MESSAGE",
+            "UiPathEventObjectType": "Message",
+            "UiPathEventObjectId": "C123:1777041494.382",
+            "UiPathAdditionalEventData": json.dumps(
+                {"processedEventId": processed_event_id}
+            ),
+        }
+        enriched_event = {
+            "channel": "alerts",
+            "user": "U456",
+            "text": "hello from slack",
+            "ts": "1777041494.382",
+        }
 
         httpx_mock.add_response(
             url=f"{base_url}/orchestrator_/api/JobTriggers/GetPayload/{inbox_id}",
             status_code=200,
-            json=payload_data,
+            json=inbox_metadata,
+        )
+        httpx_mock.add_response(
+            url=f"{base_url}/elements_/v1/events/{processed_event_id}",
+            status_code=200,
+            json=enriched_event,
         )
 
         resume_trigger = UiPathResumeTrigger(
@@ -545,7 +564,7 @@ async def test_read_inbox_trigger(
 
         reader = UiPathResumeTriggerReader()
         result = await reader.read_trigger(resume_trigger)
-        assert result == payload_data
+        assert result == enriched_event
 
     @pytest.mark.anyio
     async def test_read_inbox_trigger_failure(

packages/uipath-platform/uv.lock

@@ -1,6 +1,6 @@
 [project]
 name = "uipath"
-version = "2.10.56"
+version = "2.10.57"
 description = "Python SDK and CLI for UiPath Platform, enabling programmatic interaction with automation services, process management, and deployment tools."
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"