Synchroniser vos clients vers la liste d'exclusion

import { call } from "./retriever.mjs";

const chunk = (array, size = 1000) =>
  Array.from({ length: Math.ceil(array.length / size) }, (_, i) => array.slice(i * size, (i + 1) * size));

/**
 * crmDomains : domaines actuels du CRM.
 * registry   : Set persistant (votre base) des domaines canoniques gérés par cette synchro.
 */
export async function syncCompanies(crmDomains, registry, { prune = false, maxPruneRatio = 0.2 } = {}) {
  if (crmDomains.length === 0) throw new Error("Export CRM vide : synchro annulée par sécurité.");

  // 1. Upsert. La réponse ne renvoie pas la forme canonique, on relit la liste ensuite.
  for (const domains of chunk([...new Set(crmDomains)])) {
    const { invalid } = await call("/v1/exclusions/companies", { method: "POST", body: { domains } });
    if (invalid.length) console.warn("Valeurs ignorées :", invalid); // [{ value, reason }]
  }

  // 2. Lire la liste canonique complète
  const current = new Set();
  for (let offset = 0; offset !== null; ) {
    const page = await call(`/v1/exclusions/companies?limit=1000&offset=${offset}`);
    page.items.forEach((item) => current.add(item.domain));
    offset = page.next_offset;
  }

  // 3. Même normalisation que le serveur : minuscules, sans protocole, chemin ni "www."
  const canonical = (value) => {
    try {
      const url = new URL(/^[a-z][a-z\d+.-]*:\/\//i.test(value.trim()) ? value.trim() : `https://${value.trim()}`);
      return url.hostname.toLowerCase().replace(/\.$/, "").replace(/^www\./, "");
    } catch {
      return null;
    }
  };
  const wanted = new Set(crmDomains.map(canonical).filter(Boolean));
  wanted.forEach((d) => current.has(d) && registry.add(d));

  // 4. Retrait optionnel, limité aux domaines gérés par la synchro
  const toRemove = [...registry].filter((d) => !wanted.has(d));
  if (!prune || toRemove.length === 0) return { removed: 0, pending: toRemove.length };
  if (toRemove.length > registry.size * maxPruneRatio) {
    throw new Error(`Retrait de ${toRemove.length}/${registry.size} domaines refusé : vérifiez l'export CRM.`);
  }
  let removed = 0;
  for (const domains of chunk(toRemove)) {
    removed += (await call("/v1/exclusions/companies/remove", { method: "POST", body: { domains } })).removed;
    domains.forEach((d) => registry.delete(d));
  }
  return { removed, pending: 0 };
}