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'
29 const serverFollowsRouter = express.Router()
30 serverFollowsRouter.get('/following',
32 followingSortValidator,
35 asyncMiddleware(listFollowing)
38 serverFollowsRouter.post('/following',
40 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
43 asyncMiddleware(followInstance)
46 serverFollowsRouter.delete('/following/:host',
48 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
49 asyncMiddleware(removeFollowingValidator),
50 asyncMiddleware(removeFollowing)
53 serverFollowsRouter.get('/followers',
55 followersSortValidator,
58 asyncMiddleware(listFollowers)
61 serverFollowsRouter.delete('/followers/:nameWithHost',
63 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
64 asyncMiddleware(getFollowerValidator),
65 asyncMiddleware(removeOrRejectFollower)
68 serverFollowsRouter.post('/followers/:nameWithHost/reject',
70 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
71 asyncMiddleware(getFollowerValidator),
72 acceptOrRejectFollowerValidator,
73 asyncMiddleware(removeOrRejectFollower)
76 serverFollowsRouter.post('/followers/:nameWithHost/accept',
78 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
79 asyncMiddleware(getFollowerValidator),
80 acceptOrRejectFollowerValidator,
81 asyncMiddleware(acceptFollower)
84 // ---------------------------------------------------------------------------
90 // ---------------------------------------------------------------------------
92 async function listFollowing (req: express.Request, res: express.Response) {
93 const serverActor = await getServerActor()
94 const resultList = await ActorFollowModel.listFollowingForApi(
102 return res.json(getFormattedObjects(resultList.data, resultList.total))
105 async function listFollowers (req: express.Request, res: express.Response) {
106 const serverActor = await getServerActor()
107 const resultList = await ActorFollowModel.listFollowersForApi(
115 return res.json(getFormattedObjects(resultList.data, resultList.total))
118 async function followInstance (req: express.Request, res: express.Response) {
119 const hosts = req.body.hosts as string[]
120 const follower = await getServerActor()
122 for (const host of hosts) {
125 name: SERVER_ACTOR_NAME,
126 followerActorId: follower.id
129 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
130 .catch(err => logger.error('Cannot create follow job for %s.', host, err))
133 return res.status(204).end()
136 async function removeFollowing (req: express.Request, res: express.Response) {
137 const follow = res.locals.follow
139 await sequelizeTypescript.transaction(async t => {
140 if (follow.state === 'accepted') await sendUndoFollow(follow, t)
142 // Disable redundancy on unfollowed instances
143 const server = follow.ActorFollowing.Server
144 server.redundancyAllowed = false
145 await server.save({ transaction: t })
147 // Async, could be long
148 removeRedundancyOf(server.id)
149 .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
151 await follow.destroy({ transaction: t })
154 return res.status(204).end()
157 async function removeOrRejectFollower (req: express.Request, res: express.Response) {
158 const follow = res.locals.follow
160 await sendReject(follow.ActorFollower, follow.ActorFollowing)
162 await follow.destroy()
164 return res.status(204).end()
167 async function acceptFollower (req: express.Request, res: express.Response) {
168 const follow = res.locals.follow
170 await sendAccept(follow)
172 follow.state = 'accepted'
175 return res.status(204).end()