import type { OpenClawConfig } from "../config/types.openclaw.js";

import type { DiagnosticTraceContext } from "./diagnostic-trace-context.js";

import {

formatDiagnosticTraceparent,

type DiagnosticTraceContext,

} from "./diagnostic-trace-context.js";

import { isBlockedObjectKey } from "./prototype-keys.js";

export type DiagnosticSessionState = "idle" | "processing" | "waiting";

const MAX_ASYNC_DIAGNOSTIC_EVENTS = 10_000;

const DIAGNOSTIC_EVENTS_STATE_KEY = Symbol.for("openclaw.diagnosticEvents.state.v1");

const dispatchedTrustedDiagnosticMetadata = new WeakSet<object>();

const ASYNC_DIAGNOSTIC_EVENT_TYPES = new Set<DiagnosticEventPayload["type"]>([

"tool.execution.started",

"tool.execution.completed",

try {

for (const listener of state.listeners) {

try {

listener(cloneDiagnosticEventForListener(enriched), Object.freeze({ ...metadata }));

listener(

cloneDiagnosticEventForListener(enriched),

createDiagnosticMetadataForListener(metadata),

);

} catch (err) {

const errorMessage =

err instanceof Error

}

}

function createDiagnosticMetadataForListener(

metadata: DiagnosticEventMetadata,

): DiagnosticEventMetadata {

const listenerMetadata = Object.freeze({ ...metadata });

if (listenerMetadata.trusted) {

dispatchedTrustedDiagnosticMetadata.add(listenerMetadata);

}

return listenerMetadata;

}

function cloneDiagnosticEventForListener(event: DiagnosticEventPayload): DiagnosticEventPayload {

return deepFreezeDiagnosticValue(structuredClone(event)) as DiagnosticEventPayload;

}

});

}

export function formatDiagnosticTraceparentForPropagation(

event: { trace?: DiagnosticTraceContext },

metadata: DiagnosticEventMetadata,

): string | undefined {

if (!metadata.trusted || !dispatchedTrustedDiagnosticMetadata.has(metadata)) {

return undefined;

}

return formatDiagnosticTraceparent(event.trace);

}

export function resetDiagnosticEventsForTest(): void {

const state = getDiagnosticEventsState();

state.enabled = true;