fix: fixes cache leak and unhandled promise rejection

packages/client/src/client.ts

@@ -21,7 +21,8 @@
 const defaultValues = {
   concurrentRequests: 4,
   timeout: 30e3,
-  cacheTTL: 5 * 60 * 1000 // 5 minutes default as per https://specs.ipfs.tech/routing/http-routing-v1/#response-headers
+  cacheTTL: 5 * 60 * 1000, // 5 minutes default as per https://specs.ipfs.tech/routing/http-routing-v1/#response-headers
+  cacheName: 'delegated-routing-v1-cache'
 }
 
 export class DefaultDelegatedRoutingV1HttpApiClient implements DelegatedRoutingV1HttpApiClient {
@@ -35,6 +36,7 @@
   private readonly filterAddrs?: string[]
   private readonly filterProtocols?: string[]
   private readonly inFlightRequests: Map<string, Promise<Response>>
+  private readonly cacheName: string
   private cache?: Cache
   private readonly cacheTTL: number
   /**
@@ -55,17 +57,8 @@
     this.contentRouting = new DelegatedRoutingV1HttpApiClientContentRouting(this)
     this.peerRouting = new DelegatedRoutingV1HttpApiClientPeerRouting(this)
 
+    this.cacheName = init.cacheName ?? defaultValues.cacheName
     this.cacheTTL = init.cacheTTL ?? defaultValues.cacheTTL
-    const cacheEnabled = (typeof globalThis.caches !== 'undefined') && (this.cacheTTL > 0)
-
-    if (cacheEnabled) {
-      log('cache enabled with ttl %d', this.cacheTTL)
-      globalThis.caches.open('delegated-routing-v1-cache').then(cache => {
-        this.cache = cache
-      }).catch(() => {
-        this.cache = undefined
-      })
-    }
   }
 
   get [contentRoutingSymbol] (): ContentRouting {
@@ -80,19 +73,30 @@
     return this.started
   }
 
-  start (): void {
+  async start (): Promise<void> {
+    if (this.started) {
+      return
+    }
+
     this.started = true
+
+    if (this.cacheTTL > 0) {
+      this.cache = await globalThis.caches?.open(this.cacheName)
+
+      if (this.cache != null) {
+        log('cache enabled with ttl %d', this.cacheTTL)
+      }
+    }
   }
 
-  stop (): void {
+  async stop (): Promise<void> {
     this.httpQueue.clear()
     this.shutDownController.abort()
-    this.started = false
 
     // Clear the cache when stopping
-    if (this.cache != null) {
-      void this.cache.delete('delegated-routing-v1-cache')
-    }
+    await globalThis.caches?.delete(this.cacheName)
+
+    this.started = false
   }
 
   async * getProviders (cid: CID, options: GetProvidersOptions = {}): AsyncGenerator<PeerRecord> {

packages/client/src/index.ts

@@ -144,6 +144,15 @@ export interface DelegatedRoutingV1HttpApiClientInit extends FilterOptions {
    * If 0, caching is disabled
    */
   cacheTTL?: number
+
+  /**
+   * Where a [Cache](https://developer.mozilla.org/en-US/docs/Web/API/Cache) is
+   * available in the global scope, we will store request/responses to avoid
+   * making duplicate requests.
+   *
+   * @default 'delegated-routing-v1-cache'
+   */
+  cacheName?: string
 }
 
 export interface GetIPNSOptions extends AbortOptions {

packages/client/test/client.spec.ts

@@ -0,0 +1,17 @@
+import { expect } from 'aegir/chai'
+import { DefaultDelegatedRoutingV1HttpApiClient } from '../src/client.js'
+import { itBrowser } from './fixtures/it.js'
+
+describe('client', () => {
+  itBrowser('should remove cache on stop', async function () {
+    const cacheName = 'test-cache'
+
+    const client = new DefaultDelegatedRoutingV1HttpApiClient('http://example.com', {
+      cacheName
+    })
+    await client.start()
+    await client.stop()
+
+    await expect(globalThis.caches.has(cacheName)).to.eventually.be.false('did not remove cache on stop')
+  })
+})

packages/client/test/fixtures/it.ts

@@ -0,0 +1,5 @@
+/* eslint-env mocha */
+
+import { isBrowser } from 'wherearewe'
+
+export const itBrowser = (isBrowser ? it : it.skip)

packages/client/test/index.spec.ts

@@ -1,21 +1,21 @@
 /* eslint-env mocha */
 
 import { generateKeyPair } from '@libp2p/crypto/keys'
+import { start } from '@libp2p/interface'
 import { peerIdFromPrivateKey, peerIdFromString } from '@libp2p/peer-id'
 import { multiaddr } from '@multiformats/multiaddr'
 import { expect } from 'aegir/chai'
 import { createIPNSRecord, marshalIPNSRecord } from 'ipns'
 import all from 'it-all'
 import { CID } from 'multiformats/cid'
-import { isBrowser } from 'wherearewe'
 import { createDelegatedRoutingV1HttpApiClient, type DelegatedRoutingV1HttpApiClient } from '../src/index.js'
+import { itBrowser } from './fixtures/it.js'
 
 if (process.env.ECHO_SERVER == null) {
   throw new Error('Echo server not configured correctly')
 }
 
 const serverUrl = process.env.ECHO_SERVER
-const itBrowser = (isBrowser ? it : it.skip)
 
 describe('delegated-routing-v1-http-api-client', () => {
   let client: DelegatedRoutingV1HttpApiClient
@@ -357,6 +357,7 @@
     const clientWithShortTTL = createDelegatedRoutingV1HttpApiClient(new URL(serverUrl), {
       cacheTTL: shortTTL
     })
+    await start(clientWithShortTTL)
 
     const cid = CID.parse('QmUNLLsPACCz1vLxQVkXqqLX5R1X345qqfHbsf67hvA3Nn')
     const providers = [{