Turn Retell call analysis into verified CRM delivery.

import { Retell } from "retell-sdk";

app.use(
  "/retell/call-analyzed",
  express.raw({ type: "application/json" })
);

app.post("/retell/call-analyzed", async (req, res) => {
  const rawBody = req.body.toString("utf-8");
  const signature = req.headers["x-retell-signature"];
  const isAuthentic = Retell.verify(
    rawBody,
    process.env.RETELL_API_KEY,
    signature
  );
  if (!isAuthentic) return res.sendStatus(401);

  const { event, call } = JSON.parse(rawBody);
  if (event !== "call_analyzed") return res.sendStatus(204);

  const lead = call.call_analysis?.custom_analysis_data;
  if (!call.call_id || !lead?.name || !lead?.email) {
    return res.sendStatus(204);
  }

  await deliveryQueue.send({
    callId: call.call_id,
    lead: { name: lead.name, email: lead.email, phone: lead.phone }
  });
  return res.sendStatus(204);
});

export async function deliverRetellLead({ callId, 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": callId
      },
      body: JSON.stringify({
        destination: process.env.CRM_WEBHOOK_URL,
        ...lead,
        source: "retell_call_analyzed"
      })
    }
  );

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