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 @@
+'use strict'
+
+const express = require('express')
+const mongoose = require('mongoose')
+const multer = require('multer')
+const waterfall = require('async/waterfall')
+
+const constants = require('../../initializers/constants')
+const logger = require('../../helpers/logger')
+const friends = require('../../lib/friends')
+const middlewares = require('../../middlewares')
+const oAuth = middlewares.oauth
+const pagination = middlewares.pagination
+const validators = middlewares.validators
+const validatorsPagination = validators.pagination
+const validatorsSort = validators.sort
+const validatorsVideos = validators.videos
+const search = middlewares.search
+const sort = middlewares.sort
+const utils = require('../../helpers/utils')
+
+const router = express.Router()
+const Video = mongoose.model('Video')
+
+// multer configuration
+const storage = multer.diskStorage({
+  destination: function (req, file, cb) {
+    cb(null, constants.CONFIG.STORAGE.VIDEOS_DIR)
+  },
+
+  filename: function (req, file, cb) {
+    let extension = ''
+    if (file.mimetype === 'video/webm') extension = 'webm'
+    else if (file.mimetype === 'video/mp4') extension = 'mp4'
+    else if (file.mimetype === 'video/ogg') extension = 'ogv'
+    utils.generateRandomString(16, function (err, randomString) {
+      const fieldname = err ? undefined : randomString
+      cb(null, fieldname + '.' + extension)
+    })
+  }
+})
+
+const reqFiles = multer({ storage: storage }).fields([{ name: 'videofile', maxCount: 1 }])
+
+router.get('/',
+  validatorsPagination.pagination,
+  validatorsSort.videosSort,
+  sort.setVideosSort,
+  pagination.setPagination,
+  listVideos
+)
+router.post('/',
+  oAuth.authenticate,
+  reqFiles,
+  validatorsVideos.videosAdd,
+  addVideo
+)
+router.get('/:id',
+  validatorsVideos.videosGet,
+  getVideo
+)
+router.delete('/:id',
+  oAuth.authenticate,
+  validatorsVideos.videosRemove,
+  removeVideo
+)
+router.get('/search/:value',
+  validatorsVideos.videosSearch,
+  validatorsPagination.pagination,
+  validatorsSort.videosSort,
+  sort.setVideosSort,
+  pagination.setPagination,
+  search.setVideosSearch,
+  searchVideos
+)
+
+// ---------------------------------------------------------------------------
+
+module.exports = router
+
+// ---------------------------------------------------------------------------
+
+function addVideo (req, res, next) {
+  const videoFile = req.files.videofile[0]
+  const videoInfos = req.body
+
+  waterfall([
+
+    function insertIntoDB (callback) {
+      const videoData = {
+        name: videoInfos.name,
+        filename: videoFile.filename,
+        description: videoInfos.description,
+        author: res.locals.oauth.token.user.username,
+        duration: videoFile.duration,
+        tags: videoInfos.tags
+      }
+
+      const video = new Video(videoData)
+      video.save(function (err, video) {
+        // Assert there are only one argument sent to the next function (video)
+        return callback(err, video)
+      })
+    },
+
+    function sendToFriends (video, callback) {
+      video.toRemoteJSON(function (err, remoteVideo) {
+        if (err) return callback(err)
+
+        // Now we'll add the video's meta data to our friends
+        friends.addVideoToFriends(remoteVideo)
+
+        return callback(null)
+      })
+    }
+
+  ], function andFinally (err) {
+    if (err) {
+      logger.error('Cannot insert the video.')
+      return next(err)
+    }
+
+    // TODO : include Location of the new video -> 201
+    return res.type('json').status(204).end()
+  })
+}
+
+function getVideo (req, res, next) {
+  Video.load(req.params.id, function (err, video) {
+    if (err) return next(err)
+
+    if (!video) {
+      return res.type('json').status(204).end()
+    }
+
+    res.json(video.toFormatedJSON())
+  })
+}
+
+function listVideos (req, res, next) {
+  Video.listForApi(req.query.start, req.query.count, req.query.sort, function (err, videosList, videosTotal) {
+    if (err) return next(err)
+
+    res.json(getFormatedVideos(videosList, videosTotal))
+  })
+}
+
+function removeVideo (req, res, next) {
+  const videoId = req.params.id
+
+  waterfall([
+    function getVideo (callback) {
+      Video.load(videoId, callback)
+    },
+
+    function removeFromDB (video, callback) {
+      video.remove(function (err) {
+        if (err) return callback(err)
+
+        return callback(null, video)
+      })
+    },
+
+    function sendInformationToFriends (video, callback) {
+      const params = {
+        name: video.name,
+        magnetUri: video.magnetUri
+      }
+
+      friends.removeVideoToFriends(params)
+
+      return callback(null)
+    }
+  ], function andFinally (err) {
+    if (err) {
+      logger.error('Errors when removed the video.', { error: err })
+      return next(err)
+    }
+
+    return res.type('json').status(204).end()
+  })
+}
+
+function searchVideos (req, res, next) {
+  Video.search(req.params.value, req.query.field, req.query.start, req.query.count, req.query.sort,
+  function (err, videosList, videosTotal) {
+    if (err) return next(err)
+
+    res.json(getFormatedVideos(videosList, videosTotal))
+  })
+}
+
+// ---------------------------------------------------------------------------
+
+function getFormatedVideos (videos, videosTotal) {
+  const formatedVideos = []
+
+  videos.forEach(function (video) {
+    formatedVideos.push(video.toFormatedJSON())
+  })
+
+  return {
+    total: videosTotal,
+    data: formatedVideos
+  }
+}