Function controller_json_workflow

index.js:19391–19456

(id)

// Default action for workflow routing
function controller_json_workflow(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) {
				OPERATION(w.id, self.body, w.view ? self.callback(w.view) : self.callback(), self);
				return;
			}

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

			if (schema.meta[w.id] !== undefined) {
				w.type = '$' + w.id;
			} else if (schema.meta['workflow#' + w.id] !== undefined) {
				w.type = '$workflow';
				w.name = w.id;
			} else if (schema.meta['transform#' + w.id] !== undefined) {
				w.type = '$transform';
				w.name = w.id;
			} else if (schema.meta['operation#' + w.id] !== undefined) {
				w.type = '$operation';
				w.name = w.id;
			} else if (schema.meta['hook#' + w.id] !== undefined) {
				w.type = '$hook';
				w.name = w.id;
			}
		}

		if (w.name)
			self[w.type](w.name, self.callback(w.view));
		else {

			if (w.type)
				self[w.type](self.callback(w.view));
			else {
				var err = 'Schema "{0}" does not contain "{1}" operation.'.format(schema.name, w.id);
				if (self.route.isDYNAMICSCHEMA)
					self.throw404(err);
				else
					self.throw500(err);
			}