IA que trabalhaonde o processojá acontece

Arquitetura

Destaques técnicos

• Agregação de 5 fontes com proveniência campo a campo

  O agregador encadeia FIPE, NHTSA vPIC, HTML do site oficial, e-book PDF da fabricante e catálogo 411, e só aciona o LLM quando faltam specs. Cada atributo é etiquetado com a origem exata, a prioridade de merge é explícita e a confiança geral deriva de quantas fontes reais responderam. A interface diferencia dado oficial de valor estimado por IA.

  apps/api/src/lib/data-sources/aggregator.ts

• Ensemble ML + LLM com zona cinza e revisão humana

  O XGBoost é sempre o baseline determinístico e de custo zero; o LLM só entra quando a confiança do ML cai abaixo de 0,6. Em concordância, as probabilidades são mescladas por média ponderada; em discordância, vence a maior confiança, o resultado é penalizado em 20% e a predição é marcada para revisão humana, com as duas predições persistidas para auditoria.

  apps/api/src/modules/retention/hybrid-classifier.ts

• Pseudonimização HMAC e payload assinado no túnel API → ML

  Nenhuma PII atravessa a fronteira até o serviço Python: o identificador da concessionária vira um HMAC-SHA256 truncado em 16 caracteres e o corpo inteiro é assinado em header próprio. A verificação usa timingSafeEqual no Node e compare_digest no Python, evitando ataque de timing nas duas pontas. Se o serviço cai, há fallback heurístico determinístico.

  apps/api/src/modules/retention/ml-client.ts

• RLS multi-tenant como segunda camada de autorização

  Todas as tabelas sobem com RLS habilitado sob a regra de negar por padrão, com policies expressas em funções security definer. O analista enxerga apenas a própria concessionária, o gestor a rede. No lado da aplicação, o plugin Fastify revalida o JWT contra o endpoint de usuário em vez de confiar no payload.

  supabase/migrations/20260514_002_rls_policies.sql

• Cálculo pesado empurrado para dentro do Postgres

  Em vez de paginar centenas de milhares de linhas pelo PostgREST, funções SQL fazem o trabalho no banco: o risco composto por lead é calculado com bônus por revisão atrasada, garantia vencida e baixa fidelidade ao dealer, devolvendo o array de sinais que justifica cada posição. Sobre esse resumo, a API calcula z-score e separa anomalias de benchmarks.

  supabase/migrations/20260514_018_leads_ranking_fn.sql

• ETL em pandas e classificador sem data leakage

  O pipeline lê o XLSX bruto, converte para Parquet com cache por mtime e agrega por VIN com features comportamentais. A base de treino mantém só o que existe no ato da venda — modelo, ano, dealer, sazonalidade —, e o XGBoost roda dentro de um Pipeline sklearn com split estratificado e métricas serializadas junto ao modelo.

  scripts/etl-d2-real.py

• Extração multimodal escalonada por custo

  A rota mais barata é tentada primeiro: extração local de PDF, com heurística exigindo volume de texto e palavras-chave técnicas para decidir se vale a rota textual. O JSON passa por validação antes de ser aceito — se vier lixo, cai para visão e depois para outro provedor. Modelos caros são deliberadamente evitados por padrão, com o custo de cada rota documentado.

  apps/api/src/lib/ai-vision.ts

Arquitetura

Destaques técnicos

• Regra de negócio decidida no dispositivo

  A detecção de volta não faz round-trip à nuvem: o sensor PIR aciona o buzzer localmente e o estado é publicado em paralelo apenas para registro. O alerta crítico em tempo continua funcionando com o broker fora do ar — que é exatamente o argumento de existir do edge computing, e não só um sensor conectado.

  codigo-wokwi

• Telemetria MQTT com tópicos segregados por grandeza

  Em vez de um payload JSON monolítico, o firmware publica em três tópicos independentes. Isso deixa o consumidor assinar só a grandeza que lhe interessa — um painel de estratégia pode ouvir apenas umidade; o cronômetro, apenas o PIR — e é o padrão pub/sub correto para fan-out de telemetria.

  codigo-wokwi

• Client ID MQTT randomizado por sessão

  A cada conexão o dispositivo monta um identificador novo. Detalhe que importa em broker público compartilhado: no MQTT, dois clientes com o mesmo identificador derrubam a sessão um do outro em loop infinito — a randomização elimina essa classe de falha.

  codigo-wokwi

• Guarda de integridade antes de publicar

  O DHT22 retorna valor inválido em leitura falha. O código valida temperatura e umidade antes de qualquer publicação, então a série temporal no broker nunca recebe amostra corrompida. Validação na origem, no edge, em vez de empurrar limpeza de dados para o back-end.

  codigo-wokwi