Function findPeer

examples/bitcoin.js:9–77

(pool)

var shutdown = false;
var p = false;
var findPeer = function findPeer(pool) {
  if (pool.length == 0) {
    console.log('No more potential peers...');
    return;
  }
  
  console.log('Finding new peer from pool of '+pool.length+' potential peers');
  p = new Peer(pool.shift());
  
  var connectTimeout = setTimeout(function() { // Give them a few seconds to respond, otherwise close the connection automatically
    console.log('Peer never connected; hanging up');
    p.destroy();
  }, 5*1000);
  connectTimeout.unref();
  var verackTimeout = false;

  p.on('connect', function(d) {
    console.log('connect');
    clearTimeout(connectTimeout);

    // Send VERSION message
    var m = new Message(p.magicBytes, true);
    m.putInt32(70000); // version
    m.putInt64(1); // services
    m.putInt64(Math.round(new Date().getTime()/1000)); // timestamp
    m.pad(26); // addr_me
    m.pad(26); // addr_you
    m.putInt64(0x1234); // nonce
    m.putVarString('Node.js lite peer');
    m.putInt32(10); // start_height
  
    //console.log(m.raw().toString('hex'));
    console.log('Sending VERSION message');
    verackTimeout = setTimeout(function() {
      console.log('No VERACK received; disconnect');
      p.destroy();
    }, 10000);
    verackTimeout.unref();
    p.once('verackMessage', function() {
      console.log('VERACK received; this peer is active now');  
      clearTimeout(verackTimeout);
    });
    p.send('version', m.raw());
  });
  p.on('end', function(d) {
    console.log('end');
  });
  p.on('error', function(d) {
    console.log('error', d);
    d.peer.destroy();
  });
  p.on('close', function(d) {
    console.log('close', d);
    if (shutdown === false) {
      console.log('Connection closed, trying next...');
      setImmediate(function() {
        clearTimeout(connectTimeout);
        clearTimeout(verackTimeout);