OmniRoute/tests/unit/compression/compression-registry-clear.test.ts

import { describe, it } from "node:test";
import assert from "node:assert/strict";

import {
  registerBuiltinCompressionEngines,
  clearCompressionEngineRegistry,
  getCompressionEngine,
} from "../../../open-sse/services/compression/index.ts";

// F5.3: registerBuiltinCompressionEngines() guards on a module-level `registered` latch.
// clearCompressionEngineRegistry() empties the engine map but does NOT reset that latch, so
// a subsequent registerBuiltinCompressionEngines() no-ops and leaves the registry empty —
// any getCompressionEngine() then returns null. This file runs in its own process so the
// latch starts false (no cross-file interference).
describe("builtin compression engine registration after clear", () => {
  it("re-registers builtin engines after the registry is cleared", () => {
    registerBuiltinCompressionEngines();
    assert.ok(getCompressionEngine("rtk"), "builtins registered initially");

    clearCompressionEngineRegistry();
    assert.equal(getCompressionEngine("rtk"), null, "registry emptied by clear");

    // The `registered` latch must not block this re-registration.
    registerBuiltinCompressionEngines();
    assert.ok(getCompressionEngine("rtk"), "builtins must repopulate after a clear");
    assert.ok(getCompressionEngine("session-dedup"), "all builtins restored, not just one");
  });
});