vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-10 05:30:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: require gateway lock acquisitions

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-08 16:54:31 +01:00
parent 17444268a9
commit 5a91c7c2a7
1 changed files with 18 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/infra/gateway-lock.test.ts
View File

@@ -10,6 +10,8 @@ import { resolveConfigPath, resolveStateDir } from "../config/paths.js";
import { createSuiteTempRootTracker } from "../test-helpers/temp-dir.js";
import { acquireGatewayLock, GatewayLockError, type GatewayLockOptions } from "./gateway-lock.js";
type GatewayLock = NonNullable<Awaited<ReturnType<typeof acquireGatewayLock>>>;
const fixtureRootTracker = createSuiteTempRootTracker({ prefix: "openclaw-gateway-lock-" });
let fixtureRoot = "";
const realNow = Date.now.bind(Date);
@@ -47,6 +49,14 @@ async function acquireForTest(
});
}
function expectGatewayLock(lock: Awaited<ReturnType<typeof acquireGatewayLock>>): GatewayLock {
expect(lock).toEqual(expect.objectContaining({ release: expect.any(Function) }));
if (lock === null) {
throw new Error("Expected gateway lock");
}
return lock;
}
function resolveLockPath(env: NodeJS.ProcessEnv) {
const stateDir = resolveStateDir(env);
const configPath = resolveConfigPath(env, stateDir);
@@ -175,7 +185,7 @@ describe("gateway lock", () => {
vi.useRealTimers();
const env = await makeEnv();
const lock = await acquireForTest(env, { timeoutMs: 50 });
expect(lock).not.toBeNull();
const acquiredLock = expectGatewayLock(lock);
const pending = acquireForTest(env, {
timeoutMs: 15,
@@ -183,9 +193,9 @@ describe("gateway lock", () => {
});
await expect(pending).rejects.toBeInstanceOf(GatewayLockError);
await lock?.release();
await acquiredLock.release();
const lock2 = await acquireForTest(env);
await lock2?.release();
await expectGatewayLock(lock2).release();
});
it("treats recycled linux pid as stale when start time mismatches", async () => {
@@ -204,9 +214,9 @@ describe("gateway lock", () => {
pollIntervalMs: 5,
platform: "linux",
});
expect(lock).not.toBeNull();
const acquiredLock = expectGatewayLock(lock);
await lock?.release();
await acquiredLock.release();
spy.mockRestore();
});
@@ -259,8 +269,7 @@ describe("gateway lock", () => {
platform: "darwin",
port: 18789,
});
expect(lock).not.toBeNull();
await lock?.release();
await expectGatewayLock(lock).release();
connectSpy.mockRestore();
});
@@ -329,8 +338,7 @@ describe("gateway lock", () => {
port: 18789,
readProcessCmdline: () => ["chrome.exe", "--no-sandbox"],
});
expect(lock).not.toBeNull();
await lock?.release();
await expectGatewayLock(lock).release();
connectSpy.mockRestore();
});
@@ -394,8 +402,7 @@ describe("gateway lock", () => {
port: 18789,
readProcessCmdline: () => ["/Applications/Safari.app/Contents/MacOS/Safari"],
});
expect(lock).not.toBeNull();
await lock?.release();
await expectGatewayLock(lock).release();
connectSpy.mockRestore();
});