diff --git a/src/routes/auth.js b/src/routes/auth.js index 83f0589..3d3932c 100644 --- a/src/routes/auth.js +++ b/src/routes/auth.js @@ -67,7 +67,7 @@ export const authRoutes = (fastify, _, done) => { access_token: token.access_token, refresh_token: token.refresh_token, expires_at: new Date(token.expires_at) - }, tx); + }); session_id = session_info.session_id; } diff --git a/src/utils/token.js b/src/utils/token.js index f88609e..851f201 100644 --- a/src/utils/token.js +++ b/src/utils/token.js @@ -13,8 +13,8 @@ export async function createSession(user_id, { access_token, refresh_token, expires_at, -}, tx = db) { - const [existing_session] = await tx.select().from(sessions).where(eq(sessions.user_id, user_id)); +}) { + const [existing_session] = await db.select().from(sessions).where(eq(sessions.user_id, user_id)); if(existing_session) { return { @@ -22,7 +22,7 @@ export async function createSession(user_id, { } } - const token = await tx.insert(sessions).values({ + const token = await db.insert(sessions).values({ user_id, access_token: access_token, refresh_token: refresh_token,