Skip to content

Commit

Permalink
test: deflake test-http-remove-header-stays-removed
Browse files Browse the repository at this point in the history
Instead of relying on a timer, verify that `socket.end()` is called when
the `'finish'` event is emitted on the `ServerResponse` object.

PR-URL: #55004
Reviewed-By: James M Snell <[email protected]>
Reviewed-By: Jake Yuesong Li <[email protected]>
  • Loading branch information
lpinca authored and targos committed Oct 4, 2024
1 parent ee0a98b commit fb8470a
Showing 1 changed file with 16 additions and 17 deletions.
33 changes: 16 additions & 17 deletions test/parallel/test-http-remove-header-stays-removed.js
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,9 @@ const assert = require('assert');

const http = require('http');

const server = http.createServer(function(request, response) {
const server = http.createServer(common.mustCall(function(request, response) {
const socket = response.socket;

// Removed headers should stay removed, even if node automatically adds them
// to the output:
response.removeHeader('connection');
Expand All @@ -36,32 +38,29 @@ const server = http.createServer(function(request, response) {
response.removeHeader('date');
response.setHeader('date', 'coffee o clock');

response.end('beep boop\n');
});

let response = '';
response.on('finish', common.mustCall(function() {
// The socket should be closed immediately, with no keep-alive, because
// no content-length or transfer-encoding are used.
assert.strictEqual(socket.writableEnded, true);
}));

process.on('exit', function() {
assert.strictEqual(response, 'beep boop\n');
console.log('ok');
});
response.end('beep boop\n');
}));

server.listen(0, function() {
http.get({ port: this.address().port }, function(res) {
assert.strictEqual(res.statusCode, 200);
assert.deepStrictEqual(res.headers, { date: 'coffee o clock' });

let response = '';
res.setEncoding('ascii');
res.on('data', function(chunk) {
response += chunk;
if (response === 'beep boop\n') {
setTimeout(function() {
// The socket should be closed immediately, with no keep-alive, because
// no content-length or transfer-encoding are used:
assert.strictEqual(res.socket.closed, true);
server.close();
}, common.platformTimeout(15));
}
});

res.on('end', function() {
assert.strictEqual(response, 'beep boop\n');
server.close();
});
});
});

0 comments on commit fb8470a

Please sign in to comment.