import { resolve } from "node:path";
import { isRecord } from "../../model/config/schema.js";
import type { PilotConfigDiagnostic } from "../../pilot/config/types.js";

export type AlwaysOnTriggerConfig = {
  enabled: boolean;
  tickIntervalMinutes: number;
  cooldownMinutes: number;
  dailyBudget: number;
  heartbeatStaleSeconds: number;
  recentUserMsgMinutes: number;
  preferChannel: string;
};

export type AlwaysOnDormancyConfig = {
  enabled: boolean;
  debounceMs: number;
  ignoreGlobs: string[];
};

export type AlwaysOnWorkspaceConfig = {
  gitWorktreeBaseDir?: string;
  snapshotBaseDir?: string;
  snapshotMaxBytes: number;
  gitLfs: boolean;
};

export type AlwaysOnExecutionConfig = {
  maxTurns: number;
  maxToolCalls: number;
  timeoutMinutes: number;
};

export type AlwaysOnProjectConfig = {
  enabled: boolean;
};

export type AlwaysOnPromptLanguage = "en" | "zh-CN";

export type AlwaysOnConfig = {
  enabled: boolean;
  language?: AlwaysOnPromptLanguage;
  trigger: AlwaysOnTriggerConfig;
  dormancy: AlwaysOnDormancyConfig;
  workspace: AlwaysOnWorkspaceConfig;
  execution: AlwaysOnExecutionConfig;
  projects: Record<string, AlwaysOnProjectConfig>;
};

export const DEFAULT_IGNORE_GLOBS: string[] = [
  "**/.git/**",
  "**/node_modules/**",
  "**/.pilotdeck/**",
  "**/.pilotdeck-always-on/**",
  "**/dist/**",
  "**/.DS_Store",
];

const DEFAULT_SNAPSHOT_MAX_BYTES = 1024 * 1024 * 1024; // 1 GiB

export function defaultAlwaysOnConfig(): AlwaysOnConfig {
  return {
    enabled: false,
    trigger: {
      enabled: false,
      tickIntervalMinutes: 5,
      cooldownMinutes: 60,
      dailyBudget: 4,
      heartbeatStaleSeconds: 90,
      recentUserMsgMinutes: 5,
      preferChannel: "web",
    },
    dormancy: {
      enabled: true,
      debounceMs: 2000,
      ignoreGlobs: [...DEFAULT_IGNORE_GLOBS],
    },
    workspace: {
      snapshotMaxBytes: DEFAULT_SNAPSHOT_MAX_BYTES,
      gitLfs: false,
    },
    execution: {
      maxTurns: 30,
      maxToolCalls: 200,
      timeoutMinutes: 20,
    },
    projects: {},
  };
}

const ALLOWED_TOP_LEVEL_KEYS = new Set([
  "enabled",
  "language",
  "trigger",
  "dormancy",
  "workspace",
  "execution",
  "projects",
]);

const VALID_LANGUAGES = new Set<string>(["en", "zh-CN"]);

const REMOVED_TOP_LEVEL_KEYS: Record<string, string> = {
  discovery:
    "alwaysOn.discovery wrapper has been removed. Lift trigger / dormancy / workspace / execution / projects to alwaysOn.<key>.",
  plan: "alwaysOn.plan section has been removed. plan-per-fire is fixed at 1 by protocol.",
  cron: "Always-On cron is no longer part of this module.",
};

const REMOVED_WORKSPACE_KEYS: Record<string, string> = {
  strategy:
    "alwaysOn.workspace.strategy has been removed. WorkspaceProviderRegistry selects the strategy automatically.",
  maxConcurrentEnvs:
    "alwaysOn.workspace.maxConcurrentEnvs has been removed. Always-On runs at most one isolated workspace per project; subsequent fires reuse it.",
  retainSuccessfulEnvs:
    "alwaysOn.workspace.retainSuccessfulEnvs has been removed. Workspaces are always retained for manual inspection.",
  retainFailedEnvs:
    "alwaysOn.workspace.retainFailedEnvs has been removed. Workspaces are always retained for manual inspection.",
};

const REMOVED_EXECUTION_KEYS: Record<string, string> = {
  permissionMode:
    "alwaysOn.execution.permissionMode has been removed. Execution turns always run in bypassPermissions mode inside the isolated workspace.",
};

const REMOVED_PROJECT_KEYS: Record<string, string> = {
  sessionKey:
    "alwaysOn.projects.<root>.sessionKey is no longer accepted. The runtime derives sessionKey from projectKey + runId.",
  workspace:
    "alwaysOn.projects.<root>.workspace per-project override is no longer accepted. WorkspaceProviderRegistry resolves provider automatically.",
};

export function parseAlwaysOnConfig(
  raw: unknown,
  diagnostics: PilotConfigDiagnostic[],
): AlwaysOnConfig | undefined {
  if (raw === undefined) {
    return undefined;
  }
  if (!isRecord(raw)) {
    diagnostics.push({
      code: "ALWAYS_ON_CONFIG_INVALID",
      severity: "fatal",
      message: "alwaysOn config must be an object.",
      path: "alwaysOn",
      recoverable: false,
    });
    return undefined;
  }

  const result = defaultAlwaysOnConfig();
  result.enabled = booleanField(raw, "enabled", result.enabled);

  if (typeof raw.language === "string" && VALID_LANGUAGES.has(raw.language)) {
    result.language = raw.language as AlwaysOnPromptLanguage;
  } else if (raw.language !== undefined) {
    diagnostics.push({
      code: "ALWAYS_ON_LANGUAGE_INVALID",
      severity: "warning",
      message: `alwaysOn.language must be "en" or "zh-CN"; ignoring "${String(raw.language)}".`,
      path: "alwaysOn.language",
      recoverable: true,
    });
  }

  for (const key of Object.keys(raw)) {
    const removalReason = REMOVED_TOP_LEVEL_KEYS[key];
    if (removalReason) {
      diagnostics.push({
        code: "ALWAYS_ON_FIELD_REMOVED",
        severity: "fatal",
        message: removalReason,
        path: `alwaysOn.${key}`,
        recoverable: false,
      });
      continue;
    }
    if (!ALLOWED_TOP_LEVEL_KEYS.has(key)) {
      diagnostics.push({
        code: "ALWAYS_ON_UNKNOWN_FIELD",
        severity: "warning",
        message: `Unknown alwaysOn field ${key}.`,
        path: `alwaysOn.${key}`,
        recoverable: true,
      });
    }
  }

  if (raw.trigger !== undefined) {
    parseTrigger(raw.trigger, result.trigger, diagnostics);
  }
  if (raw.dormancy !== undefined) {
    parseDormancy(raw.dormancy, result.dormancy, diagnostics);
  }
  if (raw.workspace !== undefined) {
    parseWorkspace(raw.workspace, result.workspace, diagnostics);
  }
  if (raw.execution !== undefined) {
    parseExecution(raw.execution, result.execution, diagnostics);
  }
  if (raw.projects !== undefined) {
    result.projects = parseProjects(raw.projects, diagnostics);
  }

  return result;
}

function parseTrigger(
  raw: unknown,
  target: AlwaysOnTriggerConfig,
  diagnostics: PilotConfigDiagnostic[],
): void {
  if (!isRecord(raw)) {
    diagnostics.push({
      code: "ALWAYS_ON_TRIGGER_INVALID",
      severity: "fatal",
      message: "alwaysOn.trigger must be an object.",
      path: "alwaysOn.trigger",
      recoverable: false,
    });
    return;
  }
  target.enabled = booleanField(raw, "enabled", target.enabled);
  target.tickIntervalMinutes = positiveNumber(
    raw.tickIntervalMinutes,
    target.tickIntervalMinutes,
    "alwaysOn.trigger.tickIntervalMinutes",
    diagnostics,
  );
  target.cooldownMinutes = nonNegativeNumber(
    raw.cooldownMinutes,
    target.cooldownMinutes,
    "alwaysOn.trigger.cooldownMinutes",
    diagnostics,
  );
  target.dailyBudget = nonNegativeInteger(
    raw.dailyBudget,
    target.dailyBudget,
    "alwaysOn.trigger.dailyBudget",
    diagnostics,
  );
  target.heartbeatStaleSeconds = positiveNumber(
    raw.heartbeatStaleSeconds,
    target.heartbeatStaleSeconds,
    "alwaysOn.trigger.heartbeatStaleSeconds",
    diagnostics,
  );
  target.recentUserMsgMinutes = nonNegativeNumber(
    raw.recentUserMsgMinutes,
    target.recentUserMsgMinutes,
    "alwaysOn.trigger.recentUserMsgMinutes",
    diagnostics,
  );
  if (typeof raw.preferChannel === "string" && raw.preferChannel.length > 0) {
    target.preferChannel = raw.preferChannel;
  } else if (raw.preferChannel !== undefined) {
    diagnostics.push({
      code: "ALWAYS_ON_TRIGGER_PREFER_CHANNEL_INVALID",
      severity: "warning",
      message: "alwaysOn.trigger.preferChannel must be a non-empty string; falling back to default.",
      path: "alwaysOn.trigger.preferChannel",
      recoverable: true,
    });
  }
}

function parseDormancy(
  raw: unknown,
  target: AlwaysOnDormancyConfig,
  diagnostics: PilotConfigDiagnostic[],
): void {
  if (!isRecord(raw)) {
    diagnostics.push({
      code: "ALWAYS_ON_DORMANCY_INVALID",
      severity: "fatal",
      message: "alwaysOn.dormancy must be an object.",
      path: "alwaysOn.dormancy",
      recoverable: false,
    });
    return;
  }
  target.enabled = booleanField(raw, "enabled", target.enabled);
  target.debounceMs = nonNegativeInteger(
    raw.debounceMs,
    target.debounceMs,
    "alwaysOn.dormancy.debounceMs",
    diagnostics,
  );
  if (raw.ignoreGlobs !== undefined) {
    if (Array.isArray(raw.ignoreGlobs)) {
      const filtered = raw.ignoreGlobs.filter(
        (entry): entry is string => typeof entry === "string" && entry.length > 0,
      );
      target.ignoreGlobs = filtered;
    } else {
      diagnostics.push({
        code: "ALWAYS_ON_DORMANCY_IGNORE_GLOBS_INVALID",
        severity: "warning",
        message: "alwaysOn.dormancy.ignoreGlobs must be an array of strings; falling back to default.",
        path: "alwaysOn.dormancy.ignoreGlobs",
        recoverable: true,
      });
    }
  }
}

function parseWorkspace(
  raw: unknown,
  target: AlwaysOnWorkspaceConfig,
  diagnostics: PilotConfigDiagnostic[],
): void {
  if (!isRecord(raw)) {
    diagnostics.push({
      code: "ALWAYS_ON_WORKSPACE_INVALID",
      severity: "fatal",
      message: "alwaysOn.workspace must be an object.",
      path: "alwaysOn.workspace",
      recoverable: false,
    });
    return;
  }
  for (const key of Object.keys(raw)) {
    const removed = REMOVED_WORKSPACE_KEYS[key];
    if (removed) {
      diagnostics.push({
        code: "ALWAYS_ON_FIELD_REMOVED",
        severity: "fatal",
        message: removed,
        path: `alwaysOn.workspace.${key}`,
        recoverable: false,
      });
    }
  }
  target.gitWorktreeBaseDir = optionalString(raw.gitWorktreeBaseDir, target.gitWorktreeBaseDir);
  target.snapshotBaseDir = optionalString(raw.snapshotBaseDir, target.snapshotBaseDir);
  target.snapshotMaxBytes = positiveInteger(
    raw.snapshotMaxBytes,
    target.snapshotMaxBytes,
    "alwaysOn.workspace.snapshotMaxBytes",
    diagnostics,
  );
  target.gitLfs = booleanField(raw, "gitLfs", target.gitLfs);
}

function parseExecution(
  raw: unknown,
  target: AlwaysOnExecutionConfig,
  diagnostics: PilotConfigDiagnostic[],
): void {
  if (!isRecord(raw)) {
    diagnostics.push({
      code: "ALWAYS_ON_EXECUTION_INVALID",
      severity: "fatal",
      message: "alwaysOn.execution must be an object.",
      path: "alwaysOn.execution",
      recoverable: false,
    });
    return;
  }
  for (const key of Object.keys(raw)) {
    const removed = REMOVED_EXECUTION_KEYS[key];
    if (removed) {
      diagnostics.push({
        code: "ALWAYS_ON_FIELD_REMOVED",
        severity: "fatal",
        message: removed,
        path: `alwaysOn.execution.${key}`,
        recoverable: false,
      });
    }
  }
  target.maxTurns = positiveInteger(
    raw.maxTurns,
    target.maxTurns,
    "alwaysOn.execution.maxTurns",
    diagnostics,
  );
  target.maxToolCalls = positiveInteger(
    raw.maxToolCalls,
    target.maxToolCalls,
    "alwaysOn.execution.maxToolCalls",
    diagnostics,
  );
  target.timeoutMinutes = positiveInteger(
    raw.timeoutMinutes,
    target.timeoutMinutes,
    "alwaysOn.execution.timeoutMinutes",
    diagnostics,
  );
}

function parseProjects(
  raw: unknown,
  diagnostics: PilotConfigDiagnostic[],
): Record<string, AlwaysOnProjectConfig> {
  if (!isRecord(raw)) {
    diagnostics.push({
      code: "ALWAYS_ON_PROJECTS_INVALID",
      severity: "fatal",
      message: "alwaysOn.projects must be an object keyed by absolute project root.",
      path: "alwaysOn.projects",
      recoverable: false,
    });
    return {};
  }

  const projects: Record<string, AlwaysOnProjectConfig> = {};
  for (const [rootKey, value] of Object.entries(raw)) {
    if (typeof rootKey !== "string" || rootKey.trim().length === 0) {
      continue;
    }
    if (!isRecord(value)) {
      diagnostics.push({
        code: "ALWAYS_ON_PROJECT_INVALID",
        severity: "fatal",
        message: `alwaysOn.projects.${rootKey} must be an object.`,
        path: `alwaysOn.projects.${rootKey}`,
        recoverable: false,
      });
      continue;
    }
    for (const innerKey of Object.keys(value)) {
      const removed = REMOVED_PROJECT_KEYS[innerKey];
      if (removed) {
        diagnostics.push({
          code: "ALWAYS_ON_FIELD_REMOVED",
          severity: "fatal",
          message: removed,
          path: `alwaysOn.projects.${rootKey}.${innerKey}`,
          recoverable: false,
        });
      } else if (innerKey !== "enabled") {
        diagnostics.push({
          code: "ALWAYS_ON_PROJECT_UNKNOWN_FIELD",
          severity: "warning",
          message: `Unknown alwaysOn.projects.${rootKey}.${innerKey}; only 'enabled' is accepted.`,
          path: `alwaysOn.projects.${rootKey}.${innerKey}`,
          recoverable: true,
        });
      }
    }
    const enabled = typeof value.enabled === "boolean" ? value.enabled : false;
    const normalizedKey = resolve(rootKey);
    projects[normalizedKey] = { enabled };
  }
  return projects;
}

function booleanField(record: Record<string, unknown>, key: string, fallback: boolean): boolean {
  const value = record[key];
  if (typeof value === "boolean") {
    return value;
  }
  return fallback;
}

function optionalString(value: unknown, fallback: string | undefined): string | undefined {
  if (typeof value === "string" && value.length > 0) {
    return value;
  }
  return fallback;
}

function positiveNumber(
  value: unknown,
  fallback: number,
  path: string,
  diagnostics: PilotConfigDiagnostic[],
): number {
  if (value === undefined) return fallback;
  if (typeof value !== "number" || !Number.isFinite(value) || value <= 0) {
    diagnostics.push({
      code: "ALWAYS_ON_NUMBER_INVALID",
      severity: "warning",
      message: `${path} must be a positive number; falling back to ${fallback}.`,
      path,
      recoverable: true,
    });
    return fallback;
  }
  return value;
}

function nonNegativeNumber(
  value: unknown,
  fallback: number,
  path: string,
  diagnostics: PilotConfigDiagnostic[],
): number {
  if (value === undefined) return fallback;
  if (typeof value !== "number" || !Number.isFinite(value) || value < 0) {
    diagnostics.push({
      code: "ALWAYS_ON_NUMBER_INVALID",
      severity: "warning",
      message: `${path} must be a non-negative number; falling back to ${fallback}.`,
      path,
      recoverable: true,
    });
    return fallback;
  }
  return value;
}

function positiveInteger(
  value: unknown,
  fallback: number,
  path: string,
  diagnostics: PilotConfigDiagnostic[],
): number {
  if (value === undefined) return fallback;
  if (
    typeof value !== "number" ||
    !Number.isFinite(value) ||
    !Number.isInteger(value) ||
    value <= 0
  ) {
    diagnostics.push({
      code: "ALWAYS_ON_NUMBER_INVALID",
      severity: "warning",
      message: `${path} must be a positive integer; falling back to ${fallback}.`,
      path,
      recoverable: true,
    });
    return fallback;
  }
  return value;
}

function nonNegativeInteger(
  value: unknown,
  fallback: number,
  path: string,
  diagnostics: PilotConfigDiagnostic[],
): number {
  if (value === undefined) return fallback;
  if (
    typeof value !== "number" ||
    !Number.isFinite(value) ||
    !Number.isInteger(value) ||
    value < 0
  ) {
    diagnostics.push({
      code: "ALWAYS_ON_NUMBER_INVALID",
      severity: "warning",
      message: `${path} must be a non-negative integer; falling back to ${fallback}.`,
      path,
      recoverable: true,
    });
    return fallback;
  }
  return value;
}