wehub-resource-sync
76 lines
3.3 KiB
TypeScript
76 lines
3.3 KiB
TypeScript
import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
|
|
import { BoundedTtlCache } from "~/services/realtime/boundedTtlCache";
|
|
import { computeRunIdMintKind, type RunIdMintKind } from "./runOpsMintKind.server";
|
|
|
|
// LOCK of the CURRENT (intentional) flip-latency behavior, NOT a change request.
|
|
// resolveRunIdMintKind caches the per-org mint kind in a process-singleton
|
|
// BoundedTtlCache (TTL RUN_OPS_MINT_FLAG_CACHE_TTL_MS, 30000ms default) with get/set
|
|
// and NO invalidation hook (runOpsMintKind.server.ts:38-45,56-81). So after a flag
|
|
// flip a process keeps minting the stale kind until its cached entry expires; in
|
|
// multi-instance prod each process expires independently. This suite reconstructs the
|
|
// same flag fn over a real cache and pins both edges of that window.
|
|
|
|
// Mirror of resolveRunIdMintKind's flag fn (runOpsMintKind.server.ts:56-81).
|
|
function makeCachedFlag(
|
|
cache: BoundedTtlCache<RunIdMintKind>,
|
|
liveFlag: () => RunIdMintKind
|
|
): (orgId: string) => Promise<RunIdMintKind> {
|
|
return async (orgId: string) => {
|
|
const cached = cache.get(orgId);
|
|
if (cached !== undefined) return cached;
|
|
const kind = liveFlag();
|
|
cache.set(orgId, kind);
|
|
return kind;
|
|
};
|
|
}
|
|
|
|
const TTL_MS = 30_000;
|
|
const env = { organizationId: "org_flip", id: "env_flip" };
|
|
|
|
describe("computeRunIdMintKind flip latency (mintCache TTL window — current behavior LOCK)", () => {
|
|
beforeEach(() => vi.useFakeTimers());
|
|
afterEach(() => vi.useRealTimers());
|
|
|
|
it("returns the STALE cached kind within the TTL after the flag flips 'cuid'->'runOpsId'", async () => {
|
|
const cache = new BoundedTtlCache<RunIdMintKind>(TTL_MS, 100);
|
|
let live: RunIdMintKind = "cuid";
|
|
const flag = makeCachedFlag(cache, () => live);
|
|
const deps = { masterEnabled: true, splitEnabled: async () => true, flag };
|
|
|
|
expect(await computeRunIdMintKind(env, deps)).toBe("cuid"); // populates the cache
|
|
|
|
live = "runOpsId"; // admin flips the org flag
|
|
vi.advanceTimersByTime(TTL_MS - 1); // still inside the window
|
|
expect(await computeRunIdMintKind(env, deps)).toBe("cuid"); // STALE, as designed
|
|
});
|
|
|
|
it("returns the FRESH kind once the TTL expires after a 'cuid'->'runOpsId' flip", async () => {
|
|
const cache = new BoundedTtlCache<RunIdMintKind>(TTL_MS, 100);
|
|
let live: RunIdMintKind = "cuid";
|
|
const flag = makeCachedFlag(cache, () => live);
|
|
const deps = { masterEnabled: true, splitEnabled: async () => true, flag };
|
|
|
|
expect(await computeRunIdMintKind(env, deps)).toBe("cuid");
|
|
|
|
live = "runOpsId";
|
|
vi.advanceTimersByTime(TTL_MS + 1); // past expiry -> entry evicted on read
|
|
expect(await computeRunIdMintKind(env, deps)).toBe("runOpsId"); // re-reads the live flag
|
|
});
|
|
|
|
it("symmetric flip-back 'runOpsId'->'cuid' is also stale within TTL, fresh after", async () => {
|
|
const cache = new BoundedTtlCache<RunIdMintKind>(TTL_MS, 100);
|
|
let live: RunIdMintKind = "runOpsId";
|
|
const flag = makeCachedFlag(cache, () => live);
|
|
const deps = { masterEnabled: true, splitEnabled: async () => true, flag };
|
|
|
|
expect(await computeRunIdMintKind(env, deps)).toBe("runOpsId");
|
|
|
|
live = "cuid";
|
|
vi.advanceTimersByTime(TTL_MS - 1);
|
|
expect(await computeRunIdMintKind(env, deps)).toBe("runOpsId"); // STALE
|
|
|
|
vi.advanceTimersByTime(2); // now past expiry
|
|
expect(await computeRunIdMintKind(env, deps)).toBe("cuid"); // FRESH
|
|
});
|
|
});
|