commit
ae13cb3b55
@ -41,8 +41,5 @@
|
|||||||
"it",
|
"it",
|
||||||
"module",
|
"module",
|
||||||
"require"
|
"require"
|
||||||
],
|
]
|
||||||
"globals" : {
|
|
||||||
"Promise" : true
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
4
config/default.yml
Normal file
4
config/default.yml
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
NetworkMonitor:
|
||||||
|
network: livenet
|
||||||
|
host: localhost
|
||||||
|
port: 8333
|
||||||
136
index.js
136
index.js
@ -1,134 +1,26 @@
|
|||||||
#!/usr/bin/env node
|
|
||||||
|
|
||||||
'use strict';
|
'use strict';
|
||||||
//Set the node enviornment variable if not set before
|
|
||||||
process.env.NODE_ENV = process.env.NODE_ENV || 'development';
|
|
||||||
|
|
||||||
var fs = require('fs');
|
|
||||||
var PeerSync = require('./lib/PeerSync');
|
|
||||||
var HistoricSync = require('./lib/HistoricSync');
|
|
||||||
|
|
||||||
var http = require('http');
|
var config = require('config');
|
||||||
var https = require('https');
|
|
||||||
var express = require('express');
|
|
||||||
var program = require('commander');
|
|
||||||
|
|
||||||
var config = require('./config/config');
|
var bitcore = require('bitcore');
|
||||||
var logger = require('./lib/logger').logger;
|
|
||||||
program
|
|
||||||
.version(config.version);
|
|
||||||
|
|
||||||
// text title
|
var NetworkMonitor = require('./lib/networkmonitor');
|
||||||
console.log(
|
var EventBus = require('./lib/eventbus');
|
||||||
'bitcore-node',
|
|
||||||
'\n\t\t\t\t\t\tv%s\n', config.version);
|
|
||||||
program.on('--help', function() {
|
var bus = new EventBus();
|
||||||
logger.info('\n# Configuration:\n\
|
var nm = NetworkMonitor.create(bus, config.get('NetworkMonitor'));
|
||||||
\tBLOCKCHAIN_API_NETWORK (Network): %s\n\
|
|
||||||
\tBLOCKCHAIN_API_DB (Database Path): %s\n\
|
bus.register(bitcore.Transaction, function(tx) {
|
||||||
\tBLOCKCHAIN_API_SAFE_CONFIRMATIONS (Safe Confirmations): %s\n\
|
console.log('Transaction:', tx.id);
|
||||||
\tBLOCKCHAIN_API_IGNORE_CACHE (Ignore Cache): %s\n\
|
|
||||||
# Bicoind Connection configuration:\n\
|
|
||||||
\tRPC Username: %s\t\tBITCOIND_USER\n\
|
|
||||||
\tRPC Password: %s\tBITCOIND_PASS\n\
|
|
||||||
\tRPC Protocol: %s\t\tBITCOIND_PROTO\n\
|
|
||||||
\tRPC Host: %s\t\tBITCOIND_HOST\n\
|
|
||||||
\tRPC Port: %s\t\t\tBITCOIND_PORT\n\
|
|
||||||
\tP2P Port: %s\t\t\tBITCOIND_P2P_PORT\n\
|
|
||||||
\tBITCOIND_DATADIR: %s\n\
|
|
||||||
\t%s\n\
|
|
||||||
\nChange setting by assigning the enviroment variables above. Example:\n\
|
|
||||||
$ BLOCKCHAIN_API_NETWORK="testnet" BITCOIND_HOST="123.123.123.123" ./index.js\
|
|
||||||
\n\n',
|
|
||||||
config.network, config.leveldb, config.safeConfirmations, config.ignoreCache ? 'yes' : 'no',
|
|
||||||
config.bitcoind.user,
|
|
||||||
config.bitcoind.pass ? 'Yes(hidden)' : 'No',
|
|
||||||
config.bitcoind.protocol,
|
|
||||||
config.bitcoind.host,
|
|
||||||
config.bitcoind.port,
|
|
||||||
config.bitcoind.p2pPort,
|
|
||||||
config.bitcoind.dataDir + (config.network === 'testnet' ? '*' : ''), (config.network === 'testnet' ? '* (/testnet3 is added automatically)' : '')
|
|
||||||
);
|
|
||||||
});
|
});
|
||||||
|
|
||||||
program.parse(process.argv);
|
bus.register(bitcore.Block, function(block) {
|
||||||
|
console.log('Block:', block.id);
|
||||||
// create express app
|
|
||||||
var expressApp = express();
|
|
||||||
|
|
||||||
// setup headers
|
|
||||||
require('./config/headers')(expressApp);
|
|
||||||
|
|
||||||
// setup http/https base server
|
|
||||||
var server;
|
|
||||||
if (config.enableHTTPS) {
|
|
||||||
var serverOpts = {};
|
|
||||||
serverOpts.key = fs.readFileSync('./etc/test-key.pem');
|
|
||||||
serverOpts.cert = fs.readFileSync('./etc/test-cert.pem');
|
|
||||||
server = https.createServer(serverOpts, expressApp);
|
|
||||||
} else {
|
|
||||||
server = http.createServer(expressApp);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Bootstrap models
|
|
||||||
var models_path = __dirname + '/app/models';
|
|
||||||
var walk = function(path) {
|
|
||||||
fs.readdirSync(path).forEach(function(file) {
|
|
||||||
var newPath = path + '/' + file;
|
|
||||||
var stat = fs.statSync(newPath);
|
|
||||||
if (stat.isFile()) {
|
|
||||||
if (/(.*)\.(js$)/.test(file)) {
|
|
||||||
require(newPath);
|
|
||||||
}
|
|
||||||
} else if (stat.isDirectory()) {
|
|
||||||
walk(newPath);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
walk(models_path);
|
|
||||||
|
|
||||||
// p2pSync process
|
|
||||||
var peerSync = new PeerSync({
|
|
||||||
shouldBroadcast: true
|
|
||||||
});
|
});
|
||||||
|
|
||||||
if (!config.disableP2pSync) {
|
nm.start();
|
||||||
peerSync.run();
|
|
||||||
}
|
|
||||||
|
|
||||||
// historic_sync process
|
|
||||||
var historicSync = new HistoricSync({
|
|
||||||
shouldBroadcastSync: true
|
|
||||||
});
|
|
||||||
peerSync.historicSync = historicSync;
|
|
||||||
|
|
||||||
if (!config.disableHistoricSync) {
|
|
||||||
historicSync.start({}, function(err) {
|
|
||||||
if (err) {
|
|
||||||
var txt = 'ABORTED with error: ' + err.message;
|
|
||||||
console.log('[historic_sync] ' + txt);
|
|
||||||
}
|
|
||||||
if (peerSync) peerSync.allowReorgs = true;
|
|
||||||
});
|
|
||||||
} else
|
|
||||||
if (peerSync) peerSync.allowReorgs = true;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// socket.io
|
|
||||||
var ios = require('socket.io')(server, config);
|
|
||||||
require('./app/controllers/socket.js').init(ios);
|
|
||||||
|
|
||||||
// express settings
|
|
||||||
require('./config/express')(expressApp, historicSync, peerSync);
|
|
||||||
require('./config/routes')(expressApp);
|
|
||||||
|
|
||||||
|
|
||||||
//Start the app by listening on <port>
|
|
||||||
server.listen(config.port, function() {
|
|
||||||
logger.info('bitcoin-node API listening on port %d in %s mode', server.address().port, process.env.NODE_ENV);
|
|
||||||
});
|
|
||||||
|
|
||||||
//expose app
|
|
||||||
exports = module.exports = expressApp;
|
|
||||||
|
|||||||
@ -21,11 +21,10 @@ util.inherits(NetworkMonitor, EventEmitter);
|
|||||||
|
|
||||||
NetworkMonitor.create = function(eventBus, opts) {
|
NetworkMonitor.create = function(eventBus, opts) {
|
||||||
opts = opts || {};
|
opts = opts || {};
|
||||||
opts.network = opts.network || Networks.defaultNetwork;
|
var network = Networks.get(opts.network) || Networks.defaultNetwork;
|
||||||
opts.host = opts.host || 'localhost';
|
var host = opts.host || 'localhost';
|
||||||
opts.port = opts.port || Networks.defaultNetwork.port;
|
var port = opts.port || Networks.defaultNetwork.port;
|
||||||
|
var peer = new Peer(host, port, network);
|
||||||
var peer = new Peer(opts.host, opts.port, opts.network);
|
|
||||||
return new NetworkMonitor(eventBus, peer);
|
return new NetworkMonitor(eventBus, peer);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@ -51,9 +51,11 @@
|
|||||||
"bufferput": "bitpay/node-bufferput",
|
"bufferput": "bitpay/node-bufferput",
|
||||||
"buffertools": "*",
|
"buffertools": "*",
|
||||||
"commander": "^2.3.0",
|
"commander": "^2.3.0",
|
||||||
|
"config": "^1.12.0",
|
||||||
"cron": "^1.0.4",
|
"cron": "^1.0.4",
|
||||||
"express": "~3.4.7",
|
"express": "~3.4.7",
|
||||||
"glob": "*",
|
"glob": "*",
|
||||||
|
"js-yaml": "^3.2.7",
|
||||||
"leveldown": "~0.10.0",
|
"leveldown": "~0.10.0",
|
||||||
"levelup": "~0.19.0",
|
"levelup": "~0.19.0",
|
||||||
"lodash": "^2.4.1",
|
"lodash": "^2.4.1",
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user