fix: handle debug with api triggers

Author: cristipufu

pyproject.toml

@@ -1,12 +1,11 @@
 [project]
 name = "uipath-dev"
-version = "0.0.11"
+version = "0.0.12"
 description = "UiPath Developer Console"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"
 dependencies = [
-  "uipath-core>=0.0.9, <0.1.0",
-  "uipath-runtime>=0.1.3, <0.2.0",
+  "uipath-runtime==0.2.0.dev1000410126",
   "textual>=6.7.1, <7.0.0",
   "pyperclip>=1.11.0, <2.0.0",
 ]
@@ -113,3 +112,6 @@ name = "testpypi"
 url = "https://test.pypi.org/simple/"
 publish-url = "https://test.pypi.org/legacy/"
 explicit = true
+
+[tool.uv.sources]
+uipath-runtime = { index = "testpypi" }

src/uipath/dev/__init__.py

@@ -145,7 +145,12 @@ async def handle_chat_input(self, event: Input.Submitted) -> None:
                 return
 
             if details_panel.current_run.status == "suspended":
-                details_panel.current_run.resume_data = {"value": user_text}
+                resume_input: dict[str, Any] | str = {}
+                try:
+                    resume_input = json.loads(user_text)
+                except json.JSONDecodeError:
+                    resume_input = user_text
+                details_panel.current_run.resume_data = resume_input
             else:
                 msg = get_user_message(user_text)
                 msg_ev = get_user_message_event(user_text)

src/uipath/dev/models/execution.py

@@ -36,7 +36,7 @@ def __init__(
         self.entrypoint = entrypoint
         self.input_data = input_data
         self.mode = mode
-        self.resume_data: dict[str, Any] | None = None
+        self.resume_data: dict[str, Any] | str | None = None
         self.output_data: dict[str, Any] | str | None = None
         self.start_time = datetime.now()
         self.end_time: datetime | None = None
@@ -98,4 +98,6 @@ def messages(self) -> list[UiPathConversationMessage]:
 
     def add_event(self, event: Any) -> UiPathConversationMessage | None:
         """Add a conversation event to the run's chat aggregator."""
+        if event is None:
+            return None
         return self.chat_events.add(cast(UiPathConversationMessageEvent, event))

src/uipath/dev/services/debug_bridge.py

@@ -7,6 +7,7 @@
 from uipath.runtime.debug import UiPathBreakpointResult, UiPathDebugQuitError
 from uipath.runtime.events import UiPathRuntimeStateEvent
 from uipath.runtime.result import UiPathRuntimeResult
+from uipath.runtime.resumable import UiPathResumeTriggerType
 
 logger = logging.getLogger(__name__)
 
@@ -60,6 +61,29 @@ async def emit_breakpoint_hit(
         if self.on_breakpoint_hit:
             self.on_breakpoint_hit(breakpoint_result)
 
+    async def emit_execution_suspended(
+        self, runtime_result: UiPathRuntimeResult
+    ) -> None:
+        """Notify debugger that execution is suspended."""
+        logger.debug("Execution suspended")
+        if runtime_result.trigger is None:
+            return
+
+        if runtime_result.trigger.trigger_type == UiPathResumeTriggerType.API:
+            if self.on_breakpoint_hit:
+                self.on_breakpoint_hit(
+                    UiPathBreakpointResult(
+                        breakpoint_node="<suspended>",
+                        breakpoint_type="before",
+                        current_state=runtime_result.output,
+                        next_nodes=[],
+                    )
+                )
+
+    async def emit_execution_resumed(self, resume_data: Any) -> None:
+        """Notify debugger that execution resumed."""
+        logger.debug("Execution resumed")
+
     async def emit_execution_completed(
         self, runtime_result: UiPathRuntimeResult
     ) -> None:

src/uipath/dev/services/run_service.py

@@ -86,10 +86,7 @@ def get_run(self, run_id: str) -> ExecutionRun | None:
         return self.runs.get(run_id)
 
     async def execute(self, run: ExecutionRun) -> None:
-        """Execute or resume a run.
-
-        This is the extracted version of the old `_execute_runtime` method.
-        """
+        """Execute or resume a run."""
         new_runtime: UiPathRuntimeProtocol | None = None
         try:
             execution_input: dict[str, Any] | None = {}
@@ -179,14 +176,15 @@ async def execute(self, run: ExecutionRun) -> None:
                 ):
                     run.status = "suspended"
                 else:
-                    if result.output is None:
-                        run.output_data = {}
-                    elif isinstance(result.output, BaseModel):
-                        run.output_data = result.output.model_dump()
-                    else:
-                        run.output_data = result.output
                     run.status = "completed"
 
+                if result.output is None:
+                    run.output_data = {}
+                elif isinstance(result.output, BaseModel):
+                    run.output_data = result.output.model_dump()
+                else:
+                    run.output_data = result.output
+
                 if run.output_data:
                     self._add_info_log(run, f"Execution result: {run.output_data}")
 

src/uipath/dev/ui/panels/run_details_panel.py

@@ -436,6 +436,7 @@ def add_chat_message(
 
         if not self.current_run or chat_msg.run_id != self.current_run.id:
             return
+
         self._chat_panel.add_chat_message(chat_msg)
 
     def add_trace(self, trace_msg: TraceMessage):