aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/controllers/api/videos.js
diff options
context:
space:
mode:
Diffstat (limited to 'server/controllers/api/videos.js')
-rw-r--r--server/controllers/api/videos.js206
1 files changed, 206 insertions, 0 deletions
diff --git a/server/controllers/api/videos.js b/server/controllers/api/videos.js
new file mode 100644
index 000000000..e2d393074
--- /dev/null
+++ b/server/controllers/api/videos.js
@@ -0,0 +1,206 @@
1'use strict'
2
3const express = require('express')
4const mongoose = require('mongoose')
5const multer = require('multer')
6const waterfall = require('async/waterfall')
7
8const constants = require('../../initializers/constants')
9const logger = require('../../helpers/logger')
10const friends = require('../../lib/friends')
11const middlewares = require('../../middlewares')
12const oAuth = middlewares.oauth
13const pagination = middlewares.pagination
14const validators = middlewares.validators
15const validatorsPagination = validators.pagination
16const validatorsSort = validators.sort
17const validatorsVideos = validators.videos
18const search = middlewares.search
19const sort = middlewares.sort
20const utils = require('../../helpers/utils')
21
22const router = express.Router()
23const Video = mongoose.model('Video')
24
25// multer configuration
26const storage = multer.diskStorage({
27 destination: function (req, file, cb) {
28 cb(null, constants.CONFIG.STORAGE.VIDEOS_DIR)
29 },
30
31 filename: function (req, file, cb) {
32 let extension = ''
33 if (file.mimetype === 'video/webm') extension = 'webm'
34 else if (file.mimetype === 'video/mp4') extension = 'mp4'
35 else if (file.mimetype === 'video/ogg') extension = 'ogv'
36 utils.generateRandomString(16, function (err, randomString) {
37 const fieldname = err ? undefined : randomString
38 cb(null, fieldname + '.' + extension)
39 })
40 }
41})
42
43const reqFiles = multer({ storage: storage }).fields([{ name: 'videofile', maxCount: 1 }])
44
45router.get('/',
46 validatorsPagination.pagination,
47 validatorsSort.videosSort,
48 sort.setVideosSort,
49 pagination.setPagination,
50 listVideos
51)
52router.post('/',
53 oAuth.authenticate,
54 reqFiles,
55 validatorsVideos.videosAdd,
56 addVideo
57)
58router.get('/:id',
59 validatorsVideos.videosGet,
60 getVideo
61)
62router.delete('/:id',
63 oAuth.authenticate,
64 validatorsVideos.videosRemove,
65 removeVideo
66)
67router.get('/search/:value',
68 validatorsVideos.videosSearch,
69 validatorsPagination.pagination,
70 validatorsSort.videosSort,
71 sort.setVideosSort,
72 pagination.setPagination,
73 search.setVideosSearch,
74 searchVideos
75)
76
77// ---------------------------------------------------------------------------
78
79module.exports = router
80
81// ---------------------------------------------------------------------------
82
83function addVideo (req, res, next) {
84 const videoFile = req.files.videofile[0]
85 const videoInfos = req.body
86
87 waterfall([
88
89 function insertIntoDB (callback) {
90 const videoData = {
91 name: videoInfos.name,
92 filename: videoFile.filename,
93 description: videoInfos.description,
94 author: res.locals.oauth.token.user.username,
95 duration: videoFile.duration,
96 tags: videoInfos.tags
97 }
98
99 const video = new Video(videoData)
100 video.save(function (err, video) {
101 // Assert there are only one argument sent to the next function (video)
102 return callback(err, video)
103 })
104 },
105
106 function sendToFriends (video, callback) {
107 video.toRemoteJSON(function (err, remoteVideo) {
108 if (err) return callback(err)
109
110 // Now we'll add the video's meta data to our friends
111 friends.addVideoToFriends(remoteVideo)
112
113 return callback(null)
114 })
115 }
116
117 ], function andFinally (err) {
118 if (err) {
119 logger.error('Cannot insert the video.')
120 return next(err)
121 }
122
123 // TODO : include Location of the new video -> 201
124 return res.type('json').status(204).end()
125 })
126}
127
128function getVideo (req, res, next) {
129 Video.load(req.params.id, function (err, video) {
130 if (err) return next(err)
131
132 if (!video) {
133 return res.type('json').status(204).end()
134 }
135
136 res.json(video.toFormatedJSON())
137 })
138}
139
140function listVideos (req, res, next) {
141 Video.listForApi(req.query.start, req.query.count, req.query.sort, function (err, videosList, videosTotal) {
142 if (err) return next(err)
143
144 res.json(getFormatedVideos(videosList, videosTotal))
145 })
146}
147
148function removeVideo (req, res, next) {
149 const videoId = req.params.id
150
151 waterfall([
152 function getVideo (callback) {
153 Video.load(videoId, callback)
154 },
155
156 function removeFromDB (video, callback) {
157 video.remove(function (err) {
158 if (err) return callback(err)
159
160 return callback(null, video)
161 })
162 },
163
164 function sendInformationToFriends (video, callback) {
165 const params = {
166 name: video.name,
167 magnetUri: video.magnetUri
168 }
169
170 friends.removeVideoToFriends(params)
171
172 return callback(null)
173 }
174 ], function andFinally (err) {
175 if (err) {
176 logger.error('Errors when removed the video.', { error: err })
177 return next(err)
178 }
179
180 return res.type('json').status(204).end()
181 })
182}
183
184function searchVideos (req, res, next) {
185 Video.search(req.params.value, req.query.field, req.query.start, req.query.count, req.query.sort,
186 function (err, videosList, videosTotal) {
187 if (err) return next(err)
188
189 res.json(getFormatedVideos(videosList, videosTotal))
190 })
191}
192
193// ---------------------------------------------------------------------------
194
195function getFormatedVideos (videos, videosTotal) {
196 const formatedVideos = []
197
198 videos.forEach(function (video) {
199 formatedVideos.push(video.toFormatedJSON())
200 })
201
202 return {
203 total: videosTotal,
204 data: formatedVideos
205 }
206}