demostf/demoserver
1
0
Fork 0
mirror of https://github.com/demostf/demoserver.git synced 2026-06-03 22:04:06 +02:00
Code Issues Projects Releases Packages Wiki Activity

add optional slow mode to demoserver

Browse source
This commit is contained in:
Robin Appelman 2018-03-09 00:03:16 +01:00
commit 50bb100b71
1 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

13
index.js
View file

@ -12,7 +12,7 @@ app.get('/', function (request, response) {
response.send('Hello World!'); response.send('Hello World!');
}); });
function handleDataStream (stream, cb) { function handleDataStream (stream, cb, slow) {
var buffers = []; var buffers = [];
stream.on('data', function (buffer) { stream.on('data', function (buffer) {
buffers.push(buffer); buffers.push(buffer);
@ -21,7 +21,7 @@ function handleDataStream (stream, cb) {
try { try {
var buffer = Buffer.concat(buffers); var buffer = Buffer.concat(buffers);
var demo = DemoParser.Demo.fromNodeBuffer(buffer); var demo = DemoParser.Demo.fromNodeBuffer(buffer);
var parser = demo.getParser(true); var parser = demo.getParser(!slow);
var header = parser.readHeader(); var header = parser.readHeader();
var match = parser.parseBody(); var match = parser.parseBody();
var body = match.getState(); var body = match.getState();
@ -33,12 +33,19 @@ function handleDataStream (stream, cb) {
}); });
} }
app.post('/parse/slow', function (req, res) {
handleDataStream(req, function (body) {
res.set('Content-Type', 'application/json');
res.write(JSON.stringify(body));
res.end();
}, true)
});
app.post('/parse', function (req, res) { app.post('/parse', function (req, res) {
handleDataStream(req, function (body) { handleDataStream(req, function (body) {
res.set('Content-Type', 'application/json'); res.set('Content-Type', 'application/json');
res.write(JSON.stringify(body)); res.write(JSON.stringify(body));
res.end(); res.end();
}) }, false)
}); });
app.post('/url', function (req, res) { app.post('/url', function (req, res) {