fix: address review feedback on voice barge-in race condition

assistant/src/calls/call-controller.ts

@@ -637,8 +637,7 @@ export class CallController {
   private isExpectedAbortError(err: unknown): boolean {
     if (!(err instanceof Error)) return false;
     return err.name === 'AbortError'
-      || err.name === 'APIUserAbortError'
-      || err.message === 'Session is already processing a message';
+      || err.name === 'APIUserAbortError';
   }
 
   private isCurrentRun(runVersion: number): boolean {

assistant/src/calls/voice-session-bridge.ts

@@ -236,6 +236,7 @@ export async function startVoiceTurn(opts: VoiceTurnOptions): Promise<VoiceTurnH
       eventSink,
       voiceCallControlPrompt,
     },
+    opts.signal,
   );
 
   // If the caller provided an external AbortSignal (e.g. from a

assistant/src/runtime/run-orchestrator.ts

@@ -178,6 +178,7 @@ export class RunOrchestrator {
     content: string,
     attachmentIds?: string[],
     options?: RunStartOptions,
+    signal?: AbortSignal,
   ): Promise<RunHandle> {
     // Block inbound content that contains secrets — mirrors the IPC check in sessions.ts
     const ingressCheck = checkIngressForSecrets(content);
@@ -200,13 +201,21 @@ export class RunOrchestrator {
     if (session.isProcessing()) {
       // Voice barge-in can race with turn teardown. Wait briefly for the
       // previous run to finish aborting before giving up.
+      // The caller can pass an AbortSignal so superseded turns bail out
+      // of this wait early instead of occupying the session.
       const maxWaitMs = 3000;
       const pollIntervalMs = 50;
       let waited = 0;
       while (session.isProcessing() && waited < maxWaitMs) {
+        if (signal?.aborted) {
+          throw new Error('Run aborted while waiting for session');
+        }
         await new Promise(resolve => setTimeout(resolve, pollIntervalMs));
         waited += pollIntervalMs;
       }
+      if (signal?.aborted) {
+        throw new Error('Run aborted while waiting for session');
+      }
       if (session.isProcessing()) {
         throw new Error('Session is already processing a message');
       }