src/context-engine/registry.test-support.ts

import { requireActivePluginRegistry } from "../plugins/runtime.js";
import { resolveGlobalSingleton } from "../shared/global-singleton.js";
import {
  clearPersistedContextEngineQuarantineForProcess,
  recordPersistedContextEngineQuarantine,
} from "./quarantine-health.js";

type ContextEngineRuntimeQuarantineForTests = {
  engineId: string;
  owner?: string;
  operation: string;
  reason: string;
  failedAt: Date;
};

type ContextEngineRegistryStateForTests = {
  quarantinedEngines: Map<string, ContextEngineRuntimeQuarantineForTests>;
};

const CONTEXT_ENGINE_REGISTRY_STATE = Symbol.for("openclaw.contextEngineRegistryState");

function getContextEngineRegistryStateForTests(): ContextEngineRegistryStateForTests {
  return resolveGlobalSingleton<ContextEngineRegistryStateForTests>(
    CONTEXT_ENGINE_REGISTRY_STATE,
    () => ({ quarantinedEngines: new Map() }),
  );
}

export function captureContextEngineRegistryStateForTests(): () => void {
  const state = getContextEngineRegistryStateForTests();
  const registry = requireActivePluginRegistry();
  const engines = new Map(registry.contextEngines);
  const quarantinedEngines = new Map(state.quarantinedEngines);

  return () => {
    registry.contextEngines.clear();
    for (const [engineId, registration] of engines) {
      registry.contextEngines.set(engineId, registration as never);
    }

    state.quarantinedEngines.clear();
    clearPersistedContextEngineQuarantineForProcess(undefined, process.pid);
    for (const [engineId, quarantine] of quarantinedEngines) {
      state.quarantinedEngines.set(engineId, quarantine);
      recordPersistedContextEngineQuarantine(quarantine);
    }
  };
}

export function resetContextEngineRuntimeQuarantineForTests(): void {
  const state = getContextEngineRegistryStateForTests();
  state.quarantinedEngines.clear();
  clearPersistedContextEngineQuarantineForProcess(undefined, process.pid);
}