Integração com ERP genérico

ERP ──polling──▶ Middleware (Cloud Run / Lambda)
                  │
                  ├─ extrai produtos modificados nas últimas 5 min
                  ├─ transforma para schema Voop
                  └─ POST /api/v1/catalog/items/bulk-upsert

import { Pool } from 'pg';

const pg = new Pool({ /* ... */ });

async function pollAndSync() {
  // 1. Pega produtos alterados nos últimos 5 minutos
  const { rows } = await pg.query(`
    SELECT id, sku, descricao, preco, ncm, peso, ean,
           categoria, marca, imagens, atualizado_em
      FROM produtos
     WHERE atualizado_em > now() - interval '5 minutes'
     ORDER BY atualizado_em
  `);

  if (rows.length === 0) return;

  // 2. Transforma em chunks de 500
  for (const chunk of chunks(rows, 500)) {
    const items = chunk.map((r) => ({
      externalSystem: 'totvs',
      externalId: String(r.id),
      sku: r.sku,
      name: r.descricao,
      price: parseFloat(r.preco),
      gtin13: r.ean,
      ncm: r.ncm,
      weight: parseFloat(r.peso),
      category: r.categoria ? { name: r.categoria } : undefined,
      brand: r.marca ? { name: r.marca } : undefined,
      media: (r.imagens ?? []).map((url, i) => ({
        url,
        role: i === 0 ? 'primary' : 'gallery',
        sortOrder: i,
      })),
    }));

    const r = await fetch('https://api.voop.work/api/v1/catalog/items/bulk-upsert', {
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${process.env.VOOP_KEY}`,
        'Content-Type': 'application/json',
      },
      body: JSON.stringify({ items }),
    });

    if (!r.ok) {
      console.error('Voop returned', r.status, await r.text());
      throw new Error(`Voop sync failed: ${r.status}`);
    }

    const { data } = await r.json();
    console.log(`✓ ${data.summary.created}c ${data.summary.updated}u ${data.summary.unchanged}= ${data.summary.failed}✗`);
  }
}

// Cron a cada 5min
setInterval(() => pollAndSync().catch(console.error), 5 * 60 * 1000);

// Job: 0 3 * * *
import { createWriteStream } from 'fs';
import { execSync } from 'child_process';

async function nightlyResync() {
  const stream = createWriteStream('/tmp/voop-resync.jsonl');
  const cursor = pg.query(/* ... SELECT * FROM produtos */).cursor();

  for await (const r of cursor) {
    stream.write(JSON.stringify({ /* mesma transformação */ }) + '\n');
  }
  stream.end();

  // Delegar resto ao bulk import (assíncrono)
  // ... initiate, upload, start (ver receita "carga inicial 100k")
}

// Items inativos no ERP → status="archived" na Voop (não delete)
const items = rows.map(r => ({
  ...transformProduct(r),
  status: r.inativo ? 'archived' : 'active',
}));