wehub-resource-sync
59 lines
1.5 KiB
TypeScript
59 lines
1.5 KiB
TypeScript
import test from "node:test";
|
|
import assert from "node:assert/strict";
|
|
|
|
import { emitUsageRecorded, onUsageRecorded } from "../../src/lib/usage/usageEvents.ts";
|
|
|
|
test("emitUsageRecorded delivers provider + connectionId to subscribers", () => {
|
|
const seen: Array<[string, string]> = [];
|
|
const off = onUsageRecorded((provider, connectionId) => seen.push([provider, connectionId]));
|
|
try {
|
|
emitUsageRecorded("antigravity", "conn-1");
|
|
assert.deepEqual(seen, [["antigravity", "conn-1"]]);
|
|
} finally {
|
|
off();
|
|
}
|
|
});
|
|
|
|
test("emitUsageRecorded no-ops when provider or connectionId is missing", () => {
|
|
let calls = 0;
|
|
const off = onUsageRecorded(() => {
|
|
calls += 1;
|
|
});
|
|
try {
|
|
emitUsageRecorded(null, "conn-1");
|
|
emitUsageRecorded("agy", "");
|
|
emitUsageRecorded(undefined, undefined);
|
|
assert.equal(calls, 0);
|
|
} finally {
|
|
off();
|
|
}
|
|
});
|
|
|
|
test("onUsageRecorded unsubscribe stops further delivery", () => {
|
|
let calls = 0;
|
|
const off = onUsageRecorded(() => {
|
|
calls += 1;
|
|
});
|
|
emitUsageRecorded("agy", "conn-2");
|
|
off();
|
|
emitUsageRecorded("agy", "conn-2");
|
|
assert.equal(calls, 1);
|
|
});
|
|
|
|
test("a throwing listener does not break emit for others", () => {
|
|
let reached = false;
|
|
const offBad = onUsageRecorded(() => {
|
|
throw new Error("boom");
|
|
});
|
|
const offGood = onUsageRecorded(() => {
|
|
reached = true;
|
|
});
|
|
try {
|
|
assert.doesNotThrow(() => emitUsageRecorded("antigravity", "conn-3"));
|
|
assert.equal(reached, true);
|
|
} finally {
|
|
offBad();
|
|
offGood();
|
|
}
|
|
});
|