import React from "react";
import { getServerSession } from "next-auth/next";
import { authOptions } from "@/pages/api/auth/[...nextauth]";
import type { NextApiRequest, NextApiResponse } from "next";
import { createClient } from "redis";

const redisClient = createClient({
  url: process.env.REDIS_URL,
});

await redisClient.connect();

export default async function handler(
  req: NextApiRequest,
  res: NextApiResponse
) {
  const session = await getServerSession(req, res, authOptions);

  if (!session) {
    return res.status(401).json({ message: "Unauthorized" });
  }

  const cacheKey = `discord:servers:${session.user.id}`;
  let guilds;

  try {
    const cachedGuilds = await redisClient.get(cacheKey);
    if (cachedGuilds) {
      guilds = JSON.parse(cachedGuilds);
    } else {
      const Discord = await fetch(`https://discord.com/api/users/@me/guilds`, {
        headers: {
          Authorization: `Bearer ${session.accessToken}`,
        },
      });
      guilds = await Discord.json();

      await redisClient.set(cacheKey, JSON.stringify(guilds), {
        EX: 3600,
      });
    }
  } catch (error) {
    console.error("Redis error:", error);
    return res.status(500).json({ message: "Internal Server Error" });
  }

  const Mutual = await fetch(`${process.env.API_URL}/mutual_servers?perm=admin`, {
    method: "POST",
    body: JSON.stringify({
      user: session.user.id,
      guilds: guilds.map((guild: any) => guild.id),
    }),
    headers: {
      "Content-Type": "application/json",
    },
  });
  const mutualGuilds = await Mutual.json();
  res.status(200).json({ mutualGuilds });
}