import { authOptions } from "@/lib/auth";
import { LinkCrawlerQueue } from "@remember/shared/queues";
import prisma from "@remember/db";

import {
  zNewBookmarkedLinkRequestSchema,
  ZGetLinksResponse,
  ZBookmarkedLink,
} from "@/lib/types/api/links";
import { getServerSession } from "next-auth";
import { NextRequest, NextResponse } from "next/server";

export async function POST(request: NextRequest) {
  // TODO: We probably should be using an API key here instead of the session;
  const session = await getServerSession(authOptions);
  if (!session) {
    return new Response(null, { status: 401 });
  }

  const linkRequest = zNewBookmarkedLinkRequestSchema.safeParse(
    await request.json(),
  );

  if (!linkRequest.success) {
    return NextResponse.json(
      {
        error: linkRequest.error.toString(),
      },
      { status: 400 },
    );
  }

  const link = await prisma.bookmarkedLink.create({
    data: {
      url: linkRequest.data.url,
      userId: session.user.id,
    },
  });

  // Enqueue crawling request
  await LinkCrawlerQueue.add("crawl", {
    linkId: link.id,
    url: link.url,
  });

  let response: ZBookmarkedLink = { ...link };
  return NextResponse.json(response, { status: 201 });
}

export async function GET() {
  // TODO: We probably should be using an API key here instead of the session;
  const session = await getServerSession(authOptions);
  if (!session) {
    return new Response(null, { status: 401 });
  }
  const links = await prisma.bookmarkedLink.findMany({
    where: {
      userId: session.user.id,
    },
    select: {
      id: true,
      url: true,
      createdAt: true,
      details: {
        select: {
          title: true,
          description: true,
          imageUrl: true,
          favicon: true,
        },
      },
    },
  });

  let response: ZGetLinksResponse = { links };
  return NextResponse.json(response);
}