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,
24 } from '../../../middlewares/validators'
25 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
26 import { JobQueue } from '../../../lib/job-queue'
27 import { removeRedundancyOf } from '../../../lib/redundancy'
28 import { sequelizeTypescript } from '../../../initializers/database'
29 import { autoFollowBackIfNeeded } from '../../../lib/activitypub/follow'
31 const serverFollowsRouter = express.Router()
32 serverFollowsRouter.get('/following',
35 followingSortValidator,
38 asyncMiddleware(listFollowing)
41 serverFollowsRouter.post('/following',
43 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
46 asyncMiddleware(followInstance)
49 serverFollowsRouter.delete('/following/:host',
51 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
52 asyncMiddleware(removeFollowingValidator),
53 asyncMiddleware(removeFollowing)
56 serverFollowsRouter.get('/followers',
59 followersSortValidator,
62 asyncMiddleware(listFollowers)
65 serverFollowsRouter.delete('/followers/:nameWithHost',
67 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
68 asyncMiddleware(getFollowerValidator),
69 asyncMiddleware(removeOrRejectFollower)
72 serverFollowsRouter.post('/followers/:nameWithHost/reject',
74 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
75 asyncMiddleware(getFollowerValidator),
76 acceptOrRejectFollowerValidator,
77 asyncMiddleware(removeOrRejectFollower)
80 serverFollowsRouter.post('/followers/:nameWithHost/accept',
82 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
83 asyncMiddleware(getFollowerValidator),
84 acceptOrRejectFollowerValidator,
85 asyncMiddleware(acceptFollower)
88 // ---------------------------------------------------------------------------
94 // ---------------------------------------------------------------------------
96 async function listFollowing (req: express.Request, res: express.Response) {
97 const serverActor = await getServerActor()
98 const resultList = await ActorFollowModel.listFollowingForApi({
100 start: req.query.start,
101 count: req.query.count,
102 sort: req.query.sort,
103 search: req.query.search,
104 state: req.query.state
107 return res.json(getFormattedObjects(resultList.data, resultList.total))
110 async function listFollowers (req: express.Request, res: express.Response) {
111 const serverActor = await getServerActor()
112 const resultList = await ActorFollowModel.listFollowersForApi({
113 actorId: serverActor.id,
114 start: req.query.start,
115 count: req.query.count,
116 sort: req.query.sort,
117 search: req.query.search,
118 state: req.query.state
121 return res.json(getFormattedObjects(resultList.data, resultList.total))
124 async function followInstance (req: express.Request, res: express.Response) {
125 const hosts = req.body.hosts as string[]
126 const follower = await getServerActor()
128 for (const host of hosts) {
131 name: SERVER_ACTOR_NAME,
132 followerActorId: follower.id
135 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
136 .catch(err => logger.error('Cannot create follow job for %s.', host, err))
139 return res.status(204).end()
142 async function removeFollowing (req: express.Request, res: express.Response) {
143 const follow = res.locals.follow
145 await sequelizeTypescript.transaction(async t => {
146 if (follow.state === 'accepted') await sendUndoFollow(follow, t)
148 // Disable redundancy on unfollowed instances
149 const server = follow.ActorFollowing.Server
150 server.redundancyAllowed = false
151 await server.save({ transaction: t })
153 // Async, could be long
154 removeRedundancyOf(server.id)
155 .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
157 await follow.destroy({ transaction: t })
160 return res.status(204).end()
163 async function removeOrRejectFollower (req: express.Request, res: express.Response) {
164 const follow = res.locals.follow
166 await sendReject(follow.ActorFollower, follow.ActorFollowing)
168 await follow.destroy()
170 return res.status(204).end()
173 async function acceptFollower (req: express.Request, res: express.Response) {
174 const follow = res.locals.follow
176 await sendAccept(follow)
178 follow.state = 'accepted'
181 await autoFollowBackIfNeeded(follow)
183 return res.status(204).end()