const BASE = "https://api.gsengage.com/api/v1";
const apiKey = process.env.GS_ENGAGE_API_KEY; // nunca deixe a chave no código

const leads = [
  { name: "Maria Silva", company: "Empresa Exemplo", role: "Gerente",
    emails: [{ value: "maria@empresa.com", label: "Trabalho" }] },
  { name: "João Pereira", company: "Comércio ABC", role: "Diretor",
    mobiles: [{ value: "+5511988887777", label: "WhatsApp" }] },
];

async function callWithBackoff(url, options = {}) {
  while (true) {
    const res = await fetch(url, options);
    if (res.status === 429) {
      const wait = Number(res.headers.get("Retry-After") || 5);
      await new Promise((r) => setTimeout(r, wait * 1000));
      continue; // tenta de novo respeitando o Retry-After
    }
    return res;
  }
}

async function upsertLead(lead) {
  const email = lead.emails?.[0]?.value ?? lead.mobiles?.[0]?.value;

  // 1) Procura antes de criar
  const search = await callWithBackoff(
    `${BASE}/leads?search=${encodeURIComponent(email)}&apiKey=${apiKey}`
  );
  const found = (await search.json()).data ?? [];
  if (found.length > 0) {
    console.log(`Já existe: ${lead.name} — pulando`);
    return;
  }

  // 2) Cria
  const res = await callWithBackoff(`${BASE}/leads?apiKey=${apiKey}`, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify(lead),
  });
  if (!res.ok) {
    const { error } = await res.json(); // erros vêm dentro de "error"
    console.error(`Falha em ${lead.name}: ${error?.message}`);
    return;
  }
  console.log(`Criado: ${lead.name}`);
}

for (const lead of leads) {
  await upsertLead(lead); // sequencial, sem estourar o limite
}

import os, time, requests

BASE = "https://api.gsengage.com/api/v1"
api_key = os.environ["GS_ENGAGE_API_KEY"]  # nunca deixe a chave no código

leads = [
    {"name": "Maria Silva", "company": "Empresa Exemplo", "role": "Gerente",
     "emails": [{"value": "maria@empresa.com", "label": "Trabalho"}]},
    {"name": "João Pereira", "company": "Comércio ABC", "role": "Diretor",
     "mobiles": [{"value": "+5511988887777", "label": "WhatsApp"}]},
]

def call_with_backoff(method, url, **kwargs):
    while True:
        res = requests.request(method, url, **kwargs)
        if res.status_code == 429:
            wait = int(res.headers.get("Retry-After", "5"))
            time.sleep(wait)  # respeita o Retry-After e tenta de novo
            continue
        return res

def upsert_lead(lead):
    email = (lead.get("emails") or lead.get("mobiles"))[0]["value"]

    # 1) Procura antes de criar
    search = call_with_backoff(
        "GET", f"{BASE}/leads", params={"search": email, "apiKey": api_key}
    )
    if search.json().get("data"):
        print(f"Já existe: {lead['name']} — pulando")
        return

    # 2) Cria
    res = call_with_backoff(
        "POST", f"{BASE}/leads",
        params={"apiKey": api_key}, json=lead
    )
    if not res.ok:
        print(f"Falha em {lead['name']}: {res.json().get('message')}")
        return
    print(f"Criado: {lead['name']}")

for lead in leads:
    upsert_lead(lead)  # sequencial, sem estourar o limite