const announceSpy = vi.fn(async (_params: unknown) => true);

const runSubagentEndedHookMock = vi.fn(async (_event?: unknown, _ctx?: unknown) => {});

const emitSessionLifecycleEventMock = vi.fn();

function countMatching<T>(items: readonly T[], predicate: (item: T) => boolean) {

let count = 0;

for (const item of items) {

if (predicate(item)) {

count += 1;

}

}

return count;

}

const noopContextEngine = {

info: { id: "test-context-engine", name: "Test context engine" },

ingest: async () => ({ ingested: false }),

const childRunIds = announceSpy.mock.calls.map(

(call) => ((call[0] ?? {}) as { childRunId?: string }).childRunId,

);

expect(childRunIds.filter((id) => id === "run-parent")).toHaveLength(1);

expect(countMatching(childRunIds, (id) => id === "run-parent")).toBe(1);

});

emitLifecycleEnd("run-child");

await waitForRegistrySideEffect(() => {

const childRunIds = announceSpy.mock.calls.map(

(call) => ((call[0] ?? {}) as { childRunId?: string }).childRunId,

);

expect(childRunIds.filter((id) => id === "run-parent")).toHaveLength(2);

expect(childRunIds.filter((id) => id === "run-child")).toHaveLength(1);

expect(countMatching(childRunIds, (id) => id === "run-parent")).toBe(2);

expect(countMatching(childRunIds, (id) => id === "run-child")).toBe(1);

});

const childRunIds = announceSpy.mock.calls.map(

(call) => ((call[0] ?? {}) as { childRunId?: string }).childRunId,

);

expect(childRunIds.filter((id) => id === "run-parent")).toHaveLength(2);

expect(childRunIds.filter((id) => id === "run-child")).toHaveLength(1);

expect(countMatching(childRunIds, (id) => id === "run-parent")).toBe(2);

expect(countMatching(childRunIds, (id) => id === "run-child")).toBe(1);

});

it("retries completion-mode announce delivery with backoff and then gives up after retry limit", async () => {