RanchiMall/fcoin
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

http: add to mempool and broadcast.

Browse Source
This commit is contained in:
Christopher Jeffrey 2016-04-08 17:50:47 -07:00
parent 819b75e21b
commit 94f7bf000b
No known key found for this signature in database
GPG Key ID: 8962AB9DE6666BBD
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
lib/bcoin/http/server.js
View File

@ -28,6 +28,7 @@ function NodeServer(options) {
assert(this.node, 'HTTP requires a Node.');
this.walletdb = this.node.walletdb;
this.mempool = this.node.mempool;
this.pool = this.node.pool;
this.loaded = false;
@ -310,7 +311,7 @@ NodeServer.prototype._init = function _init() {
if (err)
return next(err);
self.pool.sendTX(tx, function(err) {
addTX(tx, function(err) {
if (err)
return next(err);
@ -320,6 +321,20 @@ NodeServer.prototype._init = function _init() {
});
});
function addMempool(tx, callback) {
if (!self.mempool)
return callback();
self.mempool.addTX(tx, callback);
}
function addTX(tx, callback) {
addMempool(tx, function(err) {
if (err)
return callback(err);
self.pool.broadcast(tx, callback);
});
}
// Zap Wallet TXs
this.post('/wallet/:id/zap', function(req, res, next, send) {
var id = req.options.id;
@ -498,7 +513,7 @@ NodeServer.prototype._init = function _init() {
// Broadcast TX
this.post('/broadcast', function(req, res, next, send) {
self.pool.sendTX(tx, function(err) {
self.pool.sendTX(req.options.tx, function(err) {
if (err)
return callback(err);