vars and exec tasks

etc/project

@@ -8,7 +8,7 @@
 
 	"initiator": {
 		"callback": {
-		
+
 			"flows": {
 				"test-basic": {
 					"tasks": [{
@@ -22,12 +22,6 @@
 							"{$uppercase}"
 						],
 						"$set": "result"
-//					}, {
-//							"$function":"console.print",
-//								"$args":[
-//									"Running equal...",
-//									"STRING against {$uppercase}"
-//								]
 					}]
 				},
 				"test-every-000": {

script/flow.js

@@ -4,7 +4,8 @@ module.exports = {
 	launchContext: function () {
 		return {
 			token:    process.argv[3],
-			param:     process.argv[4]
+			param:    process.argv[4],
+			params:   process.argv.slice(4)
 		};
 	},
 	launch: function (conf) {
@@ -21,7 +22,7 @@ module.exports = {
 		*/
 
 		var callbackIConf = conf.initiator['callback'];
-		
+
 		var callbackIClass = dataflows.initiator('callback');
 
 		if ('function' == typeof callbackIClass) {
@@ -32,7 +33,10 @@ module.exports = {
 
 		var flow = processor.process (this.launchContext().token, {
 			templates: {},
-			request: {param: this.launchContext().param},
+			request: {
+				param: this.launchContext().param,
+				params: this.launchContext().params
+			},
 			autoRun: false
 		});
 

task/exec.js

@@ -0,0 +1,27 @@
+var task = require ('dataflo.ws/task/base'),
+	util = require ('util'),
+	exec = require ('child_process').exec;
+
+var execTask = module.exports = function (config) {
+		this.init (config);
+};
+
+util.inherits (execTask, task);
+util.extend (execTask.prototype, {
+	run: function () {
+		var self = this;
+		var args = self.args || self.$args || [];
+		var options = self.options || [];
+
+		var cmd = self.command + ' ' + args.join(' ');
+
+		exec(cmd, options, function(error, stdout, stderr) {
+			if (error) {
+				self.failed(stderr);
+			} else {
+				self.completed(stdout || self.returnAnything);
+			}
+		});
+	}
+});
+

task/vars.js

@@ -0,0 +1,49 @@
+var task = require ('dataflo.ws/task/base'),
+	util = require ('util');
+
+var varsTask = module.exports = function (config) {
+		this.init (config);
+};
+
+util.inherits (varsTask, task);
+util.extend (varsTask.prototype, {
+	run: function () {
+		var self = this;
+		var args = self.args || self.$args;
+
+		var item = args.shift();
+		var funcName = args.shift();
+		var func = item[funcName];
+
+		if (typeof func == "function") {
+			self.completed( func.apply(item, args) );
+		} else {
+			self.failed(funcName + " is not a function");
+		}
+
+	},
+
+	concat: function() {
+		var self = this;
+		var args = self.args || self.$args;
+
+		self.completed(args.join(''));
+	},
+
+	join: function() {
+		var self = this;
+		var args = self.args || self.$args;
+		var clue = self.clue || self.delimiter;
+
+		self.completed(args.join(clue));
+	},
+
+	set: function() {
+		var self = this;
+		var args = self.args || self.$args;
+		var value = self.value || self.args[0];
+
+		self.completed(value);
+	}
+});
+