[codex] add mobile attention notifications

.gitignore

@@ -37,6 +37,7 @@ coverage/
 .claude/settings.local.json
 localdocs/
 execplan/
+.worktrees/
 
 # Generated npm bundle output (local)
 cli/npm/main/

cli/src/codex/codexRemoteLauncher.test.ts

@@ -5,7 +5,8 @@ import type { EnhancedMode } from './loop';
 const harness = vi.hoisted(() => ({
     notifications: [] as Array<{ method: string; params: unknown }>,
     registerRequestCalls: [] as string[],
-    initializeCalls: [] as unknown[]
+    initializeCalls: [] as unknown[],
+    turnCompletion: { status: 'Completed' } as { status: string; message?: string }
 }));
 
 vi.mock('./codexAppServerClient', () => {
@@ -40,7 +41,7 @@ vi.mock('./codexAppServerClient', () => {
             harness.notifications.push({ method: 'turn/started', params: started });
             this.notificationHandler?.('turn/started', started);
 
-            const completed = { status: 'Completed', turn: {} };
+            const completed = { ...harness.turnCompletion, turn: {} };
             harness.notifications.push({ method: 'turn/completed', params: completed });
             this.notificationHandler?.('turn/completed', completed);
 
@@ -168,6 +169,7 @@ describe('codexRemoteLauncher', () => {
         harness.notifications = [];
         harness.registerRequestCalls = [];
         harness.initializeCalls = [];
+        harness.turnCompletion = { status: 'Completed' };
     });
 
     it('finishes a turn and emits ready when task lifecycle events omit turn_id', async () => {
@@ -198,4 +200,20 @@ describe('codexRemoteLauncher', () => {
         expect(thinkingChanges).toContain(true);
         expect(session.thinking).toBe(false);
     });
+
+    it('persists failed terminal events so the hub can notify for attention', async () => {
+        harness.turnCompletion = { status: 'Failed', message: 'boom' };
+        const {
+            session,
+            codexMessages
+        } = createSessionStub();
+
+        const exitReason = await codexRemoteLauncher(session as never);
+
+        expect(exitReason).toBe('exit');
+        expect(codexMessages).toContainEqual(expect.objectContaining({
+            type: 'task_failed',
+            error: 'boom'
+        }));
+    });
 });

cli/src/codex/codexRemoteLauncher.ts

@@ -285,6 +285,10 @@ class CodexRemoteLauncher extends RemoteLauncherBase {
                 allowAnonymousTerminalEvent = false;
             }
 
+            if (msgType === 'turn_aborted' || msgType === 'task_failed') {
+                session.sendAgentMessage(msg);
+            }
+
             if (msgType === 'agent_message') {
                 const message = asString(msg.message);
                 if (message) {

cli/src/utils/spawnHappyCLI.test.ts

@@ -1,5 +1,7 @@
 import { beforeAll, afterAll, beforeEach, describe, expect, it, vi } from 'vitest';
 import type { SpawnOptions } from 'child_process';
+import { join } from 'node:path';
+import { projectPath } from '@/projectPath';
 
 const spawnMock = vi.fn((..._args: any[]) => ({ pid: 12345 } as any));
 
@@ -100,14 +102,16 @@ describe('spawnHappyCLI windowsHide behavior', () => {
 
     const command = getHappyCliCommand(['mcp', '--url', 'http://127.0.0.1:1234/']);
     const isBunRuntime = Boolean((process.versions as Record<string, string | undefined>).bun);
+    const expectedProjectRoot = projectPath().replace(/\\/g, '/');
+    const expectedEntrypoint = join(projectPath(), 'src', 'index.ts').replace(/\\/g, '/');
 
     expect(command.command).toBe(process.execPath);
     if (isBunRuntime) {
       expect(command.args[0]).toBe('--cwd');
-      expect(command.args[1].replace(/\\/g, '/')).toMatch(/\/hapi\/cli$/);
-      expect(command.args[2].replace(/\\/g, '/')).toMatch(/\/hapi\/cli\/src\/index\.ts$/);
+      expect(command.args[1].replace(/\\/g, '/')).toBe(expectedProjectRoot);
+      expect(command.args[2].replace(/\\/g, '/')).toBe(expectedEntrypoint);
     } else {
-      expect(command.args.some((arg) => arg.replace(/\\/g, '/').endsWith('/hapi/cli/src/index.ts'))).toBe(true);
+      expect(command.args.map((arg) => arg.replace(/\\/g, '/'))).toContain(expectedEntrypoint);
     }
   });