const ACCEPT = "application/json, text/event-stream";

function parseMcpResponse(text) {
  const trimmed = text.trim();
  if (!trimmed) throw new Error("Empty MCP response");
  if (trimmed.startsWith("{")) {
    return JSON.parse(trimmed);
  }
  if (trimmed.includes("event:") || trimmed.includes("data:")) {
    let payload = "";
    for (const line of trimmed.split(/\r?\n/)) {
      if (line.startsWith("data:")) payload += line.slice(5).trim();
    }
    if (payload.startsWith("{")) return JSON.parse(payload);
  }
  throw new Error(`Unrecognized MCP response format: ${trimmed.slice(0, 200)}`);
}

export class McpClient {
  constructor(url) {
    this.url = url;
    this.seq = 0;
  }

  async request(method, params = {}) {
    this.seq += 1;
    const res = await fetch(this.url, {
      method: "POST",
      headers: { "Content-Type": "application/json", Accept: ACCEPT },
      body: JSON.stringify({ jsonrpc: "2.0", id: this.seq, method, params }),
    });
    if (!res.ok) {
      throw new Error(`MCP HTTP ${res.status}: ${(await res.text()).slice(0, 300)}`);
    }
    const rpc = parseMcpResponse(await res.text());
    if (rpc.error) throw new Error(`MCP RPC error ${rpc.error.code}: ${rpc.error.message}`);
    return rpc;
  }

  async listTools() {
    const rpc = await this.request("tools/list");
    return rpc.result?.tools ?? [];
  }

  async callTool(name, args = {}) {
    const rpc = await this.request("tools/call", { name, arguments: args });
    return rpc.result;
  }
}

export function textContentFrom(result) {
  if (!result?.content) return "";
  return result.content
    .map((b) => (b.type === "text" ? b.text : JSON.stringify(b)))
    .join(" ");
}