278 lines
9.3 KiB
JavaScript
278 lines
9.3 KiB
JavaScript
'use strict';
|
|
|
|
var chai = require('chai');
|
|
var sinon = require('sinon');
|
|
var request = require('request');
|
|
var http = require('http');
|
|
var should = chai.should();
|
|
var proxyquire = require('proxyquire');
|
|
var config = require('../config.js');
|
|
|
|
var Common = require('../lib/common');
|
|
var Defaults = Common.Defaults;
|
|
|
|
|
|
|
|
describe('ExpressApp', function() {
|
|
describe('#constructor', function() {
|
|
it('will set an express app', function() {
|
|
var TestExpressApp = proxyquire('../lib/expressapp', {});
|
|
var express = new TestExpressApp();
|
|
should.exist(express.app);
|
|
should.exist(express.app.use);
|
|
should.exist(express.app.enable);
|
|
});
|
|
});
|
|
describe('#start', function() {
|
|
it('will listen at the specified port', function(done) {
|
|
var initialize = sinon.stub().callsArg(1);
|
|
var TestExpressApp = proxyquire('../lib/expressapp', {
|
|
'./server': {
|
|
initialize: initialize
|
|
}
|
|
});
|
|
var app = new TestExpressApp();
|
|
var options = {};
|
|
app.start(config, function(err) {
|
|
should.not.exist(err);
|
|
initialize.callCount.should.equal(1);
|
|
done();
|
|
});
|
|
});
|
|
|
|
describe('Routes', function() {
|
|
var testPort = 3239;
|
|
var testHost = 'http://127.0.0.1';
|
|
var httpServer;
|
|
|
|
function start(ExpressApp, done) {
|
|
var app = new ExpressApp();
|
|
httpServer = http.Server(app.app);
|
|
|
|
app.start(config, function(err) {
|
|
should.not.exist(err);
|
|
httpServer.listen(testPort);
|
|
done();
|
|
});
|
|
};
|
|
|
|
afterEach(function() {
|
|
httpServer.close();
|
|
});
|
|
|
|
it('/v2/wallets', function(done) {
|
|
var server = {
|
|
getStatus: sinon.stub().callsArgWith(1, null, {}),
|
|
};
|
|
var TestExpressApp = proxyquire('../lib/expressapp', {
|
|
'./server': {
|
|
initialize: sinon.stub().callsArg(1),
|
|
getInstanceWithAuth: sinon.stub().callsArgWith(1, null, server),
|
|
}
|
|
});
|
|
start(TestExpressApp, function() {
|
|
var requestOptions = {
|
|
url: testHost + ':' + testPort + config.basePath + '/v2/wallets',
|
|
headers: {
|
|
'x-identity': 'identity',
|
|
'x-signature': 'signature'
|
|
}
|
|
};
|
|
request(requestOptions, function(err, res, body) {
|
|
should.not.exist(err);
|
|
should.exist(res.headers['x-service-version']);
|
|
res.headers['x-service-version'].should.equal('bws-' + require('../package').version);
|
|
res.statusCode.should.equal(200);
|
|
body.should.equal('{}');
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
|
|
it('/v1/addresses', function(done) {
|
|
var server = {
|
|
getMainAddresses: sinon.stub().callsArgWith(1, null, {}),
|
|
};
|
|
var TestExpressApp = proxyquire('../lib/expressapp', {
|
|
'./server': {
|
|
initialize: sinon.stub().callsArg(1),
|
|
getInstanceWithAuth: sinon.stub().callsArgWith(1, null, server),
|
|
}
|
|
});
|
|
start(TestExpressApp, function() {
|
|
var requestOptions = {
|
|
url: testHost + ':' + testPort + config.basePath + '/v1/addresses?limit=4&reverse=1',
|
|
headers: {
|
|
'x-identity': 'identity',
|
|
'x-signature': 'signature'
|
|
}
|
|
};
|
|
request(requestOptions, function(err, res, body) {
|
|
should.not.exist(err);
|
|
res.statusCode.should.equal(200);
|
|
var args = server.getMainAddresses.getCalls()[0].args[0];
|
|
args.limit.should.equal(4);
|
|
args.reverse.should.be.true;
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
|
|
it('/v1/sendmaxinfo', function(done) {
|
|
var server = {
|
|
getSendMaxInfo: sinon.stub().callsArgWith(1, null, {
|
|
amount: 123
|
|
}),
|
|
};
|
|
var TestExpressApp = proxyquire('../lib/expressapp', {
|
|
'./server': {
|
|
initialize: sinon.stub().callsArg(1),
|
|
getInstanceWithAuth: sinon.stub().callsArgWith(1, null, server),
|
|
}
|
|
});
|
|
start(TestExpressApp, function() {
|
|
var requestOptions = {
|
|
url: testHost + ':' + testPort + config.basePath + '/v1/sendmaxinfo?feePerKb=10000&returnInputs=1',
|
|
headers: {
|
|
'x-identity': 'identity',
|
|
'x-signature': 'signature'
|
|
}
|
|
};
|
|
request(requestOptions, function(err, res, body) {
|
|
should.not.exist(err);
|
|
res.statusCode.should.equal(200);
|
|
var args = server.getSendMaxInfo.getCalls()[0].args[0];
|
|
args.feePerKb.should.equal(10000);
|
|
args.returnInputs.should.be.true;
|
|
JSON.parse(body).amount.should.equal(123);
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('Balance', function() {
|
|
it('should handle cache argument', function(done) {
|
|
var server = {
|
|
getBalance: sinon.stub().callsArgWith(1, null, {}),
|
|
};
|
|
var TestExpressApp = proxyquire('../lib/expressapp', {
|
|
'./server': {
|
|
initialize: sinon.stub().callsArg(1),
|
|
getInstanceWithAuth: sinon.stub().callsArgWith(1, null, server),
|
|
}
|
|
});
|
|
start(TestExpressApp, function() {
|
|
var reqOpts = {
|
|
url: testHost + ':' + testPort + config.basePath + '/v1/balance',
|
|
headers: {
|
|
'x-identity': 'identity',
|
|
'x-signature': 'signature'
|
|
}
|
|
};
|
|
request(reqOpts, function(err, res, body) {
|
|
should.not.exist(err);
|
|
res.statusCode.should.equal(200);
|
|
var args = server.getBalance.getCalls()[0].args[0];
|
|
should.not.exist(args.twoStep);
|
|
|
|
reqOpts.url += '?twoStep=1';
|
|
request(reqOpts, function(err, res, body) {
|
|
should.not.exist(err);
|
|
res.statusCode.should.equal(200);
|
|
var args = server.getBalance.getCalls()[1].args[0];
|
|
args.twoStep.should.equal(true);
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('/v1/notifications', function(done) {
|
|
var server, TestExpressApp, clock;
|
|
beforeEach(function() {
|
|
clock = sinon.useFakeTimers(2000000000, 'Date');
|
|
|
|
server = {
|
|
getNotifications: sinon.stub().callsArgWith(1, null, {})
|
|
};
|
|
TestExpressApp = proxyquire('../lib/expressapp', {
|
|
'./server': {
|
|
initialize: sinon.stub().callsArg(1),
|
|
getInstanceWithAuth: sinon.stub().callsArgWith(1, null, server),
|
|
}
|
|
});
|
|
});
|
|
afterEach(function() {
|
|
clock.restore();
|
|
});
|
|
|
|
it('should fetch notifications from a specified id', function(done) {
|
|
start(TestExpressApp, function() {
|
|
var requestOptions = {
|
|
url: testHost + ':' + testPort + config.basePath + '/v1/notifications' + '?notificationId=123',
|
|
headers: {
|
|
'x-identity': 'identity',
|
|
'x-signature': 'signature'
|
|
}
|
|
};
|
|
request(requestOptions, function(err, res, body) {
|
|
should.not.exist(err);
|
|
res.statusCode.should.equal(200);
|
|
body.should.equal('{}');
|
|
server.getNotifications.calledWith({
|
|
notificationId: '123',
|
|
minTs: +Date.now() - Defaults.NOTIFICATIONS_TIMESPAN * 1000,
|
|
}).should.be.true;
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
it('should allow custom minTs within limits', function(done) {
|
|
start(TestExpressApp, function() {
|
|
var requestOptions = {
|
|
url: testHost + ':' + testPort + config.basePath + '/v1/notifications' + '?timeSpan=30',
|
|
headers: {
|
|
'x-identity': 'identity',
|
|
'x-signature': 'signature'
|
|
}
|
|
};
|
|
request(requestOptions, function(err, res, body) {
|
|
should.not.exist(err);
|
|
res.statusCode.should.equal(200);
|
|
server.getNotifications.calledWith({
|
|
notificationId: undefined,
|
|
minTs: +Date.now() - 30000,
|
|
}).should.be.true;
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
it('should limit minTs to Defaults.MAX_NOTIFICATIONS_TIMESPAN', function(done) {
|
|
start(TestExpressApp, function() {
|
|
var overLimit = Defaults.MAX_NOTIFICATIONS_TIMESPAN * 2;
|
|
var requestOptions = {
|
|
url: testHost + ':' + testPort + config.basePath + '/v1/notifications' + '?timeSpan=' + overLimit ,
|
|
headers: {
|
|
'x-identity': 'identity',
|
|
'x-signature': 'signature'
|
|
}
|
|
};
|
|
request(requestOptions, function(err, res, body) {
|
|
should.not.exist(err);
|
|
res.statusCode.should.equal(200);
|
|
body.should.equal('{}');
|
|
|
|
server.getNotifications.calledWith({
|
|
notificationId: undefined,
|
|
minTs: Date.now() - Defaults.MAX_NOTIFICATIONS_TIMESPAN * 1000, // override minTs argument
|
|
}).should.be.true;
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
});
|
|
});
|
|
});
|
|
});
|