comty/packages/server/services/posts/classes/posts/methods/update.js

import { Post } from "@db_models"
import { DateTime } from "luxon"
import stage from "./stage"

export default async (post_id, update) => {
	let post = await Post.findById(post_id)

	if (!post) {
		throw new OperationError(404, "Post not found")
	}

	const updateKeys = Object.keys(update)

	updateKeys.forEach((key) => {
		post[key] = update[key]
	})

	post.updated_at = DateTime.local().toISO()

	if (Array.isArray(update.poll_options)) {
		post.poll_options = update.poll_options.map((option) => {
			if (!option.id) {
				option.id = nanoid()
			}

			return option
		})
	}

	await post.save()

	post = post.toObject()

	const result = await stage({
		posts: post,
		for_user_id: post.user_id,
	})

	if (post.visibility === "public") {
		global.websockets.senders.toTopic(
			"realtime:feed",
			`post:update`,
			result[0],
		)
	}

	if (post.visibility === "private") {
		const userSockets = await global.websockets.find.clientsByUserId(
			post.user_id,
		)

		for (const userSocket of userSockets) {
			userSocket.emit(`post:update`, result[0])
		}
	}

	return result[0]
}