Member page

frontend/lib/request.ts

@@ -0,0 +1,56 @@
+import { API_URL } from "@/lib/constants";
+import { ApiResponse } from "@/types/types";
+import { getCookie } from "cookies-next";
+import { ReadonlyRequestCookies } from "next/dist/server/web/spec-extension/adapters/request-cookies";
+export default async function request<T>(
+	endpoint: string,
+	options: {
+		method?: "GET" | "POST" | "PATCH" | "DELETE";
+		body?: any;
+		requiresAuth?: boolean;
+		csrfToken?: boolean;
+		cookies?: () => Promise<ReadonlyRequestCookies>;
+	} = {},
+): Promise<ApiResponse<T>> {
+	console.log("Hello everyone");
+	const { method = "GET", body, requiresAuth = true } = options;
+	const headers: Record<string, string> = {
+		"Content-Type": "application/json",
+	};
+
+	if (options.csrfToken) {
+		const res: ApiResponse<{ csrf: string }> = await (
+			await fetch(`${API_URL}/csrf-token`)
+		).json();
+		if (res.data) headers["X-CSRF-Token"] = res.data.csrf;
+	}
+
+	if (requiresAuth) {
+		let authToken;
+		if (!options.cookies) {
+			authToken = getCookie("auth_token");
+		} else {
+			authToken = (await options.cookies()).get("auth_token")?.value;
+		}
+
+		if (!authToken) {
+			throw new Error("User is not authenticated");
+		}
+		headers.Authorization = `Bearer ${authToken}`;
+	}
+
+	const response = await fetch(`${API_URL}${endpoint}`, {
+		method,
+		headers,
+		body: body ? JSON.stringify(body) : undefined,
+		credentials: options.csrfToken ? "include" : "omit",
+	});
+
+	const apiResponse: ApiResponse<T> = await response.json();
+
+	if (apiResponse.status === "Error") {
+		throw new Error(apiResponse.message || "An unexpected error occurred");
+	}
+
+	return apiResponse;
+}