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

fix integration tests for testnet

Browse Source
This commit is contained in:
Manuel Araoz 2015-04-20 16:24:17 -03:00
parent f01d6c98fb
commit c3ead97d64
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
integration/bitcoind.js
View File

@ -17,12 +17,14 @@ var Pool = p2p.Pool;
var Networks = bitcore.Networks;
var Messages = p2p.Messages;
var Inventory = p2p.Inventory;
var messages = new Messages();
var Block = bitcore.Block;
var Transaction = bitcore.Transaction;
// config
var network = process.env.NETWORK === 'testnet'? Networks.testnet: Networks.livenet;
var network = process.env.NETWORK === 'testnet' ? Networks.testnet : Networks.livenet;
var messages = new Messages({
network: network
});
var blockHash = {
'livenet': '000000000000000013413cf2536b491bf0988f52e90c476ffeb701c8bfdb1db9',
'testnet': '0000000058cc069d964711cd25083c0a709f4df2b34c8ff9302ce71fe5b45786'
@ -175,11 +177,10 @@ describe('Integration with ' + network.name + ' bitcoind', function() {
peer.sendMessage(message);
});
});
it.only('gets blocks', function(cb) {
it('gets blocks', function(cb) {
connect(function(peer) {
peer.once('inv', function(message) {
message.command.should.equal('inv');
console.log('LLEGO UN INV', message.inventory.length);
if (message.inventory.length === 2) {
message.inventory[0].type.should.equal(Inventory.TYPE.BLOCK);
message.inventory[1].type.should.equal(Inventory.TYPE.BLOCK);

2
lib/peer.js
View File

@ -191,7 +191,6 @@ Peer.prototype.disconnect = function() {
* @param {Message} message - A message instance
*/
Peer.prototype.sendMessage = function(message) {
console.log('>sending', message.command);
this.socket.write(message.toBuffer());
};
@ -219,7 +218,6 @@ Peer.prototype._sendPong = function(nonce) {
Peer.prototype._readMessage = function() {
var message = this.messages.parseBuffer(this.dataBuffer);
if (message) {
console.log('<read', message.command);
this.emit(message.command, message);
this._readMessage();
}