cbd-cli/bin/cbd-deploy.js

#!/usr/bin/env node

const fs = require("vinyl-fs");
const FTP = require("vinyl-ftp");
const fsx = require("fs");
const program = require("commander");
const chalk = require("chalk");
const path = require("path");
const os = require("os");
// const uid = require("uid");
// const Download = require("download");
const inquirer = require("inquirer");
const logger = require("../lib/logger");
const exists = require("fs").existsSync;

const mDate = new Date();

const year = `${mDate.getFullYear()}`;
const curMonth = mDate.getMonth();
const month = curMonth + 1 > 9 ? curMonth + 1 : `0${curMonth + 1}`;

let pwdConf;
let ftppass;

const globs = [
  "cdn/**",
  "dist/**",
  "!src/**",
  "!*.sh",
  "!*.bat",
  "!.ftppass.json",
  "!.git",
  "!*.json",
  "!*.md",
  "!*.xml",
  "!assets",
  "!bower_components",
  "!gulpfile.js",
  "!node_modules",
  "!node_modules/**",
];


/**
 * Usage.
 */

program
  .usage("<remote-dir> <dir-name>")
// .usage('[root-dir] <remote-dir> [dir-name]')
  .option("-f, --force", "重置密码")
  .option("-s, --source", "上传源文件夹")
  .option("-r, --release", "发布生产环境代码至CDN");

/**
 * Help.
 */

program.on("--help", () => {
  console.log("  Examples:");
  console.log();
  console.log(chalk.gray("    # 发布到zhuanti release目录下的my-project目录"));
  console.log("    $ cbd deploy release my-project");
  console.log();
  console.log(chalk.gray("    # 发布到zhuanti release目录下的默认本地文件夹名目录"));
  console.log("    $ cbd deploy release");
  console.log();
  console.log(chalk.gray("    # 发布到zhuanti release/wx目录下的默认本地文件夹名目录"));
  console.log("    $ cbd deploy release/wx");
  console.log();
});


/**
 * Help.
 */

function help() {
  program.parse(process.argv);

  // if (program.args.length < 1) return program.help()
}
help();


/**
 * Padding.
 */

console.log();
process.on("exit", () => {
  console.log();
});


const reset = program.force || false;

const source = program.source || false;

function inputPwd(params) {
  ftppass = {
    host: "182.254.247.29",
    user: params.username,
    password: params.password,
    parallel: 10,
    log: logger.log,
    // debug: console.log.bind(console)
  };
}

function upload(config, dest) {


  const base = source ? "./" : (exists("./cdn") ? "./cdn" : "./dist");
  const pipeFiles = fs.src(globs, {
    base,
    buffer: false
  });
  const conn = new FTP(config);
  pipeFiles
    .pipe(conn.newer(dest))
    .pipe(conn.dest(dest));
}

function uploader() {
  let remoteDir;
  let remoteDirSub;
  let rootDir;
  let dest;

  const args = program.args.slice(0);
  if (args.length > 2) {
    rootDir = args[0];
    remoteDir = args[1]; // 远程目录
    remoteDirSub = args[2] || path.relative("../", process.cwd());

    dest = path.join(rootDir, remoteDir, remoteDirSub);
  } else if (args.length === 2) {
    remoteDir = args[0]; // 远程目录
    remoteDirSub = args[1] || path.relative("../", process.cwd());
    dest = path.join("/zhuanti/", remoteDir, remoteDirSub);
  } else {
    var uploadDir = readUploadDir();
    if (uploadDir) {
      dest = uploadDir;
    } else {
      dest = path.join("/zhuanti/release/app/", year, month, path.relative("../", process.cwd()));
    }
  }

  // console.log('上传至：'+ 'http://zhuanti.chebada.com/'+dest.replace(/\\/g,'/'));

  const prompt = {
    type: "confirm",
    name: "confirm",
    default: false,
    message: `确定要上传至http://zhuanti.chebada.com/${dest.replace(/\\/g, "/")}`,
  };
  inquirer.prompt(prompt).then((answers) => {
    if (answers.confirm) {
      upload(ftppass, dest);
    }
  });
}

function ftpLogin() {
  const prompts = [{
    name: "username",
    type: "input",
    required: true,
    message: "ftp账号",
  },
  {
    name: "password",
    type: "password",
    required: true,
    message: "ftp密码",
  },
  ];

  const tmp = path.join(`${os.tmpdir()}/cbd-key/`);

  const ftpjson = `${tmp}ftppass.json`;

  if (fsx.existsSync(ftpjson) && !reset) {
    const file = fsx.readFileSync(ftpjson, "utf-8");
    pwdConf = JSON.parse(file);

    inputPwd(pwdConf);
    uploader();
  } else {
    inquirer.prompt(prompts).then((answers) => {
      inputPwd(answers);
      uploader();
      if (!fsx.existsSync(tmp)) {
        fsx.mkdirSync(tmp); // 创建目录
      }

      fsx.writeFile(`${tmp}ftppass.json`, JSON.stringify(answers), "utf8", (err) => {
        if (err) throw err;
        console.log("It's saved!");
      });
    });
  }
}

function readUploadDir() {
  var data = fsx.readFileSync(path.join(process.cwd(), "./package.json"));
  if (data) {
    var pkg = data.toString();
    pkg = JSON.parse(pkg);
    if (pkg.uploadDir) {
      return pkg.uploadDir;
    }
    return null;

  }
}


ftpLogin();