Como consultar a inscrição estadual de milhares de CNPJs em Node.js?

npm install fiscalapi-br
export FISCALAPI_API_KEY="fapi_sua_chave_aqui"

// Consulta a IE de uma lista de CNPJs nos 27 estados, com retomada.
import { appendFileSync, existsSync, readFileSync } from 'node:fs';
import { setTimeout as dormir } from 'node:timers/promises';
import {
  APIConnectionError,
  AuthenticationError,
  BadRequestError,
  FiscalAPI,
  InsufficientBalanceError,
  RateLimitError,
  ServerError,
} from 'fiscalapi-br';

const ENTRADA = 'cnpjs.txt'; // um CNPJ por linha
const SAIDA = 'resultado.jsonl'; // uma linha por CNPJ concluído (é também o checkpoint)
const FALHAS = 'falhas.jsonl'; // 5xx e falhas de rede: entram de novo na próxima rodada

// Milissegundos entre chamadas, pelo limite por minuto do plano.
const PAUSA = { lite: 12000, sem_plano: 12000, starter: 3000, pro: 1000, enterprise: 500 };
const PLANO = 'starter';

const limpar = (valor) => valor.replace(/[^0-9a-z]/gi, '').toUpperCase();

// Dígitos verificadores, também do CNPJ alfanumérico. CNPJ com DV errado não
// volta erro da API: é consultado e cobrado. Melhor barrar antes.
function cnpjValido(cnpj) {
  if (!/^[0-9A-Z]{12}[0-9]{2}$/.test(cnpj) || /^(.)\1+$/.test(cnpj)) return false;
  const v = [...cnpj].map((c) => c.charCodeAt(0) - 48);
  for (const n of [12, 13]) {
    let soma = 0;
    for (let i = 0; i < n; i++) soma += v[i] * (((n - 1 - i) % 8) + 2);
    const resto = soma % 11;
    if (v[n] !== (resto < 2 ? 0 : 11 - resto)) return false;
  }
  return true;
}

function jaConcluidos() {
  if (!existsSync(SAIDA)) return new Set();
  return new Set(
    readFileSync(SAIDA, 'utf8')
      .split('\n')
      .filter(Boolean)
      .map((linha) => JSON.parse(linha).cnpj),
  );
}

function gravar(arquivo, registro) {
  registro.consultado_em = new Date().toISOString();
  appendFileSync(arquivo, JSON.stringify(registro) + '\n');
}

const api = new FiscalAPI(); // lê FISCALAPI_API_KEY; já repete sozinho em 429 e 5xx
const pausa = PAUSA[PLANO];

const feitos = jaConcluidos();
const pendentes = [
  ...new Set(
    readFileSync(ENTRADA, 'utf8')
      .split('\n')
      .map(limpar)
      .filter((cnpj) => cnpj && !feitos.has(cnpj)),
  ),
];
console.log(`${feitos.size} já concluídos, ${pendentes.length} pendentes`);

let ultima = 0;
for (const [i, cnpj] of pendentes.entries()) {
  if (!cnpjValido(cnpj)) {
    gravar(SAIDA, { cnpj, erro: 'CNPJ_INVALIDO' }); // não chama a API
    continue;
  }

  const espera = pausa - (Date.now() - ultima);
  if (espera > 0) await dormir(espera);
  ultima = Date.now();

  let resp;
  try {
    resp = await api.consultarIeTodos({ cnpj });
  } catch (e) {
    if (e instanceof InsufficientBalanceError) {
      // 402: acabaram as consultas do mês e não há saldo de recarga. Repetir não adianta.
      console.error(`Parei no ${cnpj}: ${e.message}. Rode de novo depois de recarregar.`);
      process.exit(2);
    }
    if (e instanceof AuthenticationError) {
      // 403: chave ausente, inválida ou revogada.
      console.error(`Chave recusada: ${e.message}`);
      process.exit(3);
    }
    if (e instanceof RateLimitError) {
      // 429 mesmo depois das tentativas do SDK: espera e deixa para a próxima rodada.
      const segundos = e.retryAfter ?? 60;
      console.warn(`Limite por minuto atingido; esperando ${segundos} s`);
      await dormir(segundos * 1000);
      continue;
    }
    if (e instanceof BadRequestError) {
      // 400: documento ausente ou sem dígitos. Grava como concluído.
      gravar(SAIDA, { cnpj, erro: e.code, mensagem: e.message });
      continue;
    }
    if (e instanceof ServerError || e instanceof APIConnectionError) {
      gravar(FALHAS, { cnpj, erro: e.status ?? null, mensagem: e.message });
      continue;
    }
    throw e; // qualquer outro erro: para tudo
  }

  const inscricoes = resp.results.flatMap((estado) =>
    estado.results.map((ie) => ({
      uf: estado.uf,
      ie: ie.inscricao_estadual,
      situacao: ie.situacao_ie,
    })),
  );
  gravar(SAIDA, { cnpj, complete: resp.complete ?? true, inscricoes });
  if ((i + 1) % 100 === 0) console.log(`${i + 1}/${pendentes.length}`);
}

console.log('Fim. Os que caíram em falhas.jsonl entram de novo se você rodar outra vez.');