// dashboard/features/observability/api.js
import { fetchWithTimeout } from "../shared/api.js";

const OBSERVABILITY_ENDPOINT = "./api/observability";
const CHANNEL_CONTEXT_ENDPOINT = "./api/channel-context";
const OBSERVABILITY_HISTORY_ENDPOINT = "./api/observability/history";
const SENTIMENT_SCORES_ENDPOINT = "./api/sentiment/scores";
const POST_STREAM_REPORT_ENDPOINT = "./api/observability/post-stream-report";
const SEMANTIC_MEMORY_ENDPOINT = "./api/semantic-memory";
const REVENUE_CONVERSIONS_ENDPOINT = "./api/observability/conversions";
const REVENUE_CONVERSION_POST_ENDPOINT = "./api/observability/conversion";

function normalizeChannelId(channelId) {
  return (
    String(channelId || "")
      .trim()
      .toLowerCase() || "default"
  );
}

function buildChannelQuery(channelId, extraParams = {}) {
  const params = new URLSearchParams({
    channel: normalizeChannelId(channelId),
  });
  Object.entries(extraParams || {}).forEach(([key, value]) => {
    if (value === undefined || value === null || value === "") {
      return;
    }
    params.set(String(key), String(value));
  });
  return `?${params.toString()}`;
}

/**
 * Coleta os dados em /api/observability disparando o erro para a view em caso de falha.
 */
export async function getObservabilitySnapshot(channelId, timeoutMs = 10000) {
  return await fetchWithTimeout(
    `${OBSERVABILITY_ENDPOINT}${buildChannelQuery(channelId)}`,
    { method: "GET" },
    timeoutMs,
  );
}

export async function getChannelContextSnapshot(channelId, timeoutMs = 10000) {
  return await fetchWithTimeout(
    `${CHANNEL_CONTEXT_ENDPOINT}${buildChannelQuery(channelId)}`,
    { method: "GET" },
    timeoutMs,
  );
}

export async function getObservabilityHistorySnapshot(
  channelId,
  timeoutMs = 10000,
  limit = 24,
  compareLimit = 6,
) {
  return await fetchWithTimeout(
    `${OBSERVABILITY_HISTORY_ENDPOINT}${buildChannelQuery(channelId, {
      limit,
      compare_limit: compareLimit,
    })}`,
    { method: "GET" },
    timeoutMs,
  );
}

export async function getSentimentScoresSnapshot(channelId, timeoutMs = 10000) {
  return await fetchWithTimeout(
    `${SENTIMENT_SCORES_ENDPOINT}${buildChannelQuery(channelId)}`,
    { method: "GET" },
    timeoutMs,
  );
}

export async function getPostStreamReportSnapshot(
  channelId,
  timeoutMs = 10000,
  generate = false,
) {
  return await fetchWithTimeout(
    `${POST_STREAM_REPORT_ENDPOINT}${buildChannelQuery(channelId, {
      generate: generate ? 1 : undefined,
    })}`,
    { method: "GET" },
    timeoutMs,
  );
}

export async function getSemanticMemorySnapshot(
  channelId,
  timeoutMs = 10000,
  query = "",
  limit = 8,
  searchLimit = 60,
  minSimilarity = "",
  forceFallback = false,
) {
  return await fetchWithTimeout(
    `${SEMANTIC_MEMORY_ENDPOINT}${buildChannelQuery(channelId, {
      query: query || undefined,
      limit,
      search_limit: searchLimit,
      min_similarity: minSimilarity !== "" ? minSimilarity : undefined,
      force_fallback: forceFallback ? 1 : undefined,
    })}`,
    { method: "GET" },
    timeoutMs,
  );
}

export async function upsertSemanticMemoryEntry(payload, timeoutMs = 10000) {
  return await fetchWithTimeout(
    SEMANTIC_MEMORY_ENDPOINT,
    {
      method: "PUT",
      body: JSON.stringify(payload || {}),
    },
    timeoutMs,
  );
}

export async function getRevenueConversionsSnapshot(
  channelId,
  timeoutMs = 10000,
  limit = 20,
) {
  return await fetchWithTimeout(
    `${REVENUE_CONVERSIONS_ENDPOINT}${buildChannelQuery(channelId, { limit })}`,
    { method: "GET" },
    timeoutMs,
  );
}

export async function postRevenueConversion(payload, timeoutMs = 10000) {
  return await fetchWithTimeout(
    REVENUE_CONVERSION_POST_ENDPOINT,
    {
      method: "POST",
      body: JSON.stringify(payload || {}),
    },
    timeoutMs,
  );
}