report.js

var Stripe = require("stripe");
var _ = require("lodash");
var Promise = require("bluebird");
var moment = require("moment");
var csvStringify = require("csv-stringify");

////////////////////////////////////////////////////////////////////////////////
// Slack client
//  (webtask.io doesn't support relative requires, and the slack package wasn't
//   supported as of the last time i checked)
////////////////////////////////////////////////////////////////////////////////

var request = require("request");

var doRequest = function(requestOptions) {
    return new Promise(function(resolve, reject) {
        var req = request(requestOptions, function(err, _res, body) {
            if(err) {
                reject(err);
            } else {
                resolve(body);
            }
        });
    });
};

var Slack = function (apiKey) {
    this.apiKey = apiKey;
};

Slack.prototype._requestOptions = function(endpoint, data) {
    var options = {
        url: "https://api.slack.com" + endpoint,
        method: 'POST',
        form: _.defaults({ token: this.apiKey, as_user: true }, data)
    };

    return options;
};

Slack.prototype.post = function(to, message) {
    var postData = {
        channel: to,
        text: message
    };

    var requestOptions = this._requestOptions("/api/chat.postMessage", postData);

    return doRequest(requestOptions);
};

Slack.prototype.upload = function(to, initialComment, contents) {
    var postData = {
        channels: to,
        initial_comment: initialComment,
        content: contents,
        filename: "signups.csv"
    };

    var requestOptions = this._requestOptions("/api/files.upload", postData);

    return doRequest(requestOptions);
};

////////////////////////////////////////////////////////////////////////////////




var fetchPageOfCharges = function(stripe, startTime, endTime, startAfter) {
    var opts = {
        created: { gte: startTime, lte: endTime },
        expand: ["data.customer"]
    };

    if(startAfter) {
        opts.starting_after = startAfter;
    }

    return stripe.charges.list(opts);
};

var fetchAllCharges = function(stripe, startTime, endTime) {
    var allCharges = [];
    var startAfter = null;

    return new Promise(function(resolve, reject) {

        function doFetch() {
            return fetchPageOfCharges(stripe, startTime, endTime, startAfter)
                .then(function(response) {
                    response.data.forEach(function(charge) {
                        if(charge.metadata.nationalSignup == "true") {
                            allCharges.push(charge);
                        }
                    });

                    if(response.has_more) {
                        startAfter = _.last(response.data).id;

                        doFetch();
                    } else {
                        resolve(allCharges);
                    }
                })
                .catch(reject);
        }

        doFetch();
    });
};

var sendReport = function(options) {
    var slackApiKey = options.slackApiKey;
    var to = options.to;
    var additionalTo = options.additionalTo;
    var signups = options.signups;

    var slack = new Slack(slackApiKey);

    if(signups && signups.length) {
        var headers = ["Name",
                       "Address 1",
                       "Address 2",
                       "City",
                       "State",
                       "Zip",
                       "Email",
                       "Phone",
                       "Full Amount",
                       "Half Amount",
                       "Signed up at"];

        var csvData = [headers].concat(signups.map(function(signup) {
            var name = signup.customer.shipping.name;
            var phone = signup.customer.shipping.phone;
            var address = signup.customer.shipping.address;
            var email = signup.customer.email;

            var fullAmount = signup.amount / 100;
            var halfAmount = fullAmount / 2;
            var createdAt = moment(signup.created * 1000).format("M/D/YYYY h:mm a");

            return [name,
                    address.line1,
                    address.line2,
                    address.city,
                    address.state,
                    address.postal_code,
                    email,
                    phone,
                    fullAmount,
                    halfAmount,
                    createdAt];
        }));

        if(additionalTo) {
            slack.post(additionalTo, "We got " + signups.length + " National DSA Signups!");
        }

        return new Promise(function(resolve, reject) {
            csvStringify(csvData, function(err, signupCsv) {
                if(err) {
                    reject(err);
                } else {
                    slack.upload(to, "New National DSA signups", signupCsv)
                        .then(function(resp) {
                            resolve(resp);
                        }).catch(function(err) {
                            reject(err);
                        });
                }
            });
        });
    } else {
        var promises = _.uniq((to + (additionalTo || "")).split(",").map(function(handle) {
            return slack.post(handle, "There were no new National DSA signups :-(");
        }));

        if(promises.length == 1) {
            return promises[0];
        } else {
            return Promise.all(promises);
        }
    }
};

module.exports = function(ctx, cb) {
    var stripe = Stripe(ctx.secrets.stripeSecretKey);

    if(ctx.secrets.startTime) {
        var startTime = moment(ctx.secrets.startTime).unix();
    } else {
        var startTime = moment().subtract(1, "day").hours(0).minutes(0).seconds(0).unix();
    }
    var endTime = moment().unix();

    // for charge pagination
    var startAfter = null;

    var chargesByCustomerId = {};

    return fetchAllCharges(stripe, startTime, endTime)
        .then(function(charges) {
            return _.reject(charges, function(charge) {
                return charge.customer.deleted;
            });
        })
        .then(function(signups) {
            return sendReport({
                slackApiKey: ctx.secrets.slackApiKey,
                to: ctx.secrets.sendTo,
                additionalTo: ctx.secrets.additionalTo,
                signups: signups
            });
        })
        .then(function(resp) { return cb(null, resp); })
        .catch(cb);
};