WIP: feat(ai-native): harden ACP task startup and error recovery

.gitignore

@@ -10,6 +10,7 @@
 
 .package-temp-dir
 .tmp/
+/tools/playwright/tmp/
 
 # Logs
 logs

packages/ai-native/__test__/browser/acp-chat-mention-input-ref.test.tsx

@@ -1380,6 +1380,64 @@ describe('AcpChatMentionInput ref contract', () => {
     });
   });
 
+  it('clears an accepted first-task draft after it is promoted to an active session', async () => {
+    mockUseActualMentionInput = true;
+    jest.requireMock('@opensumi/ide-core-browser').useInjectable.mockReturnValue(createMockService());
+    const ref = React.createRef<AcpTurnEditorHandle>();
+    const submission = deferred<TurnActionResult>();
+    const submit = jest.fn(() => submission.promise);
+    const onDraftChange = jest.fn();
+    let promoteSession!: (sessionId: string) => void;
+
+    const Harness = () => {
+      const [activeSessionId, setActiveSessionId] = React.useState<string>();
+      promoteSession = setActiveSessionId;
+      return React.createElement(AcpTurnEditor, {
+        ref,
+        variant: 'main',
+        activeSessionId,
+        initialDraft: { message: 'first task draft' },
+        onDraftChange,
+        onSend: jest.fn(),
+        setTheme: jest.fn(),
+        agentId: '',
+        setAgentId: jest.fn(),
+        command: '',
+        setCommand: jest.fn(),
+        turnActions: {
+          submit,
+          stop: jest.fn(),
+          fastTrack: jest.fn(),
+          invalidateFastTrack: jest.fn(),
+          takeBackLastQueuedTurn: jest.fn(),
+        },
+      });
+    };
+
+    act(() => {
+      render(React.createElement(Harness), container);
+    });
+
+    const editor = container.querySelector('[contenteditable="true"]') as HTMLDivElement;
+    act(() => {
+      dispatchEditorKey(editor, { key: 'Enter' });
+      promoteSession('promoted-session');
+    });
+
+    await act(async () => {
+      submission.resolve({ accepted: true, outcome: 'started' });
+      await submission.promise;
+      await Promise.resolve();
+    });
+
+    expect(submit).toHaveBeenCalledWith(
+      { message: 'first task draft', images: [], agentId: '', command: '' },
+      'normal',
+    );
+    expect(ref.current!.getDraft()).toEqual({ message: '', images: [], agentId: '', command: '' });
+    expect(onDraftChange).toHaveBeenLastCalledWith({ message: '', images: [], agentId: '', command: '' });
+  });
+
   it('preserves text, pasted attachment, agent, and command changes made while submission is pending', async () => {
     mockUseActualMentionInput = true;
     const upload = jest.fn(async () => 'data:image/png;base64,new');

packages/ai-native/__test__/browser/acp-queued-turns.test.tsx

@@ -29,6 +29,7 @@ const baseSnapshot: AcpQueuedTurnSnapshot = {
   entries: [{ id: 'turn-1', message: 'first' }],
   canResume: false,
   canFastTrack: false,
+  initialStartPending: false,
 };
 
 const query = (selector: string) => container.querySelector(selector);
@@ -64,6 +65,7 @@ function renderQueue(
     onDelete?: jest.Mock;
     onImmediateSend?: jest.Mock;
     onEditorReady?: jest.Mock;
+    onOpenCapacitySettings?: jest.Mock;
   } = {},
 ) {
   const snapshot = { ...baseSnapshot, ...overrides };
@@ -97,12 +99,24 @@ function renderQueue(
         onDelete={handlers.onDelete}
         onImmediateSend={handlers.onImmediateSend}
         onEditorReady={handlers.onEditorReady}
+        onOpenCapacitySettings={overrides.onOpenCapacitySettings}
       />,
     );
   });
   return handlers;
 }
 
+it('shows a loading status while the first Task is launching', () => {
+  renderQueue({
+    activeSessionId: undefined,
+    entries: [],
+    initialStartPending: true,
+  });
+
+  expect(query('[data-testid="acp-task-launch-status"]')?.textContent).toContain('Starting task');
+  expect(query('[data-testid="acp-task-launch-status"] button')).toBeNull();
+});
+
 it('renders paused state and resumes', () => {
   renderQueue({ phase: 'paused', pauseReason: 'manual-stop', canResume: true });
   expect(query('[data-testid="acp-queued-turn-status"]')?.textContent).toContain('Paused');
@@ -111,6 +125,31 @@ it('renders paused state and resumes', () => {
   expect(onResume).toHaveBeenCalledTimes(1);
 });
 
+it('renders capacity exhaustion as a persistent actionable alert', () => {
+  const onOpenCapacitySettings = jest.fn();
+  renderQueue({
+    phase: 'paused',
+    pauseReason: 'start-failed',
+    pauseError: {
+      name: 'ACP_THREAD_POOL_SATURATED',
+      message: 'ACP concurrent tasks have reached the configured limit of 2.',
+      limit: 2,
+    },
+    canResume: true,
+    onOpenCapacitySettings,
+  });
+
+  expect(query('[data-testid="acp-capacity-error"]')?.getAttribute('role')).toBe('alert');
+  expect(query('[data-testid="acp-capacity-error"]')?.textContent).toContain('capacity limit (2) has been reached');
+  expect(query('[data-testid="acp-capacity-error"]')?.textContent).toContain(
+    'Your task draft and unsent content have been preserved',
+  );
+  click('[data-testid="acp-capacity-retry"]');
+  click('[data-testid="acp-capacity-open-settings"]');
+  expect(onResume).toHaveBeenCalledTimes(1);
+  expect(onOpenCapacitySettings).toHaveBeenCalledTimes(1);
+});
+
 it.each([
   [0, '0 Queued Turns'],
   [1, '1 Queued Turn'],