server/controllers/api/server/follows.ts

   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, SERVER_ACTOR_NAME } from '../../../initializers'
   6 import { sendReject, sendUndoFollow } from '../../../lib/activitypub/send'
   7 import {
   8   asyncMiddleware,
   9   authenticate,
  10   ensureUserHasRight,
  11   paginationValidator,
  12   setBodyHostsPort,
  13   setDefaultPagination,
  14   setDefaultSort
  15 } from '../../../middlewares'
  16 import {
  17   followersSortValidator,
  18   followingSortValidator,
  19   followValidator,
  20   removeFollowerValidator,
  21   removeFollowingValidator
  22 } from '../../../middlewares/validators'
  23 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
  24 import { JobQueue } from '../../../lib/job-queue'
  25 import { removeRedundancyOf } from '../../../lib/redundancy'
  26
  27 const serverFollowsRouter = express.Router()
  28 serverFollowsRouter.get('/following',
  29   paginationValidator,
  30   followingSortValidator,
  31   setDefaultSort,
  32   setDefaultPagination,
  33   asyncMiddleware(listFollowing)
  34 )
  35
  36 serverFollowsRouter.post('/following',
  37   authenticate,
  38   ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
  39   followValidator,
  40   setBodyHostsPort,
  41   asyncMiddleware(followInstance)
  42 )
  43
  44 serverFollowsRouter.delete('/following/:host',
  45   authenticate,
  46   ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
  47   asyncMiddleware(removeFollowingValidator),
  48   asyncMiddleware(removeFollowing)
  49 )
  50
  51 serverFollowsRouter.get('/followers',
  52   paginationValidator,
  53   followersSortValidator,
  54   setDefaultSort,
  55   setDefaultPagination,
  56   asyncMiddleware(listFollowers)
  57 )
  58
  59 serverFollowsRouter.delete('/followers/:nameWithHost',
  60   authenticate,
  61   ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
  62   asyncMiddleware(removeFollowerValidator),
  63   asyncMiddleware(removeFollower)
  64 )
  65
  66 // ---------------------------------------------------------------------------
  67
  68 export {
  69   serverFollowsRouter
  70 }
  71
  72 // ---------------------------------------------------------------------------
  73
  74 async function listFollowing (req: express.Request, res: express.Response) {
  75   const serverActor = await getServerActor()
  76   const resultList = await ActorFollowModel.listFollowingForApi(
  77     serverActor.id,
  78     req.query.start,
  79     req.query.count,
  80     req.query.sort,
  81     req.query.search
  82   )
  83
  84   return res.json(getFormattedObjects(resultList.data, resultList.total))
  85 }
  86
  87 async function listFollowers (req: express.Request, res: express.Response) {
  88   const serverActor = await getServerActor()
  89   const resultList = await ActorFollowModel.listFollowersForApi(
  90     serverActor.id,
  91     req.query.start,
  92     req.query.count,
  93     req.query.sort,
  94     req.query.search
  95   )
  96
  97   return res.json(getFormattedObjects(resultList.data, resultList.total))
  98 }
  99
 100 async function followInstance (req: express.Request, res: express.Response) {
 101   const hosts = req.body.hosts as string[]
 102   const follower = await getServerActor()
 103
 104   for (const host of hosts) {
 105     const payload = {
 106       host,
 107       name: SERVER_ACTOR_NAME,
 108       followerActorId: follower.id
 109     }
 110
 111     JobQueue.Instance.createJob({ type: 'activitypub-follow', payload })
 112       .catch(err => logger.error('Cannot create follow job for %s.', host, err))
 113   }
 114
 115   return res.status(204).end()
 116 }
 117
 118 async function removeFollowing (req: express.Request, res: express.Response) {
 119   const follow = res.locals.follow
 120
 121   await sequelizeTypescript.transaction(async t => {
 122     if (follow.state === 'accepted') await sendUndoFollow(follow, t)
 123
 124     // Disable redundancy on unfollowed instances
 125     const server = follow.ActorFollowing.Server
 126     server.redundancyAllowed = false
 127     await server.save({ transaction: t })
 128
 129     // Async, could be long
 130     removeRedundancyOf(server.id)
 131       .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, err))
 132
 133     await follow.destroy({ transaction: t })
 134   })
 135
 136   return res.status(204).end()
 137 }
 138
 139 async function removeFollower (req: express.Request, res: express.Response) {
 140   const follow = res.locals.follow
 141
 142   await sendReject(follow.ActorFollower, follow.ActorFollowing)
 143
 144   await follow.destroy()
 145
 146   return res.status(204).end()
 147 }