server/controllers/api/server/redundancy.ts

   1 import * as express from 'express'
   2 import { UserRight } from '../../../../shared/models/users'
   3 import {
   4   asyncMiddleware,
   5   authenticate,
   6   ensureUserHasRight,
   7   paginationValidator,
   8   setDefaultPagination,
   9   setDefaultVideoRedundanciesSort,
  10   videoRedundanciesSortValidator
  11 } from '../../../middlewares'
  12 import {
  13   listVideoRedundanciesValidator,
  14   updateServerRedundancyValidator,
  15   addVideoRedundancyValidator,
  16   removeVideoRedundancyValidator
  17 } from '../../../middlewares/validators/redundancy'
  18 import { removeRedundanciesOfServer, removeVideoRedundancy } from '../../../lib/redundancy'
  19 import { logger } from '../../../helpers/logger'
  20 import { VideoRedundancyModel } from '@server/models/redundancy/video-redundancy'
  21 import { JobQueue } from '@server/lib/job-queue'
  22 import { HttpStatusCode } from '../../../../shared/core-utils/miscs/http-error-codes'
  23
  24 const serverRedundancyRouter = express.Router()
  25
  26 serverRedundancyRouter.put('/redundancy/:host',
  27   authenticate,
  28   ensureUserHasRight(UserRight.MANAGE_SERVER_FOLLOW),
  29   asyncMiddleware(updateServerRedundancyValidator),
  30   asyncMiddleware(updateRedundancy)
  31 )
  32
  33 serverRedundancyRouter.get('/redundancy/videos',
  34   authenticate,
  35   ensureUserHasRight(UserRight.MANAGE_VIDEOS_REDUNDANCIES),
  36   listVideoRedundanciesValidator,
  37   paginationValidator,
  38   videoRedundanciesSortValidator,
  39   setDefaultVideoRedundanciesSort,
  40   setDefaultPagination,
  41   asyncMiddleware(listVideoRedundancies)
  42 )
  43
  44 serverRedundancyRouter.post('/redundancy/videos',
  45   authenticate,
  46   ensureUserHasRight(UserRight.MANAGE_VIDEOS_REDUNDANCIES),
  47   addVideoRedundancyValidator,
  48   asyncMiddleware(addVideoRedundancy)
  49 )
  50
  51 serverRedundancyRouter.delete('/redundancy/videos/:redundancyId',
  52   authenticate,
  53   ensureUserHasRight(UserRight.MANAGE_VIDEOS_REDUNDANCIES),
  54   removeVideoRedundancyValidator,
  55   asyncMiddleware(removeVideoRedundancyController)
  56 )
  57
  58 // ---------------------------------------------------------------------------
  59
  60 export {
  61   serverRedundancyRouter
  62 }
  63
  64 // ---------------------------------------------------------------------------
  65
  66 async function listVideoRedundancies (req: express.Request, res: express.Response) {
  67   const resultList = await VideoRedundancyModel.listForApi({
  68     start: req.query.start,
  69     count: req.query.count,
  70     sort: req.query.sort,
  71     target: req.query.target,
  72     strategy: req.query.strategy
  73   })
  74
  75   const result = {
  76     total: resultList.total,
  77     data: resultList.data.map(r => VideoRedundancyModel.toFormattedJSONStatic(r))
  78   }
  79
  80   return res.json(result)
  81 }
  82
  83 async function addVideoRedundancy (req: express.Request, res: express.Response) {
  84   const payload = {
  85     videoId: res.locals.onlyVideo.id
  86   }
  87
  88   await JobQueue.Instance.createJobWithPromise({
  89     type: 'video-redundancy',
  90     payload
  91   })
  92
  93   return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
  94 }
  95
  96 async function removeVideoRedundancyController (req: express.Request, res: express.Response) {
  97   await removeVideoRedundancy(res.locals.videoRedundancy)
  98
  99   return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
 100 }
 101
 102 async function updateRedundancy (req: express.Request, res: express.Response) {
 103   const server = res.locals.server
 104
 105   server.redundancyAllowed = req.body.redundancyAllowed
 106
 107   await server.save()
 108
 109   // Async, could be long
 110   removeRedundanciesOfServer(server.id)
 111     .catch(err => logger.error('Cannot remove redundancy of %s.', server.host, { err }))
 112
 113   return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
 114 }