# Requer jq. Grava cada versão lida em orders.ndjson (carregue no seu banco com upsert por id:
# a última linha de cada id é a mais nova) e guarda a marca em zouti-mark.txt.
mark=$(cat zouti-mark.txt 2>/dev/null || true)
since=""
if [ -n "$mark" ]; then
  # marca − 5 min; o jq faz a conta igual no Linux e no macOS
  since=$(jq -rn --arg m "$mark" '$m | sub("\\.[0-9]+Z$"; "Z") | fromdate - 300 | todate')
fi
cursor=""
while :; do
  page=$(curl -sS -G "https://api.zouti.com.br/v1/orders" \
    -H "Authorization: Bearer $ZOUTI_API_KEY" \
    --data-urlencode "sort=updated_at_asc" \
    --data-urlencode "limit=100" \
    ${since:+--data-urlencode "updated_gte=$since"} \
    ${cursor:+--data-urlencode "cursor=$cursor"})
  echo "$page" | jq -e '.data' > /dev/null || { echo "$page" >&2; exit 1; }
  echo "$page" | jq -c '.data[]' >> orders.ndjson
  page_mark=$(echo "$page" | jq -r '[.data[].updated_at | select(. != null)] | max // empty')
  if [ -n "$page_mark" ] && [[ "$page_mark" > "$mark" ]]; then mark=$page_mark; fi
  [ "$(echo "$page" | jq -r '.has_more')" = "true" ] || break
  cursor=$(echo "$page" | jq -r '.next_cursor')
done
if [ -n "$mark" ]; then echo "$mark" > zouti-mark.txt; fi

// Node.js 18+ (fetch nativo). Sincroniza os pedidos num arquivo local, zouti-orders.json.
// Rode de tempos em tempos: a 1ª execução faz a carga completa; as seguintes leem só o que
// mudou. Troque o arquivo pelo seu banco de dados.
import { existsSync, readFileSync, writeFileSync } from 'node:fs';

const API_KEY = process.env.ZOUTI_API_KEY;
const BASE_URL = 'https://api.zouti.com.br';
const STATE_FILE = 'zouti-orders.json';
const OVERLAP_MS = 5 * 60 * 1000;

// Estado: a marca (maior updated_at já lido) e a cópia dos pedidos por id.
const state = existsSync(STATE_FILE)
  ? JSON.parse(readFileSync(STATE_FILE, 'utf8'))
  : { mark: null, orders: {} };

async function listPage(query) {
  const response = await fetch(`${BASE_URL}/v1/orders?${query}`, {
    headers: { Authorization: `Bearer ${API_KEY}` },
  });
  const body = await response.json();
  if (!response.ok) {
    throw new Error(`${body.error.code}: ${body.error.message} (${body.error.request_id})`);
  }
  return body;
}

const query = new URLSearchParams({ sort: 'updated_at_asc', limit: '100' });
if (state.mark) {
  query.set('updated_gte', new Date(Date.parse(state.mark) - OVERLAP_MS).toISOString());
}

let mark = state.mark;
let read = 0;
let cursor = null;
do {
  if (cursor) query.set('cursor', cursor);
  const page = await listPage(query);
  for (const order of page.data) {
    state.orders[order.id] = order; // upsert: a versão lida substitui a anterior
    // Datas em UTC no mesmo formato: comparar como texto dá a ordem cronológica.
    if (order.updated_at && (!mark || order.updated_at > mark)) mark = order.updated_at;
    read++;
  }
  cursor = page.has_more ? page.next_cursor : null;
} while (cursor);

// A marca só avança depois da última página.
state.mark = mark;
writeFileSync(STATE_FILE, JSON.stringify(state));
console.log(`${read} pedidos lidos; ${Object.keys(state.orders).length} na cópia local; marca ${mark}`);

# Python 3 com requests. Sincroniza os pedidos num arquivo local, zouti-orders.json.
# Rode de tempos em tempos: a 1ª execução faz a carga completa; as seguintes leem só o que
# mudou. Troque o arquivo pelo seu banco de dados.
import json
import os
from datetime import datetime, timedelta

import requests

API_KEY = os.environ["ZOUTI_API_KEY"]
BASE_URL = "https://api.zouti.com.br"
STATE_FILE = "zouti-orders.json"
OVERLAP = timedelta(minutes=5)

# Estado: a marca (maior updated_at já lido) e a cópia dos pedidos por id.
if os.path.exists(STATE_FILE):
    with open(STATE_FILE, encoding="utf-8") as file:
        state = json.load(file)
else:
    state = {"mark": None, "orders": {}}


def list_page(params):
    response = requests.get(
        f"{BASE_URL}/v1/orders",
        params=params,
        headers={"Authorization": f"Bearer {API_KEY}"},
        timeout=30,
    )
    body = response.json()
    if not response.ok:
        error = body["error"]
        raise RuntimeError(f"{error['code']}: {error['message']} ({error['request_id']})")
    return body


params = {"sort": "updated_at_asc", "limit": 100}
if state["mark"]:
    mark_time = datetime.fromisoformat(state["mark"].replace("Z", "+00:00"))
    since = mark_time - OVERLAP
    params["updated_gte"] = since.isoformat(timespec="milliseconds").replace("+00:00", "Z")

mark = state["mark"]
read = 0
while True:
    page = list_page(params)
    for order in page["data"]:
        state["orders"][order["id"]] = order  # upsert: a versão lida substitui a anterior
        # Datas em UTC no mesmo formato: comparar como texto dá a ordem cronológica.
        if order["updated_at"] and (mark is None or order["updated_at"] > mark):
            mark = order["updated_at"]
        read += 1
    if not page["has_more"]:
        break
    params["cursor"] = page["next_cursor"]

# A marca só avança depois da última página.
state["mark"] = mark
with open(STATE_FILE, "w", encoding="utf-8") as file:
    json.dump(state, file)
print(f"{read} pedidos lidos; {len(state['orders'])} na cópia local; marca {mark}")

<?php
// PHP 7.4+ com a extensão curl. Sincroniza os pedidos num arquivo local, zouti-orders.json.
// Rode de tempos em tempos: a 1ª execução faz a carga completa; as seguintes leem só o que
// mudou. Troque o arquivo pelo seu banco de dados.
const BASE_URL = 'https://api.zouti.com.br';
const STATE_FILE = 'zouti-orders.json';
const OVERLAP_SECONDS = 5 * 60;

// Estado: a marca (maior updated_at já lido) e a cópia dos pedidos por id.
$state = is_file(STATE_FILE)
    ? json_decode(file_get_contents(STATE_FILE), true)
    : ['mark' => null, 'orders' => []];

function list_page(array $query): array
{
    $ch = curl_init(BASE_URL . '/v1/orders?' . http_build_query($query));
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_TIMEOUT => 30,
        CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('ZOUTI_API_KEY')],
    ]);
    $raw = curl_exec($ch);
    if ($raw === false) {
        throw new RuntimeException(curl_error($ch));
    }
    $body = json_decode($raw, true);
    if (curl_getinfo($ch, CURLINFO_RESPONSE_CODE) !== 200) {
        $error = $body['error'];
        throw new RuntimeException("{$error['code']}: {$error['message']} ({$error['request_id']})");
    }
    return $body;
}

$query = ['sort' => 'updated_at_asc', 'limit' => 100];
if ($state['mark'] !== null) {
    $since = (new DateTimeImmutable($state['mark']))->modify('-' . OVERLAP_SECONDS . ' seconds');
    $query['updated_gte'] = $since->setTimezone(new DateTimeZone('UTC'))->format('Y-m-d\TH:i:s.v\Z');
}

$mark = $state['mark'];
$read = 0;
do {
    $page = list_page($query);
    foreach ($page['data'] as $order) {
        $state['orders'][$order['id']] = $order; // upsert: a versão lida substitui a anterior
        // Datas em UTC no mesmo formato: comparar como texto dá a ordem cronológica.
        if ($order['updated_at'] !== null && ($mark === null || strcmp($order['updated_at'], $mark) > 0)) {
            $mark = $order['updated_at'];
        }
        $read++;
    }
    $query['cursor'] = $page['next_cursor'];
} while ($page['has_more']);

// A marca só avança depois da última página.
$state['mark'] = $mark;
file_put_contents(STATE_FILE, json_encode($state));
printf("%d pedidos lidos; %d na cópia local; marca %s\n", $read, count($state['orders']), $mark ?? '-');

{
  "object": "list",
  "data": [
    {
      "object": "order",
      "id": "ord_1q3s5u7w9y0a2c4e6g8i0k",
      "role": "COPRODUCER",
      "status": "PAID",
      "currency": "BRL",
      "amount_total": 9700,
      "amount_subtotal": 9700,
      "amount_in_brl": 9700,
      "created_at": "2026-10-13T18:42:10.036Z",
      "paid_at": "2026-10-13T18:43:51.274Z",
      "canceled_at": null,
      "updated_at": "2026-10-13T18:43:52.009Z",
      "customer": {
        "name": "Maria Oliveira",
        "email": "maria.oliveira@example.com",
        "phone": "+5511999998888",
        "document": "12345678909",
        "document_type": "CPF"
      },
      "shipping_address": null,
      "payment": {
        "method": "PIX",
        "status": "PAID",
        "installments": 1,
        "amount": 9700,
        "interest_amount": 0,
        "discount_amount": 0,
        "fee": 485,
        "amount_refunded": 0,
        "refunded_at": null,
        "decline_code": null,
        "decline_message": null,
        "card": null
      },
      "items": [
        {
          "product_id": "prod_9x1z3b5d7f9h1k3m5p7r9t",
          "name": "Mentoria em Grupo",
          "quantity": 1,
          "unit_price": 9700,
          "sub_total": 9700,
          "currency": "BRL",
          "offer_id": "prod_offer_4w6y8a0c2e4g6j8l0n2q4s",
          "plan_id": null,
          "order_bump_id": null
        }
      ],
      "offer": {
        "id": "prod_offer_4w6y8a0c2e4g6j8l0n2q4s",
        "name": "Mentoria em Grupo"
      },
      "promocode": null,
      "utm": null,
      "tracking": null,
      "navigator": null,
      "metadata": {
        "order_parent_id": "ord_7h9k1m3p5r7t9v1x3z5b7d"
      }
    },
    {
      "object": "order",
      "id": "ord_8k2m4q6s1v3x5z7b9d0f2h",
      "role": "OWNER",
      "status": "PAID",
      "currency": "BRL",
      "amount_total": 27730,
      "amount_subtotal": 29700,
      "amount_in_brl": 27730,
      "created_at": "2026-10-14T13:05:22.418Z",
      "paid_at": "2026-10-14T13:05:24.902Z",
      "canceled_at": null,
      "updated_at": "2026-10-14T13:05:25.117Z",
      "customer": {
        "name": "Maria Oliveira",
        "email": "maria.oliveira@example.com",
        "phone": "+5511999998888",
        "document": "12345678909",
        "document_type": "CPF"
      },
      "shipping_address": {
        "line1": "Rua das Flores",
        "line2": "123",
        "line3": "Apto 45",
        "neighborhood": "Centro",
        "city": "São Paulo",
        "state": "SP",
        "country": "BR",
        "postal_code": "01001000",
        "full_name": "Maria Oliveira"
      },
      "payment": {
        "method": "CREDIT_CARD",
        "status": "PAID",
        "installments": 1,
        "amount": 27730,
        "interest_amount": 0,
        "discount_amount": 1970,
        "fee": 1386,
        "amount_refunded": 0,
        "refunded_at": null,
        "decline_code": null,
        "decline_message": null,
        "card": {
          "brand": "MASTERCARD",
          "last4": "4242"
        }
      },
      "items": [
        {
          "product_id": "prod_3n7p1r5t9w2y4a6c8e0g1j",
          "name": "Curso Completo de Fotografia",
          "quantity": 1,
          "unit_price": 19700,
          "sub_total": 19700,
          "currency": "BRL",
          "offer_id": "prod_offer_5d1f3h7k9m2p4r6t8v0x2z",
          "plan_id": null,
          "order_bump_id": null
        },
        {
          "product_id": "prod_6b8d0f2h4k6m8p0r2t4v6x",
          "name": "Pacote de Presets",
          "quantity": 1,
          "unit_price": 10000,
          "sub_total": 10000,
          "currency": "BRL",
          "offer_id": null,
          "plan_id": null,
          "order_bump_id": "ob_2c4e6g8j0l2n4q6s8u0w2y"
        }
      ],
      "offer": {
        "id": "prod_offer_5d1f3h7k9m2p4r6t8v0x2z",
        "name": "Oferta de lançamento"
      },
      "promocode": {
        "code": "BEMVINDO10",
        "description": "10% de desconto no curso",
        "amount": -1970
      },
      "utm": {
        "utm_source": "instagram",
        "utm_medium": "social",
        "utm_campaign": "lancamento-outubro",
        "utm_term": null,
        "utm_content": "stories"
      },
      "tracking": {
        "sck": "parceiro-123",
        "src": "bio"
      },
      "navigator": {
        "user_agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 18_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 Instagram 350.0.0",
        "referer": "https://www.instagram.com/",
        "device": "Mobile",
        "browser": "Instagram",
        "origin": "instagram.com"
      },
      "metadata": {}
    }
  ],
  "has_more": false,
  "next_cursor": null
}