update to new bitcore-p2p version
This commit is contained in:
parent
59fcb44045
commit
50673f247a
1
index.js
1
index.js
@ -1,6 +1,5 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
|
|
||||||
var BitcoreNode = require('./lib/node');
|
var BitcoreNode = require('./lib/node');
|
||||||
var bitcore = require('bitcore');
|
var bitcore = require('bitcore');
|
||||||
var Unit = bitcore.Unit;
|
var Unit = bitcore.Unit;
|
||||||
|
|||||||
@ -8,7 +8,7 @@ var Networks = bitcore.Networks;
|
|||||||
var $ = bitcore.util.preconditions;
|
var $ = bitcore.util.preconditions;
|
||||||
var p2p = require('bitcore-p2p');
|
var p2p = require('bitcore-p2p');
|
||||||
var Peer = p2p.Peer;
|
var Peer = p2p.Peer;
|
||||||
var Messages = p2p.Messages;
|
var messages = new p2p.Messages();
|
||||||
|
|
||||||
function NetworkMonitor(eventBus, peer) {
|
function NetworkMonitor(eventBus, peer) {
|
||||||
$.checkArgument(eventBus);
|
$.checkArgument(eventBus);
|
||||||
@ -36,7 +36,7 @@ NetworkMonitor.prototype.setupPeer = function(peer) {
|
|||||||
});
|
});
|
||||||
peer.on('inv', function(m) {
|
peer.on('inv', function(m) {
|
||||||
// TODO only ask for data if tx or block is unknown
|
// TODO only ask for data if tx or block is unknown
|
||||||
peer.sendMessage(new Messages.GetData(m.inventory));
|
peer.sendMessage(messages.GetData(m.inventory));
|
||||||
});
|
});
|
||||||
peer.on('tx', function(m) {
|
peer.on('tx', function(m) {
|
||||||
self.bus.process(m.transaction);
|
self.bus.process(m.transaction);
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user