feat(resources): implement resource creation and update functionality, add user resource retrieval

Author: tyronejosee

src/actions/auth.ts

@@ -6,3 +6,17 @@ export async function logout() {
   const supabase = await createClient();
   await supabase.auth.signOut();
 }
+
+export async function getAuthenticatedUser() {
+  const supabase = await createClient();
+  const {
+    data: { user },
+    error,
+  } = await supabase.auth.getUser();
+
+  if (error || !user) {
+    return null;
+  }
+
+  return user;
+}

src/actions/resources.ts

@@ -1,6 +1,10 @@
 "use server";
 
-import type { Resource } from "@/types";
+import type {
+  CreateResourceInput,
+  UpdateResourceInput,
+  Resource,
+} from "@/types";
 
 import { createClient } from "@/lib/supabase/server";
 
@@ -32,3 +36,48 @@ export const getResourceBySlug = async (
   if (error) throw new Error(error.message);
   return data;
 };
+
+export const createResource = async (input: CreateResourceInput) => {
+  const supabase = await createClient();
+  const { data: userData, error: userError } = await supabase.auth.getUser();
+  if (userError || !userData?.user) throw new Error("User not found");
+  const { id: userId } = userData.user;
+  const payload = { ...input, author: userId };
+
+  const { data, error } = await supabase
+    .from("resources")
+    .insert([payload])
+    .select()
+    .single();
+
+  if (error) throw new Error(`Error creating resource: ${error.message}`);
+  return data;
+};
+
+export const updateResource = async (
+  id: string,
+  input: UpdateResourceInput,
+) => {
+  const supabase = await createClient();
+
+  const { data, error } = await supabase
+    .from("resources")
+    .update(input)
+    .eq("id", id)
+    .select()
+    .single();
+
+  if (error) throw new Error(`Error updating resource: ${error.message}`);
+  return data;
+};
+
+export async function getUserResources(userId: string) {
+  const supabase = await createClient();
+  const { data, error } = await supabase
+    .from("resources")
+    .select(`*, category:categories (id, name)`)
+    .eq("author", userId);
+
+  if (error) throw new Error(`Error fetching resources: ${error.message}`);
+  return data;
+}