chore: inject shards info to wakunode

waku-org · Jun 12, 2024 · f14b908 · f14b908
1 parent c9692ac
commit f14b908
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/apps/wakucanary/wakucanary.nim b/apps/wakucanary/wakucanary.nim
@@ -237,7 +237,7 @@ proc main(rng: ref HmacDrbgContext): Future[int] {.async.} =
       error "failed to mount libp2p ping protocol: " & getCurrentExceptionMsg()
       return 1
 
-  node.mountMetadata(conf.clusterId).isOkOr:
+  node.mountMetadata(conf.clusterId, conf.shards).isOkOr:
     error "failed to mount waku metadata protocol: ", err = error
 
   await node.start()

diff --git a/vendor/nim-bearssl b/vendor/nim-bearssl
diff --git a/waku/node/waku_node.nim b/waku/node/waku_node.nim
@@ -194,12 +194,15 @@ proc connectToNodes*(
 
 ## Waku Metadata
 
-proc mountMetadata*(node: WakuNode, clusterId: uint32): Result[void, string] =
+proc mountMetadata*(
+    node: WakuNode, clusterId: uint32, shards: seq[uint16] = @[]
+): Result[void, string] =
   if not node.wakuMetadata.isNil():
     return err("Waku metadata already mounted, skipping")
 
   let metadata = WakuMetadata.new(clusterId, node.enr, node.topicSubscriptionQueue)
-
+  for shard in shards:
+    metadata.shards.incl(uint32(shard))
   node.wakuMetadata = metadata
   node.peerManager.wakuMetadata = metadata
+1 −1		bearssl.nimble
+2 −2		bearssl/abi/bearssl_rand.nim
+4 −8		bearssl/abi/bearssl_ssl.nim
+1 −1		bearssl/abi/bearssl_x509.nim
+2 −2		bearssl/certs/cacert.nim
+1,070 −1,235		bearssl/certs/cacert20221116.c
+1 −1		bearssl/rand.nim
+1 −1		tests/test_rand.nim