import type { SupabaseClient, User } from "@supabase/supabase-js";
import { Hono } from "hono";
import type { Transporter } from "nodemailer";
import { StreamChat } from "stream-chat";
import type { Tables } from "./database.types.ts";
import { authMiddleware, streamChatMiddleware } from "./middleware.js";
import { transporter } from "./transporter.js";

export const userRouter = new Hono<{
  Variables: {
    user: User;
    supabase: SupabaseClient;
    transporter: Transporter;
    streamServerClient: StreamChat;
  };
}>();

userRouter.use(authMiddleware);
userRouter.use(streamChatMiddleware);

userRouter.post("/sign-up-to-stream", async (c) => {
  const { id } = c.get("user");
  const supabase = c.get("supabase");

  const { data } = await supabase
    .from("profiles")
    .select("*")
    .eq("id", id)
    .single();

  const user = data as Tables<"profiles">;

  const streamServerClient = c.get("streamServerClient");
  await streamServerClient.upsertUser({
    id,
    name: user.name ?? "",
    language: "fr",
  });

  return c.json({
    message: "User signed up to stream",
  });
});

userRouter.get("/me", async (c) => {
  const user = c.get("user");
  const supabase = c.get("supabase");
  const streamServerClient = c.get("streamServerClient");

  const { data, error } = await supabase
    .from("profiles")
    .select("*")
    .eq("id", user.id)
    .single();

  const userData = data as Tables<"profiles">;

  if (!userData) {
    return c.json({ error: "User not found" }, 404);
  }

  if (error) {
    return c.json({ error: error.message }, 500);
  }

  const user_id = data.id;
  const token = streamServerClient.createToken(user_id);

  return c.json({
    ...userData,
    streamToken: token,
  });
});

userRouter.post("/mark-temporary", async (c) => {
  const user = c.get("user");
  const supabase = c.get("supabase");

  const body = await c.req.json();
  const { temporary_password } = body;

  const { data: profile, error } = await supabase
    .from("profiles")
    .update({
      is_temporary: true,
    })
    .eq("id", user.id)
    .select()
    .single();

  if (error) {
    return c.json({ error: error.message }, 500);
  }

  try {
    if (profile?.email && transporter) {
      const mailOptions = {
        from: "Xtablo <noreply@xtablo.com>",
        to: profile.email,
        subject: "Bienvenue sur XTablo - Votre mot de passe temporaire",
        text: `Bienvenue sur XTablo !

Votre compte a été créé avec succès. Voici vos informations de connexion :

Email : ${profile.email}
Mot de passe temporaire : ${temporary_password}

Pour des raisons de sécurité, nous vous recommandons fortement de changer ce mot de passe temporaire lors de votre première connexion.

Connectez-vous sur : ${process.env.FRONTEND_URL || "https://app.xtablo.com"}

Cordialement,
L'équipe XTablo`,
        html: `
          <div style="font-family: Arial, sans-serif; max-width: 600px; margin: 0 auto;">
            <h2 style="color: #333;">Bienvenue sur XTablo !</h2>
            
            <p>Votre compte a été créé avec succès. Voici vos informations de connexion :</p>
            
            <div style="background-color: #f5f5f5; padding: 15px; border-radius: 5px; margin: 20px 0;">
              <p><strong>Email :</strong> ${profile.email}</p>
              <p><strong>Mot de passe temporaire :</strong> <code style="background-color: #e1e1e1; padding: 2px 4px; border-radius: 3px;">${temporary_password}</code></p>
            </div>
            
            <p style="color: #d9534f; margin-bottom: 20px;"><strong>Important :</strong> Pour des raisons de sécurité, nous vous recommandons fortement de changer ce mot de passe temporaire lors de votre première connexion.</p>
            
            <p>
              <a href="${process.env.FRONTEND_URL || "https://app.tablo.fr"}" 
                 style="background-color: #007bff; color: white; padding: 10px 20px; text-decoration: none; border-radius: 5px; display: inline-block;">
                Se connecter à XTablo
              </a>
            </p>
            
            <p style="color: #666; font-size: 14px; margin-top: 30px;">
              Cordialement,<br>
              L'équipe XTablo
            </p>
          </div>
        `,
      };
      await transporter.sendMail(mailOptions);
    }
  } catch (error) {
    console.error("Failed to send welcome email:", error);
  }

  return c.json({
    message: "User marked as temporary",
  });
});

userRouter.put("/profile", async (c) => {
  const user = c.get("user");
  const supabase = c.get("supabase");

  const body = await c.req.json();
  const { first_name, last_name, introduction_email } = body;

  // Combine first_name and last_name into a single name field
  const name = [first_name, last_name].filter(Boolean).join(" ");

  const { data: profile, error } = await supabase
    .from("profiles")
    .update({
      name: name || null,
      first_name: first_name || null,
      last_name: last_name || null,
    })
    .eq("id", user.id)
    .select()
    .single();

  if (error) {
    return c.json({ error: error.message }, 500);
  }

  // Update user metadata in Supabase Auth using updateUser
  const { error: authError } = await supabase.auth.updateUser({
    data: {
      first_name: first_name || "",
      last_name: last_name || "",
      introduction_email: introduction_email || "",
    },
  });

  if (authError) {
    console.error("Failed to update user metadata:", authError);
    // Don't fail the request if metadata update fails
  }

  return c.json({
    message: "Profile updated successfully",
    profile,
  });
});