egirlskey/packages/backend/src/server/api/endpoints/federation/stats.ts

66 lines
1.5 KiB
TypeScript
Raw Normal View History

2022-06-28 04:05:20 +00:00
import { IsNull, MoreThan, Not } from 'typeorm';
import { Followings, Instances } from '@/models/index.js';
import { awaitAll } from '@/prelude/await-all.js';
import define from '../../define.js';
export const meta = {
tags: ['federation'],
requireCredential: false,
allowGet: true,
cacheSec: 60 * 60,
} as const;
export const paramDef = {
type: 'object',
properties: {
2022-06-30 11:15:14 +00:00
limit: { type: 'integer', minimum: 1, maximum: 100, default: 10 },
},
required: [],
} as const;
// eslint-disable-next-line import/no-default-export
export default define(meta, paramDef, async (ps) => {
2022-06-28 04:05:20 +00:00
const [topSubInstances, topPubInstances, allSubCount, allPubCount] = await Promise.all([
Instances.find({
where: {
followersCount: MoreThan(0),
},
order: {
followersCount: 'DESC',
},
2022-06-30 11:15:14 +00:00
take: ps.limit,
}),
Instances.find({
where: {
followingCount: MoreThan(0),
},
order: {
followingCount: 'DESC',
},
2022-06-30 11:15:14 +00:00
take: ps.limit,
}),
2022-06-28 04:05:20 +00:00
Followings.count({
where: {
followeeHost: Not(IsNull()),
},
}),
Followings.count({
where: {
followerHost: Not(IsNull()),
},
}),
]);
2022-06-28 04:05:20 +00:00
const gotSubCount = topSubInstances.map(x => x.followersCount).reduce((a, b) => a + b, 0);
2022-07-03 10:01:08 +00:00
const gotPubCount = topPubInstances.map(x => x.followingCount).reduce((a, b) => a + b, 0);
2022-06-28 04:05:20 +00:00
return await awaitAll({
topSubInstances: Instances.packMany(topSubInstances),
2022-06-28 04:05:20 +00:00
otherFollowersCount: Math.max(0, allSubCount - gotSubCount),
topPubInstances: Instances.packMany(topPubInstances),
2022-06-28 04:05:20 +00:00
otherFollowingCount: Math.max(0, allPubCount - gotPubCount),
});
});