deps!: update to [email protected] deps (#241)

Updates all libp2p deps.

BREAKING CHANGE: can only be used with the latest versions of `@libp2p/peer-id`, `@libp2p/interface` etc

Author: achingbrain

package.json

@@ -152,9 +152,10 @@
     "@ipld/dag-cbor": "^9.0.0",
     "@ipld/dag-json": "^10.0.0",
     "@ipld/dag-pb": "^4.0.0",
-    "@libp2p/interface": "^1.2.0",
-    "@libp2p/logger": "^4.0.10",
-    "@libp2p/peer-id": "^4.0.10",
+    "@libp2p/crypto": "^5.0.0",
+    "@libp2p/interface": "^2.0.0",
+    "@libp2p/logger": "^5.0.0",
+    "@libp2p/peer-id": "^5.0.0",
     "@multiformats/multiaddr": "^12.2.1",
     "@multiformats/multiaddr-to-uri": "^10.0.1",
     "any-signal": "^4.1.1",
@@ -184,21 +185,19 @@
   },
   "devDependencies": {
     "@ipld/car": "^5.0.3",
-    "@libp2p/crypto": "^4.0.6",
-    "@libp2p/peer-id-factory": "^4.0.10",
     "@types/pako": "^2.0.3",
     "@types/readable-stream": "^4.0.11",
     "@types/sinon": "^17.0.3",
     "@web-std/file": "^3.0.3",
     "aegir": "^44.0.1",
-    "blockstore-core": "^4.4.1",
+    "blockstore-core": "^5.0.0",
     "buffer": "^6.0.3",
     "delay": "^6.0.0",
     "did-jwt": "^8.0.4",
     "interface-blockstore": "^5.2.10",
     "ipfs-unixfs-importer": "^15.2.5",
-    "ipfsd-ctl": "^14.0.0",
-    "ipns": "^9.1.0",
+    "ipfsd-ctl": "^14.1.3",
+    "ipns": "^10.0.0",
     "is-ipfs": "^8.0.1",
     "iso-random-stream": "^2.0.2",
     "it-buffer-stream": "^3.0.0",
@@ -237,5 +236,9 @@
     "fs/promises": false,
     "node:fs/promises": false
   },
-  "sideEffects": false
+  "sideEffects": false,
+  "overrides": {
+    "@libp2p/interface": "^2.0.0",
+    "@libp2p/logger": "^5.0.0"
+  }
 }

src/lib/errors.ts

@@ -21,3 +21,10 @@ export class HTTPError extends Error {
     this.response = response
   }
 }
+
+export class InvalidMtimeError extends Error {
+  constructor (message = 'Invalid mtime') {
+    super(message)
+    this.name = 'InvalidMtimeError'
+  }
+}

src/lib/files/normalise-content.browser.ts

@@ -1,4 +1,4 @@
-import { CodeError } from '@libp2p/interface'
+import { InvalidParametersError } from '@libp2p/interface'
 import browserStreamToIt from 'browser-readablestream-to-it'
 import all from 'it-all'
 import itPeekable from 'it-peekable'
@@ -59,7 +59,7 @@ export async function normaliseContent (input: ToContent): Promise<Blob> {
   }
 
   // eslint-disable-next-line @typescript-eslint/no-base-to-string
-  throw new CodeError(`Unexpected input: ${input}`, 'ERR_UNEXPECTED_INPUT')
+  throw new InvalidParametersError(`Unexpected input: ${input}`)
 }
 
 async function itToBlob (stream: AsyncIterable<BlobPart> | Iterable<BlobPart>): Promise<Blob> {

src/lib/files/normalise-content.ts

@@ -1,4 +1,4 @@
-import { CodeError } from '@libp2p/interface'
+import { InvalidParametersError } from '@libp2p/interface'
 import blobToIt from 'blob-to-it'
 import browserStreamToIt from 'browser-readablestream-to-it'
 import all from 'it-all'
@@ -66,7 +66,7 @@ export async function normaliseContent (input: ToContent): Promise<AsyncIterable
   }
 
   // eslint-disable-next-line @typescript-eslint/no-base-to-string
-  throw new CodeError(`Unexpected input: ${input}`, 'ERR_UNEXPECTED_INPUT')
+  throw new InvalidParametersError(`Unexpected input: ${input}`)
 }
 
 function toBytes (chunk: ArrayBuffer | ArrayBufferView | string | InstanceType<typeof window.String> | number[]): Uint8Array {

src/lib/files/utils.ts

@@ -1,4 +1,4 @@
-import { CodeError } from '@libp2p/interface'
+import { InvalidMtimeError } from '../errors.js'
 import type { ImportCandidate } from '../../index.js'
 import type { Mtime, MtimeLike } from 'ipfs-unixfs'
 
@@ -103,7 +103,7 @@ export function parseMtime (mtime?: MtimeLike): Mtime | undefined {
   }
 
   if (mtime.nsecs != null && (mtime.nsecs < 0 || mtime.nsecs > 999999999)) {
-    throw new CodeError('mtime-nsecs must be within the range [0,999999999]', 'ERR_INVALID_MTIME_NSECS')
+    throw new InvalidMtimeError('mtime-nsecs must be within the range [0,999999999]')
   }
 
   return mtime

src/lib/glob-source.ts

@@ -2,7 +2,7 @@ import fs from 'node:fs'
 import fsp from 'node:fs/promises'
 import os from 'node:os'
 import Path from 'node:path'
-import { CodeError } from '@libp2p/interface'
+import { InvalidParametersError } from '@libp2p/interface'
 import glob from 'it-glob'
 import type { MtimeLike } from 'ipfs-unixfs'
 import type { Options as GlobOptions } from 'it-glob'
@@ -53,7 +53,7 @@ export async function * globSource (cwd: string, pattern: string, options?: Glob
   options = options ?? {}
 
   if (typeof pattern !== 'string') {
-    throw new CodeError('Pattern must be a string', 'ERR_INVALID_PATH', { pattern })
+    throw new InvalidParametersError('Pattern must be a string')
   }
 
   if (!Path.isAbsolute(cwd)) {

src/lib/pins/normalise-input.ts

@@ -1,4 +1,4 @@
-import { CodeError } from '@libp2p/interface'
+import { InvalidParametersError } from '@libp2p/interface'
 import { CID } from 'multiformats/cid'
 
 export interface Pinnable {
@@ -56,7 +56,7 @@ function isCID (thing: any): thing is CID {
 export async function * normaliseInput (input: Source): AsyncGenerator<Pin> {
   // must give us something
   if (input === null || input === undefined) {
-    throw new CodeError(`Unexpected input: ${input}`, 'ERR_UNEXPECTED_INPUT')
+    throw new InvalidParametersError(`Unexpected input: ${input}`)
   }
 
   // CID
@@ -115,7 +115,7 @@ export async function * normaliseInput (input: Source): AsyncGenerator<Pin> {
       return
     }
 
-    throw new CodeError(`Unexpected input: ${typeof input}`, 'ERR_UNEXPECTED_INPUT')
+    throw new InvalidParametersError(`Unexpected input: ${typeof input}`)
   }
 
   // AsyncIterable<?>
@@ -151,17 +151,17 @@ export async function * normaliseInput (input: Source): AsyncGenerator<Pin> {
       return
     }
 
-    throw new CodeError(`Unexpected input: ${typeof input}`, 'ERR_UNEXPECTED_INPUT')
+    throw new InvalidParametersError(`Unexpected input: ${typeof input}`)
   }
 
-  throw new CodeError(`Unexpected input: ${typeof input}`, 'ERR_UNEXPECTED_INPUT')
+  throw new InvalidParametersError(`Unexpected input: ${typeof input}`)
 }
 
 function toPin (input: Pinnable): Pin {
   const path = input.cid ?? `${input.path}`
 
   if (path == null) {
-    throw new CodeError('Unexpected input: Please path either a CID or an IPFS path', 'ERR_UNEXPECTED_INPUT')
+    throw new InvalidParametersError('Unexpected input: Please path either a CID or an IPFS path')
   }
 
   const pin: Pin = {

src/pubsub/subscribe.ts

@@ -1,3 +1,4 @@
+import { publicKeyFromProtobuf } from '@libp2p/crypto/keys'
 import { logger } from '@libp2p/logger'
 import { peerIdFromString } from '@libp2p/peer-id'
 import { textToUrlSafeRpc, rpcToText, rpcToBytes, rpcToBigInt } from '../lib/http-rpc-wire-format.js'
@@ -104,7 +105,8 @@ async function readMessages (response: ExtendedResponse, { onMessage, onEnd, onE
             data: rpcToBytes(msg.data),
             sequenceNumber: rpcToBigInt(msg.seqno),
             topic: rpcToText(msg.topicIDs[0]),
-            key: rpcToBytes(msg.key ?? 'u'),
+            // @ts-expect-error kubo does not supply the key
+            key: msg.key != null ? publicKeyFromProtobuf(rpcToBytes(msg.key ?? 'u')) : undefined,
             signature: rpcToBytes(msg.signature ?? 'u')
           })
         } else {

test/interface-tests.spec.ts

@@ -1,5 +1,6 @@
 /* eslint-env mocha */
 
+import { path } from 'kubo'
 import { isWindows, isFirefox, isChrome } from './constants.js'
 import * as tests from './interface-tests/src/index.js'
 import { factory } from './utils/factory.js'
@@ -261,13 +262,12 @@ function executeTests (commonFactory: Factory<KuboNode>): void {
 
 describe('kubo-rpc-client tests against kubo', function () {
   void (async function () {
-    const { path } = await import('kubo')
     /**
      * @type {string|undefined}
      */
     const commonFactory = factory({
       type: 'kubo',
-      bin: path(),
+      bin: path?.(),
       test: true
     })
     describe('kubo RPC client interface tests', function () {

test/interface-tests/src/key/gen.ts

@@ -1,21 +1,17 @@
 /* eslint-env mocha */
 
-import { keys } from '@libp2p/crypto'
 import { expect } from 'aegir/chai'
 import { nanoid } from 'nanoid'
 import { getDescribe, getIt, type MochaConfig } from '../utils/mocha.js'
 import type { KuboRPCClient } from '../../../../src/index.js'
 import type { KeyType } from '../../../../src/key/index.js'
 import type { Factory, KuboNode } from 'ipfsd-ctl'
 
-const { supportedKeys } = keys
-
 interface KeyTest {
   opts: {
     type?: KeyType
     size?: number
   }
-  expectedType: any
 }
 
 export function testGen (factory: Factory<KuboNode>, options: MochaConfig): void {
@@ -25,12 +21,10 @@ export function testGen (factory: Factory<KuboNode>, options: MochaConfig): void
   describe('.key.gen', () => {
     const keyTypes: KeyTest[] = [
       {
-        opts: { type: 'ed25519' },
-        expectedType: supportedKeys.ed25519.Ed25519PrivateKey
+        opts: { type: 'ed25519' }
       },
       {
-        opts: { },
-        expectedType: supportedKeys.ed25519.Ed25519PrivateKey
+        opts: { }
       }
     ]