feat: implement delete message functionality using API client

Author: nsarrazin

src/lib/components/chat/Alternatives.svelte

@@ -5,11 +5,11 @@
 	import CarbonChevronRight from "~icons/carbon/chevron-right";
 
 	import { createEventDispatcher } from "svelte";
-	import { base } from "$app/paths";
 	import { page } from "$app/state";
 	import { error } from "$lib/stores/errors";
 	import { invalidate } from "$app/navigation";
 	import { UrlDependency } from "$lib/types/UrlDependency";
+	import { handleResponse, useAPIClient } from "$lib/APIClient";
 
 	interface Props {
 		message: Message;
@@ -24,6 +24,8 @@
 	const dispatch = createEventDispatcher<{
 		showAlternateMsg: { id: Message["id"] };
 	}>();
+
+	const client = useAPIClient();
 </script>
 
 <div
@@ -54,15 +56,18 @@
 			class="hidden group-hover/navbranch:block"
 			onclick={() => {
 				if (confirm("Are you sure you want to delete this branch?")) {
-					fetch(`${base}/api/conversation/${page.params.id}/message/${message.id}`, {
-						method: "DELETE",
-					}).then(async (r) => {
-						if (r.ok) {
+					client
+						.conversations({ id: page.params.id })
+						.message({ messageId: message.id })
+						.delete()
+						.then(handleResponse)
+						.then(async () => {
 							await invalidate(UrlDependency.Conversation);
-						} else {
-							$error = (await r.json()).message;
-						}
-					});
+						})
+						.catch((err) => {
+							console.error(err);
+							$error = String(err);
+						});
 				}
 			}}
 		>

src/lib/server/api/routes/groups/conversations.ts

@@ -456,6 +456,49 @@ export const conversationGroup = new Elysia().use(authPlugin).group("/conversati
 								model: t.Optional(t.String()),
 							}),
 						}
+					)
+					.delete(
+						"/message/:messageId",
+						async ({ locals, params, conversation }) => {
+							if (!conversation.messages.map((m) => m.id).includes(params.messageId)) {
+								throw new Error("Message not found");
+							}
+
+							const filteredMessages = conversation.messages
+								.filter(
+									(message) =>
+										// not the message AND the message is not in ancestors
+										!(message.id === params.messageId) &&
+										message.ancestors &&
+										!message.ancestors.includes(params.messageId)
+								)
+								.map((message) => {
+									// remove the message from children if it's there
+									if (message.children && message.children.includes(params.messageId)) {
+										message.children = message.children.filter(
+											(child) => child !== params.messageId
+										);
+									}
+									return message;
+								});
+
+							const res = await collections.conversations.updateOne(
+								{ _id: new ObjectId(conversation._id), ...authCondition(locals) },
+								{ $set: { messages: filteredMessages } }
+							);
+
+							if (res.modifiedCount === 0) {
+								throw new Error("Deleting message failed");
+							}
+
+							return { success: true };
+						},
+						{
+							params: t.Object({
+								id: t.String(),
+								messageId: t.String(),
+							}),
+						}
 					);
 			}
 		);