mirror of
https://github.com/waku-org/nwaku.git
synced 2025-01-22 21:02:56 +00:00
deploy: f8c4d9aebcc502538a1429246d0f59892fe28c21
This commit is contained in:
parent
08ef5186e3
commit
e03aa222b6
vendor/nim-libbacktrace/vendor/libbacktrace-upstream
waku/v2/protocol/waku_rln_relay
@ -2,7 +2,7 @@
|
||||
|
||||
# libtool - Provide generalized library-building support services.
|
||||
# Generated automatically by config.status (libbacktrace) version-unused
|
||||
# Libtool was configured on host fv-az243-466:
|
||||
# Libtool was configured on host fv-az302-360:
|
||||
# NOTE: Changes made to this file will be lost: look at ltmain.sh.
|
||||
#
|
||||
# Copyright (C) 1996, 1997, 1998, 1999, 2000, 2001, 2003, 2004, 2005,
|
||||
|
@ -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)
|
||||
|
Loading…
x
Reference in New Issue
Block a user