API CPF e CNPJ para Plataformas KYC/KYB: Validação em Tempo Real

# Node.js exemplo para plataforma KYC global
const axios = require('axios');

async function validateBrazilianDocument(document, type) {
  /**
   * Valida CPF/CNPJ brasileiro para plataforma KYC global
   * Retorna: {valid: bool, source: string, data: object}
   */

  // 1. Detecta se é documento brasileiro
  const cleanDoc = document.replace(/[^0-9]/g, '');
  const isCPF = cleanDoc.length === 11;
  const isCNPJ = cleanDoc.length === 14;

  if (!isCPF && !isCNPJ) {
    return {
      valid: false,
      error: 'INVALID_BRAZIL_DOCUMENT_FORMAT'
    };
  }

  try {
    // 2. Chama API oficial Receita Federal
    const response = await axios.get(
      `https://api.cpfcnpj.com.br/${TOKEN}/${PACKAGE}/${cleanDoc}`,
      {
        timeout: 15000,
        headers: {'X-Source': 'KYC-Platform-SumSub'} // tracking
      }
    );

    const validation = response.data;

    // 3. Mapeia resposta para formato KYC padrão
    const kycResult = {
      valid: validation.valido && validation.situacao === 'REGULAR',
      source: 'RECEITA_FEDERAL_BRAZIL_OFFICIAL',
      sourceType: 'GOVERNMENT_DATABASE',
      country: 'BR',
      documentType: isCPF ? 'CPF' : 'CNPJ',
      document: cleanDoc,
      status: validation.situacao,
      fullName: isCPF ? validation.nome : validation.razao_social,
      dateOfBirth: validation.data_nascimento || null,
      validatedAt: new Date().toISOString(),
      compliance: {
        bacen: validation.situacao === 'REGULAR',
        cvm: validation.situacao === 'REGULAR',
        officialSource: true
      }
    };

    // 4. Para CNPJ (KYB), adiciona enhanced data
    if (isCNPJ) {
      kycResult.businessData = {
        legalName: validation.razao_social,
        tradeName: validation.nome_fantasia,
        taxStatus: validation.situacao,
        incorporationDate: validation.data_abertura,
        companySize: validation.porte,
        mainActivity: validation.cnae_principal,
        shareholders: validation.qsa || []
      };
    }

    // 5. Registra log para compliance audit
    await logKYCValidation({
      platform: 'KYC_PLATFORM',
      country: 'BR',
      document: cleanDoc,
      result: kycResult.valid,
      source: 'RECEITA_FEDERAL',
      timestamp: new Date()
    });

    return kycResult;

  } catch (error) {
    // 6. Handle errors gracefully
    await logError({
      type: 'BRAZIL_API_ERROR',
      document: cleanDoc,
      error: error.message
    });

    return {
      valid: null,
      error: 'VALIDATION_UNAVAILABLE',
      message: 'Brazil official source temporarily unavailable',
      fallbackToManualReview: true
    };
  }
}

// 7. Integração no fluxo KYC principal
async function runKYCFlow(userData) {
  const {document, country, documentType} = userData;

  // Detecta país e roteia para data provider correto
  if (country === 'BR' || documentType === 'CPF' || documentType === 'CNPJ') {
    return await validateBrazilianDocument(document, documentType);
  } else {
    // Outros países: rotear para provedores globais
    return await validateWithGlobalProvider(document, country);
  }
}