deps: bump it-length-prefixed from 8.0.4 to 9.0.0 (#1672)

* deps: bump it-length-prefixed from 8.0.4 to 9.0.0

Bumps [it-length-prefixed](https://github.com/alanshaw/it-length-prefixed) from 8.0.4 to 9.0.0.
- [Release notes](https://github.com/alanshaw/it-length-prefixed/releases)
- [Changelog](https://github.com/alanshaw/it-length-prefixed/blob/master/CHANGELOG.md)
- [Commits](alanshaw/it-length-prefixed@v8.0.4...v9.0.0)

---
updated-dependencies:
- dependency-name: it-length-prefixed
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <[email protected]>

* chore: fix build

---------

Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: achingbrain <[email protected]>

package.json

@@ -144,7 +144,7 @@
     "it-filter": "^3.0.1",
     "it-first": "^3.0.1",
     "it-handshake": "^4.1.2",
-    "it-length-prefixed": "^8.0.2",
+    "it-length-prefixed": "^9.0.0",
     "it-map": "^3.0.2",
     "it-merge": "^3.0.0",
     "it-pair": "^2.0.2",

src/autonat/index.ts

@@ -150,7 +150,7 @@ export class AutonatService implements Startable {
 
       await pipe(
         source,
-        lp.decode(),
+        (source) => lp.decode(source),
         async function * (stream) {
           const buf = await first(stream)
 
@@ -357,7 +357,7 @@ export class AutonatService implements Startable {
             }
           })
         },
-        lp.encode(),
+        (source) => lp.encode(source),
         // pipe to the stream, not the abortable source other wise we
         // can't tell the remote when a dial timed out..
         data.stream
@@ -446,9 +446,9 @@ export class AutonatService implements Startable {
 
           const buf = await pipe(
             [request],
-            lp.encode(),
+            (source) => lp.encode(source),
             source,
-            lp.decode(),
+            (source) => lp.decode(source),
             async (stream) => await first(stream)
           )
           if (buf == null) {

src/fetch/index.ts

@@ -127,9 +127,9 @@ export class FetchService implements Startable {
 
       const result = await pipe(
         [FetchRequest.encode({ identifier: key })],
-        lp.encode(),
+        (source) => lp.encode(source),
         source,
-        lp.decode(),
+        (source) => lp.decode(source),
         async function (source) {
           const buf = await first(source)
 
@@ -184,7 +184,7 @@ export class FetchService implements Startable {
 
     await pipe(
       stream,
-      lp.decode(),
+      (source) => lp.decode(source),
       async function * (source) {
         const buf = await first(source)
 
@@ -215,7 +215,7 @@ export class FetchService implements Startable {
 
         yield FetchResponse.encode(response)
       },
-      lp.encode(),
+      (source) => lp.encode(source),
       stream
     )
   }

src/identify/index.ts

@@ -197,7 +197,7 @@ export class IdentifyService implements Startable {
             signedPeerRecord,
             protocols
           })],
-          lp.encode()
+          (source) => lp.encode(source)
         ))
       } catch (err: any) {
         // Just log errors
@@ -266,7 +266,7 @@ export class IdentifyService implements Startable {
       const data = await pipe(
         [],
         source,
-        lp.decode({
+        (source) => lp.decode(source, {
           maxDataLength: this.init.maxIdentifyMessageSize ?? MAX_IDENTIFY_MESSAGE_SIZE
         }),
         async (source) => await first(source)
@@ -431,7 +431,7 @@ export class IdentifyService implements Startable {
       // make stream abortable
       const source = abortableDuplex(stream, timeoutController.signal)
 
-      const msgWithLenPrefix = pipe([message], lp.encode())
+      const msgWithLenPrefix = pipe([message], (source) => lp.encode(source))
       await source.sink(msgWithLenPrefix)
     } catch (err: any) {
       log.error('could not respond to identify request', err)
@@ -461,7 +461,7 @@ export class IdentifyService implements Startable {
       const data = await pipe(
         [],
         source,
-        lp.decode({
+        (source) => lp.decode(source, {
           maxDataLength: this.init.maxIdentifyMessageSize ?? MAX_IDENTIFY_MESSAGE_SIZE
         }),
         async (source) => await first(source)

src/insecure/index.ts

@@ -71,8 +71,12 @@ async function encrypt (localId: PeerId, conn: Duplex<Uint8Array>, remoteId?: Pe
   log('write pubkey exchange to peer %p', remoteId)
 
   // Get the Exchange message
-  // @ts-expect-error needs to be generator
   const response = (await lp.decode.fromReader(shake.reader).next()).value
+
+  if (response == null) {
+    throw new Error('Did not read response')
+  }
+
   const id = Exchange.decode(response)
   log('read pubkey exchange from peer %p', remoteId)
 

test/autonat/index.spec.ts

@@ -485,7 +485,7 @@ describe('autonat', () => {
 
       const slice = await pipe(
         sink,
-        lp.decode(),
+        (source) => lp.decode(source),
         async source => await all(source)
       )
 

test/identify/index.spec.ts

@@ -203,7 +203,7 @@ describe('identify', () => {
 
         await pipe(
           [message],
-          lp.encode(),
+          (source) => lp.encode(source),
           stream,
           drain
         )
@@ -305,7 +305,7 @@ describe('identify', () => {
       void Promise.resolve().then(async () => {
         await pipe(
           [data],
-          lp.encode(),
+          (source) => lp.encode(source),
           stream,
           async (source) => { await drain(source) }
         )
@@ -351,7 +351,7 @@ describe('identify', () => {
       void Promise.resolve().then(async () => {
         await pipe(
           [data],
-          lp.encode(),
+          (source) => lp.encode(source),
           async (source) => {
             await stream.sink(async function * () {
               for await (const buf of source) {