|
|
|
include("mjsunit.js");
|
|
|
|
var PORT = 18032;
|
|
|
|
|
|
|
|
var sent_body = "";
|
|
|
|
var server_req_complete = false;
|
|
|
|
var client_res_complete = false;
|
|
|
|
|
|
|
|
var server = node.http.createServer(function(req, res) {
|
|
|
|
assertEquals("POST", req.method);
|
|
|
|
req.setBodyEncoding("utf8");
|
|
|
|
|
|
|
|
req.addListener("body", function (chunk) {
|
|
|
|
puts("server got: " + JSON.stringify(chunk));
|
|
|
|
sent_body += chunk;
|
|
|
|
});
|
|
|
|
|
|
|
|
req.addListener("complete", function () {
|
|
|
|
server_req_complete = true;
|
|
|
|
puts("request complete from server");
|
|
|
|
res.sendHeader(200, {'Content-Type': 'text/plain'});
|
|
|
|
res.sendBody('hello\n');
|
|
|
|
res.finish();
|
|
|
|
});
|
|
|
|
});
|
|
|
|
server.listen(PORT);
|
|
|
|
|
|
|
|
function onLoad () {
|
|
|
|
var client = node.http.createClient(PORT);
|
|
|
|
var req = client.post('/');
|
|
|
|
|
|
|
|
req.sendBody('1\n');
|
|
|
|
req.sendBody('2\n');
|
|
|
|
req.sendBody('3\n');
|
|
|
|
|
|
|
|
puts("client finished sending request");
|
|
|
|
req.finish(function(res) {
|
|
|
|
res.setBodyEncoding("utf8");
|
|
|
|
res.addListener('body', function(chunk) {
|
|
|
|
puts(chunk);
|
|
|
|
});
|
|
|
|
res.addListener('complete', function() {
|
|
|
|
client_res_complete = true;
|
|
|
|
server.close();
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
function onExit () {
|
|
|
|
assertEquals("1\n2\n3\n", sent_body);
|
|
|
|
assertTrue(server_req_complete);
|
|
|
|
assertTrue(client_res_complete);
|
|
|
|
}
|