Sync incremental contínuo

import express from 'express';
import { createHmac } from 'crypto';

const app = express();

app.post('/shopify/products', express.raw({ type: 'application/json' }), async (req, res) => {
  // 1. valida assinatura Shopify (omitido)
  const product = JSON.parse(req.body);

  // 2. transforma para o schema da Voop
  const voopPayload = {
    externalSystem: 'shopify',
    externalId: String(product.id),
    sku: product.variants[0]?.sku ?? `shopify-${product.id}`,
    name: product.title,
    description: product.body_html,
    price: parseFloat(product.variants[0]?.price ?? '0'),
    tags: product.tags?.split(', ') ?? [],
    media: product.images.map((img, i) => ({
      url: img.src,
      role: i === 0 ? 'primary' : 'gallery',
      sortOrder: i,
    })),
  };

  // 3. push para Voop (idempotente)
  await fetch('https://api.voop.work/api/v1/catalog/items/upsert', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.VOOP_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify(voopPayload),
  });

  res.sendStatus(200);
});

const r = await fetch('.../items/upsert', { ... });
if (r.status === 429) {
  const retry = parseInt(r.headers.get('retry-after') ?? '5', 10);
  // re-enfileira para depois
  await sleep(retry * 1000);
  // retry...
}
if (r.status >= 500) {
  // erro temporário Voop — retry com backoff exponencial
}
if (r.status === 400 || r.status === 409) {
  // payload inválido — alerta o time de integração
}

// cron: 0 3 * * *
const products = await db.fetchAllProducts();

for (const chunk of chunks(products, 500)) {
  const items = chunk.map(transformToVoopFormat);
  const r = await fetch('https://api.voop.work/api/v1/catalog/items/bulk-upsert', {
    method: 'POST',
    headers: { 'Authorization': `Bearer ${VOOP_KEY}`, 'Content-Type': 'application/json' },
    body: JSON.stringify({ items }),
  });
  const { data } = await r.json();
  console.log(`+${data.summary.created} ~${data.summary.updated} =${data.summary.unchanged} ✗${data.summary.failed}`);
}

// Diff: items na Voop mas NÃO no seu sistema → deletar
const voopItems = await listAllVoopItems(); // GET /items com cursor pagination
const localIds = new Set(products.map(p => String(p.id)));

for (const v of voopItems) {
  if (!localIds.has(v.externalId)) {
    await fetch(`https://api.voop.work/api/v1/catalog/items/shopify/${v.externalId}`, {
      method: 'DELETE',
      headers: { 'Authorization': `Bearer ${VOOP_KEY}` },
    });
  }
}