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 actorType: req.query.actorType,
105 state: req.query.state
108 return res.json(getFormattedObjects(resultList.data, resultList.total))
111 async function listFollowers (req: express.Request, res: express.Response) {
112 const serverActor = await getServerActor()
113 const resultList = await ActorFollowModel.listFollowersForApi({
114 actorId: serverActor.id,
115 start: req.query.start,
116 count: req.query.count,
117 sort: req.query.sort,
118 search: req.query.search,
119 actorType: req.query.actorType,
120 state: req.query.state
123 return res.json(getFormattedObjects(resultList.data, resultList.total))
126 async function followInstance (req: express.Request, res: express.Response) {
127 const hosts = req.body.hosts as string[]
128 const follower = await getServerActor()
130 for (const host of hosts) {
133 name: SERVER_ACTOR_NAME,
134 followerActorId: follower.id
137 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
138 .catch(err => logger.error('Cannot create follow job for %s.', host, err))
141 return res.status(204).end()
144 async function removeFollowing (req: express.Request, res: express.Response) {
145 const follow = res.locals.follow
147 await sequelizeTypescript.transaction(async t => {
148 if (follow.state === 'accepted') await sendUndoFollow(follow, t)
150 // Disable redundancy on unfollowed instances
151 const server = follow.ActorFollowing.Server
152 server.redundancyAllowed = false
153 await server.save({ transaction: t })
155 // Async, could be long
156 removeRedundancyOf(server.id)
157 .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
159 await follow.destroy({ transaction: t })
162 return res.status(204).end()
165 async function removeOrRejectFollower (req: express.Request, res: express.Response) {
166 const follow = res.locals.follow
168 await sendReject(follow.ActorFollower, follow.ActorFollowing)
170 await follow.destroy()
172 return res.status(204).end()
175 async function acceptFollower (req: express.Request, res: express.Response) {
176 const follow = res.locals.follow
178 await sendAccept(follow)
180 follow.state = 'accepted'
183 await autoFollowBackIfNeeded(follow)
185 return res.status(204).end()