62 lines
1.6 KiB
JavaScript
62 lines
1.6 KiB
JavaScript
var net = require('net');
|
|
var fs = require('fs');
|
|
var path = require('path');
|
|
|
|
var pool = require('./pool.js');
|
|
|
|
var logRef = console.log;
|
|
console.log = function(s){
|
|
var time = new Date().toISOString();
|
|
logRef(time + ': ' + s);
|
|
};
|
|
|
|
|
|
var config = JSON.parse(fs.readFileSync("config.json"));
|
|
|
|
|
|
function Coin(options){
|
|
this.options = options;
|
|
}
|
|
Coin.prototype = {};
|
|
|
|
var coins = [];
|
|
|
|
var confFolder = 'coins';
|
|
|
|
fs.readdir(confFolder, function(err, files){
|
|
if (err) throw err;
|
|
files.forEach(function(file){
|
|
var filePath = confFolder + '/' + file;
|
|
if (path.extname(filePath) !== '.json') return;
|
|
fs.readFile(filePath, {encoding: 'utf8'}, function(err, data){
|
|
if (err) throw err;
|
|
var coinJson = JSON.parse(data)
|
|
var coin = new Coin(coinJson);
|
|
console.log('Starting pool for ' + coin.options.name);
|
|
coin.pool = new pool(coin);
|
|
coins.push(coin);
|
|
});
|
|
|
|
});
|
|
});
|
|
|
|
|
|
if (config.blockNotifyListener.enabled){
|
|
var blockNotifyServer = net.createServer(function(c) {
|
|
console.log('server connected');
|
|
var data = '';
|
|
c.on('data', function(d){
|
|
console.log('got blocknotify data');
|
|
data += d;
|
|
if (data.slice(-1) === '\n'){
|
|
c.end();
|
|
}
|
|
});
|
|
c.on('end', function() {
|
|
console.log(data);
|
|
console.log('server disconnected');
|
|
});
|
|
});
|
|
blockNotifyServer.listen(config.blockNotifyListener.port, function() {});
|
|
}
|