Function findManyChannelsById

packages/core/src/channel.ts:178–218

(
	ids: string[],
	opts: {
		includeMessageCount?: boolean;
	} = {},
)

}

export async function findManyChannelsById(
	ids: string[],
	opts: {
		includeMessageCount?: boolean;
	} = {},
): Promise<ChannelWithFlags[]> {
	if (ids.length === 0) return Promise.resolve([]);
	const data = await dbReplica.query.dbChannels.findMany({
		where: inArray(dbChannels.id, ids),
	});
	const withFlags = data.map(addFlagsToChannel);
	let threadMessageCountLookup: Map<string, number | undefined> | undefined =
		undefined;
	const isThreadType = (t: ChannelType) =>
		t === ChannelType.PublicThread ||
		t === ChannelType.PrivateThread ||
		t === ChannelType.AnnouncementThread;
	if (opts.includeMessageCount) {
		const threadIds = withFlags
			.filter((c) => isThreadType(c.type))
			.map((c) => c.id);
		const threadMessageCounts = await findManyChannelMessagesCounts(threadIds);
		threadMessageCountLookup = new Map(
			threadMessageCounts.map((x) => [x.channelId, x.count]),
		);
	}
	return withFlags.map((c) => {
		let messageCount: number | undefined = undefined;
		if (opts.includeMessageCount) {
			if (isThreadType(c.type)) {
				messageCount = threadMessageCountLookup?.get(c.id);
			} else {
				messageCount = NUMBER_OF_CHANNEL_MESSAGES_TO_LOAD;
			}
		}
		return {
			...c,
			messageCount,
		};
	});
}

export async function createChannel(data: z.infer<typeof zChannelCreate>) {
	const combinedData = applyChannelSettingsChangesSideEffects({