const async = require('async')
const chai = require('chai')
const expect = chai.expect
-const request = require('supertest')
const utils = require('./utils')
describe('Test basic friends', function () {
let servers = []
- function testMadeFriends (servers, server_to_test, callback) {
+ function makeFriends (podNumber, callback) {
+ const server = servers[podNumber - 1]
+ return utils.makeFriends(server.url, server.accessToken, callback)
+ }
+
+ function testMadeFriends (servers, serverToTest, callback) {
const friends = []
for (let i = 0; i < servers.length; i++) {
- if (servers[i].url === server_to_test.url) continue
+ if (servers[i].url === serverToTest.url) continue
friends.push(servers[i].url)
}
- utils.getFriendsList(server_to_test.url, function (err, res) {
+ utils.getFriendsList(serverToTest.url, function (err, res) {
if (err) throw err
const result = res.body
- const result_urls = [ result[0].url, result[1].url ]
expect(result).to.be.an('array')
expect(result.length).to.equal(2)
- expect(result_urls[0]).to.not.equal(result_urls[1])
- const error_string = 'Friends url do not correspond for ' + server_to_test.url
- expect(friends).to.contain(result_urls[0], error_string)
- expect(friends).to.contain(result_urls[1], error_string)
+ const resultUrls = [ result[0].url, result[1].url ]
+ expect(resultUrls[0]).to.not.equal(resultUrls[1])
+
+ const errorString = 'Friends url do not correspond for ' + serverToTest.url
+ expect(friends).to.contain(resultUrls[0], errorString)
+ expect(friends).to.contain(resultUrls[1], errorString)
callback()
})
}
before(function (done) {
this.timeout(20000)
- utils.flushAndRunMultipleServers(3, function (servers_run, urls_run) {
- servers = servers_run
- done()
+ utils.flushAndRunMultipleServers(3, function (serversRun, urlsRun) {
+ servers = serversRun
+
+ async.each(servers, function (server, callbackEach) {
+ utils.loginAndGetAccessToken(server, function (err, accessToken) {
+ if (err) return callbackEach(err)
+
+ server.accessToken = accessToken
+ callbackEach()
+ })
+ }, done)
})
})
it('Should make friends', function (done) {
this.timeout(10000)
- const path = '/api/v1/pods/makefriends'
-
async.series([
// The second pod make friend with the third
function (next) {
- request(servers[1].url)
- .get(path)
- .set('Accept', 'application/json')
- .expect(204)
- .end(next)
+ makeFriends(2, next)
},
// Wait for the request between pods
function (next) {
},
// Finally the first pod make friend with the second pod
function (next) {
- request(servers[0].url)
- .get(path)
- .set('Accept', 'application/json')
- .expect(204)
- .end(next)
+ makeFriends(1, next)
},
// Wait for the request between pods
function (next) {
})
it('Should not be allowed to make friend again', function (done) {
- utils.makeFriends(servers[1].url, 409, done)
+ const server = servers[1]
+ utils.makeFriends(server.url, server.accessToken, 409, done)
})
it('Should quit friends of pod 2', function (done) {
async.series([
// Pod 1 quit friends
function (next) {
- utils.quitFriends(servers[1].url, next)
+ const server = servers[1]
+ utils.quitFriends(server.url, server.accessToken, next)
},
// Pod 1 should not have friends anymore
function (next) {
})
it('Should allow pod 2 to make friend again', function (done) {
- utils.makeFriends(servers[1].url, function () {
+ const server = servers[1]
+ utils.makeFriends(server.url, server.accessToken, function () {
async.each(servers, function (server, callback) {
testMadeFriends(servers, server, callback)
}, done)