import { API_BASE_URL } from "@/lib/config";

export interface InitVisitorConversationPayload {
  visitorId: number;
  website?: string;
  referrer?: string;
  browser?: string;
  os?: string;
  language?: string;
  ipAddress?: string;
}

export interface InitVisitorConversationResult {
  conversation_id: number;
  status: string;
}

export async function initVisitorConversation(
  payload: InitVisitorConversationPayload
): Promise<InitVisitorConversationResult> {
  const res = await fetch(`${API_BASE_URL}/conversation/init`, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({
      visitor_id: payload.visitorId,
      website: payload.website,
      referrer: payload.referrer,
      browser: payload.browser,
      os: payload.os,
      language: payload.language,
      ip_address: payload.ipAddress,
    }),
  });

  if (!res.ok) {
    throw new Error("初始化对话失败");
  }

  const data = await res.json();
  return {
    conversation_id: data.conversation_id ?? 0,
    status: data.status ?? "open",
  };
}