mirror of
https://github.com/Hopiu/webapi-eca.git
synced 2026-03-16 22:10:31 +00:00
persistence interface errors almost fixed, FLUSHALL on DB and then run unit tests again
This commit is contained in:
Dominic
parent
f35aa5a285
commit
0e087b6c42
21 changed files with 1289 additions and 1116 deletions
|
|
@ -50,13 +50,13 @@ loadConfigFile = ( configPath ) =>
|
|||
#TODO Try to get rid of crypto key
|
||||
try
|
||||
@config = JSON.parse fs.readFileSync path.resolve __dirname, '..', configPath
|
||||
isReady = true
|
||||
@isReady = true
|
||||
for prop in confProperties
|
||||
if !@config[prop]
|
||||
isReady = false
|
||||
if not isReady and not @nolog
|
||||
console.error """Missing property in config file, requires:
|
||||
- #{ confProperties.join "\n -" }"""
|
||||
@isReady = false
|
||||
if not @isReady and not @nolog
|
||||
console.error "Missing property in config file, requires:\n" +
|
||||
" - #{ confProperties.join "\n - " }"
|
||||
catch e
|
||||
if not @nolog
|
||||
console.error "Failed loading config file: #{ e.message }"
|
||||
|
|
@ -75,7 +75,7 @@ fetchProp = ( prop ) => @config?[prop]
|
|||
|
||||
@public isReady()
|
||||
###
|
||||
exports.isReady = => @config?
|
||||
exports.isReady = => @isReady
|
||||
|
||||
###
|
||||
***Returns*** the HTTP port
|
||||
|
|
|
|||
|
|
@ -231,7 +231,9 @@ class IndexedModules
|
|||
@log.info "DB | storeModule(#{ @setname }): #{ mId }"
|
||||
@db.sadd "#{ @setname }s", mId,
|
||||
replyHandler "Storing '#{ @setname }' key '#{ mId }'"
|
||||
@db.hmset "#{ @setname }:#{ mId }", data,
|
||||
@db.hmset "#{ @setname }:#{ mId }", 'code', data['code'],
|
||||
replyHandler "Storing '#{ @setname }:#{ mId }'"
|
||||
@db.hmset "#{ @setname }:#{ mId }", 'reqparams', data['reqparams'],
|
||||
replyHandler "Storing '#{ @setname }:#{ mId }'"
|
||||
|
||||
#TODO add testing
|
||||
|
|
|
|||
|
|
@ -106,6 +106,7 @@ init = =>
|
|||
process.exit()
|
||||
|
||||
logconf = conf.getLogConf()
|
||||
|
||||
if argv.m
|
||||
logconf[ 'mode' ] = argv.m
|
||||
if argv.i
|
||||
|
|
@ -145,11 +146,17 @@ init = =>
|
|||
|
||||
# Start the event poller. The module manager will emit events for it
|
||||
@log.info 'RS | Forking a child process for the event poller'
|
||||
# Grab all required log config fields
|
||||
cliArgs = [
|
||||
# the log mode: [development|productive]
|
||||
args.logconf['mode']
|
||||
# the I/O log level, refer to logging.coffee for the different levels
|
||||
args.logconf['io-level']
|
||||
# the file log level, refer to logging.coffee for the different levels
|
||||
args.logconf['file-level']
|
||||
# the optional path to the log file
|
||||
args.logconf['file-path']
|
||||
# whether a log file shall be written at all: null else
|
||||
args.logconf['nolog']
|
||||
]
|
||||
poller = cp.fork path.resolve( __dirname, nameEP ), cliArgs
|
||||
|
|
|
|||
|
|
@ -1,6 +1,9 @@
|
|||
{
|
||||
"http_port": 8125,
|
||||
"db_port": 6379,
|
||||
"crypto_key": "[choose_a_safe_cypto_key(max_256_bit)]",
|
||||
"session_secret": "[choose_a_safe_session_key]"
|
||||
"http-port": 8125,
|
||||
"db-port": 6379,
|
||||
"log": {
|
||||
"mode": "development",
|
||||
"io-level": "info",
|
||||
"file-level": "info"
|
||||
}
|
||||
}
|
||||
|
|
@ -1,4 +1,5 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
|
||||
/*
|
||||
|
||||
Components Manager
|
||||
|
|
@ -6,12 +7,10 @@ Components Manager
|
|||
> The components manager takes care of the dynamic JS modules and the rules.
|
||||
> Event Poller and Action Invoker modules are loaded as strings and stored in the database,
|
||||
> then compiled into node modules and rules and used in the engine and event poller.
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
(function() {
|
||||
var commandFunctions, db, dynmod, events, exports, fs, path, vm,
|
||||
_this = this;
|
||||
var commandFunctions, db, dynmod, events, exports, fs, path, vm;
|
||||
|
||||
db = require('./persistence');
|
||||
|
||||
|
|
@ -25,86 +24,94 @@ Components Manager
|
|||
|
||||
events = require('events');
|
||||
|
||||
|
||||
/*
|
||||
Module call
|
||||
-----------
|
||||
Initializes the HTTP listener and its request handler.
|
||||
|
||||
@param {Object} args
|
||||
*/
|
||||
*/
|
||||
|
||||
exports = module.exports = (function(_this) {
|
||||
return function(args) {
|
||||
_this.log = args.logger;
|
||||
_this.ee = new events.EventEmitter();
|
||||
db(args);
|
||||
dynmod(args);
|
||||
return module.exports;
|
||||
};
|
||||
})(this);
|
||||
|
||||
exports = module.exports = function(args) {
|
||||
_this.log = args.logger;
|
||||
_this.ee = new events.EventEmitter();
|
||||
db(args);
|
||||
dynmod(args);
|
||||
return module.exports;
|
||||
};
|
||||
|
||||
exports.addListener = function(evt, eh) {
|
||||
_this.ee.addListener(evt, eh);
|
||||
return db.getRules(function(err, obj) {
|
||||
var id, rule, _results;
|
||||
_results = [];
|
||||
for (id in obj) {
|
||||
rule = obj[id];
|
||||
_results.push(_this.ee.emit('init', rule));
|
||||
}
|
||||
return _results;
|
||||
});
|
||||
};
|
||||
|
||||
exports.processRequest = function(user, obj, cb) {
|
||||
var answ;
|
||||
if (commandFunctions[obj.command]) {
|
||||
return answ = commandFunctions[obj.command](user, obj, cb);
|
||||
} else {
|
||||
return cb({
|
||||
code: 404,
|
||||
message: 'Strange request!'
|
||||
exports.addListener = (function(_this) {
|
||||
return function(evt, eh) {
|
||||
_this.ee.addListener(evt, eh);
|
||||
return db.getRules(function(err, obj) {
|
||||
var id, rule, _results;
|
||||
_results = [];
|
||||
for (id in obj) {
|
||||
rule = obj[id];
|
||||
_results.push(_this.ee.emit('init', rule));
|
||||
}
|
||||
return _results;
|
||||
});
|
||||
}
|
||||
};
|
||||
};
|
||||
})(this);
|
||||
|
||||
exports.processRequest = (function(_this) {
|
||||
return function(user, obj, cb) {
|
||||
var answ;
|
||||
if (commandFunctions[obj.command]) {
|
||||
return answ = commandFunctions[obj.command](user, obj, cb);
|
||||
} else {
|
||||
return cb({
|
||||
code: 404,
|
||||
message: 'Strange request!'
|
||||
});
|
||||
}
|
||||
};
|
||||
})(this);
|
||||
|
||||
commandFunctions = {
|
||||
forge_event_poller: function(user, obj, cb) {
|
||||
var answ;
|
||||
answ = {
|
||||
code: 200
|
||||
};
|
||||
return db.getEventPoller(obj.id, function(err, mod) {
|
||||
var cm, id, name, src, _ref;
|
||||
if (mod) {
|
||||
answ.code = 409;
|
||||
answ.message = 'Event Poller module name already existing: ' + obj.id;
|
||||
} else {
|
||||
src = obj.data;
|
||||
cm = dynmod.compileString(src, obj.id, {}, obj.lang);
|
||||
answ = cm.answ;
|
||||
if (answ.code === 200) {
|
||||
events = [];
|
||||
_ref = cm.module;
|
||||
for (name in _ref) {
|
||||
id = _ref[name];
|
||||
events.push(name);
|
||||
}
|
||||
_this.log.info("CM | Storing new eventpoller with events " + events);
|
||||
answ.message = "Event Poller module successfully stored! Found following event(s): " + events;
|
||||
db.storeEventPoller(obj.id, user.username, {
|
||||
code: obj.data,
|
||||
lang: obj.lang,
|
||||
params: obj.params,
|
||||
events: events
|
||||
});
|
||||
if (obj["public"] === 'true') {
|
||||
db.publishEventPoller(obj.id);
|
||||
forge_event_poller: (function(_this) {
|
||||
return function(user, obj, cb) {
|
||||
var answ;
|
||||
answ = {
|
||||
code: 200
|
||||
};
|
||||
return db.getEventPoller(obj.id, function(err, mod) {
|
||||
var cm, id, name, src, _ref;
|
||||
if (mod) {
|
||||
answ.code = 409;
|
||||
answ.message = 'Event Poller module name already existing: ' + obj.id;
|
||||
} else {
|
||||
src = obj.data;
|
||||
cm = dynmod.compileString(src, obj.id, {}, obj.lang);
|
||||
answ = cm.answ;
|
||||
if (answ.code === 200) {
|
||||
events = [];
|
||||
_ref = cm.module;
|
||||
for (name in _ref) {
|
||||
id = _ref[name];
|
||||
events.push(name);
|
||||
}
|
||||
_this.log.info("CM | Storing new eventpoller with events " + events);
|
||||
answ.message = "Event Poller module successfully stored! Found following event(s): " + events;
|
||||
db.storeEventPoller(obj.id, user.username, {
|
||||
code: obj.data,
|
||||
lang: obj.lang,
|
||||
params: obj.params,
|
||||
events: events
|
||||
});
|
||||
if (obj["public"] === 'true') {
|
||||
db.publishEventPoller(obj.id);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return cb(answ);
|
||||
});
|
||||
},
|
||||
return cb(answ);
|
||||
});
|
||||
};
|
||||
})(this),
|
||||
get_event_pollers: function(user, obj, cb) {
|
||||
return db.getAvailableEventPollerIds(user.username, function(err, obj) {
|
||||
var fGetEvents, id, oRes, sem, _i, _len, _results;
|
||||
|
|
@ -169,80 +176,84 @@ Components Manager
|
|||
});
|
||||
});
|
||||
},
|
||||
forge_action_invoker: function(user, obj, cb) {
|
||||
var answ;
|
||||
answ = {
|
||||
code: 200
|
||||
};
|
||||
return db.getActionInvoker(obj.id, function(err, mod) {
|
||||
var actions, cm, id, name, src, _ref;
|
||||
if (mod) {
|
||||
answ.code = 409;
|
||||
answ.message = 'Action Invoker module name already existing: ' + obj.id;
|
||||
} else {
|
||||
src = obj.data;
|
||||
cm = dynmod.compileString(src, obj.id, {}, obj.lang);
|
||||
answ = cm.answ;
|
||||
if (answ.code === 200) {
|
||||
actions = [];
|
||||
_ref = cm.module;
|
||||
for (name in _ref) {
|
||||
id = _ref[name];
|
||||
actions.push(name);
|
||||
}
|
||||
_this.log.info("CM | Storing new eventpoller with actions " + actions);
|
||||
answ.message = "Action Invoker module successfully stored! Found following action(s): " + actions;
|
||||
db.storeActionInvoker(obj.id, user.username, {
|
||||
code: obj.data,
|
||||
lang: obj.lang,
|
||||
params: obj.params,
|
||||
actions: actions
|
||||
});
|
||||
if (obj["public"] === 'true') {
|
||||
db.publishActionInvoker(obj.id);
|
||||
forge_action_invoker: (function(_this) {
|
||||
return function(user, obj, cb) {
|
||||
var answ;
|
||||
answ = {
|
||||
code: 200
|
||||
};
|
||||
return db.getActionInvoker(obj.id, function(err, mod) {
|
||||
var actions, cm, id, name, src, _ref;
|
||||
if (mod) {
|
||||
answ.code = 409;
|
||||
answ.message = 'Action Invoker module name already existing: ' + obj.id;
|
||||
} else {
|
||||
src = obj.data;
|
||||
cm = dynmod.compileString(src, obj.id, {}, obj.lang);
|
||||
answ = cm.answ;
|
||||
if (answ.code === 200) {
|
||||
actions = [];
|
||||
_ref = cm.module;
|
||||
for (name in _ref) {
|
||||
id = _ref[name];
|
||||
actions.push(name);
|
||||
}
|
||||
_this.log.info("CM | Storing new eventpoller with actions " + actions);
|
||||
answ.message = "Action Invoker module successfully stored! Found following action(s): " + actions;
|
||||
db.storeActionInvoker(obj.id, user.username, {
|
||||
code: obj.data,
|
||||
lang: obj.lang,
|
||||
params: obj.params,
|
||||
actions: actions
|
||||
});
|
||||
if (obj["public"] === 'true') {
|
||||
db.publishActionInvoker(obj.id);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return cb(answ);
|
||||
});
|
||||
},
|
||||
return cb(answ);
|
||||
});
|
||||
};
|
||||
})(this),
|
||||
get_rules: function(user, obj, cb) {
|
||||
return console.log('CM | Implement get_rules');
|
||||
},
|
||||
forge_rule: function(user, obj, cb) {
|
||||
obj.event = JSON.parse(obj.event);
|
||||
return db.getRule(obj.id, function(err, objRule) {
|
||||
var answ, id, modules, params, rule;
|
||||
if (objRule !== null) {
|
||||
answ = {
|
||||
code: 409,
|
||||
message: 'Rule name already existing!'
|
||||
};
|
||||
} else {
|
||||
answ = {
|
||||
code: 200,
|
||||
message: 'Rule stored and activated!'
|
||||
};
|
||||
rule = {
|
||||
id: obj.id,
|
||||
event: "" + obj.event.module + " -> " + obj.event["function"],
|
||||
conditions: JSON.parse(obj.conditions),
|
||||
actions: JSON.parse(obj.actions)
|
||||
};
|
||||
modules = JSON.parse(obj.action_params);
|
||||
db.storeRule(rule.id, JSON.stringify(rule));
|
||||
db.linkRule(rule.id, user.username);
|
||||
db.activateRule(rule.id, user.username);
|
||||
db.storeEventUserParams(obj.event.module, user.username, obj.event_params);
|
||||
for (id in modules) {
|
||||
params = modules[id];
|
||||
db.storeActionUserParams(id, user.username, JSON.stringify(params));
|
||||
forge_rule: (function(_this) {
|
||||
return function(user, obj, cb) {
|
||||
obj.event = JSON.parse(obj.event);
|
||||
return db.getRule(obj.id, function(err, objRule) {
|
||||
var answ, id, modules, params, rule;
|
||||
if (objRule !== null) {
|
||||
answ = {
|
||||
code: 409,
|
||||
message: 'Rule name already existing!'
|
||||
};
|
||||
} else {
|
||||
answ = {
|
||||
code: 200,
|
||||
message: 'Rule stored and activated!'
|
||||
};
|
||||
rule = {
|
||||
id: obj.id,
|
||||
event: "" + obj.event.module + " -> " + obj.event["function"],
|
||||
conditions: JSON.parse(obj.conditions),
|
||||
actions: JSON.parse(obj.actions)
|
||||
};
|
||||
modules = JSON.parse(obj.action_params);
|
||||
db.storeRule(rule.id, JSON.stringify(rule));
|
||||
db.linkRule(rule.id, user.username);
|
||||
db.activateRule(rule.id, user.username);
|
||||
db.storeEventUserParams(obj.event.module, user.username, obj.event_params);
|
||||
for (id in modules) {
|
||||
params = modules[id];
|
||||
db.storeActionUserParams(id, user.username, JSON.stringify(params));
|
||||
}
|
||||
_this.ee.emit('newRule', JSON.stringify(rule));
|
||||
}
|
||||
_this.ee.emit('newRule', JSON.stringify(rule));
|
||||
}
|
||||
return cb(answ);
|
||||
});
|
||||
}
|
||||
return cb(answ);
|
||||
});
|
||||
};
|
||||
})(this)
|
||||
};
|
||||
|
||||
}).call(this);
|
||||
|
|
|
|||
|
|
@ -1,20 +1,20 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
|
||||
/*
|
||||
|
||||
Configuration
|
||||
=============
|
||||
> Loads the configuration file and acts as an interface to it.
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
(function() {
|
||||
var exports, fetchProp, fs, loadConfigFile, path,
|
||||
_this = this;
|
||||
var exports, fetchProp, fs, loadConfigFile, path;
|
||||
|
||||
fs = require('fs');
|
||||
|
||||
path = require('path');
|
||||
|
||||
|
||||
/*
|
||||
Module call
|
||||
-----------
|
||||
|
|
@ -24,21 +24,23 @@ Configuration
|
|||
be generated) and configPath for a custom configuration file path.
|
||||
|
||||
@param {Object} args
|
||||
*/
|
||||
*/
|
||||
|
||||
exports = module.exports = (function(_this) {
|
||||
return function(args) {
|
||||
args = args != null ? args : {};
|
||||
if (args.nolog) {
|
||||
_this.nolog = true;
|
||||
}
|
||||
if (args.configPath) {
|
||||
loadConfigFile(args.configPath);
|
||||
} else {
|
||||
loadConfigFile(path.join('config', 'config.json'));
|
||||
}
|
||||
return module.exports;
|
||||
};
|
||||
})(this);
|
||||
|
||||
exports = module.exports = function(args) {
|
||||
args = args != null ? args : {};
|
||||
if (args.nolog) {
|
||||
_this.nolog = true;
|
||||
}
|
||||
if (args.configPath) {
|
||||
loadConfigFile(args.configPath);
|
||||
} else {
|
||||
loadConfigFile(path.join('config', 'config.json'));
|
||||
}
|
||||
return module.exports;
|
||||
};
|
||||
|
||||
/*
|
||||
Tries to load a configuration file from the path relative to this module's parent folder.
|
||||
|
|
@ -46,96 +48,101 @@ Configuration
|
|||
|
||||
@private loadConfigFile
|
||||
@param {String} configPath
|
||||
*/
|
||||
*/
|
||||
|
||||
|
||||
loadConfigFile = function(configPath) {
|
||||
var confProperties, e, isReady, prop, _i, _len;
|
||||
_this.config = null;
|
||||
confProperties = ['log', 'http-port', 'db-port'];
|
||||
try {
|
||||
_this.config = JSON.parse(fs.readFileSync(path.resolve(__dirname, '..', configPath)));
|
||||
isReady = true;
|
||||
for (_i = 0, _len = confProperties.length; _i < _len; _i++) {
|
||||
prop = confProperties[_i];
|
||||
if (!_this.config[prop]) {
|
||||
isReady = false;
|
||||
loadConfigFile = (function(_this) {
|
||||
return function(configPath) {
|
||||
var confProperties, e, prop, _i, _len;
|
||||
_this.config = null;
|
||||
confProperties = ['log', 'http-port', 'db-port'];
|
||||
try {
|
||||
_this.config = JSON.parse(fs.readFileSync(path.resolve(__dirname, '..', configPath)));
|
||||
_this.isReady = true;
|
||||
for (_i = 0, _len = confProperties.length; _i < _len; _i++) {
|
||||
prop = confProperties[_i];
|
||||
if (!_this.config[prop]) {
|
||||
_this.isReady = false;
|
||||
}
|
||||
}
|
||||
if (!_this.isReady && !_this.nolog) {
|
||||
return console.error("Missing property in config file, requires:\n" + (" - " + (confProperties.join("\n - "))));
|
||||
}
|
||||
} catch (_error) {
|
||||
e = _error;
|
||||
if (!_this.nolog) {
|
||||
return console.error("Failed loading config file: " + e.message);
|
||||
}
|
||||
}
|
||||
if (!isReady && !_this.nolog) {
|
||||
return console.error("Missing property in config file, requires: \n- " + (confProperties.join("\n -")));
|
||||
}
|
||||
} catch (_error) {
|
||||
e = _error;
|
||||
if (!_this.nolog) {
|
||||
return console.error("Failed loading config file: " + e.message);
|
||||
}
|
||||
}
|
||||
};
|
||||
};
|
||||
})(this);
|
||||
|
||||
|
||||
/*
|
||||
Fetch a property from the configuration
|
||||
|
||||
@private fetchProp( *prop* )
|
||||
@param {String} prop
|
||||
*/
|
||||
*/
|
||||
|
||||
fetchProp = (function(_this) {
|
||||
return function(prop) {
|
||||
var _ref;
|
||||
return (_ref = _this.config) != null ? _ref[prop] : void 0;
|
||||
};
|
||||
})(this);
|
||||
|
||||
fetchProp = function(prop) {
|
||||
var _ref;
|
||||
return (_ref = _this.config) != null ? _ref[prop] : void 0;
|
||||
};
|
||||
|
||||
/*
|
||||
***Returns*** true if the config file is ready, else false
|
||||
|
||||
@public isReady()
|
||||
*/
|
||||
*/
|
||||
|
||||
exports.isReady = (function(_this) {
|
||||
return function() {
|
||||
return _this.isReady;
|
||||
};
|
||||
})(this);
|
||||
|
||||
exports.isReady = function() {
|
||||
return _this.config != null;
|
||||
};
|
||||
|
||||
/*
|
||||
***Returns*** the HTTP port
|
||||
|
||||
@public getHttpPort()
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.getHttpPort = function() {
|
||||
return fetchProp('http-port');
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
***Returns*** the DB port*
|
||||
|
||||
@public getDBPort()
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.getDbPort = function() {
|
||||
return fetchProp('db-port');
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
***Returns*** the log conf object
|
||||
|
||||
@public getLogConf()
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.getLogConf = function() {
|
||||
return fetchProp('log');
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
***Returns*** the crypto key
|
||||
|
||||
@public getCryptoKey()
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.getCryptoKey = function() {
|
||||
return fetchProp('crypto-key');
|
||||
|
|
|
|||
|
|
@ -1,16 +1,15 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
|
||||
/*
|
||||
|
||||
Dynamic Modules
|
||||
===============
|
||||
> Compiles CoffeeScript modules and loads JS modules in a VM, together
|
||||
> with only a few allowed node.js modules.
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
(function() {
|
||||
var cs, exports, needle, vm,
|
||||
_this = this;
|
||||
var cs, exports, needle, vm;
|
||||
|
||||
vm = require('vm');
|
||||
|
||||
|
|
@ -18,19 +17,22 @@ Dynamic Modules
|
|||
|
||||
cs = require('coffee-script');
|
||||
|
||||
|
||||
/*
|
||||
Module call
|
||||
-----------
|
||||
Initializes the dynamic module handler.
|
||||
|
||||
@param {Object} args
|
||||
*/
|
||||
*/
|
||||
|
||||
exports = module.exports = (function(_this) {
|
||||
return function(args) {
|
||||
_this.log = args.logger;
|
||||
return module.exports;
|
||||
};
|
||||
})(this);
|
||||
|
||||
exports = module.exports = function(args) {
|
||||
_this.log = args.logger;
|
||||
return module.exports;
|
||||
};
|
||||
|
||||
/*
|
||||
Try to run a JS module from a string, together with the
|
||||
|
|
@ -42,44 +44,45 @@ Dynamic Modules
|
|||
@param {String} id
|
||||
@param {Object} params
|
||||
@param {String} lang
|
||||
*/
|
||||
*/
|
||||
|
||||
|
||||
exports.compileString = function(src, id, params, lang) {
|
||||
var answ, err, ret, sandbox;
|
||||
answ = {
|
||||
code: 200,
|
||||
message: 'Successfully compiled'
|
||||
};
|
||||
if (lang === '0') {
|
||||
exports.compileString = (function(_this) {
|
||||
return function(src, id, params, lang) {
|
||||
var answ, err, ret, sandbox;
|
||||
answ = {
|
||||
code: 200,
|
||||
message: 'Successfully compiled'
|
||||
};
|
||||
if (lang === '0') {
|
||||
try {
|
||||
src = cs.compile(src);
|
||||
} catch (_error) {
|
||||
err = _error;
|
||||
answ.code = 400;
|
||||
answ.message = 'Compilation of CoffeeScript failed at line ' + err.location.first_line;
|
||||
}
|
||||
}
|
||||
sandbox = {
|
||||
id: id,
|
||||
params: params,
|
||||
needle: needle,
|
||||
log: console.log,
|
||||
exports: {}
|
||||
};
|
||||
try {
|
||||
src = cs.compile(src);
|
||||
vm.runInNewContext(src, sandbox, id + '.vm');
|
||||
} catch (_error) {
|
||||
err = _error;
|
||||
console.log(err);
|
||||
answ.code = 400;
|
||||
answ.message = 'Compilation of CoffeeScript failed at line ' + err.location.first_line;
|
||||
answ.message = 'Loading Module failed: ' + err.message;
|
||||
}
|
||||
}
|
||||
sandbox = {
|
||||
id: id,
|
||||
params: params,
|
||||
needle: needle,
|
||||
log: console.log,
|
||||
exports: {}
|
||||
ret = {
|
||||
answ: answ,
|
||||
module: sandbox.exports
|
||||
};
|
||||
return ret;
|
||||
};
|
||||
try {
|
||||
vm.runInNewContext(src, sandbox, id + '.vm');
|
||||
} catch (_error) {
|
||||
err = _error;
|
||||
console.log(err);
|
||||
answ.code = 400;
|
||||
answ.message = 'Loading Module failed: ' + err.message;
|
||||
}
|
||||
ret = {
|
||||
answ: answ,
|
||||
module: sandbox.exports
|
||||
};
|
||||
return ret;
|
||||
};
|
||||
})(this);
|
||||
|
||||
}).call(this);
|
||||
|
|
|
|||
|
|
@ -1,4 +1,5 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
|
||||
/*
|
||||
|
||||
HTTP Listener
|
||||
|
|
@ -6,12 +7,10 @@ HTTP Listener
|
|||
> Receives the HTTP requests to the server at the given port. The requests
|
||||
> (bound to a method) are then redirected to the appropriate handler which
|
||||
> takes care of the request.
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
(function() {
|
||||
var app, exports, express, initRouting, path, qs, requestHandler,
|
||||
_this = this;
|
||||
var app, exports, express, initRouting, path, qs, requestHandler;
|
||||
|
||||
requestHandler = require('./request-handler');
|
||||
|
||||
|
|
@ -23,73 +22,77 @@ HTTP Listener
|
|||
|
||||
app = express();
|
||||
|
||||
|
||||
/*
|
||||
Module call
|
||||
-----------
|
||||
Initializes the HTTP listener and its request handler.
|
||||
|
||||
@param {Object} args
|
||||
*/
|
||||
*/
|
||||
|
||||
exports = module.exports = (function(_this) {
|
||||
return function(args) {
|
||||
_this.log = args.logger;
|
||||
_this.shutDownSystem = args['shutdown-function'];
|
||||
requestHandler(args);
|
||||
initRouting(args['http-port']);
|
||||
return module.exports;
|
||||
};
|
||||
})(this);
|
||||
|
||||
exports = module.exports = function(args) {
|
||||
_this.log = args.logger;
|
||||
_this.shutDownSystem = args['shutdown-function'];
|
||||
requestHandler(args);
|
||||
initRouting(args['http-port']);
|
||||
return module.exports;
|
||||
};
|
||||
|
||||
/*
|
||||
Initializes the request routing and starts listening on the given port.
|
||||
|
||||
@param {int} port
|
||||
@private initRouting( *fShutDown* )
|
||||
*/
|
||||
*/
|
||||
|
||||
initRouting = (function(_this) {
|
||||
return function(port) {
|
||||
var server, sess_sec;
|
||||
app.use(express.cookieParser());
|
||||
sess_sec = "149u*y8C:@kmN/520Gt\\v'+KFBnQ!\\r<>5X/xRI`sT<Iw";
|
||||
app.use(express.session({
|
||||
secret: sess_sec
|
||||
}));
|
||||
_this.log.info('HL | no session backbone');
|
||||
app.use('/', express["static"](path.resolve(__dirname, '..', 'webpages', 'public')));
|
||||
app.get('/admin', requestHandler.handleAdmin);
|
||||
app.get('/forge', requestHandler.handleForge);
|
||||
app.post('/event', requestHandler.handleEvent);
|
||||
app.post('/login', requestHandler.handleLogin);
|
||||
app.post('/logout', requestHandler.handleLogout);
|
||||
app.post('/usercommand', requestHandler.handleUserCommand);
|
||||
app.post('/admincommand', requestHandler.handleAdminCommand);
|
||||
server = app.listen(parseInt(port) || 8111);
|
||||
server.on('listening', function() {
|
||||
var addr;
|
||||
addr = server.address();
|
||||
if (addr.port !== port) {
|
||||
return _this.shutDownSystem();
|
||||
}
|
||||
});
|
||||
return server.on('error', function(err) {
|
||||
|
||||
initRouting = function(port) {
|
||||
var server, sess_sec;
|
||||
app.use(express.cookieParser());
|
||||
sess_sec = "149u*y8C:@kmN/520Gt\\v'+KFBnQ!\\r<>5X/xRI`sT<Iw";
|
||||
app.use(express.session({
|
||||
secret: sess_sec
|
||||
}));
|
||||
_this.log.info('HL | no session backbone');
|
||||
app.use('/', express["static"](path.resolve(__dirname, '..', 'webpages', 'public')));
|
||||
app.get('/admin', requestHandler.handleAdmin);
|
||||
app.get('/forge', requestHandler.handleForge);
|
||||
app.post('/event', requestHandler.handleEvent);
|
||||
app.post('/login', requestHandler.handleLogin);
|
||||
app.post('/logout', requestHandler.handleLogout);
|
||||
app.post('/usercommand', requestHandler.handleUserCommand);
|
||||
app.post('/admincommand', requestHandler.handleAdminCommand);
|
||||
server = app.listen(parseInt(port) || 8111);
|
||||
server.on('listening', function() {
|
||||
var addr;
|
||||
addr = server.address();
|
||||
if (addr.port !== port) {
|
||||
/*
|
||||
Error handling of the express port listener requires special attention,
|
||||
thus we have to catch the error, which is issued if the port is already in use.
|
||||
*/
|
||||
switch (err.errno) {
|
||||
case 'EADDRINUSE':
|
||||
_this.log.error(err, 'HL | http-port already in use, shutting down!');
|
||||
break;
|
||||
case 'EACCES':
|
||||
_this.log.error(err, 'HL | http-port not accessible, shutting down!');
|
||||
break;
|
||||
default:
|
||||
_this.log.error(err, 'HL | Error in server, shutting down!');
|
||||
}
|
||||
return _this.shutDownSystem();
|
||||
}
|
||||
});
|
||||
return server.on('error', function(err) {
|
||||
/*
|
||||
Error handling of the express port listener requires special attention,
|
||||
thus we have to catch the error, which is issued if the port is already in use.
|
||||
*/
|
||||
|
||||
switch (err.errno) {
|
||||
case 'EADDRINUSE':
|
||||
_this.log.error(err, 'HL | http-port already in use, shutting down!');
|
||||
break;
|
||||
case 'EACCES':
|
||||
_this.log.error(err, 'HL | http-port not accessible, shutting down!');
|
||||
break;
|
||||
default:
|
||||
_this.log.error(err, 'HL | Error in server, shutting down!');
|
||||
}
|
||||
return _this.shutDownSystem();
|
||||
});
|
||||
};
|
||||
});
|
||||
};
|
||||
})(this);
|
||||
|
||||
}).call(this);
|
||||
|
|
|
|||
|
|
@ -1,7 +1,6 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var bunyan, fs, path,
|
||||
_this = this;
|
||||
var bunyan, fs, path;
|
||||
|
||||
fs = require('fs');
|
||||
|
||||
|
|
@ -9,64 +8,66 @@
|
|||
|
||||
bunyan = require('bunyan');
|
||||
|
||||
|
||||
/*
|
||||
Returns a bunyan logger according to the given arguments.
|
||||
|
||||
@public getLogger( *args* )
|
||||
@param {Object} args
|
||||
*/
|
||||
*/
|
||||
|
||||
|
||||
exports.getLogger = function(args) {
|
||||
var e, emptylog, opt;
|
||||
emptylog = {
|
||||
trace: function() {},
|
||||
debug: function() {},
|
||||
info: function() {},
|
||||
warn: function() {},
|
||||
error: function() {},
|
||||
fatal: function() {}
|
||||
};
|
||||
args = args != null ? args : {};
|
||||
if (args.nolog) {
|
||||
return emptylog;
|
||||
} else {
|
||||
try {
|
||||
opt = {
|
||||
name: "webapi-eca"
|
||||
};
|
||||
if (args['mode'] === 'development') {
|
||||
opt.src = true;
|
||||
}
|
||||
if (args['file-path']) {
|
||||
_this.logPath = path.resolve(args['file-path']);
|
||||
} else {
|
||||
_this.logPath = path.resolve(__dirname, '..', 'logs', 'server.log');
|
||||
}
|
||||
exports.getLogger = (function(_this) {
|
||||
return function(args) {
|
||||
var e, emptylog, opt;
|
||||
emptylog = {
|
||||
trace: function() {},
|
||||
debug: function() {},
|
||||
info: function() {},
|
||||
warn: function() {},
|
||||
error: function() {},
|
||||
fatal: function() {}
|
||||
};
|
||||
args = args != null ? args : {};
|
||||
if (args.nolog) {
|
||||
return emptylog;
|
||||
} else {
|
||||
try {
|
||||
fs.writeFileSync(_this.logPath + '.temp', 'temp');
|
||||
fs.unlinkSync(_this.logPath + '.temp');
|
||||
opt = {
|
||||
name: "webapi-eca"
|
||||
};
|
||||
if (args['mode'] === 'development') {
|
||||
opt.src = true;
|
||||
}
|
||||
if (args['file-path']) {
|
||||
_this.logPath = path.resolve(args['file-path']);
|
||||
} else {
|
||||
_this.logPath = path.resolve(__dirname, '..', 'logs', 'server.log');
|
||||
}
|
||||
try {
|
||||
fs.writeFileSync(_this.logPath + '.temp', 'temp');
|
||||
fs.unlinkSync(_this.logPath + '.temp');
|
||||
} catch (_error) {
|
||||
e = _error;
|
||||
console.error("Log folder '" + _this.logPath + "' is not writable");
|
||||
return emptylog;
|
||||
}
|
||||
opt.streams = [
|
||||
{
|
||||
level: args['io-level'],
|
||||
stream: process.stdout
|
||||
}, {
|
||||
level: args['file-level'],
|
||||
path: _this.logPath
|
||||
}
|
||||
];
|
||||
return bunyan.createLogger(opt);
|
||||
} catch (_error) {
|
||||
e = _error;
|
||||
console.error("Log folder '" + _this.logPath + "' is not writable");
|
||||
console.error(e);
|
||||
return emptylog;
|
||||
}
|
||||
opt.streams = [
|
||||
{
|
||||
level: args['io-level'],
|
||||
stream: process.stdout
|
||||
}, {
|
||||
level: args['file-level'],
|
||||
path: _this.logPath
|
||||
}
|
||||
];
|
||||
return bunyan.createLogger(opt);
|
||||
} catch (_error) {
|
||||
e = _error;
|
||||
console.error(e);
|
||||
return emptylog;
|
||||
}
|
||||
}
|
||||
};
|
||||
};
|
||||
})(this);
|
||||
|
||||
}).call(this);
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load diff
|
|
@ -1,4 +1,5 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
|
||||
/*
|
||||
|
||||
Request Handler
|
||||
|
|
@ -7,12 +8,10 @@ Request Handler
|
|||
> the [HTTP Listener](http-listener.html). It will handle user requests for
|
||||
> pages as well as POST requests such as user login, module storing, event
|
||||
> invocation and also admin commands.
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
(function() {
|
||||
var crypto, db, dirHandlers, exports, fs, getHandlerPath, getRemoteScripts, getScript, getTemplate, mustache, path, qs, renderPage,
|
||||
_this = this;
|
||||
var crypto, db, dirHandlers, exports, fs, getHandlerPath, getRemoteScripts, getScript, getTemplate, mustache, path, qs, renderPage;
|
||||
|
||||
db = require('./persistence');
|
||||
|
||||
|
|
@ -28,29 +27,32 @@ Request Handler
|
|||
|
||||
dirHandlers = path.resolve(__dirname, '..', 'webpages', 'handlers');
|
||||
|
||||
exports = module.exports = function(args) {
|
||||
var user, users, _i, _len;
|
||||
_this.log = args.logger;
|
||||
_this.userRequestHandler = args['request-service'];
|
||||
_this.objAdminCmds = {
|
||||
shutdown: function(obj, cb) {
|
||||
var data;
|
||||
data = {
|
||||
code: 200,
|
||||
message: 'Shutting down... BYE!'
|
||||
};
|
||||
setTimeout(args['shutdown-function'], 500);
|
||||
return cb(null, data);
|
||||
exports = module.exports = (function(_this) {
|
||||
return function(args) {
|
||||
var user, users, _i, _len;
|
||||
_this.log = args.logger;
|
||||
_this.userRequestHandler = args['request-service'];
|
||||
_this.objAdminCmds = {
|
||||
shutdown: function(obj, cb) {
|
||||
var data;
|
||||
data = {
|
||||
code: 200,
|
||||
message: 'Shutting down... BYE!'
|
||||
};
|
||||
setTimeout(args['shutdown-function'], 500);
|
||||
return cb(null, data);
|
||||
}
|
||||
};
|
||||
db(args);
|
||||
users = JSON.parse(fs.readFileSync(path.resolve(__dirname, '..', 'config', 'users.json')));
|
||||
for (_i = 0, _len = users.length; _i < _len; _i++) {
|
||||
user = users[_i];
|
||||
db.storeUser(user);
|
||||
}
|
||||
return module.exports;
|
||||
};
|
||||
db(args);
|
||||
users = JSON.parse(fs.readFileSync(path.resolve(__dirname, '..', 'config', 'users.json')));
|
||||
for (_i = 0, _len = users.length; _i < _len; _i++) {
|
||||
user = users[_i];
|
||||
db.storeUser(user);
|
||||
}
|
||||
return module.exports;
|
||||
};
|
||||
})(this);
|
||||
|
||||
|
||||
/*
|
||||
Handles possible events that were posted to this server and pushes them into the
|
||||
|
|
@ -62,8 +64,7 @@ Request Handler
|
|||
objects.*
|
||||
|
||||
@public handleEvent( *req, resp* )
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.handleEvent = function(req, resp) {
|
||||
var body;
|
||||
|
|
@ -94,6 +95,7 @@ Request Handler
|
|||
});
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Associates the user object with the session if login is successful.
|
||||
|
||||
|
|
@ -103,32 +105,34 @@ Request Handler
|
|||
objects.*
|
||||
|
||||
@public handleLogin( *req, resp* )
|
||||
*/
|
||||
*/
|
||||
|
||||
|
||||
exports.handleLogin = function(req, resp) {
|
||||
var body;
|
||||
body = '';
|
||||
req.on('data', function(data) {
|
||||
return body += data;
|
||||
});
|
||||
return req.on('end', function() {
|
||||
var obj;
|
||||
obj = qs.parse(body);
|
||||
return db.loginUser(obj.username, obj.password, function(err, usr) {
|
||||
if (err) {
|
||||
_this.log.warn("RH | AUTH-UH-OH ( " + obj.username + " ): " + err.message);
|
||||
} else {
|
||||
req.session.user = usr;
|
||||
}
|
||||
if (req.session.user) {
|
||||
return resp.send('OK!');
|
||||
} else {
|
||||
return resp.send(401, 'NO!');
|
||||
}
|
||||
exports.handleLogin = (function(_this) {
|
||||
return function(req, resp) {
|
||||
var body;
|
||||
body = '';
|
||||
req.on('data', function(data) {
|
||||
return body += data;
|
||||
});
|
||||
});
|
||||
};
|
||||
return req.on('end', function() {
|
||||
var obj;
|
||||
obj = qs.parse(body);
|
||||
return db.loginUser(obj.username, obj.password, function(err, usr) {
|
||||
if (err) {
|
||||
_this.log.warn("RH | AUTH-UH-OH ( " + obj.username + " ): " + err.message);
|
||||
} else {
|
||||
req.session.user = usr;
|
||||
}
|
||||
if (req.session.user) {
|
||||
return resp.send('OK!');
|
||||
} else {
|
||||
return resp.send(401, 'NO!');
|
||||
}
|
||||
});
|
||||
});
|
||||
};
|
||||
})(this);
|
||||
|
||||
|
||||
/*
|
||||
A post request retrieved on this handler causes the user object to be
|
||||
|
|
@ -140,8 +144,7 @@ Request Handler
|
|||
objects.*
|
||||
|
||||
@public handleLogout( *req, resp* )
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.handleLogout = function(req, resp) {
|
||||
if (req.session) {
|
||||
|
|
@ -150,25 +153,25 @@ Request Handler
|
|||
}
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Resolves the path to a handler webpage.
|
||||
|
||||
@private getHandlerPath( *name* )
|
||||
@param {String} name
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
getHandlerPath = function(name) {
|
||||
return path.join(dirHandlers, name + '.html');
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Fetches a template.
|
||||
|
||||
@private getTemplate( *name* )
|
||||
@param {String} name
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
getTemplate = function(name) {
|
||||
var pth;
|
||||
|
|
@ -176,13 +179,13 @@ Request Handler
|
|||
return fs.readFileSync(pth, 'utf8');
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Fetches a script.
|
||||
|
||||
@private getScript( *name* )
|
||||
@param {String} name
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
getScript = function(name) {
|
||||
var pth;
|
||||
|
|
@ -190,13 +193,13 @@ Request Handler
|
|||
return fs.readFileSync(pth, 'utf8');
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Fetches remote scripts snippets.
|
||||
|
||||
@private getRemoteScripts( *name* )
|
||||
@param {String} name
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
getRemoteScripts = function(name) {
|
||||
var pth;
|
||||
|
|
@ -204,6 +207,7 @@ Request Handler
|
|||
return fs.readFileSync(pth, 'utf8');
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Renders a page, with helps of mustache, depending on the user session and returns it.
|
||||
|
||||
|
|
@ -211,8 +215,7 @@ Request Handler
|
|||
@param {String} name
|
||||
@param {Object} sess
|
||||
@param {Object} msg
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
renderPage = function(name, req, resp, msg) {
|
||||
var code, content, data, err, menubar, page, pageElements, pathSkel, remote_scripts, script, skeleton;
|
||||
|
|
@ -251,6 +254,7 @@ Request Handler
|
|||
return resp.send(code, mustache.render(page, data));
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Present the desired forge page to the user.
|
||||
|
||||
|
|
@ -260,8 +264,7 @@ Request Handler
|
|||
objects.*
|
||||
|
||||
@public handleForge( *req, resp* )
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.handleForge = function(req, resp) {
|
||||
var page;
|
||||
|
|
@ -272,6 +275,7 @@ Request Handler
|
|||
return renderPage(page, req, resp);
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Handles the user command requests.
|
||||
|
||||
|
|
@ -281,27 +285,29 @@ Request Handler
|
|||
objects.*
|
||||
|
||||
@public handleUser( *req, resp* )
|
||||
*/
|
||||
*/
|
||||
|
||||
|
||||
exports.handleUserCommand = function(req, resp) {
|
||||
var body;
|
||||
if (req.session && req.session.user) {
|
||||
body = '';
|
||||
req.on('data', function(data) {
|
||||
return body += data;
|
||||
});
|
||||
return req.on('end', function() {
|
||||
var obj;
|
||||
obj = qs.parse(body);
|
||||
return _this.userRequestHandler(req.session.user, obj, function(obj) {
|
||||
return resp.send(obj.code, obj);
|
||||
exports.handleUserCommand = (function(_this) {
|
||||
return function(req, resp) {
|
||||
var body;
|
||||
if (req.session && req.session.user) {
|
||||
body = '';
|
||||
req.on('data', function(data) {
|
||||
return body += data;
|
||||
});
|
||||
});
|
||||
} else {
|
||||
return resp.send(401, 'Login first!');
|
||||
}
|
||||
};
|
||||
return req.on('end', function() {
|
||||
var obj;
|
||||
obj = qs.parse(body);
|
||||
return _this.userRequestHandler(req.session.user, obj, function(obj) {
|
||||
return resp.send(obj.code, obj);
|
||||
});
|
||||
});
|
||||
} else {
|
||||
return resp.send(401, 'Login first!');
|
||||
}
|
||||
};
|
||||
})(this);
|
||||
|
||||
|
||||
/*
|
||||
Present the admin console to the user if he's allowed to see it.
|
||||
|
|
@ -312,8 +318,7 @@ Request Handler
|
|||
objects.*
|
||||
|
||||
@public handleForge( *req, resp* )
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
exports.handleAdmin = function(req, resp) {
|
||||
var msg, page;
|
||||
|
|
@ -328,6 +333,7 @@ Request Handler
|
|||
return renderPage(page, req, resp, msg);
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
Handles the admin command requests.
|
||||
|
||||
|
|
@ -337,31 +343,32 @@ Request Handler
|
|||
objects.*
|
||||
|
||||
@public handleAdminCommand( *req, resp* )
|
||||
*/
|
||||
*/
|
||||
|
||||
|
||||
exports.handleAdminCommand = function(req, resp) {
|
||||
var body;
|
||||
if (req.session && req.session.user && req.session.user.isAdmin === "true") {
|
||||
body = '';
|
||||
req.on('data', function(data) {
|
||||
return body += data;
|
||||
});
|
||||
return req.on('end', function() {
|
||||
var obj;
|
||||
obj = qs.parse(body);
|
||||
_this.log.info('RH | Received admin request: ' + obj.command);
|
||||
if (obj.command && _this.objAdminCmds[obj.command]) {
|
||||
return _this.objAdminCmds[obj.command](obj, function(err, obj) {
|
||||
return resp.send(obj.code, obj);
|
||||
});
|
||||
} else {
|
||||
return resp.send(404, 'Command unknown!');
|
||||
}
|
||||
});
|
||||
} else {
|
||||
return resp.send(401, 'You need to be logged in as admin!');
|
||||
}
|
||||
};
|
||||
exports.handleAdminCommand = (function(_this) {
|
||||
return function(req, resp) {
|
||||
var body;
|
||||
if (req.session && req.session.user && req.session.user.isAdmin === "true") {
|
||||
body = '';
|
||||
req.on('data', function(data) {
|
||||
return body += data;
|
||||
});
|
||||
return req.on('end', function() {
|
||||
var obj;
|
||||
obj = qs.parse(body);
|
||||
_this.log.info('RH | Received admin request: ' + obj.command);
|
||||
if (obj.command && _this.objAdminCmds[obj.command]) {
|
||||
return _this.objAdminCmds[obj.command](obj, function(err, obj) {
|
||||
return resp.send(obj.code, obj);
|
||||
});
|
||||
} else {
|
||||
return resp.send(404, 'Command unknown!');
|
||||
}
|
||||
});
|
||||
} else {
|
||||
return resp.send(401, 'You need to be logged in as admin!');
|
||||
}
|
||||
};
|
||||
})(this);
|
||||
|
||||
}).call(this);
|
||||
|
|
|
|||
|
|
@ -1,4 +1,5 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
|
||||
/*
|
||||
|
||||
WebAPI-ECA Engine
|
||||
|
|
@ -9,12 +10,10 @@ WebAPI-ECA Engine
|
|||
> node webapi-eca [opt]
|
||||
>
|
||||
> See below in the optimist CLI preparation for allowed optional parameters `[opt]`.
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
(function() {
|
||||
var argv, cm, conf, cp, db, engine, fs, http, init, logger, nameEP, opt, optimist, path, procCmds, shutDown, usage,
|
||||
_this = this;
|
||||
var argv, cm, conf, cp, db, engine, fs, http, init, logger, nameEP, opt, optimist, path, procCmds, shutDown, usage;
|
||||
|
||||
logger = require('./logging');
|
||||
|
||||
|
|
@ -40,10 +39,10 @@ WebAPI-ECA Engine
|
|||
|
||||
procCmds = {};
|
||||
|
||||
|
||||
/*
|
||||
Let's prepare the optimist CLI optional arguments `[opt]`:
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
usage = 'This runs your webapi-based ECA engine';
|
||||
|
||||
|
|
@ -93,113 +92,117 @@ WebAPI-ECA Engine
|
|||
process.exit();
|
||||
}
|
||||
|
||||
|
||||
/*
|
||||
This function is invoked right after the module is loaded and starts the server.
|
||||
|
||||
@private init()
|
||||
*/
|
||||
*/
|
||||
|
||||
|
||||
init = function() {
|
||||
var args, logconf;
|
||||
conf(argv.c);
|
||||
if (!conf.isReady()) {
|
||||
console.error('FAIL: Config file not ready! Shutting down...');
|
||||
process.exit();
|
||||
}
|
||||
logconf = conf.getLogConf();
|
||||
if (argv.m) {
|
||||
logconf['mode'] = argv.m;
|
||||
}
|
||||
if (argv.i) {
|
||||
logconf['io-level'] = argv.i;
|
||||
}
|
||||
if (argv.f) {
|
||||
logconf['file-level'] = argv.f;
|
||||
}
|
||||
if (argv.p) {
|
||||
logconf['file-path'] = argv.p;
|
||||
}
|
||||
if (argv.n) {
|
||||
logconf['nolog'] = argv.n;
|
||||
}
|
||||
try {
|
||||
fs.unlinkSync(path.resolve(__dirname, '..', 'logs', logconf['file-path']));
|
||||
} catch (_error) {}
|
||||
_this.log = logger.getLogger(logconf);
|
||||
_this.log.info('RS | STARTING SERVER');
|
||||
args = {
|
||||
logger: _this.log,
|
||||
logconf: logconf
|
||||
};
|
||||
args['http-port'] = parseInt(argv.w || conf.getHttpPort());
|
||||
args['db-port'] = parseInt(argv.d || conf.getDbPort());
|
||||
_this.log.info('RS | Initialzing DB');
|
||||
db(args);
|
||||
return db.isConnected(function(err) {
|
||||
var cliArgs, poller;
|
||||
if (err) {
|
||||
_this.log.error('RS | No DB connection, shutting down system!');
|
||||
return shutDown();
|
||||
} else {
|
||||
_this.log.info('RS | Initialzing engine');
|
||||
engine(args);
|
||||
_this.log.info('RS | Forking a child process for the event poller');
|
||||
cliArgs = [args.logconf['mode'], args.logconf['io-level'], args.logconf['file-level'], args.logconf['file-path'], args.logconf['nolog']];
|
||||
poller = cp.fork(path.resolve(__dirname, nameEP), cliArgs);
|
||||
_this.log.info('RS | Initialzing module manager');
|
||||
cm(args);
|
||||
cm.addListener('init', function(evt) {
|
||||
return poller.send({
|
||||
event: 'init',
|
||||
data: evt
|
||||
});
|
||||
});
|
||||
cm.addListener('newRule', function(evt) {
|
||||
return poller.send({
|
||||
event: 'newRule',
|
||||
data: evt
|
||||
});
|
||||
});
|
||||
cm.addListener('init', function(evt) {
|
||||
return engine.internalEvent('init', evt);
|
||||
});
|
||||
cm.addListener('newRule', function(evt) {
|
||||
return engine.internalEvent('newRule', evt);
|
||||
});
|
||||
_this.log.info('RS | Initialzing http listener');
|
||||
args['request-service'] = cm.processRequest;
|
||||
args['shutdown-function'] = shutDown;
|
||||
return http(args);
|
||||
init = (function(_this) {
|
||||
return function() {
|
||||
var args, logconf;
|
||||
conf(argv.c);
|
||||
if (!conf.isReady()) {
|
||||
console.error('FAIL: Config file not ready! Shutting down...');
|
||||
process.exit();
|
||||
}
|
||||
});
|
||||
};
|
||||
logconf = conf.getLogConf();
|
||||
if (argv.m) {
|
||||
logconf['mode'] = argv.m;
|
||||
}
|
||||
if (argv.i) {
|
||||
logconf['io-level'] = argv.i;
|
||||
}
|
||||
if (argv.f) {
|
||||
logconf['file-level'] = argv.f;
|
||||
}
|
||||
if (argv.p) {
|
||||
logconf['file-path'] = argv.p;
|
||||
}
|
||||
if (argv.n) {
|
||||
logconf['nolog'] = argv.n;
|
||||
}
|
||||
try {
|
||||
fs.unlinkSync(path.resolve(__dirname, '..', 'logs', logconf['file-path']));
|
||||
} catch (_error) {}
|
||||
_this.log = logger.getLogger(logconf);
|
||||
_this.log.info('RS | STARTING SERVER');
|
||||
args = {
|
||||
logger: _this.log,
|
||||
logconf: logconf
|
||||
};
|
||||
args['http-port'] = parseInt(argv.w || conf.getHttpPort());
|
||||
args['db-port'] = parseInt(argv.d || conf.getDbPort());
|
||||
_this.log.info('RS | Initialzing DB');
|
||||
db(args);
|
||||
return db.isConnected(function(err) {
|
||||
var cliArgs, poller;
|
||||
if (err) {
|
||||
_this.log.error('RS | No DB connection, shutting down system!');
|
||||
return shutDown();
|
||||
} else {
|
||||
_this.log.info('RS | Initialzing engine');
|
||||
engine(args);
|
||||
_this.log.info('RS | Forking a child process for the event poller');
|
||||
cliArgs = [args.logconf['mode'], args.logconf['io-level'], args.logconf['file-level'], args.logconf['file-path'], args.logconf['nolog']];
|
||||
poller = cp.fork(path.resolve(__dirname, nameEP), cliArgs);
|
||||
_this.log.info('RS | Initialzing module manager');
|
||||
cm(args);
|
||||
cm.addListener('init', function(evt) {
|
||||
return poller.send({
|
||||
event: 'init',
|
||||
data: evt
|
||||
});
|
||||
});
|
||||
cm.addListener('newRule', function(evt) {
|
||||
return poller.send({
|
||||
event: 'newRule',
|
||||
data: evt
|
||||
});
|
||||
});
|
||||
cm.addListener('init', function(evt) {
|
||||
return engine.internalEvent('init', evt);
|
||||
});
|
||||
cm.addListener('newRule', function(evt) {
|
||||
return engine.internalEvent('newRule', evt);
|
||||
});
|
||||
_this.log.info('RS | Initialzing http listener');
|
||||
args['request-service'] = cm.processRequest;
|
||||
args['shutdown-function'] = shutDown;
|
||||
return http(args);
|
||||
}
|
||||
});
|
||||
};
|
||||
})(this);
|
||||
|
||||
|
||||
/*
|
||||
Shuts down the server.
|
||||
|
||||
@private shutDown()
|
||||
*/
|
||||
*/
|
||||
|
||||
shutDown = (function(_this) {
|
||||
return function() {
|
||||
_this.log.warn('RS | Received shut down command!');
|
||||
if (db != null) {
|
||||
db.shutDown();
|
||||
}
|
||||
if (engine != null) {
|
||||
engine.shutDown();
|
||||
}
|
||||
return process.exit();
|
||||
};
|
||||
})(this);
|
||||
|
||||
shutDown = function() {
|
||||
_this.log.warn('RS | Received shut down command!');
|
||||
if (db != null) {
|
||||
db.shutDown();
|
||||
}
|
||||
if (engine != null) {
|
||||
engine.shutDown();
|
||||
}
|
||||
return process.exit();
|
||||
};
|
||||
|
||||
/*
|
||||
## Process Commands
|
||||
*# Process Commands
|
||||
|
||||
When the server is run as a child process, this function handles messages
|
||||
from the parent process (e.g. the testing suite)
|
||||
*/
|
||||
|
||||
*/
|
||||
|
||||
process.on('message', function(cmd) {
|
||||
return typeof procCmds[cmd] === "function" ? procCmds[cmd]() : void 0;
|
||||
|
|
|
|||
|
|
@ -19,7 +19,7 @@ exports.testParameters = ( test ) =>
|
|||
'mode'
|
||||
'io-level'
|
||||
'file-level'
|
||||
'file-path'
|
||||
# 'file-path'
|
||||
]
|
||||
test.expect 3 + reqProp.length
|
||||
test.ok @conf.getHttpPort(), 'HTTP port does not exist!'
|
||||
|
|
|
|||
|
|
@ -3,7 +3,7 @@ exports.setUp = ( cb ) =>
|
|||
@path = require 'path'
|
||||
logger = require @path.join '..', 'js-coffee', 'logging'
|
||||
@log = logger.getLogger
|
||||
nolog: true
|
||||
nolog: true
|
||||
@db = require @path.join '..', 'js-coffee', 'persistence'
|
||||
opts =
|
||||
logger: @log
|
||||
|
|
@ -140,6 +140,7 @@ exports.EventQueue =
|
|||
###
|
||||
exports.ActionInvoker =
|
||||
setUp: ( cb ) =>
|
||||
@userId = 'tester1'
|
||||
@action1id = 'test-action-invoker_1'
|
||||
@action2id = 'test-action-invoker_2'
|
||||
@action1 =
|
||||
|
|
@ -158,13 +159,13 @@ exports.ActionInvoker =
|
|||
testCreateAndRead: ( test ) =>
|
||||
test.expect 3
|
||||
# store an entry to start with
|
||||
@db.storeActionInvoker @action1id, @action1
|
||||
@db.storeActionInvoker @action1id, @userId, @action1
|
||||
|
||||
# test that the ID shows up in the set
|
||||
@db.getActionInvokerIds ( err , obj ) =>
|
||||
test.ok @action1id in obj,
|
||||
'Expected key not in action-invokers set'
|
||||
|
||||
|
||||
# the retrieved object really is the one we expected
|
||||
@db.getActionInvoker @action1id, ( err , obj ) =>
|
||||
test.deepEqual obj, @action1,
|
||||
|
|
@ -180,8 +181,8 @@ exports.ActionInvoker =
|
|||
test.expect 2
|
||||
|
||||
# store an entry to start with
|
||||
@db.storeActionInvoker @action1id, @action1
|
||||
@db.storeActionInvoker @action1id, @action2
|
||||
@db.storeActionInvoker @action1id, @userId, @action1
|
||||
@db.storeActionInvoker @action1id, @userId, @action2
|
||||
|
||||
# the retrieved object really is the one we expected
|
||||
@db.getActionInvoker @action1id, ( err , obj ) =>
|
||||
|
|
@ -198,7 +199,7 @@ exports.ActionInvoker =
|
|||
test.expect 2
|
||||
|
||||
# store an entry to start with
|
||||
@db.storeActionInvoker @action1id, @action1
|
||||
@db.storeActionInvoker @action1id, @userId, @action1
|
||||
|
||||
# Ensure the action invoker has been deleted
|
||||
@db.deleteActionInvoker @action1id
|
||||
|
|
@ -227,8 +228,8 @@ exports.ActionInvoker =
|
|||
"Invoker #{ modname } does not equal the expected one"
|
||||
forkEnds()
|
||||
|
||||
@db.storeActionInvoker @action1id, @action1
|
||||
@db.storeActionInvoker @action2id, @action2
|
||||
@db.storeActionInvoker @action1id, @userId, @action1
|
||||
@db.storeActionInvoker @action2id, @userId, @action2
|
||||
@db.getActionInvokerIds ( err, obj ) =>
|
||||
test.ok @action1id in obj and @action2id in obj,
|
||||
'Not all action invoker Ids in set'
|
||||
|
|
@ -309,6 +310,7 @@ exports.ActionInvokerParams =
|
|||
###
|
||||
exports.EventPoller =
|
||||
setUp: ( cb ) =>
|
||||
@userId = 'tester1'
|
||||
@event1id = 'test-event-poller_1'
|
||||
@event2id = 'test-event-poller_2'
|
||||
@event1 =
|
||||
|
|
@ -327,7 +329,7 @@ exports.EventPoller =
|
|||
testCreateAndRead: ( test ) =>
|
||||
test.expect 3
|
||||
# store an entry to start with
|
||||
@db.storeEventPoller @event1id, @event1
|
||||
@db.storeEventPoller @event1id, @userId, @event1
|
||||
|
||||
# test that the ID shows up in the set
|
||||
@db.getEventPollerIds ( err , obj ) =>
|
||||
|
|
@ -349,8 +351,8 @@ exports.EventPoller =
|
|||
test.expect 2
|
||||
|
||||
# store an entry to start with
|
||||
@db.storeEventPoller @event1id, @event1
|
||||
@db.storeEventPoller @event1id, @event2
|
||||
@db.storeEventPoller @event1id, @userId, @event1
|
||||
@db.storeEventPoller @event1id, @userId, @event2
|
||||
|
||||
# the retrieved object really is the one we expected
|
||||
@db.getEventPoller @event1id, ( err , obj ) =>
|
||||
|
|
@ -367,7 +369,7 @@ exports.EventPoller =
|
|||
test.expect 2
|
||||
|
||||
# store an entry to start with
|
||||
@db.storeEventPoller @event1id, @event1
|
||||
@db.storeEventPoller @event1id, @userId, @event1
|
||||
|
||||
# Ensure the event poller has been deleted
|
||||
@db.deleteEventPoller @event1id
|
||||
|
|
@ -396,8 +398,8 @@ exports.EventPoller =
|
|||
"Invoker #{ modname } does not equal the expected one"
|
||||
forkEnds()
|
||||
|
||||
@db.storeEventPoller @event1id, @event1
|
||||
@db.storeEventPoller @event2id, @event2
|
||||
@db.storeEventPoller @event1id, @userId, @event1
|
||||
@db.storeEventPoller @event2id, @userId, @event2
|
||||
@db.getEventPollerIds ( err, obj ) =>
|
||||
test.ok @event1id in obj and @event2id in obj,
|
||||
'Not all event poller Ids in set'
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var fOnLoad;
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var fOnLoad;
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var fOnLoad;
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var fOnLoad;
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var fOnLoad;
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var fOnLoad;
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
// Generated by CoffeeScript 1.6.3
|
||||
// Generated by CoffeeScript 1.7.1
|
||||
(function() {
|
||||
var fOnLoad;
|
||||
|
||||
|
|
|
|||
Loading…
Reference in a new issue