feat: lightpush & filter send requests to multiple peers

package.json

@@ -5,11 +5,11 @@
   "workspaces": [
     "packages/interfaces",
     "packages/utils",
+    "packages/message-hash",
     "packages/proto",
     "packages/enr",
     "packages/core",
     "packages/relay",
-    "packages/message-hash",
     "packages/peer-exchange",
     "packages/dns-discovery",
     "packages/message-encryption",

packages/core/package.json

@@ -76,6 +76,7 @@
     "@noble/hashes": "^1.3.2",
     "@waku/enr": "^0.0.20",
     "@waku/interfaces": "0.0.21",
+    "@waku/message-hash": "^0.1.10",
     "@waku/proto": "0.0.6",
     "@waku/utils": "0.0.14",
     "debug": "^4.3.4",

packages/core/src/lib/base_protocol.ts

@@ -24,6 +24,7 @@ import { StreamManager } from "./stream_manager.js";
 export class BaseProtocol implements IBaseProtocol {
   public readonly addLibp2pEventListener: Libp2p["addEventListener"];
   public readonly removeLibp2pEventListener: Libp2p["removeEventListener"];
+  readonly NUM_PEERS_TO_USE = 3;
   protected streamManager: StreamManager;
   protected pubsubTopics: PubsubTopic[];
 
@@ -124,6 +125,12 @@ export class BaseProtocol implements IBaseProtocol {
       );
     }
 
+    if (sortedFilteredPeers.length < numPeers) {
+      this.log.warn(
+        `Only ${sortedFilteredPeers.length} peers found. Requested ${numPeers}.`
+      );
+    }
+
     return sortedFilteredPeers;
   }