import type {
  ContentItemsResponse,
  DashboardResponse,
  FlowLedgerApiResponse,
  FlowLedgerVideoResponse,
  FlowLedgerVideoWalkResponse,
  FlowLedgerVideosResponse,
  FlowLedgerWalkResponse,
  AigcPushRecordListResponse,
  QueryListResponse,
  RunListResponse,
  TimelineResponse
} from "./types";

const DEFAULT_API_BASE_URL = "http://47.245.103.121:8000";

export class ApiError extends Error {
  status: number;
  detail: unknown;

  constructor(message: string, status: number, detail: unknown) {
    super(message);
    this.name = "ApiError";
    this.status = status;
    this.detail = detail;
  }
}

export function apiBaseUrl() {
  return (
    process.env.NEXT_PUBLIC_CONTENTFIND_API_BASE_URL ||
    process.env.VITE_CONTENTFIND_API_BASE_URL ||
    DEFAULT_API_BASE_URL
  ).replace(/\/$/, "");
}

async function request<T>(path: string): Promise<T> {
  const response = await fetch(`${apiBaseUrl()}${path}`, {
    headers: { Accept: "application/json" },
    cache: "no-store"
  });
  if (!response.ok) {
    let detail: unknown = null;
    try {
      detail = await response.json();
    } catch {
      detail = await response.text();
    }
    throw new ApiError(`request failed: ${path}`, response.status, detail);
  }
  return response.json() as Promise<T>;
}

export function listRuns(params = new URLSearchParams()) {
  const query = params.toString();
  return request<RunListResponse>(`/runs${query ? `?${query}` : ""}`);
}

export function listAigcPushRecords(params = new URLSearchParams()) {
  const query = params.toString();
  return request<AigcPushRecordListResponse>(`/aigc-push-records${query ? `?${query}` : ""}`);
}

export function getDashboard(runId: string) {
  return request<DashboardResponse>(`/runs/${encodeURIComponent(runId)}/dashboard`);
}

export function getQueries(runId: string) {
  return request<QueryListResponse>(`/runs/${encodeURIComponent(runId)}/queries`);
}

export function getTimeline(runId: string) {
  return request<TimelineResponse>(`/runs/${encodeURIComponent(runId)}/timeline`);
}

export function getContentItems(runId: string) {
  return request<ContentItemsResponse>(`/runs/${encodeURIComponent(runId)}/content-items`);
}

function debugSuffix(debug = false) {
  return debug ? "?debug=true" : "";
}

export function getFlowLedger(runId: string, debug = false) {
  return request<FlowLedgerApiResponse>(
    `/runs/${encodeURIComponent(runId)}/flow-ledger${debugSuffix(debug)}`
  );
}

export function getFlowLedgerVideos(runId: string, queryId: string, debug = false) {
  return request<FlowLedgerVideosResponse>(
    `/runs/${encodeURIComponent(runId)}/flow-ledger/queries/${encodeURIComponent(queryId)}/videos${debugSuffix(debug)}`
  );
}

export function getFlowLedgerWalk(runId: string, queryId: string, debug = false) {
  return request<FlowLedgerWalkResponse>(
    `/runs/${encodeURIComponent(runId)}/flow-ledger/queries/${encodeURIComponent(queryId)}/walk${debugSuffix(debug)}`
  );
}

export function getFlowLedgerVideo(runId: string, contentId: string, debug = false) {
  return request<FlowLedgerVideoResponse>(
    `/runs/${encodeURIComponent(runId)}/flow-ledger/videos/${encodeURIComponent(contentId)}${debugSuffix(debug)}`
  );
}

export function getRunWalk(runId: string, debug = false) {
  return request<FlowLedgerWalkResponse>(
    `/runs/${encodeURIComponent(runId)}/flow-ledger/walk${debugSuffix(debug)}`
  );
}

export function getVideoWalk(runId: string, contentId: string, debug = false) {
  return request<FlowLedgerVideoWalkResponse>(
    `/runs/${encodeURIComponent(runId)}/flow-ledger/videos/${encodeURIComponent(contentId)}/walk${debugSuffix(debug)}`
  );
}