waku-org
/
nwaku
mirror of https://github.com/waku-org/nwaku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore(rln-relay): additional logging (#1243) 

* chore(rln-relay): additional logging

* fix: whitespace
This commit is contained in:
Aaryamann Challani 2022-10-08 12:14:52 +05:30 committed by GitHub
parent 3e1e7cc74f
commit f8c4d9aebc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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) handler(pubkey, index)
except Exception as err: except Exception as err:
# chronos still raises exceptions which inherit directly from Exception # chronos still raises exceptions which inherit directly from Exception
error "Error handling new member registration: ", err=err.msg
doAssert false, err.msg doAssert false, err.msg
do (err: CatchableError): do (err: CatchableError):
echo "Error from subscription: ", err.msg error "Error from subscription: ", err=err.msg
proc handleGroupUpdates*(rlnPeer: WakuRLNRelay, handler: RegistrationEventHandler) {.async, gcsafe.} = proc handleGroupUpdates*(rlnPeer: WakuRLNRelay, handler: RegistrationEventHandler) {.async, gcsafe.} =
# mounts the supplied handler for the registration events emitting from the membership contract # 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 pk = pubkey.toIDCommitment()
let isSuccessful = rlnPeer.insertMember(pk) let isSuccessful = rlnPeer.insertMember(pk)
debug "received pk", pk=pk.toHex, index =index debug "received pk", pk=pk.toHex, index =index
debug "acceptable window", validRoots=rlnPeer.validMerkleRoots
doAssert(isSuccessful.isOk()) doAssert(isSuccessful.isOk())
asyncSpawn rlnPeer.handleGroupUpdates(handler) asyncSpawn rlnPeer.handleGroupUpdates(handler)
@ -1172,8 +1174,9 @@ proc mount(node: WakuNode,
info "WakuRLNRelay is mounted successfully", pubsubtopic=conf.rlnRelayPubsubTopic, contentTopic=conf.rlnRelayContentTopic info "WakuRLNRelay is mounted successfully", pubsubtopic=conf.rlnRelayPubsubTopic, contentTopic=conf.rlnRelayContentTopic
return ok(true) return ok(true)
else: # mount the rln relay protocol in the on-chain/dynamic mode 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 # read related inputs to run rln-relay in on-chain mode and do type conversion when needed
let let
ethAccountAddr = web3.fromHex(web3.Address, conf.rlnRelayEthAccountAddress) ethAccountAddr = web3.fromHex(web3.Address, conf.rlnRelayEthAccountAddress)