Function controller_json_workflow_multiple

index.js:19459–19514

(id)

// Default action for workflow routing
function controller_json_workflow_multiple(id) {

	var self = this;
	var w = self.route.workflow;

	self.id = self.route.paramidindex === -1 ? id : self.req.split[self.route.paramidindex];
	CONF.logger && (self.req.$logger = []);

	if (w instanceof Object) {
		if (!w.type) {

			// IS IT AN OPERATION?
			if (!self.route.schema.length) {
				RUN(w.id, self.body, w.view ? self.callback(w.view) : self.callback(), null, self, w.index != null ? w.id[w.index] : null);
				return;
			}

			var schema = self.route.isDYNAMICSCHEMA ? framework_builders.findschema(self.route.schema[0] + '/' + self.params[self.route.schema[1]]) : GETSCHEMA(self.route.schema[0], self.route.schema[1]);
			if (!schema) {
				self.throw500('Schema "{0}" not found.'.format(getSchemaName(self.route.schema, self.isDYNAMICSCHEMA ? self.params : null)));
				return;
			}

			var op = [];
			for (var i = 0; i < w.id.length; i++) {
				var id = w.id[i];
				if (schema.meta[id] !== undefined) {
					op.push({ name: '$' + id });
				} else if (schema.meta['workflow#' + id] !== undefined) {
					op.push({ name: '$workflow', id: id });
				} else if (schema.meta['transform#' + id] !== undefined) {
					op.push({ name: '$transform', id: id });
				} else if (schema.meta['operation#' + id] !== undefined) {
					op.push({ name: '$operation', id: id });
				} else if (schema.meta['hook#' + id] !== undefined) {
					op.push({ name: '$hook', id: id });
				} else {
					// not found
					self.throw500('Schema "{0}" does not contain "{1}" operation.'.format(schema.name, id));
					return;
				}
			}
			w.async = op;
		}

		var async = self.$async(self.callback(w.view), w.index);
		for (var i = 0; i < w.async.length; i++) {
			var a = w.async[i];
			if (a.id)
				async[a.name](a.id);
			else
				async[a.name]();
		}
	} else
		self.$exec(w, null, self.callback(w.view));
}

function ilogger(body) {