/**
 * A 0404 NO PAPEL — a tripla inteira de `comando_da_conversa` fica medida aqui.
 *
 * A issue #1571 trocou o custo da Inbox por duas decisões que não aparecem em
 * nenhum outro teste e que envelhecem em silêncio se sumirem:
 *
 *  1. SECURITY DEFINER (a contagem das abas pagava a policy de `contacts` duas
 *     vezes por conversa — 823–846 ms → 75–94 ms medido na issue);
 *  2. parâmetro SEM NOME (com nome, a PostgREST expõe a coluna calculada em
 *     `/rpc` — e sob `definer`, uma linha fabricada de `conversations` leria
 *     `force_human`/`is_blocked` de outro tenant);
 *  3. o apêndice no `baseline.sql`, antes da varredura anon (a definição do meio
 *     do arquivo ainda nasce namedada + invoker, como a 0203 a escreveu — sem o
 *     apêndice, todo `update.sh` DESFAZ a correção);
 *  4. `ct.organization_id = $1.organization_id` nas duas subconsultas (a policy de
 *     UPDATE de `conversations` não confere `contact_id` e a FK não passa pela
 *     RLS — sem o predicado, sob o definer, uma conversa apontada para contato de
 *     outra empresa leria os dois bits dele).
 *
 * Este arquivo é a régua estática das quatro, mais a linha do MANIFEST — o
 * `pre-commit` confere a tripla no momento do commit, mas sem isto um rebase ou
 * um "arrumar o baseline" futuro derruba a decisão com o gate verde.
 *
 * O que ele NÃO faz: afirmar comportamento de banco (isso é invariante, e o
 * job `invariants` do CI roda com Postgres de verdade — `pnpm test:db` exige
 * Docker, que esta VPS não tem).
 */
import fs from "node:fs";
import path from "node:path";

import { describe, expect, it } from "vitest";

const RAIZ = process.cwd();
const DIR_MIGRACOES = path.join(RAIZ, "supabase", "migrations");
/** Sufixo estável da migration — o NNNN pode ser renumerado, o resto não. */
const SUFIXO = "_comando_da_conversa_sem_reavaliar_rls.sql";

const arquivoDaMigration = (): string | undefined =>
  fs.readdirSync(DIR_MIGRACOES).find((f) => f.endsWith(SUFIXO));

const ler = (caminho: string): string => fs.readFileSync(caminho, "utf8");

describe("a 0404 — comando_da_conversa sem reavaliar a RLS (issue #1571)", () => {
  it("a tripla está na árvore: migration, apêndice no baseline e linha no MANIFEST", () => {
    const nome = arquivoDaMigration();
    expect(
      nome,
      `migration ausente: supabase/migrations/*${SUFIXO} — sem ela o update de clone não aplica a correção`,
    ).toBeDefined();

    const manifest = ler(path.join(DIR_MIGRACOES, "MANIFEST.md"));
    const celulaDoManifest = nome!.replace(/^\d{14}_/, "").replace(/\.sql$/, "");
    expect(
      manifest.includes(celulaDoManifest),
      "MANIFEST.md sem a linha da migration — a tripla da regra de migrations está incompleta",
    ).toBe(true);

    const baseline = ler(path.join(RAIZ, "supabase", "baseline.sql"));
    expect(
      baseline.includes("drop function if exists public.comando_da_conversa(public.conversations);"),
      "baseline.sql sem o apêndice da 0404: a definição do meio nasce namedada+invoker e TODO update.sh desfaria a correção",
    ).toBe(true);
  });

  it("na migration, a função nasce SECURITY DEFINER com parâmetro SEM NOME", () => {
    const sql = ler(path.join(DIR_MIGRACOES, arquivoDaMigration()!));

    expect(
      sql.includes("create function public.comando_da_conversa(public.conversations)"),
      "parâmetro namedado na criação: a PostgREST exporia a função em /rpc, e sob security definer uma linha fabricada leria force_human/is_blocked de outro tenant",
    ).toBe(true);
    expect(
      /comando_da_conversa\(\s*c\s+public\.conversations\s*\)/.test(sql),
      "a criação voltou a nomear o parâmetro (`c public.conversations`)",
    ).toBe(false);
    expect(sql.includes("security definer"), "sem security definer a contagem das abas volta a pagar a RLS de contacts 2x por conversa").toBe(true);
    expect(sql.includes("$1.status"), "o corpo deixou de referenciar o parâmetro por posição ($1)").toBe(true);
    expect(/\bc\.status\b/.test(sql), "o corpo referencia `c.` — sobra do parâmetro nomeado removido").toBe(false);
  });

  it("a migration refaz as DUAS origens de EXECUTE e recarrega o schema do PostgREST", () => {
    const sql = ler(path.join(DIR_MIGRACOES, arquivoDaMigration()!));
    expect(sql, "revoke das duas origens ausente — o DROP levou a ACL e nasce exposta a public/anon").toMatch(
      /revoke execute on function public\.comando_da_conversa\(public\.conversations\) from public, anon;/,
    );
    expect(sql, "grant a authenticated/service_role ausente — a Inbox ficaria sem executar a função").toMatch(
      /grant\s+execute on function public\.comando_da_conversa\(public\.conversations\) to authenticated, service_role;/,
    );
    expect(sql, "notify pgrst ausente: a forma do schema mudou (o /rpc some) e o PostgREST seguiria servindo o velho até reinício manual").toContain(
      "notify pgrst, 'reload schema';",
    );
    expect(sql, "drop antes do create: sem ele o Postgres recusa o replace (mudança de nome de parâmetro) ou vira overload").toMatch(
      /drop function if exists public\.comando_da_conversa\(public\.conversations\);[\s\S]*create function public\.comando_da_conversa/,
    );
  });

  it("no baseline, o apêndice vem DEPOIS da definição da 0203 e é ele que aplica a virada", () => {
    const baseline = ler(path.join(RAIZ, "supabase", "baseline.sql"));
    const idxDef0203 = baseline.indexOf(
      "create or replace function public.comando_da_conversa(c public.conversations)",
    );
    // ⚠️ Âncora no COMENTÁRIO da 0404, e não no último `drop` do arquivo: a
    // partir da 0645 existe OUTRO drop de `comando_da_conversa` (o que move a
    // trava do contato para a coluna, issue #2739), e `lastIndexOf` passaria a
    // fatiar o apêndice errado — a régua desta seção é o apêndice DA 0404.
    const idxDrop = baseline.indexOf(
      "-- `comando_da_conversa` segue a forma da 0404 (issue #1571, upstream):",
    );

    expect(idxDef0203, "a definição da 0203 sumiu do meio do baseline (não é esta que a 0404 corrige — ela continua lá, no formato antigo)").toBeGreaterThanOrEqual(0);
    expect(idxDrop, "apêndice da 0404 ausente ou ANTES da definição da 0203 — a ordem errada deixa a função namedada+invoker como estado final").toBeGreaterThan(idxDef0203);

    const apendice = baseline.slice(idxDrop);
    expect(apendice.includes("security definer"), "o apêndice não aplica o security definer").toBe(true);
    expect(apendice.includes("create function public.comando_da_conversa(public.conversations)"), "o apêndice não recria com parâmetro sem nome").toBe(true);
    expect(apendice).toContain("notify pgrst, 'reload schema';");
  });

  it("nenhuma subconsulta em contacts dispensa a empresa da conversa, na migration e no apêndice", () => {
    const PREDICADO = "where ct.id = $1.contact_id and ct.organization_id = $1.organization_id)";

    const sql = ler(path.join(DIR_MIGRACOES, arquivoDaMigration()!));
    const baseline = ler(path.join(RAIZ, "supabase", "baseline.sql"));
    const apendice = baseline.slice(
      baseline.indexOf("-- `comando_da_conversa` segue a forma da 0404 (issue #1571, upstream):"),
    );

    const motivo =
      "subconsulta em contacts sem `ct.organization_id = $1.organization_id`: sob o definer, uma conversa apontada para contato de outra empresa leria force_human/is_blocked dele";
    // A régua é TODA subconsulta em contacts, e não um número fixo: a versão
    // desta cerca cravava "exatamente 2", o que passou a abençoar subconsulta
    // nova sem a empresa quando o total cresceu (#4012 acrescentou o caminho do
    // telefone) e a exigir subconsulta quando a #2739 tirou o resto (o wrapper
    // lê o bit da linha, `contato_trava_humano`). Medir por IGUALDADE entre
    // subconsultas e subconsultas com o predicado vale para qualquer
    // quantidade — inclusive zero.
    const subconsulta = "from public.contacts ct where ct.id = $1.contact_id";
    const semEmpresa = (texto: string): number =>
      texto.split(subconsulta).length - 1 - (texto.split(PREDICADO).length - 1);
    expect(semEmpresa(sql), `migration — ${motivo}`).toBe(0);
    expect(semEmpresa(apendice), `apêndice do baseline — ${motivo}`).toBe(0);
  });
});