Function searchMessages

packages/core/src/search.ts:414–455

(opts: MessageSearchOptions)

};
export namespace Search {
	export async function searchMessages(opts: MessageSearchOptions) {
		const results = await elastic.searchMessages(opts);
		const messagesWithAuthors = await findManyMessagesWithAuthors(
			results.map((r) => r.id!),
		);
		// TODO: Include w/ query above
		const [servers, channels] = await Promise.all([
			findManyServersById(messagesWithAuthors.map((m) => m.serverId)),
			findManyChannelsById(
				messagesWithAuthors.flatMap((m) =>
					m.parentChannelId ? [m.channelId, m.parentChannelId] : [m.channelId],
				),
			),
		]);
		const serverLookup = new Map(servers.map((s) => [s.id, s]));
		const channelLookup = new Map(channels.map((c) => [c.id, c]));
		const resultsLookup = new Map(results.map((r) => [r.id, r]));

		return messagesWithAuthors
			.map((m): SearchResult | null => {
				const channel = channelLookup.get(m.parentChannelId ?? m.channelId);
				const server = serverLookup.get(m.serverId);
				const thread = m.parentChannelId
					? channelLookup.get(m.channelId)
					: undefined;
				if (!channel || !server) {
					return null;
				}
				if (!channel.flags.indexingEnabled) {
					return null;
				}
				return {
					message: m,
					channel,
					score: resultsLookup.get(m.id)!.score ?? 0,
					server: server,
					thread,
				};
			})
			.filter((res) => res != null && res.server.kickedTime === null)
			.sort((a, b) => b!.score - a!.score) as SearchResult[];
	}

	export function indexMessageForSearch(messages: BaseMessageWithRelations[]) {
		return elastic.bulkUpsertMessages(