0
Fork 0
mirror of https://github.com/verdaccio/verdaccio.git synced 2024-12-23 22:27:34 -05:00
verdaccio/test/functional/performance/race.js
2018-01-07 07:59:36 +00:00

116 lines
3 KiB
JavaScript

import assert from 'assert';
import async from 'async';
let _oksum = 0;
const racePkg = require('../fixtures/package');
export default function(server) {
describe('race', () => {
beforeAll(function () {
return server.putPackage('race', racePkg('race'))
.status(201)
.body_ok(/created new package/);
});
test('creating new package', () => {});
test('uploading 10 same versions', callback => {
let fns = [];
for (let i = 0; i < 10; i++) {
fns.push(function (cb_) {
let data = racePkg('race');
data.rand = Math.random();
let _res;
server.putVersion('race', '0.0.1', data)
.response(function (res) {
_res = res;
})
.then(function (body) {
cb_(null, [_res, body]);
});
});
}
async.parallel(fns, function (err, res) {
let okcount = 0;
let failcount = 0;
assert.equal(err, null);
res.forEach(function (arr) {
let resp = arr[0];
let body = arr[1];
if (resp.statusCode === 201 && ~body.ok.indexOf('published')) {
okcount++;
}
if (resp.statusCode === 409 && ~body.error.indexOf('already present')) {
failcount++;
}
if (resp.statusCode === 503 && ~body.error.indexOf('unavailable')) {
failcount++;
}
});
assert.equal(okcount + failcount, 10);
assert.equal(okcount, 1);
_oksum += okcount;
callback();
});
});
test('uploading 10 diff versions', callback => {
let fns = [];
for (let i = 0; i < 10; i++) {
(function (i) {
fns.push(function (cb_) {
let _res;
server.putVersion('race', '0.1.' + String(i), require('../fixtures/package')('race'))
.response(function (res) {
_res = res;
})
.then(function (body) {
cb_(null, [_res, body]);
});
});
})(i);
}
async.parallel(fns, function (err, res) {
let okcount = 0;
let failcount = 0;
assert.equal(err, null);
res.forEach(function (arr) {
let resp = arr[0];
let body = arr[1];
if (resp.statusCode === 201 && ~body.ok.indexOf('published')) {
okcount++;
}
if (resp.statusCode === 409 && ~body.error.indexOf('already present')) {
failcount++;
}
if (resp.statusCode === 503 && ~body.error.indexOf('unavailable')) {
failcount++;
}
});
assert.equal(okcount + failcount, 10);
assert.notEqual(okcount, 1);
_oksum += okcount;
callback();
});
});
afterAll(function () {
return server.getPackage('race')
.status(200)
.then(function (body) {
assert.equal(Object.keys(body.versions).length, _oksum);
});
});
});
}