✨ Can chat in shared convo (#55)

package-lock.json

@@ -18,7 +18,8 @@
 				"nanoid": "^4.0.2",
 				"postcss": "^8.4.21",
 				"tailwind-scrollbar": "^3.0.0",
-				"tailwindcss": "^3.3.1"
+				"tailwindcss": "^3.3.1",
+				"zod": "^3.21.4"
 			},
 			"devDependencies": {
 				"@iconify-json/carbon": "^1.1.16",
@@ -4138,6 +4139,14 @@
 			"funding": {
 				"url": "https://github.com/sponsors/sindresorhus"
 			}
+		},
+		"node_modules/zod": {
+			"version": "3.21.4",
+			"resolved": "https://registry.npmjs.org/zod/-/zod-3.21.4.tgz",
+			"integrity": "sha512-m46AKbrzKVzOzs/DZgVnG5H55N1sv1M8qZU3A8RIKbs3mrACDNeIOeilDymVb2HdmP8uwshOCF4uJ8uM9rCqJw==",
+			"funding": {
+				"url": "https://github.com/sponsors/colinhacks"
+			}
 		}
 	}
 }

package.json

@@ -43,6 +43,7 @@
 		"nanoid": "^4.0.2",
 		"postcss": "^8.4.21",
 		"tailwind-scrollbar": "^3.0.0",
-		"tailwindcss": "^3.3.1"
+		"tailwindcss": "^3.3.1",
+		"zod": "^3.21.4"
 	}
 }

src/lib/types/Conversation.ts

@@ -12,4 +12,8 @@ export interface Conversation {
 
 	createdAt: Date;
 	updatedAt: Date;
+
+	meta?: {
+		fromShareId?: string;
+	};
 }

src/routes/conversation/+server.ts

@@ -1,19 +1,47 @@
 import type { RequestHandler } from "./$types";
 import { collections } from "$lib/server/database";
 import { ObjectId } from "mongodb";
-import { redirect } from "@sveltejs/kit";
+import { error, redirect } from "@sveltejs/kit";
 import { base } from "$app/paths";
+import { z } from "zod";
+import type { Message } from "$lib/types/Message";
 
 export const POST: RequestHandler = async (input) => {
+	const body = await input.request.text();
+
+	let title = "";
+	let messages: Message[] = [];
+	let fromShareId: string | undefined;
+
+	if (body) {
+		fromShareId = z.object({ fromShare: z.string().optional() }).parse(JSON.parse(body)).fromShare;
+
+		if (fromShareId) {
+			const conversation = await collections.sharedConversations.findOne({
+				_id: fromShareId,
+			});
+
+			if (!conversation) {
+				throw error(404, "Conversation not found");
+			}
+
+			title = conversation.title;
+			messages = conversation.messages;
+		}
+	}
+
 	const res = await collections.conversations.insertOne({
 		_id: new ObjectId(),
 		title:
+			title ||
 			"Untitled " +
-			((await collections.conversations.countDocuments({ sessionId: input.locals.sessionId })) + 1),
-		messages: [],
+				((await collections.conversations.countDocuments({ sessionId: input.locals.sessionId })) +
+					1),
+		messages,
 		createdAt: new Date(),
 		updatedAt: new Date(),
 		sessionId: input.locals.sessionId,
+		...(fromShareId ? { meta: { fromShareId } } : {}),
 	});
 
 	return new Response(

src/routes/conversation/[id]/+page.svelte

@@ -81,9 +81,7 @@
 			const val = $pendingMessage;
 			$pendingMessage = "";
 
-			if (messages.length === 0) {
-				writeMessage(val);
-			}
+			writeMessage(val);
 		}
 	});
 </script>

src/routes/r/[id]/+page.svelte

@@ -1,8 +1,44 @@
 <script lang="ts">
+	import { goto } from "$app/navigation";
+	import { base } from "$app/paths";
+	import { page } from "$app/stores";
 	import ChatWindow from "$lib/components/chat/ChatWindow.svelte";
+	import { pendingMessage } from "$lib/stores/pendingMessage";
 	import type { PageData } from "./$types";
 
 	export let data: PageData;
+
+	let loading = false;
+
+	async function createConversation(message: string) {
+		try {
+			loading = true;
+			const res = await fetch(`${base}/conversation`, {
+				method: "POST",
+				headers: {
+					"Content-Type": "application/json",
+				},
+				body: JSON.stringify({
+					fromShare: $page.params.id,
+				}),
+			});
+
+			if (!res.ok) {
+				alert("Error while creating conversation: " + (await res.text()));
+				return;
+			}
+
+			const { conversationId } = await res.json();
+
+			// Ugly hack to use a store as temp storage, feel free to improve ^^
+			pendingMessage.set(message);
+
+			// invalidateAll to update list of conversations
+			await goto(`${base}/conversation/${conversationId}`, { invalidateAll: true });
+		} finally {
+			loading = false;
+		}
+	}
 </script>
 
-<ChatWindow disabled={true} messages={data.messages} />
+<ChatWindow on:message={(ev) => createConversation(ev.detail)} messages={data.messages} {loading} />