fix(logs): better error logging

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

@@ -8,6 +8,7 @@ import {
 	type MessageUpdate,
 } from "$lib/types/MessageUpdate";
 import type { Message } from "$lib/types/Message";
+import { logger } from "$lib/server/logger";
 
 // -----------
 
@@ -34,7 +35,7 @@ function convertMessageUpdate(message: Message, update: MessageUpdate): MessageU
 
 		return update;
 	} catch (error) {
-		console.error("Error converting message update during migration. Skipping it... Error:", error);
+		logger.error(error, "Error converting message update during migration. Skipping it..");
 		return null;
 	}
 }

src/lib/server/textGeneration/title.ts

@@ -21,7 +21,7 @@ export async function* generateTitleForConversation(
 			title,
 		};
 	} catch (cause) {
-		console.error(Error("Failed whilte generating title for conversation", { cause }));
+		logger.error(Error("Failed whilte generating title for conversation", { cause }));
 	}
 }
 

src/lib/server/websearch/runWebSearch.ts

@@ -18,6 +18,7 @@ import {
 } from "./update";
 import { mergeAsyncGenerators } from "$lib/utils/mergeAsyncGenerators";
 import { MetricsServer } from "../metrics";
+import { logger } from "$lib/server/logger";
 
 const MAX_N_PAGES_TO_SCRAPE = 8 as const;
 const MAX_N_PAGES_TO_EMBED = 5 as const;
@@ -86,7 +87,7 @@ export async function* runWebSearch(
 		return webSearch;
 	} catch (searchError) {
 		const message = searchError instanceof Error ? searchError.message : String(searchError);
-		console.error(message);
+		logger.error(message);
 		yield makeErrorUpdate({ message: "An error occurred", args: [message] });
 
 		const webSearch: WebSearch = {

src/lib/server/websearch/scrape/playwright.ts

@@ -71,7 +71,7 @@ export async function withPage<T>(
 		env.PLAYWRIGHT_ADBLOCKER === "true" && (await blocker.enableBlockingInPage(page));
 
 		const res = await page.goto(url, { waitUntil: "load", timeout: 3500 }).catch(() => {
-			console.warn(`Failed to load page within 2s: ${url}`);
+			logger.warn(`Failed to load page within 2s: ${url}`);
 		});
 
 		// await needed here so that we don't close the context before the callback is done

src/routes/conversation/[id]/+server.ts

@@ -23,6 +23,7 @@ import { usageLimits } from "$lib/server/usageLimits";
 import { MetricsServer } from "$lib/server/metrics";
 import { textGeneration } from "$lib/server/textGeneration";
 import type { TextGenerationContext } from "$lib/server/textGeneration/types";
+import { logger } from "$lib/server/logger.js";
 
 export async function POST({ request, locals, params, getClientAddress }) {
 	const id = z.string().parse(params.id);
@@ -444,7 +445,7 @@ export async function POST({ request, locals, params, getClientAddress }) {
 					status: MessageUpdateStatus.Error,
 					message: (e as Error).message,
 				});
-				console.error(e);
+				logger.error(e);
 			} finally {
 				// check if no output was generated
 				if (!hasError && messageToWriteTo.content === initialMessageContent) {