]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blob - server/controllers/api/users.js
Server: use video hook to send information to other pods when a video is
[github/Chocobozzz/PeerTube.git] / server / controllers / api / users.js
1 'use strict'
2
3 const each = require('async/each')
4 const express = require('express')
5 const waterfall = require('async/waterfall')
6
7 const constants = require('../../initializers/constants')
8 const db = require('../../initializers/database')
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 pagination = middlewares.pagination
15 const sort = middlewares.sort
16 const validatorsPagination = middlewares.validators.pagination
17 const validatorsSort = middlewares.validators.sort
18 const validatorsUsers = middlewares.validators.users
19
20 const router = express.Router()
21
22 router.get('/me', oAuth.authenticate, getUserInformation)
23
24 router.get('/',
25 validatorsPagination.pagination,
26 validatorsSort.usersSort,
27 sort.setUsersSort,
28 pagination.setPagination,
29 listUsers
30 )
31
32 router.post('/',
33 oAuth.authenticate,
34 admin.ensureIsAdmin,
35 validatorsUsers.usersAdd,
36 createUser
37 )
38
39 router.put('/:id',
40 oAuth.authenticate,
41 validatorsUsers.usersUpdate,
42 updateUser
43 )
44
45 router.delete('/:id',
46 oAuth.authenticate,
47 admin.ensureIsAdmin,
48 validatorsUsers.usersRemove,
49 removeUser
50 )
51
52 router.post('/token', oAuth.token, success)
53 // TODO: Once https://github.com/oauthjs/node-oauth2-server/pull/289 is merged, implement revoke token route
54
55 // ---------------------------------------------------------------------------
56
57 module.exports = router
58
59 // ---------------------------------------------------------------------------
60
61 function createUser (req, res, next) {
62 const user = db.User.build({
63 username: req.body.username,
64 password: req.body.password,
65 role: constants.USER_ROLES.USER
66 })
67
68 user.save().asCallback(function (err, createdUser) {
69 if (err) return next(err)
70
71 return res.type('json').status(204).end()
72 })
73 }
74
75 function getUserInformation (req, res, next) {
76 db.User.loadByUsername(res.locals.oauth.token.user.username, function (err, user) {
77 if (err) return next(err)
78
79 return res.json(user.toFormatedJSON())
80 })
81 }
82
83 function listUsers (req, res, next) {
84 db.User.listForApi(req.query.start, req.query.count, req.query.sort, function (err, usersList, usersTotal) {
85 if (err) return next(err)
86
87 res.json(getFormatedUsers(usersList, usersTotal))
88 })
89 }
90
91 function removeUser (req, res, next) {
92 waterfall([
93 function loadUser (callback) {
94 db.User.loadById(req.params.id, callback)
95 },
96
97 function deleteUser (user, callback) {
98 user.destroy().asCallback(callback)
99 }
100 ], function andFinally (err) {
101 if (err) {
102 logger.error('Errors when removed the user.', { error: err })
103 return next(err)
104 }
105
106 return res.sendStatus(204)
107 })
108 }
109
110 function updateUser (req, res, next) {
111 db.User.loadByUsername(res.locals.oauth.token.user.username, function (err, user) {
112 if (err) return next(err)
113
114 user.password = req.body.password
115 user.save().asCallback(function (err) {
116 if (err) return next(err)
117
118 return res.sendStatus(204)
119 })
120 })
121 }
122
123 function success (req, res, next) {
124 res.end()
125 }
126
127 // ---------------------------------------------------------------------------
128
129 function getFormatedUsers (users, usersTotal) {
130 const formatedUsers = []
131
132 users.forEach(function (user) {
133 formatedUsers.push(user.toFormatedJSON())
134 })
135
136 return {
137 total: usersTotal,
138 data: formatedUsers
139 }
140 }