Function upsertManyMessages

packages/core/src/message-node.ts:120–167

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

}

export async function upsertManyMessages(
	data: BaseMessageWithRelations[],
	opts?: {
		ignoreChecks?: boolean;
	},
) {
	if (data.length === 0) return Promise.resolve([]);
	const authorIds = new Set(data.map((msg) => msg.authorId));

	// Todo: make one query for all of these
	if (!opts?.ignoreChecks) {
		const [ignoredAccounts, userServerSettings] = await Promise.all([
			findManyIgnoredDiscordAccountsById(Array.from(authorIds)),
			findManyUserServerSettings(
				data.map((msg) => ({
					userId: msg.authorId,
					serverId: msg.serverId,
				})),
			),
		]);
		const userServerSettingsLookup = new Map(
			userServerSettings.map((uss) => [`${uss.userId}-${uss.serverId}`, uss]),
		);

		const ignoredAccountIds = new Set(ignoredAccounts.map((i) => i.id));
		data = data.filter((msg) => {
			if (ignoredAccountIds.has(msg.authorId)) {
				return false;
			}
			if (
				userServerSettingsLookup.get(`${msg.authorId}-${msg.serverId}`)?.flags
					.messageIndexingDisabled
			) {
				return false;
			}
			return true;
		});
	}
	const chunkSize = 100;
	const chunks = [];
	for (let i = 0; i < data.length; i += chunkSize) {
		chunks.push(data.slice(i, i + chunkSize));
	}
	for await (const chunk of chunks) {
		await fastUpsertManyMessages(chunk);
	}
	return data;
}

export async function fastUpsertManyMessages(data: BaseMessageWithRelations[]) {
	const attachments = new Set<typeof dbAttachments.$inferInsert>();