nci/lib/scm/base.js

'use strict';

var spawn = require('child_process').spawn,
	EventEmitter = require('events').EventEmitter,
	inherits = require('util').inherits;

function BaseScm(params) {
	this.repository = params.repository;
	this.cwd = params.cwd;
	if (!this.repository && !this.cwd) throw new Error(
		'`repository` or `cwd` must be set'
	);
}

module.exports = BaseScm;

inherits(BaseScm, EventEmitter);

BaseScm.prototype._exec = function(command, args, callback) {
	var self = this,
		stdout = '';
	var cmd = spawn(command, args, {cwd: this.cwd});
	cmd.stdout.on('data', function(data) {
		if (self.isEmit) self.emit('stdout', data);
		stdout += data;
	});
	cmd.stderr.on('data', function(data) {
		callback(new Error('Scm outputs to stderr: ' + data));
		cmd.kill();
	});
	cmd.on('exit', function(code) {
		var err = null;
		if (code !== 0) err = new Error(
			'Scm command exits with non-zero code: ' + code
		);
		callback(err, stdout);
	});
	return cmd;
};

/**
 * Clone repository to the `dst` update to `rev` and  set `this.cwd` to `dst`
 */
BaseScm.prototype.clone = function(dst, rev, callback) {
};

/**
 * Pull changes from remote repository without update
 */
BaseScm.prototype.pull = function(rev, callback) {
};

/**
 * Returns string id of current revision
 */
BaseScm.prototype.getId = function(callback) {
};

/**
 * Returns array of changes between revisions
 */
BaseScm.prototype.getChanges = function(rev1, rev2, callback) {
};

/**
 * Updates to revision
 */
BaseScm.prototype.update = function(rev, callback) {
};