node/test/parallel/test-domain-http-server.js
Roman Reiss f29762f4dd test: enable linting for tests
Enable linting for the test directory. A number of changes was made so
all tests conform the current rules used by lib and src directories. The
only exception for tests is that unreachable (dead) code is allowed.

test-fs-non-number-arguments-throw had to be excluded from the changes
because of a weird issue on Windows CI.

PR-URL: https://github.com/nodejs/io.js/pull/1721
Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl>
2015-05-19 21:21:27 +02:00

95 lines
2.3 KiB
JavaScript

'use strict';
var domain = require('domain');
var http = require('http');
var assert = require('assert');
var common = require('../common');
var objects = { foo: 'bar', baz: {}, num: 42, arr: [1,2,3] };
objects.baz.asdf = objects;
var serverCaught = 0;
var clientCaught = 0;
var disposeEmit = 0;
var server = http.createServer(function(req, res) {
var dom = domain.create();
req.resume();
dom.add(req);
dom.add(res);
dom.on('error', function(er) {
serverCaught++;
console.log('horray! got a server error', er);
// try to send a 500. If that fails, oh well.
res.writeHead(500, {'content-type':'text/plain'});
res.end(er.stack || er.message || 'Unknown error');
});
dom.run(function() {
// Now, an action that has the potential to fail!
// if you request 'baz', then it'll throw a JSON circular ref error.
var data = JSON.stringify(objects[req.url.replace(/[^a-z]/g, '')]);
// this line will throw if you pick an unknown key
assert(data !== undefined, 'Data should not be undefined');
res.writeHead(200);
res.end(data);
});
});
server.listen(common.PORT, next);
function next() {
console.log('listening on localhost:%d', common.PORT);
var requests = 0;
var responses = 0;
makeReq('/');
makeReq('/foo');
makeReq('/arr');
makeReq('/baz');
makeReq('/num');
function makeReq(p) {
requests++;
var dom = domain.create();
dom.on('error', function(er) {
clientCaught++;
console.log('client error', er);
req.socket.destroy();
});
var req = http.get({ host: 'localhost', port: common.PORT, path: p });
dom.add(req);
req.on('response', function(res) {
responses++;
console.error('requests=%d responses=%d', requests, responses);
if (responses === requests) {
console.error('done, closing server');
// no more coming.
server.close();
}
dom.add(res);
var d = '';
res.on('data', function(c) {
d += c;
});
res.on('end', function() {
console.error('trying to parse json', d);
d = JSON.parse(d);
console.log('json!', d);
});
});
}
}
process.on('exit', function() {
assert.equal(serverCaught, 2);
assert.equal(clientCaught, 2);
console.log('ok');
});