wehub-resource-sync
49 lines
1.7 KiB
TypeScript
49 lines
1.7 KiB
TypeScript
import { test, after } from "node:test";
|
|
import assert from "node:assert/strict";
|
|
import { startFaultyUpstream } from "../helpers/faultyUpstream.ts";
|
|
|
|
test("ok mode returns 200 with body", async () => {
|
|
const up = await startFaultyUpstream({ kind: "ok", body: "hello" });
|
|
after(() => up.stop());
|
|
const res = await fetch(up.url);
|
|
assert.equal(res.status, 200);
|
|
assert.equal(await res.text(), "hello");
|
|
await up.stop();
|
|
});
|
|
|
|
test("status mode returns the given HTTP error code", async () => {
|
|
const up = await startFaultyUpstream({ kind: "status", code: 503, body: "down" });
|
|
const res = await fetch(up.url);
|
|
assert.equal(res.status, 503);
|
|
assert.equal(await res.text(), "down");
|
|
await up.stop();
|
|
});
|
|
|
|
test("latency mode delays the response", async () => {
|
|
const up = await startFaultyUpstream({ kind: "latency", ms: 120, body: "slow" });
|
|
const t0 = Date.now();
|
|
await (await fetch(up.url)).text();
|
|
assert.ok(Date.now() - t0 >= 100, "should be delayed ~120ms");
|
|
await up.stop();
|
|
});
|
|
|
|
test("reset mode destroys the socket (fetch rejects)", async () => {
|
|
const up = await startFaultyUpstream({ kind: "reset" });
|
|
await assert.rejects(() => fetch(up.url).then((r) => r.text()));
|
|
await up.stop();
|
|
});
|
|
|
|
test("timeout mode never responds (AbortSignal aborts)", async () => {
|
|
const up = await startFaultyUpstream({ kind: "timeout" });
|
|
await assert.rejects(() => fetch(up.url, { signal: AbortSignal.timeout(120) }));
|
|
await up.stop();
|
|
});
|
|
|
|
test("setMode switches behavior on a running server", async () => {
|
|
const up = await startFaultyUpstream({ kind: "ok", body: "a" });
|
|
up.setMode({ kind: "status", code: 429, body: "rl" });
|
|
const res = await fetch(up.url);
|
|
assert.equal(res.status, 429);
|
|
await up.stop();
|
|
});
|