1 import * as express from 'express'
2 import { UserRight } from '../../../../shared/models/users'
3 import { logger } from '../../../helpers/logger'
4 import { getFormattedObjects, getServerActor } from '../../../helpers/utils'
5 import { sequelizeTypescript, SERVER_ACTOR_NAME } from '../../../initializers'
6 import { sendAccept, sendReject, sendUndoFollow } from '../../../lib/activitypub/send'
15 } from '../../../middlewares'
17 acceptOrRejectFollowerValidator,
18 followersSortValidator,
19 followingSortValidator,
22 removeFollowingValidator
23 } from '../../../middlewares/validators'
24 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
25 import { JobQueue } from '../../../lib/job-queue'
26 import { removeRedundancyOf } from '../../../lib/redundancy'
28 const serverFollowsRouter = express.Router()
29 serverFollowsRouter.get('/following',
31 followingSortValidator,
34 asyncMiddleware(listFollowing)
37 serverFollowsRouter.post('/following',
39 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
42 asyncMiddleware(followInstance)
45 serverFollowsRouter.delete('/following/:host',
47 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
48 asyncMiddleware(removeFollowingValidator),
49 asyncMiddleware(removeFollowing)
52 serverFollowsRouter.get('/followers',
54 followersSortValidator,
57 asyncMiddleware(listFollowers)
60 serverFollowsRouter.delete('/followers/:nameWithHost',
62 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
63 asyncMiddleware(getFollowerValidator),
64 asyncMiddleware(removeOrRejectFollower)
67 serverFollowsRouter.post('/followers/:nameWithHost/reject',
69 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
70 asyncMiddleware(getFollowerValidator),
71 acceptOrRejectFollowerValidator,
72 asyncMiddleware(removeOrRejectFollower)
75 serverFollowsRouter.post('/followers/:nameWithHost/accept',
77 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
78 asyncMiddleware(getFollowerValidator),
79 acceptOrRejectFollowerValidator,
80 asyncMiddleware(acceptFollower)
83 // ---------------------------------------------------------------------------
89 // ---------------------------------------------------------------------------
91 async function listFollowing (req: express.Request, res: express.Response) {
92 const serverActor = await getServerActor()
93 const resultList = await ActorFollowModel.listFollowingForApi(
101 return res.json(getFormattedObjects(resultList.data, resultList.total))
104 async function listFollowers (req: express.Request, res: express.Response) {
105 const serverActor = await getServerActor()
106 const resultList = await ActorFollowModel.listFollowersForApi(
114 return res.json(getFormattedObjects(resultList.data, resultList.total))
117 async function followInstance (req: express.Request, res: express.Response) {
118 const hosts = req.body.hosts as string[]
119 const follower = await getServerActor()
121 for (const host of hosts) {
124 name: SERVER_ACTOR_NAME,
125 followerActorId: follower.id
128 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
129 .catch(err => logger.error('Cannot create follow job for %s.', host, err))
132 return res.status(204).end()
135 async function removeFollowing (req: express.Request, res: express.Response) {
136 const follow = res.locals.follow
138 await sequelizeTypescript.transaction(async t => {
139 if (follow.state === 'accepted') await sendUndoFollow(follow, t)
141 // Disable redundancy on unfollowed instances
142 const server = follow.ActorFollowing.Server
143 server.redundancyAllowed = false
144 await server.save({ transaction: t })
146 // Async, could be long
147 removeRedundancyOf(server.id)
148 .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
150 await follow.destroy({ transaction: t })
153 return res.status(204).end()
156 async function removeOrRejectFollower (req: express.Request, res: express.Response) {
157 const follow = res.locals.follow
159 await sendReject(follow.ActorFollower, follow.ActorFollowing)
161 await follow.destroy()
163 return res.status(204).end()
166 async function acceptFollower (req: express.Request, res: express.Response) {
167 const follow = res.locals.follow
169 await sendAccept(follow)
171 follow.state = 'accepted'
174 return res.status(204).end()