server/controllers/api/v1/users.js

   1 'use strict'
   2
   3 const each = require('async/each')
   4 const express = require('express')
   5 const mongoose = require('mongoose')
   6 const waterfall = require('async/waterfall')
   7
   8 const constants = require('../../../initializers/constants')
   9 const friends = require('../../../lib/friends')
  10 const logger = require('../../../helpers/logger')
  11 const middlewares = require('../../../middlewares')
  12 const admin = middlewares.admin
  13 const oAuth = middlewares.oauth
  14 const validatorsUsers = middlewares.validators.users
  15
  16 const User = mongoose.model('User')
  17 const Video = mongoose.model('Video')
  18
  19 const router = express.Router()
  20
  21 router.get('/', listUsers)
  22 router.get('/me', oAuth.authenticate, getUserInformation)
  23
  24 router.post('/',
  25   oAuth.authenticate,
  26   admin.ensureIsAdmin,
  27   validatorsUsers.usersAdd,
  28   createUser
  29 )
  30
  31 router.put('/:id',
  32   oAuth.authenticate,
  33   validatorsUsers.usersUpdate,
  34   updateUser
  35 )
  36
  37 router.delete('/:username',
  38   oAuth.authenticate,
  39   admin.ensureIsAdmin,
  40   validatorsUsers.usersRemove,
  41   removeUser
  42 )
  43
  44 router.post('/token', oAuth.token, success)
  45 // TODO: Once https://github.com/oauthjs/node-oauth2-server/pull/289 is merged, implement revoke token route
  46
  47 // ---------------------------------------------------------------------------
  48
  49 module.exports = router
  50
  51 // ---------------------------------------------------------------------------
  52
  53 function createUser (req, res, next) {
  54   const user = new User({
  55     username: req.body.username,
  56     password: req.body.password,
  57     role: constants.USER_ROLES.USER
  58   })
  59
  60   user.save(function (err, createdUser) {
  61     if (err) return next(err)
  62
  63     return res.type('json').status(204).end()
  64   })
  65 }
  66
  67 function getUserInformation (req, res, next) {
  68   User.loadByUsername(res.locals.oauth.token.user.username, function (err, user) {
  69     if (err) return next(err)
  70
  71     return res.json(user.toFormatedJSON())
  72   })
  73 }
  74
  75 function listUsers (req, res, next) {
  76   User.list(function (err, usersList) {
  77     if (err) return next(err)
  78
  79     res.json(getFormatedUsers(usersList))
  80   })
  81 }
  82
  83 function removeUser (req, res, next) {
  84   waterfall([
  85     function getUser (callback) {
  86       User.loadByUsername(req.params.username, callback)
  87     },
  88
  89     function getVideos (user, callback) {
  90       Video.listOwnedByAuthor(user.username, function (err, videos) {
  91         return callback(err, user, videos)
  92       })
  93     },
  94
  95     function removeVideosFromDB (user, videos, callback) {
  96       each(videos, function (video, callbackEach) {
  97         video.remove(callbackEach)
  98       }, function (err) {
  99         return callback(err, user, videos)
 100       })
 101     },
 102
 103     function sendInformationToFriends (user, videos, callback) {
 104       videos.forEach(function (video) {
 105         const params = {
 106           name: video.name,
 107           magnetUri: video.magnetUri
 108         }
 109
 110         friends.removeVideoToFriends(params)
 111       })
 112
 113       return callback(null, user)
 114     },
 115
 116     function removeUserFromDB (user, callback) {
 117       user.remove(callback)
 118     }
 119   ], function andFinally (err) {
 120     if (err) {
 121       logger.error('Errors when removed the user.', { error: err })
 122       return next(err)
 123     }
 124
 125     return res.sendStatus(204)
 126   })
 127 }
 128
 129 function updateUser (req, res, next) {
 130   User.loadByUsername(res.locals.oauth.token.user.username, function (err, user) {
 131     if (err) return next(err)
 132
 133     user.password = req.body.password
 134     user.save(function (err) {
 135       if (err) return next(err)
 136
 137       return res.sendStatus(204)
 138     })
 139   })
 140 }
 141
 142 function success (req, res, next) {
 143   res.end()
 144 }
 145
 146 // ---------------------------------------------------------------------------
 147
 148 function getFormatedUsers (users) {
 149   const formatedUsers = []
 150
 151   users.forEach(function (user) {
 152     formatedUsers.push(user.toFormatedJSON())
 153   })
 154
 155   return {
 156     data: formatedUsers
 157   }
 158 }