summaryrefslogtreecommitdiff
path: root/app/src/lib/server/db.ts
diff options
context:
space:
mode:
authorLinnnus <[email protected]>2025-02-22 16:05:11 +0100
committerLinnnus <[email protected]>2025-02-22 16:05:11 +0100
commitaa3accb6b394b2b4164061e6e962228ab8285ca6 (patch)
tree008cbf6b966415f184855a9a7efda6a3fcb3e9b7 /app/src/lib/server/db.ts
parent4baf5083f99df02ca33eca6a6a9bbc62bf795251 (diff)
Move hooks into their own modules
Diffstat (limited to 'app/src/lib/server/db.ts')
-rw-r--r--app/src/lib/server/db.ts14
1 files changed, 11 insertions, 3 deletions
diff --git a/app/src/lib/server/db.ts b/app/src/lib/server/db.ts
index db001b7..b35f853 100644
--- a/app/src/lib/server/db.ts
+++ b/app/src/lib/server/db.ts
@@ -1,5 +1,6 @@
import pg from "pg";
import { env } from "$env/dynamic/private";
+import type { Handle } from "@sveltejs/kit";
const pool = new pg.Pool({
database: env.POSTGRES_DB || "postgres",
@@ -15,6 +16,13 @@ pool.on("error", (err, client) => {
console.error("Database error: ", err, client);
});
-export function getDbClient(): Promise<pg.PoolClient> {
- return pool.connect();
-}
+export const dbHandle = (async ({ event, resolve }) => {
+ const dbClient = await pool.connect();
+ event.locals.dbClient = dbClient;
+
+ try {
+ return await resolve(event);
+ } finally {
+ dbClient.release();
+ }
+}) satisfies Handle;