E-handel

curl -X PUT https://newsletter.qrona.se/api/v1/stores/butik-se \
  -H "Authorization: Bearer $QRONA_NEWSLETTER_KEY" \
  -H "Content-Type: application/json" \
  -d '{ "name": "Exempelbutiken", "domain": "butik.se", "currency": "SEK" }'

<?php
// wp-config.php: define('QRONA_NEWSLETTER_KEY', 'qn_live_…'); define('QRONA_STORE_ID', 'butik-se');
const QRONA_API = 'https://newsletter.qrona.se/api/v1';
const QN_CID = '/^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/';

// 1. Kunden kommer från ett utskick: spara qn_cid i 30 dagar.
add_action('init', function () {
    $cid = isset($_GET['qn_cid']) ? sanitize_text_field(wp_unslash($_GET['qn_cid'])) : '';
    if (preg_match(QN_CID, $cid)) {
        setcookie('qn_cid', $cid, time() + 30 * DAY_IN_SECONDS, COOKIEPATH, COOKIE_DOMAIN, is_ssl(), true);
    }
});

// 2. I kassan: kampanjen följer med ordern.
add_action('woocommerce_checkout_create_order', function ($order) {
    $cid = isset($_COOKIE['qn_cid']) ? sanitize_text_field(wp_unslash($_COOKIE['qn_cid'])) : '';
    if (preg_match(QN_CID, $cid)) {
        $order->update_meta_data('_qn_cid', $cid);
    }
});

// 3. När ordern skapas eller byter status: skicka den hel, med kunden.
add_action('woocommerce_order_status_changed', function ($order_id) {
    $order = wc_get_order($order_id);
    $status = [
        'processing' => 'paid', 'completed' => 'paid',
        'refunded' => 'refunded', 'cancelled' => 'cancelled', 'failed' => 'cancelled',
    ][$order->get_status()] ?? 'pending';
    $lines = [];
    foreach ($order->get_items() as $item_id => $item) {
        $lines[] = [
            'id'         => (string) $item_id,
            'product_id' => (string) $item->get_product_id(),
            'variant_id' => $item->get_variation_id() ? (string) $item->get_variation_id() : null,
            'title'      => $item->get_name(),
            'quantity'   => $item->get_quantity(),
            'price'      => round($item->get_total() / max(1, $item->get_quantity()), 2),
        ];
    }
    $email = $order->get_billing_email();
    $body = [
        'customer' => [
            // Gäster har inget kund-id i WooCommerce: adressens hash blir deras id.
            'id'         => $order->get_customer_id() ? (string) $order->get_customer_id() : 'guest-' . md5(strtolower($email)),
            'email'      => $email,
            'first_name' => $order->get_billing_first_name(),
            'last_name'  => $order->get_billing_last_name(),
        ],
        'financial_status' => $status,
        'currency'         => $order->get_currency(),
        'order_total'      => round((float) $order->get_total(), 2),
        'tax_total'        => round((float) $order->get_total_tax(), 2),
        'shipping_total'   => round((float) $order->get_shipping_total(), 2),
        'processed_at'     => $order->get_date_created()->format(DATE_ATOM),
        'lines'            => $lines,
    ];
    if ($order->get_meta('_qn_cid')) {
        $body['campaign_id'] = $order->get_meta('_qn_cid');
    }
    wp_remote_request(QRONA_API . '/stores/' . QRONA_STORE_ID . '/orders/' . $order->get_id(), [
        'method'  => 'PUT',
        'timeout' => 15,
        'headers' => ['Authorization' => 'Bearer ' . QRONA_NEWSLETTER_KEY, 'Content-Type' => 'application/json'],
        'body'    => wp_json_encode($body),
    ]);
});

import { randomUUID } from 'node:crypto';

// Gamla ordrar, 500 i taget. PUT gör att en avbruten import kan köras om från
// början utan dubbletter; Idempotency-Key gör att en batch som skickas om
// (efter ett nätverksfel) får samma svar utan att köras igen.
for (let i = 0; i < orders.length; i += 500) {
  const operations = orders.slice(i, i + 500).map((o) => ({
    method: 'PUT',
    path: `/stores/butik-se/orders/${encodeURIComponent(o.id)}`,
    body: toQronaOrder(o),
  }));
  const idempotencyKey = randomUUID();
  let answer;
  for (let attempt = 1; ; attempt++) {
    const response = await fetch('https://newsletter.qrona.se/api/v1/batch', {
      method: 'POST',
      headers: {
        Authorization: `Bearer ${process.env.QRONA_NEWSLETTER_KEY}`,
        'Content-Type': 'application/json',
        'Idempotency-Key': idempotencyKey,
      },
      body: JSON.stringify({ operations }),
    });
    if (response.ok) { answer = await response.json(); break; }
    if (attempt === 5 || (response.status !== 429 && response.status < 500)) throw new Error(`Batchen svarade ${response.status}`);
    await new Promise((r) => setTimeout(r, Number(response.headers.get('retry-after') ?? 2 ** attempt) * 1000));
  }
  for (const [n, result] of answer.results.entries()) {
    if (result.status >= 400) console.warn(operations[n].path, result.body.code, result.body.errors);
  }
}