Sync contacts from your app

const BASE = "https://core-service.prod.brudcast.com/api/v1/user";
const headers = {
  "X-API-Key": process.env.BRUDCAST_API_KEY,
  "Content-Type": "application/json",
};

async function call(method, path, body) {
  const res = await fetch(`${BASE}${path}`, {
    method,
    headers,
    body: body ? JSON.stringify(body) : undefined,
  });
  const json = await res.json();
  if (!res.ok) throw new Error(`${res.status} ${json.message}`);
  return json;
}

async function findByEmail(email) {
  const { data } = await call("GET", `/contacts?search=${encodeURIComponent(email)}&limit=10`);
  return data.find((c) => (c.emails ?? []).some((e) => e.email.toLowerCase() === email));
}

export async function upsertContact(user) {
  const email = user.email.trim().toLowerCase();
  const fields = { plan: user.plan };

  let contact = user.brudcastContactId
    ? (await call("GET", `/contacts/${user.brudcastContactId}`)).data
    : await findByEmail(email);

  if (!contact) {
    try {
      const created = await call("POST", "/contacts", {
        firstName: user.firstName || undefined,
        lastName: user.lastName || undefined,
        emails: [{ email, isPrimary: true }],
        customFields: fields,
      });
      return created.data.contact;
    } catch (err) {
      contact = await findByEmail(email); // created by an earlier attempt
      if (!contact) throw err;
    }
  }

  const updated = await call("PATCH", `/contacts/${contact.id}`, {
    firstName: user.firstName || undefined,
    lastName: user.lastName || undefined,
    customFields: { ...(contact.customFields ?? {}), ...fields },
  });
  return updated.data;
}

import os
import requests

BASE = "https://core-service.prod.brudcast.com/api/v1/user"
HEADERS = {"X-API-Key": os.environ["BRUDCAST_API_KEY"]}


def call(method, path, body=None, params=None):
    res = requests.request(method, f"{BASE}{path}", headers=HEADERS, json=body, params=params)
    if not res.ok:
        raise RuntimeError(f"{res.status_code} {res.json().get('message')}")
    return res.json()


def find_by_email(email):
    data = call("GET", "/contacts", params={"search": email, "limit": 10})["data"]
    for contact in data:
        if any(e["email"].lower() == email for e in contact.get("emails") or []):
            return contact
    return None


def upsert_contact(user):
    email = user["email"].strip().lower()
    fields = {"plan": user["plan"]}
    profile = {k: v for k, v in {"firstName": user.get("first_name"),
                                 "lastName": user.get("last_name")}.items() if v}

    if user.get("brudcast_contact_id"):
        contact = call("GET", f"/contacts/{user['brudcast_contact_id']}")["data"]
    else:
        contact = find_by_email(email)

    if contact is None:
        try:
            created = call("POST", "/contacts", {
                **profile,
                "emails": [{"email": email, "isPrimary": True}],
                "customFields": fields,
            })
            return created["data"]["contact"]
        except RuntimeError:
            contact = find_by_email(email)  # created by an earlier attempt
            if contact is None:
                raise

    merged = {**(contact.get("customFields") or {}), **fields}
    return call("PATCH", f"/contacts/{contact['id']}", {**profile, "customFields": merged})["data"]

<?php
function brudcast(string $method, string $path, ?array $body = null): array
{
    $ch = curl_init('https://core-service.prod.brudcast.com/api/v1/user' . $path);
    curl_setopt_array($ch, [
        CURLOPT_CUSTOMREQUEST => $method,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => [
            'X-API-Key: ' . getenv('BRUDCAST_API_KEY'),
            'Content-Type: application/json',
        ],
        CURLOPT_POSTFIELDS => $body === null ? null : json_encode($body),
    ]);
    $payload = json_decode(curl_exec($ch), true);
    if (curl_getinfo($ch, CURLINFO_HTTP_CODE) >= 400) {
        throw new RuntimeException($payload['message'] ?? 'Request failed');
    }
    return $payload;
}

function findByEmail(string $email): ?array
{
    $result = brudcast('GET', '/contacts?' . http_build_query(['search' => $email, 'limit' => 10]));
    foreach ($result['data'] as $contact) {
        foreach ($contact['emails'] ?? [] as $identity) {
            if (strtolower($identity['email']) === $email) {
                return $contact;
            }
        }
    }
    return null;
}

function upsertContact(array $user): array
{
    $email = strtolower(trim($user['email']));
    $fields = ['plan' => $user['plan']];
    $profile = array_filter(['firstName' => $user['first_name'] ?? null, 'lastName' => $user['last_name'] ?? null]);

    $contact = !empty($user['brudcast_contact_id'])
        ? brudcast('GET', '/contacts/' . $user['brudcast_contact_id'])['data']
        : findByEmail($email);

    if ($contact === null) {
        try {
            $created = brudcast('POST', '/contacts', $profile + [
                'emails' => [['email' => $email, 'isPrimary' => true]],
                'customFields' => $fields,
            ]);
            return $created['data']['contact'];
        } catch (RuntimeException $e) {
            $contact = findByEmail($email); // created by an earlier attempt
            if ($contact === null) {
                throw $e;
            }
        }
    }

    $merged = array_merge($contact['customFields'] ?? [], $fields);
    return brudcast('PATCH', '/contacts/' . $contact['id'], $profile + ['customFields' => $merged])['data'];
}