test: throws an error for outbound connection beyond limit and added …

…test
libp2p · Dec 16, 2022 · 4058909 · 4058909
1 parent 79bff2c
commit 4058909
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 1 deletion.
diff --git a/src/connection-manager/index.ts b/src/connection-manager/index.ts
@@ -539,6 +539,13 @@ export class DefaultConnectionManager extends EventEmitter<ConnectionManagerEven
       return existingConnections[0]
     }
 
+    if ((this.getConnections().length + 1) > this.opts.maxOutgoingConnections) {
+      throw errCode(
+        new Error('Connection Manager maxOutgoing connections exceeded'),
+        codes.ERR_CONNECTION_DENIED
+      )
+    }
+
     let timeoutController: TimeoutController | undefined
 
     if (options?.signal == null) {

diff --git a/test/connection-manager/index.spec.ts b/test/connection-manager/index.spec.ts
@@ -316,8 +316,26 @@ describe('Connection Manager', () => {
       .to.eventually.be.false()
   })
 
-  it.skip('should deny connections when maxOutgoingConnections is exceeded', async () => {
+  it('should throw an error when attempting to connect and maxOutgoingConnections is exceeded', async () => {
+    const dialer = stubInterface<Dialer>()
+    dialer.dial.resolves(stubInterface<Connection>())
+
+    const connectionManager = new DefaultConnectionManager({
+      peerId: libp2p.peerId,
+      upgrader: stubInterface<Upgrader>(),
+      peerStore: stubInterface<PeerStore>(),
+      dialer
+    }, {
+      ...defaultOptions,
+      maxOutgoingConnections: 1
+    })
+
+    // max out the connection limit
+    await connectionManager.openConnection(await createEd25519PeerId())
+    expect(connectionManager.getConnections()).to.have.lengthOf(1)
 
+    await expect(connectionManager.openConnection(await createEd25519PeerId())).to.eventually.be.rejected()
+      .and.to.have.property('code', ErrorCodes.ERR_CONNECTION_DENIED)
   })
 
   it('should deny connections from peers that connect too frequently', async () => {