quic: move HTTP/3 protocol machinery into node:http3

Move nghttp3 integration, and header/priority/settings/datagram-framing
logic out of node:quic core into node:http3, leaving node:quic
as a pure transport-only layer.

Author: pimterry

lib/internal/quic/http3.js

@@ -71,9 +71,9 @@ const {
   IDX_STATE_SESSION_HANDSHAKE_CONFIRMED,
   IDX_STATE_SESSION_STREAM_OPEN_ALLOWED,
   IDX_STATE_SESSION_PRIORITY_SUPPORTED,
-  IDX_STATE_SESSION_HEADERS_SUPPORTED,
   IDX_STATE_SESSION_WRAPPED,
-  IDX_STATE_SESSION_APPLICATION_TYPE,
+  IDX_STATE_SESSION_IS_SERVER,
+  IDX_STATE_SESSION_HAS_APPLICATION,
   IDX_STATE_SESSION_NO_ERROR_CODE,
   IDX_STATE_SESSION_INTERNAL_ERROR_CODE,
   IDX_STATE_SESSION_MAX_DATAGRAM_SIZE,
@@ -117,9 +117,9 @@ assert(IDX_STATE_SESSION_HANDSHAKE_COMPLETED !== undefined);
 assert(IDX_STATE_SESSION_HANDSHAKE_CONFIRMED !== undefined);
 assert(IDX_STATE_SESSION_STREAM_OPEN_ALLOWED !== undefined);
 assert(IDX_STATE_SESSION_PRIORITY_SUPPORTED !== undefined);
-assert(IDX_STATE_SESSION_HEADERS_SUPPORTED !== undefined);
+assert(IDX_STATE_SESSION_HAS_APPLICATION !== undefined);
+assert(IDX_STATE_SESSION_IS_SERVER !== undefined);
 assert(IDX_STATE_SESSION_WRAPPED !== undefined);
-assert(IDX_STATE_SESSION_APPLICATION_TYPE !== undefined);
 assert(IDX_STATE_SESSION_NO_ERROR_CODE !== undefined);
 assert(IDX_STATE_SESSION_INTERNAL_ERROR_CODE !== undefined);
 assert(IDX_STATE_SESSION_MAX_DATAGRAM_SIZE !== undefined);
@@ -349,7 +349,6 @@ class QuicSessionState {
   static #LISTENER_SESSION_TICKET = 1 << 3;
   static #LISTENER_NEW_TOKEN = 1 << 4;
   static #LISTENER_ORIGIN = 1 << 5;
-  static #LISTENER_APPLICATION = 1 << 6;
 
   #getListenerFlag(flag) {
     const handle = this.#handle;
@@ -368,13 +367,6 @@ class QuicSessionState {
       val ? (current | flag) : (current & ~flag), kIsLittleEndian);
   }
 
-  /** @type {boolean} */
-  get hasApplicationListener() {
-    return this.#getListenerFlag(QuicSessionState.#LISTENER_APPLICATION);
-  }
-  set hasApplicationListener(val) {
-    this.#setListenerFlag(QuicSessionState.#LISTENER_APPLICATION, val);
-  }
 
   /** @type {boolean} */
   get hasPathValidationListener() {
@@ -481,14 +473,14 @@ class QuicSessionState {
   }
 
   /**
-   * Whether the negotiated application protocol supports headers.
-   * Returns 0 (unknown), 1 (supported), or 2 (not supported).
-   * @type {number}
+   * Whether a protocol application (vs the native raw-stream path) is
+   * installed on the session.
+   * @type {boolean}
    */
-  get headersSupported() {
+  get hasApplication() {
     const handle = this.#handle;
     if (handle === undefined) return undefined;
-    return DataViewPrototypeGetUint8(handle, this.#offset + IDX_STATE_SESSION_HEADERS_SUPPORTED);
+    return DataViewPrototypeGetUint8(handle, this.#offset + IDX_STATE_SESSION_HAS_APPLICATION) !== 0;
   }
 
   /** @type {boolean} */
@@ -498,17 +490,21 @@ class QuicSessionState {
     return DataViewPrototypeGetUint8(handle, this.#offset + IDX_STATE_SESSION_WRAPPED) !== 0;
   }
 
-  /** @type {number} */
-  get applicationType() {
+  /**
+   * True for server (accepted) sessions, false for client (initiated)
+   * sessions. Fixed for the session's lifetime.
+   * @type {boolean}
+   */
+  get isServer() {
     const handle = this.#handle;
     if (handle === undefined) return undefined;
-    return DataViewPrototypeGetUint8(handle, this.#offset + IDX_STATE_SESSION_APPLICATION_TYPE);
+    return DataViewPrototypeGetUint8(handle, this.#offset + IDX_STATE_SESSION_IS_SERVER) !== 0;
   }
 
   /**
-   * The negotiated application protocol's "no error" code, populated
-   * by the C++ layer when the application is selected during ALPN
-   * negotiation. For raw QUIC this is `0n`; for HTTP/3 this is
+   * The installed application's "no error" code, populated
+   * by the C++ layer when the application is installed.
+   * For raw QUIC this is `0n`; for HTTP/3 this is
    * `0x100n` (`H3_NO_ERROR`).
    * @type {bigint}
    */
@@ -520,7 +516,7 @@ class QuicSessionState {
   }
 
   /**
-   * The negotiated application protocol's "internal error" code,
+   * The installed application's "internal error" code,
    * populated by the C++ layer when the application is selected
    * during ALPN negotiation. Used as the wire code for `RESET_STREAM`
    * frames when a stream is aborted without a more specific code.
@@ -589,9 +585,9 @@ class QuicSessionState {
       isHandshakeConfirmed,
       isStreamOpenAllowed,
       isPrioritySupported,
-      headersSupported,
+      hasApplication,
       isWrapped,
-      applicationType,
+      isServer,
       noErrorCode,
       internalErrorCode,
       maxDatagramSize,
@@ -614,9 +610,9 @@ class QuicSessionState {
       isHandshakeConfirmed,
       isStreamOpenAllowed,
       isPrioritySupported,
-      headersSupported,
+      hasApplication,
       isWrapped,
-      applicationType,
+      isServer,
       noErrorCode: `${noErrorCode}`,
       internalErrorCode: `${internalErrorCode}`,
       maxDatagramSize: `${maxDatagramSize}`,
@@ -655,9 +651,9 @@ class QuicSessionState {
       isHandshakeConfirmed,
       isStreamOpenAllowed,
       isPrioritySupported,
-      headersSupported,
+      hasApplication,
       isWrapped,
-      applicationType,
+      isServer,
       noErrorCode,
       internalErrorCode,
       maxDatagramSize,
@@ -680,9 +676,9 @@ class QuicSessionState {
       isHandshakeConfirmed,
       isStreamOpenAllowed,
       isPrioritySupported,
-      headersSupported,
+      hasApplication,
       isWrapped,
-      applicationType,
+      isServer,
       noErrorCode,
       internalErrorCode,
       maxDatagramSize,

lib/internal/quic/quic.js

@@ -35,29 +35,22 @@ const kDatagram = Symbol('kDatagram');
 const kDatagramStatus = Symbol('kDatagramStatus');
 const kEarlyDataRejected = Symbol('kEarlyDataRejected');
 const kFinishClose = Symbol('kFinishClose');
-const kGoaway = Symbol('kGoaway');
 const kHandshake = Symbol('kHandshake');
 const kHandshakeCompleted = Symbol('kHandshakeCompleted');
 const kVerifyPeer = Symbol('kVerifyPeer');
-const kHeaders = Symbol('kHeaders');
 const kKeylog = Symbol('kKeylog');
 const kListen = Symbol('kListen');
 const kQlog = Symbol('kQlog');
 const kNewSession = Symbol('kNewSession');
 const kNewStream = Symbol('kNewStream');
 const kNewToken = Symbol('kNewToken');
-const kStreamCallbacks = Symbol('kStreamCallbacks');
-const kOrigin = Symbol('kOrigin');
 const kOwner = Symbol('kOwner');
 const kPathValidation = Symbol('kPathValidation');
 const kPrivateConstructor = Symbol('kPrivateConstructor');
 const kRemoveSession = Symbol('kRemoveSession');
 const kRemoveStream = Symbol('kRemoveStream');
 const kReset = Symbol('kReset');
-const kSendHeaders = Symbol('kSendHeaders');
-const kSessionApplication = Symbol('kSessionApplication');
 const kSessionTicket = Symbol('kSessionTicket');
-const kTrailers = Symbol('kTrailers');
 const kVersionNegotiation = Symbol('kVersionNegotiation');
 
 module.exports = {
@@ -69,31 +62,24 @@ module.exports = {
   kDrain,
   kEarlyDataRejected,
   kFinishClose,
-  kGoaway,
   kHandshake,
   kHandshakeCompleted,
   kVerifyPeer,
-  kHeaders,
   kInspect,
   kKeylog,
   kKeyObjectHandle,
   kListen,
   kNewSession,
   kNewStream,
   kNewToken,
-  kStreamCallbacks,
-  kOrigin,
   kOwner,
   kQlog,
   kPathValidation,
   kPrivateConstructor,
   kRemoveSession,
   kRemoveStream,
   kReset,
-  kSendHeaders,
-  kSessionApplication,
   kSessionTicket,
-  kTrailers,
   kVersionNegotiation,
 };