@athenadevops/cli/bin/athena-deploy.js

#!/usr/bin/env node

const path = require('path');
const fs = require('fs');
const { spawn } = require('child_process');
const program = require('commander');
const chalk = require('chalk');
// internal
const { version } = require('../package.json');
// scope
const basedir = process.cwd();
const terminal = chalk.cyan('athena:');
const environments = ['uat', 'uat2', 'wuxi', 'wuxiB'];
const success = chalk.cyan(`deploy success...`);

function validate() {
  if (!program.playbook || !program.inventory) {
    throw new Error(
      `The playbook, inventory options is required, please verify again.`
    );
  }

  if (!environments.includes(program.environment)) {
    throw new Error(
      `none supported runtime environment --> ${program.environment}`
    );
  }

  const key = `ANSIBLE_SUDO_PASS_${program.environment.toUpperCase()}`;
  const password = Reflect.get(process.env, key);

  if (!password) {
    throw new Error(
      `The environment sudo password is required, please verify again.`
    );
  }

  const inventory = path.resolve(basedir, program.inventory);
  const playbook = path.resolve(basedir, program.playbook);

  if (!fs.existsSync(playbook)) {
    throw new Error(`The playbook --> ${playbook} not exist`);
  }

  if (!fs.existsSync(inventory)) {
    throw new Error(`The inventory --> ${playbook} not exist`);
  }
}

function deploy() {
  const key = `ANSIBLE_SUDO_PASS_${program.environment.toUpperCase()}`;
  const password = Reflect.get(process.env, key);
  const ansible = spawn('ansible-playbook', [
    program.playbook,
    '-i',
    program.inventory,
    '--extra-vars',
    `ansible_sudo_pass=${password}`,
  ]);

  ansible.stdout.pipe(process.stdout);
  ansible.stderr.pipe(process.stderr);

  return new Promise((resolve, reject) => {
    ansible.on('error', (error) => reject(error));
    ansible.on('close', () => resolve());
  });
}

async function pipeline() {
  try {
    await validate();
    await deploy();

    /* eslint-disable no-console */
    console.log(`${terminal} ${success}`);
    /* eslint-enable no-console */
  } catch (err) {
    /* eslint-disable no-console */
    console.error(err.stack);
    /* eslint-disable no-console */
    process.exit(1);
  }
}

program
  .version(version)
  .option('-i, --inventory <inventory>', 'ansible machine inventory')
  .option('-p, --playbook <playbook>', 'ansible task compose')
  .parse(process.argv);

pipeline();