1 files changed, 45 insertions, 0 deletions
diff --git a/apps/web/app/lib/auth/authMiddleware.ts b/apps/web/app/lib/auth/authMiddleware.ts
new file mode 100644
index 00000000..e4b59243
--- /dev/null
+++ b/apps/web/app/lib/auth/authMiddleware.ts
@@ -0,0 +1,45 @@
+import { AppLoadContext, redirect } from "@remix-run/cloudflare";
+
+import { getSessionFromRequest } from "@supermemory/authkit-remix-cloudflare/src/session";
+import { database, eq } from "@supermemory/db";
+import { User, users } from "@supermemory/db/schema";
+
+export const verifyOrCreateUser = async (
+	request: Request,
+	context: AppLoadContext,
+): Promise<User | null> => {
+	const session = await getSessionFromRequest(request, context);
+	console.log(session);
+	if (!session?.user?.id) {
+		return null;
+	}
+
+	let user = await database(context.cloudflare.env.HYPERDRIVE.connectionString)
+		.select()
+		.from(users)
+		.where(eq(users.uuid, session.user.id));
+
+	if ((!user || user.length === 0) && session?.user?.id) {
+		const newUser = await database(context.cloudflare.env.HYPERDRIVE.connectionString)
+			.insert(users)
+			.values({
+				uuid: session.user?.id,
+				email: session.user?.email,
+				firstName: session.user?.firstName,
+				lastName: session.user?.lastName,
+				createdAt: new Date(),
+				updatedAt: new Date(),
+				emailVerified: false,
+				profilePictureUrl: session.user?.profilePictureUrl ?? "",
+			})
+			.returning();
+
+		user = newUser;
+	}
+
+	if (!user) {
+		return null;
+	}
+
+	return user[0];
+};