diff options
Diffstat (limited to 'server/tests/real-world')
-rw-r--r-- | server/tests/real-world/real-world.js | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/server/tests/real-world/real-world.js b/server/tests/real-world/real-world.js index bc6ea859b..b28796852 100644 --- a/server/tests/real-world/real-world.js +++ b/server/tests/real-world/real-world.js | |||
@@ -1,8 +1,9 @@ | |||
1 | 'use strict' | 1 | 'use strict' |
2 | 2 | ||
3 | const async = require('async') | 3 | const each = require('each') |
4 | const program = require('commander') | ||
5 | const isEqual = require('lodash/isEqual') | 4 | const isEqual = require('lodash/isEqual') |
5 | const program = require('commander') | ||
6 | const series = require('async/series') | ||
6 | 7 | ||
7 | process.env.NODE_ENV = 'test' | 8 | process.env.NODE_ENV = 'test' |
8 | const constants = require('../../initializers/constants') | 9 | const constants = require('../../initializers/constants') |
@@ -93,7 +94,7 @@ function getRandomNumServer (servers) { | |||
93 | function runServers (numberOfPods, callback) { | 94 | function runServers (numberOfPods, callback) { |
94 | let servers = null | 95 | let servers = null |
95 | 96 | ||
96 | async.series([ | 97 | series([ |
97 | // Run servers | 98 | // Run servers |
98 | function (next) { | 99 | function (next) { |
99 | utils.flushAndRunMultipleServers(numberOfPods, function (serversRun) { | 100 | utils.flushAndRunMultipleServers(numberOfPods, function (serversRun) { |
@@ -103,7 +104,7 @@ function runServers (numberOfPods, callback) { | |||
103 | }, | 104 | }, |
104 | // Get the access tokens | 105 | // Get the access tokens |
105 | function (next) { | 106 | function (next) { |
106 | async.each(servers, function (server, callbackEach) { | 107 | each(servers, function (server, callbackEach) { |
107 | utils.loginAndGetAccessToken(server, function (err, accessToken) { | 108 | utils.loginAndGetAccessToken(server, function (err, accessToken) { |
108 | if (err) return callbackEach(err) | 109 | if (err) return callbackEach(err) |
109 | 110 | ||
@@ -184,7 +185,7 @@ function remove (servers, numServer, callback) { | |||
184 | 185 | ||
185 | function checkIntegrity (servers, callback) { | 186 | function checkIntegrity (servers, callback) { |
186 | const videos = [] | 187 | const videos = [] |
187 | async.each(servers, function (server, callback) { | 188 | each(servers, function (server, callback) { |
188 | utils.getAllVideosListBy(server.url, function (err, res) { | 189 | utils.getAllVideosListBy(server.url, function (err, res) { |
189 | if (err) throw err | 190 | if (err) throw err |
190 | const serverVideos = res.body.data | 191 | const serverVideos = res.body.data |