X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2FpoolRequests.js;h=2eb501311d487ade69def8081ba7730c55fa9985;hb=f0f5567b6918fc60c8cab15e13aec03a89a91dfb;hp=f786c3c7a4c3657a657c0883f8d8035e88866762;hpb=b9a3e09ad5a7673f64556d1dba122ed4c4fac980;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/poolRequests.js b/server/lib/poolRequests.js index f786c3c7a..2eb501311 100644 --- a/server/lib/poolRequests.js +++ b/server/lib/poolRequests.js @@ -1,18 +1,18 @@ 'use strict' -var async = require('async') -var pluck = require('lodash-node/compat/collection/pluck') +const async = require('async') +const pluck = require('lodash-node/compat/collection/pluck') -var constants = require('../initializers/constants') -var logger = require('../helpers/logger') -var Pods = require('../models/pods') -var PoolRequests = require('../models/poolRequests') -var requests = require('../helpers/requests') -var Videos = require('../models/videos') +const constants = require('../initializers/constants') +const logger = require('../helpers/logger') +const Pods = require('../models/pods') +const PoolRequests = require('../models/poolRequests') +const requests = require('../helpers/requests') +const Videos = require('../models/videos') -var timer = null +let timer = null -var poolRequests = { +const poolRequests = { activate: activate, addRequest: addRequest, deactivate: deactivate, @@ -77,7 +77,7 @@ function makePoolRequest (type, requests_to_make, callback) { Pods.list(function (err, pods) { if (err) return callback(err) - var params = { + const params = { encrypt: true, sign: true, method: 'POST', @@ -93,8 +93,8 @@ function makePoolRequest (type, requests_to_make, callback) { return callback(new Error('Unkown pool request type.')) } - var bad_pods = [] - var good_pods = [] + const bad_pods = [] + const good_pods = [] requests.makeMultipleRetryRequest(params, pods, callbackEachPodFinished, callbackAllPodsFinished) @@ -129,7 +129,7 @@ function makePoolRequests () { if (pool_requests.length === 0) return - var requests_to_make = { + const requests_to_make = { add: { ids: [], requests: [] @@ -184,14 +184,14 @@ function removeBadPods () { if (pods.length === 0) return - var urls = pluck(pods, 'url') - var ids = pluck(pods, '_id') + const urls = pluck(pods, 'url') + const ids = pluck(pods, '_id') Videos.removeAllRemotesOf(urls, function (err, r) { if (err) { logger.error('Cannot remove videos from a pod that we removing.', { error: err }) } else { - var videos_removed = r.result.n + const videos_removed = r.result.n logger.info('Removed %d videos.', videos_removed) } @@ -199,7 +199,7 @@ function removeBadPods () { if (err) { logger.error('Cannot remove bad pods.', { error: err }) } else { - var pods_removed = r.result.n + const pods_removed = r.result.n logger.info('Removed %d pods.', pods_removed) } })