// requirement let protocoll = require('https'); // if there are no certificates protocoll will be set to require(http) const fs = require('fs'), urlparse = require('url'), perfy = require('perfy'), winston = require('winston'), DailyRotateFile = require('winston-daily-rotate-file'), path = require('path'), // own modules utils = require("./lib/utils"), prepro = require("./lib/preprocessor"), // args args = require('args-parser')(process.argv), // create an args parser // config file config = JSON.parse(fs.readFileSync("./config/server.json")), // logging config using winston fileLoggingFormat = winston.format.printf(info => { return `${info.timestamp} ${info.level.toUpperCase()}: ${JSON.stringify(info.message)}`; // the logging format for files }), consoleLoggingFormat = winston.format.printf(info => { return `${info.timestamp} [${info.level}] ${JSON.stringify(info.message)}`; //the logging format for the console }), loggingFullFormat = winston.format.combine( winston.format.splat(), winston.format.timestamp({ format: 'MM-DD HH:mm:ss.SSS' // don't include the year because the filename already tells }), fileLoggingFormat // the logging format for files that logs with a capitalized level ), logger = winston.createLogger({ level: winston.config.npm.levels, // logs with npm levels format: loggingFullFormat, // the full format for files transports: [ new winston.transports.Console({ format: winston.format.combine( winston.format.colorize(), // colorizes the console logging output winston.format.splat(), winston.format.timestamp({ format: 'YY-MM-DD HH:mm:ss.SSS' // logs with the year to the console }), consoleLoggingFormat // logs with the custom console format ), level: args.loglevel || 'info' // logs to the console with the arg loglevel or info if it is not given }), new winston.transports.File({ level: 'debug', // logs with debug level to the active file filename: './.log/rcn-frontserver.log', // the filename of the current file, options: {flags: 'w'} // overwrites the file on restart }), new DailyRotateFile({ level: 'verbose', // log verbose in the rotating logvile filename: './.log/frontserver-%DATE%.log', // the pattern of the filename datePattern: 'YYYY-MM-DD', // the pattern of %DATE% zippedArchive: true, // indicates that old logfiles should get zipped maxSize: '32m', // the maximum filesize maxFiles: '30d' // the maximum files to keep }) ] }), // serveroptions port = args.port || 443, // the port the server is running on. It's the https standard routes = config.routes || { ".html": { "path": "./res/html", // standard route to the html files "mime": "text/html" }, ".js": { "path": "./res/scripts", // standard route to the script files "mime": "text/javascript" } }, mounts = config.mounts; // mounts are more important than routes. // these will store the certificate options later var options = {}; // --- functional declaration part --- /** * Creates a server running on port 80 with tls enabled. * @return {boolean} Returns false if the server stopped by error. */ function main() { try { prepro.setLogger(logger); setInterval(utils.genSystemData, 1000); protocoll.createServer(options, function (req, res) { logger.verbose({'msg': 'Received request', 'method': req.method, 'url': req.url}); perfy.start('response-calculation'); // caluclate the response time let url = urlparse.parse(req.url); // parse the url let uri = url.pathname; // set uri to the urls uriame logger.debug({"msg": 'Got URL by using url package', 'url': url, 'path': uri}); let resArray = getResponse(uri); // get a response for the url path let response = resArray[0] || "", // the response mime = resArray[1] || "text/plain", // the mime-type statuscode = resArray[2] || 200; // the status code. 200 if not explicitly set logger.debug({'response-length': response.length, 'mime-type': mime, 'code': statuscode}); res.writeHead(statuscode, {"Content-Type": mime}); // write the mime as head res.end(response); // write the response let execTime = perfy.end('response-calculation').fullMilliseconds; // get the execution time logger.debug("Response-Time: " + execTime + " ms for " + req.url, "debug"); // log the execution time }).listen(port); // server listens on port specified in the parameter } catch (error) { logger.error(error.message); process.exit(1); } } /** * Returns a string that depends on the uri It gets the data from the routes variable. * @param uri * @return {string[]} An Array containing the files content, the mime type and sometimes the statuscode (if it is not 200) */ function getResponse(uri) { let matches = uri.match(/(\/$|\/\w+$)/g); // matches when the url has no file extension or ends in a slash (/) if (matches) uri += '/index.html'; // append index.html if there are matches logger.verbose({'msg': 'calculating response', 'path': uri}); let gp = prepro.getProcessed; // shorten the function name try { let extension = utils.getExtension(uri); // get the urls file-extension // returns the global script or css if the extension is css or js and the root-uriis glob. if (uri.includes("/glob") && (extension === ".sass" || extension === ".js")) { logger.verbose("Using global uri"); if (extension === ".sass") return [gp("." + uri), "text/css"]; else return [gp("." + uri), "text/javascript"]; } let mount = getMount(uri); // get mount for uri it will be uses as path later instead of route logger.verbose("Mount for uri is " + mount); let route = routes[extension]; // get the route from the extension json logger.verbose("Found route: " + JSON.stringify(route)); if (!route) { logger.warn(`No route found for ${uri}`); return [gp(config.errors['403']), "text/html", 403]; // return not allowed if no route was found } return [gp(mount || path.join(route["path"], uri)), route["mime"]]; // get processed output (done by preprocessor) } catch (error) { logger.warn(error.message); if (args.test) process.exit(1); return [gp(config.errors['404']), "text/html", 404]; } } /** * gets all mounted paths and returns the modified uri. * @param {String} uri The uri * @return {String} The uri that points to the mounted path */ function getMount(uri) { if (mounts) { // if mounts are set for (let mount of mounts) { // for each set mount if (mount.mount && mount.path) { // if the mount has the mount parameter and the path parameter let regEx = RegExp(mount.mount); // create a regex from the mount if (uri.match(regEx)) { // if there is a match logger.debug(regEx.toString() + " returns a result"); return uri.replace(regEx, mount.path); // return the modified uri } } } } } /** * A cleanup-function that should only be called on process exit */ function cleanup() { logger.info('Cleanup...'); prepro.cleanup(); // cleanup the preprocessor logger.end(); // let the logger finish all operations } /** * Offers help when the function is called via the --help flag */ function help() { console.log("\nUsage: server.js [options]\n\n" + "Options:\n" + " -h, --help show this help message and exit\n" + " --port define the port for the server to run on\n" + " --loglevel define at which level the console should output\n" + " --test start the server and exit after 10 seconds\n"); process.exit(0); } // Executing the main function if (typeof require !== 'undefined' && require.main === module) { // do arg specific operations if (args.help || args.h) help(); if (args.test) setTimeout(() => process.exit(0), 10000); // if in testing mode, exit after 10 seconds utils.Cleanup(cleanup); // set the cleanup function logger.exceptions.handle( new winston.transports.File({ filename: './.log/frontserver-exceptions.log' }) ); if (fs.existsSync('.ssh/key.pem') && fs.existsSync('.ssh/cert.pem')) { // check if the required cert files exists options = { key: fs.readFileSync('.ssh/key.pem'), // the key-file cert: fs.readFileSync('.ssh/cert.pem') // the certificate-file }; } else protocoll = require('http'); // if no certs could be found start the server as http-server logger.info("Starting up... "); // log the current date so that the logfile is better to read. main(); // execute the main function }