@knetik/micro-queue/bin/cli-generate.js

#!/usr/bin/env node

const { QUEUE_ROOT } = require('@knetik/micro-queue');
const program = require('commander');
const path = require('path');
const fs = require('fs');
const Mustache = require('mustache');
const Inflector = require('inflected');

program
  .version('0.0.1')
  .usage('[options]')
  .parse(process.argv);

let template = "";
let rendered = "";
const job_name = program.args[0];
const filename = `${job_name}.job.js`;

if (!job_name) {
  throw new Error('job name parameter missing!!');
}

getTemplate()
  .then(_template => template = _template)
  .then(createTemplate)
  .then(_rendered => rendered = _rendered)
  .then(createDir)
  .then(writeFile)
  .catch(err => console.log(err));

function getTemplate() {
  return new Promise((resolve, reject) => {
    const templatePath = path.join(QUEUE_ROOT, '..', 'templates', 'job.mustache');
    fs.readFile(templatePath, 'utf8', (err, data) => {
      if (err) reject(err);
      resolve(data);
    });
  });
}

function createTemplate() {
  return Mustache.render(template, {
    name: Inflector.classify(job_name)
  });
}

function createDir() {
  return new Promise((resolve, reject) => {
    const dir = path.join(process.cwd(), 'app', 'jobs');

    if (!fs.existsSync(dir)) {
      fs.mkdirSync(dir);
    }

    resolve('done');
  });
}

function writeFile() {
  return new Promise((resolve, reject) => {
    const jobPath = path.join(process.cwd(), 'app', 'jobs', filename);
    fs.writeFile(jobPath, rendered, (err) => {
      if (err) reject(err);
      resolve('done');
    });
  });
}