feat: Add getPeerMeta method

src/index.ts

@@ -37,7 +37,7 @@
  * ```
  */
 
-import { WHATWGFetch } from './whatwg-fetch-service.js'
+import { WHATWGFetch, type ProtosMap } from './whatwg-fetch-service.js'
 import type { ComponentLogger } from '@libp2p/interface'
 import type { ConnectionManager, Registrar } from '@libp2p/interface-internal'
 import type { Multiaddr } from '@multiformats/multiaddr'
@@ -49,10 +49,14 @@ export { WELL_KNOWN_PROTOCOLS } from './constants.js'
  */
 export interface HTTP {
   fetch(request: string | Request, requestInit?: RequestInit): Promise<Response>
+
   // Uses the peer's .well-known endpoint to find where it hosts a given protocol.
   // Throws an error if the peer does not serve the protocol.
   prefixForProtocol (peer: Multiaddr, protocol: string): Promise<string>
 
+  // Get the .well-known protocols for a peer.
+  getPeerMeta (peer: Multiaddr): Promise<ProtosMap>
+
   // handleHTTPProtocol registers a handler for the given protocol on the given path. This is incompatible with a customHTTPHandler.
   handleHTTPProtocol (protocol: string, path: string, handler: (req: Request) => Promise<Response>): void
 }

src/whatwg-fetch-service.ts

@@ -9,7 +9,7 @@ import type { IncomingStreamData } from '@libp2p/interface-internal'
 const multiaddrURIPrefix = 'multiaddr:'
 
 type ProtocolID = string
-type ProtosMap = Record<ProtocolID, { path: string }>
+export type ProtosMap = Record<ProtocolID, { path: string }>
 type ProtoHandlers = Record<ProtocolID, HTTPHandler>
 
 export class WHATWGFetch implements Startable, WHATWGFetchInterface {
@@ -192,13 +192,10 @@ export class WHATWGFetch implements Startable, WHATWGFetchInterface {
     this.protoHandlers[protocol] = handler
   }
 
-  async prefixForProtocol (peer: Multiaddr, protocol: string): Promise<string> {
+  async getPeerMeta (peer: Multiaddr): Promise<ProtosMap> {
     const cached = this.wellKnownProtosCache.get(peer)
     if (cached !== undefined) {
-      if (cached[protocol] == null) {
-        throw new Error(`Peer does not serve protocol: ${protocol}`)
-      }
-      return cached[protocol].path
+      return cached
     }
 
     let fetch
@@ -223,6 +220,11 @@ export class WHATWGFetch implements Startable, WHATWGFetchInterface {
     }
     const peerMeta = await resp.json()
     this.wellKnownProtosCache.set(peer, peerMeta)
+    return peerMeta
+  }
+
+  async prefixForProtocol (peer: Multiaddr, protocol: string): Promise<string> {
+    const peerMeta = await this.getPeerMeta(peer)
     if (peerMeta[protocol] == null) {
       throw new Error(`Peer does not serve protocol: ${protocol}`)
     }