logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-08 17:03:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

proper fix for stream closed and reduce mixpool polling interval

Browse Source
This commit is contained in:
Prem Chaitanya Prathi 2025-04-03 12:49:50 +05:30
parent f93b2c6972
commit d14bfa403f
4 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
Dockerfile.lightpushWithMix.compile
View File

@ -43,7 +43,8 @@ EXPOSE 30303 60000 8545
RUN apk add --no-cache libgcc pcre-dev libpq-dev \
wget \
iproute2 \
python3
python3 \
jq
# Fix for 'Error loading shared library libpcre.so.3: No such file or directory'
RUN ln -s /usr/lib/libpcre.so /usr/lib/libpcre.so.3

3
examples/lightpush_publisher_mix.nim
View File

@ -98,7 +98,8 @@ proc setupAndPublish(rng: ref HmacDrbgContext, conf: LPMixConf) {.async.} =
let (destPeerAddr, destPeerId) = splitPeerIdAndAddr(conf.destPeerAddr)
let (pxPeerAddr, pxPeerId) = splitPeerIdAndAddr(conf.pxAddr)
info "dest peer address: ", destPeerAddr = destPeerAddr, destPeerId = destPeerId
info "peer exchange address: ", pxPeerAddr = pxPeerAddr, pxPeerId = pxPeerId
let pxPeerInfo =
RemotePeerInfo.init(destPeerId, @[MultiAddress.init(destPeerAddr).get()])
node.peerManager.addServicePeer(pxPeerInfo, WakuPeerExchangeCodec)

2
vendor/mix vendored

@ -1 +1 @@
Subproject commit bb26ba75a6d479619703e29333f48a9ac9adc753
Subproject commit 9ff3f4cae579f50c16e6c2084ac0cf39e34b440c

2
waku/node/waku_node.nim
View File

@ -325,7 +325,7 @@ proc startMixNodePoolMgr*(node: WakuNode) {.async.} =
await sleepAsync(1.seconds)
# TODO: make interval configurable
heartbeat "Updating mix node pool", 10.minutes:
heartbeat "Updating mix node pool", 5.seconds:
discard node.populateMixNodePool()
proc getMixNodePoolSize*(node: WakuNode): int =