Receber Ligações

curl -X POST https://api.d-api.cloud/api/v1/sessions/minha-sessao/receive-calls-settings \
  -H "Authorization: SUA_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{ "receiveCalls": true }'

{
  "message": "Receive calls setting updated successfully",
  "sessionId": "minha-sessao",
  "receiveCalls": true,
  "updatedAt": "2026-05-26T12:00:00.000Z"
}

wss://api.d-api.cloud/voip/events?token=SUA_API_KEY&sessions=sessao-1,sessao-2

{ "type": "subscribed", "sessions": ["sessao-1", "sessao-2"] }

{ "type": "error", "code": "unauthorized", "msg": "Invalid API key or session not owned" }

{
  "type": "call.offer",
  "callId": "ABCD1234",
  "from": "5511999999999@s.whatsapp.net",
  "callCreator": "201234567890123@lid",
  "timestamp": 1716724496789,
  "sessionId": "minha-sessao"
}

curl -X POST https://api.d-api.cloud/api/v1/calls/accept \
  -H "Authorization: SUA_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{ "sessionId": "minha-sessao", "callId": "ABCD1234" }'

{
  "success": true,
  "sessionId": "minha-sessao",
  "callId": "ABCD1234",
  "wsUrl": "wss://api.d-api.cloud/voip/stream?callId=ABCD1234&token=...",
  "token": "..."
}

curl -X POST https://api.d-api.cloud/api/v1/calls/reject \
  -H "Authorization: SUA_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
        "sessionId": "minha-sessao",
        "callId": "ABCD1234",
        "from": "5511999999999@s.whatsapp.net"
      }'

{ "success": true, "sessionId": "minha-sessao" }

// Node.js 18+ — npm i ws
import WebSocket from "ws";

const HOST = "api.d-api.cloud";
const API_KEY = process.env.DAPI_API_KEY;
const SESSIONS = ["minha-sessao"];

const api = (path, body) =>
  fetch(`https://${HOST}/api/v1${path}`, {
    method: "POST",
    headers: { "Content-Type": "application/json", Authorization: API_KEY },
    body: JSON.stringify(body),
  }).then((r) => r.json());

function assinarEventos() {
  const url = `wss://${HOST}/voip/events?token=${encodeURIComponent(API_KEY)}&sessions=${SESSIONS.join(",")}`;
  const ws = new WebSocket(url);

  ws.on("message", async (raw) => {
    const ev = JSON.parse(raw.toString());

    if (ev.type === "error") {
      console.error("assinatura recusada:", ev.code, ev.msg);
      return;
    }
    if (ev.type === "subscribed") {
      console.log("assinado:", ev.sessions);
      return;
    }
    if (ev.type !== "call.offer") {
      console.log("evento:", ev.type, ev.callId);
      return;
    }

    console.log(`chamada de ${ev.from} na sessão ${ev.sessionId}`);
    await atender(ev.sessionId, ev.callId);
  });

  // Sem replay: uma queda perde as ofertas do intervalo. Reconecte rápido.
  ws.on("close", () => setTimeout(assinarEventos, 1000));
  ws.on("error", (err) => console.error("events ws:", err.message));
}

async function atender(sessionId, callId) {
  const res = await api("/calls/accept", { sessionId, callId });
  if (!res.success) {
    console.error("falha ao atender:", res.error);
    return;
  }
  conectarMidia(res.wsUrl);
}

// Daqui em diante é o mesmo fluxo da página de Ligações por Stream:
// frames binários = PCM s16le 16 kHz mono; frames de texto = ciclo de vida.
function conectarMidia(wsUrl) {
  const media = new WebSocket(wsUrl);
  let podeEnviarAudio = false;

  media.on("message", (data, isBinary) => {
    if (isBinary) {
      reproduzir(data); // áudio de quem ligou
      return;
    }
    const msg = JSON.parse(data.toString());
    if (msg.type === "accepted" || msg.type === "connected") podeEnviarAudio = true;
    if (msg.type === "ended" || msg.type === "error") media.close();
    console.log("mídia:", msg.type);
  });

  // Envie o microfone em frames de 640 bytes (320 amostras = 20 ms),
  // em cadência de tempo real, só depois de `accepted`.
  onFrameDoMicrofone((pcm) => {
    if (podeEnviarAudio && media.readyState === WebSocket.OPEN) media.send(pcm);
  });

  media.on("close", () => console.log("chamada encerrada"));
}

assinarEventos();

await api("/calls/reject", { sessionId: ev.sessionId, callId: ev.callId, from: ev.from });