import type { NextRequest } from "next/server";
import { NextResponse } from "next/server";
import { getUserId } from "./lib/getUserID";

export async function middleware(request: NextRequest) {
  if (request.nextUrl.pathname.startsWith("/dash")) {
    const token = request.cookies.get("token")?.value;

    if (token) {
      try {
        const user = await getUserId(token);

        console.log(user);
        if (user.verified === 0) {
          return NextResponse.redirect(`${process.env.WEB_DOMAIN}/verify`);
        } else return NextResponse.next();
      } catch (e) {
        console.error(e);
        return NextResponse.redirect(`${process.env.WEB_DOMAIN}/login`);
      }
    } else {
      const nextPath = encodeURIComponent(request.nextUrl.pathname);
      return NextResponse.redirect(
        `${process.env.WEB_DOMAIN}/login?next=${nextPath}`
      );
    }
  } else NextResponse.next();
}

import { User } from "@/lib/types";
import { query } from "./query";
import { jwtVerify } from "jose";

export async function verifyJwt(jwt: string): Promise<any> {
  const secretKey: Uint8Array = new TextEncoder().encode(
    process.env.JWT_SECRET as string
  );
  const { payload } = await jwtVerify(jwt, secretKey, {
    algorithms: ["HS256"],
  });

  return payload;
}

export async function getUserId(jwt: string) {
  try {
    const payload: any = await verifyJwt(jwt);

    const queryUserResult = await query(`SELECT * FROM users WHERE id=?`, [
      payload.id,
    ]);
    console.log(queryUserResult);
    const data: Array<any> = Array.isArray(queryUserResult)
      ? queryUserResult
      : [];

    return data[0] as User;
  } catch (error) {
    console.log(error);
    throw new Error("Unauthorized");
  }
}