codecombat/scripts/analytics/subscriptionStats.js

73 lines
No EOL
2 KiB
JavaScript

// To use: set the range you want below, make sure your environment has the stripe key, then run:
// node scripts/analytics/subscriptionStats.js
require('coffee-script');
require('coffee-script/register');
_ = require('lodash');
config = require('../../server_config');
if(config.stripe.secretKey.indexOf('sk_test_')==0) {
throw new Error('You should not run this on the test data... Get your environment in gear.');
}
stripe = require('stripe')(config.stripe.secretKey);
var range = {
gt: ''+(new Date('2015-03-01').getTime()/1000),
lt: ''+(new Date('2015-04-01').getTime()/1000)
};
begin = function(starting_after) {
var query = {date: range, limit: 100};
if(starting_after) {
query.starting_after = starting_after;
}
stripe.invoices.list(query, onInvoicesReceived);
}
customersPaid = [];
onInvoicesReceived = function(err, invoices) {
for(var i in invoices.data) {
var invoice = invoices.data[i];
if(!invoice.paid) { continue; }
if(!invoice.total) { continue; } // not paying anything!
//console.log(invoice);
customersPaid.push(invoice.customer);
}
if(invoices.has_more) {
console.log('Loaded', customersPaid.length, 'invoices.')
begin(invoices.data[i].id);
}
else {
console.log('--- Actual active total customers:', _.unique(customersPaid).length);
loadNewCustomers();
}
};
loadNewCustomers = function(starting_after) {
query = {created: range, limit: 100};
if(starting_after) {
query.starting_after = starting_after;
}
stripe.customers.list(query, onCustomersReceived);
};
newCustomersPaid = [];
onCustomersReceived = function(err, customers) {
for(var i in customers.data) {
var customer = customers.data[i];
if(customersPaid.indexOf(customer.id) == -1) { continue; }
newCustomersPaid.push(customer.id);
}
if(customers.has_more) {
console.log('Loaded', newCustomersPaid.length, 'new customers.');
loadNewCustomers(customers.data[i].id);
}
else {
console.log('--- Actual new customers:', newCustomersPaid.length);
}
};
begin();