RanchiMall/flocore-node
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bitcoind: fix tx event to include tx buffer

Browse Source
This commit is contained in:
Braydon Fuller 2016-04-05 14:50:49 -04:00
parent 60333bcb0e
commit b473b65207
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
lib/services/bitcoind.js
View File

@ -125,9 +125,9 @@ Bitcoin.prototype._loadConfiguration = function() {
); );
$.checkState( $.checkState(
this.configuration.zmqpubhashtx, this.configuration.zmqpubrawtx,
'"zmqpubhashtx" option is required to get event updates from bitcoind. ' + '"zmqpubrawtx" option is required to get event updates from bitcoind. ' +
'Please add "zmqpubhashtx=tcp://127.0.0.1:<port>" to your configuration and restart' 'Please add "zmqpubrawtx=tcp://127.0.0.1:<port>" to your configuration and restart'
); );
$.checkState( $.checkState(
@ -157,12 +157,12 @@ Bitcoin.prototype._registerEventHandlers = function() {
var self = this; var self = this;
this.zmqSubSocket.subscribe('hashblock'); this.zmqSubSocket.subscribe('hashblock');
this.zmqSubSocket.subscribe('hashtx'); this.zmqSubSocket.subscribe('rawtx');
this.zmqSubSocket.on('message', function(topic, message) { this.zmqSubSocket.on('message', function(topic, message) {
var topicString = topic.toString('utf8'); var topicString = topic.toString('utf8');
if (topicString === 'hashtx') { if (topicString === 'rawtx') {
self.emit('tx', message.toString('hex')); self.emit('tx', message);
} else if (topicString === 'hashblock') { } else if (topicString === 'hashblock') {
self._resetCaches(); self._resetCaches();
self.tiphash = message.toString('hex'); self.tiphash = message.toString('hex');
@ -291,7 +291,7 @@ Bitcoin.prototype.start = function(callback) {
}); });
self.zmqSubSocket.monitor(500, 0); self.zmqSubSocket.monitor(500, 0);
self.zmqSubSocket.connect(self.configuration.zmqpubhashtx); self.zmqSubSocket.connect(self.configuration.zmqpubrawtx);
if (self._reindex) { if (self._reindex) {
var interval = setInterval(function() { var interval = setInterval(function() {