server/controllers/api/remote.js

   1 'use strict'
   2
   3 const each = require('async/each')
   4 const eachSeries = require('async/eachSeries')
   5 const express = require('express')
   6 const mongoose = require('mongoose')
   7
   8 const middlewares = require('../../middlewares')
   9 const secureMiddleware = middlewares.secure
  10 const validators = middlewares.validators.remote
  11 const logger = require('../../helpers/logger')
  12
  13 const router = express.Router()
  14 const Video = mongoose.model('Video')
  15
  16 router.post('/videos',
  17   validators.signature,
  18   validators.dataToDecrypt,
  19   secureMiddleware.checkSignature,
  20   secureMiddleware.decryptBody,
  21   validators.remoteVideos,
  22   remoteVideos
  23 )
  24
  25 // ---------------------------------------------------------------------------
  26
  27 module.exports = router
  28
  29 // ---------------------------------------------------------------------------
  30
  31 function remoteVideos (req, res, next) {
  32   const requests = req.body.data
  33   const fromHost = req.body.signature.host
  34
  35   // We need to process in the same order to keep consistency
  36   // TODO: optimization
  37   eachSeries(requests, function (request, callbackEach) {
  38     const videoData = request.data
  39
  40     if (request.type === 'add') {
  41       addRemoteVideo(videoData, callbackEach)
  42     } else if (request.type === 'remove') {
  43       removeRemoteVideo(videoData, fromHost, callbackEach)
  44     } else {
  45       logger.error('Unkown remote request type %s.', request.type)
  46     }
  47   }, function (err) {
  48     if (err) logger.error('Error managing remote videos.', { error: err })
  49   })
  50
  51   // We don't need to keep the other pod waiting
  52   return res.type('json').status(204).end()
  53 }
  54
  55 function addRemoteVideo (videoToCreateData, callback) {
  56   logger.debug('Adding remote video %s.', videoToCreateData.magnetUri)
  57
  58   const video = new Video(videoToCreateData)
  59   Video.generateThumbnailFromBase64(video, videoToCreateData.thumbnailBase64, function (err) {
  60     if (err) {
  61       logger.error('Cannot generate thumbnail from base 64 data.', { error: err })
  62       return callback(err)
  63     }
  64
  65     video.save(callback)
  66   })
  67 }
  68
  69 function removeRemoteVideo (videoToRemoveData, fromHost, callback) {
  70   // We need the list because we have to remove some other stuffs (thumbnail etc)
  71   Video.listByHostAndRemoteId(fromHost, videoToRemoveData.remoteId, function (err, videosList) {
  72     if (err) {
  73       logger.error('Cannot list videos from host and magnets.', { error: err })
  74       return callback(err)
  75     }
  76
  77     if (videosList.length === 0) {
  78       logger.error('No remote video was found for this pod.', { magnetUri: videoToRemoveData.magnetUri, podHost: fromHost })
  79     }
  80
  81     each(videosList, function (video, callbackEach) {
  82       logger.debug('Removing remote video %s.', video.magnetUri)
  83
  84       video.remove(callbackEach)
  85     }, callback)
  86   })
  87 }