Initial stats for bws

multilevel/clientMultilevel.js

@@ -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);
+});