import { MAX_TIMER_TIMEOUT_MS } from "openclaw/plugin-sdk/number-runtime";

import { afterEach, describe, expect, it, vi } from "vitest";

import { createSequentialQueue } from "./sequential-queue.js";

await stuck;

});

it("clamps oversized task timeouts before scheduling", async () => {

vi.useFakeTimers();

const setTimeoutSpy = vi.spyOn(globalThis, "setTimeout");

const enqueue = createSequentialQueue({

taskTimeoutMs: Number.MAX_SAFE_INTEGER,

});

const gate = createDeferred();

const first = enqueue("feishu:default:chat-large-timeout", async () => {

await gate.promise;

});

await Promise.resolve();

expect(setTimeoutSpy).toHaveBeenCalledWith(expect.any(Function), MAX_TIMER_TIMEOUT_MS);

gate.resolve();

await first;

});

it("disables the timeout cap when taskTimeoutMs is 0 (legacy behavior)", async () => {

vi.useFakeTimers();

const timeouts: Array<{ key: string; timeoutMs: number }> = [];

import { resolveTimerTimeoutMs } from "openclaw/plugin-sdk/number-runtime";

/**

* Per-key serial task queue for Feishu inbound message handling.

*

if (!Number.isFinite(timeoutMs) || timeoutMs <= 0) {

return task();

}

const resolvedTimeoutMs = resolveTimerTimeoutMs(timeoutMs, DEFAULT_TASK_TIMEOUT_MS);

let timeoutHandle: ReturnType<typeof setTimeout> | undefined;

const timeoutPromise = new Promise<void>((resolve) => {

timeoutHandle = setTimeout(() => {

try {

onTaskTimeout?.(key, timeoutMs);

onTaskTimeout?.(key, resolvedTimeoutMs);

} catch {

// Swallow logging errors so they cannot poison the queue chain.

}

resolve();

}, timeoutMs);

}, resolvedTimeoutMs);

});

try {

await Promise.race([task(), timeoutPromise]);