index.js

var url = require('url');
var redis = require('redis');
var express = require('express');
var router = express.Router();
var config = require('histograph-config');
var client = redis.createClient(config.redis.port, config.redis.host);
var queries = require('./queries')(config);

if (config.stats.enabled) {

  // run every now and then...
  var CronJob = require('cron').CronJob;
  var job = new CronJob({
    cronTime: config.stats.cronExpression,
    onTick: function() {
      queries.update();
    }
  });
  job.start();

  // and run on startup
  queries.update();
}

router.get('/queue', function(req, res) {
  client.llen(config.redis.queue, function(err, reply) {
    if (err) {
      res.status(400).send({
        message: err
      });
    } else {
      return res.send({
        length: reply
      });
    }
  });
});

var queryNames = queries.names.map(function(name) {
  return url.resolve(config.api.baseUrl, '/stats/queries/' + name);
});

router.get('/queries', function(req, res) {
  res.send(queryNames);
});

router.get('/queries/:query', function(req, res) {
  if (queries.names.indexOf(req.params.query) > -1) {
    queries.get(req.params.query, function(err, data) {
      if (err) {
        res.status(500).send({
          message: 'Error getting query results'
        });
      } else {
        res.send(data || []);
      }
    });
  } else {
    res.status(404).send({
      message: 'Not found!'
    });
  }
});

module.exports = router;