dataflo.ws/test/004-template.js

var assert   = require('assert');

var util     = require ('util');
var path     = require ('path');

var baseName = path.basename (__filename, path.extname (__filename));

var df     = require ("../");
var flow   = require ("../flow");

// dirty, but works
// TODO: need to rewrite
require ("./common");

var verbose = true;

var tests = [];

//process.on('uncaughtException', failure ('unhadled exception'));

var dataflows = require ("./004-template.json");

var templates = {
	"jsonParseAndMerge": {
		"$origin":    "{$global.JSON}",
		"$function":  "parse",
		"$mergeWith": "result"
	},
	"jsonParseAndSet": {
		"$origin":    "{$global.JSON}",
		"$function":  "parse",
		"$set":       "result"
	},
	"indexEqItem": {
		"$function": "dfThrowUnlessEqual",
		"$args": [
			"[*every.index]",
			"[*every.item]"
		]
	},
	"testHttpResource": {
		"$class":"remoteResource",
		"$method": "toBuffer"
	}
};

// var testOnly = "test:08-every-template";
var verbose = false;

describe (baseName + " running templates", function () {
	Object.keys (dataflows).forEach (function (token) {
		var item = dataflows[token];

		var method = it;

		if (typeof testOnly !== "undefined" && testOnly) {
			if (testOnly === token) {
				method = it.only;
				verbose = true;
			} else {
				return;
			}
		}

		method (item.description ? item.description + ' ('+token+')' : token, function (done) {

			var df = new flow ({
				tasks: item.tasks,
				templates: templates,
				logger: verbose || "VERBOSE" in process.env ? undefined : function () {}
			});

			if (!df.ready) {
				console.log ("dataflow not ready");
				assert (item.expect === "no-dataflow" ? true : false);
				done ();
				return;
			}

			df.on ('completed', function () {
				assert (item.expect === "ok" ? true : false);
				done ();
			});

			df.on ('failed', function () {
				assert (item.expect === "fail" ? true : false);
				done ();
			});

			if (item.autoRun || item.autoRun == void 0)
				df.run();

		});
	});
});