var cluster = require('cluster');
var logger  = require('./logger');
var numCPUs = require('os').cpus().length;

if (cluster.isMaster) {
  
  logger.info("** MASTER start");

  // First thing, fork all our workers:
  for(var i=0; i<numCPUs; i++) {
    cluster.fork();
  }

  // 'exit' is triggered when a child dies:
  cluster.on('exit', function (worker, code, signal) {
    logger.info("** WORKER (%s) died: code(%d) signal(%s)", worker.id, code, signal || "--");
  });

} else {

  // This is the client:
  var express = require('express');
  var bs      = require('./bullshit');
  
  var app = express();
  
  // Very simple logging middleware:
  function accessLog(req, res, next) {
    var start_time = new Date().valueOf();

    var is_logged = false;
    function _doLog() {
      if (is_logged) { return; }
      is_logged = true;

      var res_time = (new Date().valueOf()) - start_time;

      logger.info("[%s] %s :: %s -> %s (%d bytes) in %d ms", req.method, req.url, req.headers['user-agent'], res.statusCode, res._headers['content-length'], res_time);
    }

    res.once('finish', _doLog);
    res.once('close', _doLog);

    next();
  }

  app.use(accessLog);
  
  app.get("/", function (req, res, next) {
    res.redirect("/sentence");
  });

  app.get("/sentence", function (req, res, next) {
    var out = bs.getSentence();
    res.status(200).send(out);
  });

  app.get("/quote/:company", function (req, res, next) {
    var company = req.param("company");
    var out = bs.getQuote(company);
    res.status(200).send(out);
  });

  app.get("/paragraph", function (req, res, next) {
    var out = bs.getParagraph();
    res.status(200).send(out);
  });

  app.get("/name", function (req, res, next) {
    var out = bs.getName();
    res.status(200).send(out);
  });

  app.listen(6543);
}