GameCult/Heimdall
Watch
9
0
Fork
You've already forked Heimdall
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

Tests: a late decider still queues behind the one waiting on the in-memory chain

Browse source 
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-10-19 11:52:27 +02:00
commit 34a8c6a81d
1 changed files with 17 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

17
tests/managed-credential.test.ts
View file

@ -532,6 +532,23 @@ for (const { kind, live } of rigKinds) describe.skipIf(live && !adminUrl)(`manag
}
});
it.runIf(!live)("a decider arriving after the first drains still waits for the one queued behind it", async () => {
const rig = await makeRig("twitch");
const events: string[] = [];
const decider = (name: string, ms: number) => async (locked: StoredLinkedIdentity) => {
events.push(`start ${name}`);
await sleep(ms);
events.push(`end ${name}`);
return { kind: "keep" as const, seen: locked };
};
const a = rig.stores[0]!.updateLinkedIdentityCredential(rig.identityId, decider("A", 20));
const b = rig.stores[0]!.updateLinkedIdentityCredential(rig.identityId, decider("B", 120));
await a;
const c = rig.stores[0]!.updateLinkedIdentityCredential(rig.identityId, decider("C", 1));
await Promise.all([b, c]);
expect(events).toEqual(["start A", "end A", "start B", "end B", "start C", "end C"]);
});
it.runIf(!live)("drops a drained row's chain entry", async () => {
const rig = await makeRig("twitch");
await Promise.all([1, 2, 3].map(() => rig.stores[0]!.updateLinkedIdentityCredential(rig.identityId, async () => ({ kind: "keep" }))));