feat: lightpush & filter send requests to multiple peers

waku-org · Jan 10, 2024 · 1044f38 · 1044f38
1 parent 69406bf
commit 1044f38
Show file tree

Hide file tree

Showing 10 changed files with 366 additions and 127 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/core/package.json b/packages/core/package.json
@@ -75,6 +75,7 @@
     "@noble/hashes": "^1.3.2",
     "@waku/enr": "^0.0.19",
     "@waku/interfaces": "0.0.20",
+    "@waku/message-hash": "0.1.9",
     "@waku/proto": "0.0.5",
     "@waku/utils": "0.0.13",
     "debug": "^4.3.4",

diff --git a/packages/core/src/lib/base_protocol.ts b/packages/core/src/lib/base_protocol.ts
@@ -26,6 +26,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;
 
   constructor(