Skip to content

Commit a6776c2

Browse files
committed
use single rippleAPI instance
1 parent e05a9c3 commit a6776c2

File tree

9 files changed

+21
-23
lines changed

9 files changed

+21
-23
lines changed

api/index.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,8 @@ var Server = require('./server');
33
var options = {
44
postgres : config.get('postgres'),
55
hbase : config.get('hbase'),
6-
port : config.get('port')
6+
port : config.get('port'),
7+
ripple : config.get('ripple')
78
}
89

910
var server = new Server(options);

api/routesV2/accountBalances.js

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,13 +4,9 @@ var Logger = require('../../lib/logger');
44
var log = new Logger({scope : 'account balances'});
55
var request = require('request');
66
var smoment = require('../../lib/smoment');
7-
var config = require('../../config/api.config');
8-
var ripple = require('ripple-lib');
9-
var rippleAPI = new ripple.RippleAPI(config.get('ripple'));
7+
var rippleAPI;
108
var hbase;
119

12-
rippleAPI.connect();
13-
1410
var accountBalances = function (req, res, next) {
1511

1612
var options = {
@@ -156,7 +152,8 @@ var accountBalances = function (req, res, next) {
156152
}
157153
};
158154

159-
module.exports = function(db) {
155+
module.exports = function(db, r) {
160156
hbase = db;
157+
rippleAPI = r;
161158
return accountBalances;
162159
};

api/routesV2/accountOrders.js

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,13 +4,9 @@ var Logger = require('../../lib/logger');
44
var log = new Logger({scope : 'account orders'});
55
var request = require('request');
66
var smoment = require('../../lib/smoment');
7-
var config = require('../../config/api.config');
8-
var ripple = require('ripple-lib');
9-
var rippleAPI = new ripple.RippleAPI(config.get('ripple'));
7+
var rippleAPI;
108
var hbase;
119

12-
rippleAPI.connect();
13-
1410
function accountOrders(req, res) {
1511
var options = {
1612
ledger_index: req.query.ledger_index || req.query.ledger,
@@ -153,7 +149,8 @@ function accountOrders(req, res) {
153149
}
154150
}
155151

156-
module.exports = function(db) {
152+
module.exports = function(db, r) {
157153
hbase = db;
154+
rippleAPI = r;
158155
return accountOrders;
159156
};

api/routesV2/index.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
'use strict';
22

3-
module.exports = function(db) {
3+
module.exports = function(db, rippleAPI) {
44
var Routes = { };
55

66
Routes.getLedger = require('./getLedger')(db);
@@ -9,8 +9,8 @@ module.exports = function(db) {
99
Routes.accountTransactions = require('./accountTransactions')(db);
1010
Routes.accountExchanges = require('./accountExchanges')(db);
1111
Routes.accountPayments = require('./accountPayments')(db);
12-
Routes.accountBalances = require('./accountBalances')(db);
13-
Routes.accountOrders = require('./accountOrders')(db);
12+
Routes.accountBalances = require('./accountBalances')(db, rippleAPI);
13+
Routes.accountOrders = require('./accountOrders')(db, rippleAPI);
1414
Routes.getChanges = require('./accountBalanceChanges')(db);
1515
Routes.getPayments = require('./getPayments')(db);
1616
Routes.getExchanges = require('./getExchanges')(db);

api/server.js

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,15 +11,19 @@ var RoutesV2 = require('./routesV2');
1111
var map = require('./apiMap');
1212
var json2csv = require('nice-json2csv');
1313
var favicon = require('serve-favicon');
14+
var ripple = require('ripple-lib');
1415

1516
var Server = function (options) {
17+
var rippleAPI = new ripple.RippleAPI(options.ripple);
1618
var app = express();
1719
var hbase;
1820
var routesV2;
1921
var postgres;
2022
var routes;
2123
var server;
2224

25+
rippleAPI.connect();
26+
2327
app.use(bodyParser.json());
2428
app.use(bodyParser.urlencoded({extended:true}));
2529
app.use(json2csv.expressDecorator);
@@ -40,7 +44,7 @@ var Server = function (options) {
4044
// v2 routes (requires hbase)
4145
if (options.hbase) {
4246
hbase = new Hbase(options.hbase);
43-
routesV2 = RoutesV2(hbase);
47+
routesV2 = RoutesV2(hbase, rippleAPI);
4448

4549
app.get('/v2/health/:aspect?', routesV2.checkHealth);
4650
app.get('/v2/gateways/:gateway?', routesV2.gateways.Gateways);

config/api.config.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,5 +3,5 @@ var nconf = require('nconf');
33
nconf.argv()
44
.env()
55
.file({ file: './config/api.config.json' });
6-
7-
module.exports = nconf;
6+
7+
module.exports = nconf;

config/import.config.js

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,5 +3,4 @@ var nconf = require('nconf');
33
nconf.argv()
44
.env()
55
.file({ file: './config/import.config.json' });
6-
7-
module.exports = nconf;
6+
module.exports = nconf;

test/hbaseTests/setup.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
var config = require('../../config/import.config');
21
var Server = require('../../api/server');
2+
var config = require('../../config/import.config');
33
var assert = require('assert');
44
var request = require('request');
55
var hbaseConfig = config.get('hbase');

test/hbaseTests/test.network.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ describe('network - exchange volume', function() {
3131
hbase.putRow(table, 'payment_volume|day|20150114000000', mockPaymentVolume),
3232
hbase.putRow(table, 'issued_value|20150114000000', mockIssuedValue),
3333
hbase.putRow(table, 'issued_value|20150113000000', mockIssuedValue)
34-
]).nodeify(function(err, resp){
34+
]).nodeify(function(err, resp) {
3535
assert.ifError(err);
3636
done();
3737
});

0 commit comments

Comments
 (0)