test: avoid infra count filter allocations · openclaw/ope...

Recent Commits to openclaw:main

steipete · 2026-05-09 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -305,7 +305,7 @@ describe("bonjour-discovery", () => {`
`305`	`305`	`run: run as unknown as typeof runCommandWithTimeout,`
`306`	`306`	`});`
`307`	`307`
`308`		`-expect(calls.filter((c) => c[1] === "-B")).toHaveLength(1);`
	`308`	`+expect(calls.reduce((count, c) => count + (c[1] === "-B" ? 1 : 0), 0)).toBe(1);`
`309`	`309`	`expect(calls.find((c) => c[1] === "-B")?.[3]).toBe("local.");`
`310`	`310`	`});`
`311`	`311`	`});`

Original file line number	Diff line number	Diff line change
`@@ -58,6 +58,16 @@ function withoutSigusr1Listeners(fn: () => void): void {`
`58`	`58`	`}`
`59`	`59`	`}`
`60`	`60`
	`61`	`+function countSigusr1Emits(calls: readonly unknown[][]): number {`
	`62`	`+let count = 0;`
	`63`	`+for (const args of calls) {`
	`64`	`+if (args[0] === "SIGUSR1") {`
	`65`	`+count += 1;`
	`66`	`+}`
	`67`	`+}`
	`68`	`+return count;`
	`69`	`+}`
	`70`	`+`
`61`	`71`	`function withRestartSupervisorEnabled(fn: () => void): void {`
`62`	`72`	`const originalVitest = process.env.VITEST;`
`63`	`73`	`const originalNodeEnv = process.env.NODE_ENV;`
`@@ -417,10 +427,10 @@ describe("infra runtime", () => {`
`417`	`427`	`expect(second.cooldownMsApplied).toBe(30_000);`
`418`	`428`
`419`	`429`	`await vi.advanceTimersByTimeAsync(29_999);`
`420`		`-expect(emitSpy.mock.calls.filter((args) => args[0] === "SIGUSR1").length).toBe(1);`
	`430`	`+expect(countSigusr1Emits(emitSpy.mock.calls)).toBe(1);`
`421`	`431`
`422`	`432`	`await vi.advanceTimersByTimeAsync(1);`
`423`		`-expect(emitSpy.mock.calls.filter((args) => args[0] === "SIGUSR1").length).toBe(2);`
	`433`	`+expect(countSigusr1Emits(emitSpy.mock.calls)).toBe(2);`
`424`	`434`	`} finally {`
`425`	`435`	`process.removeListener("SIGUSR1", handler);`
`426`	`436`	`}`
`@@ -447,7 +457,7 @@ describe("infra runtime", () => {`
`447`	`457`	`expect(forced.cooldownMsApplied).toBe(0);`
`448`	`458`
`449`	`459`	`await vi.advanceTimersByTimeAsync(0);`
`450`		`-expect(emitSpy.mock.calls.filter((args) => args[0] === "SIGUSR1").length).toBe(2);`
	`460`	`+expect(countSigusr1Emits(emitSpy.mock.calls)).toBe(2);`
`451`	`461`	`expect(peekGatewaySigusr1RestartReason()).toBe("update.run");`
`452`	`462`	`} finally {`
`453`	`463`	`process.removeListener("SIGUSR1", handler);`

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,16 @@ function normalizeReconnectAccountIdForTest(accountId?: string \| null): string {`
`25`	`25`	`return (accountId ?? "").trim() \|\| "default";`
`26`	`26`	`}`
`27`	`27`
	`28`	`+function countMatching<T>(items: readonly T[], predicate: (item: T) => boolean): number {`
	`29`	`+let count = 0;`
	`30`	`+for (const item of items) {`
	`31`	`+if (predicate(item)) {`
	`32`	`+count += 1;`
	`33`	`+}`
	`34`	`+}`
	`35`	`+return count;`
	`36`	`+}`
	`37`	`+`
`28`	`38`	`async function drainDirectChatReconnectPending(opts: {`
`29`	`39`	`accountId: string;`
`30`	`40`	`deliver: DeliverFn;`
`@@ -347,7 +357,7 @@ describe("drainPendingDeliveries for reconnect", () => {`
`347`	`357`	`await startupRecovery;`
`348`	`358`
`349`	`359`	`expect(deliver).toHaveBeenCalledTimes(2);`
`350`		`-expect(deliveredTargets.filter((target) => target === "+1555")).toHaveLength(1);`
	`360`	`+expect(countMatching(deliveredTargets, (target) => target === "+1555")).toBe(1);`
`351`	`361`	`expect(startupLog.info).toHaveBeenCalledWith(`
`352`	`362`	`expect.stringContaining("Recovery skipped for delivery"),`
`353`	`363`	`);`

Original file line number	Diff line number	Diff line change
`@@ -149,7 +149,9 @@ describe("migrateOrphanedSessionKeys", () => {`
`149`	`149`	`expect(requireStoreEntry(store, "agent:main:work").sessionId).toBe("main-session");`
`150`	`150`	`expect(requireStoreEntry(store, "agent:ops:work").sessionId).toBe("ops-session");`
`151`	`151`	`// The key must NOT have been merged into ops namespace`
`152`		`-expect(Object.keys(store).filter((k) => k.startsWith("agent:ops:")).length).toBe(1);`
	`152`	`+expect(`
	`153`	`+Object.keys(store).reduce((count, k) => count + (k.startsWith("agent:ops:") ? 1 : 0), 0),`
	`154`	`+).toBe(1);`
`153`	`155`	`});`
`154`	`156`	`});`
`155`	`157`

Original file line number	Diff line number	Diff line change
`@@ -72,6 +72,16 @@ const hoisted = vi.hoisted(() => {`
`72`	`72`	`};`
`73`	`73`	`});`
`74`	`74`
	`75`	`+function countMatching<T>(items: readonly T[], predicate: (item: T) => boolean): number {`
	`76`	`+let count = 0;`
	`77`	`+for (const item of items) {`
	`78`	`+if (predicate(item)) {`
	`79`	`+count += 1;`
	`80`	`+}`
	`81`	`+}`
	`82`	`+return count;`
	`83`	`+}`
	`84`	`+`
`75`	`85`	`vi.mock("../acp/control-plane/manager.js", () => ({`
`76`	`86`	`getAcpSessionManager: () => ({`
`77`	`87`	`cancelSession: hoisted.cancelSessionMock,`
`@@ -1120,7 +1130,7 @@ describe("task-registry", () => {`
`1120`	`1130`	`deliveryStatus: "pending",`
`1121`	`1131`	`});`
`1122`	`1132`
`1123`		`-expect(listTaskRecords().filter((task) => task.runId === "run-shared")).toHaveLength(2);`
	`1133`	`+expect(countMatching(listTaskRecords(), (task) => task.runId === "run-shared")).toBe(2);`
`1124`	`1134`	`expect(findTaskByRunId("run-shared")).toMatchObject({`
`1125`	`1135`	`runtime: "acp",`
`1126`	`1136`	`task: "Spawn ACP child",`
`@@ -1367,7 +1377,7 @@ describe("task-registry", () => {`
`1367`	`1377`	`});`
`1368`	`1378`
`1369`	`1379`	`expect(directTask.taskId).toBe(spawnedTask.taskId);`
`1370`		`-expect(listTaskRecords().filter((task) => task.runId === "run-collapse")).toHaveLength(1);`
	`1380`	`+expect(countMatching(listTaskRecords(), (task) => task.runId === "run-collapse")).toBe(1);`
`1371`	`1381`	`expect(findTaskByRunId("run-collapse")).toMatchObject({`
`1372`	`1382`	`task: "Spawn ACP child",`
`1373`	`1383`	`});`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main