Function async_middleware

index.js:19149–19225

(index, req, res, middleware, callback, options, controller)

}

function async_middleware(index, req, res, middleware, callback, options, controller) {

	if (res.success || res.headersSent || res.finished) {
		req.$total_route && req.$total_success();
		callback = null;
		return;
	}

	var name = middleware[index++];
	if (!name)
		return callback && callback(req, res);

	var item = F.routes.middleware[name];
	if (!item) {
		F.error('Middleware not found: ' + name, null, req.uri);
		return async_middleware(index, req, res, middleware, callback, options, controller);
	}

	var output;
	var $now;

	if (CONF.logger)
		$now = Date.now();

	if (item.$newversion) {
		var opt = req.$total_middleware;
		if (!index || !opt) {
			opt = req.$total_middleware = new MiddlewareOptions();
			opt.req = req;
			opt.res = res;
			opt.middleware = middleware;
			opt.options = options || EMPTYOBJECT;
			opt.controller = controller;
			opt.callback2 = callback;
			opt.next = function(err) {
				CONF.logger && F.ilogger(getLoggerMiddleware(name), req, $now);
				var mid = req.$total_middleware;
				if (err === false) {
					req.$total_route && req.$total_success();
					req.$total_middleware = null;
					callback = null;
				} else if (err instanceof Error || err instanceof ErrorBuilder) {
					res.throw500(err);
					req.$total_middleware = null;
					callback = null;
				} else
					async_middleware(mid.index, mid.req, mid.res, mid.middleware, mid.callback2, mid.options, mid.controller);
			};
		}

		opt.index = index;
		output = item(opt);

	} else {
		output = item.call(framework, req, res, function(err) {
			CONF.logger && F.ilogger(getLoggerMiddleware(name), req, $now);
			if (err === false) {
				req.$total_route && req.$total_success();