fix(infra): share diagnostic event state across loaders · openclaw/openclaw@d623354

Recent Commits to openclaw:main

steipete · 2026-04-26 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -147,7 +147,24 @@ describe("diagnostic-events", () => {`
`147`	`147`	`]);`
`148`	`148`	`});`
`149`	`149`
`150`		`-it("does not expose mutable diagnostic state on a global symbol", async () => {`
	`150`	`+it("shares diagnostic state across duplicate module instances", async () => {`
	`151`	`+const events: string[] = [];`
	`152`	`+onDiagnosticEvent((event) => {`
	`153`	`+events.push(event.type);`
	`154`	`+});`
	`155`	`+`
	`156`	`+vi.resetModules();`
	`157`	`+const specifier = "./diagnostic-events.js";`
	`158`	`+const duplicateModule = (await import(specifier)) as typeof import("./diagnostic-events.js");`
	`159`	`+duplicateModule.emitDiagnosticEvent({`
	`160`	`+type: "message.queued",`
	`161`	`+source: "plugin",`
	`162`	`+});`
	`163`	`+`
	`164`	`+expect(events).toEqual(["message.queued"]);`
	`165`	`+});`
	`166`	`+`
	`167`	`+it("does not expose mutable diagnostic state on the obsolete global symbol", async () => {`
`151`	`168`	`const globalStore = globalThis as Record<PropertyKey, unknown>;`
`152`	`169`	`const events: boolean[] = [];`
`153`	`170`	`globalStore[Symbol.for("openclaw.diagnosticEventsState")] = {`

Original file line number	Diff line number	Diff line change
`@@ -404,14 +404,49 @@ const ASYNC_DIAGNOSTIC_EVENT_TYPES = new Set<DiagnosticEventPayload["type"]>([`
`404`	`404`	`"log.record",`
`405`	`405`	`]);`
`406`	`406`
`407`		`-const diagnosticEventsState: DiagnosticEventsGlobalState = {`
`408`		`-enabled: true,`
`409`		`-seq: 0,`
`410`		`-listeners: new Set<DiagnosticEventListener>(),`
`411`		`-dispatchDepth: 0,`
`412`		`-asyncQueue: [],`
`413`		`-asyncDrainScheduled: false,`
`414`		`-};`
	`407`	`+const DIAGNOSTIC_EVENTS_STATE_KEY = Symbol.for("openclaw.diagnosticEvents.state.v1");`
	`408`	`+`
	`409`	`+function createDiagnosticEventsState(): DiagnosticEventsGlobalState {`
	`410`	`+return {`
	`411`	`+enabled: true,`
	`412`	`+seq: 0,`
	`413`	`+listeners: new Set<DiagnosticEventListener>(),`
	`414`	`+dispatchDepth: 0,`
	`415`	`+asyncQueue: [],`
	`416`	`+asyncDrainScheduled: false,`
	`417`	`+};`
	`418`	`+}`
	`419`	`+`
	`420`	`+function isDiagnosticEventsState(value: unknown): value is DiagnosticEventsGlobalState {`
	`421`	`+if (!value \|\| typeof value !== "object") {`
	`422`	`+return false;`
	`423`	`+}`
	`424`	`+const candidate = value as Partial<DiagnosticEventsGlobalState>;`
	`425`	`+return (`
	`426`	`+typeof candidate.enabled === "boolean" &&`
	`427`	`+typeof candidate.seq === "number" &&`
	`428`	`+candidate.listeners instanceof Set &&`
	`429`	`+typeof candidate.dispatchDepth === "number" &&`
	`430`	`+Array.isArray(candidate.asyncQueue) &&`
	`431`	`+typeof candidate.asyncDrainScheduled === "boolean"`
	`432`	`+);`
	`433`	`+}`
	`434`	`+`
	`435`	`+const diagnosticEventsState: DiagnosticEventsGlobalState = (() => {`
	`436`	`+const globalStore = globalThis as Record<PropertyKey, unknown>;`
	`437`	`+const existing = globalStore[DIAGNOSTIC_EVENTS_STATE_KEY];`
	`438`	`+if (isDiagnosticEventsState(existing)) {`
	`439`	`+return existing;`
	`440`	`+}`
	`441`	`+const created = createDiagnosticEventsState();`
	`442`	`+Object.defineProperty(globalStore, DIAGNOSTIC_EVENTS_STATE_KEY, {`
	`443`	`+configurable: true,`
	`444`	`+enumerable: false,`
	`445`	`+value: created,`
	`446`	`+writable: false,`
	`447`	`+});`
	`448`	`+return created;`
	`449`	`+})();`
`415`	`450`
`416`	`451`	`function getDiagnosticEventsState(): DiagnosticEventsGlobalState {`
`417`	`452`	`return diagnosticEventsState;`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main