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

import { resolveMatrixQaNoReplyWindowMs } from "./scenario-runtime-shared.js";

describe("matrix scenario runtime shared", () => {

afterEach(() => {

vi.unstubAllEnvs();

});

it("normalizes the Matrix QA no-reply window env", () => {

expect(resolveMatrixQaNoReplyWindowMs(30_000)).toBe(8_000);

vi.stubEnv("OPENCLAW_QA_MATRIX_NO_REPLY_WINDOW_MS", "12000");

expect(resolveMatrixQaNoReplyWindowMs(30_000)).toBe(12_000);

expect(resolveMatrixQaNoReplyWindowMs(5_000)).toBe(5_000);

for (const value of ["1e3", "0x1000", "1.5", "nope"]) {

vi.stubEnv("OPENCLAW_QA_MATRIX_NO_REPLY_WINDOW_MS", value);

expect(resolveMatrixQaNoReplyWindowMs(30_000)).toBe(8_000);

}

});

});

const NO_REPLY_WINDOW_ENV = "OPENCLAW_QA_MATRIX_NO_REPLY_WINDOW_MS";

export function resolveMatrixQaNoReplyWindowMs(timeoutMs: number) {

const raw = process.env[NO_REPLY_WINDOW_ENV];

const parsed = raw === undefined ? NO_REPLY_WINDOW_MS : Number(raw);

const windowMs = Number.isFinite(parsed) && parsed >= 1 ? Math.floor(parsed) : NO_REPLY_WINDOW_MS;

const raw = process.env[NO_REPLY_WINDOW_ENV]?.trim();

const parsed =

raw === undefined ? NO_REPLY_WINDOW_MS : /^\d+$/.test(raw) ? Number(raw) : Number.NaN;

const windowMs = Number.isSafeInteger(parsed) && parsed >= 1 ? parsed : NO_REPLY_WINDOW_MS;

return Math.min(windowMs, timeoutMs);

}