vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-06 06:41:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: use runtime plugin state in test setup

Browse Source
This commit is contained in:
Shakker
2026-04-01 15:18:19 +01:00
committed by Shakker
parent a764b8f8cd
commit a898cd464a
1 changed files with 5 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
test/setup-openclaw-runtime.ts
View File

@@ -6,6 +6,7 @@ import type {
} from "../src/channels/plugins/types.js";
import type { OpenClawConfig } from "../src/config/config.js";
import type { OutboundSendDeps } from "../src/infra/outbound/deliver.js";
import { resetPluginRuntimeStateForTest, setActivePluginRegistry } from "../src/plugins/runtime.js";
import type { PluginRegistry } from "../src/plugins/registry.js";
import { installSharedTestSetup } from "./setup.shared.js";
@@ -27,38 +28,13 @@ const [
import("../src/test-utils/session-state-cleanup.js"),
]);
const REGISTRY_STATE = Symbol.for("openclaw.pluginRegistryState");
const WORKER_RUNTIME_STATE = Symbol.for("openclaw.testSetupRuntimeState");
type RegistryState = {
registry: PluginRegistry | null;
httpRouteRegistry: PluginRegistry | null;
httpRouteRegistryPinned: boolean;
key: string | null;
version: number;
};
type WorkerRuntimeState = {
defaultPluginRegistry: PluginRegistry | null;
materializedDefaultPluginRegistry: PluginRegistry | null;
};
const globalRegistryState = (() => {
const globalState = globalThis as typeof globalThis & {
[REGISTRY_STATE]?: RegistryState;
};
if (!globalState[REGISTRY_STATE]) {
globalState[REGISTRY_STATE] = {
registry: null,
httpRouteRegistry: null,
httpRouteRegistryPinned: false,
key: null,
version: 0,
};
}
return globalState[REGISTRY_STATE];
})();
const workerRuntimeState = (() => {
const globalState = globalThis as typeof globalThis & {
[WORKER_RUNTIME_STATE]?: WorkerRuntimeState;
@@ -289,11 +265,9 @@ function resolveDefaultPluginRegistryProxy(): PluginRegistry {
}
function installDefaultPluginRegistry(): void {
const defaultRegistry = resolveDefaultPluginRegistryProxy();
globalRegistryState.registry = defaultRegistry;
if (!globalRegistryState.httpRouteRegistryPinned) {
globalRegistryState.httpRouteRegistry = defaultRegistry;
}
workerRuntimeState.materializedDefaultPluginRegistry = null;
resetPluginRuntimeStateForTest();
setActivePluginRegistry(resolveDefaultPluginRegistryProxy());
}
beforeAll(() => {
@@ -305,11 +279,7 @@ afterEach(async () => {
resetContextWindowCacheForTest();
resetModelsJsonReadyCacheForTest();
resetSessionWriteLockStateForTest();
if (globalRegistryState.registry !== resolveDefaultPluginRegistryProxy()) {
installDefaultPluginRegistry();
globalRegistryState.key = null;
globalRegistryState.version += 1;
}
installDefaultPluginRegistry();
});
afterAll(async () => {