git.js

const { exec, execCommand } = require('./util');
// @BUG 新的没有改动可提交的时候会报错？

const GIT_TYPE_MAP = {
  '??': 'add',
  D: 'delete',
  M: 'update',
};
const parseStatus = (data) => {
  const result = [];
  data.split('\n').forEach((changedItem) => {
    const [type, path] = changedItem.trim().split(' ');
    if (!type || !path) return;
    result.push({
      rawType: type,
      type: GIT_TYPE_MAP[type],
      path,
    });
  });
  return result;
};

const LOG_SEPERATOR = '<seperator>';
const parseLog = (data) => {
  const result = [];
  data.split('\n').forEach((commit) => {
    const [version, author, date, message] = commit.split(LOG_SEPERATOR);
    result.push({
      version,
      author,
      date: date.slice(0, 19), // 2019-03-31 13:36:28 +0800 => 2019-03-31 13:36:28
      msg: message,
    });
  });
  return result;
};

class Git {
  static async status(codePath) {
    // -s means short: show git status message in short-format
    const command = 'git status -s';
    let statusData = [];
    await exec(command, codePath)
      .then((data) => {
        statusData = parseStatus(data);
      })
      .catch(() => {
        statusData = false;
      });
    return statusData;
  }

  // @TODO 支持查询位置
  static async log(codePath) {
    const countLimit = 10;
    const command = `git log -n ${countLimit} --pretty=format:'%h${LOG_SEPERATOR}%an${LOG_SEPERATOR}%ai${LOG_SEPERATOR}%s'`;
    let logData = [];
    await exec(command, codePath)
      .then((data) => {
        logData = parseLog(data);
      })
      .catch((error) => {
        if (!error.message.includes('does not have any commits yet')) console.log(error);
        return [];
      });
    return logData;
  }

  static async update(codePath) {
    const command = 'git pull --rebase';
    return await execCommand(command, codePath);
  }

  static async addAll(codePath) {
    const command = 'git add --all';
    return await execCommand(command, codePath);
  }

  static async push(codePath) {
    const command = 'git push';
    return await execCommand(command, codePath);
  }

  static async commit(codePath, commitMsg) {
    const command = `git commit -m '${commitMsg}'`;
    await this.addAll(codePath);
    const result = { error: false, msg: '' };
    await exec(command, codePath)
      .then((data) => {
        result.msg = data;
      })
      .catch((error) => {
        // @BUG 新的没有改动可提交的时候会报错？
        result.error = true;
        result.msg = error;
      });
    return result;
  }

  static async revert(codePath, version) {
    const result = { error: false, msg: '' };
    const command = `git reset ${version} --hard`;
    if (!version) {
      result.error = true;
      result.msg = 'version is required!';
      return result;
    }
    await exec(command, codePath)
      .then((data) => {
        result.msg = data;
      })
      .catch((error) => {
        result.error = true;
        result.msg = error;
      });
    return result;
  }
}

module.exports = Git;