import { EventEmitter } from "node:events";

import { mkdtemp, rm } from "node:fs/promises";

import { mkdtempSync, rmSync } from "node:fs";

import { tmpdir } from "node:os";

import path from "node:path";

import type { ChannelGatewayContext } from "openclaw/plugin-sdk/channel-contract";

kill = vi.fn(() => true);

}

const tempDirs = new Set<string>();

function makeTempDir(prefix: string): string {

// openclaw-temp-dir: allow extension tests cannot import root test helpers

const dir = mkdtempSync(path.join(tmpdir(), prefix));

tempDirs.add(dir);

return dir;

}

function createContext(accountId = "default") {

const status = {

accountId,

if (value !== undefined) {

return value;

}

await new Promise((resolve) => setTimeout(resolve, 5));

await new Promise<void>((resolve) => {

setTimeout(resolve, 5);

});

}

throw new Error("Timed out waiting for value.");

}

afterEach(() => {

resetPluginStateStoreForTests();

for (const dir of tempDirs) {

rmSync(dir, { force: true, recursive: true });

}

tempDirs.clear();

vi.restoreAllMocks();

});

settled = true;

});

await new Promise((resolve) => setTimeout(resolve, 0));

await new Promise<void>((resolve) => {

setTimeout(resolve, 0);

});

expect(settled).toBe(false);

expect(spawnBridge).not.toHaveBeenCalled();

body: JSON.stringify({ eventId: "wake-1", timestamp: 2 }),

}),

).resolves.toMatchObject({ status: 202 });

await new Promise((resolve) => setTimeout(resolve, 0));

await new Promise<void>((resolve) => {

setTimeout(resolve, 0);

});

expect(run).toHaveBeenCalledTimes(1);

await expect(

fetch(wakeEndpoint, {

});

it("persists accepted wake dedupe across restarts without crossing accounts", async () => {

const stateDir = await mkdtemp(path.join(tmpdir(), "openclaw-raft-wake-dedupe-"));

const stateDir = makeTempDir("openclaw-raft-wake-dedupe-");

try {

const first = createContext();

Object.defineProperty(first.ctx, "abortSignal", { value: first.controller.signal });

}

} finally {

resetPluginStateStoreForTests();

await rm(stateDir, { force: true, recursive: true });

}

});