'use strict'
-const async = require('async')
const config = require('config')
+const eachLimit = require('async/eachLimit')
const ffmpeg = require('fluent-ffmpeg')
const fs = require('fs')
+const parallel = require('async/parallel')
const pathUtils = require('path')
const mongoose = require('mongoose')
const constants = require('../initializers/constants')
-const customValidators = require('../helpers/customValidators')
+const customVideosValidators = require('../helpers/custom-validators').videos
const logger = require('../helpers/logger')
const utils = require('../helpers/utils')
const webtorrent = require('../lib/webtorrent')
// TODO: add indexes on searchable columns
const VideoSchema = mongoose.Schema({
name: String,
- namePath: String,
+ filename: String,
description: String,
magnetUri: String,
podUrl: String,
}
})
-VideoSchema.path('name').validate(customValidators.isVideoNameValid)
-VideoSchema.path('description').validate(customValidators.isVideoDescriptionValid)
-VideoSchema.path('magnetUri').validate(customValidators.isVideoMagnetUriValid)
-VideoSchema.path('podUrl').validate(customValidators.isVideoPodUrlValid)
-VideoSchema.path('author').validate(customValidators.isVideoAuthorValid)
-VideoSchema.path('duration').validate(customValidators.isVideoDurationValid)
+VideoSchema.path('name').validate(customVideosValidators.isVideoNameValid)
+VideoSchema.path('description').validate(customVideosValidators.isVideoDescriptionValid)
+VideoSchema.path('magnetUri').validate(customVideosValidators.isVideoMagnetUriValid)
+VideoSchema.path('podUrl').validate(customVideosValidators.isVideoPodUrlValid)
+VideoSchema.path('author').validate(customVideosValidators.isVideoAuthorValid)
+VideoSchema.path('duration').validate(customVideosValidators.isVideoDurationValid)
// The tumbnail can be the path or the data in base 64
// The pre save hook will convert the base 64 data in a file on disk and replace the thumbnail key by the filename
VideoSchema.path('thumbnail').validate(function (value) {
- return customValidators.isVideoThumbnailValid(value) || customValidators.isVideoThumbnail64Valid(value)
+ return customVideosValidators.isVideoThumbnailValid(value) || customVideosValidators.isVideoThumbnail64Valid(value)
})
-VideoSchema.path('tags').validate(customValidators.isVideoTagsValid)
+VideoSchema.path('tags').validate(customVideosValidators.isVideoTagsValid)
VideoSchema.methods = {
isOwned: isOwned,
)
}
- async.parallel(tasks, next)
+ parallel(tasks, next)
})
VideoSchema.pre('save', function (next) {
const tasks = []
if (video.isOwned()) {
- const videoPath = pathUtils.join(uploadsDir, video.namePath)
+ const videoPath = pathUtils.join(uploadsDir, video.filename)
this.podUrl = http + '://' + host + ':' + port
tasks.push(
}
)
- async.parallel(tasks, function (err, results) {
+ parallel(tasks, function (err, results) {
if (err) return next(err)
video.magnetUri = results[0].magnetURI
// ------------------------------ METHODS ------------------------------
function isOwned () {
- return this.namePath !== null
+ return this.filename !== null
}
function toFormatedJSON () {
name: self.name,
description: self.description,
magnetUri: self.magnetUri,
- namePath: null,
+ filename: null,
author: self.author,
duration: self.duration,
thumbnailBase64: new Buffer(thumbnailData).toString('base64'),
}
function listOwned (callback) {
- // If namePath is not null this is *our* video
- this.find({ namePath: { $ne: null } }, callback)
+ // If filename is not null this is *our* video
+ this.find({ filename: { $ne: null } }, callback)
}
function listRemotes (callback) {
- this.find({ namePath: null }, callback)
+ this.find({ filename: null }, callback)
}
function load (id, callback) {
findWithCount.call(this, query, start, count, sort, callback)
}
-// TODO
-function seedAllExisting () {
+function seedAllExisting (callback) {
+ listOwned.call(this, function (err, videos) {
+ if (err) return callback(err)
+ eachLimit(videos, constants.SEEDS_IN_PARALLEL, function (video, callbackEach) {
+ const videoPath = pathUtils.join(uploadsDir, video.filename)
+ seed(videoPath, callbackEach)
+ }, callback)
+ })
}
// ---------------------------------------------------------------------------
function findWithCount (query, start, count, sort, callback) {
const self = this
- async.parallel([
+ parallel([
function (asyncCallback) {
- self.find(query).skip(start).limit(start + count).sort(sort).exec(asyncCallback)
+ self.find(query).skip(start).limit(count).sort(sort).exec(asyncCallback)
},
function (asyncCallback) {
self.count(query, asyncCallback)
}
function removeFile (video, callback) {
- fs.unlink(uploadsDir + video.namePath, callback)
+ fs.unlink(uploadsDir + video.filename, callback)
}
// Maybe the torrent is not seeded, but we catch the error to don't stop the removing process