Syncing the catalogue

// A tiny client. Node 18+ (global fetch). Set NUNUA_KEY to the shop's key.
const BASE = 'https://nunuapro.app/api/pos/v1';

async function nunua(path, { method = 'GET', body, idempotencyKey } = {}) {
  const res = await fetch(BASE + path, {
    method,
    headers: {
      Authorization: `Bearer ${process.env.NUNUA_KEY}`,
      'Content-Type': 'application/json',
      ...(idempotencyKey && { 'Idempotency-Key': idempotencyKey }),
    },
    body: body && JSON.stringify(body),
  });
  const json = await res.json().catch(() => ({}));
  if (!res.ok) throw new Error(`${res.status} ${json.error?.code ?? ''} ${json.error?.message ?? ''}`);
  return json;
}

// Send the catalogue in batches of 200 (a full snapshot, so removed products are archived).
async function syncCatalogue(products) {
  const { snapshot_id } = await nunua('/sync/snapshots', { method: 'POST' });
  for (let i = 0; i < products.length; i += 200) {
    const { results } = await nunua(`/sync/snapshots/${snapshot_id}/items`, { method: 'POST', body: { products: products.slice(i, i + 200) } });
    for (const r of results.filter((r) => r.status === 'rejected')) console.warn('rejected', r.external_id, r.errors);
  }
  return nunua(`/sync/snapshots/${snapshot_id}/commit`, { method: 'POST', body: {} });
}

// On every sale / stock receipt / price change.
const updateStock = (items) => nunua('/inventory', { method: 'PATCH', body: { items } });

// Local POS (cannot receive webhooks): poll the change feed, remembering the last event id.
async function pollOrders(handle, after = 0) {
  for (;;) {
    const feed = await nunua(`/events?after=${after}`);
    for (const event of feed.events) {
      await handle(event);              // record the sale / void it, send stock BEFORE the ack
      after = event.event_id;           // persist this so a restart continues from here
    }
    await new Promise((r) => setTimeout(r, 5000));
  }
}

const ack = (orderId, body) => nunua(`/orders/${orderId}/ack`, { method: 'POST', body });

module.exports = { nunua, syncCatalogue, updateStock, pollOrders, ack };

# A tiny client (pip install requests). Set NUNUA_KEY to the shop's key.
import os
import time

import requests

BASE = "https://nunuapro.app/api/pos/v1"


def nunua(path, method="GET", body=None, idempotency_key=None):
    headers = {"Authorization": f"Bearer {os.environ['NUNUA_KEY']}"}
    if idempotency_key:
        headers["Idempotency-Key"] = idempotency_key
    res = requests.request(method, BASE + path, json=body, headers=headers, timeout=30)
    data = res.json() if res.content else {}
    if not res.ok:
        err = data.get("error", {})
        raise RuntimeError(f"{res.status_code} {err.get('code', '')} {err.get('message', '')}")
    return data


def sync_catalogue(products):
    """Send the whole catalogue in batches of 200; products no longer sent are archived."""
    snapshot = nunua("/sync/snapshots", "POST")["snapshot_id"]
    for i in range(0, len(products), 200):
        results = nunua(f"/sync/snapshots/{snapshot}/items", "POST", {"products": products[i : i + 200]})["results"]
        for r in results:
            if r["status"] == "rejected":
                print("rejected", r["external_id"], r["errors"])
    return nunua(f"/sync/snapshots/{snapshot}/commit", "POST", {})


def update_stock(items):
    """On every sale, stock receipt or price change."""
    return nunua("/inventory", "PATCH", {"items": items})


def poll_orders(handle, after=0):
    """Local POS (cannot receive webhooks): poll the change feed, remembering the last event id."""
    while True:
        for event in nunua(f"/events?after={after}")["events"]:
            handle(event)                 # record the sale / void it, send stock BEFORE the ack
            after = event["event_id"]     # persist this so a restart continues from here
        time.sleep(5)


def ack(order_id, body):
    return nunua(f"/orders/{order_id}/ack", "POST", body)

<?php
// A tiny client using only PHP's curl extension. Set NUNUA_KEY to the shop's key.
const NUNUA_BASE = 'https://nunuapro.app/api/pos/v1';

function nunua(string $path, string $method = 'GET', ?array $body = null, ?string $idempotencyKey = null): array
{
    $headers = ['Authorization: Bearer ' . getenv('NUNUA_KEY'), 'Content-Type: application/json'];
    if ($idempotencyKey) {
        $headers[] = 'Idempotency-Key: ' . $idempotencyKey;
    }
    $ch = curl_init(NUNUA_BASE . $path);
    curl_setopt_array($ch, [
        CURLOPT_CUSTOMREQUEST => $method, CURLOPT_HTTPHEADER => $headers, CURLOPT_RETURNTRANSFER => true, CURLOPT_TIMEOUT => 30,
        CURLOPT_POSTFIELDS => $body === null ? null : json_encode($body),
    ]);
    $raw = curl_exec($ch);
    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    $data = json_decode((string) $raw, true) ?? [];
    if ($status >= 400) {
        throw new RuntimeException("$status " . ($data['error']['code'] ?? '') . ' ' . ($data['error']['message'] ?? ''));
    }

    return $data;
}

// Send the whole catalogue in batches of 200; products no longer sent are archived.
function syncCatalogue(array $products): array
{
    $snapshot = nunua('/sync/snapshots', 'POST')['snapshot_id'];
    foreach (array_chunk($products, 200) as $chunk) {
        foreach (nunua("/sync/snapshots/$snapshot/items", 'POST', ['products' => $chunk])['results'] as $r) {
            if ($r['status'] === 'rejected') {
                error_log('rejected ' . $r['external_id'] . ': ' . implode(', ', $r['errors']));
            }
        }
    }

    return nunua("/sync/snapshots/$snapshot/commit", 'POST', []);
}

// On every sale, stock receipt or price change.
function updateStock(array $items): array
{
    return nunua('/inventory', 'PATCH', ['items' => $items]);
}

// Local POS (cannot receive webhooks): poll the change feed, remembering the last event id.
function pollOrders(callable $handle, int $after = 0): void
{
    while (true) {
        foreach (nunua("/events?after=$after")['events'] as $event) {
            $handle($event);               // record the sale / void it, send stock BEFORE the ack
            $after = $event['event_id'];   // persist this so a restart continues from here
        }
        sleep(5);
    }
}

function ack(int $orderId, array $body): array
{
    return nunua("/orders/$orderId/ack", 'POST', $body);
}