import { buildXiaomiSpeechProvider } from "./speech-provider.js";

const MAX_TIMER_TIMEOUT_MS = 2_147_000_000;

describe("buildXiaomiSpeechProvider", () => {

const provider = buildXiaomiSpeechProvider();

});

});

it("caps oversized TTS request timeouts before scheduling or fetching", async () => {

const audio = Buffer.from("fake-mp3-audio").toString("base64");

const timeoutSpy = vi

.spyOn(globalThis, "setTimeout")

.mockImplementation((() => 1) as typeof setTimeout);

const clearTimeoutSpy = vi

.spyOn(globalThis, "clearTimeout")

.mockImplementation(() => undefined);

vi.mocked(globalThis.fetch).mockResolvedValueOnce(

new Response(JSON.stringify({ choices: [{ message: { audio: { data: audio } } }] }), {

status: 200,

headers: { "Content-Type": "application/json" },

}),

);

try {

await provider.synthesize({

text: "Hello from OpenClaw.",

cfg: {} as never,

providerConfig: { apiKey: "sk-test" },

target: "audio-file",

timeoutMs: MAX_TIMER_TIMEOUT_MS + 1_000_000,

});

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

} finally {

timeoutSpy.mockRestore();

clearTimeoutSpy.mockRestore();

}

});

it("throws when API key is missing", async () => {

const savedKey = process.env.XIAOMI_API_KEY;

delete process.env.XIAOMI_API_KEY;

import { transcodeAudioBufferToOpus } from "openclaw/plugin-sdk/media-runtime";

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

import { assertOkOrThrowProviderError } from "openclaw/plugin-sdk/provider-http";

import { normalizeResolvedSecretInputString } from "openclaw/plugin-sdk/secret-input";

import type {

timeoutMs: number;

}): Promise<Buffer> {

const { text, apiKey, baseUrl, model, voice, format, style, timeoutMs } = params;

const requestTimeoutMs = resolveTimerTimeoutMs(timeoutMs, 1);

const controller = new AbortController();

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

const timeout = setTimeout(() => controller.abort(), requestTimeoutMs);

try {

const { response, release } = await fetchWithSsrFGuard({

}),

signal: controller.signal,

},

timeoutMs,

timeoutMs: requestTimeoutMs,

policy: ssrfPolicyFromHttpBaseUrlAllowedHostname(baseUrl),

auditContext: "xiaomi.tts",

});