1 import * as express from 'express'
2 import { getServerActor } from '@server/models/application/application'
3 import { HttpStatusCode } from '../../../../shared/core-utils/miscs/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 followersSortValidator,
25 followingSortValidator,
29 removeFollowingValidator
30 } from '../../../middlewares/validators'
31 import { ActorFollowModel } from '../../../models/actor/actor-follow'
33 const serverFollowsRouter = express.Router()
34 serverFollowsRouter.get('/following',
37 followingSortValidator,
40 asyncMiddleware(listFollowing)
43 serverFollowsRouter.post('/following',
45 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
48 asyncMiddleware(followInstance)
51 serverFollowsRouter.delete('/following/:host',
53 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
54 asyncMiddleware(removeFollowingValidator),
55 asyncMiddleware(removeFollowing)
58 serverFollowsRouter.get('/followers',
61 followersSortValidator,
64 asyncMiddleware(listFollowers)
67 serverFollowsRouter.delete('/followers/:nameWithHost',
69 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
70 asyncMiddleware(getFollowerValidator),
71 asyncMiddleware(removeOrRejectFollower)
74 serverFollowsRouter.post('/followers/:nameWithHost/reject',
76 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
77 asyncMiddleware(getFollowerValidator),
78 acceptOrRejectFollowerValidator,
79 asyncMiddleware(removeOrRejectFollower)
82 serverFollowsRouter.post('/followers/:nameWithHost/accept',
84 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
85 asyncMiddleware(getFollowerValidator),
86 acceptOrRejectFollowerValidator,
87 asyncMiddleware(acceptFollower)
90 // ---------------------------------------------------------------------------
96 // ---------------------------------------------------------------------------
98 async function listFollowing (req: express.Request, res: express.Response) {
99 const serverActor = await getServerActor()
100 const resultList = await ActorFollowModel.listFollowingForApi({
102 start: req.query.start,
103 count: req.query.count,
104 sort: req.query.sort,
105 search: req.query.search,
106 actorType: req.query.actorType,
107 state: req.query.state
110 return res.json(getFormattedObjects(resultList.data, resultList.total))
113 async function listFollowers (req: express.Request, res: express.Response) {
114 const serverActor = await getServerActor()
115 const resultList = await ActorFollowModel.listFollowersForApi({
116 actorId: serverActor.id,
117 start: req.query.start,
118 count: req.query.count,
119 sort: req.query.sort,
120 search: req.query.search,
121 actorType: req.query.actorType,
122 state: req.query.state
125 return res.json(getFormattedObjects(resultList.data, resultList.total))
128 async function followInstance (req: express.Request, res: express.Response) {
129 const hosts = req.body.hosts as string[]
130 const follower = await getServerActor()
132 for (const host of hosts) {
135 name: SERVER_ACTOR_NAME,
136 followerActorId: follower.id
139 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
142 return res.status(HttpStatusCode.NO_CONTENT_204).end()
145 async function removeFollowing (req: express.Request, res: express.Response) {
146 const follow = res.locals.follow
148 await sequelizeTypescript.transaction(async t => {
149 if (follow.state === 'accepted') await sendUndoFollow(follow, t)
151 // Disable redundancy on unfollowed instances
152 const server = follow.ActorFollowing.Server
153 server.redundancyAllowed = false
154 await server.save({ transaction: t })
156 // Async, could be long
157 removeRedundanciesOfServer(server.id)
158 .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
160 await follow.destroy({ transaction: t })
163 return res.status(HttpStatusCode.NO_CONTENT_204).end()
166 async function removeOrRejectFollower (req: express.Request, res: express.Response) {
167 const follow = res.locals.follow
169 await sendReject(follow.url, follow.ActorFollower, follow.ActorFollowing)
171 await follow.destroy()
173 return res.status(HttpStatusCode.NO_CONTENT_204).end()
176 async function acceptFollower (req: express.Request, res: express.Response) {
177 const follow = res.locals.follow
179 await sendAccept(follow)
181 follow.state = 'accepted'
184 await autoFollowBackIfNeeded(follow)
186 return res.status(HttpStatusCode.NO_CONTENT_204).end()