This repository has been archived by the owner on Apr 22, 2023. It is now read-only.
/
test-http-proxy.js
64 lines (55 loc) · 1.6 KB
/
test-http-proxy.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
require("../common");
http = require("http");
url = require("url");
var PROXY_PORT = PORT;
var BACKEND_PORT = PORT+1;
var backend = http.createServer(function (req, res) {
debug("backend request");
res.writeHead(200, {"content-type": "text/plain"});
res.write("hello world\n");
res.end();
});
var proxy_client = http.createClient(BACKEND_PORT);
var proxy = http.createServer(function (req, res) {
debug("proxy req headers: " + JSON.stringify(req.headers));
var proxy_req = proxy_client.request(url.parse(req.url).pathname);
proxy_req.addListener('response', function(proxy_res) {
res.writeHead(proxy_res.statusCode, proxy_res.headers);
proxy_res.addListener("data", function(chunk) {
res.write(chunk);
});
proxy_res.addListener("end", function() {
res.end();
debug("proxy res");
});
});
proxy_req.end();
});
var body = "";
nlistening = 0;
function startReq () {
nlistening++;
if (nlistening < 2) return;
var client = http.createClient(PROXY_PORT);
var req = client.request("/test");
debug("client req")
req.addListener('response', function (res) {
debug("got res");
assert.equal(200, res.statusCode);
res.setBodyEncoding("utf8");
res.addListener('data', function (chunk) { body += chunk; });
res.addListener('end', function () {
proxy.close();
backend.close();
debug("closed both");
});
});
req.end();
}
debug("listen proxy")
proxy.listen(PROXY_PORT, startReq);
debug("listen backend")
backend.listen(BACKEND_PORT, startReq);
process.addListener("exit", function () {
assert.equal(body, "hello world\n");
});