mirror of
https://github.com/nodejs/node.git
synced 2025-04-29 06:19:07 +00:00
ada4abf2d1
According to the comment, this should be checking whether
`frame->hd.type` is `NGHTTP2_GOAWAY`, i.e. `0x07` and not `0x03`.
PR-URL: https://github.com/nodejs/node/pull/57644
Refs: 1b693fa03a
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Rafael Gonzaga <rafael.nunu@hotmail.com>
89 lines
2.4 KiB
JavaScript
89 lines
2.4 KiB
JavaScript
// 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,
|
|
common.mustCall(async () => {
|
|
await requestAndClose(server);
|
|
}),
|
|
);
|