Function updateAttachments

packages/core/src/message-node.ts:69–98

()

		set: parsed,
	});
	const updateAttachments = async () => {
		const existingAttachments = await db
			.select()
			.from(dbAttachments)
			.where(eq(dbAttachments.messageId, msg.id));
		const existingAttachmentIds = new Set(existingAttachments.map((a) => a.id));

		if (!attachments) {
			await db.delete(dbAttachments).where(eq(dbAttachments.messageId, msg.id));
			return;
		}
		for await (const attachment of attachments) {
			if (!existingAttachmentIds.has(attachment.id)) {
				void uploadFileFromUrl({
					url: attachment.url,
					id: attachment.id,
					contentType: attachment.contentType ?? undefined,
					filename: attachment.filename,
				}).then(async (uploaded) => {
					if (!uploaded) return;
					await db.insert(dbAttachments).values(
						attachmentSchema.parse({
							...attachment,
							proxyUrl: `https://cdn.answeroverflow.com/${attachment.id}/${attachment.filename}`,
						}),
					);
				});
			}
		}
	};
	const updateReactions = async () => {
		await db.delete(dbReactions).where(eq(dbReactions.messageId, msg.id));
		if (!reactions) return;