fix: update stream deps (#3055)

achingbrain · web-flow · commit b2124c2db02d · 2025-03-19T12:19:32.000+01:00
Updates it-byte-stream, it-length-prefixed-stream, etc.
diff --git a/packages/connection-encrypter-plaintext/package.json b/packages/connection-encrypter-plaintext/package.json
@@ -55,7 +55,7 @@
     "@libp2p/crypto": "^5.0.15",
     "@libp2p/interface": "^2.7.0",
     "@libp2p/peer-id": "^5.1.0",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "it-stream-types": "^2.0.2",
     "protons-runtime": "^5.5.0",
     "uint8arraylist": "^2.4.8",
diff --git a/packages/interface-compliance-tests/package.json b/packages/interface-compliance-tests/package.json
@@ -122,13 +122,13 @@
     "any-signal": "^4.1.1",
     "delay": "^6.0.0",
     "it-all": "^3.0.6",
-    "it-byte-stream": "^1.1.0",
+    "it-byte-stream": "^2.0.1",
     "it-drain": "^3.0.7",
     "it-map": "^3.1.1",
     "it-ndjson": "^1.0.7",
     "it-pair": "^2.0.6",
     "it-pipe": "^3.0.1",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "it-pushable": "^3.2.3",
     "it-stream-types": "^2.0.2",
     "it-to-buffer": "^4.0.7",
diff --git a/packages/kad-dht/package.json b/packages/kad-dht/package.json
@@ -75,7 +75,7 @@
     "it-merge": "^3.0.5",
     "it-parallel": "^3.0.8",
     "it-pipe": "^3.0.1",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "it-take": "^3.0.6",
     "mortice": "^3.0.6",
     "multiformats": "^13.3.1",
diff --git a/packages/kad-dht/src/routing-table/k-bucket.ts b/packages/kad-dht/src/routing-table/k-bucket.ts
@@ -6,8 +6,7 @@ import { xor as uint8ArrayXor } from 'uint8arrays/xor'
 import { PeerDistanceList } from '../peer-distance-list.js'
 import { convertPeerId } from '../utils.js'
 import { KBUCKET_SIZE, LAST_PING_THRESHOLD, PING_OLD_CONTACT_COUNT, PREFIX_LENGTH } from './index.js'
-import type { PeerId } from '@libp2p/interface'
-import type { AbortOptions } from 'it-protobuf-stream'
+import type { PeerId, AbortOptions } from '@libp2p/interface'
 
 export interface PingFunction {
   /**
diff --git a/packages/libp2p/package.json b/packages/libp2p/package.json
@@ -107,7 +107,7 @@
     "any-signal": "^4.1.1",
     "datastore-core": "^10.0.2",
     "interface-datastore": "^8.3.1",
-    "it-byte-stream": "^1.1.0",
+    "it-byte-stream": "^2.0.1",
     "it-merge": "^3.0.5",
     "it-parallel": "^3.0.8",
     "merge-options": "^3.0.4",
diff --git a/packages/libp2p/src/connection-monitor.ts b/packages/libp2p/src/connection-monitor.ts
@@ -111,7 +111,8 @@ export class ConnectionMonitor implements Startable {
               bs.write(randomBytes(PING_LENGTH), {
                 signal
               }),
-              bs.read(PING_LENGTH, {
+              bs.read({
+                bytes: PING_LENGTH,
                 signal
               })
             ])
diff --git a/packages/multistream-select/package.json b/packages/multistream-select/package.json
@@ -60,7 +60,7 @@
   "dependencies": {
     "@libp2p/interface": "^2.7.0",
     "it-length-prefixed": "^10.0.1",
-    "it-length-prefixed-stream": "^1.2.0",
+    "it-length-prefixed-stream": "^2.0.1",
     "it-stream-types": "^2.0.2",
     "p-defer": "^4.0.1",
     "race-signal": "^1.1.2",
diff --git a/packages/pnet/package.json b/packages/pnet/package.json
@@ -52,7 +52,7 @@
   "dependencies": {
     "@libp2p/crypto": "^5.0.15",
     "@libp2p/interface": "^2.7.0",
-    "it-byte-stream": "^1.1.0",
+    "it-byte-stream": "^2.0.1",
     "it-map": "^3.1.1",
     "it-pair": "^2.0.6",
     "it-pipe": "^3.0.1",
diff --git a/packages/pnet/src/index.ts b/packages/pnet/src/index.ts
@@ -136,7 +136,8 @@ class PreSharedKeyConnectionProtector implements ConnectionProtector {
       bytes.write(localNonce, {
         signal
       }),
-      bytes.read(NONCE_LENGTH, {
+      bytes.read({
+        bytes: NONCE_LENGTH,
         signal
       })
     ])
diff --git a/packages/protocol-autonat/package.json b/packages/protocol-autonat/package.json
@@ -59,7 +59,7 @@
     "@libp2p/utils": "^6.6.0",
     "@multiformats/multiaddr": "^12.3.3",
     "any-signal": "^4.1.1",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "multiformats": "^13.3.1",
     "protons-runtime": "^5.5.0",
     "uint8arraylist": "^2.4.8"
diff --git a/packages/protocol-dcutr/package.json b/packages/protocol-dcutr/package.json
@@ -58,7 +58,7 @@
     "@multiformats/multiaddr": "^12.3.3",
     "@multiformats/multiaddr-matcher": "^1.6.0",
     "delay": "^6.0.0",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "protons-runtime": "^5.5.0",
     "uint8arraylist": "^2.4.8"
   },
diff --git a/packages/protocol-echo/package.json b/packages/protocol-echo/package.json
@@ -54,7 +54,7 @@
     "@libp2p/interface": "^2.7.0",
     "@libp2p/interface-internal": "^2.3.9",
     "@multiformats/multiaddr": "^12.3.3",
-    "it-byte-stream": "^1.1.0",
+    "it-byte-stream": "^2.0.1",
     "it-pipe": "^3.0.1"
   },
   "devDependencies": {
diff --git a/packages/protocol-echo/src/echo.ts b/packages/protocol-echo/src/echo.ts
@@ -58,7 +58,10 @@ export class Echo implements Startable, EchoInterface {
 
     const [, output] = await Promise.all([
       bytes.write(buf, options),
-      bytes.read(buf.byteLength, options)
+      bytes.read({
+        ...options,
+        bytes: buf.byteLength
+      })
     ])
 
     await stream.close(options)
diff --git a/packages/protocol-fetch/package.json b/packages/protocol-fetch/package.json
@@ -54,7 +54,7 @@
   "dependencies": {
     "@libp2p/interface": "^2.7.0",
     "@libp2p/interface-internal": "^2.3.9",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "protons-runtime": "^5.5.0",
     "uint8arraylist": "^2.4.8",
     "uint8arrays": "^5.1.0"
diff --git a/packages/protocol-identify/package.json b/packages/protocol-identify/package.json
@@ -62,7 +62,7 @@
     "@multiformats/multiaddr-matcher": "^1.6.0",
     "it-drain": "^3.0.7",
     "it-parallel": "^3.0.8",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "protons-runtime": "^5.5.0",
     "uint8arraylist": "^2.4.8",
     "uint8arrays": "^5.1.0"
diff --git a/packages/protocol-ping/package.json b/packages/protocol-ping/package.json
@@ -54,7 +54,7 @@
     "@libp2p/interface": "^2.7.0",
     "@libp2p/interface-internal": "^2.3.9",
     "@multiformats/multiaddr": "^12.3.3",
-    "it-byte-stream": "^1.1.0",
+    "it-byte-stream": "^2.0.1",
     "uint8arrays": "^5.1.0"
   },
   "devDependencies": {
diff --git a/packages/protocol-ping/src/ping.ts b/packages/protocol-ping/src/ping.ts
@@ -69,7 +69,8 @@ export class PingService implements Startable, PingServiceInterface {
           stream?.abort(new TimeoutError('ping timeout'))
         })
 
-        const buf = await bytes.read(PING_LENGTH, {
+        const buf = await bytes.read({
+          bytes: PING_LENGTH,
           signal
         })
         await bytes.write(buf, {
@@ -136,7 +137,10 @@ export class PingService implements Startable, PingServiceInterface {
 
       const [, result] = await Promise.all([
         bytes.write(data, options),
-        bytes.read(PING_LENGTH, options)
+        bytes.read({
+          ...options,
+          bytes: PING_LENGTH
+        })
       ])
 
       const ms = Date.now() - start
diff --git a/packages/transport-circuit-relay-v2/package.json b/packages/transport-circuit-relay-v2/package.json
@@ -62,7 +62,7 @@
     "@multiformats/multiaddr": "^12.3.3",
     "@multiformats/multiaddr-matcher": "^1.6.0",
     "any-signal": "^4.1.1",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "it-stream-types": "^2.0.2",
     "multiformats": "^13.3.1",
     "nanoid": "^5.0.9",
diff --git a/packages/transport-webrtc/package.json b/packages/transport-webrtc/package.json
@@ -66,7 +66,7 @@
     "detect-browser": "^5.3.0",
     "get-port": "^7.1.0",
     "it-length-prefixed": "^10.0.1",
-    "it-protobuf-stream": "^1.1.5",
+    "it-protobuf-stream": "^2.0.1",
     "it-pushable": "^3.2.3",
     "it-stream-types": "^2.0.2",
     "multiformats": "^13.3.1",
diff --git a/packages/transport-webrtc/src/private-to-private/util.ts b/packages/transport-webrtc/src/private-to-private/util.ts
@@ -6,8 +6,8 @@ import { RTCIceCandidate } from '../webrtc/index.js'
 import { Message } from './pb/message.js'
 import type { WebRTCDialEvents } from './transport.js'
 import type { RTCPeerConnection } from '../webrtc/index.js'
-import type { LoggerOptions, Stream } from '@libp2p/interface'
-import type { AbortOptions, MessageStream } from 'it-protobuf-stream'
+import type { AbortOptions, LoggerOptions, Stream } from '@libp2p/interface'
+import type { MessageStream } from 'it-protobuf-stream'
 import type { DeferredPromise } from 'p-defer'
 import type { ProgressOptions } from 'progress-events'
 
