const workspaceDir = "/tmp/openclaw-workspace";

beforeEach(() => {

vi.useRealTimers();

restoreCliRunnerTestDeps();

});

afterEach(() => {

vi.clearAllTimers();

vi.useRealTimers();

restoreCliRunnerTestDeps();

});

});

it("retries up to three times before giving up", async () => {

vi.useFakeTimers();

const probe = vi.fn(async () => false);

setCliRunnerTestDeps({ claudeCliSessionTranscriptHasContent: probe });

expect(await isCliBindingFlushed("sid-cold", "claude-cli", workspaceDir)).toBe(false);

const resultPromise = isCliBindingFlushed("sid-cold", "claude-cli", workspaceDir);

await vi.advanceTimersByTimeAsync(0);

await vi.advanceTimersByTimeAsync(50);

await vi.advanceTimersByTimeAsync(150);

await expect(resultPromise).resolves.toBe(false);

expect(probe).toHaveBeenCalledTimes(3);

});

it("succeeds when the transcript becomes visible on a later retry", async () => {

vi.useFakeTimers();

let calls = 0;

const probe = vi.fn(async () => {

calls += 1;

return calls >= 2;

});

setCliRunnerTestDeps({ claudeCliSessionTranscriptHasContent: probe });

expect(await isCliBindingFlushed("sid-late", "claude-cli", workspaceDir)).toBe(true);

const resultPromise = isCliBindingFlushed("sid-late", "claude-cli", workspaceDir);

await vi.advanceTimersByTimeAsync(0);

await vi.advanceTimersByTimeAsync(50);

await expect(resultPromise).resolves.toBe(true);

expect(probe).toHaveBeenCalledTimes(2);

});

expect(errored).not.toHaveBeenCalled();

expect(probe).toHaveBeenCalledTimes(3);

} finally {

vi.clearAllTimers();

vi.useRealTimers();

}

});

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

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

import type { OpenClawConfig } from "../config/types.openclaw.js";

import { MAX_TIMER_TIMEOUT_MS } from "../shared/number-coercion.js";

import { loadModelCatalogForBrowse } from "./model-catalog-browse.js";

}

describe("loadModelCatalogForBrowse", () => {

beforeEach(() => {

vi.useRealTimers();

});

afterEach(() => {

vi.clearAllTimers();

vi.useRealTimers();

});

});

it("returns an empty catalog when read-only catalog loading times out", async () => {

vi.useFakeTimers();

const onTimeout = vi.fn();

const loadCatalog = vi.fn(

() =>

onTimeout,

});

await vi.advanceTimersByTimeAsync(5);

await expect(resultPromise).resolves.toEqual([]);

expect(onTimeout).toHaveBeenCalledExactlyOnceWith(5);

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

await vi.advanceTimersByTimeAsync(10);

});

it("uses the default timeout when timeoutMs is non-finite", async () => {

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

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

import { MAX_TIMER_TIMEOUT_MS } from "../shared/number-coercion.js";

import { createTypingCallbacks } from "./typing.js";

try {

await run();

} finally {

vi.clearAllTimers();

vi.useRealTimers();

}

}

}

describe("createTypingCallbacks", () => {

beforeEach(() => {

vi.useRealTimers();

});

afterEach(() => {

vi.clearAllTimers();

vi.useRealTimers();

});

it("invokes start on reply start", async () => {

const { start, onStartError, callbacks } = createTypingHarness();

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

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

import type { MsgContext } from "../auto-reply/templating.js";

import type { OpenClawConfig } from "../config/types.js";

import { MIN_AUDIO_FILE_BYTES } from "./defaults.js";

}

describe("runCapability skips tiny audio files", () => {

beforeEach(() => {

vi.useRealTimers();

});

it("skips audio transcription when file is smaller than MIN_AUDIO_FILE_BYTES", async () => {

await withAudioFixture({

filePrefix: "openclaw-tiny-audio",

media,

cache,

transcribeAudio: async () => {

throw new Error("upstream 500");

throw Object.assign(new Error("HTTP 400 validation failed"), { status: 400 });

},

});

throw new Error("expected failed audio decision attempt");

}

expect(attempt.outcome).toBe("failed");

expect(attempt.reason).toContain("upstream 500");

expect(attempt.reason).toContain("HTTP 400 validation failed");

},

});

});