FM / lib

/usr/lib/node_modules/pm2/node_modules/vizion/lib/

/usr/lib/node_modules/pm2/node_modules/vizion/lib

Name	Size	Mode	Actions
git.js	7813	0644	edit dl rm
hg.js	2088	0644	edit dl rm
identify.js	474	0644	edit dl rm
svn.js	2851	0644	edit dl rm
vizion.js	2337	0644	edit dl rm

Edit: /usr/lib/node_modules/pm2/node_modules/vizion/lib/git.js (7813B)

var fs = require('fs');
var async = require('async');
var exec = require('child_process').exec;

var git = {};

var TIMEOUT = 5000;
var MAXBUFFER = 1024 * 64; // 16KB

git.parse = function(folder, cb) {
  var myTrim = function(str) {
    if (typeof(str) === 'string')
      return str.replace(/\n/g, '');
    return str;
  };

var getRemoteBrancheExistence = function(data, cb) {
    exec("cd '"+folder+"';LC_ALL=en_US.UTF-8 git show-ref refs/remotes/"+data.remote+"/"+data.branch, {timeout: TIMEOUT, maxBuffer: MAXBUFFER},
         function(err, stdout, stderr) {
      if (err)
        data.branch_exists_on_remote = false;
      else
        data.branch_exists_on_remote = true;

return cb(null, data);
    });
  };

var getPrevNext = function(data, cb) {
    var prefix = '';

if (data.branch_exists_on_remote)
      prefix = data.remote + '/';

exec("cd '"+folder+"';LC_ALL=en_US.UTF-8 git log "+ prefix + data.branch +" --pretty=oneline -n 100",
         {timeout: TIMEOUT, maxBuffer: MAXBUFFER},
    function(err, stdout, stderr) {
      if(err !== null)
        return cb(err);
      var commit_history = [];
      var lines = stdout.split('\n');

lines.forEach(function(key) {
        var parse = key.match(/([^ ]*) (.*)/);
        if (parse)
          commit_history.push(parse[1]);
      });

var current = commit_history.indexOf(data.revision);
      data.ahead = false;
      data.next_rev = null;
      data.prev_rev = null;
      if (current === -1) {
        data.ahead = true;
      }
      else {
        data.next_rev = (current === 0) ? null : commit_history[current - 1];
        data.prev_rev = (current === (commit_history.length - 1)) ? null : commit_history[current + 1];
      }
      return cb(null, data);
    });
  };

var getDate = function(data, cb) {
    fs.stat(folder+".git", function(err, stats) {
      if(err !== null)
        return cb(err);
      data.update_time = myTrim(stats.mtime);
      return cb(null, data);
    });
  };

async.waterfall([getUrl, getMeta, getStaged, getBranch, getRemote, getRemoteBrancheExistence, getPrevNext, getDate, getTags],
  function(err, data) {
    if (err !== null)
      return cb(err);
    return cb(null, data);
  });
};

git.isUpdated = function(folder, cb) {
  git.parse(folder, function(err, data) {
    var prefix = '';

if (err !== null)
      return cb(err);

if (data.branch_exists_on_remote)
      prefix = data.remote + '/';

exec("cd '"+folder+"';LC_ALL=en_US.UTF-8 git remote update >> /dev/null 2>&1; git log "+ prefix+data.branch+
         " --pretty=oneline -n 1", {timeout: 60000, maxBuffer: MAXBUFFER},
    function(err, stdout, stderr) {
           var res = {};

if(err !== null)
             return cb(err);
           if (stdout.substring(0, 40) === data.revision.substring(0, 40))
             res.is_up_to_date = true;
           else
             res.is_up_to_date = false;
           res.new_revision = stdout.substring(0, 40);
           res.current_revision = data.revision.substring(0, 40);
           return cb(null, res);
    });
  });
};

git.revert = function(args, cb) {
  var ret = {};
  var command = "cd '"+args.folder+"';LC_ALL=en_US.UTF-8 git reset --hard "+args.revision;
  ret.output = '';
  ret.output += command + '\n';
  ret.success = true;
  exec(command, {timeout: TIMEOUT, maxBuffer: MAXBUFFER},
  function(err, stdout, stderr) {
    ret.output += stdout;
    if (err !== null || stderr.substring(0, 6) === 'fatal:')
      ret.success = false;
    return cb(null, ret);
  });
};

git.update = function(folder, cb) {
  git.isUpdated(folder, function(err, data) {
    var res = {};
    if (err !== null)
      return cb(err);
    if (data.is_up_to_date === true) {
      res.success = false;
      res.current_revision = data.new_revision;
      return cb(null, res);
    }
    else {
      git.revert({folder: folder, revision: data.new_revision},
      function (err, dt) {
        if (err !== null)
          return cb(err);
        res.output = dt.output;
        res.success = dt.success;
        res.current_revision = (dt.success) ? data.new_revision : data.current_revision;
        return cb(null, res);
      });
    }
  });
};

git.prev = function(folder, cb) {
  git.parse(folder, function(err, data) {
    if (err !== null)
      return cb(err);
    var res = {};
    if (data.prev_rev !== null) {
      git.revert({folder: folder, revision: data.prev_rev}, function(err, meta){
        if (err !== null)
          return cb(err);
        res.output = meta.output;
        res.success = meta.success;
        res.current_revision = (res.success) ? data.prev_rev : data.revision;
        return cb(null, res);
      });
    }
    else {
      res.success = false;
      res.current_revision = data.revision;
      return cb(null, res);
    }
  });
};

git.next = function(folder, cb) {
  git.parse(folder, function(err, data) {
    if (err !== null)
      return cb(err);
    var res = {};
    if (data.next_rev !== null) {
      git.revert({folder: folder, revision: data.next_rev}, function(err, meta){
        if (err !== null)
          return cb(err);
        res.output = meta.output;
        res.success = meta.success;
        res.current_revision = (res.success) ? data.next_rev : data.revision;
        return cb(null, res);
      });
    }
    else {
      res.success = false;
      res.current_revision = data.revision;
      return cb(null, res);
    }
  });
};

module.exports = git;

cmd: