import { lucia } from "$lib/server/auth";
import { error, type RequestEvent } from "@sveltejs/kit";
import { adventureTable } from "$lib/db/schema";
import { db } from "$lib/db/db.server";
import { and, eq, isNull } from "drizzle-orm";
import type { Adventure } from "$lib/utils/types";

// Gets all the adventures that the user has visited
export async function GET(event: RequestEvent): Promise<Response> {
  if (!event.locals.user) {
    return new Response(JSON.stringify({ error: "No user found" }), {
      status: 401,
      headers: {
        "Content-Type": "application/json",
      },
    });
  }
  let result = await db
    .select()
    .from(adventureTable)
    .where(
      and(
        eq(adventureTable.userId, event.locals.user.id),
        eq(adventureTable.type, "planner"),
        isNull(adventureTable.tripId)
      )
    )
    .execute();
  return new Response(
    // turn the result into an Adventure object array
    JSON.stringify(
      result.map((r) => {
        const adventure: Adventure = r as Adventure;
        if (typeof adventure.activityTypes === "string") {
          try {
            adventure.activityTypes = JSON.parse(adventure.activityTypes);
          } catch (error) {
            console.error("Error parsing activityTypes:", error);
            adventure.activityTypes = undefined;
          }
        }
        return adventure;
      })
    ),
    {
      status: 200,
      headers: {
        "Content-Type": "application/json",
      },
    }
  );
}

// deletes the adventure given the adventure id and the user object
export async function DELETE(event: RequestEvent): Promise<Response> {
  if (!event.locals.user) {
    return new Response(JSON.stringify({ error: "No user found" }), {
      status: 401,
      headers: {
        "Content-Type": "application/json",
      },
    });
  }

  // get id from the body
  const { id } = await event.request.json();

  if (!id) {
    return new Response(JSON.stringify({ error: "No id found" }), {
      status: 400,
      headers: {
        "Content-Type": "application/json",
      },
    });
  }

  let res = await db
    .delete(adventureTable)
    .where(
      and(
        eq(adventureTable.userId, event.locals.user.id),
        eq(adventureTable.id, Number(id))
      )
    )
    .execute();

  return new Response(JSON.stringify({ id: id, res: res }), {
    status: 200,
    headers: {
      "Content-Type": "application/json",
    },
  });
}

export async function POST(event: RequestEvent): Promise<Response> {
  if (!event.locals.user) {
    return new Response(JSON.stringify({ error: "No user found" }), {
      status: 401,
      headers: {
        "Content-Type": "application/json",
      },
    });
  }

  const body = await event.request.json();
  if (!body.detailAdventure) {
    return error(400, {
      message: "No adventure data provided",
    });
  }

  const {
    name,
    location,
    date,
    description,
    activityTypes,
    rating,
    tripId,
    imageUrl,
  } = body.detailAdventure;

  if (!name) {
    return error(400, {
      message: "Name field is required!",
    });
  }

  if (rating && (rating < 1 || rating > 5)) {
    return error(400, {
      message: "Rating must be between 1 and 5",
    });
  }

  console.log(activityTypes);

  // insert the adventure to the user's visited list
  let res = await db
    .insert(adventureTable)
    .values({
      userId: event.locals.user.id,
      type: "planner",
      name: name,
      location: location || null,
      tripId: tripId || null,
      date: date || null,
      description: description || null,
      activityTypes: JSON.stringify(activityTypes) || null,
      rating: rating || null,
      imageUrl: imageUrl || null,
    })
    .returning({ insertedId: adventureTable.id })
    .execute();

  let insertedId = res[0].insertedId;
  console.log(insertedId);

  body.detailAdventure.id = insertedId;

  // return a response with the adventure object values
  return new Response(
    JSON.stringify({
      adventure: body.detailAdventure,
      message: { message: "Adventure added" },
      id: insertedId,
    }),
    {
      status: 200,
      headers: {
        "Content-Type": "application/json",
      },
    }
  );
}

// put route to update existing adventure
export async function PUT(event: RequestEvent): Promise<Response> {
  if (!event.locals.user) {
    return new Response(JSON.stringify({ error: "No user found" }), {
      status: 401,
      headers: {
        "Content-Type": "application/json",
      },
    });
  }

  const body = await event.request.json();
  if (!body.detailAdventure) {
    return error(400, {
      message: "No adventure data provided",
    });
  }

  const {
    name,
    location,
    date,
    description,
    activityTypes,
    id,
    rating,
    imageUrl,
  } = body.detailAdventure;

  if (!name) {
    return error(400, {
      message: "Name field is required!",
    });
  }

  // update the adventure in the user's visited list
  await db
    .update(adventureTable)
    .set({
      name: name,
      location: location,
      date: date,
      description: description,
      rating: rating,
      activityTypes: JSON.stringify(activityTypes),
      imageUrl: imageUrl,
    })
    .where(
      and(
        eq(adventureTable.userId, event.locals.user.id),
        eq(adventureTable.id, Number(id))
      )
    )
    .execute();

  return new Response(
    JSON.stringify({
      adventure: body.detailAdventure,
      message: { message: "Adventure updated" },
    }),
    {
      status: 200,
      headers: {
        "Content-Type": "application/json",
      },
    }
  );
}