fix(markdown): make sure messages are serializable

src/lib/components/chat/MarkdownRenderer.svelte

@@ -28,7 +28,9 @@
 					}
 					resolve(event.data.tokens);
 				};
-				worker.postMessage({ content, sources, type: "process" } as IncomingMessage);
+				worker.postMessage(
+					JSON.parse(JSON.stringify({ content, sources, type: "process" })) as IncomingMessage
+				);
 			});
 		} else {
 			return processTokens(content, sources);

src/lib/utils/marked.ts

@@ -156,13 +156,9 @@ function createMarkedInstance(sources: WebSearchSource[]): Marked {
 			html: (html) => escapeHTML(html),
 		},
 		gfm: true,
+		breaks: true,
 	});
 }
-
-export function getMarked(sources: WebSearchSource[]): Marked {
-	return createMarkedInstance(sources);
-}
-
 type CodeToken = {
 	type: "code";
 	lang: string;
@@ -175,7 +171,7 @@ type TextToken = {
 };
 
 export async function processTokens(content: string, sources: WebSearchSource[]): Promise<Token[]> {
-	const marked = getMarked(sources);
+	const marked = createMarkedInstance(sources);
 	const tokens = marked.lexer(content);
 
 	const processedTokens = await Promise.all(
@@ -199,7 +195,7 @@ export async function processTokens(content: string, sources: WebSearchSource[])
 }
 
 export function processTokensSync(content: string, sources: WebSearchSource[]): Token[] {
-	const marked = getMarked(sources);
+	const marked = createMarkedInstance(sources);
 	const tokens = marked.lexer(content);
 	return tokens.map((token) => {
 		if (token.type === "code") {

src/lib/workers/markdownWorker.ts

@@ -29,7 +29,7 @@ async function processMessage() {
 		try {
 			const { content, sources } = nextMessage;
 			const processedTokens = await processTokens(content, sources);
-			postMessage({ type: "processed", tokens: processedTokens } satisfies OutgoingMessage);
+			postMessage(JSON.parse(JSON.stringify({ type: "processed", tokens: processedTokens })));
 		} finally {
 			isProcessing = false;