nci/resources/projects.js

'use strict';

var Steppy = require('twostep').Steppy,
	_ = require('underscore'),
	getAvgProjectBuildDuration =
		require('../lib/project').getAvgProjectBuildDuration,
	createBuildDataResource = require('../distributor').createBuildDataResource,
	logger = require('../lib/logger')('projects resource'),
	db = require('../db');

module.exports = function(app) {

	var resource = app.dataio.resource('projects'),
		distributor = app.distributor;

	resource.use('createBuildDataResource', function(req, res) {
		createBuildDataResource(req.data.buildId);
		res.send();
	});

	resource.use('readAll', function(req, res) {
		var filteredProjects = app.projects,
			nameQuery = req.data && req.data.nameQuery;

		if (nameQuery) {
			filteredProjects = _(filteredProjects).filter(function(project) {
				return project.name.indexOf(nameQuery) !== -1;
			});
		}

		res.send(filteredProjects);
	});

	var getProject = function(params, callback) {
		var project;
		Steppy(
			function() {
				project = _(app.projects).findWhere(params.condition);

				getAvgProjectBuildDuration(project.name, this.slot());

				// get last done build
				db.builds.find({
					start: {
						projectName: project.name,
						status: 'done',
						descCreateDate: ''
					},
					limit: 1
				}, this.slot());

				// tricky but effective streak counting inside filter goes below
				var doneBuildsStreakCallback = _(this.slot()).once(),
					doneBuildsStreak = 0;

				db.builds.find({
					start: {
						projectName: project.name,
						descCreateDate: ''
					},
					filter: function(build) {
						// error exits streak
						if (build.status === 'error') {
							doneBuildsStreakCallback(null, doneBuildsStreak);
							return true;
						}
						if (build.status === 'done') {
							doneBuildsStreak++;
						}
					},
					limit: 1
				}, function(err) {
					doneBuildsStreakCallback(err, doneBuildsStreak);
				});
			},
			function(err, avgProjectBuildDuration, lastDoneBuilds, doneBuildsStreak) {
				project.lastDoneBuild = lastDoneBuilds[0];
				project.avgBuildDuration = avgProjectBuildDuration;
				project.doneBuildsStreak = doneBuildsStreak;

				this.pass(project);
			},
			callback
		);
	};

	// resource custom method which finds project by condition
	// and emits event about it change to clients
	resource.clientEmitSyncChange = function(condition) {
		Steppy(
			function() {
				getProject({condition: condition}, this.slot());
			},
			function(err, project) {
				resource.clientEmitSync('change', {project: project});
			},
			function(err) {
				console.error(
					'Error during sync project change occurred:',
					err.stack || err
				);
			}
		);
	};

	resource.use('read', function(req, res) {
		Steppy(
			function() {
				getProject({condition: req.data}, this.slot());
			},
			function(err, project) {
				res.send(project);
			}
		);
	});

	resource.use('run', function(req, res) {
		var projectName = req.data.projectName;
		logger.log('Run the project: "%s"', projectName);
		distributor.run({
			projectName: projectName,
			initiator: {type: 'user'}
		});
		res.send();
	});

	return resource;
};