chore: fix

packages/core/src/lib/base_protocol.ts

@@ -66,8 +66,11 @@ export class BaseProtocol implements IBaseProtocolCore {
   public async connectedPeers(): Promise<Peer[]> {
     const peers = await this.allPeers();
     return peers.filter((peer) => {
-      return (
-        this.components.connectionManager.getConnections(peer.id).length > 0
+      const connections = this.components.connectionManager.getConnections(
+        peer.id
+      );
+      return connections.some((c) =>
+        c.streams.some((s) => s.protocol === this.multicodec)
       );
     });
   }

packages/sdk/src/protocols/base_protocol.ts

@@ -174,6 +174,7 @@ export class BaseProtocolSDK implements IBaseProtocolSDK {
     }
 
     this.maintainPeersLock = true;
+    await this.confirmPeers();
     this.log.info(`Maintaining peers, current count: ${this.peers.length}`);
     try {
       const numPeersToAdd = this.numPeersToUse - this.peers.length;
@@ -190,6 +191,11 @@ export class BaseProtocolSDK implements IBaseProtocolSDK {
     return true;
   }
 
+  private async confirmPeers(): Promise<void> {
+    const peers = await this.core.connectedPeers();
+    this.updatePeers(peers);
+  }
+
   /**
    * Finds and adds new peers to the peers list.
    * @param numPeers The number of peers to find and add.

packages/sdk/src/protocols/filter/subscription_manager.ts

@@ -299,9 +299,9 @@ export class SubscriptionManager implements ISubscriptionSDK {
     }
 
     this.keepAliveTimer = setInterval(() => {
-      void this.ping().catch((error) => {
-        log.error("Error in keep-alive ping cycle:", error);
-      });
+      void this.ping()
+        .then(() => log.info("Keep-alive ping successful"))
+        .catch((error) => log.error("Error in keep-alive ping cycle:", error));
     }, interval) as unknown as number;
   }