gitlab-client.js

var request = require('request');
var async = require('async');


function GitlabClient(url, options) {
	this.url = url + '/api/v3/';
	this.options = options;
}

GitlabClient.prototype.auth = function(username, password, cb) {
	var isEmail = username.indexOf('@') !== -1;
	var params = {
		url: this.url + 'session',
		method: 'POST',
		json: {
			login: isEmail ? undefined : username,
			email: isEmail ? username : undefined,
			password: password
		},
		ca: this.options.caFile
	};
	request(params, function(error, response, body) {
		if(error) return cb(error);
		if(response.statusCode < 200 || response.statusCode >= 300) return cb('Invalid status code ' + response.statusCode);
		cb(null, body);
	});
};

GitlabClient.prototype.token = function (token, cb) {
	var params = {
		url: this.url + 'user',
		method: 'GET',
		qs: {
			private_token: token,
		},
		ca: this.options.caFile
	};
	request(params, function (error, response, user) {
		if (error) return cb(error);
		if (response.statusCode < 200 || response.statusCode >= 300) return cb('Invalid status code ' + response.statusCode);
		cb(null, user);
	});
};

GitlabClient.prototype.paginate = function(params, cb) {
	params.qs.per_page = 50;
	params.qs.page = 1;
	var results = [];
	var hasMore = true;
	async.whilst(function() {
		return hasMore;
	}, function(next) {
		request(params, function(error, response, body) {
			if(error) return cb(error);
			if(response.statusCode < 200 || response.statusCode >= 300) return next('Invalid status code ' + response.statusCode);
			body = JSON.parse(body);
			Array.prototype.push.apply(results, body);
			delete params.qs;
			if (!response.headers.link) {
				hasMore = false;
			} else {
				var linkParts = response.headers.link.split(/ *, */g);
				var linkNext;
				linkParts.forEach(function(part) {
					var partParts = part.split(/ *; */g);
					var rel, link;
					partParts.forEach(function(partPart) {
						var matches;
						matches = /^rel="([a-z]+)"$/.exec(partPart);
						if (matches) {
							rel = matches[1];
						}
						matches = /^<(.*)>$/.exec(partPart);
						if (matches) {
							link = matches[1];
						}
					});
					if (rel === 'next' && link) {
						linkNext = link;
					}
				});
				if (linkNext) {
					params.url = linkNext;
				} else {
					hasMore = false;
				}
			}
			next();
		});
	}, function(error) {
		if(error) return cb(error);
		cb(null, results);
	});
};

GitlabClient.prototype.listUsers = function(search, privateToken, cb) {
	this.paginate({
		url: this.url + 'users',
		qs: {
			private_token: privateToken,
			search: search
		},
		ca: this.options.caFile
	}, cb);
};

GitlabClient.prototype.listAllProjects = function(search, privateToken, cb) {
	this.paginate({
		url: this.url + 'projects/all',
		qs: {
			private_token: privateToken,
			search: search
		},
		ca: this.options.caFile
	}, cb);
};

GitlabClient.prototype.getProject = function(id, privateToken, cb) {
	request({
		url: this.url + 'projects/' + encodeURIComponent(id),
		qs: {
			private_token: privateToken
		},
		ca: this.options.caFile
	}, function(error, response, body) {
		if(error) return cb(error);
		if(response.statusCode == 404) return cb(null, null);
		if(response.statusCode < 200 || response.statusCode >= 300) return cb('Invalid status code ' + response.statusCode);
		cb(null, JSON.parse(body));
	});
};

GitlabClient.prototype.listProjects = function(search, privateToken, cb) {
	this.paginate({
		url: this.url + 'projects',
		qs: {
			private_token: privateToken,
			search: search
		},
		ca: this.options.caFile
	}, cb);
};

GitlabClient.prototype.getProjectTeamMember = function(projectId, userId, privateToken, cb) {
	request({
		url: this.url + 'projects/' + encodeURIComponent(projectId) + '/members/' + encodeURIComponent(userId),
		qs: {
			private_token: privateToken
		},
		ca: this.options.caFile
	}, function(error, response, body) {
		if(error) return cb(error);
		if(response.statusCode == 404) return cb(null, null);
		if(response.statusCode < 200 || response.statusCode >= 300) return cb('Invalid status code ' + response.statusCode);
		cb(null, JSON.parse(body));
	});
};

GitlabClient.prototype.listGroupMembers = function(groupId, privateToken, cb) {
	this.paginate({
		url: this.url + 'groups/' + groupId + '/members',
		qs: {
			private_token: privateToken
		},
		ca: this.options.caFile
	}, cb);
};

module.exports = GitlabClient;