diff --git a/server.js b/server.js index 33e34019d..9322bca19 100644 --- a/server.js +++ b/server.js @@ -37,6 +37,7 @@ const routes = require('./server/controllers') const utils = require('./server/helpers/utils') const webtorrent = require('./server/lib/webtorrent') const Request = mongoose.model('Request') +const Video = mongoose.model('Video') // Get configurations const port = config.get('listen.port') @@ -139,11 +140,13 @@ installer.installApplication(function (err) { // Activate the pool requests Request.activate() - // videos.seedAllExisting(function () { + Video.seedAllExisting(function (err) { + if (err) throw err + logger.info('Seeded all the videos') logger.info('Server listening on port %d', port) app.emit('ready') - // }) + }) }) }) }) diff --git a/server/models/video.js b/server/models/video.js index 8b14e9b35..b111e29aa 100644 --- a/server/models/video.js +++ b/server/models/video.js @@ -230,9 +230,15 @@ function search (value, field, start, count, sort, 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) + async.each(videos, function (video, callbackEach) { + const videoPath = pathUtils.join(uploadsDir, video.namePath) + seed(videoPath, callbackEach) + }, callback) + }) } // ---------------------------------------------------------------------------