Merge pull request #210 from melgarafael/fix/provedores-de-ia-forward

fix(ia): os 53 defeitos que entraram com o painel de provedores — e os dois gates que não rodavam

Author: melgarafael

.github/workflows/ci.yml

@@ -40,6 +40,12 @@ jobs:
       # Scripts do kit self-host num repo git descartável (docker/crontab
       # dublados). É o único gate que exercita o update.sh — um erro aqui
       # rebobina a instalação de quem hospeda, e nenhum teste TS o veria.
+      #
+      # Desde 2026-08-08 inclui `hostgator-setup-kit/test-validators.sh`, os 163
+      # casos que cobrem o install.sh. Eles existiam e NÃO rodavam em job nenhum
+      # (issue #191): dois defeitos que tornavam a instalação impossível —
+      # escolher OpenRouter travava o instalador num laço, escolher OpenAI
+      # deixava o .env pela metade — passaram por todos os checks verdes. 15s.
       - name: Kit self-host (bash)
         run: pnpm test:shell
 

.github/workflows/e2e.yml

@@ -178,6 +178,11 @@ jobs:
           pnpm exec tsx scripts/seed-e2e-escalacao.ts
           pnpm exec tsx --env-file=.env.local scripts/seed-e2e-capacidades-ausentes.ts
           pnpm exec tsx scripts/seed-e2e-followup-agent.ts
+          # O catálogo da OpenRouter não existe em banco fresco (o baseline
+          # semeia só anthropic/openai/google; os demais vêm do cron diário, que
+          # busca na internet). Sem esta linha, `prova-painel-provedores` mede a
+          # sorte do ambiente em vez da tela.
+          pnpm exec tsx scripts/seed-e2e-catalogo-openrouter.ts
 
       # O que ficou DE FORA (e por quê) é declarado no passo de summary —
       # cobertura parcial silenciosa se lê como cobertura total.
@@ -240,7 +245,8 @@ jobs:
             distribuicao-atendimento.spec.ts followup-journey.spec.ts \
             webhooks.spec.ts \
             capacidades-do-agente.spec.ts \
-            escopo-de-funil-do-agente.spec.ts
+            escopo-de-funil-do-agente.spec.ts \
+            prova-painel-provedores.spec.ts
         env:
           # Só o que NÃO vem do `.env.e2e`: isto é ajuste de CI, não config do
           # produto. CI = 1 IP para todos os specs, e o teto de produção
@@ -254,18 +260,25 @@ jobs:
           {
             echo "## E2E — cobertura deste job"
             echo ""
-            echo "**Rodou (32 de 33 specs):** smoke, auth, error-pages, password-recovery,"
-            echo "signup-journey, rbac-roles, inbox-scope, reset-password-mfa,"
-            echo "degradacao-silenciosa, vps-webhook-outbound-ssrf, kanban-owner-filter,"
-            echo "queue-assign, risk-radar, invite-lifecycle, system-update,"
+            echo "**Rodou (37 de 39 specs no disco):** smoke, auth, error-pages,"
+            echo "password-recovery, signup-journey, rbac-roles, inbox-scope,"
+            echo "reset-password-mfa, degradacao-silenciosa, vps-webhook-outbound-ssrf,"
+            echo "kanban-owner-filter, queue-assign, conversa-vira-lead, contato-salva-email,"
+            echo "confirmar-dado-do-contato, risk-radar, invite-lifecycle, system-update,"
             echo "agente-novo-e-uso, agente-organiza-operacao, central-de-avisos-capacidades,"
             echo "escalacao-ciclo, navegacao, olhar-telas-do-epico, pipelines-gestao,"
             echo "qa-agente-usa-as-maos, qa-selo-no-funil-usado, qa-telas-descobertas-w4,"
             echo "retorno-anti-morte, followup-builder, followup-queue,"
-            echo "distribuicao-atendimento, followup-journey, capacidades-do-agente, webhooks."
+            echo "distribuicao-atendimento, followup-journey, capacidades-do-agente,"
+            echo "escopo-de-funil-do-agente, prova-painel-provedores, webhooks."
             echo ""
-            echo "**Não rodou (1):**"
+            echo "**Não rodou (2):**"
             echo "- precisa de WAHA + Redis + Resend + Nuvemshop: vps-fresh-onboarding (P0)"
+            echo "- agente-papeis-operador"
+            echo ""
+            echo "A contagem sai de \`ls tests/e2e/*.spec.ts\` contra as duas invocações do"
+            echo "playwright acima — o texto anterior dizia \"32 de 33\" com 39 specs no disco,"
+            echo "e cobertura declarada a mais é pior que cobertura parcial declarada."
             echo ""
             echo "Expandir é trabalho de seguimento — issue #63."
           } >> "$GITHUB_STEP_SUMMARY"

app/api/v1/admin/tenants/[id]/route.ts

@@ -94,8 +94,12 @@ export async function GET(
       // números divergem de propósito: este é o total do tenant, aquele é a
       // fila de SLA da plataforma.
       .not("status", "in", "(completed,failed)"),
+    // `llm_calls` e não `ai_invocations`: a migration 0130 deixou a segunda sem
+    // nenhum escritor (`lib/ai/log-invocation.ts` passou a gravar na primeira).
+    // Lendo a tabela morta, este contador viraria ZERO em 30 dias para todo
+    // tenant — com o dinheiro saindo. É o mesmo sintoma que a 0130 veio matar.
     admin
-      .from("ai_invocations")
+      .from("llm_calls")
       .select("*", { count: "exact", head: true })
       .eq("organization_id", id)
       .gte(

app/api/v1/admin/usage/route.ts

@@ -149,15 +149,22 @@ export async function GET(req: NextRequest) {
     }
   }
 
-  // ---- ai_invocations per org ----
+  // ---- consumo de IA por org: `llm_calls`, a tabela única (migration 0130) ----
+  //
+  // Lia `ai_invocations`, e a 0130 deixou essa tabela SEM NENHUM ESCRITOR:
+  // `lib/ai/log-invocation.ts` passou a gravar em `llm_calls`. O painel de
+  // plataforma continuaria somando o histórico congelado e, passados os 30 dias
+  // da janela, mostraria ZERO consumo para todo tenant com o dinheiro saindo —
+  // exatamente o sintoma que a 0130 existe para matar, reintroduzido na tela do
+  // outro lado. `tests/unit/telemetria-tem-um-leitor-so.test.ts` guarda isto.
   const aiInvCountMap = new Map<string, number>();
   const aiTokensMap = new Map<string, number>();
   const aiCostMap = new Map<string, number>();
 
   if (orgIds.length > 0) {
     const { data: aiRows, error: aiErr } = await admin
-      .from("ai_invocations")
-      .select("organization_id, prompt_tokens, completion_tokens, cost_cents")
+      .from("llm_calls")
+      .select("organization_id, input_tokens, output_tokens, cost_cents")
       .in("organization_id", orgIds)
       .gte("created_at", startIso);
     if (!aiErr && aiRows) {
@@ -167,8 +174,8 @@ export async function GET(req: NextRequest) {
         aiTokensMap.set(
           oid,
           (aiTokensMap.get(oid) ?? 0) +
-            ((row.prompt_tokens as number) ?? 0) +
-            ((row.completion_tokens as number) ?? 0),
+            ((row.input_tokens as number) ?? 0) +
+            ((row.output_tokens as number) ?? 0),
         );
         aiCostMap.set(
           oid,
@@ -233,9 +240,10 @@ export async function GET(req: NextRequest) {
   const aiTokensDayMap = new Map<string, number>();
   if (orgIds.length > 0) {
     const filterOrgIds = tenant_id ? [tenant_id] : orgIds;
+    // `llm_calls`, pelo mesmo motivo do bloco acima (migration 0130).
     const { data: aiDays, error: aiDayErr } = await admin
-      .from("ai_invocations")
-      .select("created_at, prompt_tokens, completion_tokens, cost_cents")
+      .from("llm_calls")
+      .select("created_at, input_tokens, output_tokens, cost_cents")
       .in("organization_id", filterOrgIds)
       .gte("created_at", startIso);
     if (!aiDayErr && aiDays) {
@@ -248,8 +256,8 @@ export async function GET(req: NextRequest) {
         aiTokensDayMap.set(
           day,
           (aiTokensDayMap.get(day) ?? 0) +
-            ((row.prompt_tokens as number) ?? 0) +
-            ((row.completion_tokens as number) ?? 0),
+            ((row.input_tokens as number) ?? 0) +
+            ((row.output_tokens as number) ?? 0),
         );
       }
     }

app/api/v1/ai/credentials/route.ts

@@ -18,6 +18,7 @@ import { audit } from "@/lib/audit";
 import { requireRole } from "@/lib/auth/require-role";
 import { bufToBytea, encryptKey } from "@/lib/crypto/aes_gcm";
 import { validateProviderKey, type Provider } from "@/lib/ai/provider-validators";
+import { IDS_DE_PROVEDOR } from "@/lib/ai/pontos/provedores";
 import { createAdminClient } from "@/lib/supabase/admin";
 import { createClient } from "@/lib/supabase/server";
 
@@ -27,7 +28,11 @@ const SAFE_COLUMNS =
   "id, organization_id, provider, label, api_key_last4, validated_at, validation_error, models_available, is_active, created_by, created_at, updated_at";
 
 const createSchema = z.object({
-  provider: z.enum(["anthropic", "openai", "google"]),
+  // Derivado de `lib/ai/pontos/provedores.ts`, a lista única desde a migration
+  // 0127. Enquanto era uma cópia à mão, o banco aceitava OpenRouter e ESTA rota
+  // recusava com 422 — o operador via a tela de Provedores oferecer OpenRouter
+  // e não tinha onde cadastrar a chave.
+  provider: z.enum(IDS_DE_PROVEDOR),
   label: z.string().trim().min(1).max(80),
   api_key: z.string().trim().min(8).max(2048),
 });

app/api/v1/ai/providers/[provider]/models/route.ts

@@ -10,10 +10,14 @@ import { type NextRequest } from "next/server";
 import { ok, fail } from "@/lib/api/wrappers";
 import { loadAuthUser, resolveActiveOrg } from "@/lib/auth/server";
 import { createClient } from "@/lib/supabase/server";
+import { ehProvedorSuportado } from "@/lib/ai/pontos/provedores";
 
 export const dynamic = "force-dynamic";
 
-const PROVIDERS = new Set(["anthropic", "openai", "google"]);
+// A lista única (`lib/ai/pontos/provedores.ts`) — não uma quarta cópia. Esta
+// rota alimenta o seletor de modelos; com a lista velha, pedir os modelos da
+// OpenRouter devolvia "provedor desconhecido" para um provedor que a tela ao
+// lado oferecia.
 
 const MODEL_COLUMNS =
   "id, provider, model_id, display_name, description, context_window, input_price_per_million_cents, output_price_per_million_cents, supports_tools, is_default_for_provider, deprecated_at, released_at";
@@ -25,7 +29,7 @@ export async function GET(
   const requestId = randomUUID();
   const { provider } = await ctx.params;
 
-  if (!PROVIDERS.has(provider)) {
+  if (!ehProvedorSuportado(provider)) {
     return fail("not_found", "Provider desconhecido.", 404, { requestId });
   }
 

app/api/v1/ai/providers/route.ts

@@ -25,7 +25,7 @@ import {
   type LinhaDeBinding,
 } from "@/lib/ai/pontos/resolver";
 import { PAPEIS, PONTOS_DE_IA, PONTO_POR_ID } from "@/lib/ai/pontos/registro";
-import { PROVEDORES } from "@/lib/ai/pontos/provedores";
+import { PROVEDORES, ehProvedorSuportado } from "@/lib/ai/pontos/provedores";
 import { validarBinding } from "@/lib/ai/pontos/validar-binding";
 import { createClient } from "@/lib/supabase/server";
 
@@ -121,8 +121,18 @@ export async function GET(): Promise<Response> {
       exige: ponto.exige,
       sintomaDeFalha: ponto.sintomaDeFalha,
       fixo: ponto.fixo ?? null,
-      /** Escolha do agente publicado — a tela mostra como leitura, com link. */
-      mandadoPeloAgente: PONTOS_DO_AGENTE_PUBLICADO.has(ponto.id),
+      /**
+       * Escolha do agente publicado — a tela mostra como leitura, com link.
+       *
+       * Depende de EXISTIR versão publicada: é a mesma condição que o resolvedor
+       * usa (`resolver.ts` exige `agentePublicado !== null`). Sem o `&&`, uma
+       * instalação recém-feita — nenhum agente publicado ainda — abria o painel
+       * com os DOIS pontos que respondem o cliente sem seletor, dizendo que são
+       * governados por uma versão publicada que não existe e mandando
+       * configurar num lugar vazio. É a primeira tela da feature; travá-la no
+       * primeiro uso é o pior lugar para esse defeito estar.
+       */
+      mandadoPeloAgente: agentePublicado !== null && PONTOS_DO_AGENTE_PUBLICADO.has(ponto.id),
       efetivo: {
         provider: decisao.provider,
         modelId: decisao.modelId,
@@ -156,7 +166,19 @@ export async function GET(): Promise<Response> {
 
 const corpoDoPut = z.object({
   purpose: z.string().min(1),
-  provider: z.string().min(1),
+  // A migration 0127 removeu os CHECKs do banco dizendo que "a garantia de que
+  // a tela não oferece opção inválida passa a morar" na lista de provedores —
+  // mas a lista não era aplicada em NENHUM ponto de escrita. Um PUT direto (e a
+  // API é pública) gravava `provider: "foobar"`, a rota respondia 200, e todo
+  // uso daquele ponto morria em produção com provedor desconhecido. Metade da
+  // defesa transferida e nunca instalada.
+  provider: z
+    .string()
+    .min(1)
+    .refine(ehProvedorSuportado, {
+      message:
+        "provedor não suportado por esta instalação — escolha um da lista em Agente de IA → Provedores",
+    }),
   model_id: z.string().min(1),
   credential_id: z.string().uuid().nullable().optional(),
   base_url: z.string().url().nullable().optional(),
@@ -240,7 +262,7 @@ export async function PUT(req: NextRequest): Promise<Response> {
       },
       { onConflict: "organization_id,purpose" },
     )
-    .select("purpose, provider, model_id, credential_id, base_url, is_enabled")
+    .select("id, purpose, provider, model_id, credential_id, base_url, is_enabled")
     .maybeSingle();
 
   if (error) return fail("save_failed", error.message, 500);
@@ -255,11 +277,19 @@ export async function PUT(req: NextRequest): Promise<Response> {
     organizationId: org.orgId,
     actorUserId: user.id,
     resourceType: "ai_purpose_binding",
-    resourceId: corpo.purpose,
+    // O ID DA LINHA, não o `purpose`. `api_audit_log.resource_id` é **uuid**, e
+    // `purpose` é texto (`stage_classifier`): o INSERT falhava com 22P02
+    // (`invalid input syntax for type uuid`) e — como o audit é
+    // fire-and-forget — o erro ia só para o log do servidor. Resultado: NENHUMA
+    // troca de modelo era auditada, num painel cujo efeito é justamente mudar
+    // para onde o dinheiro e os dados do cliente vão. Achado dirigindo a tela;
+    // nenhum gate via, porque nada assertava a linha de auditoria.
+    resourceId: (gravado as { id?: string }).id ?? null,
     // O modelo entra no metadata, a credencial NÃO — só o id dela seria
     // inócuo, mas o hábito de mandar campo de credencial para o audit é o que
     // acaba vazando a chave quando alguém troca o campo de lugar.
     metadata: {
+      purpose: corpo.purpose,
       provider: corpo.provider,
       model_id: corpo.model_id,
       tem_endpoint_proprio: Boolean(corpo.base_url),

app/api/v1/ai/runs/route.ts

@@ -8,6 +8,7 @@
  * porque é assim que o operador pensa depois de configurar o painel: "troquei o
  * modelo do classificador de estágio, está funcionando?".
  */
+import { z } from "zod";
 import type { NextRequest } from "next/server";
 
 import { fail, ok } from "@/lib/api/wrappers";
@@ -59,6 +60,12 @@ interface LinhaDeExecucao {
   created_at: string;
 }
 
+const filtrosDaQuery = z.object({
+  purpose: z.string().min(1).max(64).optional(),
+  status: z.enum(["ok", "erro"]).optional(),
+  limit: z.coerce.number().int().min(1).max(200).default(100),
+});
+
 export async function GET(req: NextRequest): Promise<Response> {
   const user = await requireAuth();
   const org = await resolveActiveOrg(user);
@@ -67,10 +74,15 @@ export async function GET(req: NextRequest): Promise<Response> {
     return fail("forbidden", "requer papel de gerente ou superior", 403);
   }
 
-  const url = new URL(req.url);
-  const purpose = url.searchParams.get("purpose");
-  const status = url.searchParams.get("status");
-  const limite = Math.min(Number(url.searchParams.get("limit") ?? 100), 200);
+  // Zod na query string, como a rota irmã de uso já faz. `Math.min(Number(…))`
+  // não valida nada: `?limit=abc` virava `NaN` e `?limit=-5` passava direto,
+  // o PostgREST recusava, e o erro dele voltava como **500** com a mensagem
+  // crua no corpo — resposta de servidor para um erro do cliente.
+  const filtros = filtrosDaQuery.safeParse(Object.fromEntries(new URL(req.url).searchParams));
+  if (!filtros.success) {
+    return fail("invalid_query", "filtros inválidos", 422, { details: filtros.error.issues });
+  }
+  const { purpose, status, limit: limite } = filtros.data;
 
   const db = await createClient();
   let q = db
@@ -83,7 +95,7 @@ export async function GET(req: NextRequest): Promise<Response> {
     .limit(limite);
 
   if (purpose) q = q.eq("purpose", purpose);
-  if (status === "erro" || status === "ok") q = q.eq("status", status);
+  if (status) q = q.eq("status", status);
 
   const { data, error } = await q;
   if (error) return fail("query_failed", error.message, 500);

app/app/ai/agents/[id]/_components/ModelPicker.tsx

@@ -11,8 +11,14 @@ import {
   SelectTrigger,
   SelectValue,
 } from "@/components/ui/select";
+import { PROVEDORES } from "@/lib/ai/pontos/provedores";
 
-export type Provider = "anthropic" | "openai" | "google";
+/**
+ * Derivado de `lib/ai/pontos/provedores.ts` — a mesma lista única da tela de
+ * Credenciais e da rota. Como literal aqui, o seletor de modelo do agente não
+ * conseguia representar um agente publicado em OpenRouter.
+ */
+export type Provider = (typeof PROVEDORES)[number]["id"];
 
 export interface ModelOption {
   provider: Provider;

app/app/ai/credentials/_components/AddCredentialDialog.tsx

@@ -32,9 +32,11 @@ import {
   type CredentialRow,
   type Provider,
 } from "@/hooks/ai/useCredentials";
+import { IDS_DE_PROVEDOR, PROVEDORES } from "@/lib/ai/pontos/provedores";
 
 const formSchema = z.object({
-  provider: z.enum(["anthropic", "openai", "google"]),
+  // Derivado da lista única (`lib/ai/pontos/provedores.ts`), como a rota.
+  provider: z.enum(IDS_DE_PROVEDOR),
   label: z.string().trim().min(1, "Obrigatório").max(80),
   api_key: z.string().trim().min(8, "API key muito curta").max(2048),
 });
@@ -141,9 +143,11 @@ export function AddCredentialDialog({ open, onOpenChange }: Props) {
                 <SelectValue />
               </SelectTrigger>
               <SelectContent>
-                <SelectItem value="anthropic">Anthropic</SelectItem>
-                <SelectItem value="openai">OpenAI</SelectItem>
-                <SelectItem value="google">Google</SelectItem>
+                {PROVEDORES.map((p) => (
+                  <SelectItem key={p.id} value={p.id}>
+                    {p.rotulo}
+                  </SelectItem>
+                ))}
               </SelectContent>
             </Select>
             {errors.provider && (