getMMStats.js

var utility = require('./utility');
var config = require("./config");
var secret = config.RETRIEVER_SECRET;
var retrieverConfig = config.RETRIEVER_HOST;
var getData = utility.getData;
var DATA_POINTS = 60 / (config.MMSTATS_DATA_INTERVAL || 1) * 24; //Store 24 hours worth of data
module.exports = function getMMStats(redis, cb) {
    var retrievers = retrieverConfig.split(",").map(function(r) {
        return "http://" + r + "?key=" + secret;
    });
    var result = retrievers;
    //make array of retriever urls and use a random one on each retry
    var urls = result.map(function(r) {
        return r + "&mmstats=1";
    });
    getData(urls, function(err, body) {
        if (err) return cb(err);
        redis.lpush("mmstats:time", Date.now());
        redis.ltrim("mmstats:time", 0, DATA_POINTS);
        body.forEach(function(elem, index) {
            redis.lpush('mmstats:' + index, elem);
            redis.ltrim('mmstats:' + index, 0, DATA_POINTS);
        });
        cb(err);
    });
}