/**
 * Helpers dos specs de auth E2E: leitura de e-mails reais no Mailpit do
 * Supabase local + parsing do link /auth/confirm dos templates.
 */
import { readFileSync } from "node:fs";
import { join } from "node:path";

import { expect, type Page } from "@playwright/test";

const MAILPIT_URL = process.env.MAILPIT_URL ?? "http://127.0.0.1:54324";

/** Parser mínimo de .env.local (os specs rodam fora do runtime Next). */
export function loadEnvLocal(): Record<string, string> {
  const out: Record<string, string> = {};
  try {
    const raw = readFileSync(join(process.cwd(), ".env.local"), "utf-8");
    for (const line of raw.split("\n")) {
      const m = line.match(/^([A-Z0-9_]+)=(.*)$/);
      if (m) out[m[1]!] = m[2]!.replace(/^["']|["']$/g, "");
    }
  } catch {
    // sem .env.local — caller decide se é fatal
  }
  return out;
}

export function uniqueEmail(prefix: string): string {
  return `e2e-${prefix}-${Date.now()}-${Math.random().toString(36).slice(2, 6)}@deskcomm.test`;
}

interface MailpitSearchResult {
  messages: { ID: string; Subject: string }[];
}

/**
 * Aguarda um e-mail para `to` cujo assunto contenha `subjectPart` e devolve o
 * HTML da mensagem mais recente.
 */
export async function waitForEmail(
  to: string,
  subjectPart: string,
  timeoutMs = 30_000,
): Promise<string> {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const res = await fetch(
      `${MAILPIT_URL}/api/v1/search?query=${encodeURIComponent(`to:${to}`)}`,
    );
    if (res.ok) {
      const data = (await res.json()) as MailpitSearchResult;
      const msg = data.messages?.find((m) => m.Subject.includes(subjectPart));
      if (msg) {
        const msgRes = await fetch(`${MAILPIT_URL}/api/v1/message/${msg.ID}`);
        const body = (await msgRes.json()) as { HTML: string; Text: string };
        return body.HTML || body.Text;
      }
    }
    await new Promise((r) => setTimeout(r, 500));
  }
  throw new Error(`email para ${to} com assunto contendo "${subjectPart}" não chegou em ${timeoutMs}ms`);
}

/**
 * Extrai o link /auth/confirm do HTML do e-mail e reescreve a origin para a
 * baseURL sob teste (o SiteURL/RedirectTo do GoTrue pode apontar para outra
 * porta em dev — o token_hash é o que importa).
 */
export function extractAuthConfirmLink(html: string, baseUrl: string): string {
  // Se o redirect_to não está na allowlist do GoTrue, o link cai no site_url
  // sem o path /auth/confirm — por isso ancoramos no token_hash e remontamos a
  // URL contra a baseURL sob teste (o token é o que importa).
  const m = html.match(/href="([^"]*token_hash=[^"]*)"/);
  if (!m) throw new Error("link com token_hash não encontrado no e-mail");
  const href = m[1]!.replace(/&amp;/g, "&");
  const url = new URL(href);
  const base = new URL(baseUrl);
  url.protocol = base.protocol;
  url.host = base.host;
  url.pathname = "/auth/confirm";
  return url.toString();
}

/**
 * Segue um link de e-mail como a pessoa faz: abre, vê a tela de confirmação e
 * aperta "Continuar". Abrir o link sozinho não gasta mais o token (é o que
 * protege do verificador de links do Hotmail/Outlook) — ver
 * `app/auth/confirm/route.ts`.
 */
export async function seguirLinkDeAcesso(page: Page, link: string): Promise<void> {
  await page.goto(link);
  await expect(page).toHaveURL(/\/login\/continuar/);
  await page.getByRole("button", { name: "Continuar" }).click();
}