From e0f5c70f85456297ff9b235c6aeab9746a054f6c Mon Sep 17 00:00:00 2001
From: Linnnus <linnnus@users.noreply.github.com>
Date: Tue, 18 Feb 2025 18:02:23 +0100
Subject: Use abstract client interface for DB interactions

---
 app/src/lib/server/sessions.ts | 8 ++++----
 app/src/lib/server/users.ts    | 2 +-
 2 files changed, 5 insertions(+), 5 deletions(-)

(limited to 'app/src/lib/server')

diff --git a/app/src/lib/server/sessions.ts b/app/src/lib/server/sessions.ts
index 1b829ff..0ca46e0 100644
--- a/app/src/lib/server/sessions.ts
+++ b/app/src/lib/server/sessions.ts
@@ -51,7 +51,7 @@ function encodeBase32LowerCaseNoPadding(input: Uint8Array): string {
 const VALID_MILLISECONDS = 1000 * 60 * 60 * 24 * 30;
 
 /** Creates a new session for the user with the given `userId`. */
-export async function createSession(dbConn: pg.PoolClient, userId: number): Promise<Session> {
+export async function createSession(dbConn: pg.ClientBase, userId: number): Promise<Session> {
 	const token = generateSessionToken();
 	const session: Session = {
 		token: token,
@@ -78,7 +78,7 @@ export async function createSession(dbConn: pg.PoolClient, userId: number): Prom
  * @returns A session + user pair if the session is valid, or `null` for both otherwise.
  */
 export async function validateSessionToken(
-	dbConn: pg.PoolClient,
+	dbConn: pg.ClientBase,
 	token: string,
 ): Promise<SessionValidationResult> {
 	// Step 1
@@ -129,13 +129,13 @@ export async function validateSessionToken(
 
 /** Invalidates the session with token `sessionToken`. */
 export async function invalidateSession(
-	dbConn: pg.PoolClient,
+	dbConn: pg.ClientBase,
 	sessionToken: string,
 ): Promise<void> {
 	await dbConn.query("DELETE sessions WHERE token = ?;", [sessionToken]);
 }
 
 /** Invalidates all sessions for the user with the id `userId`. */
-export async function invalidateAllSessions(dbConn: pg.PoolClient, userId: number): Promise<void> {
+export async function invalidateAllSessions(dbConn: pg.ClientBase, userId: number): Promise<void> {
 	await dbConn.query("DELETE sessions WHERE user_id = ?", [userId]);
 }
diff --git a/app/src/lib/server/users.ts b/app/src/lib/server/users.ts
index c233fda..a2e734f 100644
--- a/app/src/lib/server/users.ts
+++ b/app/src/lib/server/users.ts
@@ -17,7 +17,7 @@ export interface User {
  * @returns The user, or `undefined` on authentication failure.
  */
 export async function getUser(
-	dbConn: pg.PoolClient,
+	dbConn: pg.ClientBase,
 	email: string,
 	password: string,
 ): Promise<User | undefined> {
-- 
cgit v1.2.3