Merge pull request #187 from matiaspando/feat/stats
Initial stats for bws
This commit is contained in:
commit
1d57e4224b
|
@ -0,0 +1,70 @@
|
|||
#!/usr/bin/env node
|
||||
|
||||
var multilevel = require('multilevel');
|
||||
var net = require('net');
|
||||
var moment = require('moment');
|
||||
|
||||
var PORT = 3230;
|
||||
|
||||
var otherDate;
|
||||
|
||||
//trying to parse optional parameter to get stats on any given date
|
||||
try {
|
||||
otherDate = process.argv[2] && moment(process.argv[2]).isValid() ? moment(process.argv[2]) : null;
|
||||
} catch (e) {
|
||||
console.log('Enter the date in the format YYYY-MM-DD.');
|
||||
}
|
||||
|
||||
var db = multilevel.client();
|
||||
var con = net.connect(PORT);
|
||||
con.pipe(db.createRpcStream()).pipe(con);
|
||||
|
||||
|
||||
var Today = otherDate || moment();
|
||||
var TotalTx = 0;
|
||||
var TotalAmount = 0;
|
||||
var TotalNewWallets = 0;
|
||||
|
||||
var IsToday = function(date) {
|
||||
if (!date) return false;
|
||||
var date = moment(date * 1000);
|
||||
return (date >= Today.startOf('day') && date <= Today.endOf('day'));
|
||||
}
|
||||
|
||||
var TotalTxpForToday = function(data) {
|
||||
if (!data) return;
|
||||
if (data.key.indexOf('!txp!') < 0) return;
|
||||
if (!data.value || !IsToday(data.value.createdOn)) return;
|
||||
TotalTx++;
|
||||
TotalAmount = TotalAmount + data.value.amount;
|
||||
};
|
||||
|
||||
var TotalNewWalletForToday = function(data) {
|
||||
if (!data) return;
|
||||
if (data.key.indexOf('!main') < 0) return;
|
||||
if (!data.value || !IsToday(data.value.createdOn)) return;
|
||||
TotalNewWallets++;
|
||||
};
|
||||
|
||||
var PrintStats = function() {
|
||||
console.log('Stats for date : ', Today.format("YYYY-MM-DD"));
|
||||
console.log('New wallets : ', TotalNewWallets);
|
||||
console.log('Total tx : ', TotalTx);
|
||||
console.log('Total amount in tx (satoshis) : ', TotalAmount);
|
||||
};
|
||||
|
||||
var ProcessData = function(data) {
|
||||
TotalTxpForToday(data);
|
||||
TotalNewWalletForToday(data);
|
||||
};
|
||||
|
||||
// streams
|
||||
db.createReadStream().on('data', function(data) {
|
||||
ProcessData(data);
|
||||
}).on('error', function(err) {
|
||||
console.log('Error : ', err);
|
||||
process.exit(code = 1);
|
||||
}).on('close', function() {
|
||||
PrintStats();
|
||||
process.exit(code = 0);
|
||||
});
|
Loading…
Reference in New Issue