server/controllers/api/users.js

   1 'use strict'
   2
   3 const express = require('express')
   4 const waterfall = require('async/waterfall')
   5
   6 const constants = require('../../initializers/constants')
   7 const db = require('../../initializers/database')
   8 const logger = require('../../helpers/logger')
   9 const utils = require('../../helpers/utils')
  10 const middlewares = require('../../middlewares')
  11 const admin = middlewares.admin
  12 const oAuth = middlewares.oauth
  13 const pagination = middlewares.pagination
  14 const sort = middlewares.sort
  15 const validatorsPagination = middlewares.validators.pagination
  16 const validatorsSort = middlewares.validators.sort
  17 const validatorsUsers = middlewares.validators.users
  18
  19 const router = express.Router()
  20
  21 router.get('/me',
  22   oAuth.authenticate,
  23   getUserInformation
  24 )
  25
  26 router.get('/me/videos/:videoId/rating',
  27   oAuth.authenticate,
  28   validatorsUsers.usersVideoRating,
  29   getUserVideoRating
  30 )
  31
  32 router.get('/',
  33   validatorsPagination.pagination,
  34   validatorsSort.usersSort,
  35   sort.setUsersSort,
  36   pagination.setPagination,
  37   listUsers
  38 )
  39
  40 router.post('/',
  41   oAuth.authenticate,
  42   admin.ensureIsAdmin,
  43   validatorsUsers.usersAdd,
  44   createUser
  45 )
  46
  47 router.put('/:id',
  48   oAuth.authenticate,
  49   validatorsUsers.usersUpdate,
  50   updateUser
  51 )
  52
  53 router.delete('/:id',
  54   oAuth.authenticate,
  55   admin.ensureIsAdmin,
  56   validatorsUsers.usersRemove,
  57   removeUser
  58 )
  59
  60 router.post('/token', oAuth.token, success)
  61 // TODO: Once https://github.com/oauthjs/node-oauth2-server/pull/289 is merged, implement revoke token route
  62
  63 // ---------------------------------------------------------------------------
  64
  65 module.exports = router
  66
  67 // ---------------------------------------------------------------------------
  68
  69 function createUser (req, res, next) {
  70   const user = db.User.build({
  71     username: req.body.username,
  72     password: req.body.password,
  73     email: req.body.email,
  74     displayNSFW: false,
  75     role: constants.USER_ROLES.USER
  76   })
  77
  78   user.save().asCallback(function (err, createdUser) {
  79     if (err) return next(err)
  80
  81     return res.type('json').status(204).end()
  82   })
  83 }
  84
  85 function getUserInformation (req, res, next) {
  86   db.User.loadByUsername(res.locals.oauth.token.user.username, function (err, user) {
  87     if (err) return next(err)
  88
  89     return res.json(user.toFormatedJSON())
  90   })
  91 }
  92
  93 function getUserVideoRating (req, res, next) {
  94   const videoId = req.params.videoId
  95   const userId = res.locals.oauth.token.User.id
  96
  97   db.UserVideoRate.load(userId, videoId, function (err, ratingObj) {
  98     if (err) return next(err)
  99
 100     const rating = ratingObj ? ratingObj.type : 'none'
 101
 102     res.json({
 103       videoId,
 104       rating
 105     })
 106   })
 107 }
 108
 109 function listUsers (req, res, next) {
 110   db.User.listForApi(req.query.start, req.query.count, req.query.sort, function (err, usersList, usersTotal) {
 111     if (err) return next(err)
 112
 113     res.json(utils.getFormatedObjects(usersList, usersTotal))
 114   })
 115 }
 116
 117 function removeUser (req, res, next) {
 118   waterfall([
 119     function loadUser (callback) {
 120       db.User.loadById(req.params.id, callback)
 121     },
 122
 123     function deleteUser (user, callback) {
 124       user.destroy().asCallback(callback)
 125     }
 126   ], function andFinally (err) {
 127     if (err) {
 128       logger.error('Errors when removed the user.', { error: err })
 129       return next(err)
 130     }
 131
 132     return res.sendStatus(204)
 133   })
 134 }
 135
 136 function updateUser (req, res, next) {
 137   db.User.loadByUsername(res.locals.oauth.token.user.username, function (err, user) {
 138     if (err) return next(err)
 139
 140     if (req.body.password) user.password = req.body.password
 141     if (req.body.displayNSFW !== undefined) user.displayNSFW = req.body.displayNSFW
 142
 143     user.save().asCallback(function (err) {
 144       if (err) return next(err)
 145
 146       return res.sendStatus(204)
 147     })
 148   })
 149 }
 150
 151 function success (req, res, next) {
 152   res.end()
 153 }