fix: enrich trigger response

Author: GabrielVasilescu04

packages/uipath-core/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-core"
-version = "0.5.13"
+version = "0.5.14"
 description = "UiPath Core abstractions"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"

packages/uipath-core/uv.lock

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-platform"
-version = "0.1.38"
+version = "0.1.39"
 description = "HTTP client library for programmatic access to UiPath Platform"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"

packages/uipath-platform/pyproject.toml

@@ -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,
@@ -947,13 +952,15 @@ async def _handle_inbox_trigger(
         connections = await uipath.connections.list_async(
             name=value.connection_name,
             folder_path=value.connection_folder_path,
+            connector_key=value.connector,
         )
         connection = next(
             (c for c in connections if c.name == value.connection_name), None
         )
         if connection is None:
             raise Exception(
-                f"No connection named '{value.connection_name}' found"
+                f"No connection named '{value.connection_name}' "
+                f"for connector '{value.connector}' found"
                 + (
                     f" in folder '{value.connection_folder_path}'"
                     if value.connection_folder_path

packages/uipath-platform/src/uipath/platform/resume_triggers/_protocol.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(
@@ -1490,7 +1509,7 @@ async def test_create_resume_trigger_wait_integration_event(
         assert isinstance(resume_trigger.integration_resume.inbox_id, str)
         uuid.UUID(resume_trigger.integration_resume.inbox_id)
         mock_list_async.assert_called_once_with(
-            name="Slack-Alerts", folder_path="Shared"
+            name="Slack-Alerts", folder_path="Shared", connector_key="slack"
         )
 
     @pytest.mark.anyio
@@ -1522,7 +1541,7 @@ async def test_create_resume_trigger_wait_integration_event_optional_fields_omit
         assert resume_trigger.integration_resume.filter_expression is None
         assert resume_trigger.integration_resume.parameters is None
         mock_list_async.assert_called_once_with(
-            name="Teams-Default", folder_path=None
+            name="Teams-Default", folder_path=None, connector_key="teams"
         )
 
     @pytest.mark.anyio

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

@@ -1,6 +1,6 @@
 [project]
 name = "uipath"
-version = "2.10.56"
+version = "2.10.59"
 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"