From 9ea697ac09603a6fce37e88bd87b4dda0c9c3b32 Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Fri, 12 Dec 2025 18:07:33 +0000 Subject: [PATCH] style(test): biome format --- src/gateway/server.test.ts | 94 ++++++++++++++++++++----------------- src/process/tau-rpc.test.ts | 5 +- 2 files changed, 55 insertions(+), 44 deletions(-) diff --git a/src/gateway/server.test.ts b/src/gateway/server.test.ts index d76dfc478..d5a1bc7b5 100644 --- a/src/gateway/server.test.ts +++ b/src/gateway/server.test.ts @@ -481,52 +481,60 @@ describe("gateway server", () => { await server.close(); }); - test("agent ack response then final response", { timeout: 8000 }, async () => { - const { server, ws } = await startServerWithClient(); - ws.send( - JSON.stringify({ - type: "hello", - minProtocol: 1, - maxProtocol: 1, - client: { - name: "test", - version: "1.0.0", - platform: "test", - mode: "test", - }, - caps: [], - }), - ); - await onceMessage(ws, (o) => o.type === "hello-ok"); + test( + "agent ack response then final response", + { timeout: 8000 }, + async () => { + const { server, ws } = await startServerWithClient(); + ws.send( + JSON.stringify({ + type: "hello", + minProtocol: 1, + maxProtocol: 1, + client: { + name: "test", + version: "1.0.0", + platform: "test", + mode: "test", + }, + caps: [], + }), + ); + await onceMessage(ws, (o) => o.type === "hello-ok"); - const ackP = onceMessage( - ws, - (o) => - o.type === "res" && o.id === "ag1" && o.payload?.status === "accepted", - ); - const finalP = onceMessage( - ws, - (o) => - o.type === "res" && o.id === "ag1" && o.payload?.status !== "accepted", - ); - ws.send( - JSON.stringify({ - type: "req", - id: "ag1", - method: "agent", - params: { message: "hi", idempotencyKey: "idem-ag" }, - }), - ); + const ackP = onceMessage( + ws, + (o) => + o.type === "res" && + o.id === "ag1" && + o.payload?.status === "accepted", + ); + const finalP = onceMessage( + ws, + (o) => + o.type === "res" && + o.id === "ag1" && + o.payload?.status !== "accepted", + ); + ws.send( + JSON.stringify({ + type: "req", + id: "ag1", + method: "agent", + params: { message: "hi", idempotencyKey: "idem-ag" }, + }), + ); - const ack = await ackP; - const final = await finalP; - expect(ack.payload.runId).toBeDefined(); - expect(final.payload.runId).toBe(ack.payload.runId); - expect(final.payload.status).toBe("ok"); + const ack = await ackP; + const final = await finalP; + expect(ack.payload.runId).toBeDefined(); + expect(final.payload.runId).toBe(ack.payload.runId); + expect(final.payload.status).toBe("ok"); - ws.close(); - await server.close(); - }); + ws.close(); + await server.close(); + }, + ); test( "agent dedupes by idempotencyKey after completion", diff --git a/src/process/tau-rpc.test.ts b/src/process/tau-rpc.test.ts index e0c3cbdd5..0737fc2c1 100644 --- a/src/process/tau-rpc.test.ts +++ b/src/process/tau-rpc.test.ts @@ -74,7 +74,10 @@ describe("tau-rpc", () => { expect(writes.length).toBeGreaterThan(0); const first = writes[0]?.trim(); expect(first?.endsWith("\n")).toBe(false); - const obj = JSON.parse(first ?? "{}") as { type?: string; message?: unknown }; + const obj = JSON.parse(first ?? "{}") as { + type?: string; + message?: unknown; + }; expect(obj.type).toBe("prompt"); expect(obj.message).toBe("hello"); });