import * as fetchModule from "openclaw/plugin-sdk/fetch-runtime";

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

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

import {

containerCheck,

throw new Error("expected fetch call to include an abort signal");

}

});

it("caps oversized REST request timeouts before arming abort timers", async () => {

const timeoutSpy = vi

.spyOn(globalThis, "setTimeout")

.mockReturnValue(0 as unknown as ReturnType<typeof setTimeout>);

try {

mockFetch.mockResolvedValue({

ok: true,

status: 200,

text: async () => "{}",

});

await containerRestRequest("/v1/about", {

baseUrl: "http://localhost:8080",

timeoutMs: Number.MAX_SAFE_INTEGER,

});

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

expect(requireFetchCall()[1].signal).toBeInstanceOf(AbortSignal);

} finally {

timeoutSpy.mockRestore();

}

});

});

describe("containerSendMessage", () => {

import nodePath from "node:path";

import { resolveFetch } from "openclaw/plugin-sdk/fetch-runtime";

import { detectMime, parseMediaContentLength } from "openclaw/plugin-sdk/media-runtime";

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

import {

parseStrictNonNegativeInteger,

resolveTimerTimeoutMs,

} from "openclaw/plugin-sdk/number-runtime";

import { readResponseWithLimit } from "openclaw/plugin-sdk/response-limit-runtime";

import WebSocket from "ws";

if (!fetchImpl) {

throw new Error("fetch is not available");

}

const safeTimeoutMs = resolveTimerTimeoutMs(timeoutMs, DEFAULT_TIMEOUT_MS);

const controller = new AbortController();

const timer = setTimeout(() => controller.abort(), timeoutMs);

const timer = setTimeout(() => controller.abort(), safeTimeoutMs);

try {

return await fetchImpl(url, { ...init, signal: controller.signal });

} finally {

): Promise<{ ok: boolean; status?: number | null; error?: string | null }> {

const wsUrl = `${normalizedBaseUrl.replace(/^http/, "ws")}/v1/receive/${encodeURIComponent(account)}`;

return new Promise((resolve) => {

const safeTimeoutMs = resolveTimerTimeoutMs(timeoutMs, DEFAULT_TIMEOUT_MS);

let settled = false;

let ws: WebSocket | undefined;

const timer = setTimeout(() => {

settle({ ok: false, status: null, error: "Signal container receive WebSocket timed out" });

ws?.terminate();

}, timeoutMs);

}, safeTimeoutMs);

timer.unref?.();

const settle = (result: { ok: boolean; status?: number | null; error?: string | null }) => {

if (settled) {