Deliver every ElevenLabs post-call lead to the CRM exactly once.

import { ElevenLabsClient } from "elevenlabs";

const elevenlabs = new ElevenLabsClient();

export async function POST(request: Request) {
  const rawBody = await request.text();
  const signature = request.headers.get("ElevenLabs-Signature");

  let event;
  try {
    event = await elevenlabs.webhooks.constructEvent(
      rawBody,
      signature,
      process.env.ELEVENLABS_WEBHOOK_SECRET
    );
  } catch {
    return Response.json({ error: "Invalid signature" }, { status: 401 });
  }

  if (event.type !== "post_call_transcription") {
    return Response.json({ received: true }, { status: 200 });
  }

  const conversationId = event.data?.conversation_id;
  const fields = event.data?.analysis?.data_collection_results;
  const lead = {
    name: fields?.name?.value,
    email: fields?.email?.value,
    phone: fields?.phone?.value
  };

  if (conversationId && lead.name && lead.email) {
    await deliveryQueue.send({ conversationId, lead });
  }

  return Response.json({ received: true }, { status: 200 });
}

export async function deliverElevenLabsLead({ conversationId, lead }) {
  const response = await fetch(
    "https://leadproof.jessesay.chatgpt.site/api/v1/leads",
    {
      method: "POST",
      headers: {
        Authorization: `Bearer ${process.env.LEADPROOF_API_KEY}`,
        "Content-Type": "application/json",
        "Idempotency-Key": conversationId
      },
      body: JSON.stringify({
        destination: process.env.CRM_WEBHOOK_URL,
        ...lead,
        source: "elevenlabs_post_call"
      })
    }
  );

  if (!response.ok) throw new Error("Lead delivery failed");
  const delivery = await response.json();
  await persistReceipt(conversationId, delivery.receipt?.id);
}