logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-02-27 21:53:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

apply suggestions from code review

Browse Source 
Co-authored-by: Ivan FB <128452529+Ivansete-status@users.noreply.github.com>
This commit is contained in:
Prem Chaitanya Prathi 2026-02-15 09:26:55 +05:30
parent 3070c94f5c
commit 5a0b7bafda
No known key found for this signature in database
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
waku/discovery/waku_kademlia.nim
View File

@ -1,7 +1,7 @@
{.push raises: [].}
import std/[options, sequtils]
import
std/[options, sequtils],
chronos,
chronicles,
results,
@ -110,7 +110,7 @@ proc extractMixPubKey(service: ServiceInfo): Option[Curve25519Key] =
let key = intoCurve25519Key(service.data)
debug "successfully extracted mix pub key", keyHex = byteutils.toHex(key)
some(key)
return some(key)
proc remotePeerInfoFrom(record: ExtendedPeerRecord): Option[RemotePeerInfo] =
debug "processing kademlia record",
@ -240,8 +240,8 @@ proc runDiscoveryLoop(
info "found mix peers via targeted kademlia lookup", count = found
await sleepAsync(interval)
except CancelledError:
debug "extended kademlia discovery loop cancelled"
except CancelledError as e:
debug "extended kademlia discovery loop cancelled", error = e.msg
except CatchableError as e:
error "extended kademlia discovery loop failed", error = e.msg

2
waku/waku_mix/protocol.nim
View File

@ -62,7 +62,7 @@ proc processBootNodes(
let mixPubInfo = MixPubInfo.init(peerId, multiAddr, node.pubKey, peerPubKey.skkey)
mix.nodePool.add(mixPubInfo)
count += 1
count.inc()
peermgr.addPeer(
RemotePeerInfo.init(peerId, @[multiAddr], mixPubKey = some(node.pubKey))