/**
 * SystemDomain：system 领域统一实现。
 *
 * 关键点（中文）
 * - 收敛 system 的资产加载、上下文档位判定、plugin prompt 收集、messages 组装。
 * - `DefaultSessionSystemComposer` 只做组件适配；核心逻辑统一在本文件。
 */

import type { SystemModelMessage } from "ai";
import { transform_prompts_into_system_messages } from "@executor/composer/system/default/PromptRenderer.js";
import type { PluginContext } from "@/types/plugin/PluginContext.js";
import { build_runtime_clock_system_prompt } from "@executor/composer/system/default/variables/VariableReplacer.js";
import {
  CORE_SYSTEM_PROMPT,
  TASK_SYSTEM_PROMPT,
} from "@executor/composer/system/default/SystemPromptAssets.js";

const DEFAULT_DISABLED_MANAGED_PLUGIN_NAMES: string[] = [];

function normalizeSystemText(input: string | null | undefined): string {
  return String(input || "").trim();
}

/**
 * Ship 默认系统提示模板。
 */
export const DEFAULT_SHIP_PROMPTS = CORE_SYSTEM_PROMPT;

/**
 * 构建一次运行的运行时 system prompt。
 *
 * 关键点（中文）
 * - 仅承载“稳定规则”块，避免把每轮变化字段放在前缀 system。
 * - task 模式下追加任务输出规则；chat 模式为空。
 */
export function build_context_system_prompt(input: {
  /**
   * 项目根目录。
   */
  project_root: string;

  /**
   * 当前会话 ID。
   */
  session_id: string;

  /**
   * 当前 system 模式（默认 chat）。
   */
  mode?: "chat" | "task";

  /**
   * 额外上下文行（可选）。
   */
  extra_context_lines?: string[];
}): string {
  const { project_root, extra_context_lines } = input;
  const mode = input.mode === "task" ? "task" : "chat";
  if (mode === "chat") return "";

  const runtimeContextLines: string[] = [
    "Task runtime context:",
    `- Project root: ${project_root}`,
  ];

  if (Array.isArray(extra_context_lines) && extra_context_lines.length > 0) {
    runtimeContextLines.push(...extra_context_lines);
  }

  const outputRules = [
    "Task-run output rules:",
    "- This is a task execution context, not an interactive chat turn.",
    "- Do NOT send external channel messages via `downcity chat send` unless explicitly required by the task itself.",
    "- Reply with result-oriented content; do NOT paste raw tool outputs or JSON logs.",
    "- Keep output compact and avoid unnecessary conversational fillers.",
  ].join("\n");

  return [runtimeContextLines.join("\n"), "", outputRules].join("\n");
}

/**
 * 解析静态 system prompts。
 *
 * 关键点（中文）
 * - task 执行上下文可替换默认 core prompt（`DEFAULT_SHIP_PROMPTS`）为任务专用提示词。
 * - PROFILE/SOUL 等其他静态提示保持不变。
 */
export function resolve_static_system_prompts(input: {
  /**
   * 当前静态 system 文本集合。
   */
  systems: string[];

  /**
   * 可选默认 core prompt 替换文本（task 场景常用）。
   */
  replace_default_core_prompt?: string;
}): string[] {
  const base = Array.isArray(input.systems) ? [...input.systems] : [];
  const replacement = String(input.replace_default_core_prompt || "").trim();
  if (!replacement) return base;
  return [...base.filter((item) => item !== DEFAULT_SHIP_PROMPTS), replacement];
}

type ResolvedSystemContextProfile = {
  mode: "chat" | "task";
  replace_default_core_prompt?: string;
  disable_plugin_systems: string[];
};

/**
 * System 档位。
 *
 * 关键点（中文）
 * - 由外部创建 system 时显式指定，避免在 system 域猜测业务上下文。
 */
export type SystemProfile = "chat" | "task";

/**
 * 按显式 profile 解析 system 上下文档位。
 *
 * 关键点（中文）
 * - chat 模式：使用默认 core prompt 与全部 plugin system。
 * - task 模式：自动替换 task core prompt，并禁用 chat plugin system。
 */
export function resolve_system_context_profile(
  profile?: SystemProfile,
): ResolvedSystemContextProfile {
  if (profile !== "task") {
    return {
      mode: "chat",
      disable_plugin_systems: [...DEFAULT_DISABLED_MANAGED_PLUGIN_NAMES],
    };
  }
  return {
    mode: "task",
    replace_default_core_prompt: TASK_SYSTEM_PROMPT,
    disable_plugin_systems: ["chat"],
  };
}

/**
 * 收集受 agent 托管的 plugin system 文本。
 *
 * 关键点（中文）
 * - core prompt 已包含 plugin 系统总规则；这里仅收集各 plugin 自己的 system prompt。
 * - 单个加载失败走 fail-open，不阻断主链路。
 */
export async function load_managed_plugin_system_prompts(input: {
  /**
   * 当前执行上下文。
   */
  context: PluginContext;

  /**
   * 当前轮禁用的 plugin 名称集合。
   */
  disabled_plugin_names: string[];
}): Promise<string[]> {
  const out: string[] = [];
  const disabled_plugin_names = new Set(
    input.disabled_plugin_names
      .map((item) => String(item || "").trim())
      .filter(Boolean),
  );

  for (const snapshot of input.context.plugins.snapshots()) {
    const plugin = input.context.plugins.get(snapshot.name);
    if (!plugin) continue;
    if (disabled_plugin_names.has(plugin.name)) continue;
    if (typeof plugin.system !== "function") continue;
    try {
      if (input.context.plugins.status(plugin.name)?.status !== "ready") continue;
      if (typeof plugin.availability === "function") {
        const availability = await plugin.availability(input.context);
        if (!availability.available) continue;
      }
      const text = normalizeSystemText(await plugin.system(input.context));
      if (!text) continue;
      out.push(text);
    } catch {
      // fail-open
    }
  }

  return out;
}

/**
 * 收集本地 plugin 的 system 文本。
 *
 * 关键点（中文）
 * - 本地 plugin 的 `plugin.system` 在语义上属于“增强注入”。
 * - 若 plugin 显式声明 availability 且当前 unavailable，则跳过其 system 注入。
 * - 单个 plugin 加载失败走 fail-open，不阻断主链路。
 */
export async function load_local_plugin_system_prompts(input: {
  /**
   * 当前统一执行上下文。
   */
  context: PluginContext;
}): Promise<string[]> {
  void input;
  return [];
}

/**
 * 统一构建一次 Session 运行所需的 system messages。
 *
 * 关键点（中文）
 * - context/static/plugin 的组装逻辑统一收敛在 system 域。
 */
export async function build_session_system_messages(input: {
  /**
   * 项目根目录（用于模板变量和运行态上下文）。
   */
  project_root: string;

  /**
   * 当前会话 ID。
   */
  session_id: string;

  /**
   * 本轮模式（chat/task）。
   */
  mode?: "chat" | "task";

  /**
   * 可选默认 core prompt 替换文本（task 场景常用）。
   */
  replace_default_core_prompt?: string;

  /**
   * 静态 system 文本集合（profile/soul/user/default）。
   */
  static_system_prompts: string[];

  /**
   * 受 agent 托管的 plugin system 文本集合（main plugin + managed plugins）。
   */
  managed_plugin_system_prompts: string[];

  /**
   * 本地 plugin system 文本集合。
   */
  local_plugin_system_prompts: string[];
}): Promise<SystemModelMessage[]> {
  const runtimeClockText = build_runtime_clock_system_prompt({
    projectPath: input.project_root,
    session_id: input.session_id,
  });
  const runtimeClockMessages: SystemModelMessage[] = runtimeClockText
    ? [{ role: "system", content: runtimeClockText }]
    : [];
  const runtimeSystemText = build_context_system_prompt({
    project_root: input.project_root,
    session_id: input.session_id,
    mode: input.mode,
  });
  const runtimeRuleMessages: SystemModelMessage[] = runtimeSystemText
    ? [{ role: "system", content: runtimeSystemText }]
    : [];

  const staticSystemMessages = await transform_prompts_into_system_messages(
    resolve_static_system_prompts({
      systems: input.static_system_prompts,
      replace_default_core_prompt: input.replace_default_core_prompt,
    }),
    {
      projectPath: input.project_root,
      variableMode: "stable",
    },
  );

  const managedPluginSystemMessages = await transform_prompts_into_system_messages(
    Array.isArray(input.managed_plugin_system_prompts)
      ? input.managed_plugin_system_prompts
      : [],
    {
      projectPath: input.project_root,
      variableMode: "stable",
    },
  );

  const localPluginSystemMessages = await transform_prompts_into_system_messages(
    Array.isArray(input.local_plugin_system_prompts)
      ? input.local_plugin_system_prompts
      : [],
    {
      projectPath: input.project_root,
      variableMode: "stable",
    },
  );

  return [
    ...staticSystemMessages,
    ...managedPluginSystemMessages,
    ...localPluginSystemMessages,
    ...runtimeRuleMessages,
    ...runtimeClockMessages,
  ];
}

/**
 * 统一解析一次 Session 运行所需的 system messages（含上下文档位判定与 plugin 收集）。
 */
export async function resolve_session_system_messages(input: {
  /**
   * 项目根目录。
   */
  project_root: string;

  /**
   * 当前会话 ID。
   */
  session_id: string;

  /**
   * 当前 system 档位（默认 chat）。
   */
  profile?: SystemProfile;

  /**
   * 当前静态 system 文本集合。
   */
  static_system_prompts: string[];

  /**
   * 当前执行上下文。
   */
  context: PluginContext;

}): Promise<SystemModelMessage[]> {
  const profile = resolve_system_context_profile(input.profile);
  return await build_session_system_messages({
    project_root: input.project_root,
    session_id: input.session_id,
    mode: profile.mode,
    replace_default_core_prompt: profile.replace_default_core_prompt,
    static_system_prompts: input.static_system_prompts,
    managed_plugin_system_prompts: await load_managed_plugin_system_prompts({
      context: input.context,
      disabled_plugin_names: profile.disable_plugin_systems,
    }),
    local_plugin_system_prompts: await load_local_plugin_system_prompts({
      context: input.context,
    }),
  });
}