mirror of
https://github.com/Hopiu/webapi-eca.git
synced 2026-03-16 22:10:31 +00:00
628 lines
19 KiB
JavaScript
628 lines
19 KiB
JavaScript
// Generated by CoffeeScript 1.7.1
|
|
|
|
/*
|
|
|
|
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, encryption, eventEmitter, events, exports, forgeModule, fs, getModuleParams, getModuleUserArguments, getModuleUserParams, getModules, hasRequiredParams, path, storeModule, storeRule;
|
|
|
|
db = require('./persistence');
|
|
|
|
dynmod = require('./dynamic-modules');
|
|
|
|
encryption = require('./encryption');
|
|
|
|
fs = require('fs');
|
|
|
|
path = require('path');
|
|
|
|
events = require('events');
|
|
|
|
eventEmitter = new events.EventEmitter();
|
|
|
|
|
|
/*
|
|
Module call
|
|
-----------
|
|
Initializes the Components Manager and constructs a new Event Emitter.
|
|
|
|
@param {Object} args
|
|
*/
|
|
|
|
exports = module.exports = (function(_this) {
|
|
return function(args) {
|
|
_this.log = args.logger;
|
|
db(args);
|
|
dynmod(args);
|
|
return module.exports;
|
|
};
|
|
})(this);
|
|
|
|
|
|
/*
|
|
Add an event handler (eh) that listens for rules.
|
|
|
|
@public addRuleListener ( *eh* )
|
|
@param {function} eh
|
|
*/
|
|
|
|
exports.addRuleListener = (function(_this) {
|
|
return function(eh) {
|
|
eventEmitter.addListener('rule', eh);
|
|
return db.getAllActivatedRuleIdsPerUser(function(err, objUsers) {
|
|
var fGoThroughUsers, rules, user, _results;
|
|
fGoThroughUsers = function(user, rules) {
|
|
var fFetchRule, rule, _i, _len, _results;
|
|
fFetchRule = function(userName) {
|
|
return function(rule) {
|
|
return db.getRule(rule, function(err, strRule) {
|
|
var eventInfo, oRule;
|
|
try {
|
|
oRule = JSON.parse(strRule);
|
|
db.resetLog(userName, oRule.id);
|
|
eventInfo = '';
|
|
if (oRule.event_start) {
|
|
eventInfo = "Starting at " + (new Date(oRule.event_start)) + ", Interval set to " + oRule.event_interval + " minutes";
|
|
}
|
|
db.appendLog(userName, oRule.id, "INIT", "Rule '" + oRule.id + "' initialized. " + eventInfo);
|
|
return eventEmitter.emit('rule', {
|
|
event: 'init',
|
|
user: userName,
|
|
rule: oRule
|
|
});
|
|
} catch (_error) {
|
|
err = _error;
|
|
return _this.log.warn("CM | There's an invalid rule in the system: " + strRule);
|
|
}
|
|
});
|
|
};
|
|
};
|
|
_results = [];
|
|
for (_i = 0, _len = rules.length; _i < _len; _i++) {
|
|
rule = rules[_i];
|
|
_results.push(fFetchRule(user)(rule));
|
|
}
|
|
return _results;
|
|
};
|
|
_results = [];
|
|
for (user in objUsers) {
|
|
rules = objUsers[user];
|
|
_results.push(fGoThroughUsers(user, rules));
|
|
}
|
|
return _results;
|
|
});
|
|
};
|
|
})(this);
|
|
|
|
|
|
/*
|
|
Processes a user request coming through the request-handler.
|
|
|
|
- `user` is the user object as it comes from the DB.
|
|
- `oReq` is the request object that contains:
|
|
|
|
- `command` as a string
|
|
- `body` an optional stringified JSON object
|
|
The callback function `callback( obj )` will receive an object
|
|
containing the HTTP response code and a corresponding message.
|
|
|
|
@public processRequest ( *user, oReq, callback* )
|
|
*/
|
|
|
|
exports.processRequest = function(user, oReq, callback) {
|
|
var dat, err;
|
|
if (!oReq.body) {
|
|
oReq.body = '{}';
|
|
}
|
|
try {
|
|
dat = JSON.parse(oReq.body);
|
|
} catch (_error) {
|
|
err = _error;
|
|
return callback({
|
|
code: 404,
|
|
message: 'You had a strange body in your request!'
|
|
});
|
|
}
|
|
if (commandFunctions[oReq.command]) {
|
|
return commandFunctions[oReq.command](user, dat, callback);
|
|
} else {
|
|
return callback({
|
|
code: 404,
|
|
message: 'What do you want from me?'
|
|
});
|
|
}
|
|
};
|
|
|
|
|
|
/*
|
|
Checks whether all required parameters are present in the body.
|
|
|
|
@private hasRequiredParams ( *arrParams, oBody* )
|
|
@param {Array} arrParams
|
|
@param {Object} oBody
|
|
*/
|
|
|
|
hasRequiredParams = function(arrParams, oBody) {
|
|
var answ, param, _i, _len;
|
|
answ = {
|
|
code: 400,
|
|
message: "Your request didn't contain all necessary fields! Requires: " + (arrParams.join())
|
|
};
|
|
for (_i = 0, _len = arrParams.length; _i < _len; _i++) {
|
|
param = arrParams[_i];
|
|
if (!oBody[param]) {
|
|
return answ;
|
|
}
|
|
}
|
|
answ.code = 200;
|
|
answ.message = 'All required properties found';
|
|
return answ;
|
|
};
|
|
|
|
|
|
/*
|
|
Fetches all available modules and return them together with the available functions.
|
|
|
|
@private getModules ( *user, oBody, dbMod, callback* )
|
|
@param {Object} user
|
|
@param {Object} oBody
|
|
@param {Object} dbMod
|
|
@param {function} callback
|
|
*/
|
|
|
|
getModules = function(user, oBody, dbMod, callback) {
|
|
var fProcessIds;
|
|
fProcessIds = function(userName) {
|
|
return function(err, arrNames) {
|
|
var answReq, fGetFunctions, id, oRes, sem, _i, _len, _results;
|
|
oRes = {};
|
|
answReq = function() {
|
|
return callback({
|
|
code: 200,
|
|
message: JSON.stringify(oRes)
|
|
});
|
|
};
|
|
sem = arrNames.length;
|
|
if (sem === 0) {
|
|
return answReq();
|
|
} else {
|
|
fGetFunctions = (function(_this) {
|
|
return function(id) {
|
|
return dbMod.getModule(userName, id, function(err, oModule) {
|
|
if (oModule) {
|
|
oRes[id] = JSON.parse(oModule.functions);
|
|
}
|
|
if (--sem === 0) {
|
|
return answReq();
|
|
}
|
|
});
|
|
};
|
|
})(this);
|
|
_results = [];
|
|
for (_i = 0, _len = arrNames.length; _i < _len; _i++) {
|
|
id = arrNames[_i];
|
|
_results.push(fGetFunctions(id));
|
|
}
|
|
return _results;
|
|
}
|
|
};
|
|
};
|
|
return dbMod.getAvailableModuleIds(user.username, fProcessIds(user.username));
|
|
};
|
|
|
|
getModuleParams = function(user, oBody, dbMod, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return dbMod.getModuleField(user.username, oBody.id, "params", function(err, oBody) {
|
|
answ.message = oBody;
|
|
return callback(answ);
|
|
});
|
|
}
|
|
};
|
|
|
|
getModuleUserParams = function(user, oBody, dbMod, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return dbMod.getUserParams(oBody.id, user.username, function(err, str) {
|
|
var name, oParam, oParams;
|
|
oParams = JSON.parse(str);
|
|
for (name in oParams) {
|
|
oParam = oParams[name];
|
|
if (!oParam.shielded) {
|
|
oParam.value = encryption.decrypt(oParam.value);
|
|
}
|
|
}
|
|
answ.message = JSON.stringify(oParams);
|
|
return callback(answ);
|
|
});
|
|
}
|
|
};
|
|
|
|
getModuleUserArguments = function(user, oBody, dbMod, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['ruleId', 'moduleId'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return dbMod.getAllModuleUserArguments(user.username, oBody.ruleId, oBody.moduleId, function(err, oBody) {
|
|
answ.message = oBody;
|
|
return callback(answ);
|
|
});
|
|
}
|
|
};
|
|
|
|
forgeModule = (function(_this) {
|
|
return function(user, oBody, modType, dbMod, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id', 'params', 'lang', 'data'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
if (oBody.overwrite) {
|
|
return storeModule(user, oBody, modType, dbMod, callback);
|
|
} else {
|
|
return dbMod.getModule(user.username, oBody.id, function(err, mod) {
|
|
if (mod) {
|
|
answ.code = 409;
|
|
answ.message = 'Module name already existing: ' + oBody.id;
|
|
return callback(answ);
|
|
} else {
|
|
return storeModule(user, oBody, modType, dbMod, callback);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
};
|
|
})(this);
|
|
|
|
storeModule = (function(_this) {
|
|
return function(user, oBody, modType, dbMod, callback) {
|
|
var src;
|
|
src = oBody.data;
|
|
return dynmod.compileString(src, user.username, {
|
|
id: 'dummyRule'
|
|
}, oBody.id, oBody.lang, modType, null, function(cm) {
|
|
var answ, funcs, id, name, _ref;
|
|
answ = cm.answ;
|
|
if (answ.code === 200) {
|
|
funcs = [];
|
|
_ref = cm.module;
|
|
for (name in _ref) {
|
|
id = _ref[name];
|
|
funcs.push(name);
|
|
}
|
|
_this.log.info("CM | Storing new module with functions " + (funcs.join(', ')));
|
|
answ.message = " Module " + oBody.id + " successfully stored! Found following function(s): " + funcs;
|
|
oBody.functions = JSON.stringify(funcs);
|
|
oBody.functionArgs = JSON.stringify(cm.funcParams);
|
|
dbMod.storeModule(user.username, oBody);
|
|
}
|
|
return callback(answ);
|
|
});
|
|
};
|
|
})(this);
|
|
|
|
storeRule = (function(_this) {
|
|
return function(user, oBody, callback) {
|
|
var args, arr, epModId, eventInfo, id, oFuncArgs, oParams, params, rule, strRule;
|
|
rule = {
|
|
id: oBody.id,
|
|
event: oBody.event,
|
|
event_start: oBody.event_start,
|
|
event_interval: oBody.event_interval,
|
|
conditions: oBody.conditions,
|
|
actions: oBody.actions
|
|
};
|
|
if (oBody.event_start) {
|
|
rule.timestamp = (new Date()).toISOString();
|
|
}
|
|
strRule = JSON.stringify(rule);
|
|
db.storeRule(rule.id, strRule);
|
|
db.linkRule(rule.id, user.username);
|
|
db.activateRule(rule.id, user.username);
|
|
if (oBody.event_params) {
|
|
epModId = rule.event.split(' -> ')[0];
|
|
db.eventPollers.storeUserParams(epModId, user.username, JSON.stringify(oBody.event_params));
|
|
}
|
|
oFuncArgs = oBody.event_functions;
|
|
for (id in oFuncArgs) {
|
|
args = oFuncArgs[id];
|
|
arr = id.split(' -> ');
|
|
db.eventPollers.storeUserArguments(user.username, rule.id, arr[0], arr[1], JSON.stringify(args));
|
|
}
|
|
oParams = oBody.action_params;
|
|
for (id in oParams) {
|
|
params = oParams[id];
|
|
db.actionInvokers.storeUserParams(id, user.username, JSON.stringify(params));
|
|
}
|
|
oFuncArgs = oBody.action_functions;
|
|
for (id in oFuncArgs) {
|
|
args = oFuncArgs[id];
|
|
arr = id.split(' -> ');
|
|
db.actionInvokers.storeUserArguments(user.username, rule.id, arr[0], arr[1], JSON.stringify(args));
|
|
}
|
|
eventInfo = '';
|
|
if (rule.event_start) {
|
|
eventInfo = "Starting at " + (new Date(rule.event_start)) + ", Interval set to " + rule.event_interval + " minutes";
|
|
}
|
|
db.resetLog(user.username, rule.id);
|
|
db.appendLog(user.username, rule.id, "INIT", "Rule '" + rule.id + "' initialized. " + eventInfo);
|
|
eventEmitter.emit('rule', {
|
|
event: 'new',
|
|
user: user.username,
|
|
rule: rule
|
|
});
|
|
return callback({
|
|
code: 200,
|
|
message: "Rule '" + rule.id + "' stored and activated!"
|
|
});
|
|
};
|
|
})(this);
|
|
|
|
commandFunctions = {
|
|
get_public_key: function(user, oBody, callback) {
|
|
return callback({
|
|
code: 200,
|
|
message: encryption.getPublicKey()
|
|
});
|
|
},
|
|
get_event_pollers: function(user, oBody, callback) {
|
|
return getModules(user, oBody, db.eventPollers, callback);
|
|
},
|
|
get_full_event_poller: function(user, oBody, callback) {
|
|
return db.eventPollers.getModule(user.username, oBody.id, function(err, obj) {
|
|
return callback({
|
|
code: 200,
|
|
message: JSON.stringify(obj)
|
|
});
|
|
});
|
|
},
|
|
get_event_poller_params: function(user, oBody, callback) {
|
|
return getModuleParams(user, oBody, db.eventPollers, callback);
|
|
},
|
|
get_event_poller_user_params: function(user, oBody, callback) {
|
|
return getModuleUserParams(user, oBody, db.eventPollers, callback);
|
|
},
|
|
get_event_poller_user_arguments: function(user, oBody, callback) {
|
|
return getModuleUserArguments(user, oBody, db.eventPollers, callback);
|
|
},
|
|
get_event_poller_function_arguments: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return db.eventPollers.getModuleField(user.username, oBody.id, 'functionArgs', function(err, obj) {
|
|
return callback({
|
|
code: 200,
|
|
message: obj
|
|
});
|
|
});
|
|
}
|
|
},
|
|
forge_event_poller: function(user, oBody, callback) {
|
|
return forgeModule(user, oBody, "eventpoller", db.eventPollers, callback);
|
|
},
|
|
delete_event_poller: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
db.eventPollers.deleteModule(user.username, oBody.id);
|
|
return callback({
|
|
code: 200,
|
|
message: 'OK!'
|
|
});
|
|
}
|
|
},
|
|
get_action_invokers: function(user, oBody, callback) {
|
|
return getModules(user, oBody, db.actionInvokers, callback);
|
|
},
|
|
get_full_action_invoker: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return db.actionInvokers.getModule(user.username, oBody.id, function(err, obj) {
|
|
return callback({
|
|
code: 200,
|
|
message: JSON.stringify(obj)
|
|
});
|
|
});
|
|
}
|
|
},
|
|
get_action_invoker_params: function(user, oBody, callback) {
|
|
return getModuleParams(user, oBody, db.actionInvokers, callback);
|
|
},
|
|
get_action_invoker_user_params: function(user, oBody, callback) {
|
|
return getModuleUserParams(user, oBody, db.actionInvokers, callback);
|
|
},
|
|
get_action_invoker_user_arguments: function(user, oBody, callback) {
|
|
return getModuleUserArguments(user, oBody, db.actionInvokers, callback);
|
|
},
|
|
get_action_invoker_function_arguments: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return db.actionInvokers.getModuleField(user.username, oBody.id, 'functionArgs', function(err, obj) {
|
|
return callback({
|
|
code: 200,
|
|
message: obj
|
|
});
|
|
});
|
|
}
|
|
},
|
|
forge_action_invoker: function(user, oBody, callback) {
|
|
return forgeModule(user, oBody, "actioninvoker", db.actionInvokers, callback);
|
|
},
|
|
delete_action_invoker: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
db.actionInvokers.deleteModule(user.username, oBody.id);
|
|
return callback({
|
|
code: 200,
|
|
message: 'OK!'
|
|
});
|
|
}
|
|
},
|
|
get_rules: function(user, oBody, callback) {
|
|
return db.getUserLinkedRules(user.username, function(err, obj) {
|
|
return callback({
|
|
code: 200,
|
|
message: obj
|
|
});
|
|
});
|
|
},
|
|
get_rule: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return db.getRule(oBody.id, function(err, obj) {
|
|
return callback({
|
|
code: 200,
|
|
message: obj
|
|
});
|
|
});
|
|
}
|
|
},
|
|
get_rule_log: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return db.getLog(user.username, oBody.id, function(err, obj) {
|
|
return callback({
|
|
code: 200,
|
|
message: obj
|
|
});
|
|
});
|
|
}
|
|
},
|
|
forge_rule: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id', 'event', 'conditions', 'actions'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
if (oBody.overwrite) {
|
|
return storeRule(user, oBody, callback);
|
|
} else {
|
|
return db.getRule(oBody.id, (function(_this) {
|
|
return function(err, mod) {
|
|
if (mod) {
|
|
answ.code = 409;
|
|
answ.message = 'Rule name already existing: ' + oBody.id;
|
|
return callback(answ);
|
|
} else {
|
|
return storeRule(user, oBody, callback);
|
|
}
|
|
};
|
|
})(this));
|
|
}
|
|
}
|
|
},
|
|
delete_rule: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['id'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
db.deleteRule(oBody.id);
|
|
eventEmitter.emit('rule', {
|
|
event: 'del',
|
|
user: user.username,
|
|
rule: null,
|
|
ruleId: oBody.id
|
|
});
|
|
return callback({
|
|
code: 200,
|
|
message: 'OK!'
|
|
});
|
|
}
|
|
},
|
|
create_webhook: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['hookname'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return db.getWebhooks((function(_this) {
|
|
return function(err, hooks) {
|
|
if (hooks.indexOf(oBody.hookname > -1)) {
|
|
answ.code = 409;
|
|
answ.message = 'Webhook already existing: ' + oBody.hookname;
|
|
return callback(answ);
|
|
} else {
|
|
db.storeWebhook(user.username, oBody.hookname);
|
|
return callback({
|
|
code: 200,
|
|
message: 'OK!'
|
|
});
|
|
}
|
|
};
|
|
})(this));
|
|
}
|
|
},
|
|
delete_webhook: function(user, oBody, callback) {
|
|
var answ;
|
|
answ = hasRequiredParams(['hookname'], oBody);
|
|
if (answ.code !== 200) {
|
|
return callback(answ);
|
|
} else {
|
|
return db.getWebhooks((function(_this) {
|
|
return function(err, hooks) {
|
|
if (hooks.indexOf(oBody.hookname === -1)) {
|
|
answ.code = 409;
|
|
answ.message = 'Webhook does not exist: ' + oBody.hookname;
|
|
return callback(answ);
|
|
} else {
|
|
db.deleteWebhook(user.username, oBody.hookname);
|
|
return callback({
|
|
code: 200,
|
|
message: 'OK!'
|
|
});
|
|
}
|
|
};
|
|
})(this));
|
|
}
|
|
},
|
|
get_webhooks: function(user, oBody, callback) {
|
|
return db.getWebhooks(user.username, function(err, data) {
|
|
if (err) {
|
|
return callback({
|
|
code: 400,
|
|
message: "We didn't like your request!"
|
|
});
|
|
} else {
|
|
return callback({
|
|
code: 200,
|
|
message: JSON.stringify(data)
|
|
});
|
|
}
|
|
});
|
|
}
|
|
};
|
|
|
|
}).call(this);
|