summary refs log tree commit diff
path: root/src/activitypub/routes/guilds/#guild_id/followers.ts
blob: 7f3b9e319431b06b09c85241c2148954faf905b9 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
import { makeOrderedCollection } from "@spacebar/ap";
import { route } from "@spacebar/api";
import {
	Channel,
	Config,
	Datasource,
	FederationKey,
	Member,
} from "@spacebar/util";
import { Request, Response, Router } from "express";
const router = Router();

router.get("/", route({}), async (req: Request, res: Response) => {
	const { guild_id } = req.params;
	const { page, min_id, max_id } = req.query;

	const { host } = Config.get().federation;

	const ret = await makeOrderedCollection({
		page: page != undefined,
		min_id: min_id?.toString(),
		max_id: max_id?.toString(),
		id: `https://${host}/federation/guilds/${guild_id}/following`,
		getTotalElements: () => Channel.count({ where: { guild_id } }),
		getElements: async (before, after): Promise<string[]> => {
			const members = await Datasource.getRepository(FederationKey)
				.createQueryBuilder("key")
				.leftJoin(Member, "member", "member.id == key.actorId")
				.where("member.guild_id = :guild_id", { guild_id })
				.getMany();

			// TODO: actual pagination

			return members.map((x) => x.federatedId);
		},
	});

	return res.json(ret);
});

export default router;