Sync customers

const BASE = `${process.env.FLUX_BASE_URL}/api/v1`;
const HEADERS = { Authorization: `ApiKey ${process.env.FLUX_API_KEY}`, "Content-Type": "application/json" };

// workspace: your record. Returns the Flux customer.
export async function syncCustomer(workspace) {
  const ref = `ws_${workspace.id}`;
  const fields = {
    customerType: "company",
    companyName: workspace.companyName,
    legalName: workspace.legalName,
    email: workspace.billingEmail,
    taxId: workspace.tin,
    rcNumber: workspace.rcNumber,
    defaultCurrency: "NGN",
  };

  // 1. Look it up by your reference.
  const found = await fetch(`${BASE}/customers?externalRef=${encodeURIComponent(ref)}`, { headers: HEADERS }).then((r) => r.json());
  const existing = found.data[0];

  if (!existing) {
    // 2. Create it. The Idempotency-Key makes a retry safe.
    const res = await fetch(`${BASE}/customers`, {
      method: "POST",
      headers: { ...HEADERS, "Idempotency-Key": `create-customer-${ref}` },
      body: JSON.stringify({ ...fields, externalRef: ref, contacts: workspace.billingContacts }),
    });
    if (res.status === 409) throw new Error(`Needs a person: ${(await res.json()).message}`);
    if (!res.ok) throw new Error(`Create failed: ${res.status} ${await res.text()}`);
    return res.json();
  }

  // 3. Update only what changed. Leave contacts out unless you mean to replace them.
  const changed = Object.fromEntries(Object.entries(fields).filter(([k, v]) => v != null && existing[k] !== v));
  if (Object.keys(changed).length === 0) return existing;
  const res = await fetch(`${BASE}/customers/${existing.id}`, { method: "PATCH", headers: HEADERS, body: JSON.stringify(changed) });
  if (!res.ok) throw new Error(`Update failed: ${res.status} ${await res.text()}`);
  return res.json();
}

import os

import requests

BASE = f"{os.environ['FLUX_BASE_URL']}/api/v1"
HEADERS = {"Authorization": f"ApiKey {os.environ['FLUX_API_KEY']}"}


def sync_customer(workspace):
    """workspace: your record. Returns the Flux customer."""
    ref = f"ws_{workspace['id']}"
    fields = {
        "customerType": "company",
        "companyName": workspace["company_name"],
        "legalName": workspace["legal_name"],
        "email": workspace["billing_email"],
        "taxId": workspace["tin"],
        "rcNumber": workspace["rc_number"],
        "defaultCurrency": "NGN",
    }

    # 1. Look it up by your reference.
    found = requests.get(f"{BASE}/customers", headers=HEADERS, params={"externalRef": ref}, timeout=30).json()
    existing = found["data"][0] if found["data"] else None

    if existing is None:
        # 2. Create it. The Idempotency-Key makes a retry safe.
        res = requests.post(f"{BASE}/customers", timeout=30,
                            headers={**HEADERS, "Idempotency-Key": f"create-customer-{ref}"},
                            json={**fields, "externalRef": ref, "contacts": workspace["billing_contacts"]})
        if res.status_code == 409:
            raise RuntimeError(f"Needs a person: {res.json()['message']}")
        res.raise_for_status()
        return res.json()

    # 3. Update only what changed. Leave contacts out unless you mean to replace them.
    changed = {k: v for k, v in fields.items() if v is not None and existing.get(k) != v}
    if not changed:
        return existing
    res = requests.patch(f"{BASE}/customers/{existing['id']}", headers=HEADERS, json=changed, timeout=30)
    res.raise_for_status()
    return res.json()