ci: merge staging to master

package.json

@@ -1,6 +1,6 @@
 {
   "name": "polykey",
-  "version": "1.16.4",
+  "version": "1.17.0",
   "homepage": "https://polykey.com",
   "author": "Matrix AI",
   "contributors": [
@@ -78,7 +78,7 @@
     "@matrixai/id": "^3.3.6",
     "@matrixai/logger": "^3.1.2",
     "@matrixai/mdns": "^1.2.6",
-    "@matrixai/quic": "^1.3.1",
+    "@matrixai/quic": "^1.3.2",
     "@matrixai/resources": "^1.1.5",
     "@matrixai/rpc": "^0.6.2",
     "@matrixai/timer": "^1.1.3",

src/PolykeyAgent.ts

@@ -99,6 +99,8 @@ type PolykeyAgentOptions = {
     connectionKeepAliveTimeoutTime: number;
     connectionKeepAliveIntervalTime: number;
     connectionHolePunchIntervalTime: number;
+    connectionInitialMaxStreamsBidi: number;
+    connectionInitialMaxStreamsUni: number;
     rpcCallTimeoutTime: number;
     rpcParserBufferSize: number;
     dnsServers: Array<string> | undefined;
@@ -196,6 +198,10 @@ class PolykeyAgent {
           config.defaultsSystem.nodesConnectionKeepAliveIntervalTime,
         connectionHolePunchIntervalTime:
           config.defaultsSystem.nodesConnectionHolePunchIntervalTime,
+        connectionInitialMaxStreamsBidi:
+          config.defaultsSystem.nodesConnectionInitialMaxStreamsBidi,
+        connectionInitialMaxStreamsUni:
+          config.defaultsSystem.nodesConnectionInitialMaxStreamsUni,
       },
       mdns: {
         groups: config.defaultsSystem.mdnsGroups,
@@ -374,6 +380,10 @@ class PolykeyAgent {
           optionsDefaulted.nodes.connectionKeepAliveIntervalTime,
         connectionHolePunchIntervalTime:
           optionsDefaulted.nodes.connectionHolePunchIntervalTime,
+        connectionInitialMaxStreamsBidi:
+          optionsDefaulted.nodes.connectionInitialMaxStreamsBidi,
+        connectionInitialMaxStreamsUni:
+          optionsDefaulted.nodes.connectionInitialMaxStreamsBidi,
         rpcParserBufferSize: optionsDefaulted.nodes.rpcParserBufferSize,
         rpcCallTimeoutTime: optionsDefaulted.nodes.rpcCallTimeoutTime,
         logger: logger.getChild(NodeConnectionManager.name),

src/config.ts

@@ -251,6 +251,9 @@ const config = {
      * Interval for hole punching reverse node connections.
      */
     nodesConnectionHolePunchIntervalTime: 1_000, // 1 second
+    nodesConnectionInitialMaxStreamsBidi: 1_000,
+    nodesConnectionInitialMaxStreamsUni: 0, // We don't use unidirectional streams so we disable them
+
     /**
      * Interval for refreshing buckets.
      *

src/nodes/NodeConnection.ts

@@ -171,6 +171,10 @@ class NodeConnection {
       connectionKeepAliveIntervalTime,
       connectionKeepAliveTimeoutTime = config.defaultsSystem
         .nodesConnectionIdleTimeoutTimeMin,
+      connectionInitialMaxStreamsBidi = config.defaultsSystem
+        .nodesConnectionInitialMaxStreamsBidi,
+      connectionInitialMaxStreamsUni = config.defaultsSystem
+        .nodesConnectionInitialMaxStreamsUni,
       quicSocket,
       manifest,
       logger,
@@ -182,6 +186,8 @@ class NodeConnection {
       tlsConfig: TLSConfig;
       connectionKeepAliveIntervalTime?: number;
       connectionKeepAliveTimeoutTime?: number;
+      connectionInitialMaxStreamsBidi?: number;
+      connectionInitialMaxStreamsUni?: number;
       quicSocket?: QUICSocket;
       manifest: AgentClientManifest;
       logger?: Logger;
@@ -203,6 +209,10 @@ class NodeConnection {
       connectionKeepAliveIntervalTime,
       connectionKeepAliveTimeoutTime = config.defaultsSystem
         .nodesConnectionIdleTimeoutTimeMin,
+      connectionInitialMaxStreamsBidi = config.defaultsSystem
+        .nodesConnectionInitialMaxStreamsBidi,
+      connectionInitialMaxStreamsUni = config.defaultsSystem
+        .nodesConnectionInitialMaxStreamsUni,
       quicSocket,
       logger = new Logger(this.name),
     }: {
@@ -214,6 +224,8 @@ class NodeConnection {
       manifest: AgentClientManifest;
       connectionKeepAliveIntervalTime?: number;
       connectionKeepAliveTimeoutTime?: number;
+      connectionInitialMaxStreamsBidi?: number;
+      connectionInitialMaxStreamsUni?: number;
       quicSocket: QUICSocket;
       logger?: Logger;
     },
@@ -255,6 +267,8 @@ class NodeConnection {
             ca: undefined,
             key: tlsConfig.keyPrivatePem,
             cert: tlsConfig.certChainPem,
+            initialMaxStreamsBidi: connectionInitialMaxStreamsBidi,
+            initialMaxStreamsUni: connectionInitialMaxStreamsUni,
           },
           crypto: nodesUtils.quicClientCrypto,
           reasonToCode: nodesUtils.reasonToCode,

src/nodes/NodeConnectionManager.ts

@@ -143,6 +143,16 @@ class NodeConnectionManager {
    */
   public readonly connectionHolePunchIntervalTime: number;
 
+  /**
+   * Total number of active bidirectional streams that can be created
+   */
+  public readonly connectionInitialMaxStreamsBidi: number;
+
+  /**
+   * Total number of active unidirectional streams that can be created
+   */
+  public readonly connectionInitialMaxStreamsUni: number;
+
   /**
    * Max parse buffer size before RPC parser throws an parse error.
    */
@@ -370,9 +380,12 @@ class NodeConnectionManager {
       .nodesConnectionKeepAliveIntervalTime,
     connectionHolePunchIntervalTime = config.defaultsSystem
       .nodesConnectionHolePunchIntervalTime,
+    connectionInitialMaxStreamsBidi = config.defaultsSystem
+      .nodesConnectionInitialMaxStreamsBidi,
+    connectionInitialMaxStreamsUni = config.defaultsSystem
+      .nodesConnectionInitialMaxStreamsUni,
     rpcParserBufferSize = config.defaultsSystem.rpcParserBufferSize,
     rpcCallTimeoutTime = config.defaultsSystem.rpcCallTimeoutTime,
-
     logger,
   }: {
     keyRing: KeyRing;
@@ -386,6 +399,8 @@ class NodeConnectionManager {
     connectionKeepAliveTimeoutTime?: number;
     connectionKeepAliveIntervalTime?: number;
     connectionHolePunchIntervalTime?: number;
+    connectionInitialMaxStreamsBidi?: number;
+    connectionInitialMaxStreamsUni?: number;
     rpcParserBufferSize?: number;
     rpcCallTimeoutTime?: number;
     logger?: Logger;
@@ -402,6 +417,8 @@ class NodeConnectionManager {
     this.connectionKeepAliveTimeoutTime = connectionKeepAliveTimeoutTime;
     this.connectionKeepAliveIntervalTime = connectionKeepAliveIntervalTime;
     this.connectionHolePunchIntervalTime = connectionHolePunchIntervalTime;
+    this.connectionInitialMaxStreamsBidi = connectionInitialMaxStreamsBidi;
+    this.connectionInitialMaxStreamsUni = connectionInitialMaxStreamsUni;
     this.rpcParserBufferSize = rpcParserBufferSize;
     this.rpcCallTimeoutTime = rpcCallTimeoutTime;
 
@@ -422,6 +439,8 @@ class NodeConnectionManager {
         cert: tlsConfig.certChainPem,
         verifyPeer: true,
         verifyCallback: nodesUtils.verifyClientCertificateChain,
+        initialMaxStreamsBidi: 1000,
+        initialMaxStreamsUni: 0,
       },
       socket: quicSocket,
       reasonToCode: nodesUtils.reasonToCode,
@@ -736,6 +755,8 @@ class NodeConnectionManager {
         tlsConfig: this.tlsConfig,
         connectionKeepAliveIntervalTime: this.connectionKeepAliveIntervalTime,
         connectionKeepAliveTimeoutTime: this.connectionKeepAliveTimeoutTime,
+        connectionInitialMaxStreamsBidi: this.connectionInitialMaxStreamsBidi,
+        connectionInitialMaxStreamsUni: this.connectionInitialMaxStreamsUni,
         quicSocket: this.quicSocket,
         logger: this.logger.getChild(
           `${NodeConnection.name}Forward [${host}:${port}]`,