'use strict'
-var child_process = require('child_process')
-var exec = child_process.exec
-var fork = child_process.fork
-var pathUtils = require('path')
-var request = require('supertest')
+const child_process = require('child_process')
+const exec = child_process.exec
+const fork = child_process.fork
+const pathUtils = require('path')
+const request = require('supertest')
-var testUtils = {
+const testUtils = {
flushTests: flushTests,
getFriendsList: getFriendsList,
getVideosList: getVideosList,
}
function getFriendsList (url, end) {
- var path = '/api/v1/pods/'
+ const path = '/api/v1/pods/'
request(url)
.get(path)
}
function getVideosList (url, end) {
- var path = '/api/v1/videos'
+ const path = '/api/v1/videos'
request(url)
.get(path)
expected_status = 204
}
- var path = '/api/v1/pods/makefriends'
+ const path = '/api/v1/pods/makefriends'
// The first pod make friend with the third
request(url)
}
function quitFriends (url, callback) {
- var path = '/api/v1/pods/quitfriends'
+ const path = '/api/v1/pods/quitfriends'
// The first pod make friend with the third
request(url)
}
function removeVideo (url, id, end) {
- var path = '/api/v1/videos'
+ const path = '/api/v1/videos'
request(url)
.delete(path + '/' + id)
}
function flushAndRunMultipleServers (total_servers, serversRun) {
- var apps = []
- var urls = []
- var i = 0
+ let apps = []
+ let urls = []
+ let i = 0
function anotherServerDone (number, app, url) {
apps[number - 1] = app
}
flushTests(function () {
- for (var j = 1; j <= total_servers; j++) {
- (function (k) { // TODO: ES6 with let
- // For the virtual buffer
- setTimeout(function () {
- runServer(k, function (app, url) {
- anotherServerDone(k, app, url)
- })
- }, 1000 * k)
- })(j)
+ for (let j = 1; j <= total_servers; j++) {
+ // For the virtual buffer
+ setTimeout(function () {
+ runServer(j, function (app, url) {
+ anotherServerDone(j, app, url)
+ })
+ }, 1000 * j)
}
})
}
function runServer (number, callback) {
- var port = 9000 + number
- var server_run_string = {
+ const port = 9000 + number
+ const server_run_string = {
'Connected to mongodb': false,
'Server listening on port': false
}
// Share the environment
- var env = Object.create(process.env)
+ const env = Object.create(process.env)
env.NODE_ENV = 'test'
env.NODE_APP_INSTANCE = number
- var options = {
+ const options = {
silent: true,
env: env,
detached: true
}
- var app = fork(pathUtils.join(__dirname, '../../../server.js'), [], options)
+ const app = fork(pathUtils.join(__dirname, '../../../server.js'), [], options)
app.stdout.on('data', function onStdout (data) {
- var dont_continue = false
+ let dont_continue = false
// Check if all required sentences are here
- for (var key of Object.keys(server_run_string)) {
+ for (const key of Object.keys(server_run_string)) {
if (data.toString().indexOf(key) !== -1) server_run_string[key] = true
if (server_run_string[key] === false) dont_continue = true
}
}
function searchVideo (url, search, end) {
- var path = '/api/v1/videos'
+ const path = '/api/v1/videos'
request(url)
.get(path + '/search/' + search)
}
function uploadVideo (url, name, description, fixture, end) {
- var path = '/api/v1/videos'
+ const path = '/api/v1/videos'
request(url)
.post(path)
.field('name', name)
.field('description', description)
.attach('input_video', pathUtils.join(__dirname, 'fixtures', fixture))
- .expect(201)
+ .expect(204)
.end(end)
}