// Routes about self (or users in general)
import express from 'express';
import { prisma } from '../config/db';

interface RecentPlayedGame {
  gameInternalName: string;
  timestamp: BigInt;
}

interface SafeGameCount {
  gameInternalName: string;
  formattedName: string;
  count: number;
}

export const handleMeRoute = async (req: express.Request, res: express.Response) => {
  try {
    const { userId } = req.query;
    if (!userId) {
      return res.status(400).json({ error: 'userId query parameter is required' });
    }
    const user = await prisma.user.findUniqueOrThrow({
      where: { id: parseInt(userId as string) },
      select: { id: true, username: true, isAdmin: true, bio: true }
    });
    const recentPlayedGames: RecentPlayedGame[] = await prisma.$queryRaw`
      SELECT *
      FROM (
        SELECT DISTINCT ON (s."gameInternalName")
          g."formattedName",
          s."timestamp",
          s."gameInternalName"
        FROM "Score" s
        INNER JOIN "Game" g ON g."internalName" = s."gameInternalName"
        WHERE s."userId" = ${parseInt(userId as string)}
        ORDER BY s."gameInternalName", s."timestamp" DESC
      ) sub
      ORDER BY sub."timestamp" DESC
      LIMIT 5;
    `;
    const scoreCountByGame: SafeGameCount[] = await prisma.$queryRaw`
      SELECT
        s."gameInternalName",
        g."formattedName",
        COUNT(*) as "count"
      FROM "Score" s
      INNER JOIN "Game" g ON g."internalName" = s."gameInternalName"
      WHERE s."userId" = ${parseInt(userId as string)}
      GROUP BY s."gameInternalName", g."formattedName"
    `;
    const safeGames= recentPlayedGames.map((game) => ({
      ...game,
      timestamp:
        typeof game.timestamp === "bigint"
          ? Number(game.timestamp)
          : game.timestamp,
    }));
    const safeScoreCountByGame = scoreCountByGame.map((game) => ({
      ...game,
      count: Number(game.count),
    }));
    const isAdmin = user.id === 1 || user.isAdmin;
    const { isAdmin: _, ...safeUser } = user;
    res.json({ user: safeUser, recentPlayedGames: safeGames, scoreCountByGame: safeScoreCountByGame, isAdmin });
  } catch (error) {
    console.error('Me endpoint error:', error);
    res.status(500).json({ error: 'Internal server error' });
  }
};

export const handleGetCurrentSession =  async (req: express.Request, res: express.Response) => {
  try {
    if (!req.session.userId) {
      return res.json({ authenticated: false });
    }

    const user = await prisma.user.findUnique({
      where: { id: req.session.userId },
      select: { id: true, username: true, isAdmin: true }
    });

    if (!user) {
      req.session.destroy((err) => {
        if (err) console.error('Session destroy error:', err);
      });
      return res.json({ authenticated: false });
    }

    res.json({
      authenticated: true,
      user
    });
  } catch (error) {
    console.error('Session check error:', error);
    res.status(500).json({ error: 'Internal server error' });
  }
}

export const handleGetScoresHeatmap = async (req: express.Request, res: express.Response) => {
  const { userId, gameInternalName } = req.query;
  if (!userId) {
    return res.status(400).json({ error: "Must specify userId to lookup parameters" });
  }
  try {
    const user = await prisma.user.findUnique({
      where: { id: parseInt(userId as string) },
      select: { id: true, username: true, isAdmin: true }
    });
    if (!user) {
      return res.status(404).json({ error: "User not found" });
    }

    const oneYearAndOneDay = new Date(Date.now() - 365 * 24 * 60 * 60 * 1000);
    const unixMs = Math.floor(oneYearAndOneDay.getTime() / 1000);

    const scores = await prisma.score.findMany({
      where: {
        userId: parseInt(userId as string),
        timestamp: { gte: unixMs },
        ...(gameInternalName && { gameInternalName: gameInternalName as string })
      },
      orderBy: { timestamp: 'desc' },
      select: {
        timestamp: true
      }
    }).then(scores => scores.map(score => ({
      ...score,
      timestamp: Number(score.timestamp)
    })))

    res.json({
      "username": user.username,
      "isAdmin": user.isAdmin,
      scores
    });
  } catch (error) {
    console.error('Session check error:', error);
    res.status(500).json({ error: 'Internal server error' });
  }
}