This commit is contained in:
Omer Sabic 2024-06-07 14:35:02 +02:00
parent 54ed89cdd8
commit 096b4f64d4

View File

@ -14,25 +14,32 @@ export async function createSession(user_id, {
refresh_token,
expires_at,
}) {
const [existing_session] = await db.select().from(sessions).where(eq(sessions.user_id, user_id));
try {
if(existing_session) {
return {
session_id: existing_session.id
const [existing_session] = await db.select().from(sessions).where(eq(sessions.user_id, user_id));
if (existing_session) {
return {
session_id: existing_session.id
}
}
const token = await db.insert(sessions).values({
user_id,
access_token: access_token,
refresh_token: refresh_token,
expires_at
}).returning({ id: sessions.id });
if (token.length == 0) {
throw new Error("Error creating auth token");
}
return {
session_id: token[0].id
}
} catch (e) {
console.log(e);
throw e;
}
const token = await db.insert(sessions).values({
user_id,
access_token: access_token,
refresh_token: refresh_token,
expires_at
}).returning({ id: sessions.id });
if(token.length == 0) {
throw new Error("Error creating auth token");
}
return {
session_id: token[0].id
}
}