jenkins-upload.js

"use strict";

var gulp = require('gulp');
var jenkinsProperties = require('./jenkins-properties');
var jenkins = require('jenkins')(jenkinsProperties.connection);
var fs = require('fs');

gulp.task('jenkinsUpload', function() {

	var projectName = process.env.npm_config_project_name;
	if (projectName === undefined) {
		projectName = "";
	}
	var artifactGroup = process.env.npm_config_artifact_group;
	if (artifactGroup === undefined) {
		artifactGroup = "";
	}
	var artifactId = process.env.npm_config_artifact_id;
	if (artifactId === undefined) {
		artifactId = "";
	}
	var gitRepo = process.env.npm_config_git_repo;
	if (gitRepo === undefined) {
		gitRepo = "";
	}
	var gitGroup = process.env.npm_config_git_group;
	if (gitGroup === undefined) {
		gitGroup = "";
	}
	
	function getAllJobs() {

		fs.readdir("jobs-upload", function(err, files) {

			if (err){
				return console.log(err);
			}
			
			if (files.length) {
				var callback = function(i) {
					i++;
					if (i < files.length) {
						getFile(files[i], i, callback);
					}
				};
				getFile(files[0], 0, callback);
			}
			
		});
	}

	function getFile(file, index, callback){
		
		fs.readFile("jobs-upload/" + file, 'utf8', function(err, data) {
			if (err){
				return console.log(err);
			}
			checkJob(replacePlaceholder(file.replace(".xml", "")), replacePlaceholder(data), index, callback);
		});
	}

	function checkJob(name, content, index, callback) {

		jenkins.job.exists(name, function(err, exists) {
			if (err) throw err;

			if(exists) {
				updateJob(name, content, index, callback);
			}
			else {
				createJob(name, content, index, callback);
			}
		});
	}

	function createJob(name, content, index, callback) {

		jenkins.job.create(name, content, function(err) {
			if (err) throw err;
			console.log(name + " created.");
			callback(index);
		});
	}

	function updateJob(name, content, index, callback) {

		jenkins.job.config(name, content, function(err) {
			if (err) throw err;
			console.log(name + " updated.");
			callback(index);
		});
	}
	
	function replacePlaceholder(str) {
		return str.replace(new RegExp('#GIT_GROUP#', 'g'), gitGroup)
			.replace(new RegExp('#GIT_REPO#', 'g'), gitRepo)
			.replace(new RegExp('#PROJECT_NAME#', 'g'), projectName)
			.replace(new RegExp('#ARTIFACT_GROUP#', 'g'), artifactGroup)
			.replace(new RegExp('#ARTIFACT_ID#', 'g'), artifactId);
	}

	getAllJobs();
});