feat: expose terminal stdin in threads for traceability

Author: Dimillian

src/features/app/hooks/useAppServerEvents.ts

@@ -41,6 +41,12 @@ type AppServerEventHandlers = {
   onReasoningSummaryDelta?: (workspaceId: string, threadId: string, itemId: string, delta: string) => void;
   onReasoningTextDelta?: (workspaceId: string, threadId: string, itemId: string, delta: string) => void;
   onCommandOutputDelta?: (workspaceId: string, threadId: string, itemId: string, delta: string) => void;
+  onTerminalInteraction?: (
+    workspaceId: string,
+    threadId: string,
+    itemId: string,
+    stdin: string,
+  ) => void;
   onFileChangeOutputDelta?: (workspaceId: string, threadId: string, itemId: string, delta: string) => void;
   onTurnDiffUpdated?: (workspaceId: string, threadId: string, diff: string) => void;
   onThreadTokenUsageUpdated?: (
@@ -246,6 +252,17 @@ export function useAppServerEvents(handlers: AppServerEventHandlers) {
         return;
       }
 
+      if (method === "item/commandExecution/terminalInteraction") {
+        const params = message.params as Record<string, unknown>;
+        const threadId = String(params.threadId ?? params.thread_id ?? "");
+        const itemId = String(params.itemId ?? params.item_id ?? "");
+        const stdin = String(params.stdin ?? "");
+        if (threadId && itemId) {
+          handlers.onTerminalInteraction?.(workspace_id, threadId, itemId, stdin);
+        }
+        return;
+      }
+
       if (method === "item/fileChange/outputDelta") {
         const params = message.params as Record<string, unknown>;
         const threadId = String(params.threadId ?? params.thread_id ?? "");

src/features/threads/hooks/useThreads.ts

@@ -752,6 +752,18 @@ export function useThreads({
     [markProcessing, safeMessageActivity],
   );
 
+  const handleTerminalInteraction = useCallback(
+    (threadId: string, itemId: string, stdin: string) => {
+      if (!stdin) {
+        return;
+      }
+      const normalized = stdin.replace(/\r\n/g, "\n");
+      const suffix = normalized.endsWith("\n") ? "" : "\n";
+      handleToolOutputDelta(threadId, itemId, `\n[stdin]\n${normalized}${suffix}`);
+    },
+    [handleToolOutputDelta],
+  );
+
   const handleWorkspaceConnected = useCallback(
     (workspaceId: string) => {
       onWorkspaceConnected(workspaceId);
@@ -907,6 +919,14 @@ export function useThreads({
       ) => {
         handleToolOutputDelta(threadId, itemId, delta);
       },
+      onTerminalInteraction: (
+        _workspaceId: string,
+        threadId: string,
+        itemId: string,
+        stdin: string,
+      ) => {
+        handleTerminalInteraction(threadId, itemId, stdin);
+      },
       onFileChangeOutputDelta: (
         _workspaceId: string,
         threadId: string,