gogogo/index.js

// Generated by CoffeeScript 1.6.3
/*
CLI to automatically deploy stuff, kind of like heroku.
Ubuntu only! (upstart)

TODO remember last command again
TODO multiple services
TODO multiple cron
*/


(function() {
  var COMMIT_HISTORY, CONFIG, LOGS_LINES, Layer, MainConfig, VERSION, exec, finish, fs, getConfigRepo, getLayer, init, list, mainConfigPath, parseTargetAndProcessName, path, program, reponame, runProcessSpecificCommandOnLayer;

  CONFIG = "ggg";

  LOGS_LINES = 40;

  COMMIT_HISTORY = 5;

  VERSION = require("./package.json").version;

  exec = require("child_process").exec;

  fs = require('fs');

  path = require('path');

  program = require('commander');

  MainConfig = require("./lib/MainConfig");

  Layer = require("./lib/Layer");

  parseTargetAndProcessName = function(arg) {
    var processName, target, _ref;
    _ref = arg.split(':'), target = _ref[0], processName = _ref[1];
    return {
      target: target,
      processName: processName
    };
  };

  program.version(VERSION).option("-l, --local <user>", "deploy locally for bootstrapping").option("-n, --noPlugin", "disable plugins");

  program.command("init").description("creates a ggg.js config file for you").action(function() {
    return init(finish);
  });

  program.command("deploy <name> [branch]").description("deploys a branch (defaults to origin/master) to named target").action(function(name, branch) {
    return getLayer(name, function(err, layer) {
      if (err != null) {
        return finish(err);
      }
      branch = branch || "origin/master";
      return layer.deploy(branch, finish);
    });
  });

  runProcessSpecificCommandOnLayer = function(command) {
    return function(name) {
      var processName, target, _ref;
      _ref = parseTargetAndProcessName(name), target = _ref.target, processName = _ref.processName;
      return getLayer(target, function(err, layer) {
        if (err != null) {
          return finish(err);
        }
        if (processName) {
          return layer[command](processName, finish);
        } else {
          return layer[command](finish);
        }
      });
    };
  };

  program.command("restart <name:process>").description("restarts all processes associated with target.\nIf process is provided, restarts only the named process.\n`ggg restart prod` would restart all processes under the prod target\n`ggg restart prod:web` would restart only the `web` process in the `prod` target.").action(runProcessSpecificCommandOnLayer('restart'));

  program.command("start <name:process>").description("starts all processes associated with target. if process is provided, starts only the named process").action(runProcessSpecificCommandOnLayer('start'));

  program.command("stop <name:process>").description("stops all processes associated with name. if process is provided, stops only the named process").action(runProcessSpecificCommandOnLayer('stop'));

  program.command("logs <name:process>").description("Logs " + LOGS_LINES + " lines from target and process. When no process is supplied, defaults to the first process.").option("-l, --lines <num>", "the number of lines to log").action(function(name) {
    var processName, target, _ref;
    _ref = parseTargetAndProcessName(name), target = _ref.target, processName = _ref.processName;
    return getLayer(target, function(err, layer) {
      var lines;
      if (err != null) {
        return finish(err);
      }
      lines = program.lines || LOGS_LINES;
      if (processName) {
        return layer.serverLogs(lines, processName, finish);
      } else {
        return layer.serverLogs(lines, finish);
      }
    });
  });

  program.command("history <name>").description("Shows a history of " + COMMIT_HISTORY + " last commits deployed").option("-r, --revisions <num>", "the number of commits to show").action(function(name) {
    return getLayer(name, function(err, layer) {
      var revisions;
      if (err != null) {
        return finish(err);
      }
      revisions = program.args.revisions || COMMIT_HISTORY;
      return layer.commitHistory(revisions, finish);
    });
  });

  program.command("command <name> <command>").description("run a command over ssh in the root of your project directory").action(function(name, command) {
    return getLayer(name, function(err, layer) {
      if (err != null) {
        return finish(err);
      }
      return layer.runCommand(command, finish);
    });
  });

  program.command("list").description("lists all deploy targets").action(function() {
    return getConfigRepo(function(err, repoName, mainConfig) {
      if (err != null) {
        return finish(err);
      }
      return list(mainConfig, finish);
    });
  });

  program.command("servers <name>").description("lists deploy server locations").action(function(name) {
    return getLayer(name, finish);
  });

  program.command("help").description("display this help").action(function() {
    console.log(program.helpInformation());
    return finish();
  });

  program.command("*").action(function() {
    return finish(new Error("bad command!"));
  });

  init = function(cb) {
    var initConfigContent;
    initConfigContent = "// example ggg.js. Delete what you don't need\nmodule.exports = {\n\n  // services\n  // can either be a string or an object with mutiple processes to start up\n  start: \"node app.js\",\n  /* or\n  start: {\n    web: 'node app.js',\n    worker 'node worker.js',\n    montior: 'node monitor.js'\n  },\n  */\n\n  // install\n  install: \"npm install\",\n\n  // cron jobs (from your app folder)\n  cron: {\n    someTask: { time: \"0 3 * * *\", command: \"node sometask.js\"},\n  },\n\n  // servers to deploy to\n  servers: {\n    dev: \"deploy@dev.mycompany.com\",\n    staging: [\"deploy@staging.mycompany.com\", \"deploy@staging2.mycompany.com\"],\n    prod: {\n      hosts: [\"deploy@mycompany.com\", \"deploy@backup.mycompany.com\"],\n      cron: {\n        someTask: {time: \"0 3 * * *\", command: \"node sometask.js\"},\n        anotherTask: {time: \"0 3 * * *\", command: \"node secondTask.js\"}\n      },\n      start: \"prodstart app.js\"\n    }\n  }\n}";
    console.log("GOGOGO INITIALIZING!");
    console.log("*** Written to ggg.js ***");
    console.log(initConfigContent);
    return fs.writeFile(mainConfigPath() + ".js", initConfigContent, cb);
  };

  list = function(mainConfig, cb) {
    console.log("GOGOGO servers (see ggg.js)");
    return console.log(" - " + mainConfig.getLayerNames().join("\n - "));
  };

  reponame = function(dir, cb) {
    return exec("git config --get remote.origin.url", {
      cwd: dir
    }, function(err, stdout, stderr) {
      var url;
      if (err != null) {
        return cb(null, path.basename(dir));
      } else {
        url = stdout.replace("\n", "");
        return cb(null, path.basename(url).replace(".git", ""));
      }
    });
  };

  mainConfigPath = function() {
    return path.join(process.cwd(), CONFIG);
  };

  getConfigRepo = function(cb) {
    return reponame(process.cwd(), function(err, repoName) {
      if (err != null) {
        return cb(err);
      }
      return MainConfig.loadFromFile(mainConfigPath(), function(err, mainConfig) {
        var errString;
        if (err) {
          errString = "Bad gogogo config file, ggg.js. Run 'gogogo init' to" + (" create one. Err=" + err.message);
          return cb(new Error(errString));
        }
        return cb(null, repoName, mainConfig);
      });
    });
  };

  getLayer = function(name, cb) {
    return getConfigRepo(function(err, repoName, mainConfig) {
      var layer, layerConfig;
      if (err != null) {
        return cb(err);
      }
      layerConfig = mainConfig.getLayerByName(name);
      if (!layerConfig) {
        return cb(new Error("Invalid layer Name: " + name));
      }
      if (program.noPlugin) {
        layerConfig.plugins = null;
        mainConfig.disablePlugins();
      }
      if (program.local) {
        layerConfig.hosts = ["" + program.local + "@localhost"];
      }
      layer = new Layer(name, layerConfig, repoName, mainConfig, program.local);
      layer.on("error", function(err) {
        return cb(err);
      });
      return layer.on("ready", function() {
        return cb(null, layer);
      });
    });
  };

  finish = function(err) {
    if (err != null) {
      console.log("!!! " + err.message);
      console.log("stack follows:\n\n " + err.stack);
      process.exit(1);
    }
    return console.log("OK");
  };

  module.exports = program;

}).call(this);