feat: Add new server action to get user by email

lib/actions/authenticatedDBActions.ts

@@ -3,18 +3,18 @@
 import type { NewBoard, NewPost } from "@/db/schema";
 import { createBoard, deleteBoard } from "@/lib/db/board";
 import { createPost, fetchPostsByBoardID } from "@/lib/db/post";
-import { findUserIdByKindeID } from "@/lib/db/user";
+import { findUserByEmail, findUserIdByKindeID } from "@/lib/db/user";
 import { getKindeServerSession } from "@kinde-oss/kinde-auth-nextjs/server";
 import { redirect } from "next/navigation";
 
-export async function authenticatedAction<T>(
+async function authenticatedAction<T>(
   action: () => Promise<T>
 ): Promise<T | null> {
   const { isAuthenticated } = getKindeServerSession();
 
   if (!isAuthenticated()) {
     console.warn("Not authenticated");
-    redirect("/api/auth/login");
+    redirect("/");
   }
 
   return await action();
@@ -48,3 +48,5 @@ export const authenticatedDeleteBoard = async (
 ) => authenticatedAction(() => deleteBoard(boardId, userId));
 
 export const authenticatedFindUserIdByKindeID = async (kindeId: string) => authenticatedAction(() => findUserIdByKindeID(kindeId));
+
+export const authenticatedFindUserByEmail = async (email: string) => authenticatedAction(() => findUserByEmail(email));

lib/db/user.ts

@@ -7,7 +7,8 @@ export async function findUserIdByKindeID(kindeId: string) {
   const result = await db
     .select({ id: userTable.id })
     .from(userTable)
-    .where(eq(userTable.kinde_id, kindeId)).limit(1);
+    .where(eq(userTable.kinde_id, kindeId))
+    .limit(1);
   if (result.length > 0) {
     return result[0].id;
   } else {
@@ -37,6 +38,15 @@ export const deleteUser = async (userID: string) => {
   const result = await db
     .delete(userTable)
     .where(or(eq(userTable.id, userID), eq(userTable.kinde_id, userID)))
-    .returning({ deletedId: userTable.id });;
-  return result.length > 0 ? result[0] : 'No user deleted';
+    .returning({ deletedId: userTable.id });
+  return result.length > 0 ? result[0] : "No user deleted";
+};
+
+export const findUserByEmail = async (email: string) => {
+  const result = await db
+    .select()
+    .from(userTable)
+    .where(eq(userTable.email, email))
+    .limit(1);
+  return result.length > 0 ? result[0] : undefined;
 };