Pull de pedidos + processamento + rastreio

const params = new URLSearchParams({ limit: "200" });
const res = await fetch(`${BASE_URL}/pedidos?${params}`, {
  headers: { "X-API-Key": KEY },
});
const { data } = await res.json();

for (const pedido of data.pedidos) {
  await processarPedido(pedido);
  cursor = pedido.atualizado_em; // avança
}

saveCursor(cursor);

async function tickDePull() {
  const cursor = getSavedCursor(); // ISO 8601 do último pedido processado

  const params = new URLSearchParams({ limit: "200" });
  if (cursor) params.set("updated_since", cursor);

  const res = await fetch(`${BASE_URL}/pedidos?${params}`, {
    headers: { "X-API-Key": KEY },
  });

  if (!res.ok) {
    // 429/500 — backoff
    return handleErro(res);
  }

  const { data } = await res.json();
  let ultimoCursor = cursor;

  for (const pedido of data.pedidos) {
    try {
      await roteador(pedido);
      ultimoCursor = pedido.atualizado_em;
    } catch (err) {
      // Loga o erro mas NÃO avança cursor (retentará no próximo tick)
      logger.error({ codigo: pedido.codigo, err });
      break;
    }
  }

  if (ultimoCursor !== cursor) saveCursor(ultimoCursor);

  // Se tem_mais, dispara outro tick imediatamente
  if (data.paginacao.tem_mais) return tickDePull();
}

setInterval(tickDePull, 5 * 60 * 1000);

async function roteador(pedido) {
  switch (pedido.status) {
    case "pagamento_aprovado":
      if (pedido.hunter_processado_em !== null) {
        return; // replay — ignora
      }
      return processarPedidoAprovado(pedido);

    case "em_separacao":
      // Se você processou (hunter_processado_em preenchido), o pedido está
      // aguardando você postar. Verifique seu WMS/ERP — assim que a etiqueta
      // for gerada e o pacote postar, chame POST /rastreio.
      return; // handled pelo evento de postagem no seu lado

    case "enviado":
    case "entregue":
      return; // fim do fluxo pro integrador

    case "cancelado":
      return processarCancelamento(pedido);
  }
}

async function processarPedidoAprovado(pedido) {
  // 1. Baixa estoque local
  for (const item of pedido.itens) {
    await sistemaIntegrado.baixaEstoque(item.variante_hunter_id, item.quantidade);
  }

  // 2. Emite NF
  const nfe = await sistemaIntegrado.emitirNFe({
    cliente: pedido.cliente,
    endereco: pedido.endereco_entrega,
    itens: pedido.itens,
    total: pedido.total,
  });

  // 3. Confirma na loja
  await fetch(`${BASE_URL}/pedidos/${pedido.codigo}/processado`, {
    method: "POST",
    headers: { "X-API-Key": KEY, "Content-Type": "application/json" },
    body: JSON.stringify({
      nota_fiscal: {
        numero: nfe.numero,
        serie: nfe.serie,
        chave_acesso: nfe.chave,
        data_emissao: nfe.emitidaEm,
        url_danfe: nfe.pdfUrl,
      },
    }),
  });
}

// Evento "pacote postado" no seu WMS/ERP
async function onPacotePostado({ pedidoCodigo, codigoRastreio, transportadora, urlRastreio }) {
  await fetch(`${BASE_URL}/pedidos/${pedidoCodigo}/rastreio`, {
    method: "POST",
    headers: { "X-API-Key": KEY, "Content-Type": "application/json" },
    body: JSON.stringify({
      codigo_rastreio: codigoRastreio,
      transportadora: transportadora,
      url_rastreio: urlRastreio,
    }),
  });
}

async function processarCancelamento(pedido) {
  const existeNoLocal = await sistemaIntegrado.existePedido(pedido.codigo);
  if (!existeNoLocal) return; // ignora — nunca chegou a entrar

  // Cancela do lado do integrador (estorna NF, restora estoque, etc)
  await sistemaIntegrado.cancelarPedido(pedido.codigo, {
    motivo: pedido.cancelamento?.motivo ?? "Cancelamento sincronizado da loja",
    dataOriginal: pedido.cancelamento?.cancelado_em,
  });
}