}

async function expectOversizedPromptRejected(params: { sessionId: string; text: string }) {

const request = vi.fn(async () => ({ ok: true })) as GatewayClient["request"];

const requestMock = vi.fn(async (_method: string) => ({ ok: true }));

const request = requestMock as GatewayClient["request"];

const sessionStore = createInMemorySessionStore();

const agent = new AcpGatewayAgent(createAcpConnection(), createAcpGateway(request), {

sessionStore,

await expect(agent.prompt(createPromptRequest(params.sessionId, params.text))).rejects.toThrow(

/maximum allowed size/i,

);

expect(request.mock.calls.some(([method]) => method === "chat.send")).toBe(false);

expect(requestMock.mock.calls.some(([method]) => method === "chat.send")).toBe(false);

const session = sessionStore.getSession(params.sessionId);

expect(session?.activeRunId).toBeNull();

expect(session?.abortController).toBeNull();

it("accepts forwarded timeout config options without failing OpenClaw ACP bridge turns", async () => {

const sessionStore = createInMemorySessionStore();

const connection = createAcpConnection();

const request = vi.fn(async (method: string) => {

const requestMock = vi.fn(async (method: string) => {

if (method === "sessions.list") {

return {

ts: Date.now(),

}

expect(method).not.toBe("sessions.patch");

return { ok: true };

}) as GatewayClient["request"];

});

const request = requestMock as GatewayClient["request"];

const agent = new AcpGatewayAgent(connection, createAcpGateway(request), {

sessionStore,

});

);

expect(Array.isArray(result.configOptions)).toBe(true);

expect(request.mock.calls.some(([method]) => method === "sessions.patch")).toBe(false);

expect(requestMock.mock.calls.some(([method]) => method === "sessions.patch")).toBe(false);

sessionStore.clearAllSessionsForTest();

});