import { createRouteHandlerClient } from "@supabase/auth-helpers-nextjs";
import { cookies } from "next/headers";
import { NextResponse, NextRequest } from "next/server";
import { Database } from "@/types/supabase";
import { prisma } from "@/lib/prisma";
import { OpenAIEmbeddings } from "langchain/embeddings/openai";
import { SupabaseVectorStore } from "langchain/vectorstores/supabase";

async function getSession(supabase: any) {
  const {
    data: { session },
  } = await supabase.auth.getSession();
  return session;
}

export async function POST(
  req: NextRequest,
  {
    params: { workspaceID, projectID },
  }: { params: { workspaceID: string; projectID: string } }
) {
  const supabase = createRouteHandlerClient<Database>({ cookies });
  const session = await getSession(supabase);

  if (!session) return NextResponse.redirect("/auth");

  try {
    const formData = await req.json();
    const tasks: any[] = Array(formData);

    console.log("TASKS FORM DATA ===>", formData);

    let res_data: any[] = [];
    for (const task of formData) {
      console.log("CURRENT TASK ===>", task);
      const name = String(task.name);
      const description = String(task.description);
      const featureID =
        task.feature_id != undefined ? String(task.feature_id) : null;

      const task_data = await prisma.task.create({
        data: {
          name,
          description,
          project_id: BigInt(projectID),
          feature_id: featureID != null ? BigInt(featureID) : null,
        },
      });
      await prisma.profile_task.create({
        data: { profile_id: session.user.id, task_id: task_data.id },
      });

      const task_data_res = {
        ...task_data,
        id: String(task_data.id),
        project_id: String(task_data.project_id),
        feature_id: String(task_data.feature_id),
      };

      res_data.push(task_data_res);
    }

    console.log(res_data);
    return NextResponse.json({ feature: res_data }, { status: 200 });
  } catch (err) {
    console.error(err);
    return NextResponse.json({ error: err }, { status: 500 });
  }
}