Webhooks para monitoramento processual: como receber alertas em tempo real via API

import requests
import os

API_KEY = os.getenv("JUDIT_API_KEY")
TRACKING_ENDPOINT = "https://tracking.prod.judit.io/tracking"

def iniciar_monitoramento(cpf_cnpj: str, webhook_url: str) -> dict:
    """Cadastra uma entidade para monitoramento contínuo."""

    headers = {
        "Authorization": f"Bearer {API_KEY}",
        "Content-Type": "application/json"
    }

    payload = {
        "search_type": "cpf_cnpj",
        "search_key": cpf_cnpj,
        "webhook_url": webhook_url,    # URL que receberá as notificações
        "notification_config": {
            "on_new_lawsuit": True,      # Avisa em novos processos
            "on_movement": True,          # Avisa em movimentações
            "on_decision": True           # Avisa em decisões
        }
    }

    response = requests.post(TRACKING_ENDPOINT, headers=headers, json=payload)
    response.raise_for_status()
    return response.json()


# Exemplo de uso:
resultado = iniciar_monitoramento(
    cpf_cnpj="12345678000190",  # CNPJ da empresa monitorada
    webhook_url="https://meusite.com/webhook/judit"
)
print(f"Monitoramento ativado! ID: {resultado['tracking_id']}")

from flask import Flask, request, jsonify
import logging

app = Flask(__name__)
logging.basicConfig(level=logging.INFO)

@app.route("/webhook/judit", methods=["POST"])
def receber_webhook():
    """Endpoint que recebe notificações da Judit."""

    payload = request.get_json()

    if not payload:
        return jsonify({"error": "payload inválido"}), 400

    # Identifica o tipo de evento
    event_type = payload.get("event_type")  # "new_lawsuit" | "movement" | "decision"
    tracking_id = payload.get("tracking_id")
    entity = payload.get("search_key")  # CPF ou CNPJ monitorado

    logging.info(f"Evento recebido: {event_type} | Entidade: {entity}")

    # Processa conforme o tipo de evento
    if event_type == "new_lawsuit":
        processar_novo_processo(payload)
    elif event_type == "movement":
        processar_movimentacao(payload)
    elif event_type == "decision":
        processar_decisao(payload)

    # IMPORTANTE: sempre retorne 200 rapidamente
    # Processe em background se necessário (fila, celery, etc.)
    return jsonify({"status": "ok"}), 200


def processar_novo_processo(payload):
    lawsuit = payload.get("lawsuit", {})
    numero_cnj = lawsuit.get("cnj_number")
    assunto = lawsuit.get("subject")
    tribunal = lawsuit.get("court")
    logging.info(f"🚨 NOVO PROCESSO: {numero_cnj} | {assunto} | {tribunal}")
    # → Aqui você envia email, Slack, WhatsApp, salva no banco, etc.


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

{
  "event_type": "new_lawsuit",
  "tracking_id": "track_xyz789",
  "search_key": "12345678000190",          // CNPJ monitorado
  "timestamp": "2026-03-10T14:32:00Z",
  "lawsuit": {
    "cnj_number": "0001234-56.2026.8.26.0100",
    "subject": "Cobrança",
    "court": "TJSP",
    "filing_date": "2026-03-10",
    "value": 15000.00,
    "parties": [
      { "role": "author", "name": "João Silva", "cpf": "111.222.333-44" },
      { "role": "defendant", "name": "Empresa XYZ LTDA", "cnpj": "12.345.678/0001-90" }
    ]
  }
}

# 1. Enviar alerta no Slack
def notificar_slack(payload):
    lawsuit = payload['lawsuit']
    mensagem = f"""🚨 *Novo processo detectado*
• Número: {lawsuit['cnj_number']}
• Assunto: {lawsuit['subject']}
• Tribunal: {lawsuit['court']}
• Valor: R$ {lawsuit['value']:,.2f}"""
    requests.post(SLACK_WEBHOOK_URL, json={"text": mensagem})

# 2. Salvar no banco de dados
def salvar_banco(payload):
    db.lawsuits.upsert(
        {"cnj_number": payload['lawsuit']['cnj_number']},
        payload['lawsuit']
    )

# 3. Atualizar planilha Google Sheets via API
# 4. Enviar email para o responsável
# 5. Acionar workflow no n8n, Make ou Zapier
# 6. Criar tarefa no Asana / Jira para o time jurídico
# 7. Enviar mensagem no WhatsApp via Zapi/Twilio