gogogo/plugins/chefHosts.js

// Generated by CoffeeScript 1.3.1
(function() {
  var buildKnifeCommand, defaultFindHost, exec, getNodesByRoleAndEnv, knife;

  exec = require("child_process").exec;

  knife = "knife";

  buildKnifeCommand = function(role, env) {
    if (env) {
      return "" + knife + " search node --format=json 'role:" + role + " AND chef_environment:" + env + "' --format=json";
    }
  };

  getNodesByRoleAndEnv = function(role, env, cb) {
    return exec(buildKnifeCommand(role, env), function(err, stdout) {
      var nodes;
      if (err != null) {
        return cb(err);
      }
      nodes = JSON.parse(stdout);
      return cb(null, nodes);
    });
  };

  defaultFindHost = function(member) {
    return member.automatic.cloud.public_hostname;
  };

  module.exports = function(opts, cb) {
    var env, findHost;
    if (!opts.role) {
      return cb(new Error("no role specified"));
    }
    findHost = opts.findHost || defaultFindHost;
    knife = opts.knifePath || knife;
    env = opts.env || "_default";
    return getNodesByRoleAndEnv(opts.role, env, function(err, nodes) {
      var hosts, member, members, _i, _len;
      if (err != null) {
        return cb(err);
      }
      if (!nodes.results) {
        return cb(new Error("no hosts found!"));
      }
      members = nodes.rows;
      hosts = [];
      for (_i = 0, _len = members.length; _i < _len; _i++) {
        member = members[_i];
        try {
          hosts.push(findHost(member));
        } catch (error) {
          return cb(new Error("failed to find the hostname using method:\n " + (findHost.toString())));
        }
      }
      return cb(null, hosts);
    });
  };

}).call(this);