fix(v2): drain message queue after compaction completes (#1414)

handleCompactionEvent set isProcessing: false but never called
processQueue(), leaving messages queued during compaction stuck
until the next sendMessage — which then ran out of order.

Add processQueue() calls after both completed and failed branches,
matching the existing pattern in sendMessage.

Author: MaxStenklyft

packages/tui/src/stores/app-store.ts

@@ -220,7 +220,7 @@ interface BaseAppActions {
     agent: { name: string; welcomeMessage?: string } | null
   ) => void;
   setPreviousAgentName: (name: string | null) => void;
-  handleCompactionEvent: (event: AgentStreamEvent) => void;
+  handleCompactionEvent: (event: AgentStreamEvent) => Promise<void>;
 
   // Chat actions
   clearMessages: () => void;
@@ -1245,7 +1245,7 @@ export const createAppStore = (props: AppStoreProps) => {
     },
     setPreviousAgentName: (previousAgentName) => set({ previousAgentName }),
 
-    handleCompactionEvent: (event) => {
+    handleCompactionEvent: async (event) => {
       if (event.type === AgentEventType.ContextUsage) {
         logger.info(
           '[context-usage] ContextUsage event in compactionHandler, percent=',
@@ -1277,13 +1277,15 @@ export const createAppStore = (props: AppStoreProps) => {
           }
           return { isCompacting: false, isProcessing: false, messages };
         });
+        await get().processQueue();
       } else if (event.status === 'failed') {
         set({ isCompacting: false, isProcessing: false });
         get().showTransientAlert({
           message: `Compaction failed: ${event.error ?? 'unknown error'}`,
           status: 'error',
           autoHideMs: 5000,
         });
+        await get().processQueue();
       }
     },
 

packages/tui/src/stores/message-queue.test.ts

@@ -1,6 +1,7 @@
 import { describe, it, expect, mock } from 'bun:test';
 import { createAppStore } from './app-store';
 import { Kiro } from '../kiro';
+import { AgentEventType } from '../types/agent-events';
 
 mock.module('../kiro', () => ({
   Kiro: mock(() => ({
@@ -206,4 +207,53 @@ describe('Message queue', () => {
       expect(store.getState().toolOutputsExpanded).toBe(true);
     });
   });
+
+  describe('compaction drains queue', () => {
+    it('processQueue is called after compaction completes', async () => {
+      const store = createTestStore();
+      store.setState({
+        isCompacting: true,
+        isProcessing: true,
+        queuedMessages: ['queued during compaction'],
+      });
+
+      await store.getState().handleCompactionEvent({
+        type: AgentEventType.CompactionStatus,
+        status: 'completed',
+      });
+
+      expect(store.getState().isCompacting).toBe(false);
+      expect(store.getState().queuedMessages).toEqual([]);
+    });
+
+    it('processQueue is called after compaction fails', async () => {
+      const store = createTestStore();
+      store.setState({
+        isCompacting: true,
+        isProcessing: true,
+        queuedMessages: ['queued during compaction'],
+      });
+
+      await store.getState().handleCompactionEvent({
+        type: AgentEventType.CompactionStatus,
+        status: 'failed',
+        error: 'test error',
+      });
+
+      expect(store.getState().isCompacting).toBe(false);
+      expect(store.getState().queuedMessages).toEqual([]);
+    });
+
+    it('queue is untouched when compaction starts', async () => {
+      const store = createTestStore();
+      store.setState({ queuedMessages: ['pre-existing'] });
+
+      await store.getState().handleCompactionEvent({
+        type: AgentEventType.CompactionStatus,
+        status: 'started',
+      });
+
+      expect(store.getState().queuedMessages).toEqual(['pre-existing']);
+    });
+  });
 });