Exemplo de integração: webphone + CRM

const express = require("express");
const app = express();

const SECRET = process.env.IPBOX_WEBHOOK_SECRET;
const eventosVistos = new Set();       // produção: tabela/Redis com expiração
const ultimaSequencia = new Map();     // produção: coluna na tabela de ligações

app.post("/webhook-ipbox", express.json(), (req, res) => {
  if (req.get("X-Webhook-Secret") !== SECRET) return res.sendStatus(401);
  res.sendStatus(200); // responde já; processa depois
  setImmediate(() => processar(req.body).catch(console.error));
});

async function processar(ev) {
  if (ev.evento === "agente.busy") return tratarAgenteBusy(ev);
  if (!ev.evento || !ev.evento.startsWith("ligacao.")) return;

  if (eventosVistos.has(ev.evento_id)) return;               // duplicado
  eventosVistos.add(ev.evento_id);

  if ((ultimaSequencia.get(ev.ligacao_id) || 0) >= ev.sequencia) return; // antigo
  ultimaSequencia.set(ev.ligacao_id, ev.sequencia);

  switch (ev.evento) {
    case "ligacao.recebida": {
      // entrante chegou: ainda não há agente (ramal/usuario_id nulos)
      const cliente = await buscarClientePorTelefone(ev.numero_origem);
      await registrarLigacaoEmAndamento(ev.ligacao_id, ev, cliente);
      break;
    }
    case "ligacao.tocando":
    case "ligacao.discando": {
      // agora o evento já traz o agente (usuario_id) que está sendo chamado
      if (ev.usuario_id) {
        const numero = ev.direcao === "sainte" ? ev.numero_destino : ev.numero_origem;
        const cliente = await buscarClientePorTelefone(numero);
        await abrirFichaParaAgente(ev.usuario_id, cliente); // screen pop
      }
      break;
    }
    case "ligacao.atendida":
    case "ligacao.conectada":
      await marcarInicioConversa(ev.ligacao_id, ev.ocorrido_em, ev.usuario_id);
      break;
    case "ligacao.encerrada":
      await gravarHistorico(ev.ligacao_id, {
        resultado: ev.resultado,             // atendida, abandonada, desligada, falha...
        motivo: ev.motivo,
        duracao: ev.duracao,
        duracaoAtendida: ev.duracao_atendida,
        gravacaoUrl: ev.gravacao_url,
        agente: ev.usuario_id,
      });
      break;
  }
}

// O agente entrou na ligação: aqui chega o código do prospect.
async function tratarAgenteBusy(ev) {
  // codigo = identificador do prospect cadastrado no IPBoX (vazio em ligações sem prospect)
  const prospect = ev.codigo
    ? await buscarProspectPorCodigo(ev.codigo)
    : await buscarClientePorTelefone(ev.numero);
  await vincularLigacaoAoAgente(ev.usuario_id, ev.numero, prospect);
  await abrirFichaParaAgente(ev.usuario_id, prospect); // screen pop
}

// As funções abaixo são do SEU CRM:
async function buscarProspectPorCodigo(codigo) { /* SELECT ... WHERE codigo = ? */ }
async function vincularLigacaoAoAgente(usuarioId, numero, prospect) { /* UPDATE ... */ }
async function buscarClientePorTelefone(telefone) { /* SELECT ... */ }
async function registrarLigacaoEmAndamento(ligacaoId, ev, cliente) { /* INSERT ... */ }
async function abrirFichaParaAgente(usuarioId, cliente) { /* envia ao navegador (SSE/WebSocket) */ }
async function marcarInicioConversa(ligacaoId, quando, usuarioId) { /* UPDATE ... */ }
async function gravarHistorico(ligacaoId, dados) { /* UPDATE ... */ }

app.listen(3000);

<?php
$secret = getenv('IPBOX_WEBHOOK_SECRET');
if (($_SERVER['HTTP_X_WEBHOOK_SECRET'] ?? '') !== $secret) {
    http_response_code(401);
    exit;
}

$ev = json_decode(file_get_contents('php://input'), true);

// Responde 200 já e continua processando
http_response_code(200);
header('Connection: close');
header('Content-Length: 0');
if (function_exists('fastcgi_finish_request')) {
    fastcgi_finish_request();
}

// Eventos de agente não têm evento_id/sequencia: tratados à parte.
if (($ev['evento'] ?? '') === 'agente.busy') {
    // codigo = identificador do prospect cadastrado no IPBoX (vazio em ligações sem prospect)
    $prospect = !empty($ev['codigo'])
        ? buscarProspectPorCodigo($ev['codigo'])
        : buscarClientePorTelefone($ev['numero']);
    vincularLigacaoAoAgente($ev['usuario_id'], $ev['numero'], $prospect);
    abrirFichaParaAgente($ev['usuario_id'], $prospect);
    exit;
}

if (!isset($ev['evento']) || strpos($ev['evento'], 'ligacao.') !== 0) {
    exit;
}

// Duplicado ou antigo? (tabela com evento_id único e última sequência por ligação)
if (jaProcessado($ev['evento_id']) || $ev['sequencia'] <= ultimaSequencia($ev['ligacao_id'])) {
    exit;
}
marcarProcessado($ev['evento_id'], $ev['ligacao_id'], $ev['sequencia']);

switch ($ev['evento']) {
    case 'ligacao.recebida':
        $cliente = buscarClientePorTelefone($ev['numero_origem']);
        registrarLigacaoEmAndamento($ev['ligacao_id'], $ev, $cliente);
        break;
    case 'ligacao.tocando':
    case 'ligacao.discando':
        if (!empty($ev['usuario_id'])) {
            $numero = $ev['direcao'] === 'sainte' ? $ev['numero_destino'] : $ev['numero_origem'];
            abrirFichaParaAgente($ev['usuario_id'], buscarClientePorTelefone($numero));
        }
        break;
    case 'ligacao.atendida':
    case 'ligacao.conectada':
        marcarInicioConversa($ev['ligacao_id'], $ev['ocorrido_em'], $ev['usuario_id']);
        break;
    case 'ligacao.encerrada':
        gravarHistorico($ev['ligacao_id'], array(
            'resultado' => $ev['resultado'],
            'motivo' => $ev['motivo'],
            'duracao' => $ev['duracao'],
            'duracaoAtendida' => $ev['duracao_atendida'],
            'gravacaoUrl' => $ev['gravacao_url'] ?? null,
            'agente' => $ev['usuario_id'],
        ));
        break;
}
// As funções acima (jaProcessado, buscarProspectPorCodigo...) são do SEU CRM.