feat(db): centralize Mongo access via db service; refactor runtime to use it

- Add src/lib/server/db.ts with helpers for conversations, shared, messageEvents, settings, users, sessions, tokenCache, config, reports, assistants, files, abortedGenerations
- Refactor runtime routes/libs to use db service instead of direct collections access
- Keep migrations/tests on collections for now
- No user-facing behavior changes; structural refactor only

Author: gary149

src/hooks.server.ts

@@ -1,6 +1,6 @@
 import { config, ready } from "$lib/server/config";
 import type { Handle, HandleServerError, ServerInit, HandleFetch } from "@sveltejs/kit";
-import { collections } from "$lib/server/database";
+import { db } from "$lib/server/db";
 import { base } from "$app/paths";
 import { authenticateRequest, refreshSessionCookie, requiresUser } from "$lib/server/auth";
 import { ERROR_MESSAGES } from "$lib/stores/errors";
@@ -168,10 +168,10 @@ export const handle: Handle = async ({ event, resolve }) => {
 		// if the request is a POST request or login-related we refresh the cookie
 		refreshSessionCookie(event.cookies, auth.secretSessionId);
 
-		await collections.sessions.updateOne(
-			{ sessionId: auth.sessionId },
-			{ $set: { updatedAt: new Date(), expiresAt: addWeeks(new Date(), 2) } }
-		);
+		await db.sessions.updateBySessionId(auth.sessionId, {
+			updatedAt: new Date(),
+			expiresAt: addWeeks(new Date(), 2),
+		});
 	}
 
 	if (
@@ -196,10 +196,7 @@ export const handle: Handle = async ({ event, resolve }) => {
 			!event.url.pathname.startsWith(`${base}/settings`) &&
 			config.PUBLIC_APP_DISCLAIMER === "1"
 		) {
-			const hasAcceptedEthicsModal = await collections.settings.countDocuments({
-				sessionId: event.locals.sessionId,
-				ethicsModalAcceptedAt: { $exists: true },
-			});
+			const hasAcceptedEthicsModal = await db.settings.hasAcceptedEthicsModal(event.locals.sessionId);
 
 			if (!hasAcceptedEthicsModal) {
 				return errorResponse(405, "You need to accept the welcome modal first");

src/lib/jobs/refresh-conversation-stats.ts

@@ -1,12 +1,12 @@
 import type { ConversationStats } from "$lib/types/ConversationStats";
-import { CONVERSATION_STATS_COLLECTION, collections } from "$lib/server/database";
+import { CONVERSATION_STATS_COLLECTION, db } from "$lib/server/db";
 import { logger } from "$lib/server/logger";
 import type { ObjectId } from "mongodb";
 import { acquireLock, refreshLock } from "$lib/migrations/lock";
 import { Semaphores } from "$lib/types/Semaphore";
 
 async function getLastComputationTime(): Promise<Date> {
-	const lastStats = await collections.conversationStats.findOne({}, { sort: { "date.at": -1 } });
+	const lastStats = await (await db.raw()).conversationStats.findOne({}, { sort: { "date.at": -1 } });
 	return lastStats?.date?.at || new Date(0);
 }
 
@@ -33,7 +33,7 @@ async function computeStats(params: {
 	span: ConversationStats["date"]["span"];
 	type: ConversationStats["type"];
 }) {
-	const lastComputed = await collections.conversationStats.findOne(
+	const lastComputed = await (await db.raw()).conversationStats.findOne(
 		{ "date.field": params.dateField, "date.span": params.span, type: params.type },
 		{ sort: { "date.at": -1 } }
 	);
@@ -227,7 +227,7 @@ async function computeStats(params: {
 		},
 	];
 
-	await collections.conversations.aggregate(pipeline, { allowDiskUse: true }).next();
+	await (await db.raw()).conversations.aggregate(pipeline, { allowDiskUse: true }).next();
 
 	logger.debug(
 		{ minDate, dateField: params.dateField, span: params.span, type: params.type },

src/lib/migrations/lock.ts

@@ -1,4 +1,4 @@
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 import { ObjectId } from "mongodb";
 import type { Semaphores } from "$lib/types/Semaphore";
 

src/lib/migrations/routines/01-update-search-assistants.ts

@@ -1,5 +1,5 @@
 import type { Migration } from ".";
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 import { ObjectId, type AnyBulkWriteOperation } from "mongodb";
 import type { Assistant } from "$lib/types/Assistant";
 import { generateSearchTokens } from "$lib/utils/searchTokens";

src/lib/migrations/routines/02-update-assistants-models.ts

@@ -1,5 +1,5 @@
 import type { Migration } from ".";
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 import { ObjectId } from "mongodb";
 
 const updateAssistantsModels: Migration = {

src/lib/migrations/routines/04-update-message-updates.ts

@@ -1,5 +1,5 @@
 import type { Migration } from ".";
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 import { ObjectId, type WithId } from "mongodb";
 import type { Conversation } from "$lib/types/Conversation";
 // Simple type to replace removed WebSearchSource for migration compatibility

src/lib/migrations/routines/05-update-message-files.ts

@@ -1,5 +1,5 @@
 import { ObjectId, type WithId } from "mongodb";
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 
 import type { Migration } from ".";
 import type { Conversation } from "$lib/types/Conversation";

src/lib/migrations/routines/06-trim-message-updates.ts

@@ -1,5 +1,5 @@
 import type { Migration } from ".";
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 import { ObjectId, type WithId } from "mongodb";
 import type { Conversation } from "$lib/types/Conversation";
 import { MessageUpdateType, type MessageUpdate } from "$lib/types/MessageUpdate";

src/lib/migrations/routines/08-update-featured-to-review.ts

@@ -1,5 +1,5 @@
 import type { Migration } from ".";
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 import { ObjectId } from "mongodb";
 import { ReviewStatus } from "$lib/types/Review";
 

src/lib/migrations/routines/10-update-reports-assistantid.ts

@@ -1,4 +1,4 @@
-import { collections } from "$lib/server/database";
+import { asCollections as collections } from "$lib/server/db";
 import type { Migration } from ".";
 import { ObjectId } from "mongodb";