From e8dc492cb085596ec0054b8046322a561eb33c8f Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Mon, 11 May 2026 12:59:51 +0100 Subject: [PATCH] test: tighten gateway runtime assertions --- src/gateway/server-http.request-trace.test.ts | 6 ++--- src/gateway/server-runtime-services.test.ts | 22 +++++++++---------- 2 files changed, 12 insertions(+), 16 deletions(-) diff --git a/src/gateway/server-http.request-trace.test.ts b/src/gateway/server-http.request-trace.test.ts index 0cdba3df5e4..b1a7023aefa 100644 --- a/src/gateway/server-http.request-trace.test.ts +++ b/src/gateway/server-http.request-trace.test.ts @@ -93,10 +93,8 @@ describe("gateway HTTP request trace scope", () => { .split("\n") .map((line) => JSON.parse(line) as Record) .find((record) => record.message === "handled request trace"); - expect(traceRecord).toMatchObject({ - traceId: activeTraceInHandler?.traceId, - spanId: activeTraceInHandler?.spanId, - }); + expect(traceRecord?.traceId).toBe(activeTraceInHandler?.traceId); + expect(traceRecord?.spanId).toBe(activeTraceInHandler?.spanId); } finally { fs.rmSync(dir, { recursive: true, force: true }); } diff --git a/src/gateway/server-runtime-services.test.ts b/src/gateway/server-runtime-services.test.ts index 9e5a6d8e7e9..48844d8f370 100644 --- a/src/gateway/server-runtime-services.test.ts +++ b/src/gateway/server-runtime-services.test.ts @@ -185,18 +185,16 @@ describe("server-runtime-services", () => { expect(services.heartbeatRunner).toBe(hoisted.heartbeatRunner); await vi.advanceTimersByTimeAsync(1_250); await vi.dynamicImportSettled(); - expect(hoisted.recoverPendingDeliveries).toHaveBeenCalledWith( - expect.objectContaining({ - deliver: hoisted.deliverOutboundPayloads, - cfg: {}, - }), - ); - expect(hoisted.recoverPendingRestartContinuationDeliveries).toHaveBeenCalledWith( - expect.objectContaining({ - deps: {}, - maxEnqueuedAt: 123, - }), - ); + expect(hoisted.recoverPendingDeliveries).toHaveBeenCalledWith({ + deliver: hoisted.deliverOutboundPayloads, + cfg: {}, + log: expect.any(Object), + }); + expect(hoisted.recoverPendingRestartContinuationDeliveries).toHaveBeenCalledWith({ + deps: {}, + maxEnqueuedAt: 123, + log: expect.any(Object), + }); }); it("can defer cron startup while activating other scheduled services", async () => {