Sincronização periódica de estoque e preço

// pseudo-código do worker
setInterval(async () => {
  const deltas = await bufferDeStock.drain(); // pega tudo acumulado + limpa

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

  // divide em batches de 500 (limite da API)
  for (let i = 0; i < deltas.length; i += 500) {
    const lote = deltas.slice(i, i + 500).map(d => ({
      hunter_variante_id: d.sku,
      quantidade: d.quantidadeAtual,
    }));

    await postComRetry(`${BASE_URL}/estoque`, { estoques: lote });
  }
}, 10 * 60 * 1000);

async function onVendaConfirmada(sku, novaQuantidade) {
  await postComRetry(`${BASE_URL}/estoque`, {
    estoques: [
      { hunter_variante_id: sku, quantidade: novaQuantidade },
    ],
  });
}

setInterval(async () => {
  const deltasPreco = await bufferDePrecos.drain();

  for (let i = 0; i < deltasPreco.length; i += 500) {
    const lote = deltasPreco.slice(i, i + 500).map(d => ({
      hunter_variante_id: d.sku,
      preco: d.novoPreco,
      preco_promocional: d.novaPromo, // pode ser null pra remover
    }));

    await postComRetry(`${BASE_URL}/precos`, { precos: lote });
  }
}, 10 * 60 * 1000);

{
  "hunter_variante_id": "VAR-999",
  "acao": "erro",
  "erro": "Variante com hunter_id 'VAR-999' não encontrada."
}

// Uma vez, sob demanda:
const todosSKUs = await sistemaIntegradoListarTudo();
for (let i = 0; i < todosSKUs.length; i += 500) {
  const lote = todosSKUs.slice(i, i + 500).map(s => ({
    hunter_variante_id: s.sku,
    quantidade: s.estoqueAtual,
  }));
  await postComRetry(`${BASE_URL}/estoque`, { estoques: lote });
}