try {

await waitForStartedAccount(started, "beta");

expect(started).toEqual(["alpha", "beta"]);

expect(started.filter((accountId) => accountId === "alpha")).toHaveLength(1);

expect(started.reduce((count, accountId) => count + (accountId === "alpha" ? 1 : 0), 0)).toBe(

1,

);

} finally {

releaseStartedBetaProbe();

abortController.abort();

};

};

const list = root.plugins.entries["file-transfer"].config.nodes.n1.allowReadPaths;

expect(list.filter((p) => p === "/tmp/x").length).toBe(1);

expect(list.reduce((count, p) => count + (p === "/tmp/x" ? 1 : 0), 0)).toBe(1);

});

});

WebSocketClosedBeforeOpenError,

} from "./monitor-websocket.js";

function countMatching<T>(items: readonly T[], predicate: (item: T) => boolean): number {

let count = 0;

for (const item of items) {

if (predicate(item)) {

count += 1;

}

}

return count;

}

class FakeWebSocket implements MattermostWebSocketLike {

public readonly sent: string[] = [];

public pingCalls = 0;

data: { token: "token" },

seq: 1,

});

expect(patches.filter((patch) => patch.connected === true)).toHaveLength(1);

expect(patches.filter((patch) => patch.connected === false)).toHaveLength(2);

expect(countMatching(patches, (patch) => patch.connected === true)).toBe(1);

expect(countMatching(patches, (patch) => patch.connected === false)).toBe(2);

});

it("dispatches reaction events to the reaction handler", async () => {

const fetchCallUrls = (fetchMock: ReturnType<typeof vi.fn>): string[] =>

fetchMock.mock.calls.map(([input]) => String(input));

const countFetchCallUrls = (fetchMock: ReturnType<typeof vi.fn>, suffix: string): number =>

fetchCallUrls(fetchMock).reduce((count, url) => count + (url.endsWith(suffix) ? 1 : 0), 0);

const expectDiscoveryCallCounts = (

fetchMock: ReturnType<typeof vi.fn>,

params: { tags: number; show: number },

) => {

const urls = fetchCallUrls(fetchMock);

expect(urls.filter((url) => url.endsWith("/api/tags"))).toHaveLength(params.tags);

expect(urls.filter((url) => url.endsWith("/api/show"))).toHaveLength(params.show);

expect(countFetchCallUrls(fetchMock, "/api/tags")).toBe(params.tags);

expect(countFetchCallUrls(fetchMock, "/api/show")).toBe(params.show);

};

async function withOllamaApiKey<T>(run: () => Promise<T>): Promise<T> {

env: { OLLAMA_API_KEY: "test-key" },

});

expect(fetchCallUrls(fetchMock).filter((url) => url.endsWith("/api/tags"))).toHaveLength(1);

expect(countFetchCallUrls(fetchMock, "/api/tags")).toBe(1);

// Native API strips /v1 suffix via resolveOllamaApiBase()

expect(provider?.baseUrl).toBe("http://192.168.20.14:11434");