Website form to lead

use GuzzleHttp\Client;
use GuzzleHttp\Exception\ClientException;

function sendLeadToKlantly(array $form, string $submissionId): void
{
    $klantly = new Client([
        'base_uri' => 'https://app.klantly.com/api/v1/',
        'headers' => ['Authorization' => 'Bearer ' . getenv('KLANTLY_API_KEY')],
    ]);

    // 1. Does the customer exist already?
    $found = json_decode((string) $klantly->get('customers', [
        'query' => ['filter' => ['email' => $form['email']]],
    ])->getBody(), true)['data'];

    // 2. If not: create the lead.
    $customer = $found[0] ?? json_decode((string) $klantly->post('customers', [
        'headers' => ['Idempotency-Key' => "form-{$submissionId}"],
        'json' => array_filter(['email' => $form['email'], 'name' => $form['name'], 'phone' => $form['phone']]),
    ])->getBody(), true)['data'];

    // 3. The message as a note.
    $klantly->post("customers/{$customer['id']}/notes", [
        'headers' => ['Idempotency-Key' => "form-{$submissionId}-note"],
        'json' => ['content' => $form['message']],
    ]);

    // 4. A deal; 409 means there already is an open deal.
    try {
        $klantly->post('deals', [
            'headers' => ['Idempotency-Key' => "form-{$submissionId}-deal"],
            'json' => ['customer_id' => $customer['id'], 'title' => $form['subject']],
        ]);
    } catch (ClientException $e) {
        if ($e->getResponse()->getStatusCode() !== 409) {
            throw $e;
        }
    }
}

const BASE_URL = 'https://app.klantly.com/api/v1';

async function klantly(method, path, { body, idempotencyKey } = {}) {
  const response = await fetch(`${BASE_URL}/${path}`, {
    method,
    headers: {
      Authorization: `Bearer ${process.env.KLANTLY_API_KEY}`,
      ...(body ? { 'Content-Type': 'application/json' } : {}),
      ...(idempotencyKey ? { 'Idempotency-Key': idempotencyKey } : {}),
    },
    body: body ? JSON.stringify(body) : undefined,
  });

  return { status: response.status, json: await response.json() };
}

export async function sendLeadToKlantly(form, submissionId) {
  // 1. Does the customer exist already?
  const found = await klantly('GET', `customers?${new URLSearchParams({ 'filter[email]': form.email })}`);
  if (found.status !== 200) throw new Error(found.json.detail ?? found.json.title);
  let customer = found.json.data[0];

  // 2. If not: create the lead.
  if (!customer) {
    const created = await klantly('POST', 'customers', {
      body: { email: form.email, name: form.name, ...(form.phone ? { phone: form.phone } : {}) },
      idempotencyKey: `form-${submissionId}`,
    });
    if (created.status !== 201) throw new Error(created.json.detail ?? created.json.title);
    customer = created.json.data;
  }

  // 3. The message as a note.
  await klantly('POST', `customers/${customer.id}/notes`, {
    body: { content: form.message },
    idempotencyKey: `form-${submissionId}-note`,
  });

  // 4. A deal; 409 means there already is an open deal.
  const deal = await klantly('POST', 'deals', {
    body: { customer_id: customer.id, title: form.subject },
    idempotencyKey: `form-${submissionId}-deal`,
  });
  if (deal.status !== 201 && deal.status !== 409) throw new Error(deal.json.detail ?? deal.json.title);
}