index.js

#!/usr/bin/env node
var Promise = require('bluebird'),
    _ = require('underscore'),
    rp = require('request-promise'),
    argv = require('yargs').argv;

require('dotenv-safe').config({
    path: `${process.cwd()}/.env`,
    example: `${__dirname}/.env.example`
});

function crash(e) {
    console.log(e);
    return process.exit(1);
}

var Pipeline = function({ user, token, url, jobName, parameters }) {
    this.url = `https://${user}:${token}@${url}/`;
    this.jenkins = require('jenkins')({
        baseUrl: this.url,
        crumbIssuer: true,
        promisify: true
    });
    this.options = {
        name: jobName,
        parameters: parameters
    };
}

Pipeline.prototype.getLatestBuildNumber = function() {
    return this.jenkins.job.get(this.options)
        .then(res => this.options.number = res.lastBuild.number)
        .catch(crash);
}

Pipeline.prototype.build = function() {
    return this.jenkins.job.build(this.options)
        .then(() => this.getLatestBuildNumber())
        .catch(crash)
}

Pipeline.prototype.stop = function() {
    return this.getLatestBuildNumber()
        .then(() => {
            console.log(`NOTICE: Stopping build #${this.options.number}`);
            return this.jenkins.build.stop(this.options);
        });
}

Pipeline.prototype.log = function() {
    var done = false,
    log = this.jenkins.build.logStream(this.options);

    log.on('data', function(text) {
        console.log(text);
    });

    log.on('end', function(res) {
        done = true;
    });

    log.on('error', function(err) {
        return Promise.reject(err);
    });

    (function resolver() {
        if (done) return Promise.resolve();
        setTimeout(resolver, 30);
    })();
}

function parseParams(params) {
    return _((params instanceof Array ? params : [params]))
        .reduce((memo, param) => {
            var p = param.split('=');
            memo[p[0]] = p[1];
            return memo;
    }, {});
}

module.exports = () => {
    var options = {
        user: process.env.JENKINS_USERNAME,
        token: process.env.JENKINS_USER_TOKEN,
        url: process.env.JENKINS_URL,
        jobName: process.env.JENKINS_JOB_NAME
    };

    if (argv.p && argv.p.length) {
        options.parameters = parseParams(argv.p);
    }

    var pipeline = new Pipeline(options);

    if (argv.stop) {
        return pipeline.stop()
            .then(() => pipeline.log)
            .then(() => {
                return process.exit();
            })
            .catch(e => {
                console.error(e);
                return process.exit(1);
            });
    }

    return pipeline.build(pipeline.options)
        .then(() => pipeline.log())
    // filter for dotenv-safe error where errors are missing
    // overwrite it's error message one that uses the correct path of user's .env file
        .catch((e) => { return e.name === 'MissingEnvVarsError'; },
               e => {
                   var message = `Missing the following variables in ${process.cwd()}/.env:`;
                   _(e.missing).each((key, i) => { message += `\n ${i+1}: ${key}`; });
                   return Promise.reject(new Error(message));
        })
        .catch(e => {
            console.error(e);
        });
};

module.exports();