1 import express from 'express'
2 import { getServerActor } from '@server/models/application/application'
3 import { HttpStatusCode } from '../../../../shared/models/http/http-error-codes'
4 import { UserRight } from '../../../../shared/models/users'
5 import { logger } from '../../../helpers/logger'
6 import { getFormattedObjects } from '../../../helpers/utils'
7 import { SERVER_ACTOR_NAME } from '../../../initializers/constants'
8 import { sequelizeTypescript } from '../../../initializers/database'
9 import { autoFollowBackIfNeeded } from '../../../lib/activitypub/follow'
10 import { sendAccept, sendReject, sendUndoFollow } from '../../../lib/activitypub/send'
11 import { JobQueue } from '../../../lib/job-queue'
12 import { removeRedundanciesOfServer } from '../../../lib/redundancy'
21 } from '../../../middlewares'
23 acceptOrRejectFollowerValidator,
24 instanceFollowersSortValidator,
25 instanceFollowingSortValidator,
29 removeFollowingValidator
30 } from '../../../middlewares/validators'
31 import { ActorFollowModel } from '../../../models/actor/actor-follow'
32 import { ServerFollowCreate } from '@shared/models'
34 const serverFollowsRouter = express.Router()
35 serverFollowsRouter.get('/following',
38 instanceFollowingSortValidator,
41 asyncMiddleware(listFollowing)
44 serverFollowsRouter.post('/following',
46 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
49 asyncMiddleware(addFollow)
52 serverFollowsRouter.delete('/following/:hostOrHandle',
54 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
55 asyncMiddleware(removeFollowingValidator),
56 asyncMiddleware(removeFollowing)
59 serverFollowsRouter.get('/followers',
62 instanceFollowersSortValidator,
65 asyncMiddleware(listFollowers)
68 serverFollowsRouter.delete('/followers/:nameWithHost',
70 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
71 asyncMiddleware(getFollowerValidator),
72 asyncMiddleware(removeOrRejectFollower)
75 serverFollowsRouter.post('/followers/:nameWithHost/reject',
77 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
78 asyncMiddleware(getFollowerValidator),
79 acceptOrRejectFollowerValidator,
80 asyncMiddleware(removeOrRejectFollower)
83 serverFollowsRouter.post('/followers/:nameWithHost/accept',
85 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
86 asyncMiddleware(getFollowerValidator),
87 acceptOrRejectFollowerValidator,
88 asyncMiddleware(acceptFollower)
91 // ---------------------------------------------------------------------------
97 // ---------------------------------------------------------------------------
99 async function listFollowing (req: express.Request, res: express.Response) {
100 const serverActor = await getServerActor()
101 const resultList = await ActorFollowModel.listInstanceFollowingForApi({
102 followerId: serverActor.id,
103 start: req.query.start,
104 count: req.query.count,
105 sort: req.query.sort,
106 search: req.query.search,
107 actorType: req.query.actorType,
108 state: req.query.state
111 return res.json(getFormattedObjects(resultList.data, resultList.total))
114 async function listFollowers (req: express.Request, res: express.Response) {
115 const serverActor = await getServerActor()
116 const resultList = await ActorFollowModel.listFollowersForApi({
117 actorIds: [ serverActor.id ],
118 start: req.query.start,
119 count: req.query.count,
120 sort: req.query.sort,
121 search: req.query.search,
122 actorType: req.query.actorType,
123 state: req.query.state
126 return res.json(getFormattedObjects(resultList.data, resultList.total))
129 async function addFollow (req: express.Request, res: express.Response) {
130 const { hosts, handles } = req.body as ServerFollowCreate
131 const follower = await getServerActor()
133 for (const host of hosts) {
136 name: SERVER_ACTOR_NAME,
137 followerActorId: follower.id
140 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
143 for (const handle of handles) {
144 const [ name, host ] = handle.split('@')
149 followerActorId: follower.id
152 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
155 return res.status(HttpStatusCode.NO_CONTENT_204).end()
158 async function removeFollowing (req: express.Request, res: express.Response) {
159 const follow = res.locals.follow
161 await sequelizeTypescript.transaction(async t => {
162 if (follow.state === 'accepted') sendUndoFollow(follow, t)
164 // Disable redundancy on unfollowed instances
165 const server = follow.ActorFollowing.Server
166 server.redundancyAllowed = false
167 await server.save({ transaction: t })
169 // Async, could be long
170 removeRedundanciesOfServer(server.id)
171 .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
173 await follow.destroy({ transaction: t })
176 return res.status(HttpStatusCode.NO_CONTENT_204).end()
179 async function removeOrRejectFollower (req: express.Request, res: express.Response) {
180 const follow = res.locals.follow
182 await sendReject(follow.url, follow.ActorFollower, follow.ActorFollowing)
184 await follow.destroy()
186 return res.status(HttpStatusCode.NO_CONTENT_204).end()
189 async function acceptFollower (req: express.Request, res: express.Response) {
190 const follow = res.locals.follow
194 follow.state = 'accepted'
197 await autoFollowBackIfNeeded(follow)
199 return res.status(HttpStatusCode.NO_CONTENT_204).end()