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

chore: remove inconsistancy

Browse Source
This commit is contained in:
darshankabariya 2025-03-25 03:15:59 +05:30
parent 3034517b25
commit 0cb8760a90
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
waku/waku_rln_relay/group_manager/on_chain/group_manager.nim
View File

@ -63,7 +63,6 @@ type
keystorePath*: Option[string] keystorePath*: Option[string]
keystorePassword*: Option[string] keystorePassword*: Option[string]
registrationHandler*: Option[RegistrationHandler] registrationHandler*: Option[RegistrationHandler]
validRootBuffer*: Deque[MerkleNode]
latestProcessedBlock*: BlockNumber latestProcessedBlock*: BlockNumber
proc setMetadata*( proc setMetadata*(
@ -80,7 +79,7 @@ proc setMetadata*(
lastProcessedBlock: normalizedBlock.uint64, lastProcessedBlock: normalizedBlock.uint64,
chainId: g.chainId, chainId: g.chainId,
contractAddress: g.ethContractAddress, contractAddress: g.ethContractAddress,
validRoots: g.validRootBuffer.toSeq(), validRoots: g.validRoots.toSeq(),
) )
) )
if metadataSetRes.isErr(): if metadataSetRes.isErr():
@ -121,7 +120,7 @@ template retryWrapper(
body body
method validateRoot*(g: OnchainGroupManager, root: MerkleNode): bool = method validateRoot*(g: OnchainGroupManager, root: MerkleNode): bool =
if g.validRootBuffer.find(root) >= 0: if g.validRoots.find(root) >= 0:
return true return true
return false return false
@ -143,12 +142,12 @@ proc slideRootQueue*(g: OnchainGroupManager) {.async.} =
let merkleRoot = toMerkleNode(rootRes.get()) let merkleRoot = toMerkleNode(rootRes.get())
let overflowCount = g.validRootBuffer.len - AcceptableRootWindowSize + 1 let overflowCount = g.validRoots.len - AcceptableRootWindowSize + 1
if overflowCount > 0: if overflowCount > 0:
for i in 0 ..< overflowCount: for i in 0 ..< overflowCount:
discard g.validRootBuffer.popFirst() discard g.validRoots.popFirst()
g.validRootBuffer.addLast(merkleRoot) g.validRoots.addLast(merkleRoot)
method atomicBatch*( method atomicBatch*(
g: OnchainGroupManager, g: OnchainGroupManager,
@ -375,7 +374,7 @@ method verifyProof*(
proofBytes = serialize(normalizedProof, input) proofBytes = serialize(normalizedProof, input)
proofBuffer = proofBytes.toBuffer() proofBuffer = proofBytes.toBuffer()
validProof: bool validProof: bool
rootsBytes = serialize(g.validRootBuffer.items().toSeq()) rootsBytes = serialize(g.validRoots.items().toSeq())
rootsBuffer = rootsBytes.toBuffer() rootsBuffer = rootsBytes.toBuffer()
trace "serialized proof", proof = byteutils.toHex(proofBytes) trace "serialized proof", proof = byteutils.toHex(proofBytes)