feat: support batch dialling

packages/interface-connection-manager/src/index.ts

@@ -58,7 +58,7 @@ export interface ConnectionManager extends EventEmitter<ConnectionManagerEvents>
    * const connection = await libp2p.connectionManager.openConnection(peerId)
    * ```
    */
-  openConnection: (peer: PeerId | Multiaddr, options?: AbortOptions) => Promise<Connection>
+  openConnection: (peer: PeerId | Multiaddr | Multiaddr[], options?: AbortOptions) => Promise<Connection>
 
   /**
    * Close our connections to a peer
@@ -81,9 +81,9 @@ export interface ConnectionManager extends EventEmitter<ConnectionManagerEvents>
 
 export interface Dialer {
   /**
-   * Dial a peer or multiaddr and return the promise of a connection
+   * Dial a peer or multiaddr, or multiple multiaddrs and return the promise of a connection
    */
-  dial: (peer: PeerId | Multiaddr, options?: AbortOptions) => Promise<Connection>
+  dial: (peer: PeerId | Multiaddr | Multiaddr[], options?: AbortOptions) => Promise<Connection>
 
   /**
    * Request `num` dial tokens. Only the returned number of dials may be attempted.

packages/interface-libp2p/src/index.ts

@@ -348,7 +348,7 @@ export interface Libp2p extends Startable, EventEmitter<Libp2pEvents> {
    * await conn.close()
    * ```
    */
-  dial: (peer: PeerId | Multiaddr, options?: AbortOptions) => Promise<Connection>
+  dial: (peer: PeerId | Multiaddr | Multiaddr[], options?: AbortOptions) => Promise<Connection>
 
   /**
    * Dials to the provided peer and tries to handshake with the given protocols in order.
@@ -366,7 +366,7 @@ export interface Libp2p extends Startable, EventEmitter<Libp2pEvents> {
    * pipe([1, 2, 3], stream, consume)
    * ```
    */
-  dialProtocol: (peer: PeerId | Multiaddr, protocols: string | string[], options?: AbortOptions) => Promise<Stream>
+  dialProtocol: (peer: PeerId | Multiaddr | Multiaddr[], protocols: string | string[], options?: AbortOptions) => Promise<Stream>
 
   /**
    * Attempts to gracefully close an open connection to the given peer. If the connection is not closed in the grace period, it will be forcefully closed.

packages/interface-mocks/src/connection-manager.ts

@@ -8,6 +8,7 @@ import { CodeError } from '@libp2p/interfaces/errors'
 import type { Registrar } from '@libp2p/interface-registrar'
 import type { PubSub } from '@libp2p/interface-pubsub'
 import { isMultiaddr, Multiaddr } from '@multiformats/multiaddr'
+import { peerIdFromString } from '@libp2p/peer-id'
 
 export interface MockNetworkComponents {
   peerId: PeerId
@@ -23,7 +24,11 @@ class MockNetwork {
     this.components.push(components)
   }
 
-  getNode (peerId: PeerId): MockNetworkComponents {
+  getNode (peerId: PeerId | Multiaddr []): MockNetworkComponents {
+    if (Array.isArray(peerId)) {
+      peerId = peerIdFromString(peerId[0].getPeerId() ?? '')
+    }
+
     for (const components of this.components) {
       if (peerId.equals(components.peerId)) {
         return components
@@ -72,7 +77,7 @@ class MockConnectionManager extends EventEmitter<ConnectionManagerEvents> implem
     this.started = false
   }
 
-  getConnections (peerId?: PeerId): Connection[] {
+  getConnections (peerId?: PeerId | Multiaddr[]): Connection[] {
     if (peerId != null) {
       return this.connections
         .filter(c => c.remotePeer.toString() === peerId.toString())
@@ -81,7 +86,7 @@ class MockConnectionManager extends EventEmitter<ConnectionManagerEvents> implem
     return this.connections
   }
 
-  async openConnection (peerId: PeerId | Multiaddr): Promise<Connection> {
+  async openConnection (peerId: PeerId | Multiaddr | Multiaddr[]): Promise<Connection> {
     if (this.components == null) {
       throw new CodeError('Not initialized', 'ERR_NOT_INITIALIZED')
     }