import type { Command } from "commander";

import type { HealthSummary } from "../../commands/health.js";

import { formatGatewayTransportErrorJson } from "../../gateway/call.js";

import type { CostUsageSummary } from "../../infra/session-cost-usage.js";

import type {

DiagnosticStabilityBundle,

ReadDiagnosticStabilityBundleResult,

} from "../../logging/diagnostic-stability-bundle.js";

import {

normalizeDiagnosticStabilityQuery,

selectDiagnosticStabilitySnapshot,

type DiagnosticStabilityEventRecord,

type DiagnosticStabilitySnapshot,

} from "../../logging/diagnostic-stability.js";

import { createLazyImportLoader } from "../../shared/lazy-promise.js";

import { formatDocsLink } from "../../terminal/links.js";

import { colorize, isRich, theme } from "../../terminal/theme.js";

import { runCommandWithRuntime } from "../cli-utils.js";

import { inheritOptionFromParent } from "../command-options.js";

import { addGatewayServiceCommands } from "../daemon-cli/register-service-commands.js";

import { formatHelpExamples } from "../help-format.js";

import { withProgress } from "../progress.js";

import { callGatewayCli, gatewayCallOpts, type GatewayRpcOpts } from "./call.js";

import type { GatewayRpcOpts } from "./call.js";

import type { GatewayDiscoverOpts } from "./discover.js";

import {

dedupeBeacons,

parseDiscoverTimeoutMs,

pickBeaconHost,

pickGatewayPort,

renderBeaconLines,

} from "./discover.js";

import { addGatewayRunCommand } from "./run.js";

import { addGatewayRunCommand } from "./run-command.js";

const configModuleLoader = createLazyImportLoader(

() => import("../../config/read-best-effort-config.runtime.js"),

return daemonStatusGatherModuleLoader.load();

}

function runGatewayCommand(action: () => Promise<void>, label?: string, opts?: { json?: boolean }) {

return runCommandWithRuntime(defaultRuntime, action, (err) => {

function gatewayCallOpts(cmd: Command): Command {

return cmd

.option("--url <url>", "Gateway WebSocket URL (defaults to gateway.remote.url when configured)")

.option("--token <token>", "Gateway token (if required)")

.option("--password <password>", "Gateway password (password auth)")

.option("--timeout <ms>", "Timeout in ms", "10000")

.option("--expect-final", "Wait for final response (agent)", false)

.option("--json", "Output JSON", false);

}

async function callGatewayCli(method: string, opts: GatewayRpcOpts, params?: unknown) {

const mod = await import("./call.js");

return mod.callGatewayCli(method, opts, params);

}

async function runGatewayCommand(

action: () => Promise<void>,

label?: string,

opts?: { json?: boolean },

) {

try {

await action();

} catch (err) {

if (opts?.json) {

const { formatGatewayTransportErrorJson } = await import("../../gateway/call.js");

const payload = formatGatewayTransportErrorJson(err);

if (payload) {

defaultRuntime.writeJson(payload);

const message = String(err);

defaultRuntime.error(label ? `${label}: ${message}` : message);

defaultRuntime.exit(1);

});

}

}

function parseDaysOption(raw: unknown, fallback = 30): number {

.option("--output <path>", "Diagnostics export output .zip path")

.action(async (opts, command) => {

await runGatewayCommand(async () => {

const { normalizeDiagnosticStabilityQuery, selectDiagnosticStabilitySnapshot } =

await import("../../logging/diagnostic-stability.js");

const rpcOpts = resolveGatewayRpcOptions(opts, command);

const query = normalizeDiagnosticStabilityQuery(

{

{ readSourceConfigBestEffort },

{ discoverGatewayBeacons },

{ resolveWideAreaDiscoveryDomain },

{

dedupeBeacons,

parseDiscoverTimeoutMs,

pickBeaconHost,

pickGatewayPort,

renderBeaconLines,

},

{ withProgress },

] = await Promise.all([

loadConfigModule(),

loadBonjourDiscoveryModule(),

loadWideAreaDnsModule(),

import("./discover.js"),

import("../progress.js"),

]);

const cfg = await readSourceConfigBestEffort();

const wideAreaDomain = resolveWideAreaDiscoveryDomain({