import type {
  GatewayStatusPayload,
  OpenClawDeviceListPayload,
  StatusPayload
} from "@/lib/openclaw/client/gateway-client";
import { isDeferredPayloadResult } from "@/lib/openclaw/client/payload-cache";
import { getOpenClawGatewayOperationLabel } from "@/lib/openclaw/client/gateway-compatibility";
import { filterActiveOpenClawGatewayFallbackDiagnostics } from "@/lib/openclaw/client/gateway-diagnostic-activity";
import {
  collectIssues,
  compareVersionStrings,
  normalizeOptionalValue,
  normalizeUpdateError,
  resolveDiagnosticHealth,
  resolveUpdateInfo
} from "@/lib/openclaw/domains/control-plane-normalization";
import type {
  MissionControlSnapshot,
  ModelReadiness,
  OpenClawBinarySelection,
  OpenClawCapabilityMatrix,
  OpenClawCommandDiagnostic
} from "@/lib/openclaw/types";
import {
  buildRuntimeIssues,
  type RuntimeIssueState
} from "@/lib/openclaw/runtime-issues";
import {
  resolveOpenClawUpdateCompatibilitySnapshot,
  shouldShowDefaultOpenClawUpdate
} from "@/lib/openclaw/update-compatibility";
import type { OpenClawCompatibilityManifest } from "@/lib/openclaw/update-compatibility";

type PayloadReuseState = {
  reusedCachedValue: boolean;
};

export function buildSecurityWarnings(status: StatusPayload | undefined) {
  return (
    status?.securityAudit?.findings
      ?.filter((entry) => entry.severity === "warn")
      .map((entry) => entry.title || entry.detail || "Security warning") ?? []
  );
}

export function buildVersionDiagnostics(input: {
  status: StatusPayload | undefined;
  updateStatus?: Record<string, unknown>;
  updateStatusError?: string;
  fallbackVersion?: string;
}) {
  const updateStatusRecords = collectUpdateStatusRecords(input.updateStatus);
  const currentVersion =
    normalizeOptionalValue(
      input.status?.runtimeVersion ||
        input.status?.overview?.version ||
        input.status?.version
    ) ??
    readFirstOptionalString(updateStatusRecords, [
      "runningVersion",
      "currentVersion",
      "runtimeVersion",
      "version",
      "afterVersion"
    ]) ??
    input.fallbackVersion ??
    undefined;
  const latestVersion =
    normalizeOptionalValue(input.status?.update?.registry?.latestVersion ?? undefined) ??
    readFirstOptionalString(updateStatusRecords, [
      "latestVersion",
      "targetVersion",
      "availableVersion",
      "recommendedVersion"
    ]);
  const updateError =
    normalizeUpdateError(input.status?.update?.registry?.error ?? undefined) ??
    readUpdateStatusError(updateStatusRecords) ??
    normalizeUpdateError(input.updateStatusError);
  const updateAvailable =
    currentVersion && latestVersion
      ? compareVersionStrings(latestVersion, currentVersion) > 0
      : readFirstOptionalBoolean(updateStatusRecords, ["updateAvailable", "available", "hasRegistryUpdate"]);
  const updateInfo = resolveUpdateInfo({
    currentVersion,
    latestVersion,
    updateError,
    legacyInfo:
      input.status?.overview?.update ??
      readFirstOptionalString(updateStatusRecords, ["updateInfo", "summary", "detail"])
  });

  return {
    currentVersion,
    latestVersion,
    updateAvailable,
    updateError,
    updateInfo
  };
}

function collectUpdateStatusRecords(payload: Record<string, unknown> | undefined) {
  const records: Record<string, unknown>[] = [];

  function add(value: unknown) {
    if (!isRecord(value) || records.includes(value)) {
      return;
    }

    records.push(value);
  }

  add(payload);
  add(payload?.result);
  add(payload?.data);
  add(payload?.update);
  add(payload?.availability);
  add(readRecord(payload?.update)?.registry);
  add(payload?.registry);
  add(payload?.stats);
  add(payload?.sentinel);
  add(readRecord(payload?.sentinel)?.stats);
  add(readRecord(payload?.result)?.update);
  add(readRecord(readRecord(payload?.result)?.update)?.registry);
  add(readRecord(payload?.result)?.registry);
  add(readRecord(payload?.result)?.stats);

  return records;
}

function readFirstOptionalString(records: Record<string, unknown>[], keys: string[]) {
  for (const record of records) {
    for (const key of keys) {
      const value = normalizeOptionalValue(typeof record[key] === "string" ? record[key] : undefined);

      if (value) {
        return value;
      }
    }
  }

  return undefined;
}

function readFirstOptionalBoolean(records: Record<string, unknown>[], keys: string[]) {
  for (const record of records) {
    for (const key of keys) {
      if (typeof record[key] === "boolean") {
        return record[key];
      }
    }
  }

  return undefined;
}

function readUpdateStatusError(records: Record<string, unknown>[]) {
  const directError = readFirstOptionalString(records, ["error", "errorMessage"]);

  if (directError) {
    return normalizeUpdateError(directError);
  }

  for (const record of records) {
    if (record.ok === false) {
      const message = readFirstOptionalString([record], ["message", "reason", "status"]);

      if (message) {
        return normalizeUpdateError(message);
      }
    }
  }

  return undefined;
}

function readRecord(value: unknown): Record<string, unknown> | undefined {
  return isRecord(value) ? value : undefined;
}

function isRecord(value: unknown): value is Record<string, unknown> {
  return Boolean(value && typeof value === "object" && !Array.isArray(value));
}

export function buildGatewayDiagnostics(input: {
  gatewayStatus: GatewayStatusPayload | undefined;
  status: StatusPayload | undefined;
  deviceAccess?: OpenClawDeviceListPayload;
  configuredWorkspaceRoot: string | null;
  workspaceRoot: string;
  configuredGatewayUrl?: string | null;
  hasOpenClawSignal: boolean;
  securityWarnings: string[];
  runtimeDiagnostics: MissionControlSnapshot["diagnostics"]["runtime"];
  openClawBinarySelection: OpenClawBinarySelection;
  modelReadiness: ModelReadiness;
  taskHealth?: MissionControlSnapshot["diagnostics"]["taskHealth"];
  capabilityMatrix?: OpenClawCapabilityMatrix;
  compatibilityReport?: MissionControlSnapshot["diagnostics"]["compatibilityReport"];
  configUpdatePacing?: MissionControlSnapshot["diagnostics"]["configUpdatePacing"];
  compatibilitySmokeTest?: MissionControlSnapshot["diagnostics"]["compatibilitySmokeTest"];
  updateCompatibilityManifest?: OpenClawCompatibilityManifest | null;
  commandHistory?: OpenClawCommandDiagnostic[];
  transport?: MissionControlSnapshot["diagnostics"]["transport"];
  eventBridge?: MissionControlSnapshot["diagnostics"]["eventBridge"];
  runtimeIssueStates?: Record<string, RuntimeIssueState>;
  issues: string[];
  versionDiagnostics: ReturnType<typeof buildVersionDiagnostics>;
  agentOsVersion?: string;
}): MissionControlSnapshot["diagnostics"] {
  const gatewayFallbackDiagnostics = (input.transport?.recentFallbackDiagnostics ?? []).map((entry) => ({
    ...entry,
    operationLabel: getOpenClawGatewayOperationLabel(entry.operation)
  }));
  const activeGatewayFallbackDiagnostics = filterActiveOpenClawGatewayFallbackDiagnostics(
    gatewayFallbackDiagnostics,
    input.transport
  );
  const securityWarnings = [
    ...input.securityWarnings,
    ...buildLocalExposureWarnings(input.gatewayStatus, input.configuredGatewayUrl)
  ];
  const deviceAccessIssue = buildGatewayDeviceAccessIssue(input.gatewayStatus);
  const issues = deviceAccessIssue
    ? [
      deviceAccessIssue,
      ...input.issues.filter((issue) => !isNativeTimeoutNoiseDuringDeviceAccessRepair(issue))
    ]
    : input.issues;
  const runtimeIssues = buildRuntimeIssues({
    status: input.status,
    deviceAccess: input.deviceAccess,
    gatewayStatus: input.gatewayStatus,
    diagnostics: {
      installed: true,
      loaded: Boolean(input.gatewayStatus?.service?.loaded),
      rpcOk: Boolean(input.gatewayStatus?.rpc?.ok),
      health: resolveDiagnosticHealth({
        rpcOk: input.gatewayStatus?.rpc?.ok,
        warningCount: securityWarnings.length,
        runtimeIssueCount:
          issues.filter((issue) => !isTransientRefreshIssue(issue)).length +
          activeGatewayFallbackDiagnostics.filter((entry) => !isNonBlockingUpdateAvailabilityFallback(entry)).length +
          (input.eventBridge && input.eventBridge.mode !== "live" ? 1 : 0),
        hasOpenClawSignal: input.hasOpenClawSignal
      }),
      transport: input.transport,
      gatewayFallbackDiagnostics,
      gatewayFallbackReasons: activeGatewayFallbackDiagnostics.map(
        (entry) => `${entry.operationLabel} (${entry.operation}): ${entry.kind}: ${entry.issue} Recovery: ${entry.recovery}`
      ),
      issues
    },
    issues,
    runtimeIssues: input.runtimeDiagnostics.issues,
    modelReadinessIssues: input.modelReadiness.issues,
    states: input.runtimeIssueStates
  });
  const updateCompatibility = resolveOpenClawUpdateCompatibilitySnapshot({
    manifest: input.updateCompatibilityManifest ?? undefined,
    agentOsVersion: input.agentOsVersion ?? "0.7.2",
    currentVersion: input.versionDiagnostics.currentVersion,
    latestVersion: input.versionDiagnostics.latestVersion
  });
  const updateAvailable = shouldShowDefaultOpenClawUpdate({
    currentVersion: input.versionDiagnostics.currentVersion,
    decision: updateCompatibility.recommendedDecision
  });

  return {
    installed: true,
    loaded: Boolean(input.gatewayStatus?.service?.loaded),
    rpcOk: Boolean(input.gatewayStatus?.rpc?.ok),
    health: resolveDiagnosticHealth({
      rpcOk: input.gatewayStatus?.rpc?.ok,
      warningCount: securityWarnings.length,
      runtimeIssueCount:
        issues.filter((issue) => !isTransientRefreshIssue(issue)).length +
        activeGatewayFallbackDiagnostics.filter((entry) => !isNonBlockingUpdateAvailabilityFallback(entry)).length +
        (input.eventBridge && input.eventBridge.mode !== "live" ? 1 : 0),
      hasOpenClawSignal: input.hasOpenClawSignal
    }),
    version: input.versionDiagnostics.currentVersion,
    latestVersion: input.versionDiagnostics.latestVersion ?? updateCompatibility.recommendedVersion,
    updateAvailable,
    updateError: input.versionDiagnostics.updateError,
    updateCompatibility,
    updateRoot: normalizeOptionalValue(input.status?.update?.root ?? undefined),
    updateInstallKind: normalizeOptionalValue(input.status?.update?.installKind ?? undefined),
    updatePackageManager: normalizeOptionalValue(input.status?.update?.packageManager ?? undefined),
    workspaceRoot: input.workspaceRoot,
    configuredWorkspaceRoot: input.configuredWorkspaceRoot,
    dashboardUrl: `http://127.0.0.1:${input.gatewayStatus?.gateway?.port ?? 18789}/`,
    gatewayUrl: input.gatewayStatus?.gateway?.probeUrl || "ws://127.0.0.1:18789",
    configuredGatewayUrl: input.configuredGatewayUrl ?? null,
    bindMode: input.gatewayStatus?.gateway?.bindMode,
    port: input.gatewayStatus?.gateway?.port,
    updateChannel: input.status?.updateChannel || "stable",
    updateInfo: input.versionDiagnostics.updateInfo,
    serviceLabel: input.gatewayStatus?.service?.label,
    openClawBinarySelection: input.openClawBinarySelection,
    modelReadiness: input.modelReadiness,
    taskHealth: input.taskHealth,
    capabilityMatrix: input.capabilityMatrix,
    compatibilityReport: input.compatibilityReport ?? null,
    configUpdatePacing: input.configUpdatePacing ?? createDefaultConfigUpdatePacingDiagnostics(),
    compatibilitySmokeTest: input.compatibilitySmokeTest ?? null,
    gatewayFallbackDiagnostics,
    gatewayFallbackReasons: activeGatewayFallbackDiagnostics.map(
      (entry) => `${entry.operationLabel} (${entry.operation}): ${entry.kind}: ${entry.issue} Recovery: ${entry.recovery}`
    ),
    runtime: input.runtimeDiagnostics,
    eventBridge: input.eventBridge,
    commandHistory: input.commandHistory,
    transport: input.transport,
    runtimeIssues,
    securityWarnings,
    issues
  };
}

function createDefaultConfigUpdatePacingDiagnostics(): MissionControlSnapshot["diagnostics"]["configUpdatePacing"] {
  return {
    settings: {
      mode: "respect-gateway",
      minimumIntervalMs: null
    },
    queueDurability: "persistent",
    pending: false,
    pendingCount: 0,
    pendingPaths: [],
    pendingSince: null,
    cooldownUntil: null,
    retryAfterMs: null,
    lastIssue: null,
    lastUpdatedAt: null
  };
}

function buildGatewayDeviceAccessIssue(gatewayStatus: GatewayStatusPayload | undefined) {
  const messages = [
    gatewayStatus?.rpc?.error,
    gatewayStatus?.rpc?.capability,
    gatewayStatus?.rpc?.auth?.capability
  ].filter((value): value is string => typeof value === "string" && Boolean(value.trim()));
  const summary = messages.join("\n");

  if (
    !/scope upgrade pending approval|pairing_pending|device token scope mismatch|connected_no_operator_scope|missing operator/i.test(summary)
  ) {
    return null;
  }

  const requestId = readGatewayDeviceAccessRequestId(summary);

  return requestId
    ? `OpenClaw Gateway device access is waiting for operator-scope approval (${requestId}). Run Repair access in Gateway settings or approve that request with OpenClaw devices, then retry.`
    : "OpenClaw Gateway device access is waiting for operator-scope approval. Run Repair access in Gateway settings or approve the pending OpenClaw device request, then retry.";
}

function readGatewayDeviceAccessRequestId(value: string) {
  const match = /\brequestId:\s*([a-f0-9-]{12,})\b/i.exec(value);

  return match?.[1] ?? null;
}

function isNativeTimeoutNoiseDuringDeviceAccessRepair(issue: string) {
  return /Timed out waiting for OpenClaw Gateway method|Gateway-native operation failed; CLI fallback disabled|Native Gateway: Unreachable/i.test(issue);
}

function buildLocalExposureWarnings(
  gatewayStatus: GatewayStatusPayload | undefined,
  configuredGatewayUrl: string | null | undefined
) {
  const warnings: string[] = [];
  const probeHost = readUrlHostname(gatewayStatus?.gateway?.probeUrl);
  const configuredHost = readUrlHostname(configuredGatewayUrl ?? undefined);
  const bindMode = normalizeOptionalValue(gatewayStatus?.gateway?.bindMode ?? undefined)?.toLowerCase();

  if (probeHost && !isLoopbackGatewayHost(probeHost)) {
    warnings.push("OpenClaw Gateway is reachable on a non-loopback host. AgentOS mutation APIs stay restricted to same-origin localhost requests.");
  }

  if (configuredHost && !isLoopbackGatewayHost(configuredHost)) {
    warnings.push("AgentOS is configured to use a non-loopback Gateway URL. Keep AgentOS itself bound to localhost unless an explicit operator tunnel is in place.");
  }

  if (bindMode && !/(local|loopback|localhost)/i.test(bindMode)) {
    warnings.push("OpenClaw Gateway bind mode is not local-only. Review Gateway exposure before using operator write actions.");
  }

  return Array.from(new Set(warnings));
}

function readUrlHostname(value: string | undefined) {
  if (!value) {
    return null;
  }

  try {
    return new URL(value).hostname;
  } catch {
    return null;
  }
}

function isLoopbackGatewayHost(host: string) {
  const normalized = host.trim().toLowerCase().replace(/^\[|\]$/g, "");

  return (
    normalized === "localhost" ||
    normalized === "::1" ||
    normalized === "0:0:0:0:0:0:0:1" ||
    /^127\.(?:\d{1,3}\.){2}\d{1,3}$/.test(normalized)
  );
}

export function buildDiagnosticIssues(input: {
  payloadResults: Record<string, PromiseSettledResult<unknown>>;
  gatewayStatusRejectedWithCachedValue: boolean;
  payloadReuse: Record<string, PayloadReuseState>;
  runtimeIssues: string[];
}) {
  return [
    ...collectIssues(
      Object.fromEntries(
        Object.entries(input.payloadResults).filter(([, result]) => !isDeferredPayloadResult(result))
      )
    ),
    ...(input.gatewayStatusRejectedWithCachedValue
      ? ["gatewayStatus: Reusing the last successful gateway status after a transient OpenClaw check failure."]
      : []),
    ...Object.entries(input.payloadReuse)
      .map(([label, state]) => describeCachedPayloadReuse(label, state.reusedCachedValue))
      .filter((issue): issue is string => Boolean(issue)),
    ...input.runtimeIssues
  ];
}

function describeCachedPayloadReuse(label: string, reusedCachedValue: boolean) {
  return reusedCachedValue
    ? `${label}: Reusing the last successful payload while a slow OpenClaw command refreshes in the background.`
    : null;
}

function isTransientRefreshIssue(issue: string) {
  return (
    issue.includes("Reusing the last successful payload while a slow OpenClaw command refreshes in the background.") ||
    issue.includes("Reusing the last successful gateway status after a transient OpenClaw check failure.")
  );
}

function isNonBlockingUpdateAvailabilityFallback(entry: {
  operation: string;
  kind: string;
  issue: string;
}) {
  return (
    entry.operation === "update.status" &&
    entry.kind === "malformed-response" &&
    /update availability details/i.test(entry.issue)
  );
}
