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 { sequelizeTypescript } from '../../../initializers'
6 import { sendUndoFollow } from '../../../lib/activitypub/send'
12 removeFollowingValidator,
16 } from '../../../middlewares'
17 import { followersSortValidator, followingSortValidator, followValidator } from '../../../middlewares/validators'
18 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
19 import { JobQueue } from '../../../lib/job-queue'
21 const serverFollowsRouter = express.Router()
22 serverFollowsRouter.get('/following',
24 followingSortValidator,
27 asyncMiddleware(listFollowing)
30 serverFollowsRouter.post('/following',
32 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
35 asyncMiddleware(followInstance)
38 serverFollowsRouter.delete('/following/:host',
40 ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
41 asyncMiddleware(removeFollowingValidator),
42 asyncMiddleware(removeFollow)
45 serverFollowsRouter.get('/followers',
47 followersSortValidator,
50 asyncMiddleware(listFollowers)
53 // ---------------------------------------------------------------------------
59 // ---------------------------------------------------------------------------
61 async function listFollowing (req: express.Request, res: express.Response, next: express.NextFunction) {
62 const serverActor = await getServerActor()
63 const resultList = await ActorFollowModel.listFollowingForApi(serverActor.id, req.query.start, req.query.count, req.query.sort)
65 return res.json(getFormattedObjects(resultList.data, resultList.total))
68 async function listFollowers (req: express.Request, res: express.Response, next: express.NextFunction) {
69 const serverActor = await getServerActor()
70 const resultList = await ActorFollowModel.listFollowersForApi(serverActor.id, req.query.start, req.query.count, req.query.sort)
72 return res.json(getFormattedObjects(resultList.data, resultList.total))
75 async function followInstance (req: express.Request, res: express.Response, next: express.NextFunction) {
76 const hosts = req.body.hosts as string[]
78 for (const host of hosts) {
79 JobQueue.Instance.createJob({ type: 'activitypub-follow', payload: { host } })
80 .catch(err => logger.error('Cannot create follow job for %s.', host, err))
83 return res.status(204).end()
86 async function removeFollow (req: express.Request, res: express.Response, next: express.NextFunction) {
87 const follow: ActorFollowModel = res.locals.follow
89 await sequelizeTypescript.transaction(async t => {
90 if (follow.state === 'accepted') await sendUndoFollow(follow, t)
92 await follow.destroy({ transaction: t })
95 // Destroy the actor that will destroy video channels, videos and video files too
96 // This could be long so don't wait this task
97 const following = follow.ActorFollowing
99 .catch(err => logger.error('Cannot destroy actor that we do not follow anymore %s.', following.url, { err }))
101 return res.status(204).end()