Improve initialization of a simple node

This commit is contained in:
eordano 2015-03-25 17:52:18 -03:00 committed by Manuel Araoz
parent 541a06f5c3
commit de62831851
3 changed files with 36 additions and 5 deletions

View File

@ -25,7 +25,7 @@ Transactions.setNode = function(aNode) {
* Finds a transaction by its hash
*/
Transactions.txHashParam = function(req, res, next, txHash) {
node.getTransaction(txHash)
node.transactionService.getTransaction(txHash)
.then(function(tx) {
req.tx = tx;
})

View File

@ -4,22 +4,31 @@ var util = require('util');
var EventEmitter = require('eventemitter2').EventEmitter2;
var bitcore = require('bitcore');
var config = require('config');
var p2p = require('bitcore-p2p');
var messages = new p2p.Messages();
var $ = bitcore.util.preconditions;
var Promise = require('bluebird');
var RPC = require('bitcoind-rpc');
var NetworkMonitor = require('./networkmonitor');
var EventBus = require('./eventbus');
var BlockService = require('./services/block.js');
var BitcoreNode = function(bus, networkMonitor) {
var LevelUp = require('levelup');
var BlockService = require('./services/block');
var TransactionService = require('./services/transaction');
var AddressService = require('./services/address');
var BitcoreNode = function(bus, networkMonitor, blockService, transactionService, addressService) {
$.checkArgument(bus);
$.checkArgument(networkMonitor);
var self = this;
this.bus = bus;
this.networkMonitor = networkMonitor;
this.blockService = new BlockService();
this.addressService = addressService;
this.transactionService = transactionService;
this.blockService = blockService;
this.bus.register(bitcore.Block, this.blockService.onBlock.bind(this.blockService));
@ -38,9 +47,30 @@ 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);
var database = new LevelUp(opts.LevelUp || config.get('LevelUp'));
var rpc = Promise.promisifyAll(new RPC(config.get('RPC')));
var transactionService = new TransactionService({
rpc: rpc,
database: database
});
var blockService = new BlockService({
rpc: rpc,
database: database,
transactionService: transactionService
});
var addressService = new AddressService({
rpc: rpc,
database: database,
transactionService: transactionService,
blockService: blockService
});
return new BitcoreNode(bus, networkMonitor, blockService, transactionService, addressService);
};
BitcoreNode.prototype.start = function() {

View File

@ -3,6 +3,7 @@
var Promise = require('bluebird');
var bitcore = require('bitcore');
var TransactionService = require('./transaction');
var RPC = require('bitcoind-rpc');
var _ = bitcore.deps._;
var NULLTXHASH = bitcore.util.buffer.emptyBuffer(32).toString('hex');