cakejs/lib/CakeJS.js

'use strict';

var _inherits = require('babel-runtime/helpers/inherits')['default'];

var _get = require('babel-runtime/helpers/get')['default'];

var _createClass = require('babel-runtime/helpers/create-class')['default'];

var _classCallCheck = require('babel-runtime/helpers/class-call-check')['default'];

var _core = require('babel-runtime/core-js')['default'];

var _regeneratorRuntime = require('babel-runtime/regenerator')['default'];

var _interopRequireWildcard = require('babel-runtime/helpers/interop-require-wildcard')['default'];

_core.Object.defineProperty(exports, '__esModule', {
	value: true
});

exports.createServer = createServer;

var _MissingConfigException = require('./Exception/MissingConfigException');

var _sessionParser = require('./ExpressMiddleware/SessionParser');

var _sessionParser2 = _interopRequireWildcard(_sessionParser);

var _sessionManager = require('./Session/SessionManager');

var _sessionManager2 = _interopRequireWildcard(_sessionManager);

var _socketIOConnection = require('./ExpressMiddleware/SocketIOConnection');

var _socketIOConnection2 = _interopRequireWildcard(_socketIOConnection);

var _static2 = require('./ExpressMiddleware/Static');

var _static3 = _interopRequireWildcard(_static2);

var _proxy = require('./ExpressMiddleware/Proxy');

var _proxy2 = _interopRequireWildcard(_proxy);

var _controllerManager = require('./Controller/ControllerManager');

var _controllerManager2 = _interopRequireWildcard(_controllerManager);

var _router = require('./Routing/Router');

var _router2 = _interopRequireWildcard(_router);

var _configure = require('./Core/Configure');

var _configure2 = _interopRequireWildcard(_configure);

var events = require('events');
var fs = require('fs');
var path = require('path');
var express = require('express');
var http = require('http');
var socketio = require('socket.io');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

/**
 * @class
 */

var Server = (function (_events$EventEmitter) {
	/**
  * Constructor
  * 
  * @param {string|object} Path to config or a json object containing the configuration
  * @extends events.EventEmitter
  */

	function Server(config) {
		_classCallCheck(this, Server);

		_get(_core.Object.getPrototypeOf(Server.prototype), 'constructor', this).call(this);
		this._app = express();
		this._http = http.Server(this._app);
		this._sio = socketio(this._http);
		if (typeof config !== 'undefined') this.config(config);
	}

	_inherits(Server, _events$EventEmitter);

	_createClass(Server, [{
		key: 'config',

		/**
   * Sets config for CakeJS
   * 
   * This methods set default values for missing keys
   * 
   * @param {string|object} Path to config or a json object containing the configuration
   * @returns {void}
   */
		value: (function (_config) {
			function config(_x) {
				return _config.apply(this, arguments);
			}

			config.toString = function () {
				return _config.toString();
			};

			return config;
		})(function (config) {
			_configure2['default'].config(config);
		})
	}, {
		key: 'start',

		/**
   * Starts the CakeJS server
   * 
   * @returns {Promise}
   */
		value: function start() {
			var javascriptLibraryContent;
			return _regeneratorRuntime.async(function start$(context$2$0) {
				var _this = this;

				while (1) switch (context$2$0.prev = context$2$0.next) {
					case 0:
						context$2$0.next = 2;
						return _controllerManager2['default'].load(path.resolve(_configure2['default'].get('CakeJS.src', path.resolve('.')), 'Controller'));

					case 2:
						context$2$0.next = 4;
						return _router2['default'].initialize();

					case 4:

						//Starts the web related services
						_sessionManager2['default'].config(_configure2['default'].get('Session.name', 'cakejs_sessid'), _configure2['default'].get('Session.ttl', 1000 * 60 * 60 * 24));
						this._app.use(cookieParser());
						this._app.use(_sessionParser2['default'](_configure2['default'].get('Session.name', 'cakejs_sessid'), _configure2['default'].get('Session.ttl', 1000 * 60 * 60 * 24)));
						this.emit('use', this._app);
						javascriptLibraryContent = fs.readFileSync(path.resolve(__filename, '..', 'Client', 'client.js'));

						this._app.get('/js/cakejs.js', function (request, response) {
							response.writeHead(200, { 'content-type': 'text/javascript' });
							response.write(javascriptLibraryContent);
							response.end();
						});
						if (_configure2['default'].get('Static') !== null) {
							this._app.use(bodyParser.urlencoded({ extended: false }));
							this._app.use(_static3['default'](_configure2['default'].get('Static.webroot', '/var/www')));
						} else if (_configure2['default'].get('Proxy') !== null) {
							this._app.use(_proxy2['default'](_configure2['default'].get('Proxy.host', '127.0.0.1'), _configure2['default'].get('Proxy.port', 80)));
						}
						this._sio.set('authorization', _sessionParser2['default']());
						this._sio.on('connection', _socketIOConnection2['default']());
						context$2$0.next = 15;
						return new _core.Promise(function (resolve) {
							return _this._http.listen(_configure2['default'].get('Listen.port', 8080), function () {
								resolve();
							});
						});

					case 15:
					case 'end':
						return context$2$0.stop();
				}
			}, null, this);
		}
	}, {
		key: 'stop',

		/**
   * Stops the CakeJS server
   * 
   * @returns {Promise}
   */
		value: function stop() {
			return _regeneratorRuntime.async(function stop$(context$2$0) {
				var _this2 = this;

				while (1) switch (context$2$0.prev = context$2$0.next) {
					case 0:
						context$2$0.next = 2;
						return new _core.Promise(function (resolve) {
							return _this2._http.close(resolve);
						});

					case 2:
					case 'end':
						return context$2$0.stop();
				}
			}, null, this);
		}
	}]);

	return Server;
})(events.EventEmitter);

exports.Server = Server;

function createServer() {
	return new Server();
}

//Preloads managers

//Build routes