Function upsertMessage

packages/core/src/message-node.ts:33–118

(
	data: BaseMessageWithRelations,
	opts?: {
		ignoreChecks?: boolean;
	},
)

} from './message';

export async function upsertMessage(
	data: BaseMessageWithRelations,
	opts?: {
		ignoreChecks?: boolean;
	},
) {
	if (!opts?.ignoreChecks) {
		const [ignoredAccount, userServerSettings] = await Promise.all([
			findIgnoredDiscordAccountById(data.authorId),
			findUserServerSettingsById({
				userId: data.authorId,
				serverId: data.serverId,
			}),
		]);
		if (ignoredAccount) {
			throw new DBError(
				CANNOT_UPSERT_MESSAGE_FOR_IGNORED_ACCOUNT_MESSAGE,
				'IGNORED_ACCOUNT',
			);
		}
		if (userServerSettings?.flags.messageIndexingDisabled) {
			throw new DBError(
				CANNOT_UPSERT_MESSAGE_FOR_USER_WITH_MESSAGE_INDEXING_DISABLED_MESSAGE,
				'MESSAGE_INDEXING_DISABLED',
			);
		}
	}
	const { attachments, reactions, embeds, ...msg } = data;
	const parsed = {
		...messageSchema.parse(msg),
		embeds,
	};

	await db.insert(dbMessages).values(parsed).onDuplicateKeyUpdate({
		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({