import { resolveStorePath } from "../config/sessions/paths.js";

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

import { buildGatewayConnectionDetails, callGateway } from "../gateway/call.js";

import {

DEFAULT_CHANNEL_CONNECT_GRACE_MS,

DEFAULT_CHANNEL_STALE_EVENT_THRESHOLD_MS,

evaluateChannelHealth,

} from "../gateway/channel-health-policy.js";

import type { ChannelRuntimeSnapshot } from "../gateway/server-channel-runtime.types.js";

import { info } from "../globals.js";

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

return parts.join(" ");

};

function formatEventLoopHealthLine(summary: HealthSummary): string | null {

const eventLoop = summary.eventLoop;

if (!eventLoop) {

return null;

}

const state = eventLoop.degraded ? "degraded" : "ok";

const reasons = eventLoop.reasons.length > 0 ? ` reasons=${eventLoop.reasons.join(",")}` : "";

return `Gateway event loop: ${state}${reasons} max=${Math.round(

eventLoop.delayMaxMs,

)}ms p99=${Math.round(eventLoop.delayP99Ms)}ms util=${eventLoop.utilization} cpu=${

eventLoop.cpuCoreRatio

}`;

}

const resolveHeartbeatSummary = (cfg: OpenClawConfig, agentId: string) =>

resolveHeartbeatSummaryForAgent(cfg, agentId);

probe?: boolean;

includeSensitive?: boolean;

runtimeSnapshot?: ChannelRuntimeSnapshot;

eventLoop?: HealthSummary["eventLoop"];

}): Promise<HealthSummary> {

const timeoutMs = params?.timeoutMs;

const cfg = getRuntimeConfig();

if (lastProbeAt) {

snapshot.lastProbeAt = lastProbeAt;

}

const health = evaluateChannelHealth(snapshot, {

channelId: plugin.id,

now: Date.now(),

staleEventThresholdMs: DEFAULT_CHANNEL_STALE_EVENT_THRESHOLD_MS,

channelConnectGraceMs: DEFAULT_CHANNEL_CONNECT_GRACE_MS,

});

if (!health.healthy) {

snapshot.healthState = health.reason;

}

const summary = plugin.status?.buildChannelSummary

? await plugin.status.buildChannelSummary({

ok: true,

ts: Date.now(),

durationMs: Date.now() - start,

...(params?.eventLoop ? { eventLoop: params.eventLoop } : {}),

...(pluginHealth ? { plugins: pluginHealth } : {}),

channels,

channelOrder,

for (const line of channelLines) {

runtime.log(styleHealthChannelLine(line, rich));

}

const eventLoopLine = formatEventLoopHealthLine(summary);

if (eventLoopLine) {

runtime.log(styleHealthChannelLine(eventLoopLine, rich));

}

for (const plugin of displayPlugins) {

const channelSummary = summary.channels?.[plugin.id];

if (!channelSummary || channelSummary.linked !== true) {