feat: support pending tool call UI

Author: PoolPirate

src/proxy/bridge-non-streaming.ts

@@ -23,7 +23,6 @@ import {
 import { createBridgeCloseController } from "./bridge-close-controller";
 
 const MCP_TOOL_BATCH_WINDOW_MS = 150;
-const MCP_TOOL_METADATA_GRACE_MS = 1_500;
 
 interface CollectedResponse {
   text: string;
@@ -90,8 +89,6 @@ async function collectFullResponse(
   let endStreamError: Error | null = null;
   const pendingToolCalls: OpenAIToolCall[] = [];
   let toolCallEndTimer: NodeJS.Timeout | undefined;
-  const announcedToolCallIds = new Set<string>();
-  let toolCallMetadataDeadlineMs = 0;
 
   const { bridge, heartbeatTimer } = await startBridge(
     accessToken,
@@ -103,44 +100,10 @@ async function collectFullResponse(
     clearTimeout(toolCallEndTimer);
     toolCallEndTimer = undefined;
   };
-  const getMissingAnnouncedToolCallIds = () => {
-    const pendingExecIds = new Set(pendingToolCalls.map((call) => call.id));
-    return [...announcedToolCallIds].filter(
-      (toolCallId) => !pendingExecIds.has(toolCallId),
-    );
-  };
   const scheduleToolCallBridgeEnd = () => {
     stopToolCallEndTimer();
     toolCallEndTimer = setTimeout(
-      () => {
-        const missingAnnouncedToolCallIds = getMissingAnnouncedToolCallIds();
-        if (
-          missingAnnouncedToolCallIds.length > 0 &&
-          Date.now() < toolCallMetadataDeadlineMs
-        ) {
-          scheduleToolCallBridgeEnd();
-          return;
-        }
-
-        if (missingAnnouncedToolCallIds.length > 0) {
-          endStreamError = new Error(
-            `Cursor announced MCP tool calls without matching exec metadata: ${missingAnnouncedToolCallIds.join(", ")}`,
-          );
-          logPluginError(
-            "Aborting non-streaming Cursor response because announced MCP tool calls never received exec metadata",
-            {
-              modelId,
-              convKey,
-              pendingExecToolCallIds: pendingToolCalls.map((call) => call.id),
-              missingAnnouncedToolCallIds,
-            },
-          );
-          scheduleBridgeEnd(bridge);
-          return;
-        }
-
-        scheduleBridgeEnd(bridge);
-      },
+      () => scheduleBridgeEnd(bridge),
       MCP_TOOL_BATCH_WINDOW_MS,
     );
   };
@@ -173,7 +136,6 @@ async function collectFullResponse(
               fullText += content;
             },
             (exec) => {
-              announcedToolCallIds.add(exec.toolCallId);
               const toolCall = {
                 id: exec.toolCallId,
                 type: "function" as const,
@@ -190,21 +152,9 @@ async function collectFullResponse(
               } else {
                 pendingToolCalls.push(toolCall);
               }
-              toolCallMetadataDeadlineMs =
-                Date.now() + MCP_TOOL_METADATA_GRACE_MS;
               scheduleToolCallBridgeEnd();
             },
-            (info: McpToolCallUpdateInfo) => {
-              if (info.updateCase === "toolCallCompleted") {
-                announcedToolCallIds.delete(info.toolCallId);
-              } else {
-                announcedToolCallIds.add(info.toolCallId);
-              }
-
-              if (pendingToolCalls.length > 0) {
-                scheduleToolCallBridgeEnd();
-              }
-            },
+            (_info: McpToolCallUpdateInfo) => {},
             (checkpointBytes) => {
               updateConversationCheckpoint(convKey, checkpointBytes);
               bridgeCloseController.noteCheckpoint();