1 import * as express from 'express'
2 import { UserRight } from '../../../../shared/models/users'
3 import { logger } from '../../../helpers/logger'
4 import { getFormattedObjects } 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 { removeRedundanciesOfServer } from '../../../lib/redundancy'
28 import { sequelizeTypescript } from '../../../initializers/database'
29 import { autoFollowBackIfNeeded } from '../../../lib/activitypub/follow'
30 import { getServerActor } from '@server/models/application/application'
32 const serverFollowsRouter = express.Router()
33 serverFollowsRouter.get('/following',
36 followingSortValidator,
39 asyncMiddleware(listFollowing)
42 serverFollowsRouter.post('/following',
44 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
47 asyncMiddleware(followInstance)
50 serverFollowsRouter.delete('/following/:host',
52 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
53 asyncMiddleware(removeFollowingValidator),
54 asyncMiddleware(removeFollowing)
57 serverFollowsRouter.get('/followers',
60 followersSortValidator,
63 asyncMiddleware(listFollowers)
66 serverFollowsRouter.delete('/followers/:nameWithHost',
68 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
69 asyncMiddleware(getFollowerValidator),
70 asyncMiddleware(removeOrRejectFollower)
73 serverFollowsRouter.post('/followers/:nameWithHost/reject',
75 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
76 asyncMiddleware(getFollowerValidator),
77 acceptOrRejectFollowerValidator,
78 asyncMiddleware(removeOrRejectFollower)
81 serverFollowsRouter.post('/followers/:nameWithHost/accept',
83 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
84 asyncMiddleware(getFollowerValidator),
85 acceptOrRejectFollowerValidator,
86 asyncMiddleware(acceptFollower)
89 // ---------------------------------------------------------------------------
95 // ---------------------------------------------------------------------------
97 async function listFollowing (req: express.Request, res: express.Response) {
98 const serverActor = await getServerActor()
99 const resultList = await ActorFollowModel.listFollowingForApi({
101 start: req.query.start,
102 count: req.query.count,
103 sort: req.query.sort,
104 search: req.query.search,
105 actorType: req.query.actorType,
106 state: req.query.state
109 return res.json(getFormattedObjects(resultList.data, resultList.total))
112 async function listFollowers (req: express.Request, res: express.Response) {
113 const serverActor = await getServerActor()
114 const resultList = await ActorFollowModel.listFollowersForApi({
115 actorId: serverActor.id,
116 start: req.query.start,
117 count: req.query.count,
118 sort: req.query.sort,
119 search: req.query.search,
120 actorType: req.query.actorType,
121 state: req.query.state
124 return res.json(getFormattedObjects(resultList.data, resultList.total))
127 async function followInstance (req: express.Request, res: express.Response) {
128 const hosts = req.body.hosts as string[]
129 const follower = await getServerActor()
131 for (const host of hosts) {
134 name: SERVER_ACTOR_NAME,
135 followerActorId: follower.id
138 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
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 removeRedundanciesOfServer(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.url, 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()