libp2p - npm Package Compare versions

Comparing version 2.7.5 to 2.8.0

dist/src/upgrader.d.ts

@@ -44,3 +44,3 @@ import type { Libp2pEvents, AbortOptions, ComponentLogger, MultiaddrConnection, Connection, Stream, ConnectionProtector, ConnectionEncrypter, SecuredConnection, ConnectionGater, TypedEventTarget, Metrics, PeerId, PeerStore, StreamMuxerFactory, Upgrader as UpgraderInterface, UpgraderOptions, ConnectionLimits, SecureConnectionOptions, ClearableSignal } from '@libp2p/interface';
 }
-export interface DefaultUpgraderComponents {
+export interface UpgraderComponents {
     peerId: PeerId;
@@ -66,3 +66,3 @@ metrics?: Metrics;
     private readonly metrics;
-    constructor(components: DefaultUpgraderComponents, init: UpgraderInit);
+    constructor(components: UpgraderComponents, init: UpgraderInit);
     readonly [Symbol.toStringTag] = "@libp2p/upgrader";
@@ -114,4 +114,6 @@ shouldBlockConnection(connectionType: 'denyInboundConnection', maConn: MultiaddrConnection): Promise<void>;
     }>;
+    getConnectionEncrypters(): Map<string, ConnectionEncrypter<unknown>>;
+    getStreamMuxers(): Map<string, StreamMuxerFactory>;
 }
 export {};
 //# sourceMappingURL=upgrader.d.ts.map

dist/src/upgrader.js

@@ -179,3 +179,4 @@ import { InvalidMultiaddrError, TooManyInboundProtocolStreamsError, TooManyOutboundProtocolStreamsError, LimitedConnectionError, setMaxListeners, InvalidPeerIdError } from '@libp2p/interface';
                     remotePeer,
-                    protocol: cryptoProtocol
+                    protocol: cryptoProtocol,
+                    streamMuxer: muxerFactory
                 } = await (direction === 'inbound'
@@ -210,3 +211,3 @@ ? this._encryptInbound(protectedConn, opts)
             }
-            else if (this.streamMuxers.size > 0) {
+            else if (muxerFactory == null && this.streamMuxers.size > 0) {
                 opts?.onProgress?.(new CustomProgressEvent(`upgrader:multiplex-${direction}-connection`));
@@ -557,3 +558,9 @@ // Multiplex the connection
     }
+    getConnectionEncrypters() {
+        return this.connectionEncrypters;
+    }
+    getStreamMuxers() {
+        return this.streamMuxers;
+    }
 }
 //# sourceMappingURL=upgrader.js.map

dist/src/version.d.ts

@@ -1,3 +0,3 @@
-export declare const version = "2.7.5";
+export declare const version = "2.8.0";
 export declare const name = "js-libp2p";
 //# sourceMappingURL=version.d.ts.map

dist/src/version.js

@@ -1,3 +0,3 @@
-export const version = '2.7.5';
+export const version = '2.8.0';
 export const name = 'js-libp2p';
 //# sourceMappingURL=version.js.map

package.json

 {
   "name": "libp2p",
-  "version": "2.7.5",
+  "version": "2.8.0",
   "description": "JavaScript implementation of libp2p, a modular peer to peer network stack",
@@ -95,11 +95,11 @@ "license": "Apache-2.0 OR MIT",
     "@chainsafe/netmask": "^2.0.0",
-    "@libp2p/crypto": "^5.0.14",
-    "@libp2p/interface": "^2.6.1",
-    "@libp2p/interface-internal": "^2.3.6",
-    "@libp2p/logger": "^5.1.11",
-    "@libp2p/multistream-select": "^6.0.18",
-    "@libp2p/peer-collections": "^6.0.22",
-    "@libp2p/peer-id": "^5.0.15",
-    "@libp2p/peer-store": "^11.0.22",
-    "@libp2p/utils": "^6.5.6",
+    "@libp2p/crypto": "^5.0.15",
+    "@libp2p/interface": "^2.7.0",
+    "@libp2p/interface-internal": "^2.3.7",
+    "@libp2p/logger": "^5.1.12",
+    "@libp2p/multistream-select": "^6.0.19",
+    "@libp2p/peer-collections": "^6.0.23",
+    "@libp2p/peer-id": "^5.0.16",
+    "@libp2p/peer-store": "^11.1.0",
+    "@libp2p/utils": "^6.5.7",
     "@multiformats/dns": "^1.0.6",
@@ -106,0 +106,0 @@ "@multiformats/multiaddr": "^12.3.5",

src/upgrader.ts

@@ -103,3 +103,3 @@ import { InvalidMultiaddrError, TooManyInboundProtocolStreamsError, TooManyOutboundProtocolStreamsError, LimitedConnectionError, setMaxListeners, InvalidPeerIdError } from '@libp2p/interface'
 
-export interface DefaultUpgraderComponents {
+export interface UpgraderComponents {
   peerId: PeerId
@@ -119,3 +119,3 @@ metrics?: Metrics
 export class Upgrader implements UpgraderInterface {
-  private readonly components: DefaultUpgraderComponents
+  private readonly components: UpgraderComponents
   private readonly connectionEncrypters: Map<string, ConnectionEncrypter>
@@ -132,3 +132,3 @@ private readonly streamMuxers: Map<string, StreamMuxerFactory>
 
-  constructor (components: DefaultUpgraderComponents, init: UpgraderInit) {
+  constructor (components: UpgraderComponents, init: UpgraderInit) {
     this.components = components
@@ -292,3 +292,4 @@ this.connectionEncrypters = new Map()
           remotePeer,
-          protocol: cryptoProtocol
+          protocol: cryptoProtocol,
+          streamMuxer: muxerFactory
         } = await (direction === 'inbound'
@@ -329,3 +330,3 @@ ? this._encryptInbound(protectedConn, opts)
         muxerFactory = opts.muxerFactory
-      } else if (this.streamMuxers.size > 0) {
+      } else if (muxerFactory == null && this.streamMuxers.size > 0) {
         opts?.onProgress?.(new CustomProgressEvent(`upgrader:multiplex-${direction}-connection`))
@@ -754,2 +755,10 @@
   }
+
+  getConnectionEncrypters (): Map<string, ConnectionEncrypter<unknown>> {
+    return this.connectionEncrypters
+  }
+
+  getStreamMuxers (): Map<string, StreamMuxerFactory> {
+    return this.streamMuxers
+  }
 }

src/version.ts

@@ -1,2 +0,2 @@
-export const version = '2.7.5'
+export const version = '2.8.0'
 export const name = 'js-libp2p'

No alert changes

Improved metrics

Total package byte prevSize

961618

increased by0.29%

Lines of code

12443

increased by0.19%

Dependency changes

• Updated@libp2p/crypto@^5.0.15

• Updated@libp2p/interface@^2.7.0

• Updated@libp2p/interface-internal@^2.3.7

• Updated@libp2p/logger@^5.1.12

• Updated@libp2p/multistream-select@^6.0.19

• Updated@libp2p/peer-collections@^6.0.23

• Updated@libp2p/peer-id@^5.0.16

• Updated@libp2p/peer-store@^11.1.0

• Updated@libp2p/utils@^6.5.7