Add watermarking service, fix everything

1 files changed, 8 insertions, 5 deletions

diff --git a/app/src/hooks.server.ts b/app/src/hooks.server.ts
index f342e03..78342cd 100644
--- a/app/src/hooks.server.ts
+++ b/app/src/hooks.server.ts
@@ -1,21 +1,23 @@
-import { getDbConnection } from "$lib/server/db";
+import { getDbClient } from "$lib/server/db";
 import { getS3Client } from "$lib/server/s3";
 import { validateSessionToken } from "$lib/server/sessions";
 import { type Handle } from "@sveltejs/kit";
 import { sequence } from "@sveltejs/kit/hooks";
+import { beanstalkdHandle } from "$lib/server/beanstalkd";
 
 const dbHandle = (async ({ event, resolve }) => {
-	const dbConn = await getDbConnection();
-	event.locals.dbConn = dbConn;
+	const dbClient = await getDbClient();
+	event.locals.dbClient = dbClient;
 
 	try {
 		return await resolve(event);
 	} finally {
-		dbConn.release();
+		dbClient.release();
 	}
 }) satisfies Handle;
 
 // FIXME: Kind of stupid to load for every request. Should probs move handler to $lib and import for relevant routes.
+// Same goes for beanstalkd.
 const s3Handle = (async ({ event, resolve }) => {
 	const s3Client = getS3Client();
 	event.locals.s3Client = s3Client;
@@ -39,4 +41,5 @@ const sessionHandle = (async ({ event, resolve }) => {
 	return resolve(event);
 }) satisfies Handle;
 
-export const handle = sequence(dbHandle, s3Handle, sessionHandle);
+// FIXME: Kind of stupid to load for every request. Should probs move handler to $lib and import for relevant routes.
+export const handle = sequence(dbHandle, s3Handle, beanstalkdHandle, sessionHandle);