summaryrefslogtreecommitdiff
path: root/tests/http/server.js
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2015-10-28 12:50:48 -0700
committerAdam Ierymenko <adam.ierymenko@gmail.com>2015-10-28 12:50:48 -0700
commitc6a918d9962dcf2354483b709b8bf0fffbbc3983 (patch)
tree54f8b9f631c011479c54a75cbf90f00e9c905480 /tests/http/server.js
parent0034efafe4f141d06d07464e7df2e151f4304294 (diff)
downloadinfinitytier-c6a918d9962dcf2354483b709b8bf0fffbbc3983.tar.gz
infinitytier-c6a918d9962dcf2354483b709b8bf0fffbbc3983.zip
HTTP test code.
Diffstat (limited to 'tests/http/server.js')
-rw-r--r--tests/http/server.js48
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('');
+});