'use strict';

var util = require('util');
var EventEmitter = require('eventemitter2').EventEmitter2;

var bitcore = require('bitcore');
var p2p = require('bitcore-p2p');
var messages = new p2p.Messages();
var $ = bitcore.util.preconditions;

var NetworkMonitor = require('./networkmonitor');
var EventBus = require('./eventbus');
var BlockService = require('./services/block.js');

var BitcoreNode = function(bus, networkMonitor) {
  $.checkArgument(bus);
  $.checkArgument(networkMonitor);
  var self = this;
  this.bus = bus;
  this.networkMonitor = networkMonitor;

  this.blockService = new BlockService();

  this.bus.register(bitcore.Block, this.blockService.onBlock.bind(this.blockService));

  this.bus.onAny(function(value) {
    self.emit(this.event, value);
  });
  this.networkMonitor.on('error', function(err) {
    self.emit('error', err);
  });
  this.networkMonitor.on('disconnect', function() {
    console.log('network monitor disconnected');
  });

};
util.inherits(BitcoreNode, EventEmitter);

BitcoreNode.create = function(opts) {
  opts = opts || {};
  var bus = new EventBus();
  var networkMonitor = NetworkMonitor.create(bus, opts.NetworkMonitor);
  return new BitcoreNode(bus, networkMonitor);
};

BitcoreNode.prototype.start = function() {
  this.sync();
  this.networkMonitor.start();
};

BitcoreNode.prototype.sync = function() {
  var genesis = bitcore.Networks.defaultNetwork.genesis;
  var self = this;
  this.networkMonitor.on('ready', function() {
    console.log('ready');
    self.blockService.getLatest().then(function(latest) {
        var start = genesis;
        if (latest) {
          start = latest.rawHash;
        }
        console.log('Starting sync from', start);
        self.networkMonitor.syncFrom(start);
      })
      .catch(function(err) {
        self.networkMonitor.disconnect();
        throw err;
      });
  });
};


module.exports = BitcoreNode;