app.js

(function() {
  var UI, app, async, ejs, express, forever, foreverUI, fs, _;
  express = require('express');
  async = require('async');
  fs = require('fs');
  forever = require('forever');
  _ = require('underscore');
  ejs = require('ejs');
  ansiparse = require('ansiparse');
  process.on("uncaughtException", function(err) {
    return console.log("Caught exception: " + err);
  });
  foreverUI = (function() {
    function foreverUI() {}
    foreverUI.prototype.findProcessByUID = function(uid, cb) {
      return forever.list("", function(err, processes) {
        if (err) {
          return cb(err, null);
        }
        return cb(null, _.find(processes, function(o) {
          return o.uid === uid;
        }));
      });
    };
    foreverUI.prototype.findProcIndexByUID = function(uid, cb) {
      return forever.list("", function(err, processes) {
        var i;
        if (err) {
          return cb(err, null);
        }
        i = -1;
        while (processes[++i]) {
          if (processes[i].uid === uid) {
            return cb(null, i);
          }
        }
        return cb("Process '" + uid + "' not found", null);
      });
    };
    foreverUI.prototype.info = function(uid, cb) {
      return this.findProcessByUID(uid, function(err, proc) {
        if (err) {
          return cb(err, null);
        }
        if (!proc) {
          return cb("Undefined proc", null);
        }
        return async.map([proc.logFile, proc.outFile, proc.errFile].filter(function(s) {
          return s !== void 0;
        }), function(filename, cb) {
          return fs.readFile(filename, function(err, data) {
            var d;
            d = data.toString().trim();
            if (!d || d === '\n') {
              return cb(null, [filename, 'Empty log']);
            } else {
              return cb(null, [filename, ansiparse(data.toString())]);
            }
          });
        }, function(err, results) {
          return cb(err, results);
        });
      });
    };
    foreverUI.prototype.stop = function(uid, cb) {
      return this.findProcIndexByUID(uid, function(err, index) {
        if (err) {
          return cb(err, null);
        }
        return forever.stop(index).on('stop', function(res) {
          return cb(null, true);
        }).on('error', function(err) {
          return cb(err, null);
        });
      });
    };
    foreverUI.prototype.restart = function(uid, cb) {
      return this.findProcIndexByUID(uid, function(err, index) {
        if (err) {
          return cb(err, null);
        }
        return forever.restart(index).on('restart', function(res) {
          return cb(null, true);
        }).on('error', function(err) {
          return cb(err, null);
        });
      });
    };
    return foreverUI;
  })();
  UI = new foreverUI();
  app = express.createServer();
  app.configure(function() {
    app.use(express.bodyParser());
    app.use(express.cookieParser());
    app.register('.ejs', ejs);
    app.set('views', __dirname + '/views');
    app.set('view engine', 'html');
    app.use(express.methodOverride());
    return app.use(app.router);
  });
  app.configure("development", function() {
    app.use(express.errorHandler({
      dumpExceptions: true,
      showStack: true
    }));
    return app.use(express.static(__dirname + "/public"));
  });
  app.configure("production", function() {
    app.use(express.errorHandler());
    return app.use(express.static(__dirname + '/public', {
      maxAge: oneYear
    }));
  });
  app.set('view options', {
    layout: false
  });
  app.get('/', function(req, res) {
    return forever.list("", function(err, results) {
      return res.render('index.ejs', {
        process: results
      });
    });
  });
  app.get('/refresh/', function(req, res) {
    return forever.list("", function(err, results) {
      return res.send(JSON.stringify(results), {
        'Content-Type': 'text/javascript'
      }, 200);
    });
  });
  app.get('/processes', function(req, res) {
    return forever.list("", function(err, results) {
      return res.send(JSON.stringify(results), {
        'Content-Type': 'text/javascript'
      }, 200);
    });
  });
  app.get('/restart/:uid', function(req, res) {
    return UI.restart(req.params.uid, function(err, results) {
      if (err) {
        return res.send(JSON.stringify({
          status: 'error',
          details: err
        }), {
          'Content-Type': 'text/javascript'
        }, 500);
      } else {
        return res.send(JSON.stringify({
          status: 'success',
          details: results
        }), {
          'Content-Type': 'text/javascript'
        }, 200);
      }
    });
  });
  app.get('/stop/:uid', function(req, res) {
    return UI.stop(req.params.uid, function(err, results) {
      if (err) {
        return res.send(JSON.stringify({
          status: 'error',
          details: err
        }), {
          'Content-Type': 'text/javascript'
        }, 500);
      } else {
        return res.send(JSON.stringify({
          status: 'success',
          details: results
        }), {
          'Content-Type': 'text/javascript'
        }, 200);
      }
    });
  });
  app.get('/info/:uid', function(req, res) {
    return UI.info(req.params.uid, function(err, results) {
      if (err) {
        return res.send(JSON.stringify({
          status: 'error',
          details: err
        }), {
          'Content-Type': 'text/javascript'
        }, 500);
      } else {
        return res.send(JSON.stringify({
          status: 'success',
          details: results
        }), {
          'Content-Type': 'text/javascript'
        }, 200);
      }
    });
  });
  app.listen(8085, "127.0.0.1");
  console.log("Listening on 127.0.0.1:8085");
}).call(this);