Fix scheduled tasks blocking Telegram message processing

Two changes that fix messages being silently dropped while heartbeat
or other scheduled tasks are running:

1. group-queue: preempt idle task containers when user messages arrive
   instead of queuing messages behind a 30-minute idle timeout

2. agent-runner: scheduled tasks exit immediately after completing
   instead of entering the IPC wait loop. Frees the group slot so
   user messages can be processed without delay.

Also mocks transcription module in WhatsApp tests so voice note test
is deterministic regardless of local .env state.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: ziggy

container/agent-runner/src/index.ts

@@ -571,6 +571,15 @@ async function main(): Promise<void> {
         break;
       }
 
+      // Scheduled tasks are one-shot — exit after the first query instead
+      // of waiting for IPC messages that will never arrive. This frees the
+      // group slot immediately so user messages aren't blocked.
+      if (containerInput.isScheduledTask) {
+        log('Scheduled task complete, exiting');
+        writeOutput({ status: 'success', result: null, newSessionId: sessionId });
+        break;
+      }
+
       // Emit session update so host can track it
       writeOutput({ status: 'success', result: null, newSessionId: sessionId });
 

src/channels/whatsapp.test.ts

@@ -45,6 +45,17 @@ vi.mock('child_process', () => ({
   exec: vi.fn(),
 }));
 
+// Mock transcription — avoid real HTTP calls and env-dependent behavior
+vi.mock('../transcription.js', () => ({
+  transcribeAudioMessage: vi
+    .fn()
+    .mockResolvedValue('Hello from a voice note'),
+  isVoiceMessage: vi.fn(
+    (msg: any) => msg.message?.audioMessage?.ptt === true,
+  ),
+  textToSpeech: vi.fn().mockResolvedValue(null),
+}));
+
 // Build a fake WASocket that's an EventEmitter with the methods we need
 function createFakeSocket() {
   const ev = new EventEmitter();
@@ -564,7 +575,7 @@ describe('WhatsAppChannel', () => {
         expect.objectContaining({
           id: 'msg-8',
           sender_name: 'Frank',
-          content: expect.stringMatching(/^\[Voice: /),
+          content: '[Voice: Hello from a voice note]',
         }),
       );
     });

src/group-queue.ts

@@ -63,6 +63,18 @@ export class GroupQueue {
     const state = this.getGroup(groupJid);
 
     if (state.active) {
+      // If an idle task container is blocking messages, kill it so the
+      // message can be processed immediately instead of waiting for the
+      // task's idle timeout (which can be 30+ minutes).
+      if (state.isTaskContainer && state.idleWaiting) {
+        logger.info(
+          { groupJid },
+          'Preempting idle task container for incoming message',
+        );
+        this.closeStdin(groupJid);
+        // The message will be picked up when drainGroup runs after the
+        // task container exits (pendingMessages flag below).
+      }
       state.pendingMessages = true;
       logger.debug({ groupJid }, 'Container active, message queued');
       return;