@libp2p/autonat - npm Package Compare versions

Comparing version 2.0.14 to 2.0.15-20d9ba73e

dist/src/autonat.d.ts

@@ -11,2 +11,3 @@ import { serviceCapabilities, serviceDependencies } from '@libp2p/interface';
     private readonly maxOutboundStreams;
+    private readonly maxMessageSize;
     private started;
@@ -13,0 +14,0 @@ private readonly log;

dist/src/autonat.js

@@ -13,3 +13,3 @@ import { serviceCapabilities, serviceDependencies, setMaxListeners } from '@libp2p/interface';
 import * as Digest from 'multiformats/hashes/digest';
-import { DEFAULT_CONNECTION_THRESHOLD, MAX_INBOUND_STREAMS, MAX_OUTBOUND_STREAMS, PROTOCOL_NAME, PROTOCOL_PREFIX, PROTOCOL_VERSION, TIMEOUT } from './constants.js';
+import { DEFAULT_CONNECTION_THRESHOLD, MAX_INBOUND_STREAMS, MAX_MESSAGE_SIZE, MAX_OUTBOUND_STREAMS, PROTOCOL_NAME, PROTOCOL_PREFIX, PROTOCOL_VERSION, TIMEOUT } from './constants.js';
 import { Message } from './pb/index.js';
@@ -27,2 +27,3 @@ // if more than 3 peers manage to dial us on what we believe to be our external
     maxOutboundStreams;
+    maxMessageSize;
     started;
@@ -44,2 +45,3 @@ log;
         this.connectionThreshold = init.connectionThreshold ?? DEFAULT_CONNECTION_THRESHOLD;
+        this.maxMessageSize = init.maxMessageSize ?? MAX_MESSAGE_SIZE;
         this.dialResults = new Map();
@@ -147,3 +149,5 @@ this.findPeers = repeatingTask(this.findRandomPeers.bind(this), 60_000);
         setMaxListeners(Infinity, signal);
-        const messages = pbStream(data.stream).pb(Message);
+        const messages = pbStream(data.stream, {
+            maxDataLength: this.maxMessageSize
+        }).pb(Message);
         try {
@@ -150,0 +154,0 @@ const request = await messages.read({

dist/src/constants.d.ts

@@ -14,5 +14,6 @@ /**
 export declare const TIMEOUT = 30000;
-export declare const MAX_INBOUND_STREAMS = 1;
-export declare const MAX_OUTBOUND_STREAMS = 1;
+export declare const MAX_INBOUND_STREAMS = 2;
+export declare const MAX_OUTBOUND_STREAMS = 20;
 export declare const DEFAULT_CONNECTION_THRESHOLD = 80;
+export declare const MAX_MESSAGE_SIZE = 8192;
 //# sourceMappingURL=constants.d.ts.map

dist/src/constants.js

@@ -14,5 +14,6 @@ /**
 export const TIMEOUT = 30000;
-export const MAX_INBOUND_STREAMS = 1;
-export const MAX_OUTBOUND_STREAMS = 1;
+export const MAX_INBOUND_STREAMS = 2;
+export const MAX_OUTBOUND_STREAMS = 20;
 export const DEFAULT_CONNECTION_THRESHOLD = 80;
+export const MAX_MESSAGE_SIZE = 8192;
 //# sourceMappingURL=constants.js.map

dist/src/index.d.ts

@@ -69,2 +69,9 @@ /**
     connectionThreshold?: number;
+    /**
+     * How large incoming autonat messages are allowed to be in bytes. If messages
+     * larger than this are received the stream will be reset.
+     *
+     * @default 8192
+     */
+    maxMessageSize?: number;
 }
@@ -71,0 +78,0 @@ export interface AutoNATComponents {

package.json

 {
   "name": "@libp2p/autonat",
-  "version": "2.0.14",
+  "version": "2.0.15-20d9ba73e",
   "description": "Implementation of Autonat Protocol",
@@ -55,7 +55,7 @@ "license": "Apache-2.0 OR MIT",
   "dependencies": {
-    "@libp2p/interface": "^2.3.0",
-    "@libp2p/interface-internal": "^2.2.1",
-    "@libp2p/peer-collections": "^6.0.13",
-    "@libp2p/peer-id": "^5.0.9",
-    "@libp2p/utils": "^6.3.0",
+    "@libp2p/interface": "2.3.0-20d9ba73e",
+    "@libp2p/interface-internal": "2.2.1-20d9ba73e",
+    "@libp2p/peer-collections": "6.0.13-20d9ba73e",
+    "@libp2p/peer-id": "5.0.9-20d9ba73e",
+    "@libp2p/utils": "6.3.0-20d9ba73e",
     "@multiformats/multiaddr": "^12.3.3",
@@ -69,4 +69,4 @@ "any-signal": "^4.1.1",
   "devDependencies": {
-    "@libp2p/crypto": "^5.0.8",
-    "@libp2p/logger": "^5.1.5",
+    "@libp2p/crypto": "5.0.8-20d9ba73e",
+    "@libp2p/logger": "5.1.5-20d9ba73e",
     "aegir": "^45.0.5",
@@ -73,0 +73,0 @@ "it-all": "^3.0.6",

src/autonat.ts

@@ -13,6 +13,3 @@ import { serviceCapabilities, serviceDependencies, setMaxListeners } from '@libp2p/interface'
 import * as Digest from 'multiformats/hashes/digest'
-import {
-  DEFAULT_CONNECTION_THRESHOLD,
-  MAX_INBOUND_STREAMS, MAX_OUTBOUND_STREAMS, PROTOCOL_NAME, PROTOCOL_PREFIX, PROTOCOL_VERSION, TIMEOUT
-} from './constants.js'
+import { DEFAULT_CONNECTION_THRESHOLD, MAX_INBOUND_STREAMS, MAX_MESSAGE_SIZE, MAX_OUTBOUND_STREAMS, PROTOCOL_NAME, PROTOCOL_PREFIX, PROTOCOL_VERSION, TIMEOUT } from './constants.js'
 import { Message } from './pb/index.js'
@@ -93,2 +90,3 @@ import type { AutoNATComponents, AutoNATServiceInit } from './index.js'
   private readonly maxOutboundStreams: number
+  private readonly maxMessageSize: number
   private started: boolean
@@ -111,2 +109,3 @@ private readonly log: Logger
     this.connectionThreshold = init.connectionThreshold ?? DEFAULT_CONNECTION_THRESHOLD
+    this.maxMessageSize = init.maxMessageSize ?? MAX_MESSAGE_SIZE
     this.dialResults = new Map()
@@ -235,3 +234,5 @@ this.findPeers = repeatingTask(this.findRandomPeers.bind(this), 60_000)
 
-    const messages = pbStream(data.stream).pb(Message)
+    const messages = pbStream(data.stream, {
+      maxDataLength: this.maxMessageSize
+    }).pb(Message)
 
@@ -238,0 +239,0 @@ try {

src/constants.ts

@@ -16,4 +16,5 @@ /**
 export const TIMEOUT = 30000
-export const MAX_INBOUND_STREAMS = 1
-export const MAX_OUTBOUND_STREAMS = 1
+export const MAX_INBOUND_STREAMS = 2
+export const MAX_OUTBOUND_STREAMS = 20
 export const DEFAULT_CONNECTION_THRESHOLD = 80
+export const MAX_MESSAGE_SIZE = 8192

src/index.ts

@@ -78,2 +78,10 @@ /**
   connectionThreshold?: number
+
+  /**
+   * How large incoming autonat messages are allowed to be in bytes. If messages
+   * larger than this are received the stream will be reset.
+   *
+   * @default 8192
+   */
+  maxMessageSize?: number
 }
@@ -80,0 +88,0 @@

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

269995

increased by0.27%

Lines of code

2727

increased by0.59%

Worsened metrics

Number of package files

24

decreased by-4%

Number of low quality alerts

1

increased byInfinity%

Dependency changes

• + Added@libp2p/crypto@5.0.8-20d9ba73e(transitive)

• + Added@libp2p/interface@2.3.0-20d9ba73e(transitive)

• + Added@libp2p/interface-internal@2.2.1-20d9ba73e(transitive)

• + Added@libp2p/logger@5.1.5-20d9ba73e(transitive)

• + Added@libp2p/peer-collections@6.0.13-20d9ba73e(transitive)

• + Added@libp2p/peer-id@5.0.9-20d9ba73e(transitive)

• + Added@libp2p/utils@6.3.0-20d9ba73e(transitive)

• + Added@types/murmurhash3js-revisited@3.0.3(transitive)

• + Addedmurmurhash3js-revisited@3.0.0(transitive)

• - Removed@libp2p/crypto@5.0.12(transitive)

• - Removed@libp2p/interface@2.6.0(transitive)

• - Removed@libp2p/interface-internal@2.3.4(transitive)

• - Removed@libp2p/logger@5.1.9(transitive)

• - Removed@libp2p/peer-collections@6.0.20(transitive)

• - Removed@libp2p/peer-id@5.0.13(transitive)

• - Removed@libp2p/utils@6.5.4(transitive)

• Updated@libp2p/interface@2.3.0-20d9ba73e

• Updated@libp2p/interface-internal@2.2.1-20d9ba73e

• Updated@libp2p/peer-collections@6.0.13-20d9ba73e

• Updated@libp2p/peer-id@5.0.9-20d9ba73e

• Updated@libp2p/utils@6.3.0-20d9ba73e