server/middlewares/validators/user-subscriptions.ts

   1 import express from 'express'
   2 import { body, param, query } from 'express-validator'
   3 import { HttpStatusCode } from '../../../shared/models/http/http-error-codes'
   4 import { areValidActorHandles, isValidActorHandle } from '../../helpers/custom-validators/activitypub/actor'
   5 import { toArray } from '../../helpers/custom-validators/misc'
   6 import { logger } from '../../helpers/logger'
   7 import { WEBSERVER } from '../../initializers/constants'
   8 import { ActorFollowModel } from '../../models/actor/actor-follow'
   9 import { areValidationErrors } from './shared'
  10
  11 const userSubscriptionListValidator = [
  12   query('search')
  13     .optional()
  14     .not().isEmpty(),
  15
  16   (req: express.Request, res: express.Response, next: express.NextFunction) => {
  17     logger.debug('Checking userSubscriptionListValidator parameters', { parameters: req.query })
  18
  19     if (areValidationErrors(req, res)) return
  20
  21     return next()
  22   }
  23 ]
  24
  25 const userSubscriptionAddValidator = [
  26   body('uri')
  27     .custom(isValidActorHandle).withMessage('Should have a valid URI to follow (username@domain)'),
  28
  29   (req: express.Request, res: express.Response, next: express.NextFunction) => {
  30     logger.debug('Checking userSubscriptionAddValidator parameters', { parameters: req.body })
  31
  32     if (areValidationErrors(req, res)) return
  33
  34     return next()
  35   }
  36 ]
  37
  38 const areSubscriptionsExistValidator = [
  39   query('uris')
  40     .customSanitizer(toArray)
  41     .custom(areValidActorHandles).withMessage('Should have a valid array of URIs'),
  42
  43   (req: express.Request, res: express.Response, next: express.NextFunction) => {
  44     logger.debug('Checking areSubscriptionsExistValidator parameters', { parameters: req.query })
  45
  46     if (areValidationErrors(req, res)) return
  47
  48     return next()
  49   }
  50 ]
  51
  52 const userSubscriptionGetValidator = [
  53   param('uri')
  54     .custom(isValidActorHandle),
  55
  56   async (req: express.Request, res: express.Response, next: express.NextFunction) => {
  57     logger.debug('Checking userSubscriptionGetValidator parameters', { parameters: req.params })
  58
  59     if (areValidationErrors(req, res)) return
  60
  61     let [ name, host ] = req.params.uri.split('@')
  62     if (host === WEBSERVER.HOST) host = null
  63
  64     const user = res.locals.oauth.token.User
  65     const subscription = await ActorFollowModel.loadByActorAndTargetNameAndHostForAPI({
  66       actorId: user.Account.Actor.id,
  67       targetName: name,
  68       targetHost: host,
  69       state: 'accepted'
  70     })
  71
  72     if (!subscription || !subscription.ActorFollowing.VideoChannel) {
  73       return res.fail({
  74         status: HttpStatusCode.NOT_FOUND_404,
  75         message: `Subscription ${req.params.uri} not found.`
  76       })
  77     }
  78
  79     res.locals.subscription = subscription
  80     return next()
  81   }
  82 ]
  83
  84 // ---------------------------------------------------------------------------
  85
  86 export {
  87   areSubscriptionsExistValidator,
  88   userSubscriptionListValidator,
  89   userSubscriptionAddValidator,
  90   userSubscriptionGetValidator
  91 }