Function findServerWithCommunityPageData

packages/core/src/pages.ts:118–222

(opts: {
	idOrVanityUrl: string;
	limit?: number;
	selectedChannel: string | undefined;
	page: number;
})

}

export async function findServerWithCommunityPageData(opts: {
	idOrVanityUrl: string;
	limit?: number;
	selectedChannel: string | undefined;
	page: number;
}) {
	const { idOrVanityUrl, limit = NUMBER_OF_THREADS_TO_LOAD } = opts;
	let serverId = idOrVanityUrl;
	try {
		BigInt(idOrVanityUrl);
	} catch (e) {
		const found = await db.query.dbServers.findFirst({
			where: eq(dbServers.vanityUrl, idOrVanityUrl),
		});
		if (!found) return null;
		serverId = found.id;
	}

	const offset = (opts.page > 0 ? opts.page - 1 : opts.page) * limit;
	// eslint-disable-next-line prefer-const
	let [found, questions] = await Promise.all([
		db.query.dbServers.findFirst({
			where: eq(dbServers.id, serverId),
			with: {
				channels: {
					where: and(
						or(
							eq(dbChannels.type, ChannelType.GuildAnnouncement),
							eq(dbChannels.type, ChannelType.GuildText),
							eq(dbChannels.type, ChannelType.GuildForum),
						),
						sql`${dbChannels.bitfield} & ${channelBitfieldValues.indexingEnabled} > 0`,
					),
				},
			},
		}),
		opts.selectedChannel
			? db.query.dbChannels.findMany({
					where: eq(dbChannels.parentId, opts.selectedChannel),
					orderBy: desc(dbChannels.id),
					offset,
					limit: limit * 10, // Allow buffer room if some threads are private
				})
			: [],
	]);
	if (!found || found.kickedTime != null) return null;
	const channels = found.channels
		.map((c) => zChannelPublic.parse(c))
		.sort((a, b) => {
			if (
				a.type === ChannelType.GuildForum.valueOf() &&
				b.type !== ChannelType.GuildForum.valueOf()
			)
				return -1;
			if (
				a.type !== ChannelType.GuildForum.valueOf() &&
				b.type === ChannelType.GuildForum.valueOf()
			)