Sincronizar contatos com um sistema externo

async function lerTodosOsContatos() {
  const contatos = [];
  let cursor = null;

  do {
    const params = new URLSearchParams({ limit: '100' });
    if (cursor) params.set('cursor', cursor);

    const res = await fetch(`https://api.socialsell.ai/v1/contacts?${params}`, {
      headers: { Authorization: `Bearer ${process.env.SOCIALSELL_API_KEY}` },
    });
    const { data, meta } = await res.json();

    contatos.push(...data);
    cursor = meta.has_more ? meta.next_cursor : null;
  } while (cursor);

  return contatos;
}

curl "https://api.socialsell.ai/v1/contacts?updated_after=2026-08-25T00:00:00.000Z&limit=100" \
  -H "Authorization: Bearer sk_live_..."

async function criarOuAtualizar(contato) {
  const res = await fetch('https://api.socialsell.ai/v1/contacts', {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${process.env.SOCIALSELL_API_KEY}`,
      'Content-Type': 'application/json',
      'Idempotency-Key': contato.idExterno, // um UUID estável por contato do seu lado
    },
    body: JSON.stringify(contato),
  });

  if (res.ok) return (await res.json()).data;

  const { error } = await res.json();

  if (error.code === 'DUPLICATE_CONTACT') {
    const id = error.existing_contact.id;
    const patch = await fetch(`https://api.socialsell.ai/v1/contacts/${id}`, {
      method: 'PATCH',
      headers: {
        Authorization: `Bearer ${process.env.SOCIALSELL_API_KEY}`,
        'Content-Type': 'application/json',
      },
      body: JSON.stringify(contato),
    });
    return (await patch.json()).data;
  }

  throw new Error(`[${error.code}] ${error.message}`);
}

curl -X POST https://api.socialsell.ai/v1/webhooks \
  -H "Authorization: Bearer sk_live_..." \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Sincronização ERP",
    "url": "https://meusistema.com/webhooks/socialsell",
    "events": ["contact.created", "contact.updated"]
  }'