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);

});

}

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);

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,

readProcessCmdline: () => ["openclaw", "gateway", "run"],

});

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 () => {

pollIntervalMs: 5,

platform: "linux",

});

expect(lock).not.toBeNull();

const acquiredLock = expectGatewayLock(lock);

await lock?.release();

await acquiredLock.release();

spy.mockRestore();

});

platform: "darwin",

port: 18789,

});

expect(lock).not.toBeNull();

await lock?.release();

await expectGatewayLock(lock).release();

connectSpy.mockRestore();

});

port: 18789,

readProcessCmdline: () => ["chrome.exe", "--no-sandbox"],

});

expect(lock).not.toBeNull();

await lock?.release();

await expectGatewayLock(lock).release();

connectSpy.mockRestore();

});

port: 18789,

readProcessCmdline: () => ["/Applications/Safari.app/Contents/MacOS/Safari"],

});

expect(lock).not.toBeNull();

await lock?.release();

await expectGatewayLock(lock).release();

connectSpy.mockRestore();

});