"use server";

import { headers } from "next/headers";
import { revalidatePath } from "next/cache";

import { respostaParaOperador } from "@/lib/erros/para-operador";
import { ipDoCliente } from "@/lib/http/ip-do-cliente";
import { createClient } from "@/lib/supabase/server";
import { audit } from "@/lib/audit";
import {
  profileSchema,
  SEM_PREFERENCIA_DE_IDIOMA,
  type ProfileInput,
} from "@/lib/schemas/settings";
import { invalidarUsuario } from "@/lib/auth/cache-curto";
import { resolveActiveOrg, loadAuthUser } from "@/lib/auth/server";

export type UpdateProfileResult =
  | { ok: true }
  | { ok: false; error: string; details?: unknown };

export async function updateProfile(input: ProfileInput): Promise<UpdateProfileResult> {
  const parsed = profileSchema.safeParse(input);
  if (!parsed.success) {
    return { ok: false, error: "validation_failed", details: parsed.error.flatten() };
  }

  const authUser = await loadAuthUser();
  if (!authUser) return { ok: false, error: "unauthenticated" };

  const supabase = await createClient();
  const hdrs = await headers();
  const requestId = hdrs.get("x-request-id");
  const ip = ipDoCliente(hdrs);
  const userAgent = hdrs.get("user-agent") ?? null;

  const { error } = await supabase.auth.updateUser({
    data: {
      full_name: parsed.data.full_name ?? null,
      // `null` é o que faz a cadeia seguir para a organização: o resolvedor
      // de idioma lê a preferência primeiro e só cai na empresa se ela faltar.
      locale: parsed.data.locale === SEM_PREFERENCIA_DE_IDIOMA ? null : parsed.data.locale,
      timezone: parsed.data.timezone,
      avatar_url: parsed.data.avatar_url ?? null,
    },
  });
  // #3696: o `getUser` vai para o cache curto; outra sessão da pessoa leria o metadata velho.
  invalidarUsuario(authUser.id);
  if (error) {
    // #3747: `auth.updateUser` devolve erro SEM `code` — o mapeador reconhece a
    // sessão vencida pelo texto e o resto cai na genérica. O cru vai para o log.
    return respostaParaOperador(error, {
      contexto: "[perfil] falha ao gravar os dados do usuário",
      idioma: authUser.idioma,
    });
  }

  const activeOrg = await resolveActiveOrg(authUser);

  await audit({
    action: "profile.updated",
    actorUserId: authUser.id,
    organizationId: activeOrg?.orgId ?? null,
    resourceType: "user",
    resourceId: authUser.id,
    requestId,
    ip,
    userAgent,
    metadata: {
      locale: parsed.data.locale,
      timezone: parsed.data.timezone,
    },
  });

  // Best-effort emit (event_log is org-scoped; skip if no org).
  if (activeOrg && authUser.support?.access_mode !== "support_readonly") {
    await supabase
      .rpc("emit_event", {
        p_event_type: "user.profile_updated",
        p_entity_kind: "user",
        p_entity_id: authUser.id,
        p_payload: { user_id: authUser.id },
        p_metadata: { request_id: requestId },
        p_organization_id: activeOrg.orgId,
      })
      .then(({ error: e }) => {
        if (e) console.error("[updateProfile] emit_event failed", e.message);
      });
  }

  revalidatePath("/app/settings/profile");
  return { ok: true };
}