// Active session shutdown tracker.

// Remembers sessions needing `session_end` hooks during gateway shutdown/restart.

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

// Module-level tracker of sessions that have received `session_start` but not

}

export function listActiveSessionsForShutdown(): ActiveSessionForShutdown[] {

// Return a snapshot, not the backing map, so shutdown drains can iterate while

// lifecycle hooks concurrently forget finalized sessions.

return Array.from(trackedSessions.values());

}

// Gateway assistant-event text extractor.

// Normalizes provider stream event shapes into a display text delta.

import type { AgentEventPayload } from "../infra/agent-events.js";

// Agent stream events may carry assistant text as either incremental delta or

// Gateway channel health policy.

// Evaluates channel lifecycle snapshots for restart/readiness decisions.

import type { ChannelId } from "../channels/plugins/types.public.js";

type ChannelHealthSnapshot = {

snapshot: ChannelHealthSnapshot,

evaluation: ChannelHealthEvaluation,

): ChannelRestartReason {

// Restart reasons are intentionally coarse: downstream logs/UI need stable

// categories, while detailed channel state stays in the health snapshot.

if (evaluation.reason === "stale-socket") {

return "stale-socket";

}

// Gateway chat display sanitizer.

// Removes OpenClaw-only envelopes before messages are shown in UI/RPC results.

import { normalizeLowercaseStringOrEmpty } from "@openclaw/normalization-core/string-coerce";

import {

stripInternalMetadataForDisplay,

export { stripEnvelope };

function extractMessageSenderLabel(entry: Record<string, unknown>): string | null {

// Sender labels can be explicit fields or embedded in text/envelope content.

// Preserve the first label found so user-origin rows keep human context.

if (typeof entry.senderLabel === "string" && entry.senderLabel.trim()) {

return entry.senderLabel.trim();

}

// Server-side gateway client readiness adapter.

// Defers client start until the shared event-loop readiness probe succeeds.

import type {

GatewayClientStartable,

GatewayClientStartReadinessOptions,

// Gateway method authorization scope resolver.

// Maps static and plugin-defined gateway methods to operator scopes.

import { normalizeOptionalString as normalizeSessionActionParam } from "@openclaw/normalization-core/string-coerce";

import { getPluginRegistryState } from "../plugins/runtime-state.js";

import { resolveReservedGatewayMethodScope } from "../shared/gateway-method-policy.js";

return undefined;

}

const requiredScopes = registration.action.requiredScopes;

// Registered session actions default to write scope when they omit a custom

// requirement; this preserves the historical mutation boundary.

return requiredScopes && requiredScopes.length > 0 ? [...requiredScopes] : [WRITE_SCOPE];

}

// Plugin/channel activation config merge helpers.

// Carries activation enablement into runtime config without copying stale state.

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

import { isRecord } from "../utils.js";

// Gateway restart timing trace helpers.

// Emits opt-in restart handoff diagnostics with bounded metric formatting.

import { performance } from "node:perf_hooks";

import { isTruthyEnvValue } from "../infra/env.js";

import { createSubsystemLogger } from "../logging/subsystem.js";

}

function formatMetricKey(key: string): string {

// Metric keys are log tokens, not structured JSON. Keep them compact and

// shell-friendly so trace lines remain grepable.

const normalized = key.replace(/[^A-Za-z0-9]/gu, "");

if (!normalized) {

return "metric";

}

function normalizeRestartTraceHandoff(value: unknown): GatewayRestartTraceHandoff | null {

// Handoff values come from another process. Reject stale/future values so a

// reused shell environment cannot poison later restart measurements.

if (typeof value !== "object" || value === null || Array.isArray(value)) {

return null;

}