Como criar um agente que lê editais do PNCP e te avisa no WhatsApp em 15 min

Cron 06h → API PNCP → Supabase (já mandei?) → Claude (SIM/NÃO) → WhatsApp

create table editais_enviados (
  id          text primary key,          -- numeroControlePNCP
  objeto      text,
  orgao       text,
  link        text,
  enviado_em  timestamptz default now()
);

-- RLS ligado e nenhuma política: ninguém de fora lê nem escreve.
-- Só o seu servidor, com a chave service_role, passa.
alter table editais_enviados enable row level security;

import time
from datetime import date

import requests

BASE = "https://pncp.gov.br/api/consulta/v1"
PREGAO_ELETRONICO = 6  # codigoModalidadeContratacao: obrigatório na API


def link_edital(c: dict) -> str:
    # O link público usa CNPJ/ano/sequencial, não o numeroControlePNCP.
    cnpj = c["orgaoEntidade"]["cnpj"]
    return f"https://pncp.gov.br/app/editais/{cnpj}/{c['anoCompra']}/{c['sequencialCompra']}"


def buscar_hoje(palavras: list[str], uf: str = "MG", dia: date | None = None) -> list[dict]:
    ymd = (dia or date.today()).strftime("%Y%m%d")  # a API quer yyyyMMdd
    achados, pagina = [], 1
    while True:
        r = requests.get(
            f"{BASE}/contratacoes/publicacao",
            params={
                "dataInicial": ymd,
                "dataFinal": ymd,
                "codigoModalidadeContratacao": PREGAO_ELETRONICO,
                "uf": uf,
                "pagina": pagina,
                "tamanhoPagina": 50,  # máximo aceito
            },
            timeout=60,
        )
        if r.status_code == 204:  # sem conteúdo: acabaram as páginas
            break
        r.raise_for_status()
        dados = r.json()
        for c in dados.get("data", []):
            texto = f"{c.get('objetoCompra') or ''} {c.get('informacaoComplementar') or ''}".lower()
            if any(p.lower() in texto for p in palavras):
                achados.append({
                    "id": c["numeroControlePNCP"],
                    "objeto": c.get("objetoCompra") or "",
                    "orgao": c["orgaoEntidade"]["razaoSocial"],
                    "link": link_edital(c),
                })
        if dados.get("paginasRestantes", 0) <= 0:
            break
        pagina += 1
        time.sleep(0.5)  # gentileza com a API pública
    return achados

import anthropic

claude = anthropic.Anthropic()  # lê ANTHROPIC_API_KEY do ambiente

PROMPT = """Você é um filtro de editais para uma agência que cria agentes de IA
para lojas e prefeituras. Responda só SIM ou NÃO.

Objeto: {objeto}
Órgão: {orgao}

É relevante para quem vende automação, WhatsApp, agente de atendimento?"""


def relevante(objeto: str, orgao: str) -> bool:
    resp = claude.messages.create(
        model="claude-haiku-5-5",  # rápido e barato para classificar
        max_tokens=64,
        messages=[{"role": "user", "content": PROMPT.format(objeto=objeto[:600], orgao=orgao)}],
    )
    texto = "".join(b.text for b in resp.content if b.type == "text").strip().upper()
    return texto.startswith("SIM")

import os

import requests

GRAPH = "https://graph.facebook.com/v21.0"  # use a versão que o painel da Meta mostrar


def enviar_whatsapp(para: str, texto: str) -> None:
    r = requests.post(
        f"{GRAPH}/{os.environ['WHATSAPP_PHONE_ID']}/messages",
        headers={"Authorization": f"Bearer {os.environ['WHATSAPP_TOKEN']}"},
        json={"messaging_product": "whatsapp", "to": para, "type": "text", "text": {"body": texto}},
        timeout=15,
    )
    r.raise_for_status()

import os

from dotenv import load_dotenv
from supabase import create_client

load_dotenv()

from ia import relevante              # noqa: E402
from pncp import buscar_hoje          # noqa: E402
from whatsapp import enviar_whatsapp  # noqa: E402  (a função do Lab 01)

# Chave service_role: ignora o RLS. Só no servidor, nunca no navegador nem no Git.
sb = create_client(os.environ["SUPABASE_URL"], os.environ["SUPABASE_SERVICE_ROLE_KEY"])
MEU_NUMERO = os.environ["MEU_NUMERO"]
PALAVRAS = ["agente de IA", "inteligência artificial", "chatbot", "WhatsApp",
            "atendimento", "software", "sistema"]


def ja_enviado(id_: str) -> bool:
    r = sb.table("editais_enviados").select("id").eq("id", id_).limit(1).execute()
    return bool(r.data)


def run() -> None:
    for e in buscar_hoje(PALAVRAS, uf="MG"):
        if ja_enviado(e["id"]):
            continue
        if not relevante(e["objeto"], e["orgao"]):
            continue
        msg = (f"🔔 *Novo edital PNCP*\n{e['orgao']}\n{e['link']}\n\n"
               f"Objeto: {e['objeto'][:300]}...")
        enviar_whatsapp(MEU_NUMERO, msg)
        sb.table("editais_enviados").insert(e).execute()  # id, objeto, orgao, link
        print("enviado:", e["id"])


if __name__ == "__main__":
    run()

# crontab -e  (06h no horário do servidor; confira o fuso)
0 6 * * * cd /app && .venv/bin/python main.py >> agente.log 2>&1

requests
anthropic
supabase
python-dotenv

SUPABASE_URL=https://SEU-PROJETO.supabase.co
SUPABASE_SERVICE_ROLE_KEY=chave-service-role   # só no servidor
ANTHROPIC_API_KEY=sua-chave-da-anthropic
WHATSAPP_TOKEN=token-do-painel-da-meta
WHATSAPP_PHONE_ID=id-do-numero-no-painel
MEU_NUMERO=5531999999999

python -m venv .venv && source .venv/bin/activate
pip install -r requirements.txt
cp .env.example .env   # e preencha
python main.py