diff options
| author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2015-10-28 12:50:48 -0700 |
|---|---|---|
| committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2015-10-28 12:50:48 -0700 |
| commit | c6a918d9962dcf2354483b709b8bf0fffbbc3983 (patch) | |
| tree | 54f8b9f631c011479c54a75cbf90f00e9c905480 /tests/http/server.js | |
| parent | 0034efafe4f141d06d07464e7df2e151f4304294 (diff) | |
| download | infinitytier-c6a918d9962dcf2354483b709b8bf0fffbbc3983.tar.gz infinitytier-c6a918d9962dcf2354483b709b8bf0fffbbc3983.zip | |
HTTP test code.
Diffstat (limited to 'tests/http/server.js')
| -rw-r--r-- | tests/http/server.js | 48 |
1 files changed, 48 insertions, 0 deletions
diff --git a/tests/http/server.js b/tests/http/server.js new file mode 100644 index 00000000..221dcda9 --- /dev/null +++ b/tests/http/server.js @@ -0,0 +1,48 @@ +// --------------------------------------------------------------------------- +// Customizable parameters: + +var SERVER_PORT = 18080; + +// --------------------------------------------------------------------------- + +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(''); + var resultData = null; + try { + resultData = JSON.parse(req.rawBody); + } catch (e) { + resultData = req.rawBody; + } + result = { + agentId: agentId, + result: resultData + }; + console.log(result); + return res.status(200).send(''); +}); + +var expressServer = app.listen(SERVER_PORT,function () { + console.log('LISTENING ON '+SERVER_PORT); + console.log(''); +}); |
