96 lines
2.3 KiB
JavaScript
96 lines
2.3 KiB
JavaScript
'use strict';
|
|
|
|
var _trader;
|
|
var _lamassuConfig;
|
|
|
|
// Make sure these are higher than polling interval
|
|
// or there will be a lot of errors
|
|
var STALE_TICKER = 180000;
|
|
var STALE_BALANCE = 180000;
|
|
|
|
Error.prototype.toJSON = function () {
|
|
var self = this;
|
|
var ret = {};
|
|
Object.getOwnPropertyNames(self).forEach(function (key) {
|
|
ret[key] = self[key];
|
|
});
|
|
return ret;
|
|
};
|
|
|
|
var poll = function(req, res) {
|
|
if (req.device.unpair) {
|
|
return res.json({
|
|
unpair: true
|
|
});
|
|
}
|
|
|
|
var rateRec = _trader.rate(req.params.currency);
|
|
var satoshiBalanceRec = _trader.balance;
|
|
|
|
// `rateRec` and `satoshiBalanceRec` are both objects, so there's no danger
|
|
// of misinterpreting rate or balance === 0 as 'Server initializing'.
|
|
if (!rateRec || !satoshiBalanceRec) {
|
|
return res.json({err: 'Server initializing'});
|
|
}
|
|
|
|
if (Date.now() - rateRec.timestamp > STALE_TICKER) {
|
|
return res.json({err: 'Stale ticker'});
|
|
}
|
|
|
|
if (Date.now() - rateRec.timestamp > STALE_BALANCE) {
|
|
return res.json({err: 'Stale balance'});
|
|
}
|
|
|
|
var rate = rateRec.rate;
|
|
|
|
res.json({
|
|
err: null,
|
|
rate: rate * _trader.config.exchanges.settings.commission,
|
|
fiat: _trader.fiatBalance(0, 0),
|
|
currency: req.params.currency,
|
|
txLimit: parseInt(_trader.config.exchanges.settings.compliance.maximum.limit, 10)
|
|
});
|
|
};
|
|
|
|
var trade = function (req, res) {
|
|
_trader.trade(req.body.fiat, req.body.satoshis, req.body.currency, function(err) {
|
|
res.json({err: err});
|
|
});
|
|
};
|
|
|
|
var send = function(req, res) {
|
|
var fingerprint = req.connection.getPeerCertificate().fingerprint;
|
|
_trader.sendBitcoins(fingerprint, req.body, function(err, txHash) {
|
|
res.json({err: err, txHash: txHash});
|
|
});
|
|
};
|
|
|
|
var pair = function(req, res) {
|
|
var token = req.body.token;
|
|
var name = req.body.name;
|
|
|
|
_lamassuConfig.pair(
|
|
token,
|
|
req.connection.getPeerCertificate().fingerprint,
|
|
name,
|
|
function(err) {
|
|
if (err) {
|
|
return res.json(500, { err: err.message });
|
|
}
|
|
|
|
res.json(200);
|
|
}
|
|
);
|
|
};
|
|
|
|
exports.init = function(app, config, trader, authMiddleware) {
|
|
_lamassuConfig = config;
|
|
_trader = trader;
|
|
|
|
app.get('/poll/:currency', authMiddleware, poll);
|
|
app.post('/send', authMiddleware, send);
|
|
app.post('/trade', authMiddleware, trade);
|
|
app.post('/pair', pair);
|
|
|
|
return app;
|
|
};
|