refactor request/process flows (#12)

* refactor request/process flows

* print error and report to monitor in case of uncaught exception

* change timeout ot 60 seconds

* bump version

Author: itai-codefresh

.gitignore

@@ -1 +1,2 @@
-node_modules
+node_modules
+coverage

.jshintrc

@@ -0,0 +1,26 @@
+
+{
+  "eqeqeq": true,
+  "immed": true,
+  "latedef": "nofunc",
+  "newcap": false,
+  "noarg": true,
+  "sub": true,
+  "undef": true,
+  "unused": true,
+  "boss": true,
+  "eqnull": true,
+  "node": true,
+  "indent": 10,
+  "esnext": true,
+  "globals"   : {
+    /* MOCHA */
+    "describe"   : false,
+    "it"         : false,
+    "before"     : false,
+    "beforeEach" : false,
+    "after"      : false,
+    "afterEach"  : false
+  }
+
+}

.travis.yml

@@ -0,0 +1,32 @@
+"use strict";
+
+var Queue  = require('../lib/queue');
+
+process.on('uncaughtException', function (err)
+{
+    console.error('Uncaught Exception:' + err.stack);
+});
+
+var queue = new Queue("myChannel", {
+    workers: 50,
+    servers: ['nats://192.168.99.100:4222'],
+    timeout: 1000
+});
+
+var req = {
+    field: "myField"
+};
+
+
+for (var i = 0; i < 1; i++){
+    queue.request(req)
+        .then(function (res) { // jshint ignore:line
+            console.log(`finished: ${JSON.stringify(res)}`);
+        })
+        .progress(function (info) { // jshint ignore:line
+            console.log(`progress: ${info.toString()}`);
+        })
+        .catch(function (err) { // jshint ignore:line
+            console.error(`error: ${JSON.stringify(err.toString())}`);
+        });
+}

docker-compose.yml

@@ -0,0 +1,20 @@
+"use strict";
+
+var Queue = require('../lib/queue');
+
+var queue = new Queue("myChannel", {
+    workers: 50,
+    servers: ['nats://192.168.99.100:4222']
+});
+
+
+
+queue.process(function(request, callback){
+    request.progress("progress");
+    setTimeout(() => {
+        console.log(`got request: ${JSON.stringify(request)}`);
+        callback(null, "ok");
+        //callback(null, "ok");
+        request.progress("progress");
+    }, 4000);
+});

example/queueClient.js

@@ -0,0 +1,107 @@
+var gulp        = require('gulp');
+var jshint      = require('gulp-jshint');
+var rimraf      = require('gulp-rimraf');
+var env         = require('gulp-env');
+var runSequence = require('run-sequence');
+var fs          = require('fs');
+var coveralls   = require('gulp-coveralls');
+var istanbul    = require('gulp-istanbul');
+var isparta     = require('isparta');
+var mocha       = require('gulp-mocha-co');
+require('shelljs/global');
+
+gulp.task('no.onlys', function (callback) {
+	exec('find . -path "*/*.spec.js" -type f -exec grep -l "describe.only" {} + \n find . -path "*/*.spec.js" -type f -exec grep -l "it.only" {} +', function (code, output) { // jshint ignore:line
+		if (output) return callback(new Error("The following files contain .only in their tests"));
+		return callback();
+	});
+});
+
+
+gulp.task('lint', ['clean'], function () {
+	return gulp.src(['**/*.js', '!**/node_modules/**', '!**/server/migration/**', '!coverage/**/*.js'])
+		.pipe(jshint({lookup: true}))
+		.pipe(jshint.reporter('default'))
+		.pipe(jshint.reporter('fail'));
+});
+
+gulp.task('set_unit_env_vars', function () {
+	env({
+		vars: {
+		}
+	});
+});
+
+gulp.task('unit_pre', function () {
+	return gulp.src(['**/*.js', '!**/*.spec.js', '!**/node_modules/**/*.js', '!.debug/**/*.js', '!gulpfile.js', '!coverage/**/*.js'])
+		.pipe(istanbul({ // Covering files
+			instrumenter: isparta.Instrumenter,
+			includeUntested: true
+		}))
+		.pipe(istanbul.hookRequire()) // Force `require` to return covered files
+		.on('finish', function () {
+			gulp.src(['**/*.unit.spec.js', '!**/node_modules/**/*.js'], {read: false})
+				.pipe(mocha({reporter: 'spec', timeout: '10000'}))
+				.pipe(istanbul.writeReports({
+					reporters: ['lcov'],
+					reportOpts: {dir: 'coverage'}
+				}))
+				.once('end', function () {
+					process.exit();
+				});
+		});
+});
+
+
+gulp.task('set_integ_env_vars', function () {
+	env({
+		vars: {
+		}
+	});
+});
+
+gulp.task('integ_pre', function () {
+	return gulp.src(['**/*.integ.spec.js', '!**/node_modules/**/*.js'], {read: false})
+		.pipe(mocha({reporter: 'spec', timeout: '10000'}))
+		.once('end', function () {
+			process.exit();
+		});
+});
+
+
+
+gulp.task('clean', function () {
+	return gulp.src(['.coverdata', '.debug', '.coverrun'], {read: false})
+		.pipe(rimraf());
+});
+
+
+gulp.task('unit_test', function (callback) {
+	runSequence('set_unit_env_vars',
+		'unit_pre',
+		callback);
+});
+
+gulp.task('integ_test', function (callback) {
+	runSequence('set_integ_env_vars',
+		'integ_pre',
+		callback);
+});
+
+gulp.task('coveralls', function (callback) {
+	var repo_token = process.env.COVERALLS_TOKEN;
+	if (!repo_token) {
+		return callback(new Error("COVERALLS_TOKEN environment variable is missing"));
+	}
+	else {
+		fs.writeFile(".coveralls.yml", "service_name: codefresh-io\nrepo_token: " + repo_token, function (err) {
+			if (err) {
+				callback(err);
+			}
+			else {
+				gulp.src('coverage/lcov.info')
+					.pipe(coveralls());
+			}
+		});
+	}
+});