Hopiu/webapi-eca
1
0
Fork 0
mirror of https://github.com/Hopiu/webapi-eca.git synced 2026-03-16 22:10:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Dirty state, we need to fix the open issues, such as makeover of the rules forge and the dynamic webhooks

Browse source
This commit is contained in:
Dominic Bosch 2014-04-25 15:49:55 +02:00
parent 7ffb6d69d7
commit 9fe1c37881
26 changed files with 669 additions and 292 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

67
coffee/components-manager.coffee
View file

@ -445,40 +445,38 @@ commandFunctions =
message: 'OK!'
# WEBHOOKS
create_webhook: ( user, oBody, callback ) ->
answ = hasRequiredParams [ 'hookname' ], oBody
if answ.code isnt 200
callback answ
else
db.getWebhooks ( err, hooks ) =>
if hooks.indexOf oBody.hookname > -1
db.getUserWebhooks user.username, ( err, hooks ) =>
if hooks.indexOf( oBody.hookname ) > -1
answ.code = 409
answ.message = 'Webhook already existing: ' + oBody.hookname
callback answ
else
db.storeWebhook user.username, oBody.hookname
callback
code: 200
message: 'OK!'
db.getAllWebhookIDs ( arrHooks ) ->
genHookID = ( arrHooks ) ->
hookid = ''
for i in [0..1]
hookid += Math.random().toString( 36 ).substring 2
if arrHooks and arrHooks.indexOf( hookid ) > -1
genHookID arrHooks
else
hookid
hookid = genHookID arrHooks
db.createWebhook user.username, oBody.hookname, hookid
callback
code: 200
message: JSON.stringify
hookid: hookid
delete_webhook: ( user, oBody, callback ) ->
answ = hasRequiredParams [ 'hookname' ], oBody
if answ.code isnt 200
callback answ
else
db.getWebhooks ( err, hooks ) =>
if hooks.indexOf oBody.hookname is -1
answ.code = 409
answ.message = 'Webhook does not exist: ' + oBody.hookname
callback answ
else
db.deleteWebhook user.username, oBody.hookname
callback
code: 200
message: 'OK!'
get_webhooks: ( user, oBody, callback ) ->
db.getWebhooks user.username, ( err, data ) ->
get_all_webhooks: ( user, oBody, callback ) ->
db.getUserWebhooks user.username, ( err, data ) ->
if err
callback
code: 400
@ -488,3 +486,24 @@ commandFunctions =
code: 200
message: JSON.stringify data
delete_webhook: ( user, oBody, callback ) ->
answ = hasRequiredParams [ 'hookname' ], oBody
if answ.code isnt 200
callback answ
else
db.getUserWebhooks user.username, ( err, hooks ) =>
if hooks.indexOf( oBody.hookname ) is -1
answ.code = 409
answ.message = 'Webhook does not exist: ' + oBody.hookname
callback answ
else
db.deleteUserWebhook user.username, oBody.hookname
callback
code: 200
message: 'OK!'

4
coffee/event-poller.coffee
View file

@ -31,6 +31,10 @@ logconf[ 'file-path' ] = process.argv[ 5 ]
log = logger.getLogger logconf
log.info 'EP | Event Poller starts up'
process.on 'uncaughtException', ( err ) ->
log.error 'Probably one of the event pollers created an error in a callback function!'
log.error err
# Initialize required modules (should be in cache already)
db logger: log
dynmod

43
coffee/http-listener.coffee
View file

@ -19,8 +19,6 @@ db = require './persistence'
# [querystring](http://nodejs.org/api/querystring.html)
path = require 'path'
qs = require 'querystring'
fs = require 'fs'
path = require 'path'
# - External Modules: [express](http://expressjs.com/api.html)
express = require 'express'
@ -44,41 +42,6 @@ exports = module.exports = ( args ) =>
initRouting args[ 'http-port' ]
module.exports
indexEvent = ( event, body, resp ) ->
if typeof body is 'string'
try
obj = qs.parse body
catch err
try
obj = JSON.parse body
catch err
resp.send 400, 'Badly formed event!'
return
else
obj = body
timestamp = ( new Date() ).toISOString()
rand = ( Math.floor Math.random() * 10e9 ).toString( 16 ).toUpperCase()
obj.event = event
obj.eventid = "#{ obj.event }_UTC|#{ timestamp }_#{ rand }"
db.pushEvent obj
resp.send 200, "Thank you for the event: #{ obj.eventid }"
# Activate a webhook. the body will be JSON parsed, the name of the webhook will
# be the event name given to the event object, a timestamp will be added
activateWebHook = ( app, name ) =>
@log.info "HL | Webhook activated for #{ name }"
app.post "/webhooks/#{ name }", ( req, resp ) ->
body = ''
req.on 'data', ( data ) ->
body += data
req.on 'end', ->
indexEvent name, body, resp
# This is a hack to quickly allow storing of public accessible data
if name is 'uptimestatistics'
fPath = path.resolve __dirname, '..', 'webpages', 'public', 'data', 'histochart.json'
fs.writeFile fPath, JSON.stringify( JSON.parse( body ), undefined, 2 ), 'utf8'
###
Initializes the request routing and starts listening on the given port.
@ -118,8 +81,10 @@ initRouting = ( port ) =>
app.post '/usercommand', requestHandler.handleUserCommand
# - **`POST` to _"/admincommand"_:** Admin requests are only possible for admins
app.post '/admincommand', requestHandler.handleAdminCommand
# - **`POST` to _"/webhooks/*"_:** Webhooks can be added in the config file
activateWebHook app, hookName for hookName in @arrWebhooks
# - **`POST` to _"/webhooks/*"_:** Webhooks retrieve remote events
app.post '/webhooks', requestHandler.handleWebhooks
# - **`POST` to _"/measurements/*"_:** We also want to record measurements
app.post '/measurements', requestHandler.handleMeasurements
server = app.listen parseInt( port ) || 8111 # inbound event channel

32
coffee/persistence.coffee
View file

@ -801,9 +801,28 @@ Creates and stores a webhook.
@param {String} userId
@param {String} hookname
###
exports.createWebhook = ( userId, hookname ) =>
exports.createWebhook = ( userId, hookname, hookid ) =>
@db.sadd "user:#{ userId }:webhooks", hookname,
replyHandler "sadd 'user:#{ userId }:webhooks' -> '#{ hookname }'"
@db.sadd "webhooks", hookid, replyHandler "sadd 'webhooks' -> '#{ hookid }'"
###
Gets all the users webhooks.
@public getWebhooks( *userId* )
@param {String} userId
###
exports.getUserWebhooks = ( userId, cb ) =>
@db.smembers "user:#{ userId }:webhooks", cb
###
Gets all the users webhooks.
@public getWebhooks( *userId* )
@param {String} userId
###
exports.getAllWebhookIDs = ( cb ) =>
@db.smembers "webhooks", cb
###
Deletes a webhook.
@ -812,19 +831,10 @@ Deletes a webhook.
@param {String} userId
@param {String} hookname
###
exports.deleteWebhook = ( userId, hookname ) =>
exports.deleteUserWebhook = ( userId, hookname ) =>
@db.srem "user:#{ userId }:webhooks", hookname,
replyHandler "srem 'user:#{ userId }:webhooks' -> '#{ hookname }'"
###
Gets all the users webhooks.
@public getWebhooks( *userId* )
@param {String} userId
###
exports.getWebhooks = ( userId, cb ) =>
@db.smembers "user:#{ userId }:webhooks", cb
###
Shuts down the db link.

67
coffee/request-handler.coffee
View file

@ -110,11 +110,14 @@ exports.handleEvent = ( req, resp ) ->
req.on 'end', ->
#if req.session and req.session.user
console.log typeof body
console.log body
try
obj = JSON.parse body
catch err
resp.send 400, 'Badly formed event!'
# If required event properties are present we process the event #
console.log obj
if obj and obj.event and not err
timestamp = ( new Date() ).toISOString()
rand = ( Math.floor Math.random() * 10e9 ).toString( 16 ).toUpperCase()
@ -360,4 +363,66 @@ exports.handleAdminCommand = ( req, resp ) =>
resp.send obj.code, obj
else
resp.send 401, 'You need to be logged in as admin!'
indexEvent = ( event, body, resp ) ->
if typeof body is 'string'
try
obj = qs.parse body
catch err
try
obj = JSON.parse body
catch err
resp.send 400, 'Badly formed event!'
return
else
obj = body
timestamp = ( new Date() ).toISOString()
rand = ( Math.floor Math.random() * 10e9 ).toString( 16 ).toUpperCase()
obj.event = event
obj.eventid = "#{ obj.event }_UTC|#{ timestamp }_#{ rand }"
db.pushEvent obj
resp.send 200, "Thank you for the event: #{ obj.eventid }"
obj
###
Handles webhook posts
###
exports.handleWebhooks = ( req, resp ) =>
console.log 'RH | IMPLEMENT WEBHOOKS'
###
Handles measurement posts
###
exports.handleMeasurements = ( req, resp ) =>
body = ''
req.on 'data', ( data ) ->
body += data
req.on 'end', ->
obj = indexEvent name, body, resp
if obj.eventname is 'uptimestatistics'
# This is a hack to quickly allow storing of public accessible data
fPath = path.resolve __dirname, '..', 'webpages', 'public', 'data', 'histochart.json'
fs.writeFile fPath, JSON.stringify( JSON.parse( body ), undefined, 2 ), 'utf8'
# Activate a webhook. the body will be JSON parsed, the name of the webhook will
# be the event name given to the event object, a timestamp will be added
activateWebHook = ( app, name ) =>
@log.info "HL | Webhook activated for #{ name }"
app.post "/webhooks/#{ name }", ( req, resp ) ->
body = ''
req.on 'data', ( data ) ->
body += data
req.on 'end', ->
indexEvent name, body, resp
# Remove a webhook
removeWebHook = ( app, hookid ) =>
@log.info "HL | Removing Webhook for #{ hookid }"
isFound = false
for oRoute, i in app.routes.post
if oRoute.path is "/webhooks/#{ name }"
app.routes.post.splice i, 1
isFound = true

31
examples/action-invokers/system.coffee → examples/action-invokers/converter.coffee
View file

@ -86,4 +86,33 @@ fConvertTimeStringToDate = ( text ) ->
start.setMilliseconds 0
if start < new Date()
start.setDate start.getDate() + 1
start
start
degToRad = ( deg ) ->
deg * Math.PI / 180
exports.LongLatToMeterDistance = ( latOne, longOne, latTwo, longTwo, eventname ) ->
earthRadius = 3958.75
latOne = parseFloat latOne
longOne = parseFloat longOne
latTwo = parseFloat latTwo
longTwo = parseFloat longTwo
if isNaN latOne or isNaN longOne or isNaN latTwo or isNaN longTwo
log "Illegal values detected in yur given parameters:
#{ latOne }, #{ longOne }, #{ latTwo }, #{ longTwo }"
return
dLat = degToRad latTwo - latOne
dLng = degToRad longTwo - longOne
a = Math.sin( dLat / 2 ) * Math.sin( dLat / 2 ) +
Math.cos( degToRad latOne ) * Math.cos( degToRad latTwo ) *
Math.sin( dLng / 2 ) * Math.sin( dLng / 2 )
c = 2 * Math.atan2 Math.sqrt( a ), Math.sqrt 1 - a
pushEvent
event: eventname
body:
latOne: latOne
longOne: longOne
latTwo: latTwo
longTwo: longTwo
distance: earthRadius * c * 1609 # meter conversion

6
examples/arguments.json Normal file
View file

@ -0,0 +1,6 @@
[
"47.563176999999996",
"7.581330899999998",
"47.563186999999996",
"7.587331899999998"
]

100
examples/eventproducers/hoststatistics.coffee
View file

@ -1,70 +1,72 @@
fs = require 'fs'
# libnmap = require 'node-libnmap'
ping = require 'net-ping'
# request = require 'request'
needle = require 'needle'
# remoteUrl = "localhost:8125"
remoteUrl = "http://ec2-54-226-188-9.compute-1.amazonaws.com:8126"
fPushEvent = ( evt ) ->
needle.post remoteUrl + '/webhooks/uptimestatistics', JSON.stringify( evt ), ( err, resp, body ) ->
needle.post remoteUrl + '/measurements', evt, ( err, resp, body ) ->
if err or resp.statusCode isnt 200
console.log 'Error in pushing event!'
else
console.log 'Successfully posted an event'
try
# arrHosts = JSON.parse fs.readFileSync 'hostlist.json', 'utf8'
histData = JSON.parse fs.readFileSync 'histochart.json', 'utf8'
histData = fs.readFileSync 'histoappend.json', 'utf8'
catch err
console.error err
console.error "Error reading historical data file"
process.exit()
# console.log arrHosts
# libnmap.nmap 'scan',
# range: arrHosts,
# callback: ( err, report ) ->
# if err
# console.log err
# else
# report.forEach ( item ) ->
# console.log item[ 0 ]
session = ping.createSession retries: 2
everyMins = 10
oHosts = {}
oPings = {}
i = -1
oSum = {}
if histData
oHosts = histData.hosts
oPings = histData.pingtimes
arrPings = histData.split "\n"
try
for strObj, i in arrPings
if strObj isnt ''
oTmp = JSON.parse strObj
oSum[ oTmp.timestamp ] =
sum: oTmp.sum
if oTmp
fPushEvent
currentlyon: oSum[ oTmp.timestamp ].sum
pingtimes: oSum
catch err
console.log 'Error parsing histo data'
console.log err
i = -1
ips = []
pingTime = (new Date()).toISOString()
oPings[ pingTime ] = ips: []
fPollHosts = () ->
i++
console.log "Pinging 131.152.85.#{ i }"
session.pingHost "131.152.85.#{ i }", ( err, target, sent, rcvd ) ->
if not err
if not oHosts[ target ]
oHosts[ target ] = {}
oHosts[ target ][ pingTime ] = (new Date( rcvd - sent )).getTime()
oPings[ pingTime ].ips.push target
ips.push target
if i is 255
i = -1
console.log 'All ping requests returned, pushing event into the system and starting again at 0'
oPings[ pingTime ].sum = oPings[ pingTime ].ips.length
evt =
currentlyon: oPings[ pingTime ].ips.length
pingtimes: oPings
hosts: oHosts
fPushEvent evt
fs.writeFile 'histochart.json', JSON.stringify( evt, undefined, 2 ), 'utf8'
console.log "All ping requests returned (#{ips.length} answered), pushing event into the system and starting again at 0"
oSum[ pingTime ] = sum: ips.length
fPushEvent
eventname: 'uptimestatistics'
payload:
currentlyon: ips.length
pingtimes: oSum
oPing =
timestamp: pingTime
ips: ips
sum: ips.length
fs.appendFile 'histoappend.json', JSON.stringify( oPing ) + "\n", 'utf8'
pingTime = (new Date()).toISOString()
oPings[ pingTime ] = ips: []
ips = []
setTimeout fPollHosts, 7000
@ -72,29 +74,3 @@ fPollHosts = () ->
fPollHosts()
# Some pings eventually get blocked if you ping 255 IPs within one second...
#
# fPollHosts = () ->
# semaphore = arrHosts.length
# pingTime = (new Date()).toISOString()
# oPings[ pingTime ] = ips: []
# for host in arrHosts
# session.pingHost host, ( err, target, sent, rcvd ) ->
# if not err
# if not oHosts[ target ]
# oHosts[ target ] = {}
# oHosts[ target ][ pingTime ] = (new Date( rcvd - sent )).getTime()
# oPings[ pingTime ].ips.push target
# if --semaphore is 0
# console.log 'All ping requests returned, pushing event into the system'
# oPings[ pingTime ].sum = oPings[ pingTime ].ips.length
# evt =
# currentlyon: oPings[ pingTime ].ips.length
# pingtimes: oPings
# hosts: oHosts
# fPushEvent evt
# fs.writeFile 'histochart.json', JSON.stringify( evt, undefined, 2 ), 'utf8'
# console.log "Pinging again in #{ everyMins } minutes"
# setTimeout fPollHosts, everyMins * 60 * 1000

10
examples/runscript.coffee
View file

@ -21,6 +21,8 @@ request = require 'request'
importio = require( 'import-io' ).client
params = JSON.parse fs.readFileSync 'params.json', 'utf8'
arrArgs = JSON.parse fs.readFileSync 'arguments.json', 'utf8'
code = fs.readFileSync process.argv[ 2 ], 'utf8'
src = cs.compile code
@ -40,13 +42,7 @@ sandbox =
vm.runInNewContext src, sandbox, sandbox.id
# sandbox.exports[ process.argv[ 3 ] ].apply null, [ "FS14", "FS14 - CS108", "param3", "param4" ]
sandbox.exports[ process.argv[ 3 ] ].apply null, [
useraccount: "10595"
semester: "FS14"
studies: "BSC4"
major: "BL"
]
console.log sandbox.exports[ process.argv[ 3 ] ].apply null, arrArgs
console.log "If no error happened until here it seems the script
compiled and ran correctly! Congrats!"

13
examples/runscript.js
View file

@ -9,7 +9,7 @@ compilation and running of module code
*/
(function() {
var code, crypto, cs, fs, importio, needle, params, request, sandbox, src, vm;
var arrArgs, code, crypto, cs, fs, importio, needle, params, request, sandbox, src, vm;
if (!process.argv[2]) {
console.log('Please provide a path to a coffee file');
@ -32,6 +32,8 @@ compilation and running of module code
params = JSON.parse(fs.readFileSync('params.json', 'utf8'));
arrArgs = JSON.parse(fs.readFileSync('arguments.json', 'utf8'));
code = fs.readFileSync(process.argv[2], 'utf8');
src = cs.compile(code);
@ -54,14 +56,7 @@ compilation and running of module code
vm.runInNewContext(src, sandbox, sandbox.id);
sandbox.exports[process.argv[3]].apply(null, [
{
useraccount: "10595",
semester: "FS14",
studies: "BSC4",
major: "BL"
}
]);
console.log(sandbox.exports[process.argv[3]].apply(null, arrArgs));
console.log("If no error happened until here it seems the script compiled and ran correctly! Congrats!");

80
js/components-manager.js
View file

@ -568,48 +568,43 @@ Components Manager
if (answ.code !== 200) {
return callback(answ);
} else {
return db.getWebhooks((function(_this) {
return db.getUserWebhooks(user.username, (function(_this) {
return function(err, hooks) {
if (hooks.indexOf(oBody.hookname > -1)) {
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!'
return db.getAllWebhookIDs(function(arrHooks) {
var genHookID, hookid;
genHookID = function(arrHooks) {
var hookid, i, _i;
hookid = '';
for (i = _i = 0; _i <= 1; i = ++_i) {
hookid += Math.random().toString(36).substring(2);
}
if (arrHooks && arrHooks.indexOf(hookid) > -1) {
return genHookID(arrHooks);
} else {
return hookid;
}
};
hookid = genHookID(arrHooks);
db.createWebhook(user.username, oBody.hookname, hookid);
return callback({
code: 200,
message: JSON.stringify({
hookid: hookid
})
});
});
}
};
})(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) {
get_all_webhooks: function(user, oBody, callback) {
return db.getUserWebhooks(user.username, function(err, data) {
if (err) {
return callback({
code: 400,
@ -622,6 +617,29 @@ Components Manager
});
}
});
},
delete_webhook: function(user, oBody, callback) {
var answ;
answ = hasRequiredParams(['hookname'], oBody);
if (answ.code !== 200) {
return callback(answ);
} else {
return db.getUserWebhooks(user.username, (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.deleteUserWebhook(user.username, oBody.hookname);
return callback({
code: 200,
message: 'OK!'
});
}
};
})(this));
}
}
};

5
js/event-poller.js
View file

@ -39,6 +39,11 @@ Dynamic Modules
log.info('EP | Event Poller starts up');
process.on('uncaughtException', function(err) {
log.error('Probably one of the event pollers created an error in a callback function!');
return log.error(err);
});
db({
logger: log
});

62
js/http-listener.js
View file

@ -10,7 +10,7 @@ HTTP Listener
*/
(function() {
var activateWebHook, app, db, exports, express, fs, indexEvent, initRouting, path, qs, requestHandler;
var app, db, exports, express, initRouting, path, qs, requestHandler;
requestHandler = require('./request-handler');
@ -20,10 +20,6 @@ HTTP Listener
qs = require('querystring');
fs = require('fs');
path = require('path');
express = require('express');
app = express();
@ -48,53 +44,6 @@ HTTP Listener
};
})(this);
indexEvent = function(event, body, resp) {
var err, obj, rand, timestamp;
if (typeof body === 'string') {
try {
obj = qs.parse(body);
} catch (_error) {
err = _error;
try {
obj = JSON.parse(body);
} catch (_error) {
err = _error;
resp.send(400, 'Badly formed event!');
return;
}
}
} else {
obj = body;
}
timestamp = (new Date()).toISOString();
rand = (Math.floor(Math.random() * 10e9)).toString(16).toUpperCase();
obj.event = event;
obj.eventid = "" + obj.event + "_UTC|" + timestamp + "_" + rand;
db.pushEvent(obj);
return resp.send(200, "Thank you for the event: " + obj.eventid);
};
activateWebHook = (function(_this) {
return function(app, name) {
_this.log.info("HL | Webhook activated for " + name);
return app.post("/webhooks/" + name, function(req, resp) {
var body;
body = '';
req.on('data', function(data) {
return body += data;
});
return req.on('end', function() {
var fPath;
indexEvent(name, body, resp);
if (name === 'uptimestatistics') {
fPath = path.resolve(__dirname, '..', 'webpages', 'public', 'data', 'histochart.json');
return fs.writeFile(fPath, JSON.stringify(JSON.parse(body), void 0, 2), 'utf8');
}
});
});
};
})(this);
/*
Initializes the request routing and starts listening on the given port.
@ -105,7 +54,7 @@ HTTP Listener
initRouting = (function(_this) {
return function(port) {
var hookName, server, sess_sec, _i, _len, _ref;
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({
@ -120,11 +69,8 @@ HTTP Listener
app.post('/logout', requestHandler.handleLogout);
app.post('/usercommand', requestHandler.handleUserCommand);
app.post('/admincommand', requestHandler.handleAdminCommand);
_ref = _this.arrWebhooks;
for (_i = 0, _len = _ref.length; _i < _len; _i++) {
hookName = _ref[_i];
activateWebHook(app, hookName);
}
app.post('/webhooks', requestHandler.handleWebhooks);
app.post('/measurements', requestHandler.handleMeasurements);
server = app.listen(parseInt(port) || 8111);
server.on('listening', function() {
var addr;

49
js/persistence.js
View file

@ -1044,8 +1044,37 @@ Persistence
*/
exports.createWebhook = (function(_this) {
return function(userId, hookname) {
return _this.db.sadd("user:" + userId + ":webhooks", hookname, replyHandler("sadd 'user:" + userId + ":webhooks' -> '" + hookname + "'"));
return function(userId, hookname, hookid) {
_this.db.sadd("user:" + userId + ":webhooks", hookname, replyHandler("sadd 'user:" + userId + ":webhooks' -> '" + hookname + "'"));
return _this.db.sadd("webhooks", hookid, replyHandler("sadd 'webhooks' -> '" + hookid + "'"));
};
})(this);
/*
Gets all the users webhooks.
@public getWebhooks( *userId* )
@param {String} userId
*/
exports.getUserWebhooks = (function(_this) {
return function(userId, cb) {
return _this.db.smembers("user:" + userId + ":webhooks", cb);
};
})(this);
/*
Gets all the users webhooks.
@public getWebhooks( *userId* )
@param {String} userId
*/
exports.getAllWebhookIDs = (function(_this) {
return function(cb) {
return _this.db.smembers("webhooks", cb);
};
})(this);
@ -1058,27 +1087,13 @@ Persistence
@param {String} hookname
*/
exports.deleteWebhook = (function(_this) {
exports.deleteUserWebhook = (function(_this) {
return function(userId, hookname) {
return _this.db.srem("user:" + userId + ":webhooks", hookname, replyHandler("srem 'user:" + userId + ":webhooks' -> '" + hookname + "'"));
};
})(this);
/*
Gets all the users webhooks.
@public getWebhooks( *userId* )
@param {String} userId
*/
exports.getWebhooks = (function(_this) {
return function(userId, cb) {
return _this.db.smembers("user:" + userId + ":webhooks", cb);
};
})(this);
/*
Shuts down the db link.

102
js/request-handler.js
View file

@ -11,7 +11,7 @@ Request Handler
*/
(function() {
var crypto, db, dirHandlers, exports, fs, getHandlerPath, getRemoteScripts, getScript, getTemplate, mustache, path, pathUsers, qs, renderPage;
var activateWebHook, crypto, db, dirHandlers, exports, fs, getHandlerPath, getRemoteScripts, getScript, getTemplate, indexEvent, mustache, path, pathUsers, qs, removeWebHook, renderPage;
db = require('./persistence');
@ -127,12 +127,15 @@ Request Handler
});
return req.on('end', function() {
var answ, err, obj, rand, timestamp;
console.log(typeof body);
console.log(body);
try {
obj = JSON.parse(body);
} catch (_error) {
err = _error;
resp.send(400, 'Badly formed event!');
}
console.log(obj);
if (obj && obj.event && !err) {
timestamp = (new Date()).toISOString();
rand = (Math.floor(Math.random() * 10e9)).toString(16).toUpperCase();
@ -435,4 +438,101 @@ Request Handler
};
})(this);
indexEvent = function(event, body, resp) {
var err, obj, rand, timestamp;
if (typeof body === 'string') {
try {
obj = qs.parse(body);
} catch (_error) {
err = _error;
try {
obj = JSON.parse(body);
} catch (_error) {
err = _error;
resp.send(400, 'Badly formed event!');
return;
}
}
} else {
obj = body;
}
timestamp = (new Date()).toISOString();
rand = (Math.floor(Math.random() * 10e9)).toString(16).toUpperCase();
obj.event = event;
obj.eventid = "" + obj.event + "_UTC|" + timestamp + "_" + rand;
db.pushEvent(obj);
resp.send(200, "Thank you for the event: " + obj.eventid);
return obj;
};
/*
Handles webhook posts
*/
exports.handleWebhooks = (function(_this) {
return function(req, resp) {
return console.log('RH | IMPLEMENT WEBHOOKS');
};
})(this);
/*
Handles measurement posts
*/
exports.handleMeasurements = (function(_this) {
return function(req, resp) {
var body;
body = '';
req.on('data', function(data) {
return body += data;
});
return req.on('end', function() {
var fPath, obj;
obj = indexEvent(name, body, resp);
if (obj.eventname === 'uptimestatistics') {
fPath = path.resolve(__dirname, '..', 'webpages', 'public', 'data', 'histochart.json');
return fs.writeFile(fPath, JSON.stringify(JSON.parse(body), void 0, 2), 'utf8');
}
});
};
})(this);
activateWebHook = (function(_this) {
return function(app, name) {
_this.log.info("HL | Webhook activated for " + name);
return app.post("/webhooks/" + name, function(req, resp) {
var body;
body = '';
req.on('data', function(data) {
return body += data;
});
return req.on('end', function() {
return indexEvent(name, body, resp);
});
});
};
})(this);
removeWebHook = (function(_this) {
return function(app, hookid) {
var i, isFound, oRoute, _i, _len, _ref, _results;
_this.log.info("HL | Removing Webhook for " + hookid);
isFound = false;
_ref = app.routes.post;
_results = [];
for (i = _i = 0, _len = _ref.length; _i < _len; i = ++_i) {
oRoute = _ref[i];
if (oRoute.path === ("/webhooks/" + name)) {
app.routes.post.splice(i, 1);
_results.push(isFound = true);
} else {
_results.push(void 0);
}
}
return _results;
};
})(this);
}).call(this);

2
webpages/handlers/coffee/forge_event.coffee
View file

@ -54,7 +54,7 @@ fOnLoad = () ->
oSelector = fFindKeyStringPair obj.body
if oSelector
sel = "&selkey=#{ oSelector.key }&selval=#{ oSelector.val }"
url = 'forge?page=forge_rule&eventname=' + obj.event + sel
url = 'forge?page=forge_rule&eventtype=custom&eventname=' + obj.event + sel
window.open url, '_blank'
else
$( '#info' ).text 'Please provide a valid eventname'

17
webpages/handlers/coffee/forge_rule.coffee
View file

@ -62,11 +62,18 @@ fOnLoad = () ->
# EVENT
# If the user is coming from an event he wants a rule to be setup for him
if oParams.eventname
$( '#select_event_type' ).val 'Custom Event'
inpEvt = $( '<input>' ).attr( 'type', 'text').attr 'id', 'input_eventname'
inpEvt.val oParams.eventname
$( '#event_parameters' ).append inpEvt
switch oParams.eventtype
when 'custom'
$( '#select_event_type' ).val 'Custom Event'
inpEvt = $( '<input>' ).attr( 'type', 'text').attr 'id', 'input_eventname'
inpEvt.val oParams.eventname
$( '#event_parameters' ).append inpEvt
when 'webhook'
console.log 'webhook'
when 'poller'
console.log 'poller'
# Event type is changed, changes the whole event section
$( '#select_event_type' ).change () ->

89
webpages/handlers/coffee/forge_webhook.coffee
View file

@ -0,0 +1,89 @@
# Fetch the search string and transform it into an object for easy access
arrParams = window.location.search.substring(1).split '&'
oParams = {}
for param in arrParams
arrKV = param.split '='
oParams[ arrKV[ 0 ] ] = arrKV[ 1 ]
if oParams.id
oParams.id = decodeURIComponent oParams.id
fDisplayError = ( msg ) ->
window.scrollTo 0, 0
$( '#info' ).text "Error: #{ msg }"
$( '#info' ).attr 'class', 'error'
fIssueRequest = ( args ) ->
$( '#info' ).text ''
$.post( '/usercommand', args.body )
.done args.done
.fail args.fail
fFailedRequest = ( msg ) ->
( err ) ->
if err.status is 401
window.location.href = 'forge?page=forge_rule'
else
fDisplayError msg
fUpdateWebhookList = ( data ) ->
$( '#table_webhooks tr' ).remove()
oHooks = JSON.parse data.message
console.log oHooks
for modName of oHooks
tr = $ '<tr>'
inp = $( '<div>' ).text modName
img = $( '<img>' ).attr( 'class', 'del' )
.attr( 'title', 'Delete Module' ).attr 'src', 'red_cross_small.png'
tr.append( $( '<td>' ).append img )
tr.append( $( '<td>' ).append inp )
$( '#table_webhooks' ).append tr
fOnLoad = () ->
document.title = 'Create Webhooks!'
# Load existing rules
fIssueRequest
body:
command: 'get_all_webhooks'
done: fUpdateWebhookList
fail: fFailedRequest 'Unable to post get_all_webhooks request'
# Register button action
$( '#but_submit' ).click ->
$( '#info' ).text ''
hookname = $( '#inp_hookname' ).val()
if hookname is ''
fDisplayError 'Please provide a hookname!'
else
$( '#display_hookurl *' ).remove()
fIssueRequest
body:
command: 'create_webhook'
body: JSON.stringify
hookname: hookname
done: ( data ) ->
oAnsw = JSON.parse data.message
url = [ location.protocol, '//', location.host ].join ''
h3 = $( '<h3>' ).text "This is the Webhook Url you should use:"
inp = $('<input>').attr( 'type', 'text' ).attr( 'style', 'font-size:1em' )
.val "#{ url }/webhooks/#{ oAnsw.hookid }"
h3.append inp
$( '#display_hookurl' ).append h3
div = $('<div>').html "Push your location via <a href=\"#{ url }/mobile/index.html?hookid=#{ oAnsw.hookid }\">this page</a>"
$( '#display_hookurl' ).append div
fail: ( err ) ->
if err.status is 409
fFailedRequest( 'Webhook Event Name already existing!' ) err
else
fFailedRequest( 'Unable to create Webhook! ' + err.message ) err
# <h3>This is the Webhook Url you should use:</h3>
# push your location via this page: mobile?hookid=
window.addEventListener 'load', fOnLoad, true

2
webpages/handlers/js/forge_event.js
View file

@ -73,7 +73,7 @@
sel = "&selkey=" + oSelector.key + "&selval=" + oSelector.val;
}
}
url = 'forge?page=forge_rule&eventname=' + obj.event + sel;
url = 'forge?page=forge_rule&eventtype=custom&eventname=' + obj.event + sel;
return window.open(url, '_blank');
} else {
$('#info').text('Please provide a valid eventname');

17
webpages/handlers/js/forge_rule.js
View file

@ -68,11 +68,18 @@
editor.setTheme("ace/theme/monokai");
editor.getSession().setMode("ace/mode/json");
editor.setShowPrintMargin(false);
if (oParams.eventname) {
$('#select_event_type').val('Custom Event');
inpEvt = $('<input>').attr('type', 'text').attr('id', 'input_eventname');
inpEvt.val(oParams.eventname);
$('#event_parameters').append(inpEvt);
switch (oParams.eventtype) {
case 'custom':
$('#select_event_type').val('Custom Event');
inpEvt = $('<input>').attr('type', 'text').attr('id', 'input_eventname');
inpEvt.val(oParams.eventname);
$('#event_parameters').append(inpEvt);
break;
case 'webhook':
console.log('webhook');
break;
case 'poller':
console.log('poller');
}
$('#select_event_type').change(function() {
$('#event_parameters *').remove();

101
webpages/handlers/js/forge_webhook.js
View file

@ -1,5 +1,106 @@
// Generated by CoffeeScript 1.7.1
(function() {
var arrKV, arrParams, fDisplayError, fFailedRequest, fIssueRequest, fOnLoad, fUpdateWebhookList, oParams, param, _i, _len;
arrParams = window.location.search.substring(1).split('&');
oParams = {};
for (_i = 0, _len = arrParams.length; _i < _len; _i++) {
param = arrParams[_i];
arrKV = param.split('=');
oParams[arrKV[0]] = arrKV[1];
}
if (oParams.id) {
oParams.id = decodeURIComponent(oParams.id);
}
fDisplayError = function(msg) {
window.scrollTo(0, 0);
$('#info').text("Error: " + msg);
return $('#info').attr('class', 'error');
};
fIssueRequest = function(args) {
$('#info').text('');
return $.post('/usercommand', args.body).done(args.done).fail(args.fail);
};
fFailedRequest = function(msg) {
return function(err) {
if (err.status === 401) {
return window.location.href = 'forge?page=forge_rule';
} else {
return fDisplayError(msg);
}
};
};
fUpdateWebhookList = function(data) {
var img, inp, modName, oHooks, tr, _results;
$('#table_webhooks tr').remove();
oHooks = JSON.parse(data.message);
console.log(oHooks);
_results = [];
for (modName in oHooks) {
tr = $('<tr>');
inp = $('<div>').text(modName);
img = $('<img>').attr('class', 'del').attr('title', 'Delete Module').attr('src', 'red_cross_small.png');
tr.append($('<td>').append(img));
tr.append($('<td>').append(inp));
_results.push($('#table_webhooks').append(tr));
}
return _results;
};
fOnLoad = function() {
document.title = 'Create Webhooks!';
fIssueRequest({
body: {
command: 'get_all_webhooks'
},
done: fUpdateWebhookList,
fail: fFailedRequest('Unable to post get_all_webhooks request')
});
return $('#but_submit').click(function() {
var hookname;
$('#info').text('');
hookname = $('#inp_hookname').val();
if (hookname === '') {
return fDisplayError('Please provide a hookname!');
} else {
$('#display_hookurl *').remove();
return fIssueRequest({
body: {
command: 'create_webhook',
body: JSON.stringify({
hookname: hookname
})
},
done: function(data) {
var div, h3, inp, oAnsw, url;
oAnsw = JSON.parse(data.message);
url = [location.protocol, '//', location.host].join('');
h3 = $('<h3>').text("This is the Webhook Url you should use:");
inp = $('<input>').attr('type', 'text').attr('style', 'font-size:1em').val("" + url + "/webhooks/" + oAnsw.hookid);
h3.append(inp);
$('#display_hookurl').append(h3);
div = $('<div>').html("Push your location via <a href=\"" + url + "/mobile/index.html?hookid=" + oAnsw.hookid + "\">this page</a>");
return $('#display_hookurl').append(div);
},
fail: function(err) {
if (err.status === 409) {
return fFailedRequest('Webhook Event Name already existing!')(err);
} else {
return fFailedRequest('Unable to create Webhook! ' + err.message)(err);
}
}
});
}
});
};
window.addEventListener('load', fOnLoad, true);
}).call(this);

5
webpages/handlers/templates/forge_event.html
View file

@ -9,5 +9,6 @@
}
</div>
</div>
<button id="but_submit">invoke</button><button id="but_prepare">prepare a rule for this event</button>
<button id="but_prepare">Prepare a Rule for this Event</button>
<br>
<button id="but_submit">Push Event into System</button>

6
webpages/handlers/templates/forge_webhook.html
View file

@ -1,5 +1,7 @@
<input type="text" id="inp_hookname" style="width:300px" />
<h2>Create your own Webhooks</h2>
<h3>Provide your desired Event Name :
<input type="text" id="inp_hookname" style="font-size:1em;width:300px" /></h3>
<button type="button" id="but_submit">Create Webhook!</button>
<br><br>
<h3>This is the Webhook Url you should use:</h3>
<div id="display_hookurl" />
<div id="table_webhooks" />

6
webpages/handlers/templates/menubar.html
View file

@ -20,6 +20,9 @@
fCreateLink( 'Create Rule',
fRedirect( 'forge?page=forge_rule' )
);
fCreateLink( 'Create Webhooks',
fRedirect( 'forge?page=forge_webhook' )
);
fCreateLink( 'Edit Rules',
fRedirect( 'forge?page=edit_rules' )
);
@ -32,9 +35,6 @@
fCreateLink( 'Edit EPs & AIs',
fRedirect( 'forge?page=edit_modules' )
);
fCreateLink( 'Webhooks',
fRedirect( 'forge?page=forge_webhook' )
);
// fCreateLink( 'admin', fRedirect( 'admin' ) );
fCreateLink( 'Logout', function() {

3
webpages/public/histogram.html
View file

@ -10,6 +10,7 @@
<body>
<script>
google.setOnLoadCallback(drawChart);
var dateNow = new Date()
function drawChart() {
$.getJSON('data/histochart.json', function(d) {
var data = new google.visualization.DataTable();
@ -23,7 +24,7 @@
intervals: { 'style':'line' },
legend: 'none',
vAxis: { title: "Number of Responding Hosts" },
hAxis: { title: "Timestamp", format: "MMM d, HH:mm" }
hAxis: { title: "Timestamp", format: "MMM d, HH" }
};
var dat = d.pingtimes;
for(var prop in dat) {

42
webpages/public/mobile/index.html
View file

@ -7,24 +7,44 @@
<body>
<h1>Mobile Page</h1>
<script>
function displayPosition(position) {
var arrParams = window.location.search.substring( 1 ).split( '&' );
var oParams = {};
var hookid, arrKV;
for( var i = 0; i < arrParams.length; i++ ) {
arrKV = arrParams[ i ].split( '=' );
if( arrKV[ 0 ] === 'hookid' ) hookid = arrKV[ 1 ]
}
function displayPosition( position ) {
var lat = position.coords.latitude,
lon = position.coords.longitude;
$('#print').html("<table border='1'><tr><th>Timestamp</th><td>" + position.timestamp +
"<tr><th>Latitude</th><td>" + lat + " deg</td></tr>" +
"<tr><th>Longitude</th><td>" + lon + " deg</td></tr></table>");
$('#print').html("<h3>You're here!</h3>");
// $('#print').html("<table border='1'><tr><th>Timestamp</th><td>" + position.timestamp +
// "<tr><th>Latitude</th><td>" + lat + " deg</td></tr>" +
// "<tr><th>Longitude</th><td>" + lon + " deg</td></tr></table>");
var img_url="http://maps.googleapis.com/maps/api/staticmap?center="
+lat+","+lon+"&zoom=15&size=400x300&sensor=false&maptype=roadmap&markers=color:orange|label:1|"+lat+","+lon;
document.getElementById("mapholder").innerHTML="<img src='"+img_url+"'>";
$.post('../push_event', { event: 'geoposition', eventid: 'geoposition_' + position.timestamp })
.done(function(data) {
$('#info').text("Sent event to engine: " + data);
})
.fail(function(err) {
$('#info').text("Error: " + err);
});
var fPostPosition = function() {
var url = '../event';
if( hookid ) url = '../webhooks/' + hookid
$.post( url, JSON.stringify({
event: 'geoposition',
latitude: lat,
longitude: lon
}))
.done(function(data) {
$('#info').text("Sent event to engine: " + data.message);
})
.fail(function(err) {
$('#info').text("Error: " + err);
});
// Post position every 5 mins
setTimeout( fPostPosition, 5 * 60 * 1000 );
}
fPostPosition()
}
function displayError(positionError) {