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

deploy: 87e57c627995d7f7581ffefa6eb6442072c7fb66

Browse Source
This commit is contained in:
rymnc 2022-10-08 07:20:08 +00:00
parent 457900567d
commit 8c5631702b
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
waku/v2/protocol/waku_rln_relay/waku_rln_relay_utils.nim
View File

@ -929,9 +929,10 @@ proc subscribeToGroupEvents(ethClientUri: string, ethAccountAddress: Address, co
handler(pubkey, index)
except Exception as err:
# chronos still raises exceptions which inherit directly from Exception
error "Error handling new member registration: ", err=err.msg
doAssert false, err.msg
do (err: CatchableError):
echo "Error from subscription: ", err.msg
error "Error from subscription: ", err=err.msg
proc handleGroupUpdates*(rlnPeer: WakuRLNRelay, handler: RegistrationEventHandler) {.async, gcsafe.} =
# mounts the supplied handler for the registration events emitting from the membership contract
@ -1109,6 +1110,7 @@ proc mountRlnRelayDynamic*(node: WakuNode,
let pk = pubkey.toIDCommitment()
let isSuccessful = rlnPeer.insertMember(pk)
debug "received pk", pk=pk.toHex, index =index
debug "acceptable window", validRoots=rlnPeer.validMerkleRoots
doAssert(isSuccessful.isOk())
asyncSpawn rlnPeer.handleGroupUpdates(handler)
@ -1172,8 +1174,9 @@ proc mount(node: WakuNode,
info "WakuRLNRelay is mounted successfully", pubsubtopic=conf.rlnRelayPubsubTopic, contentTopic=conf.rlnRelayContentTopic
return ok(true)
else: # mount the rln relay protocol in the on-chain/dynamic mode
echo " setting up waku-rln-relay in on-chain mode... "
echo "setting up waku-rln-relay in on-chain mode... "
debug "on-chain parameters", contractAddress=conf.rlnRelayEthContractAddress
# read related inputs to run rln-relay in on-chain mode and do type conversion when needed
let
ethAccountAddr = web3.fromHex(web3.Address, conf.rlnRelayEthAccountAddress)