pjandro/OmniRoute
1
0
Fork 0
mirror of https://github.com/diegosouzapw/OmniRoute.git synced 2026-07-31 04:12:10 +03:00
Code Issues Packages Projects Releases Wiki Activity

test: fix typescript compilation errors in unit tests

Browse Source
This commit is contained in:
diegosouzapw
2026-04-28 14:45:03 -03:00
parent 5c42f16995
commit cd3074b2d1
2 changed files with 18 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
tests/unit/executor-codex.test.ts
View File

@@ -24,7 +24,7 @@ test.afterEach(() => {
__setCodexWebSocketTransportForTesting(undefined);
});
async function withEnv(entries, fn) {
async function withEnv(entries: Record<string, string | undefined>, fn: () => any) {
const previous = new Map();
for (const [key, value] of Object.entries(entries)) {
@@ -379,7 +379,7 @@ test("CodexExecutor.execute falls back to HTTP when websocket transport is unava
// When WS transport is unavailable, isCodexResponsesWebSocketRequired returns false
// and the executor falls back to HTTP via super.execute()
assert.equal(result.response.status, 200);
assert.equal(result.transformedBody.model, "gpt-5.5");
assert.equal((result.transformedBody as any).model, "gpt-5.5");
} finally {
globalThis.fetch = originalFetch;
}

25
tests/unit/responses-handler.test.ts
View File

@@ -21,7 +21,7 @@ function noopLog() {
};
}
function toPlainHeaders(headers) {
function toPlainHeaders(headers: any) {
if (!headers) return {};
if (headers instanceof Headers) return Object.fromEntries(headers.entries());
return Object.fromEntries(
@@ -55,7 +55,7 @@ function buildOpenAISseResponse(text = "hello") {
);
}
function buildJsonResponse(status, payload) {
function buildJsonResponse(status: number, payload: any) {
return new Response(JSON.stringify(payload), {
status,
headers: { "Content-Type": "application/json" },
@@ -75,8 +75,15 @@ async function invokeResponsesCore({
credentials,
responseFactory,
signal,
}: {
body?: any;
provider?: string;
model?: string;
credentials?: any;
responseFactory?: any;
signal?: AbortSignal;
} = {}) {
const calls = [];
const calls: any[] = [];
globalThis.fetch = async (url, init = {}) => {
const call = {
@@ -263,10 +270,10 @@ test("handleResponsesCore rejects invalid Responses API input that cannot be tra
test("handleResponsesCore injects SSE keepalive comments for Responses streams", async () => {
const originalSetInterval = globalThis.setInterval;
const originalClearInterval = globalThis.clearInterval;
const intervals = [];
const intervals: any[] = [];
let nextId = 0;
globalThis.setInterval = (callback, delay = 0, ...args) => {
(globalThis as any).setInterval = (callback: any, delay = 0, ...args: any[]) => {
const interval = {
id: ++nextId,
callback,
@@ -278,7 +285,7 @@ test("handleResponsesCore injects SSE keepalive comments for Responses streams",
return interval;
};
globalThis.clearInterval = (interval) => {
(globalThis as any).clearInterval = (interval: any) => {
if (interval && typeof interval === "object") {
interval.cleared = true;
}
@@ -312,10 +319,10 @@ test("handleResponsesCore injects SSE keepalive comments for Responses streams",
test("handleResponsesCore clears heartbeat timers immediately when the request signal aborts", async () => {
const originalSetInterval = globalThis.setInterval;
const originalClearInterval = globalThis.clearInterval;
const intervals = [];
const intervals: any[] = [];
let nextId = 0;
globalThis.setInterval = (callback, delay = 0, ...args) => {
(globalThis as any).setInterval = (callback: any, delay = 0, ...args: any[]) => {
const interval = {
id: ++nextId,
callback,
@@ -327,7 +334,7 @@ test("handleResponsesCore clears heartbeat timers immediately when the request s
return interval;
};
globalThis.clearInterval = (interval) => {
(globalThis as any).clearInterval = (interval: any) => {
if (interval && typeof interval === "object") {
interval.cleared = true;
}