remove config loading on poll
This commit is contained in:
parent
653b55dc1a
commit
adc1a4f353
5 changed files with 22 additions and 30 deletions
|
|
@ -1,34 +1,34 @@
|
||||||
#!/usr/bin/env node
|
#!/usr/bin/env node
|
||||||
|
|
||||||
'use strict';
|
'use strict'
|
||||||
|
|
||||||
var fs = require('fs');
|
var fs = require('fs')
|
||||||
var createServer = require('../lib/app.js');
|
var createServer = require('../lib/app.js')
|
||||||
var argv = require('minimist')(process.argv.slice(2));
|
var argv = require('minimist')(process.argv.slice(2))
|
||||||
|
|
||||||
var options = {
|
var options = {
|
||||||
postgres: process.env.DATABASE_URL
|
postgres: process.env.DATABASE_URL
|
||||||
};
|
}
|
||||||
|
|
||||||
var port = process.env.PORT || 3000;
|
var port = process.env.PORT || 3000
|
||||||
|
|
||||||
if (!argv.http) {
|
if (!argv.http) {
|
||||||
if (!argv.key || !argv.cert) {
|
if (!argv.key || !argv.cert) {
|
||||||
console.error('--key and --cert are required');
|
console.error('--key and --cert are required')
|
||||||
process.exit(1);
|
process.exit(1)
|
||||||
}
|
}
|
||||||
|
|
||||||
options.https = {
|
options.https = {
|
||||||
key: fs.readFileSync(argv.key),
|
key: fs.readFileSync(argv.key),
|
||||||
cert: fs.readFileSync(argv.cert)
|
cert: fs.readFileSync(argv.cert)
|
||||||
};
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
options.mock = argv.mock;
|
options.mock = argv.mock
|
||||||
|
|
||||||
|
var server = createServer(options)
|
||||||
|
|
||||||
var server = createServer(options);
|
|
||||||
server.listen(port, function () {
|
server.listen(port, function () {
|
||||||
console.log('lamassu-server listening on port ' + port + ' ' +
|
console.log('lamassu-server listening on port ' + port + ' ' +
|
||||||
(argv.http ? '(http)' : '(https)'));
|
(argv.http ? '(http)' : '(https)'))
|
||||||
});
|
})
|
||||||
|
|
|
||||||
13
lib/app.js
13
lib/app.js
|
|
@ -49,17 +49,6 @@ module.exports = function (options) {
|
||||||
|
|
||||||
app.use(express.bodyParser())
|
app.use(express.bodyParser())
|
||||||
|
|
||||||
var reloadConfigMiddleware = function (req, res, next) {
|
|
||||||
lamassuConfig.load(function (err, config) {
|
|
||||||
if (err) {
|
|
||||||
logger.error('Error while reloading config')
|
|
||||||
return next(err)
|
|
||||||
}
|
|
||||||
plugins.configure(config)
|
|
||||||
next()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
var authMiddleware
|
var authMiddleware
|
||||||
|
|
||||||
if (options.https) {
|
if (options.https) {
|
||||||
|
|
@ -110,7 +99,7 @@ module.exports = function (options) {
|
||||||
lamassuConfig: lamassuConfig,
|
lamassuConfig: lamassuConfig,
|
||||||
plugins: plugins,
|
plugins: plugins,
|
||||||
authMiddleware: authMiddleware,
|
authMiddleware: authMiddleware,
|
||||||
reloadConfigMiddleware: reloadConfigMiddleware,
|
// reloadConfigMiddleware: reloadConfigMiddleware,
|
||||||
mock: options.mock
|
mock: options.mock
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -555,6 +555,7 @@ function stopTrader (cryptoCode) {
|
||||||
}
|
}
|
||||||
|
|
||||||
function pollBalance (cryptoCode, cb) {
|
function pollBalance (cryptoCode, cb) {
|
||||||
|
console.trace('pollBalance')
|
||||||
logger.debug('[%s] collecting balance', cryptoCode)
|
logger.debug('[%s] collecting balance', cryptoCode)
|
||||||
|
|
||||||
var walletPlugin = walletPlugins[cryptoCode]
|
var walletPlugin = walletPlugins[cryptoCode]
|
||||||
|
|
|
||||||
|
|
@ -281,11 +281,10 @@ function init (localConfig) {
|
||||||
mock = localConfig.mock
|
mock = localConfig.mock
|
||||||
|
|
||||||
var authMiddleware = localConfig.authMiddleware
|
var authMiddleware = localConfig.authMiddleware
|
||||||
var reloadConfigMiddleware = localConfig.reloadConfigMiddleware
|
|
||||||
var app = localConfig.app
|
var app = localConfig.app
|
||||||
var localApp = localConfig.localApp
|
var localApp = localConfig.localApp
|
||||||
|
|
||||||
app.get('/poll', authMiddleware, reloadConfigMiddleware, poll)
|
app.get('/poll', authMiddleware, poll)
|
||||||
|
|
||||||
app.post('/trade', authMiddleware, trade)
|
app.post('/trade', authMiddleware, trade)
|
||||||
app.post('/send', authMiddleware, send)
|
app.post('/send', authMiddleware, send)
|
||||||
|
|
|
||||||
5
todo.txt
5
todo.txt
|
|
@ -1,4 +1,7 @@
|
||||||
- change satoshis to crypto_atoms in db (ask neal about this)
|
- change satoshis to crypto_atoms in db (ask neal about this)
|
||||||
|
|
||||||
- on upgrade, make sure we're not sending out lots of notifications
|
- on upgrade, make sure we're not sending out lots of notifications
|
||||||
- fix plugin reloading, in current version and master
|
- fix plugin reloading, in current version (v) and master
|
||||||
|
- sending two notifications on confirmation
|
||||||
|
- reproduce by setting db record to uncomfirmed, etc
|
||||||
|
- something is being called twice, especially notifyConfirmation
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue