import { ObservationEvent } from "#/types/v1/core";
import { getObservationResult } from "./get-observation-result";
import { getDefaultEventContent, MAX_CONTENT_LENGTH } from "./shared";
import i18n from "#/i18n";
import {
  MCPToolObservation,
  FinishObservation,
  ThinkObservation,
  BrowserObservation,
  ExecuteBashObservation,
  TerminalObservation,
  FileEditorObservation,
  StrReplaceEditorObservation,
  TaskTrackerObservation,
  GlobObservation,
  GrepObservation,
} from "#/types/v1/core/base/observation";

// File Editor Observations
const getFileEditorObservationContent = (
  event: ObservationEvent<FileEditorObservation | StrReplaceEditorObservation>,
): string => {
  const { observation } = event;

  if (observation.error) {
    return `**Error:**\n${observation.error}`;
  }

  // Extract text content from the observation if it exists
  const textContent =
    "content" in observation && Array.isArray(observation.content)
      ? observation.content
          .filter((c) => c.type === "text")
          .map((c) => c.text)
          .join("\n")
      : null;

  const successMessage = getObservationResult(event) === "success";

  // For view commands or successful edits with content changes, format as code block
  if (
    (successMessage &&
      "old_content" in observation &&
      "new_content" in observation &&
      observation.old_content &&
      observation.new_content) ||
    observation.command === "view"
  ) {
    // Prefer content over output for view commands, fallback to output if content is not available
    const displayContent = textContent || observation.output;
    return `\`\`\`\n${displayContent}\n\`\`\``;
  }

  // For other commands, prefer content if available, otherwise use output
  return textContent || observation.output;
};

// Command Observations
const getTerminalObservationContent = (
  event: ObservationEvent<ExecuteBashObservation | TerminalObservation>,
): string => {
  const { observation } = event;

  // Extract text content from the observation
  const textContent = observation.content
    .filter((c) => c.type === "text")
    .map((c) => c.text)
    .join("\n");

  let content = textContent || "";

  if (content.length > MAX_CONTENT_LENGTH) {
    content = `${content.slice(0, MAX_CONTENT_LENGTH)}...`;
  }

  // Build the output string
  let output = "";

  // Display the command if available
  if (observation.command) {
    output += `Command: \`${observation.command}\`\n\n`;
  }

  // Display the output
  output += `Output:\n\`\`\`sh\n${content.trim() || i18n.t("OBSERVATION$COMMAND_NO_OUTPUT")}\n\`\`\``;

  return output;
};

// Tool Observations
const getBrowserObservationContent = (
  event: ObservationEvent<BrowserObservation>,
): string => {
  const { observation } = event;

  // Extract text content from the observation
  const textContent =
    "content" in observation && Array.isArray(observation.content)
      ? observation.content
          .filter((c) => c.type === "text")
          .map((c) => c.text)
          .join("\n")
      : observation.output || "";

  let contentDetails = "";

  if (observation.error) {
    contentDetails += `**Error:**\n${observation.error}`;
  } else if (textContent) {
    contentDetails += `**Output:**\n${textContent}`;
  } else {
    contentDetails += "Browser action completed successfully.";
  }

  if (contentDetails.length > MAX_CONTENT_LENGTH) {
    contentDetails = `${contentDetails.slice(0, MAX_CONTENT_LENGTH)}...(truncated)`;
  }

  return contentDetails;
};

const getMCPToolObservationContent = (
  event: ObservationEvent<MCPToolObservation>,
): string => {
  const { observation } = event;

  // Extract text content from the observation
  const textContent = observation.content
    .filter((c) => c.type === "text")
    .map((c) => c.text)
    .join("\n");

  let content = `**Tool:** ${observation.tool_name}\n\n`;

  if (observation.is_error) {
    content += `**Error:**\n${textContent}`;
  } else {
    content += `**Result:**\n${textContent}`;
  }

  if (content.length > MAX_CONTENT_LENGTH) {
    content = `${content.slice(0, MAX_CONTENT_LENGTH)}...`;
  }

  return content;
};

// Complex Observations
const getTaskTrackerObservationContent = (
  event: ObservationEvent<TaskTrackerObservation>,
): string => {
  const { observation } = event;

  const { command, task_list: taskList } = observation;
  let content = `**Command:** \`${command}\``;

  if (command === "plan" && taskList.length > 0) {
    content += `\n\n**Task List (${taskList.length} ${taskList.length === 1 ? "item" : "items"}):**\n`;

    taskList.forEach((task, index: number) => {
      const statusMap = {
        todo: "⏳",
        in_progress: "🔄",
        done: "✅",
      };
      const statusIcon =
        statusMap[task.status as keyof typeof statusMap] || "❓";

      content += `\n${index + 1}. ${statusIcon} **[${task.status.toUpperCase().replace("_", " ")}]** ${task.title}`;
      if (task.notes) {
        content += `\n   *Notes: ${task.notes}*`;
      }
    });
  } else if (command === "plan") {
    content += "\n\n**Task List:** Empty";
  }

  if (
    "content" in observation &&
    observation.content &&
    typeof observation.content === "string" &&
    observation.content.trim()
  ) {
    content += `\n\n**Result:** ${observation.content.trim()}`;
  }

  return content;
};

// Simple Observations
const getThinkObservationContent = (
  event: ObservationEvent<ThinkObservation>,
): string => {
  const { observation } = event;

  const textContent = observation.content
    .filter((c) => c.type === "text")
    .map((c) => c.text)
    .join("\n");

  return textContent || "";
};

const getFinishObservationContent = (
  event: ObservationEvent<FinishObservation>,
): string => {
  const { observation } = event;

  // Extract text content from the observation
  const textContent = observation.content
    .filter((c) => c.type === "text")
    .map((c) => c.text)
    .join("\n");

  let content = "";

  if (observation.is_error) {
    content += `**Error:**\n${textContent}`;
  } else {
    content += textContent;
  }

  return content;
};

// Glob Observations
const getGlobObservationContent = (
  event: ObservationEvent<GlobObservation>,
): string => {
  const { observation } = event;

  // Extract text content from the observation
  const textContent = observation.content
    .filter((c) => c.type === "text")
    .map((c) => c.text)
    .join("\n");

  let content = `**Pattern:** \`${observation.pattern}\`\n`;
  content += `**Search Path:** \`${observation.search_path}\`\n\n`;

  if (observation.is_error) {
    content += `**Error:**\n${textContent}`;
  } else if (observation.files.length === 0) {
    content += "**Result:** No files found.";
  } else {
    content += `**Files Found (${observation.files.length}${observation.truncated ? "+, truncated" : ""}):**\n`;
    content += observation.files.map((f) => `- \`${f}\``).join("\n");
  }

  if (content.length > MAX_CONTENT_LENGTH) {
    content = `${content.slice(0, MAX_CONTENT_LENGTH)}...(truncated)`;
  }

  return content;
};

// Grep Observations
const getGrepObservationContent = (
  event: ObservationEvent<GrepObservation>,
): string => {
  const { observation } = event;

  // Extract text content from the observation
  const textContent = observation.content
    .filter((c) => c.type === "text")
    .map((c) => c.text)
    .join("\n");

  let content = `**Pattern:** \`${observation.pattern}\`\n`;
  content += `**Search Path:** \`${observation.search_path}\`\n`;
  if (observation.include_pattern) {
    content += `**Include:** \`${observation.include_pattern}\`\n`;
  }
  content += "\n";

  if (observation.is_error) {
    content += `**Error:**\n${textContent}`;
  } else if (observation.matches.length === 0) {
    content += "**Result:** No matches found.";
  } else {
    content += `**Matches (${observation.matches.length}${observation.truncated ? "+, truncated" : ""}):**\n`;
    content += observation.matches.map((f) => `- \`${f}\``).join("\n");
  }

  if (content.length > MAX_CONTENT_LENGTH) {
    content = `${content.slice(0, MAX_CONTENT_LENGTH)}...(truncated)`;
  }

  return content;
};

export const getObservationContent = (event: ObservationEvent): string => {
  const observationType = event.observation.kind;

  switch (observationType) {
    case "FileEditorObservation":
    case "StrReplaceEditorObservation":
      return getFileEditorObservationContent(
        event as ObservationEvent<
          FileEditorObservation | StrReplaceEditorObservation
        >,
      );

    case "ExecuteBashObservation":
    case "TerminalObservation":
      return getTerminalObservationContent(
        event as ObservationEvent<ExecuteBashObservation | TerminalObservation>,
      );

    case "BrowserObservation":
      return getBrowserObservationContent(
        event as ObservationEvent<BrowserObservation>,
      );

    case "MCPToolObservation":
      return getMCPToolObservationContent(
        event as ObservationEvent<MCPToolObservation>,
      );

    case "TaskTrackerObservation":
      return getTaskTrackerObservationContent(
        event as ObservationEvent<TaskTrackerObservation>,
      );

    case "ThinkObservation":
      return getThinkObservationContent(
        event as ObservationEvent<ThinkObservation>,
      );

    case "FinishObservation":
      return getFinishObservationContent(
        event as ObservationEvent<FinishObservation>,
      );

    case "GlobObservation":
      return getGlobObservationContent(
        event as ObservationEvent<GlobObservation>,
      );

    case "GrepObservation":
      return getGrepObservationContent(
        event as ObservationEvent<GrepObservation>,
      );

    default:
      return getDefaultEventContent(event);
  }
};