}

}

async function readSpawnedChildRow(params: {

function hasCodexAppServerLifecycleEvent(params: {

childSessionKey: string;

client: GatewayClient;

parentSessionKey: string;

}): Promise<Record<string, unknown> | undefined> {

const result = await params.client.request(

"sessions.list",

{

spawnedBy: params.parentSessionKey,

limit: 20,

},

{ timeoutMs: 10_000 },

events: CapturedAgentEvent[];

}): boolean {

return params.events.some(

(event) =>

event.sessionKey === params.childSessionKey && event.stream === "codex_app_server.lifecycle",

);

const sessions = asRecord(result)?.sessions;

if (!Array.isArray(sessions)) {

return undefined;

}

return sessions

.map((entry) => asRecord(entry))

.find((entry): entry is Record<string, unknown> => entry?.key === params.childSessionKey);

}

function isActiveCodexSubagentRow(row: Record<string, unknown> | undefined): boolean {

if (!row) {

return false;

}

return row.hasActiveSubagentRun === true || row.subagentRunState === "active";

}

async function waitForCodexSubagentStarted(params: {

childSessionKey: string;

client: GatewayClient;

events: CapturedAgentEvent[];

parentSessionKey: string;

}): Promise<Record<string, unknown> | undefined> {

}): Promise<void> {

const deadline = Date.now() + Math.min(CODEX_HARNESS_REQUEST_TIMEOUT_MS, 120_000);

let lastRow: Record<string, unknown> | undefined;

let lastError: unknown;

while (Date.now() < deadline) {

try {

lastRow = await readSpawnedChildRow({

childSessionKey: params.childSessionKey,

client: params.client,

parentSessionKey: params.parentSessionKey,

});

const hasLifecycleEvent = params.events.some(

(event) =>

event.sessionKey === params.childSessionKey &&

event.stream === "codex_app_server.lifecycle",

);

if (lastRow && (hasLifecycleEvent || isActiveCodexSubagentRow(lastRow))) {

return lastRow;

}

} catch (error) {

lastError = error;

if (hasCodexAppServerLifecycleEvent(params)) {

return;

}

await delay(2_000);

}

throw new Error(

[

`subagent ${params.childSessionKey} did not start through the Codex app-server harness`,

`lastRow=${JSON.stringify(lastRow)}`,

`events=${JSON.stringify(params.events)}`,

`lastError=${lastError instanceof Error ? lastError.message : String(lastError)}`,

].join("\n"),

);

}

`subagent spawn did not return a child session key: ${JSON.stringify(spawnResult)}`,

);

}

const childRow = await waitForCodexSubagentStarted({

await waitForCodexSubagentStarted({

childSessionKey,

client: params.client,

events,

parentSessionKey: params.sessionKey,

});

expect(childRow?.key).toBe(childSessionKey);

} finally {

const { testing: subagentSpawnTesting } = await import("../agents/subagent-spawn.js");

subagentSpawnTesting.setDepsForTest();