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 { SERVER_ACTOR_NAME } from '../../../initializers/constants'
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'
27 import { sequelizeTypescript } from '../../../initializers/database'
28 import { autoFollowBackIfNeeded } from '../../../lib/activitypub/follow'
30 const serverFollowsRouter = express.Router()
31 serverFollowsRouter.get('/following',
33 followingSortValidator,
36 asyncMiddleware(listFollowing)
39 serverFollowsRouter.post('/following',
41 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
44 asyncMiddleware(followInstance)
47 serverFollowsRouter.delete('/following/:host',
49 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
50 asyncMiddleware(removeFollowingValidator),
51 asyncMiddleware(removeFollowing)
54 serverFollowsRouter.get('/followers',
56 followersSortValidator,
59 asyncMiddleware(listFollowers)
62 serverFollowsRouter.delete('/followers/:nameWithHost',
64 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
65 asyncMiddleware(getFollowerValidator),
66 asyncMiddleware(removeOrRejectFollower)
69 serverFollowsRouter.post('/followers/:nameWithHost/reject',
71 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
72 asyncMiddleware(getFollowerValidator),
73 acceptOrRejectFollowerValidator,
74 asyncMiddleware(removeOrRejectFollower)
77 serverFollowsRouter.post('/followers/:nameWithHost/accept',
79 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
80 asyncMiddleware(getFollowerValidator),
81 acceptOrRejectFollowerValidator,
82 asyncMiddleware(acceptFollower)
85 // ---------------------------------------------------------------------------
91 // ---------------------------------------------------------------------------
93 async function listFollowing (req: express.Request, res: express.Response) {
94 const serverActor = await getServerActor()
95 const resultList = await ActorFollowModel.listFollowingForApi(
103 return res.json(getFormattedObjects(resultList.data, resultList.total))
106 async function listFollowers (req: express.Request, res: express.Response) {
107 const serverActor = await getServerActor()
108 const resultList = await ActorFollowModel.listFollowersForApi(
116 return res.json(getFormattedObjects(resultList.data, resultList.total))
119 async function followInstance (req: express.Request, res: express.Response) {
120 const hosts = req.body.hosts as string[]
121 const follower = await getServerActor()
123 for (const host of hosts) {
126 name: SERVER_ACTOR_NAME,
127 followerActorId: follower.id
130 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
131 .catch(err => logger.error('Cannot create follow job for %s.', host, err))
134 return res.status(204).end()
137 async function removeFollowing (req: express.Request, res: express.Response) {
138 const follow = res.locals.follow
140 await sequelizeTypescript.transaction(async t => {
141 if (follow.state === 'accepted') await sendUndoFollow(follow, t)
143 // Disable redundancy on unfollowed instances
144 const server = follow.ActorFollowing.Server
145 server.redundancyAllowed = false
146 await server.save({ transaction: t })
148 // Async, could be long
149 removeRedundancyOf(server.id)
150 .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
152 await follow.destroy({ transaction: t })
155 return res.status(204).end()
158 async function removeOrRejectFollower (req: express.Request, res: express.Response) {
159 const follow = res.locals.follow
161 await sendReject(follow.ActorFollower, follow.ActorFollowing)
163 await follow.destroy()
165 return res.status(204).end()
168 async function acceptFollower (req: express.Request, res: express.Response) {
169 const follow = res.locals.follow
171 await sendAccept(follow)
173 follow.state = 'accepted'
176 await autoFollowBackIfNeeded(follow)
178 return res.status(204).end()