1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
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];
};
|