fix: tool permission request handling

Refactor tool permission flow to use dedicated permission queue instead of
generic message queue. Adds waitForPermissionResponse and sendPermissionResponse
methods to handle tool permission confirmations separately, ensuring proper
sequencing of permission requests.

Author: damassi

src/components/AgentChat.tsx

@@ -107,7 +107,7 @@ export const AgentChat: React.FC = () => {
         }
       })()}
 
-      <UserInput />
+      {!state.pendingToolPermission && <UserInput />}
 
       <Box marginTop={1} />
     </Box>

src/components/ToolPermissionPrompt.tsx

@@ -19,19 +19,8 @@ export const ToolPermissionPrompt: React.FC = () => {
   const handleSubmit = (value: string) => {
     const response = value.trim() || "yes"
 
-    // Resolve ALL pending tool permission requests with the same response
-    // This handles the case where multiple tools are called in parallel
-    while (
-      store.messageQueue.hasPendingRequests() &&
-      store.pendingToolPermission
-    ) {
-      store.messageQueue.sendMessage(response)
-
-      // Check if there are still more requests after sending
-      if (!store.messageQueue.hasPendingRequests()) {
-        break
-      }
-    }
+    // Send the permission response to the waiting canUseTool call
+    store.messageQueue.sendPermissionResponse(response)
 
     actions.setPendingToolPermission(undefined)
     actions.setInput("")

src/utils/MessageQueue.ts

@@ -2,6 +2,7 @@ import { EventEmitter } from "events"
 
 export class MessageQueue extends EventEmitter {
   private messageBuffer: string[] = []
+  private permissionBuffer: string[] = []
 
   constructor() {
     super()
@@ -25,15 +26,39 @@ export class MessageQueue extends EventEmitter {
     }
   }
 
+  async waitForPermissionResponse(): Promise<string> {
+    if (this.permissionBuffer.length > 0) {
+      return this.permissionBuffer.shift()!
+    }
+
+    return new Promise<string>((resolve) => {
+      this.once("permissionResponse", resolve)
+    })
+  }
+
+  sendPermissionResponse(value: string): void {
+    if (this.listenerCount("permissionResponse") > 0) {
+      this.emit("permissionResponse", value)
+    } else {
+      this.permissionBuffer.push(value)
+    }
+  }
+
   clear(): void {
     this.removeAllListeners("message")
+    this.removeAllListeners("permissionResponse")
     this.messageBuffer = []
+    this.permissionBuffer = []
   }
 
   hasPendingRequests(): boolean {
     return this.listenerCount("message") > 0
   }
 
+  hasPendingPermissionRequest(): boolean {
+    return this.listenerCount("permissionResponse") > 0
+  }
+
   subscribe(callback: (message: string) => void): () => void {
     this.on("message", callback)
     return () => {

src/utils/canUseTool.ts

@@ -25,7 +25,7 @@ export const createCanUseTool = (options: CanUseToolOptions) => {
       onToolPermissionRequest(toolName, input)
     }
 
-    const userResponse = await messageQueue.waitForMessage()
+    const userResponse = await messageQueue.waitForPermissionResponse()
     const response = userResponse.toLowerCase().trim()
 
     const CONFIRM = ["y", "yes", "allow"].includes(response)