sofa/app/api/stats/route.ts

import { headers } from "next/headers";
import { NextResponse } from "next/server";
import { auth } from "@/lib/auth/server";
import { getWatchCount, type TimePeriod } from "@/lib/services/discovery";

const validTypes = ["movies", "episodes"] as const;
const validPeriods: TimePeriod[] = [
  "today",
  "this_week",
  "this_month",
  "this_year",
];

export async function GET(request: Request) {
  const session = await auth.api.getSession({ headers: await headers() });
  if (!session)
    return NextResponse.json({ error: "Unauthorized" }, { status: 401 });

  const { searchParams } = new URL(request.url);
  const type = searchParams.get("type");
  const period = searchParams.get("period");

  if (
    !type ||
    !period ||
    !validTypes.includes(type as (typeof validTypes)[number]) ||
    !validPeriods.includes(period as TimePeriod)
  ) {
    return NextResponse.json({ error: "Invalid parameters" }, { status: 400 });
  }

  const count = getWatchCount(
    session.user.id,
    type as "movies" | "episodes",
    period as TimePeriod,
  );

  return NextResponse.json({ count });
}