mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-16 13:51:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

more and break more

Browse Source
This commit is contained in:
Ciro Spaciari
2025-05-21 15:18:36 -07:00
parent 7da15d4e72
commit f451ddb910
3 changed files with 90 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/js/node/test/parallel/test-http2-large-write-close.js
View File

@@ -28,7 +28,7 @@ server.on('stream', common.mustCall((stream) => {
}));
server.listen(0, common.mustCall(() => {
const client = http2.connect(`https://localhost:${server.address().port}`,
const client = http2.connect(`https://127.0.0.1:${server.address().port}`,
{ rejectUnauthorized: false });
const req = client.request({ ':path': '/' });

1
test/js/node/test/parallel/test-http2-pipe-named-pipe.js
View File

@@ -31,7 +31,6 @@ server.on('stream', common.mustCall((stream) => {
fs.readFileSync(loc).length);
}));
}));
server.listen(common.PIPE, common.mustCall(() => {
const client = http2.connect('http://localhost', {
createConnection(url) {

89
test/js/node/test/parallel/test-http2-premature-close.js Normal file
View File

@@ -0,0 +1,89 @@
// Flags: --expose-internals
'use strict';
const common = require('../common');
if (!common.hasCrypto) common.skip('missing crypto');
const h2 = require('http2');
const net = require('net');
async function requestAndClose(server) {
const client = new net.Socket();
const address = server.address();
if (!common.hasIPv6 && address.family === 'IPv6') {
// Necessary to pass CI running inside containers.
client.connect(address.port);
} else {
client.connect(address);
}
client.on('connect', common.mustCall(function() {
// Send HTTP/2 Preface
client.write(Buffer.from('PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n', 'utf8'));
// Send a SETTINGS frame (empty payload)
client.write(Buffer.from([0x00, 0x00, 0x00, 0x04, 0x00, 0x00, 0x00, 0x00, 0x00]));
const streamId = 1;
// Send a valid HEADERS frame
const headersFrame = Buffer.concat([
Buffer.from([
0x00, 0x00, 0x0e, // Length: 14 bytes
0x01, // Type: HEADERS
0x04, // Flags: END_HEADERS
(streamId >> 24) & 0xFF, // Stream ID: high byte
(streamId >> 16) & 0xFF,
(streamId >> 8) & 0xFF,
streamId & 0xFF, // Stream ID: low byte
]),
Buffer.from([
0x82, // Indexed Header Field Representation (Predefined ":method: GET")
0x84, // Indexed Header Field Representation (Predefined ":path: /")
0x86, // Indexed Header Field Representation (Predefined ":scheme: http")
0x41, 0x09, // ":authority: localhost" Length: 9 bytes
0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x68, 0x6f, 0x73, 0x74,
]),
]);
client.write(headersFrame);
// Send a valid DATA frame
const dataFrame = Buffer.concat([
Buffer.from([
0x00, 0x00, 0x05, // Length: 5 bytes
0x00, // Type: DATA
0x00, // Flags: No flags
(streamId >> 24) & 0xFF, // Stream ID: high byte
(streamId >> 16) & 0xFF,
(streamId >> 8) & 0xFF,
streamId & 0xFF, // Stream ID: low byte
]),
Buffer.from('Hello', 'utf8'), // Data payload
]);
client.write(dataFrame);
// Does not wait for server to reply. Shutdown the socket
client.end();
}));
}
const server = h2.createServer();
server.on('error', common.mustNotCall());
server.on(
'session',
common.mustCall((session) => {
session.on('close', common.mustCall(() => {
server.close();
}));
}),
);
server.listen(
0,
"127.0.0.1",
common.mustCall(async () => {
await requestAndClose(server);
}),
);