url: string;

init?: RequestInit;

policy?: unknown;

signal?: AbortSignal;

timeoutMs?: number;

auditContext?: string;

};

);

});

it("passes caller abort signals at guard level when a timeout is present", async () => {

await withMockNdjsonFetch(

[

'{"model":"m","created_at":"t","message":{"role":"assistant","content":"ok"},"done":false}',

'{"model":"m","created_at":"t","message":{"role":"assistant","content":""},"done":true,"prompt_eval_count":1,"eval_count":1}',

],

async (fetchMock) => {

const signal = new AbortController().signal;

const stream = await createOllamaTestStream({

baseUrl: "http://ollama-host:11434",

options: { signal, timeoutMs: 123_456 },

});

await collectStreamEvents(stream);

const request = getGuardedFetchCall(fetchMock);

expect(request.timeoutMs).toBe(123_456);

expect(request.signal).toBe(signal);

expect(request.init?.signal).toBeUndefined();

},

);

});

it("maps native Ollama max thinking to think=high on the wire", async () => {

await withMockNdjsonFetch(

[

maxTokens?: number;

temperature?: number;

signal?: AbortSignal;

timeoutMs?: number;

headers?: Record<string, string>;

};

}) {

const request = getGuardedFetchCall(fetchMock);

expect(request.url).toBe("http://ollama-host:11434/api/chat");

expect(request.auditContext).toBe("ollama-stream.chat");

expect(request.signal).toBe(signal);

const requestInit = request.init ?? {};

expect(requestInit.signal).toBe(signal);

expect(requestInit.signal).toBeUndefined();

if (typeof requestInit.body !== "string") {

throw new Error("Expected string request body");

}