vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 15:50:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(matrix): mock runtime fetch seam

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-17 17:31:54 +01:00
parent 769198e67e
commit 8caad53f57
1 changed files with 23 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
extensions/matrix/src/matrix/sdk.test.ts
View File

@@ -18,6 +18,21 @@ function requestUrl(input: RequestInfo | URL | undefined): string {
return input.url; return input.url;
} }
const TEST_UNDICI_RUNTIME_DEPS_KEY = "__OPENCLAW_TEST_UNDICI_RUNTIME_DEPS__";
function clearTestUndiciRuntimeDepsOverride(): void {
Reflect.deleteProperty(globalThis as object, TEST_UNDICI_RUNTIME_DEPS_KEY);
}
function stubRuntimeFetch(fetchImpl: typeof fetch): void {
(globalThis as Record<string, unknown>)[TEST_UNDICI_RUNTIME_DEPS_KEY] = {
Agent: function MockAgent() {},
EnvHttpProxyAgent: function MockEnvHttpProxyAgent() {},
ProxyAgent: function MockProxyAgent() {},
fetch: fetchImpl,
};
}
class FakeMatrixEvent extends EventEmitter { class FakeMatrixEvent extends EventEmitter {
private readonly roomId: string; private readonly roomId: string;
private readonly eventId: string; private readonly eventId: string;
@@ -224,11 +239,13 @@ describe("MatrixClient request hardening", () => {
lastCreateClientOpts = null; lastCreateClientOpts = null;
vi.useRealTimers(); vi.useRealTimers();
vi.unstubAllGlobals(); vi.unstubAllGlobals();
clearTestUndiciRuntimeDepsOverride();
}); });
afterEach(() => { afterEach(() => {
vi.useRealTimers(); vi.useRealTimers();
vi.unstubAllGlobals(); vi.unstubAllGlobals();
clearTestUndiciRuntimeDepsOverride();
}); });
it("blocks absolute endpoints unless explicitly allowed", async () => { it("blocks absolute endpoints unless explicitly allowed", async () => {
@@ -238,7 +255,7 @@ describe("MatrixClient request hardening", () => {
headers: { "content-type": "application/json" }, headers: { "content-type": "application/json" },
}); });
}); });
vi.stubGlobal("fetch", fetchMock as unknown as typeof fetch); stubRuntimeFetch(fetchMock as unknown as typeof fetch);
const client = new MatrixClient("https://matrix.example.org", "token"); const client = new MatrixClient("https://matrix.example.org", "token");
await expect(client.doRequest("GET", "https://matrix.example.org/start")).rejects.toThrow( await expect(client.doRequest("GET", "https://matrix.example.org/start")).rejects.toThrow(
@@ -265,7 +282,7 @@ describe("MatrixClient request hardening", () => {
const fetchMock = vi.fn<(input: RequestInfo | URL, init?: RequestInit) => Promise<Response>>( const fetchMock = vi.fn<(input: RequestInfo | URL, init?: RequestInit) => Promise<Response>>(
async () => new Response(payload, { status: 200 }), async () => new Response(payload, { status: 200 }),
); );
vi.stubGlobal("fetch", fetchMock as unknown as typeof fetch); stubRuntimeFetch(fetchMock as unknown as typeof fetch);
const client = new MatrixClient("http://127.0.0.1:8008", "token", { const client = new MatrixClient("http://127.0.0.1:8008", "token", {
ssrfPolicy: { allowPrivateNetwork: true }, ssrfPolicy: { allowPrivateNetwork: true },
@@ -296,7 +313,7 @@ describe("MatrixClient request hardening", () => {
} }
return new Response(payload, { status: 200 }); return new Response(payload, { status: 200 });
}); });
vi.stubGlobal("fetch", fetchMock as unknown as typeof fetch); stubRuntimeFetch(fetchMock as unknown as typeof fetch);
const client = new MatrixClient("http://127.0.0.1:8008", "token", { const client = new MatrixClient("http://127.0.0.1:8008", "token", {
ssrfPolicy: { allowPrivateNetwork: true }, ssrfPolicy: { allowPrivateNetwork: true },
@@ -475,7 +492,7 @@ describe("MatrixClient request hardening", () => {
}, },
}); });
}); });
vi.stubGlobal("fetch", fetchMock as unknown as typeof fetch); stubRuntimeFetch(fetchMock as unknown as typeof fetch);
const client = new MatrixClient("http://127.0.0.1:8008", "token", { const client = new MatrixClient("http://127.0.0.1:8008", "token", {
ssrfPolicy: { allowPrivateNetwork: true }, ssrfPolicy: { allowPrivateNetwork: true },
@@ -506,7 +523,7 @@ describe("MatrixClient request hardening", () => {
headers: { "content-type": "application/json" }, headers: { "content-type": "application/json" },
}); });
}); });
vi.stubGlobal("fetch", fetchMock as unknown as typeof fetch); stubRuntimeFetch(fetchMock as unknown as typeof fetch);
const client = new MatrixClient("http://127.0.0.1:8008", "token", { const client = new MatrixClient("http://127.0.0.1:8008", "token", {
ssrfPolicy: { allowPrivateNetwork: true }, ssrfPolicy: { allowPrivateNetwork: true },
@@ -531,7 +548,7 @@ describe("MatrixClient request hardening", () => {
}); });
}); });
}); });
vi.stubGlobal("fetch", fetchMock as unknown as typeof fetch); stubRuntimeFetch(fetchMock as unknown as typeof fetch);
const client = new MatrixClient("http://127.0.0.1:8008", "token", { const client = new MatrixClient("http://127.0.0.1:8008", "token", {
localTimeoutMs: 25, localTimeoutMs: 25,