mirrors/nodejs
mirrors/nodejs
0
0
Fork 0
mirror of https://github.com/nodejs/node.git synced 2024-12-01 16:10:02 +01:00
Code Issues Releases Activity

Add HTTP proxy test. Fix bug in http.Server.

Browse Source 
was not properly inheriting http.Server from http.LowLevelServer.
This commit is contained in:
Ryan 2009-06-09 14:10:53 +02:00
parent 90d584129d
commit 88c04e74c9
2 changed files with 55 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/http.js
View File

@ -125,7 +125,6 @@ node.http.ServerResponse = function (connection, responses) {
this.closeOnFinish = false;
var output = [];
var chunked_encoding = false;
this.sendHeader = function (statusCode, headers) {
@ -314,8 +313,7 @@ node.http.Server = function (RequestHandler, options) {
};
}
this.__proto__.__proto__ =
new node.http.LowLevelServer(ConnectionHandler, options);
this.__proto__ = new node.http.LowLevelServer(ConnectionHandler, options);
};
node.http.Client = function (port, host) {
@ -410,7 +408,6 @@ node.http.Client = function (port, host) {
};
connection.onEOF = function () {
//node.debug("onEOF. readyState = " + connection.readyState);
connection.close();
};

54
test/test-http-proxy.js Normal file
View File

@ -0,0 +1,54 @@
include("mjsunit.js");
var PROXY_PORT = 8869;
var BACKEND_PORT = 8870;
var backend = new node.http.Server(function (req, res) {
// node.debug("backend");
res.sendHeader(200, [["content-type", "text/plain"]]);
res.sendBody("hello world\n");
res.finish();
});
// node.debug("listen backend")
backend.listen(BACKEND_PORT);
var proxy_client = new node.http.Client(BACKEND_PORT);
var proxy = new node.http.Server(function (req, res) {
// node.debug("proxy req");
var proxy_req = proxy_client.get(req.uri.path);
proxy_req.finish(function(proxy_res) {
res.sendHeader(proxy_res.statusCode, proxy_res.headers);
proxy_res.onBody = function(chunk) {
res.sendBody(chunk);
};
proxy_res.onBodyComplete = function() {
res.finish();
// node.debug("proxy res");
};
});
});
// node.debug("listen proxy")
proxy.listen(PROXY_PORT);
var body = "";
function onLoad () {
var client = new node.http.Client(PROXY_PORT);
var req = client.get("/test");
// node.debug("client req")
req.finish(function (res) {
// node.debug("got res");
assertEquals(200, res.statusCode);
res.setBodyEncoding("utf8");
res.onBody = function (chunk) { body += chunk; };
res.onBodyComplete = function () {
proxy.close();
backend.close();
// node.debug("closed both");
};
});
}
function onExit () {
assertEquals(body, "hello world\n");
}