1 files changed, 196 insertions, 198 deletions

diff --git a/models/videos.js b/models/videos.js
index ea1823e27..4da389c24 100644
--- a/models/videos.js
+++ b/models/videos.js
@@ -1,237 +1,235 @@
-;(function () {
-  'use strict'
-
-  var async = require('async')
-  var config = require('config')
-  var dz = require('dezalgo')
-  var fs = require('fs')
-  var mongoose = require('mongoose')
-  var path = require('path')
-
-  var logger = require('../helpers/logger')
-
-  var http = config.get('webserver.https') === true ? 'https' : 'http'
-  var host = config.get('webserver.host')
-  var port = config.get('webserver.port')
-  var uploadDir = path.join(__dirname, '..', config.get('storage.uploads'))
-
-  // ---------------------------------------------------------------------------
-
-  var videosSchema = mongoose.Schema({
-    name: String,
-    namePath: String,
-    description: String,
-    magnetUri: String,
-    podUrl: String
+'use strict'
+
+var async = require('async')
+var config = require('config')
+var dz = require('dezalgo')
+var fs = require('fs')
+var mongoose = require('mongoose')
+var path = require('path')
+
+var logger = require('../helpers/logger')
+
+var http = config.get('webserver.https') === true ? 'https' : 'http'
+var host = config.get('webserver.host')
+var port = config.get('webserver.port')
+var uploadDir = path.join(__dirname, '..', config.get('storage.uploads'))
+
+// ---------------------------------------------------------------------------
+
+var videosSchema = mongoose.Schema({
+  name: String,
+  namePath: String,
+  description: String,
+  magnetUri: String,
+  podUrl: String
+})
+var VideosDB = mongoose.model('videos', videosSchema)
+
+// ---------------------------------------------------------------------------
+
+var Videos = {
+  add: add,
+  addRemotes: addRemotes,
+  get: get,
+  getVideoState: getVideoState,
+  isOwned: isOwned,
+  list: list,
+  listOwned: listOwned,
+  removeOwned: removeOwned,
+  removeAllRemotes: removeAllRemotes,
+  removeAllRemotesOf: removeAllRemotesOf,
+  removeRemotesOfByMagnetUris: removeRemotesOfByMagnetUris,
+  search: search
+}
+
+function add (video, callback) {
+  logger.info('Adding %s video to database.', video.name)
+
+  var params = video
+  params.podUrl = http + '://' + host + ':' + port
+
+  VideosDB.create(params, function (err, video) {
+    if (err) {
+      logger.error('Cannot insert this video into database.')
+      return callback(err)
+    }
+
+    callback(null)
   })
-  var VideosDB = mongoose.model('videos', videosSchema)
-
-  // ---------------------------------------------------------------------------
-
-  var Videos = {
-    add: add,
-    addRemotes: addRemotes,
-    get: get,
-    getVideoState: getVideoState,
-    isOwned: isOwned,
-    list: list,
-    listOwned: listOwned,
-    removeOwned: removeOwned,
-    removeAllRemotes: removeAllRemotes,
-    removeAllRemotesOf: removeAllRemotesOf,
-    removeRemotesOfByMagnetUris: removeRemotesOfByMagnetUris,
-    search: search
-  }
-
-  function add (video, callback) {
-    logger.info('Adding %s video to database.', video.name)
-
-    var params = video
-    params.podUrl = http + '://' + host + ':' + port
-
-    VideosDB.create(params, function (err, video) {
-      if (err) {
-        logger.error('Cannot insert this video into database.')
-        return callback(err)
-      }
-
-      callback(null)
-    })
-  }
+}
 
-  // TODO: avoid doublons
-  function addRemotes (videos, callback) {
-    if (!callback) callback = function () {}
+// TODO: avoid doublons
+function addRemotes (videos, callback) {
+  if (!callback) callback = function () {}
 
-    var to_add = []
+  var to_add = []
 
-    async.each(videos, function (video, callback_each) {
-      callback_each = dz(callback_each)
-      logger.debug('Add remote video from pod: %s', video.podUrl)
-
-      var params = {
-        name: video.name,
-        namePath: null,
-        description: video.description,
-        magnetUri: video.magnetUri,
-        podUrl: video.podUrl
-      }
+  async.each(videos, function (video, callback_each) {
+    callback_each = dz(callback_each)
+    logger.debug('Add remote video from pod: %s', video.podUrl)
 
-      to_add.push(params)
+    var params = {
+      name: video.name,
+      namePath: null,
+      description: video.description,
+      magnetUri: video.magnetUri,
+      podUrl: video.podUrl
+    }
 
-      callback_each()
-    }, function () {
-      VideosDB.create(to_add, function (err, videos) {
-        if (err) {
-          logger.error('Cannot insert this remote video.')
-          return callback(err)
-        }
-
-        return callback(null, videos)
-      })
-    })
-  }
+    to_add.push(params)
 
-  function get (id, callback) {
-    VideosDB.findById(id, function (err, video) {
+    callback_each()
+  }, function () {
+    VideosDB.create(to_add, function (err, videos) {
       if (err) {
-        logger.error('Cannot get this video.')
+        logger.error('Cannot insert this remote video.')
         return callback(err)
       }
 
-      return callback(null, video)
+      return callback(null, videos)
     })
-  }
+  })
+}
 
-  function getVideoState (id, callback) {
-    get(id, function (err, video) {
-      if (err) return callback(err)
+function get (id, callback) {
+  VideosDB.findById(id, function (err, video) {
+    if (err) {
+      logger.error('Cannot get this video.')
+      return callback(err)
+    }
 
-      var exist = (video !== null)
-      var owned = false
-      if (exist === true) {
-        owned = (video.namePath !== null)
-      }
+    return callback(null, video)
+  })
+}
 
-      return callback(null, { exist: exist, owned: owned })
-    })
-  }
+function getVideoState (id, callback) {
+  get(id, function (err, video) {
+    if (err) return callback(err)
 
-  function isOwned (id, callback) {
-    VideosDB.findById(id, function (err, video) {
-      if (err || !video) {
-        if (!err) err = new Error('Cannot find this video.')
-        logger.error('Cannot find this video.')
-        return callback(err)
-      }
+    var exist = (video !== null)
+    var owned = false
+    if (exist === true) {
+      owned = (video.namePath !== null)
+    }
 
-      if (video.namePath === null) {
-        var error_string = 'Cannot remove the video of another pod.'
-        logger.error(error_string)
-        return callback(new Error(error_string), false, video)
-      }
+    return callback(null, { exist: exist, owned: owned })
+  })
+}
+
+function isOwned (id, callback) {
+  VideosDB.findById(id, function (err, video) {
+    if (err || !video) {
+      if (!err) err = new Error('Cannot find this video.')
+      logger.error('Cannot find this video.')
+      return callback(err)
+    }
+
+    if (video.namePath === null) {
+      var error_string = 'Cannot remove the video of another pod.'
+      logger.error(error_string)
+      return callback(new Error(error_string), false, video)
+    }
+
+    callback(null, true, video)
+  })
+}
 
-      callback(null, true, video)
-    })
-  }
+function list (callback) {
+  VideosDB.find(function (err, videos_list) {
+    if (err) {
+      logger.error('Cannot get the list of the videos.')
+      return callback(err)
+    }
 
-  function list (callback) {
-    VideosDB.find(function (err, videos_list) {
-      if (err) {
-        logger.error('Cannot get the list of the videos.')
-        return callback(err)
-      }
+    return callback(null, videos_list)
+  })
+}
 
-      return callback(null, videos_list)
-    })
-  }
+function listOwned (callback) {
+  // If namePath is not null this is *our* video
+  VideosDB.find({ namePath: { $ne: null } }, function (err, videos_list) {
+    if (err) {
+      logger.error('Cannot get the list of owned videos.')
+      return callback(err)
+    }
+
+    return callback(null, videos_list)
+  })
+}
+
+function removeOwned (id, callback) {
+  VideosDB.findByIdAndRemove(id, function (err, video) {
+    if (err) {
+      logger.error('Cannot remove the torrent.')
+      return callback(err)
+    }
 
-  function listOwned (callback) {
-    // If namePath is not null this is *our* video
-    VideosDB.find({ namePath: { $ne: null } }, function (err, videos_list) {
+    fs.unlink(uploadDir + video.namePath, function (err) {
       if (err) {
-        logger.error('Cannot get the list of owned videos.')
+        logger.error('Cannot remove this video file.')
         return callback(err)
       }
 
-      return callback(null, videos_list)
+      callback(null)
     })
-  }
-
-  function removeOwned (id, callback) {
-    VideosDB.findByIdAndRemove(id, function (err, video) {
-      if (err) {
-        logger.error('Cannot remove the torrent.')
-        return callback(err)
+  })
+}
+
+function removeAllRemotes (callback) {
+  VideosDB.remove({ namePath: null }, callback)
+}
+
+function removeAllRemotesOf (fromUrl, callback) {
+  // TODO { podUrl: { $in: urls } }
+  VideosDB.remove({ podUrl: fromUrl }, callback)
+}
+
+// Use the magnet Uri because the _id field is not the same on different servers
+function removeRemotesOfByMagnetUris (fromUrl, magnetUris, callback) {
+  if (callback === undefined) callback = function () {}
+
+  VideosDB.find({ magnetUri: { $in: magnetUris } }, function (err, videos) {
+    if (err || !videos) {
+      logger.error('Cannot find the torrent URI of these remote videos.')
+      return callback(err)
+    }
+
+    var to_remove = []
+    async.each(videos, function (video, callback_async) {
+      callback_async = dz(callback_async)
+
+      if (video.podUrl !== fromUrl) {
+        logger.error('The pod %s has not the rights on the video of %s.', fromUrl, video.podUrl)
+      } else {
+        to_remove.push(video._id)
       }
 
-      fs.unlink(uploadDir + video.namePath, function (err) {
+      callback_async()
+    }, function () {
+      VideosDB.remove({ _id: { $in: to_remove } }, function (err) {
         if (err) {
-          logger.error('Cannot remove this video file.')
+          logger.error('Cannot remove the remote videos.')
           return callback(err)
         }
 
+        logger.info('Removed remote videos from %s.', fromUrl)
         callback(null)
       })
     })
-  }
-
-  function removeAllRemotes (callback) {
-    VideosDB.remove({ namePath: null }, callback)
-  }
-
-  function removeAllRemotesOf (fromUrl, callback) {
-    // TODO { podUrl: { $in: urls } }
-    VideosDB.remove({ podUrl: fromUrl }, callback)
-  }
-
-  // Use the magnet Uri because the _id field is not the same on different servers
-  function removeRemotesOfByMagnetUris (fromUrl, magnetUris, callback) {
-    if (callback === undefined) callback = function () {}
-
-    VideosDB.find({ magnetUri: { $in: magnetUris } }, function (err, videos) {
-      if (err || !videos) {
-        logger.error('Cannot find the torrent URI of these remote videos.')
-        return callback(err)
-      }
-
-      var to_remove = []
-      async.each(videos, function (video, callback_async) {
-        callback_async = dz(callback_async)
-
-        if (video.podUrl !== fromUrl) {
-          logger.error('The pod %s has not the rights on the video of %s.', fromUrl, video.podUrl)
-        } else {
-          to_remove.push(video._id)
-        }
-
-        callback_async()
-      }, function () {
-        VideosDB.remove({ _id: { $in: to_remove } }, function (err) {
-          if (err) {
-            logger.error('Cannot remove the remote videos.')
-            return callback(err)
-          }
-
-          logger.info('Removed remote videos from %s.', fromUrl)
-          callback(null)
-        })
-      })
-    })
-  }
+  })
+}
 
-  function search (name, callback) {
-    VideosDB.find({ name: new RegExp(name) }, function (err, videos) {
-      if (err) {
-        logger.error('Cannot search the videos.')
-        return callback(err)
-      }
+function search (name, callback) {
+  VideosDB.find({ name: new RegExp(name) }, function (err, videos) {
+    if (err) {
+      logger.error('Cannot search the videos.')
+      return callback(err)
+    }
 
-      return callback(null, videos)
-    })
-  }
+    return callback(null, videos)
+  })
+}
 
-  // ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
 
-  module.exports = Videos
-})()
+module.exports = Videos