mirror of
https://github.com/MichMich/MagicMirror.git
synced 2025-06-28 04:02:12 +00:00
Merge pull request #2407 from fewieden/feature/update-node-js-code
update node js code
This commit is contained in:
commit
612cf25878
@ -14,6 +14,7 @@ _This release is scheduled to be released on 2021-04-01._
|
|||||||
### Updated
|
### Updated
|
||||||
|
|
||||||
- Updated markdown files.
|
- Updated markdown files.
|
||||||
|
- Cleaned up old code on server side.
|
||||||
|
|
||||||
### Removed
|
### Removed
|
||||||
|
|
||||||
|
126
js/app.js
126
js/app.js
@ -4,22 +4,22 @@
|
|||||||
* By Michael Teeuw https://michaelteeuw.nl
|
* By Michael Teeuw https://michaelteeuw.nl
|
||||||
* MIT Licensed.
|
* MIT Licensed.
|
||||||
*/
|
*/
|
||||||
var fs = require("fs");
|
const fs = require("fs");
|
||||||
var path = require("path");
|
const path = require("path");
|
||||||
var Log = require(__dirname + "/logger.js");
|
const Log = require(`${__dirname}/logger`);
|
||||||
var Server = require(__dirname + "/server.js");
|
const Server = require(`${__dirname}/server`);
|
||||||
var Utils = require(__dirname + "/utils.js");
|
const Utils = require(`${__dirname}/utils`);
|
||||||
var defaultModules = require(__dirname + "/../modules/default/defaultmodules.js");
|
const defaultModules = require(`${__dirname}/../modules/default/defaultmodules`);
|
||||||
|
|
||||||
// Alias modules mentioned in package.js under _moduleAliases.
|
// Alias modules mentioned in package.js under _moduleAliases.
|
||||||
require("module-alias/register");
|
require("module-alias/register");
|
||||||
|
|
||||||
// Get version number.
|
// Get version number.
|
||||||
global.version = JSON.parse(fs.readFileSync("package.json", "utf8")).version;
|
global.version = require(`${__dirname}/../package.json`).version;
|
||||||
Log.log("Starting MagicMirror: v" + global.version);
|
Log.log("Starting MagicMirror: v" + global.version);
|
||||||
|
|
||||||
// global absolute root path
|
// global absolute root path
|
||||||
global.root_path = path.resolve(__dirname + "/../");
|
global.root_path = path.resolve(`${__dirname}/../`);
|
||||||
|
|
||||||
if (process.env.MM_CONFIG_FILE) {
|
if (process.env.MM_CONFIG_FILE) {
|
||||||
global.configuration_file = process.env.MM_CONFIG_FILE;
|
global.configuration_file = process.env.MM_CONFIG_FILE;
|
||||||
@ -45,8 +45,8 @@ process.on("uncaughtException", function (err) {
|
|||||||
*
|
*
|
||||||
* @class
|
* @class
|
||||||
*/
|
*/
|
||||||
var App = function () {
|
function App() {
|
||||||
var nodeHelpers = [];
|
let nodeHelpers = [];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Loads the config file. Combines it with the defaults, and runs the
|
* Loads the config file. Combines it with the defaults, and runs the
|
||||||
@ -54,34 +54,31 @@ var App = function () {
|
|||||||
*
|
*
|
||||||
* @param {Function} callback Function to be called after loading the config
|
* @param {Function} callback Function to be called after loading the config
|
||||||
*/
|
*/
|
||||||
var loadConfig = function (callback) {
|
function loadConfig(callback) {
|
||||||
Log.log("Loading config ...");
|
Log.log("Loading config ...");
|
||||||
var defaults = require(__dirname + "/defaults.js");
|
const defaults = require(`${__dirname}/defaults`);
|
||||||
|
|
||||||
// For this check proposed to TestSuite
|
// For this check proposed to TestSuite
|
||||||
// https://forum.magicmirror.builders/topic/1456/test-suite-for-magicmirror/8
|
// https://forum.magicmirror.builders/topic/1456/test-suite-for-magicmirror/8
|
||||||
var configFilename = path.resolve(global.root_path + "/config/config.js");
|
const configFilename = path.resolve(global.configuration_file || `${global.root_path}/config/config.js`);
|
||||||
if (typeof global.configuration_file !== "undefined") {
|
|
||||||
configFilename = path.resolve(global.configuration_file);
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
fs.accessSync(configFilename, fs.F_OK);
|
fs.accessSync(configFilename, fs.F_OK);
|
||||||
var c = require(configFilename);
|
const c = require(configFilename);
|
||||||
checkDeprecatedOptions(c);
|
checkDeprecatedOptions(c);
|
||||||
var config = Object.assign(defaults, c);
|
const config = Object.assign(defaults, c);
|
||||||
callback(config);
|
callback(config);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
if (e.code === "ENOENT") {
|
if (e.code === "ENOENT") {
|
||||||
Log.error(Utils.colors.error("WARNING! Could not find config file. Please create one. Starting with default configuration."));
|
Log.error(Utils.colors.error("WARNING! Could not find config file. Please create one. Starting with default configuration."));
|
||||||
} else if (e instanceof ReferenceError || e instanceof SyntaxError) {
|
} else if (e instanceof ReferenceError || e instanceof SyntaxError) {
|
||||||
Log.error(Utils.colors.error("WARNING! Could not validate config file. Starting with default configuration. Please correct syntax errors at or above this line: " + e.stack));
|
Log.error(Utils.colors.error(`WARNING! Could not validate config file. Starting with default configuration. Please correct syntax errors at or above this line: ${e.stack}`));
|
||||||
} else {
|
} else {
|
||||||
Log.error(Utils.colors.error("WARNING! Could not load config file. Starting with default configuration. Error found: " + e));
|
Log.error(Utils.colors.error(`WARNING! Could not load config file. Starting with default configuration. Error found: ${e}`));
|
||||||
}
|
}
|
||||||
callback(defaults);
|
callback(defaults);
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Checks the config for deprecated options and throws a warning in the logs
|
* Checks the config for deprecated options and throws a warning in the logs
|
||||||
@ -89,21 +86,15 @@ var App = function () {
|
|||||||
*
|
*
|
||||||
* @param {object} userConfig The user config
|
* @param {object} userConfig The user config
|
||||||
*/
|
*/
|
||||||
var checkDeprecatedOptions = function (userConfig) {
|
function checkDeprecatedOptions(userConfig) {
|
||||||
var deprecated = require(global.root_path + "/js/deprecated.js");
|
const deprecated = require(`${global.root_path}/js/deprecated`);
|
||||||
var deprecatedOptions = deprecated.configs;
|
const deprecatedOptions = deprecated.configs;
|
||||||
|
|
||||||
var usedDeprecated = [];
|
const usedDeprecated = deprecatedOptions.filter((option) => userConfig.hasOwnProperty(option));
|
||||||
|
|
||||||
deprecatedOptions.forEach(function (option) {
|
|
||||||
if (userConfig.hasOwnProperty(option)) {
|
|
||||||
usedDeprecated.push(option);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
if (usedDeprecated.length > 0) {
|
if (usedDeprecated.length > 0) {
|
||||||
Log.warn(Utils.colors.warn("WARNING! Your config is using deprecated options: " + usedDeprecated.join(", ") + ". Check README and CHANGELOG for more up-to-date ways of getting the same functionality."));
|
Log.warn(Utils.colors.warn(`WARNING! Your config is using deprecated options: ${usedDeprecated.join(", ")}. Check README and CHANGELOG for more up-to-date ways of getting the same functionality.`));
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Loads a specific module.
|
* Loads a specific module.
|
||||||
@ -111,35 +102,35 @@ var App = function () {
|
|||||||
* @param {string} module The name of the module (including subpath).
|
* @param {string} module The name of the module (including subpath).
|
||||||
* @param {Function} callback Function to be called after loading
|
* @param {Function} callback Function to be called after loading
|
||||||
*/
|
*/
|
||||||
var loadModule = function (module, callback) {
|
function loadModule(module, callback) {
|
||||||
var elements = module.split("/");
|
const elements = module.split("/");
|
||||||
var moduleName = elements[elements.length - 1];
|
const moduleName = elements[elements.length - 1];
|
||||||
var moduleFolder = __dirname + "/../modules/" + module;
|
let moduleFolder = `${__dirname}/../modules/${module}`;
|
||||||
|
|
||||||
if (defaultModules.indexOf(moduleName) !== -1) {
|
if (defaultModules.includes(moduleName)) {
|
||||||
moduleFolder = __dirname + "/../modules/default/" + module;
|
moduleFolder = `${__dirname}/../modules/default/${module}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
var helperPath = moduleFolder + "/node_helper.js";
|
const helperPath = `${moduleFolder}/node_helper.js`;
|
||||||
|
|
||||||
var loadModule = true;
|
let loadHelper = true;
|
||||||
try {
|
try {
|
||||||
fs.accessSync(helperPath, fs.R_OK);
|
fs.accessSync(helperPath, fs.R_OK);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
loadModule = false;
|
loadHelper = false;
|
||||||
Log.log("No helper found for module: " + moduleName + ".");
|
Log.log(`No helper found for module: ${moduleName}.`);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (loadModule) {
|
if (loadHelper) {
|
||||||
var Module = require(helperPath);
|
const Module = require(helperPath);
|
||||||
var m = new Module();
|
let m = new Module();
|
||||||
|
|
||||||
if (m.requiresVersion) {
|
if (m.requiresVersion) {
|
||||||
Log.log("Check MagicMirror version for node helper '" + moduleName + "' - Minimum version: " + m.requiresVersion + " - Current version: " + global.version);
|
Log.log(`Check MagicMirror version for node helper '${moduleName}' - Minimum version: ${m.requiresVersion} - Current version: ${global.version}`);
|
||||||
if (cmpVersions(global.version, m.requiresVersion) >= 0) {
|
if (cmpVersions(global.version, m.requiresVersion) >= 0) {
|
||||||
Log.log("Version is ok!");
|
Log.log("Version is ok!");
|
||||||
} else {
|
} else {
|
||||||
Log.log("Version is incorrect. Skip module: '" + moduleName + "'");
|
Log.warn(`Version is incorrect. Skip module: '${moduleName}'`);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -152,7 +143,7 @@ var App = function () {
|
|||||||
} else {
|
} else {
|
||||||
callback();
|
callback();
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Loads all modules.
|
* Loads all modules.
|
||||||
@ -160,12 +151,12 @@ var App = function () {
|
|||||||
* @param {Module[]} modules All modules to be loaded
|
* @param {Module[]} modules All modules to be loaded
|
||||||
* @param {Function} callback Function to be called after loading
|
* @param {Function} callback Function to be called after loading
|
||||||
*/
|
*/
|
||||||
var loadModules = function (modules, callback) {
|
function loadModules(modules, callback) {
|
||||||
Log.log("Loading module helpers ...");
|
Log.log("Loading module helpers ...");
|
||||||
|
|
||||||
var loadNextModule = function () {
|
function loadNextModule() {
|
||||||
if (modules.length > 0) {
|
if (modules.length > 0) {
|
||||||
var nextModule = modules[0];
|
const nextModule = modules[0];
|
||||||
loadModule(nextModule, function () {
|
loadModule(nextModule, function () {
|
||||||
modules = modules.slice(1);
|
modules = modules.slice(1);
|
||||||
loadNextModule();
|
loadNextModule();
|
||||||
@ -175,10 +166,10 @@ var App = function () {
|
|||||||
Log.log("All module helpers loaded.");
|
Log.log("All module helpers loaded.");
|
||||||
callback();
|
callback();
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
|
|
||||||
loadNextModule();
|
loadNextModule();
|
||||||
};
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Compare two semantic version numbers and return the difference.
|
* Compare two semantic version numbers and return the difference.
|
||||||
@ -190,11 +181,11 @@ var App = function () {
|
|||||||
* number if a is smaller and 0 if they are the same
|
* number if a is smaller and 0 if they are the same
|
||||||
*/
|
*/
|
||||||
function cmpVersions(a, b) {
|
function cmpVersions(a, b) {
|
||||||
var i, diff;
|
let i, diff;
|
||||||
var regExStrip0 = /(\.0+)+$/;
|
const regExStrip0 = /(\.0+)+$/;
|
||||||
var segmentsA = a.replace(regExStrip0, "").split(".");
|
const segmentsA = a.replace(regExStrip0, "").split(".");
|
||||||
var segmentsB = b.replace(regExStrip0, "").split(".");
|
const segmentsB = b.replace(regExStrip0, "").split(".");
|
||||||
var l = Math.min(segmentsA.length, segmentsB.length);
|
const l = Math.min(segmentsA.length, segmentsB.length);
|
||||||
|
|
||||||
for (i = 0; i < l; i++) {
|
for (i = 0; i < l; i++) {
|
||||||
diff = parseInt(segmentsA[i], 10) - parseInt(segmentsB[i], 10);
|
diff = parseInt(segmentsA[i], 10) - parseInt(segmentsB[i], 10);
|
||||||
@ -219,21 +210,19 @@ var App = function () {
|
|||||||
|
|
||||||
Log.setLogLevel(config.logLevel);
|
Log.setLogLevel(config.logLevel);
|
||||||
|
|
||||||
var modules = [];
|
let modules = [];
|
||||||
|
|
||||||
for (var m in config.modules) {
|
for (const module of config.modules) {
|
||||||
var module = config.modules[m];
|
if (!modules.includes(module.module) && !module.disabled) {
|
||||||
if (modules.indexOf(module.module) === -1 && !module.disabled) {
|
|
||||||
modules.push(module.module);
|
modules.push(module.module);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
loadModules(modules, function () {
|
loadModules(modules, function () {
|
||||||
var server = new Server(config, function (app, io) {
|
const server = new Server(config, function (app, io) {
|
||||||
Log.log("Server started ...");
|
Log.log("Server started ...");
|
||||||
|
|
||||||
for (var h in nodeHelpers) {
|
for (let nodeHelper of nodeHelpers) {
|
||||||
var nodeHelper = nodeHelpers[h];
|
|
||||||
nodeHelper.setExpressApp(app);
|
nodeHelper.setExpressApp(app);
|
||||||
nodeHelper.setSocketIO(io);
|
nodeHelper.setSocketIO(io);
|
||||||
nodeHelper.start();
|
nodeHelper.start();
|
||||||
@ -256,8 +245,7 @@ var App = function () {
|
|||||||
* Added to fix #1056
|
* Added to fix #1056
|
||||||
*/
|
*/
|
||||||
this.stop = function () {
|
this.stop = function () {
|
||||||
for (var h in nodeHelpers) {
|
for (const nodeHelper of nodeHelpers) {
|
||||||
var nodeHelper = nodeHelpers[h];
|
|
||||||
if (typeof nodeHelper.stop === "function") {
|
if (typeof nodeHelper.stop === "function") {
|
||||||
nodeHelper.stop();
|
nodeHelper.stop();
|
||||||
}
|
}
|
||||||
@ -292,6 +280,6 @@ var App = function () {
|
|||||||
this.stop();
|
this.stop();
|
||||||
process.exit(0);
|
process.exit(0);
|
||||||
});
|
});
|
||||||
};
|
}
|
||||||
|
|
||||||
module.exports = new App();
|
module.exports = new App();
|
||||||
|
@ -11,9 +11,9 @@ const linter = new Linter();
|
|||||||
const path = require("path");
|
const path = require("path");
|
||||||
const fs = require("fs");
|
const fs = require("fs");
|
||||||
|
|
||||||
const rootPath = path.resolve(__dirname + "/../");
|
const rootPath = path.resolve(`${__dirname}/../`);
|
||||||
const Log = require(rootPath + "/js/logger.js");
|
const Log = require(`${rootPath}/js/logger.js`);
|
||||||
const Utils = require(rootPath + "/js/utils.js");
|
const Utils = require(`${rootPath}/js/utils.js`);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns a string with path of configuration file.
|
* Returns a string with path of configuration file.
|
||||||
@ -23,11 +23,7 @@ const Utils = require(rootPath + "/js/utils.js");
|
|||||||
*/
|
*/
|
||||||
function getConfigFile() {
|
function getConfigFile() {
|
||||||
// FIXME: This function should be in core. Do you want refactor me ;) ?, be good!
|
// FIXME: This function should be in core. Do you want refactor me ;) ?, be good!
|
||||||
let configFileName = path.resolve(rootPath + "/config/config.js");
|
return path.resolve(process.env.MM_CONFIG_FILE || `${rootPath}/config/config.js`);
|
||||||
if (process.env.MM_CONFIG_FILE) {
|
|
||||||
configFileName = path.resolve(process.env.MM_CONFIG_FILE);
|
|
||||||
}
|
|
||||||
return configFileName;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -54,21 +50,18 @@ function checkConfigFile() {
|
|||||||
Log.info(Utils.colors.info("Checking file... "), configFileName);
|
Log.info(Utils.colors.info("Checking file... "), configFileName);
|
||||||
|
|
||||||
// I'm not sure if all ever is utf-8
|
// I'm not sure if all ever is utf-8
|
||||||
fs.readFile(configFileName, "utf-8", function (err, data) {
|
const configFile = fs.readFileSync(configFileName, "utf-8");
|
||||||
if (err) {
|
|
||||||
throw err;
|
const errors = linter.verify(configFile);
|
||||||
|
if (errors.length === 0) {
|
||||||
|
Log.info(Utils.colors.pass("Your configuration file doesn't contain syntax errors :)"));
|
||||||
|
} else {
|
||||||
|
Log.error(Utils.colors.error("Your configuration file contains syntax errors :("));
|
||||||
|
|
||||||
|
for (const error of errors) {
|
||||||
|
Log.error(`Line ${error.line} column ${error.column}: ${error.message}`);
|
||||||
}
|
}
|
||||||
const messages = linter.verify(data);
|
}
|
||||||
if (messages.length === 0) {
|
|
||||||
Log.info(Utils.colors.pass("Your configuration file doesn't contain syntax errors :)"));
|
|
||||||
} else {
|
|
||||||
Log.error(Utils.colors.error("Your configuration file contains syntax errors :("));
|
|
||||||
// In case the there errors show messages and return
|
|
||||||
messages.forEach((error) => {
|
|
||||||
Log.error("Line", error.line, "col", error.column, error.message);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
checkConfigFile();
|
checkConfigFile();
|
||||||
|
@ -6,11 +6,6 @@
|
|||||||
* Olex S. original idea this deprecated option
|
* Olex S. original idea this deprecated option
|
||||||
*/
|
*/
|
||||||
|
|
||||||
var deprecated = {
|
module.exports = {
|
||||||
configs: ["kioskmode"]
|
configs: ["kioskmode"]
|
||||||
};
|
};
|
||||||
|
|
||||||
/*************** DO NOT EDIT THE LINE BELOW ***************/
|
|
||||||
if (typeof module !== "undefined") {
|
|
||||||
module.exports = deprecated;
|
|
||||||
}
|
|
||||||
|
@ -5,7 +5,7 @@ const core = require("./app.js");
|
|||||||
const Log = require("./logger.js");
|
const Log = require("./logger.js");
|
||||||
|
|
||||||
// Config
|
// Config
|
||||||
var config = process.env.config ? JSON.parse(process.env.config) : {};
|
let config = process.env.config ? JSON.parse(process.env.config) : {};
|
||||||
// Module to control application life.
|
// Module to control application life.
|
||||||
const app = electron.app;
|
const app = electron.app;
|
||||||
// Module to create native browser window.
|
// Module to create native browser window.
|
||||||
@ -20,7 +20,7 @@ let mainWindow;
|
|||||||
*/
|
*/
|
||||||
function createWindow() {
|
function createWindow() {
|
||||||
app.commandLine.appendSwitch("autoplay-policy", "no-user-gesture-required");
|
app.commandLine.appendSwitch("autoplay-policy", "no-user-gesture-required");
|
||||||
var electronOptionsDefaults = {
|
let electronOptionsDefaults = {
|
||||||
width: 800,
|
width: 800,
|
||||||
height: 600,
|
height: 600,
|
||||||
x: 0,
|
x: 0,
|
||||||
@ -42,7 +42,7 @@ function createWindow() {
|
|||||||
electronOptionsDefaults.autoHideMenuBar = true;
|
electronOptionsDefaults.autoHideMenuBar = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
var electronOptions = Object.assign({}, electronOptionsDefaults, config.electronOptions);
|
const electronOptions = Object.assign({}, electronOptionsDefaults, config.electronOptions);
|
||||||
|
|
||||||
// Create the browser window.
|
// Create the browser window.
|
||||||
mainWindow = new BrowserWindow(electronOptions);
|
mainWindow = new BrowserWindow(electronOptions);
|
||||||
@ -50,14 +50,14 @@ function createWindow() {
|
|||||||
// and load the index.html of the app.
|
// and load the index.html of the app.
|
||||||
// If config.address is not defined or is an empty string (listening on all interfaces), connect to localhost
|
// If config.address is not defined or is an empty string (listening on all interfaces), connect to localhost
|
||||||
|
|
||||||
var prefix;
|
let prefix;
|
||||||
if (config["tls"] !== null && config["tls"]) {
|
if (config["tls"] !== null && config["tls"]) {
|
||||||
prefix = "https://";
|
prefix = "https://";
|
||||||
} else {
|
} else {
|
||||||
prefix = "http://";
|
prefix = "http://";
|
||||||
}
|
}
|
||||||
|
|
||||||
var address = (config.address === void 0) | (config.address === "") ? (config.address = "localhost") : config.address;
|
let address = (config.address === void 0) | (config.address === "") ? (config.address = "localhost") : config.address;
|
||||||
mainWindow.loadURL(`${prefix}${address}:${config.port}`);
|
mainWindow.loadURL(`${prefix}${address}:${config.port}`);
|
||||||
|
|
||||||
// Open the DevTools if run with "npm start dev"
|
// Open the DevTools if run with "npm start dev"
|
||||||
@ -125,7 +125,7 @@ app.on("before-quit", (event) => {
|
|||||||
|
|
||||||
// Start the core application if server is run on localhost
|
// Start the core application if server is run on localhost
|
||||||
// This starts all node helpers and starts the webserver.
|
// This starts all node helpers and starts the webserver.
|
||||||
if (["localhost", "127.0.0.1", "::1", "::ffff:127.0.0.1", undefined].indexOf(config.address) > -1) {
|
if (["localhost", "127.0.0.1", "::1", "::ffff:127.0.0.1", undefined].includes(config.address)) {
|
||||||
core.start(function (c) {
|
core.start(function (c) {
|
||||||
config = c;
|
config = c;
|
||||||
});
|
});
|
||||||
|
@ -8,18 +8,18 @@ const Class = require("./class.js");
|
|||||||
const Log = require("./logger.js");
|
const Log = require("./logger.js");
|
||||||
const express = require("express");
|
const express = require("express");
|
||||||
|
|
||||||
var NodeHelper = Class.extend({
|
const NodeHelper = Class.extend({
|
||||||
init: function () {
|
init() {
|
||||||
Log.log("Initializing new module helper ...");
|
Log.log("Initializing new module helper ...");
|
||||||
},
|
},
|
||||||
|
|
||||||
loaded: function (callback) {
|
loaded(callback) {
|
||||||
Log.log("Module helper loaded: " + this.name);
|
Log.log(`Module helper loaded: ${this.name}`);
|
||||||
callback();
|
callback();
|
||||||
},
|
},
|
||||||
|
|
||||||
start: function () {
|
start() {
|
||||||
Log.log("Starting module helper: " + this.name);
|
Log.log(`Starting module helper: ${this.name}`);
|
||||||
},
|
},
|
||||||
|
|
||||||
/* stop()
|
/* stop()
|
||||||
@ -28,8 +28,8 @@ var NodeHelper = Class.extend({
|
|||||||
* gracefully exit the module.
|
* gracefully exit the module.
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
stop: function () {
|
stop() {
|
||||||
Log.log("Stopping module helper: " + this.name);
|
Log.log(`Stopping module helper: ${this.name}`);
|
||||||
},
|
},
|
||||||
|
|
||||||
/* socketNotificationReceived(notification, payload)
|
/* socketNotificationReceived(notification, payload)
|
||||||
@ -38,8 +38,8 @@ var NodeHelper = Class.extend({
|
|||||||
* argument notification string - The identifier of the notification.
|
* argument notification string - The identifier of the notification.
|
||||||
* argument payload mixed - The payload of the notification.
|
* argument payload mixed - The payload of the notification.
|
||||||
*/
|
*/
|
||||||
socketNotificationReceived: function (notification, payload) {
|
socketNotificationReceived(notification, payload) {
|
||||||
Log.log(this.name + " received a socket notification: " + notification + " - Payload: " + payload);
|
Log.log(`${this.name} received a socket notification: ${notification} - Payload: ${payload}`);
|
||||||
},
|
},
|
||||||
|
|
||||||
/* setName(name)
|
/* setName(name)
|
||||||
@ -47,7 +47,7 @@ var NodeHelper = Class.extend({
|
|||||||
*
|
*
|
||||||
* argument name string - Module name.
|
* argument name string - Module name.
|
||||||
*/
|
*/
|
||||||
setName: function (name) {
|
setName(name) {
|
||||||
this.name = name;
|
this.name = name;
|
||||||
},
|
},
|
||||||
|
|
||||||
@ -56,7 +56,7 @@ var NodeHelper = Class.extend({
|
|||||||
*
|
*
|
||||||
* argument path string - Module path.
|
* argument path string - Module path.
|
||||||
*/
|
*/
|
||||||
setPath: function (path) {
|
setPath(path) {
|
||||||
this.path = path;
|
this.path = path;
|
||||||
},
|
},
|
||||||
|
|
||||||
@ -66,7 +66,7 @@ var NodeHelper = Class.extend({
|
|||||||
* argument notification string - The identifier of the notification.
|
* argument notification string - The identifier of the notification.
|
||||||
* argument payload mixed - The payload of the notification.
|
* argument payload mixed - The payload of the notification.
|
||||||
*/
|
*/
|
||||||
sendSocketNotification: function (notification, payload) {
|
sendSocketNotification(notification, payload) {
|
||||||
this.io.of(this.name).emit(notification, payload);
|
this.io.of(this.name).emit(notification, payload);
|
||||||
},
|
},
|
||||||
|
|
||||||
@ -76,11 +76,10 @@ var NodeHelper = Class.extend({
|
|||||||
*
|
*
|
||||||
* argument app Express app - The Express app object.
|
* argument app Express app - The Express app object.
|
||||||
*/
|
*/
|
||||||
setExpressApp: function (app) {
|
setExpressApp(app) {
|
||||||
this.expressApp = app;
|
this.expressApp = app;
|
||||||
|
|
||||||
var publicPath = this.path + "/public";
|
app.use(`/${this.name}`, express.static(`${this.path}/public`));
|
||||||
app.use("/" + this.name, express.static(publicPath));
|
|
||||||
},
|
},
|
||||||
|
|
||||||
/* setSocketIO(io)
|
/* setSocketIO(io)
|
||||||
@ -89,27 +88,25 @@ var NodeHelper = Class.extend({
|
|||||||
*
|
*
|
||||||
* argument io Socket.io - The Socket io object.
|
* argument io Socket.io - The Socket io object.
|
||||||
*/
|
*/
|
||||||
setSocketIO: function (io) {
|
setSocketIO(io) {
|
||||||
var self = this;
|
this.io = io;
|
||||||
self.io = io;
|
|
||||||
|
|
||||||
Log.log("Connecting socket for: " + this.name);
|
Log.log(`Connecting socket for: ${this.name}`);
|
||||||
var namespace = this.name;
|
|
||||||
io.of(namespace).on("connection", function (socket) {
|
io.of(this.name).on("connection", (socket) => {
|
||||||
// add a catch all event.
|
// add a catch all event.
|
||||||
var onevent = socket.onevent;
|
const onevent = socket.onevent;
|
||||||
socket.onevent = function (packet) {
|
socket.onevent = function (packet) {
|
||||||
var args = packet.data || [];
|
const args = packet.data || [];
|
||||||
onevent.call(this, packet); // original call
|
onevent.call(this, packet); // original call
|
||||||
packet.data = ["*"].concat(args);
|
packet.data = ["*"].concat(args);
|
||||||
onevent.call(this, packet); // additional call to catch-all
|
onevent.call(this, packet); // additional call to catch-all
|
||||||
};
|
};
|
||||||
|
|
||||||
// register catch all.
|
// register catch all.
|
||||||
socket.on("*", function (notification, payload) {
|
socket.on("*", (notification, payload) => {
|
||||||
if (notification !== "*") {
|
if (notification !== "*") {
|
||||||
//Log.log('received message in namespace: ' + namespace);
|
this.socketNotificationReceived(notification, payload);
|
||||||
self.socketNotificationReceived(notification, payload);
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
@ -120,7 +117,4 @@ NodeHelper.create = function (moduleDefinition) {
|
|||||||
return NodeHelper.extend(moduleDefinition);
|
return NodeHelper.extend(moduleDefinition);
|
||||||
};
|
};
|
||||||
|
|
||||||
/*************** DO NOT EDIT THE LINE BELOW ***************/
|
module.exports = NodeHelper;
|
||||||
if (typeof module !== "undefined") {
|
|
||||||
module.exports = NodeHelper;
|
|
||||||
}
|
|
||||||
|
48
js/server.js
48
js/server.js
@ -4,25 +4,22 @@
|
|||||||
* By Michael Teeuw https://michaelteeuw.nl
|
* By Michael Teeuw https://michaelteeuw.nl
|
||||||
* MIT Licensed.
|
* MIT Licensed.
|
||||||
*/
|
*/
|
||||||
var express = require("express");
|
const express = require("express");
|
||||||
var app = require("express")();
|
const app = require("express")();
|
||||||
var path = require("path");
|
const path = require("path");
|
||||||
var ipfilter = require("express-ipfilter").IpFilter;
|
const ipfilter = require("express-ipfilter").IpFilter;
|
||||||
var fs = require("fs");
|
const fs = require("fs");
|
||||||
var helmet = require("helmet");
|
const helmet = require("helmet");
|
||||||
|
|
||||||
var Log = require("./logger.js");
|
const Log = require("./logger.js");
|
||||||
var Utils = require("./utils.js");
|
const Utils = require("./utils.js");
|
||||||
|
|
||||||
var Server = function (config, callback) {
|
function Server(config, callback) {
|
||||||
var port = config.port;
|
const port = process.env.MM_PORT || config.port;
|
||||||
if (process.env.MM_PORT) {
|
|
||||||
port = process.env.MM_PORT;
|
|
||||||
}
|
|
||||||
|
|
||||||
var server = null;
|
let server = null;
|
||||||
if (config.useHttps) {
|
if (config.useHttps) {
|
||||||
var options = {
|
const options = {
|
||||||
key: fs.readFileSync(config.httpsPrivateKey),
|
key: fs.readFileSync(config.httpsPrivateKey),
|
||||||
cert: fs.readFileSync(config.httpsCertificate)
|
cert: fs.readFileSync(config.httpsCertificate)
|
||||||
};
|
};
|
||||||
@ -30,18 +27,18 @@ var Server = function (config, callback) {
|
|||||||
} else {
|
} else {
|
||||||
server = require("http").Server(app);
|
server = require("http").Server(app);
|
||||||
}
|
}
|
||||||
var io = require("socket.io")(server);
|
const io = require("socket.io")(server);
|
||||||
|
|
||||||
Log.log("Starting server on port " + port + " ... ");
|
Log.log(`Starting server on port ${port} ... `);
|
||||||
|
|
||||||
server.listen(port, config.address ? config.address : "localhost");
|
server.listen(port, config.address || "localhost");
|
||||||
|
|
||||||
if (config.ipWhitelist instanceof Array && config.ipWhitelist.length === 0) {
|
if (config.ipWhitelist instanceof Array && config.ipWhitelist.length === 0) {
|
||||||
Log.warn(Utils.colors.warn("You're using a full whitelist configuration to allow for all IPs"));
|
Log.warn(Utils.colors.warn("You're using a full whitelist configuration to allow for all IPs"));
|
||||||
}
|
}
|
||||||
|
|
||||||
app.use(function (req, res, next) {
|
app.use(function (req, res, next) {
|
||||||
var result = ipfilter(config.ipWhitelist, { mode: config.ipWhitelist.length === 0 ? "deny" : "allow", log: false })(req, res, function (err) {
|
ipfilter(config.ipWhitelist, { mode: config.ipWhitelist.length === 0 ? "deny" : "allow", log: false })(req, res, function (err) {
|
||||||
if (err === undefined) {
|
if (err === undefined) {
|
||||||
return next();
|
return next();
|
||||||
}
|
}
|
||||||
@ -52,10 +49,9 @@ var Server = function (config, callback) {
|
|||||||
app.use(helmet({ contentSecurityPolicy: false }));
|
app.use(helmet({ contentSecurityPolicy: false }));
|
||||||
|
|
||||||
app.use("/js", express.static(__dirname));
|
app.use("/js", express.static(__dirname));
|
||||||
var directories = ["/config", "/css", "/fonts", "/modules", "/vendor", "/translations", "/tests/configs"];
|
|
||||||
var directory;
|
const directories = ["/config", "/css", "/fonts", "/modules", "/vendor", "/translations", "/tests/configs"];
|
||||||
for (var i in directories) {
|
for (const directory of directories) {
|
||||||
directory = directories[i];
|
|
||||||
app.use(directory, express.static(path.resolve(global.root_path + directory)));
|
app.use(directory, express.static(path.resolve(global.root_path + directory)));
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -68,10 +64,10 @@ var Server = function (config, callback) {
|
|||||||
});
|
});
|
||||||
|
|
||||||
app.get("/", function (req, res) {
|
app.get("/", function (req, res) {
|
||||||
var html = fs.readFileSync(path.resolve(global.root_path + "/index.html"), { encoding: "utf8" });
|
let html = fs.readFileSync(path.resolve(`${global.root_path}/index.html`), { encoding: "utf8" });
|
||||||
html = html.replace("#VERSION#", global.version);
|
html = html.replace("#VERSION#", global.version);
|
||||||
|
|
||||||
var configFile = "config/config.js";
|
let configFile = "config/config.js";
|
||||||
if (typeof global.configuration_file !== "undefined") {
|
if (typeof global.configuration_file !== "undefined") {
|
||||||
configFile = global.configuration_file;
|
configFile = global.configuration_file;
|
||||||
}
|
}
|
||||||
@ -83,6 +79,6 @@ var Server = function (config, callback) {
|
|||||||
if (typeof callback === "function") {
|
if (typeof callback === "function") {
|
||||||
callback(app, io);
|
callback(app, io);
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
|
|
||||||
module.exports = Server;
|
module.exports = Server;
|
||||||
|
@ -4,9 +4,9 @@
|
|||||||
* By Rodrigo Ramírez Norambuena https://rodrigoramirez.com
|
* By Rodrigo Ramírez Norambuena https://rodrigoramirez.com
|
||||||
* MIT Licensed.
|
* MIT Licensed.
|
||||||
*/
|
*/
|
||||||
var colors = require("colors/safe");
|
const colors = require("colors/safe");
|
||||||
|
|
||||||
var Utils = {
|
module.exports = {
|
||||||
colors: {
|
colors: {
|
||||||
warn: colors.yellow,
|
warn: colors.yellow,
|
||||||
error: colors.red,
|
error: colors.red,
|
||||||
@ -14,7 +14,3 @@ var Utils = {
|
|||||||
pass: colors.green
|
pass: colors.green
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
if (typeof module !== "undefined") {
|
|
||||||
module.exports = Utils;
|
|
||||||
}
|
|
||||||
|
@ -3,12 +3,12 @@ const path = require("path");
|
|||||||
const expect = require("chai").expect;
|
const expect = require("chai").expect;
|
||||||
const vm = require("vm");
|
const vm = require("vm");
|
||||||
|
|
||||||
before(function () {
|
const basedir = path.join(__dirname, "../../..");
|
||||||
var basedir = path.join(__dirname, "../../..");
|
|
||||||
|
|
||||||
var fileName = "js/app.js";
|
before(function () {
|
||||||
var filePath = path.join(basedir, fileName);
|
const fileName = "js/app.js";
|
||||||
var code = fs.readFileSync(filePath);
|
const filePath = path.join(basedir, fileName);
|
||||||
|
const code = fs.readFileSync(filePath);
|
||||||
|
|
||||||
this.sandbox = {
|
this.sandbox = {
|
||||||
module: {},
|
module: {},
|
||||||
@ -36,22 +36,12 @@ before(function () {
|
|||||||
vm.runInNewContext(code, this.sandbox, fileName);
|
vm.runInNewContext(code, this.sandbox, fileName);
|
||||||
});
|
});
|
||||||
|
|
||||||
after(function () {
|
|
||||||
//console.log(global);
|
|
||||||
});
|
|
||||||
|
|
||||||
describe("Default modules set in modules/default/defaultmodules.js", function () {
|
describe("Default modules set in modules/default/defaultmodules.js", function () {
|
||||||
var expectedDefaultModules = ["alert", "calendar", "clock", "compliments", "currentweather", "helloworld", "newsfeed", "weatherforecast", "updatenotification"];
|
const expectedDefaultModules = require("../../../modules/default/defaultmodules");
|
||||||
|
|
||||||
expectedDefaultModules.forEach((defaultModule) => {
|
for (const defaultModule of expectedDefaultModules) {
|
||||||
it(`contains default module "${defaultModule}"`, function () {
|
|
||||||
expect(this.sandbox.defaultModules).to.include(defaultModule);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
expectedDefaultModules.forEach((defaultModule) => {
|
|
||||||
it(`contains a folder for modules/default/${defaultModule}"`, function () {
|
it(`contains a folder for modules/default/${defaultModule}"`, function () {
|
||||||
expect(fs.existsSync(path.join(this.sandbox.global.root_path, "modules/default", defaultModule))).to.equal(true);
|
expect(fs.existsSync(path.join(this.sandbox.global.root_path, "modules/default", defaultModule))).to.equal(true);
|
||||||
});
|
});
|
||||||
});
|
}
|
||||||
});
|
});
|
||||||
|
Loading…
x
Reference in New Issue
Block a user