2015-10-28 19:50:48 +00:00
|
|
|
// ---------------------------------------------------------------------------
|
|
|
|
// Customizable parameters:
|
|
|
|
|
|
|
|
var SERVER_PORT = 18080;
|
|
|
|
|
|
|
|
// ---------------------------------------------------------------------------
|
|
|
|
|
2015-10-28 20:14:53 +00:00
|
|
|
var fs = require('fs');
|
|
|
|
|
2015-10-28 19:50:48 +00:00
|
|
|
var express = require('express');
|
|
|
|
var app = express();
|
|
|
|
|
|
|
|
app.use(function(req,res,next) {
|
|
|
|
req.rawBody = '';
|
|
|
|
req.on('data', function(chunk) { req.rawBody += chunk.toString(); });
|
|
|
|
req.on('end', function() { return next(); });
|
|
|
|
});
|
|
|
|
|
|
|
|
var knownAgents = {};
|
|
|
|
|
|
|
|
app.get('/:agentId',function(req,res) {
|
|
|
|
var agentId = req.params.agentId;
|
|
|
|
if ((!agentId)||(agentId.length !== 32))
|
|
|
|
return res.status(404).send('');
|
|
|
|
knownAgents[agentId] = Date.now();
|
|
|
|
return res.status(200).send(JSON.stringify(Object.keys(knownAgents)));
|
|
|
|
});
|
|
|
|
|
|
|
|
app.post('/:agentId',function(req,res) {
|
|
|
|
var agentId = req.params.agentId;
|
|
|
|
if ((!agentId)||(agentId.length !== 32))
|
|
|
|
return res.status(404).send('');
|
2015-10-28 20:14:53 +00:00
|
|
|
|
|
|
|
var receiveTime = Date.now();
|
2015-10-28 19:50:48 +00:00
|
|
|
var resultData = null;
|
|
|
|
try {
|
|
|
|
resultData = JSON.parse(req.rawBody);
|
|
|
|
} catch (e) {
|
|
|
|
resultData = req.rawBody;
|
|
|
|
}
|
|
|
|
result = {
|
|
|
|
agentId: agentId,
|
2015-10-28 20:14:53 +00:00
|
|
|
receiveTime: receiveTime,
|
2015-10-28 19:50:48 +00:00
|
|
|
result: resultData
|
|
|
|
};
|
2015-10-28 20:14:53 +00:00
|
|
|
|
|
|
|
var nows = receiveTime.toString(16);
|
|
|
|
while (nows.length < 16)
|
|
|
|
nows = '0' + nows;
|
|
|
|
fs.writeFile('result_'+agentId+'_'+nows,JSON.stringify(result),function(err) {
|
|
|
|
console.log(result);
|
|
|
|
});
|
|
|
|
|
2015-10-28 19:50:48 +00:00
|
|
|
return res.status(200).send('');
|
|
|
|
});
|
|
|
|
|
|
|
|
var expressServer = app.listen(SERVER_PORT,function () {
|
|
|
|
console.log('LISTENING ON '+SERVER_PORT);
|
|
|
|
console.log('');
|
|
|
|
});
|