} as unknown as EmbeddedRunAttemptParams;

}

function expectFirstBlockReplyText(params: EmbeddedRunAttemptParams): string {

const onBlockReply = params.onBlockReply;

if (onBlockReply === undefined) {

throw new Error("Expected onBlockReply callback");

}

const payload = vi.mocked(onBlockReply).mock.calls[0]?.[0];

if (typeof payload?.text !== "string") {

throw new Error("Expected first block reply text");

}

return payload.text;

}

describe("Codex app-server user input bridge", () => {

it("prompts the originating chat and resolves request_user_input from the next queued message", async () => {

const params = createParams();

});

await vi.waitFor(() => expect(params.onBlockReply).toHaveBeenCalledTimes(1));

const payload = vi.mocked(params.onBlockReply!).mock.calls[0]?.[0];

expect(payload).toEqual(expect.objectContaining({ text: expect.any(String) }));

const text = payload?.text ?? "";

const text = expectFirstBlockReplyText(params);

expect(text).toContain("Mode <\uff20U123>");

expect(text).toContain("Pick \uff3btrusted\uff3d\uff08https://evil\uff09 \uff20here");

expect(text).toContain(

if (!result.manager) {

throw new Error(missingMessage);

}

return result.manager;

return result.manager as unknown as MemoryIndexManager;

}

async function getPersistentManager(cfg: TestCfg): Promise<MemoryIndexManager> {

if (!result.manager) {

throw new Error("manager missing");

}

manager = result.manager;

manager = result.manager as unknown as MemoryIndexManager;

expect(watchMock).not.toHaveBeenCalled();

});

});

const { manager } = await createManager({ mode: "full" });

if (releaseUpdate === null) {

throw new Error("Expected qmd update release callback");

}

releaseUpdate();

(

releaseUpdate ??

(() => {

throw new Error("Expected qmd update release callback");

})

)();

await manager?.close();

});