Cleaning repo for full refactoring

Author: fmsouza

.gitignore

@@ -1,9 +1,6 @@
 .DS_Store
 node_modules
-.compiled
-dist
 .settings
 .idea
 *.log
-defs
-tmp
+.vscode

Dockerfile

@@ -1,6 +1,6 @@
 FROM node:latest
 EXPOSE 8080
 EXPOSE 80
-RUN npm install -g gulp mocha pm2
+RUN npm install -g mocha
 RUN mkdir /app
-WORKDIR /app
+WORKDIR /app

gulpfile.js

@@ -0,0 +1,6 @@
+{
+    "compilerOptions": {
+        "target": "ES6",
+        "module": "commonjs"
+    }
+}

jsconfig.json

@@ -1,16 +1,15 @@
 {
-  "name": "server",
-  "version": "3.2.0",
-  "description": "RioBus server application",
-  "main": ".compiled/src/index.js",
+  "name": "proxy",
+  "version": "4.0.0",
+  "description": "RioBus proxy application",
+  "main": "src/app.js",
   "scripts": {
-    "test": "gulp buildTest && mocha .compiled/test/**/* --timeout 10000",
-    "build": "gulp build",
-    "start": "gulp build && node .compiled/src/index.js"
+    "test": "mocha test/**/*",
+    "start": "node src/app.js"
   },
   "repository": {
     "type": "git",
-    "url": "https://github.com/riobus/server"
+    "url": "https://github.com/riobus/proxy"
   },
   "keywords": [
     "riobus",
@@ -27,29 +26,23 @@
     "wrapper",
     "infrastructure"
   ],
-  "author": "Fred Souza <[email protected]> (http://fmsouza.github.io)",
-  "license": "http://github.com/RioBus/server/blob/master/LICENSE",
+  "license": "http://github.com/RioBus/proxy/blob/master/LICENSE",
   "bugs": {
-    "url": "http://github.com/RioBus/server/issues"
+    "url": "http://github.com/RioBus/proxy/issues"
   },
-  "homepage": "http://github.com/RioBus/server",
+  "homepage": "http://github.com/RioBus/proxy",
   "dependencies": {
-    "compression": "latest",
-    "deasync": "latest",
-    "emailjs": "latest",
-    "express": "latest",
-    "fs-extra": "latest",
-    "moment": "latest",
-    "moment-timezone": "latest",
-    "mongodb": "latest",
-    "nodealytics": "latest",
-    "request": "latest"
+    "body-parser": "^1.14.1",
+    "co": "^4.6.0",
+    "compression": "^1.5.2",
+    "express": "^4.13.3",
+    "fs-extra": "^0.26.0",
+    "mongodb": "^1.4.4",
+    "request-promise": "^1.0.2",
+    "robe": "^0.12.0"
   },
   "devDependencies": {
-    "gulp": "latest",
-    "gulp-load-plugins": "latest",
-    "gulp-typescript": "latest",
-    "gulp-util": "^3.0.6",
-    "mocha": "latest"
+    "co-mocha": "^1.1.2",
+    "mocha": "^2.3.3"
   }
 }

package.json

@@ -1,2 +1,2 @@
 #!/bin/bash
-docker run -it --rm -p 8080:8080 -p 80:80 --link mongo:mongo -v $(pwd):/app --name riobus-proxy riobus /bin/bash
+docker run -it --rm -p 8080:8080 -p 80:80 --link mongo:mongo -v "$(pwd)":/app --name riobus-proxy nodejs /bin/bash

run-container

@@ -0,0 +1,24 @@
+'use strict';
+/* global process; */
+const Config        = require('./config');
+const Core          = require('./core');
+const LoggerFactory = Core.LoggerFactory;
+const Router        = Core.Router;
+const spawn         = require('co');
+
+const logger = LoggerFactory.getRuntimeLogger();
+
+spawn(function* main(){
+    logger.info('Starting the server...');
+
+    // Configuring the RESTful router to handle HTTP requests
+    let router = new Router();
+    router.registerResources(Config.resources); // Registering resources to handle the URLs
+    
+    let server = Config.server;
+    router.start(server.ip, server.port); // Starting RESTful application
+})
+.catch(function(error) {
+    logger.error(error);
+    process.exit(1);
+});

src/app.js

@@ -0,0 +1,30 @@
+/* global __dirname, process; */
+/**
+ * Application configuration
+ * You may use it to describe every global configuration data
+ */
+module.exports = {
+    root: __dirname,
+    logs: {
+        runtime: `/tmp/riobus/log/runtime-${new Date("Y-m-d").toISOString()}.log`,
+        server: `/tmp/riobus/log/server-${new Date("Y-m-d").toISOString()}.log`
+    },
+    server: {
+        ip: '0.0.0.0',
+        port: 8080
+    },
+    database: {
+        dbName: process.env.RIOBUS_DB_NAME  || 'riobus',
+        host: process.env.RIOBUS_DB_HOST    || 'localhost',
+        port: process.env.RIOBUS_DB_PORT    || 27017,
+        user: process.env.RIOBUS_DB_USER    || '',
+        pass: process.env.RIOBUS_DB_PASS    || ''
+    },
+    analytics: {
+        ua: process.env.RIOBUS_ANALYTICS_UA     || '',
+        host: process.env.RIOBUS_ANALYTICS_HOST || ''
+    },
+    resources: [
+        'main/mainResource'
+    ]
+};

src/config.js

@@ -0,0 +1,9 @@
+const root = './core';
+module.exports = {
+	Database:		require(`${root}/database`),
+	File: 			require(`${root}/file`),
+	Http: 			require(`${root}/http`),
+	Logger: 		require(`${root}/log/logger`),
+	LoggerFactory: 	require(`${root}/log/loggerFactory`),
+	Router: 		require(`${root}/router`)
+}

src/core.js

@@ -0,0 +1,15 @@
+'use strict';
+const Robe = require('robe');
+const Config = require('../config');
+
+class Database {
+	
+	static connect(config) {
+		if(!config) config = Config.database;
+		var url = `${config.host}:${config.port}/${config.dbName}`;
+		if(config.user!=='' && config.pass!=='') url = `${config.user}:${config.pass}@${url}`;
+		return Robe.connect(url);
+	}
+}
+
+module.exports = Database;

src/core/database.js

@@ -0,0 +1,67 @@
+'use strict';
+/**
+ * Manipulates files access
+ * @class {File}
+ */
+class File {
+
+    constructor(path) {
+        this.fullPath = path;
+        var splittedPath = path.split('/');
+        this.file = splittedPath.pop();
+        this.directory = splittedPath.join('/');
+        this.fs = require("fs-extra");
+		this.fs.ensureFileSync(this.fullPath);
+    }
+    
+    /**
+     * Get the full file path
+     * @return {string}
+     */
+    get filePath() {
+        return this.fullPath;
+    }
+    
+    /**
+     * Get the directory where the file is
+     * @return {string}
+     */
+    get dirPath() {
+        return this.directory;
+    }
+    
+    /**
+     * Get the file name
+     * @return {string}
+     */
+    get fileName() {
+        return this.file;
+    }
+
+    /**
+     * Appends content to end of file
+     * @param {string} content - Content to be written to the file
+	 * @return {void}
+     */
+    append(content) {
+        this.fs.appendFileSync(this.fullPath, `${content}\n`);
+    }
+
+    /**
+     * Writes the given content to a file. Ovewrites if it already has any content.
+     * @param {string} content - Content to be written to the file
+	 * @return {void}
+     */
+    write(content) {
+        this.fs.outputFileSync(this.fullPath, `${content}\n`);
+    }
+
+    /**
+     * Reads the file content
+     * @return {string}
+     */
+    read() {
+        return this.fs.readFileSync(this.fullPath, 'utf8');
+    }
+}
+module.exports = File;

src/core/file.js

@@ -0,0 +1,67 @@
+'use strict';
+const request = require('request-promise');
+
+var optionsObj = {
+    method: 'GET',
+    simple: true,
+    resolveWithFullResponse: true,
+    json: true
+}
+/**
+ * Creates a new synchronized HttpRequest
+ * @class {Http}
+ */
+class Http {
+    
+    /**
+     * Makes requests through Options object
+     * @param {Object} options - Options object
+     * @returns {Promise}
+     */
+    static request(options) {
+        var data = JSON.parse(JSON.stringify(optionsObj));
+        for(var key in Object.keys(options)) {
+            data[key] = options[key];
+        }
+        return request(options);
+    }
+
+    /**
+     * Makes GET request
+     * @param {string} host - Host URL
+     * @returns {Promise}
+     */
+    static get(host){
+        return Http.request({ uri: host });
+    }
+
+    /**
+     * Makes POST request
+     * @param {string} host - Host URL
+     * @param {Object} data - Data to be sent
+     * @returns {Promise}
+     */
+    static post(host, data){
+        return Http.request({ method: 'POST', uri: host, body: data });
+    }
+
+    /**
+     * Makes PUT request
+     * @param {string} host - Host URL
+     * @param {Object} options
+     * @returns {Promise}
+     */
+    static put(host, data){
+        return Http.request({ method: 'PUT', uri: host, body: data });
+    }
+
+    /**
+     * Makes DELETE request
+     * @param {String} host - Host URL
+     * @returns {Promise}
+     */
+    static delete(host){
+        return Http.request({ method: 'DELETE', uri: host });
+    }
+}
+module.exports = Http;