Como integrar API de CPF em chatbots do WhatsApp Business

[WhatsApp Business API] <--> [Servidor do Chatbot] <--> [API CPFHub.io]

Bot: Olá! Para continuarmos, preciso verificar sua identidade.
    Por favor, informe seu CPF (apenas números).

Usuário: 12345678900

Bot: Aguarde um momento enquanto verifico seus dados...

[Chatbot consulta API da CPFHub.io]

Bot: Encontrei! Seu nome é João da Silva, correto?

Usuário: Sim

Bot: Identidade verificada com sucesso!
    Como posso ajudá-lo hoje?

Bot: Não consegui localizar este CPF. Por favor, verifique
    o número e tente novamente.

const express = require('express');
const app = express();
app.use(express.json());

const CPFHUB_API_KEY = process.env.CPFHUB_API_KEY;
const WHATSAPP_TOKEN = process.env.WHATSAPP_TOKEN;

// Estado das conversas (em produção, use Redis ou banco de dados)
const conversas = {};

// Webhook para receber mensagens do WhatsApp
app.post('/webhook', async (req, res) => {
    const message = req.body.entry?.[0]?.changes?.[0]?.value?.messages?.[0];

    if (!message) {
    return res.sendStatus(200);
    }

    const telefone = message.from;
    const texto = message.text?.body?.trim();

    if (!texto) {
    return res.sendStatus(200);
    }

    const estado = conversas[telefone] || { etapa: 'inicio' };

    if (estado.etapa === 'inicio') {
    await enviarMensagem(telefone,
    'Olá! Para continuarmos, preciso verificar sua identidade.\n' +
    'Por favor, informe seu CPF (apenas números).'
    );
    conversas[telefone] = { etapa: 'aguardando_cpf' };
    }
    else if (estado.etapa === 'aguardando_cpf') {
    const cpf = texto.replace(/\D/g, '');

    if (cpf.length !== 11) {
    await enviarMensagem(telefone,
    'O CPF deve conter 11 dígitos. Por favor, tente novamente.'
    );
    return res.sendStatus(200);
    }

    await enviarMensagem(telefone,
    'Aguarde um momento enquanto verifico seus dados...'
    );

    // Consultar API da CPFHub.io
    const resultado = await consultarCPF(cpf);

    if (resultado.success) {
    const nome = resultado.data.name;
    await enviarMensagem(telefone,
    `Encontrei! Seu nome é ${nome}, correto?\n` +
    'Responda SIM para confirmar ou NÃO para tentar outro CPF.'
    );
    conversas[telefone] = {
    etapa: 'confirmando_nome',
    cpf: cpf,
    nome: nome
    };
    } else {
    await enviarMensagem(telefone,
    'Não consegui localizar este CPF. ' +
    'Por favor, verifique o número e tente novamente.'
    );
    }
    }
    else if (estado.etapa === 'confirmando_nome') {
    if (texto.toUpperCase() === 'SIM') {
    await enviarMensagem(telefone,
    'Identidade verificada com sucesso!\n' +
    'Como posso ajudá-lo hoje?'
    );
    conversas[telefone] = {
    etapa: 'atendimento',
    cpf: estado.cpf,
    nome: estado.nome
    };
    } else {
    await enviarMensagem(telefone,
    'Por favor, informe o CPF correto (apenas números).'
    );
    conversas[telefone] = { etapa: 'aguardando_cpf' };
    }
    }

    res.sendStatus(200);
});

async function consultarCPF(cpf) {
    const response = await fetch(`https://api.cpfhub.io/cpf/${cpf}`, {
    method: 'GET',
    headers: {
    'x-api-key': CPFHUB_API_KEY,
    'Accept': 'application/json'
    },
    timeout: 10000
    });

    return response.json();
}

async function enviarMensagem(telefone, texto) {
    await fetch(
    `https://graph.facebook.com/v18.0/PHONE_NUMBER_ID/messages`,
    {
    method: 'POST',
    headers: {
    'Authorization': `Bearer ${WHATSAPP_TOKEN}`,
    'Content-Type': 'application/json'
    },
    body: JSON.stringify({
    messaging_product: 'whatsapp',
    to: telefone,
    type: 'text',
    text: { body: texto }
    }),
    timeout: 10000
    }
    );
}

app.listen(3000, () => {
    console.log('Chatbot rodando na porta 3000');
});

from flask import Flask, request, jsonify
import requests
import os

app = Flask(__name__)

CPFHUB_API_KEY = os.environ.get("CPFHUB_API_KEY")
WHATSAPP_TOKEN = os.environ.get("WHATSAPP_TOKEN")

# Estado das conversas
conversas = {}

@app.route("/webhook", methods=["POST"])
def webhook():
    data = request.get_json()
    message = (data.get("entry", [{}])[0]
    .get("changes", [{}])[0]
    .get("value", {})
    .get("messages", [{}])[0])

    telefone = message.get("from")
    texto = message.get("text", {}).get("body", "").strip()

    if not telefone or not texto:
    return jsonify({"status": "ok"}), 200

    estado = conversas.get(telefone, {"etapa": "inicio"})

    if estado["etapa"] == "inicio":
    enviar_mensagem(telefone,
    "Olá! Para continuarmos, informe seu CPF (apenas números).")
    conversas[telefone] = {"etapa": "aguardando_cpf"}

    elif estado["etapa"] == "aguardando_cpf":
    cpf = "".join(filter(str.isdigit, texto))

    if len(cpf) != 11:
    enviar_mensagem(telefone,
    "O CPF deve conter 11 dígitos. Tente novamente.")
    return jsonify({"status": "ok"}), 200

    resultado = consultar_cpf(cpf)

    if resultado.get("success"):
    nome = resultado["data"]["name"]
    enviar_mensagem(telefone,
    f"Encontrei! Seu nome é {nome}, correto? (SIM/NÃO)")
    conversas[telefone] = {
    "etapa": "confirmando",
    "cpf": cpf,
    "nome": nome
    }
    else:
    enviar_mensagem(telefone,
    "CPF não encontrado. Verifique e tente novamente.")

    elif estado["etapa"] == "confirmando":
    if texto.upper() == "SIM":
    enviar_mensagem(telefone,
    "Identidade verificada! Como posso ajudá-lo?")
    conversas[telefone] = {
    "etapa": "atendimento",
    "cpf": estado["cpf"],
    "nome": estado["nome"]
    }
    else:
    enviar_mensagem(telefone,
    "Informe o CPF correto (apenas números).")
    conversas[telefone] = {"etapa": "aguardando_cpf"}

    return jsonify({"status": "ok"}), 200

def consultar_cpf(cpf):
    response = requests.get(
    f"https://api.cpfhub.io/cpf/{cpf}",
    headers={
    "x-api-key": CPFHUB_API_KEY,
    "Accept": "application/json"
    },
    timeout=10
    )
    return response.json()

def enviar_mensagem(telefone, texto):
    requests.post(
    f"https://graph.facebook.com/v18.0/PHONE_NUMBER_ID/messages",
    headers={
    "Authorization": f"Bearer {WHATSAPP_TOKEN}",
    "Content-Type": "application/json"
    },
    json={
    "messaging_product": "whatsapp",
    "to": telefone,
    "type": "text",
    "text": {"body": texto}
    },
    timeout=10
    )

if __name__ == "__main__":
    app.run(port=3000)