// Copyright 2012-2016 (c) Peter Širka <petersirka@gmail.com>

//

// Permission is hereby granted, free of charge, to any person obtaining a

// copy of this software and associated documentation files (the

// "Software"), to deal in the Software without restriction, including

// without limitation the rights to use, copy, modify, merge, publish,

// distribute, sublicense, and/or sell copies of the Software, and to permit

// persons to whom the Software is furnished to do so, subject to the

// following conditions:

//

// The above copyright notice and this permission notice shall be included

// in all copies or substantial portions of the Software.

//

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN

// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,

// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR

// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE

// USE OR OTHER DEALINGS IN THE SOFTWARE.

/**

* @module Framework

* @version 2.1.0

*/

'use strict';

const qs = require('querystring');

const os = require('os');

const fs = require('fs');

const zlib = require('zlib');

const path = require('path');

const crypto = require('crypto');

const parser = require('url');

const events = require('events');

const http = require('http');

const child = require('child_process');

const util = require('util');

const ENCODING = 'utf8';

const RESPONSE_HEADER_CACHECONTROL = 'Cache-Control';

const RESPONSE_HEADER_CONTENTTYPE = 'Content-Type';

const RESPONSE_HEADER_CONTENTLENGTH = 'Content-Length';

const CONTENTTYPE_TEXTPLAIN = 'text/plain';

const CONTENTTYPE_TEXTHTML = 'text/html';

const REQUEST_COMPRESS_CONTENTTYPE = { 'text/plain': true, 'text/javascript': true, 'text/css': true, 'text/jsx': true, 'application/x-javascript': true, 'application/json': true, 'text/xml': true, 'image/svg+xml': true, 'text/x-markdown': true, 'text/html': true };

const TEMPORARY_KEY_REGEX = /\//g;

const REG_MOBILE = /Android|webOS|iPhone|iPad|iPod|BlackBerry|IEMobile|Opera Mini|Mobile|Tablet/i;

const REG_ROBOT = /search|agent|bot|crawler|spider/i;

const REG_VERSIONS = /(href|src)="[a-zA-Z0-9\/\:\-\.]+\.(jpg|js|css|png|gif|svg|html|ico|json|less|sass|scss|swf|txt|webp|woff|woff2|xls|xlsx|xml|xsl|xslt|zip|rar|csv|doc|docx|eps|gzip|jpe|jpeg|manifest|mov|mp3|mp4|ogg|package|pdf)"/gi;

const REG_MULTIPART = /\/form\-data$/i;

const REG_COMPILECSS = /url\(.*?\)/g;

const REG_ROUTESTATIC = /^(\/\/|https\:|http\:)+/;

const REG_EMPTY = /\s/g;

const REG_SANITIZE_BACKSLASH = /\/\//g;

const REG_WEBSOCKET_ERROR = /ECONNRESET|EHOSTUNREACH|EPIPE|is closed/i;

const REG_WINDOWSPATH = /\\/g;

const REG_SCRIPTCONTENT = /\<|\>|;/;

const REG_HTTPHTTPS = /^(\/)?(http|https)\:\/\//i;

const REG_TEXTAPPLICATION = /text|application/;

const REQUEST_PROXY_FLAGS = ['post', 'json'];

const EMPTYARRAY = [];

const EMPTYOBJECT = {};

const EMPTYREQUEST = { uri: {} };

const SINGLETONS = {};

const REPOSITORY_HEAD = '$head';

const REPOSITORY_META = '$meta';

const REPOSITORY_META_TITLE = '$title';

const REPOSITORY_META_DESCRIPTION = '$description';

const REPOSITORY_META_KEYWORDS = '$keywords';

const REPOSITORY_META_AUTHOR = '$author';

const REPOSITORY_META_IMAGE = '$image';

const REPOSITORY_PLACE = '$place';

const REPOSITORY_SITEMAP = '$sitemap';

const ATTR_END = '"';

Object.freeze(EMPTYOBJECT);

Object.freeze(EMPTYARRAY);

Object.freeze(EMPTYREQUEST);

global.EMPTYOBJECT = EMPTYOBJECT;

global.EMPTYARRAY = EMPTYARRAY;

var RANGE = { start: 0, end: 0 };

var HEADERS = {};

var SUCCESSHELPER = { success: true };

// Cached headers for repeated usage

HEADERS['responseCode'] = {};

HEADERS['responseCode'][RESPONSE_HEADER_CONTENTTYPE] = CONTENTTYPE_TEXTPLAIN;

HEADERS['responseRedirect'] = {};

HEADERS['responseRedirect'][RESPONSE_HEADER_CONTENTTYPE] = CONTENTTYPE_TEXTHTML + '; charset=utf-8';

HEADERS['responseRedirect'][RESPONSE_HEADER_CONTENTLENGTH] = '0';

HEADERS['sse'] = {};

HEADERS['sse'][RESPONSE_HEADER_CACHECONTROL] = 'no-cache, no-store, must-revalidate';

HEADERS['sse']['Pragma'] = 'no-cache';

HEADERS['sse']['Expires'] = '0';

HEADERS['sse'][RESPONSE_HEADER_CONTENTTYPE] = 'text/event-stream';

HEADERS['mmr'] = {};

HEADERS['mmr'][RESPONSE_HEADER_CACHECONTROL] = 'no-cache, no-store, must-revalidate';

HEADERS['mmr']['Pragma'] = 'no-cache';

HEADERS['mmr']['Expires'] = '0';

HEADERS['proxy'] = {};

HEADERS['proxy']['X-Proxy'] = 'total.js';

HEADERS['responseFile.etag'] = {};

HEADERS['responseFile.etag']['Last-Modified'] = 'Mon, 01 Jan 2001 08:00:00 GMT';

HEADERS['responseFile.etag']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.etag'][RESPONSE_HEADER_CACHECONTROL] = 'public, max-age=11111111';

HEADERS['responseFile.release.compress'] = {};

HEADERS['responseFile.release.compress'][RESPONSE_HEADER_CACHECONTROL] = 'public, max-age=11111111';

HEADERS['responseFile.release.compress']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.release.compress']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.release.compress']['Last-Modified'] = 'Mon, 01 Jan 2001 08:00:00 GMT';

HEADERS['responseFile.release.compress']['Content-Encoding'] = 'gzip';

HEADERS['responseFile.release.compress.range'] = {};

HEADERS['responseFile.release.compress.range']['Accept-Ranges'] = 'bytes';

HEADERS['responseFile.release.compress.range'][RESPONSE_HEADER_CACHECONTROL] = 'public, max-age=11111111';

HEADERS['responseFile.release.compress.range']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.release.compress.range']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.release.compress.range']['Last-Modified'] = 'Mon, 01 Jan 2001 08:00:00 GMT';

HEADERS['responseFile.release.compress.range']['Content-Encoding'] = 'gzip';

HEADERS['responseFile.release.compress.range'][RESPONSE_HEADER_CONTENTLENGTH] = '0';

HEADERS['responseFile.release.compress.range']['Content-Range'] = '';

HEADERS['responseFile.release'] = {};

HEADERS['responseFile.release'][RESPONSE_HEADER_CACHECONTROL] = 'public, max-age=11111111';

HEADERS['responseFile.release']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.release']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.release']['Last-Modified'] = 'Mon, 01 Jan 2001 08:00:00 GMT';

HEADERS['responseFile.release.range'] = {};

HEADERS['responseFile.release.range']['Accept-Ranges'] = 'bytes';

HEADERS['responseFile.release.range'][RESPONSE_HEADER_CACHECONTROL] = 'public, max-age=11111111';

HEADERS['responseFile.release.range']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.release.range']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.release.range']['Last-Modified'] = 'Mon, 01 Jan 2001 08:00:00 GMT';

HEADERS['responseFile.release.range'][RESPONSE_HEADER_CONTENTLENGTH] = '0';

HEADERS['responseFile.release.range']['Content-Range'] = '';

HEADERS['responseFile.debug.compress'] = {};

HEADERS['responseFile.debug.compress'][RESPONSE_HEADER_CACHECONTROL] = 'private, no-cache, no-store, must-revalidate';

HEADERS['responseFile.debug.compress']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.debug.compress']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.debug.compress']['Pragma'] = 'no-cache';

HEADERS['responseFile.debug.compress']['Expires'] = '0';

HEADERS['responseFile.debug.compress']['Content-Encoding'] = 'gzip';

HEADERS['responseFile.debug.compress.range'] = {};

HEADERS['responseFile.debug.compress.range']['Accept-Ranges'] = 'bytes';

HEADERS['responseFile.debug.compress.range'][RESPONSE_HEADER_CACHECONTROL] = 'private, no-cache, no-store, must-revalidate';

HEADERS['responseFile.debug.compress.range']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.debug.compress.range']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.debug.compress.range']['Content-Encoding'] = 'gzip';

HEADERS['responseFile.debug.compress.range']['Pragma'] = 'no-cache';

HEADERS['responseFile.debug.compress.range']['Expires'] = '0';

HEADERS['responseFile.debug.compress.range'][RESPONSE_HEADER_CONTENTLENGTH] = '0';

HEADERS['responseFile.debug.compress.range']['Content-Range'] = '';

HEADERS['responseFile.debug'] = {};

HEADERS['responseFile.debug'][RESPONSE_HEADER_CACHECONTROL] = 'private, no-cache, no-store, must-revalidate';

HEADERS['responseFile.debug']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.debug']['Pragma'] = 'no-cache';

HEADERS['responseFile.debug']['Expires'] = '0';

HEADERS['responseFile.debug']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.debug.range'] = {};

HEADERS['responseFile.debug.range']['Accept-Ranges'] = 'bytes';

HEADERS['responseFile.debug.range'][RESPONSE_HEADER_CACHECONTROL] = 'private, no-cache, no-store, must-revalidate';

HEADERS['responseFile.debug.range']['Vary'] = 'Accept-Encoding';

HEADERS['responseFile.debug.range']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseFile.debug.range']['Pragma'] = 'no-cache';

HEADERS['responseFile.debug.range']['Expires'] = '0';

HEADERS['responseFile.debug.range'][RESPONSE_HEADER_CONTENTLENGTH] = '0';

HEADERS['responseFile.debug.range']['Content-Range'] = '';

HEADERS['responseContent.mobile.compress'] = {};

HEADERS['responseContent.mobile.compress']['Vary'] = 'Accept-Encoding, User-Agent';

HEADERS['responseContent.mobile.compress']['Content-Encoding'] = 'gzip';

HEADERS['responseContent.mobile'] = {};

HEADERS['responseContent.mobile']['Vary'] = 'Accept-Encoding, User-Agent';

HEADERS['responseContent.compress'] = {};

HEADERS['responseContent.compress'][RESPONSE_HEADER_CACHECONTROL] = 'private';

HEADERS['responseContent.compress']['Vary'] = 'Accept-Encoding';

HEADERS['responseContent.compress']['Content-Encoding'] = 'gzip';

HEADERS['responseContent'] = {};

HEADERS['responseContent']['Vary'] = 'Accept-Encoding';

HEADERS['responseStream.release.compress'] = {};

HEADERS['responseStream.release.compress'][RESPONSE_HEADER_CACHECONTROL] = 'public, max-age=11111111';

HEADERS['responseStream.release.compress']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseStream.release.compress']['Content-Encoding'] = 'gzip';

HEADERS['responseStream.release'] = {};

HEADERS['responseStream.release'][RESPONSE_HEADER_CACHECONTROL] = 'public, max-age=11111111';

HEADERS['responseStream.release']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseStream.debug.compress'] = {};

HEADERS['responseStream.debug.compress'][RESPONSE_HEADER_CACHECONTROL] = 'private, no-cache, no-store, must-revalidate';

HEADERS['responseStream.debug.compress']['Pragma'] = 'no-cache';

HEADERS['responseStream.debug.compress']['Expires'] = '0';

HEADERS['responseStream.debug.compress']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseStream.debug.compress']['Content-Encoding'] = 'gzip';

HEADERS['responseStream.debug'] = {};

HEADERS['responseStream.debug'][RESPONSE_HEADER_CACHECONTROL] = 'private, no-cache, no-store, must-revalidate';

HEADERS['responseStream.debug']['Pragma'] = 'no-cache';

HEADERS['responseStream.debug']['Expires'] = '0';

HEADERS['responseStream.debug']['Access-Control-Allow-Origin'] = '*';

HEADERS['responseBinary.compress'] = {};

HEADERS['responseBinary.compress'][RESPONSE_HEADER_CACHECONTROL] = 'public';

HEADERS['responseBinary.compress']['Content-Encoding'] = 'gzip';

HEADERS['responseBinary'] = {};

HEADERS['responseBinary'][RESPONSE_HEADER_CACHECONTROL] = 'public';

HEADERS.redirect = { 'Location': '' };

HEADERS.authorization = { user: '', password: '', empty: true };

HEADERS.fsStreamRead = { flags: 'r', mode: '0666', autoClose: true }

HEADERS.fsStreamReadRange = { flags: 'r', mode: '0666', autoClose: true, start: 0, end: 0 };

HEADERS.workers = { cwd: '' };

HEADERS.mmrpipe = { end: false };

var _controller = '';

var _owner = '';

var _test;

var _flags;

// GO ONLINE MODE

if (!global.framework_internal)

global.framework_internal = require('./internal');

if (!global.framework_builders)

global.framework_builders = require('./builders');

if (!global.framework_utils)

global.framework_utils = require('./utils');

if (!global.framework_mail)

global.framework_mail = require('./mail');

if (!global.framework_image)

global.framework_image = global.Image = require('./image');

if (!global.framework_nosql)

global.framework_nosql = require('./nosql');

global.Builders = framework_builders;

var utils = global.Utils = global.utils = global.U = framework_utils;

global.Mail = framework_mail;

global.INCLUDE = global.SOURCE = function(name, options) {

return framework.source(name, options);

};

global.MODULE = function(name) {

return framework.module(name);

};

global.NOSQL = function(name) {

return framework.nosql(name);

};

global.DB = global.DATABASE = function() {

if (typeof(framework.database) === 'object')

return framework.database;

return framework.database.apply(framework, arguments);

};

global.CONFIG = function(name) {

return framework.config[name];

};

global.INSTALL = function(type, name, declaration, options, callback) {

return framework.install(type, name, declaration, options, callback);

};

global.UNINSTALL = function(type, name, options) {

return framework.uninstall(type, name, options);

};

global.RESOURCE = function(name, key) {

return framework.resource(name, key);

};

global.TRANSLATE = function(name, key) {

return framework.translate(name, key);

};

global.TRANSLATOR = function(name, text) {

return framework.translator(name, text);

};

global.LOG = function() {

return framework.log.apply(framework, arguments);

};

global.LOGGER = function() {

return framework.logger.apply(framework, arguments);

};

global.MODEL = function(name) {

return framework.model(name);

};

global.GETSCHEMA = function(group, name) {

return framework_builders.getschema(group, name);

};

global.CREATE = function(group, name) {

return framework_builders.getschema(group, name).default();

};

global.UID = function() {

var plus = UIDGENERATOR.index % 2 ? 1 : 0;

return UIDGENERATOR.date + (UIDGENERATOR.index++).padLeft(4, '0') + UIDGENERATOR.instance + plus;

};

global.MAKE = global.TRANSFORM = function(transform, fn) {

if (typeof(transform) === 'function') {

var tmp = fn;

fn = transform;

transform = tmp;

}

var obj;

if (typeof(fn) === 'function') {

obj = {};

fn.call(obj, obj);

} else

obj = fn;

return transform ? TransformBuilder.transform.apply(obj, arguments) : obj;

};

global.SINGLETON = function(name) {

return SINGLETONS[name] || (SINGLETONS[name] = {});

};

global.NEWTRANSFORM = function(name, fn, isDefault) {

return TransformBuilder.addTransform.apply(this, arguments);

};

/**

* Creates schema in the specific group

* @param {String} [group=default]

* @param {String} name

* @return {SchemaBuilderEntity}

*/

global.NEWSCHEMA = function(group, name) {

if (!name) {

name = group;

group = 'default';

}

return framework_builders.newschema(group, name);

};

global.EACHSCHEMA = function(group, fn) {

return framework_builders.eachschema(group, fn);

};

global.FUNCTION = function(name) {

return framework.functions[name];

};

global.ROUTING = function(name) {

return framework.routing(name);

};

global.SCHEDULE = function(date, each, fn) {

return framework.schedule(date, each, fn);

};

global.FINISHED = function(stream, callback) {

framework_internal.onFinished(stream, callback);

};

global.DESTROY = function(stream) {

framework_internal.destroyStream(stream);

};

global.CLEANUP = function(stream, callback) {

var fn = function() {

FINISHED(stream, function() {

DESTROY(stream);

if (callback) {

callback();

callback = null;

}

});

};

stream.on('error', fn);

if (stream.readable)

stream.on('end', fn);

else

stream.on('finish', fn);

};

global.SUCCESS = function(success, value) {

if (typeof(success) === 'function') {

return function(err, value) {

success(err, SUCCESS(err, value));

};

}

var err;

if (success instanceof Error) {

err = success;

success = false;

} else if (success instanceof framework_builders.ErrorBuilder) {

if (success.hasError()) {

err = success.output();

success = false;

} else

success = true;

} else if (success == null)

success = true;

SUCCESSHELPER.success = success ? true : false;

SUCCESSHELPER.value = value == null ? undefined : value;

SUCCESSHELPER.error = err ? err : undefined;

return SUCCESSHELPER;

};

global.TRY = function(fn, err) {

try {

fn();

return true;

} catch (e) {

err && err(e);

return false;

}

};

global.OBSOLETE = function(name, message) {

console.log(':: OBSOLETE / IMPORTANT ---> "' + name + '"', message);

framework.stats.other.obsolete++;

};

global.DEBUG = false;

global.TEST = false;

global.RELEASE = false;

global.is_client = false;

global.is_server = true;

var directory = framework_utils.$normalize(require.main ? path.dirname(require.main.filename) : process.cwd());

// F._service() changes the values below:

var DATE_EXPIRES = new Date().add('y', 1).toUTCString();

const UIDGENERATOR = { date: new Date().format('yyMMddHHmm'), instance: 'abcdefghijklmnoprstuwxy'.split('').randomize().join('').substring(0, 3), index: 1 };

const controller_error_status = function(controller, status, problem) {

if (status !== 500 && problem)

controller.problem(problem);

if (controller.res.success || controller.res.headersSent || !controller.isConnected)

return controller;

controller.precache && controller.precache(null, null, null);

controller.req.path = EMPTYARRAY;

controller.subscribe.success();

controller.subscribe.route = framework.lookup(controller.req, '#' + status, EMPTYARRAY, 0);

controller.subscribe.exception = problem;

controller.subscribe.execute(status, true);

return controller;

};

function Framework() {

this.id = null;

this.version = 2100;

this.version_header = '2.1.0';

this.version_node = process.version.toString().replace('v', '').replace(/\./g, '').parseFloat();

this.config = {

debug: false,

trace: true,

name: 'Total.js',

version: '1.0.0',

author: '',

secret: os.hostname() + '-' + os.platform() + '-' + os.arch(),

'etag-version': '',

'directory-controllers': '/controllers/',

'directory-views': '/views/',

'directory-definitions': '/definitions/',

'directory-temp': '/tmp/',

'directory-models': '/models/',

'directory-resources': '/resources/',

'directory-public': '/public/',

'directory-public-virtual': '/app/',

'directory-modules': '/modules/',

'directory-source': '/source/',

'directory-logs': '/logs/',

'directory-tests': '/tests/',

'directory-databases': '/databases/',

'directory-workers': '/workers/',

'directory-packages': '/packages/',

'directory-private': '/private/',

'directory-isomorphic': '/isomorphic/',

'directory-configs': '/configs/',

'directory-services': '/services/',

'directory-themes': '/themes/',

// all HTTP static request are routed to directory-public

'static-url': '',

'static-url-script': '/js/',

'static-url-style': '/css/',

'static-url-image': '/img/',

'static-url-video': '/video/',

'static-url-font': '/fonts/',

'static-url-download': '/download/',

'static-accepts': { '.jpg': true, '.png': true, '.gif': true, '.ico': true, '.js': true, '.css': true, '.txt': true, '.xml': true, '.woff': true, '.woff2': true, '.otf': true, '.ttf': true, '.eot': true, '.svg': true, '.zip': true, '.rar': true, '.pdf': true, '.docx': true, '.xlsx': true, '.doc': true, '.xls': true, '.html': true, '.htm': true, '.appcache': true, '.manifest': true, '.map': true, '.ogv': true, '.ogg': true, '.mp4': true, '.mp3': true, '.webp': true, '.webm': true, '.swf': true, '.package': true, '.json': true, '.md': true, '.m4v': true, '.jsx': true },

// 'static-accepts-custom': [],

'default-layout': 'layout',

'default-theme': '',

// default maximum request size / length

// default 10 kB

'default-request-length': 10,

'default-websocket-request-length': 2,

'default-websocket-encodedecode': true,

'default-maximum-file-descriptors': 0,

'default-timezone': '',

'default-root': '',

'default-response-maxage': '11111111',

// Seconds (2 minutes)

'default-cors-maxage': 120,

// in milliseconds

'default-request-timeout': 5000,

// otherwise is used ImageMagick (Heroku supports ImageMagick)

// gm = graphicsmagick or im = imagemagick

'default-image-converter': 'gm',

'default-image-quality': 93,

'allow-handle-static-files': true,

'allow-gzip': true,

'allow-websocket': true,

'allow-compile-script': true,

'allow-compile-style': true,

'allow-compile-html': true,

'allow-performance': false,

'allow-custom-titles': false,

'allow-compatibility': false,

'disable-strict-server-certificate-validation': true,

'disable-clear-temporary-directory': false,

// Used in framework._service()

// All values are in minutes

'default-interval-clear-resources': 20,

'default-interval-clear-cache': 7,

'default-interval-precompile-views': 61,

'default-interval-websocket-ping': 3,

'default-interval-clear-dnscache': 120

};

this.global = {};

this.resources = {};

this.connections = {};

this.functions = {};

this.themes = {};

this.versions = null;

this.schedules = [];

this.isDebug = true;

this.isTest = false;

this.isLoaded = false;

this.isWorker = true;

this.isCluster = require('cluster').isWorker;

this.routes = {

sitemap: null,

web: [],

files: [],

cors: [],

websockets: [],

middleware: {},

redirects: {},

resize: {},

request: [],

views: {},

merge: {},

mapping: {},

packages: {},

blocks: {},

resources: {},

mmr: {}

};

this.behaviours = null;

this.modificators = null;

this.helpers = {};

this.modules = {};

this.models = {};

this.sources = {};

this.controllers = {};

this.dependencies = {};

this.isomorphic = {};

this.tests = [];

this.errors = [];

this.problems = [];

this.changes = [];

this.server = null;

this.port = 0;

this.ip = '';

this.workers = {};

this.databases = {};

this.directory = HEADERS.workers.cwd = directory;

this.isLE = os.endianness ? os.endianness() === 'LE' : true;

this.isHTTPS = false;

this.datetime = new Date();

// It's hidden

// this.waits = {};

this.temporary = {

path: {},

processing: {},

range: {},

views: {},

dependencies: {}, // temporary for module dependencies

other: {},

internal: {} // internal controllers/modules names for the routing

};

this.stats = {

other: {

websocketPing: 0,

websocketCleaner: 0,

obsolete: 0,

restart: 0

},

request: {

request: 0,

pending: 0,

web: 0,

xhr: 0,

file: 0,

websocket: 0,

get: 0,

options: 0,

head: 0,

post: 0,

put: 0,

path: 0,

upload: 0,

mmr: 0,

blocked: 0,

'delete': 0,

mobile: 0,

desktop: 0

},

response: {

view: 0,

json: 0,

websocket: 0,

timeout: 0,

custom: 0,

binary: 0,

pipe: 0,

file: 0,

destroy: 0,

stream: 0,

streaming: 0,

plain: 0,

empty: 0,

redirect: 0,

forward: 0,

restriction: 0,

notModified: 0,

sse: 0,

mmr: 0,

error400: 0,

error401: 0,

error403: 0,

error404: 0,

error408: 0,

error431: 0,

error500: 0,

error501: 0

}

};

// intialize cache

this.cache = new FrameworkCache();

this.path = new FrameworkPath();

this.restrictions = new FrameworkRestrictions();

this._request_check_redirect = false;

this._request_check_referer = false;

this._request_check_POST = false;

this._request_check_robot = false;

this._length_middleware = 0;

this._length_request_middleware = 0;

this._length_files = 0;

this._length_wait = 0;

this._length_themes = 0;

this._length_cors = 0;

this._length_subdomain_web = 0;

this._length_subdomain_websocket = 0;

this.isVirtualDirectory = false;

this.isTheme = false;

this.isWindows = os.platform().substring(0, 3).toLowerCase() === 'win';

}

// ======================================================

// PROTOTYPES

// ======================================================

Framework.prototype.__proto__ = new events.EventEmitter();

/**

* Internal function

* @return {String} Returns current (dependency type and name) owner.

*/

Framework.prototype.$owner = function() {

return _owner;

};

/**

* Adds a new behaviour

* @param {String} url A relative URL address.

* @param {String Array} flags

* @return {Framework}

*/

Framework.prototype.behaviour = function(url, flags) {

var self = this;

if (!self.behaviours)

self.behaviours = {};

if (typeof(flags) === 'string')

flags = [flags];

url = framework_internal.preparePath(url);

if (!self.behaviours[url])

self.behaviours[url] = {};

for (var i = 0; i < flags.length; i++)

self.behaviours[url][flags[i]] = true;

return self;

};

Framework.prototype.isSuccess = function(obj) {

return obj === SUCCESSHELPER;

};

/**

* Refersh framework internal informations

* @param {Boolean} clear Clear temporary files, optional

* @return {Framework}

*/

Framework.prototype.refresh = function(clear) {

var self = this;

self.emit('clear', 'refresh');

self.resources = {};

self.databases = {};

self._configure();

self._configure_versions();

self._configure_sitemap();

self.temporary.path = {};

self.temporary.range = {};

self.temporary.views = {};

self.temporary.other = {};

self.emit('reconfigure');

return self;

};

/**

* Get a controller

* @param {String} name

* @return {Object}

*/

Framework.prototype.controller = function(name) {

return this.controllers[name] || null;

};

/**

* Use configuration

* @param {String} filename

* @return {Framework}

*/

Framework.prototype.useConfig = function(name) {

return this._configure(name, true);

};

/**

* Sort all routes

* @return {Framework}

*/

Framework.prototype._routesSort = function(type) {

var self = this;

self.routes.web.sort(function(a, b) {

if (a.priority > b.priority)

return -1;

if (a.priority < b.priority)

return 1;

return 0;

});

self.routes.websockets.sort(function(a, b) {

if (a.priority > b.priority)

return -1;

if (a.priority < b.priority)

return 1;

return 0;

});

var cache = {};

var length = self.routes.web.length;

var url;

for (var i = 0; i < length; i++) {

var route = self.routes.web[i];

var name = self.temporary.internal[route.controller];

if (name)

route.controller = name;

if (!route.isMOBILE || route.isUPLOAD || route.isXHR || route.isJSON || route.isSYSTEM || route.isXML || route.flags.indexOf('get') === -1)

continue;

url = route.url.join('/');

cache[url] = true;

}

for (var i = 0; i < length; i++) {

var route = self.routes.web[i];

if (route.isMOBILE || route.isUPLOAD || route.isXHR || route.isJSON || route.isSYSTEM || route.isXML || route.flags.indexOf('get') === -1)

continue;

url = route.url.join('/');

route.isMOBILE_VARY = cache[url] === true;

}

(!type || type === 1) && self.routes.web.forEach(function(route) {

var tmp = self.routes.web.findItem(function(item) {

return item.hash === route.hash && item !== route;

});

route.isUNIQUE = tmp == null;

});

return self;

};

/**

* Get a database instance

* @param {String} name Database name (optional)

* @return {Database}

*/

Framework.prototype.database = function(name) {

return this.nosql(name);

};

/**

* Get a database instance (NoSQL embedded)

* @param {String} name Database name (optional)

* @return {Database}

*/

Framework.prototype.nosql = function(name) {

var self = this;

var db = self.databases[name];

if (db)

return db;

self.path.verify('databases');

db = framework_nosql.load(name, self.path.databases(name));

self.databases[name] = db;

return db;

};

/**

* Stop application

* @param {String} signal

* @return {Framework}

*/

Framework.prototype.stop = function(signal) {

var self = this;

for (var m in framework.workers) {

var worker = framework.workers[m];

TRY(() => worker && worker.kill && worker.kill(signal || 'SIGTERM'));

}

framework.emit('exit');

if (!self.isWorker && typeof(process.send) === 'function')

TRY(() => process.send('stop'));

self.cache.stop();

self.server && self.server.close();

setTimeout(() => process.exit(signal || 'SIGTERM'), TEST ? 2000 : 100);

return self;

};

/**

* Add a route redirect

* @param {String} host Domain with protocol.

* @param {String} newHost Domain with protocol.

* @param {Boolean} withPath Copy path (default: true).

* @param {Boolean} permanent Is permanent redirect (302)? (default: false)

* @return {Framework}

*/

Framework.prototype.redirect = function(host, newHost, withPath, permanent) {

var self = this;

var external = host.startsWith('http://') || host.startsWith('https');

if (external) {

if (host[host.length - 1] === '/')

host = host.substring(0, host.length - 1);

if (newHost[newHost.length - 1] === '/')

newHost = newHost.substring(0, newHost.length - 1);

self.routes.redirects[host] = {

url: newHost,

path: withPath,

permanent: permanent

};

self._request_check_redirect = true;

return self;

}

if (host[0] !== '/')

host = '/' + host;

var flags;

if (withPath instanceof Array) {

flags = withPath;

withPath = permanent === true;

} else if (permanent instanceof Array) {

flags = permanent;

withPath = withPath === true;

} else

withPath = withPath === true;

permanent = withPath;

framework.route(host, function() {

if (newHost.startsWith('http://') || newHost.startsWith('https://')) {

this.redirect(newHost + this.href(), permanent);

return;

}

if (newHost[0] !== '/')

newHost = '/' + newHost;

this.redirect(newHost + this.href(), permanent);

}, flags);

return self;

};

/**

* Schedule job

* @param {Date or String} date

* @param {Boolean} repeat Repeat schedule

* @param {Function} fn

* @return {Framework}

*/

Framework.prototype.schedule = function(date, repeat, fn) {

if (fn === undefined) {

fn = repeat;

repeat = false;

}

var self = this;

var type = typeof(date);

if (type === 'string')

date = date.parseDate();

else if (type === 'number')

date = new Date(date);

var sum = date.getTime();

var id = framework_utils.GUID(5) + framework_utils.random(10000);

if (repeat)

repeat = repeat.replace('each', '1');

self.schedules.push({ expire: sum, fn: fn, repeat: repeat });

return self;