codex-storage
/
nim-libp2p
mirror of https://github.com/codex-storage/nim-libp2p.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

decode properly ControlPrune (#392)

This commit is contained in:
Giovanni Petrantoni 2020-10-09 09:12:38 +09:00 committed by GitHub
parent 98d82fce5c
commit e3bdb9eb13
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
libp2p/protocols/pubsub/rpc/protobuf.nim
View File

@ -107,6 +107,20 @@ proc decodeGraft*(pb: ProtoBuffer): ProtoResult[ControlGraft] {.
trace "decodeGraft: topicId is missing" trace "decodeGraft: topicId is missing"
ok(control) ok(control)
proc decodePeerInfoMsg*(pb: ProtoBuffer): ProtoResult[PeerInfoMsg] {.
inline.} =
trace "decodePeerInfoMsg: decoding message"
var pi = PeerInfoMsg()
if ? pb.getField(1, pi.peerID):
trace "decodePeerInfoMsg: read peerID", peerID = pi.peerID
else:
trace "decodePeerInfoMsg: peerID is missing"
if ? pb.getField(2, pi.signedPeerRecord):
trace "decodePeerInfoMsg: read signedPeerRecord", signedPeerRecord = pi.signedPeerRecord
else:
trace "decodePeerInfoMsg: signedPeerRecord is missing"
ok(pi)
proc decodePrune*(pb: ProtoBuffer): ProtoResult[ControlPrune] {. proc decodePrune*(pb: ProtoBuffer): ProtoResult[ControlPrune] {.
inline.} = inline.} =
trace "decodePrune: decoding message" trace "decodePrune: decoding message"
@ -115,7 +129,12 @@ proc decodePrune*(pb: ProtoBuffer): ProtoResult[ControlPrune] {.
trace "decodePrune: read topicId", topic_id = control.topicId trace "decodePrune: read topicId", topic_id = control.topicId
else: else:
trace "decodePrune: topicId is missing" trace "decodePrune: topicId is missing"
# TODO gossip 1.1 fields var bpeers: seq[seq[byte]]
if ? pb.getRepeatedField(2, bpeers):
for bpeer in bpeers:
control.peers &= ? decodePeerInfoMsg(initProtoBuffer(bpeer))
if ? pb.getField(3, control.backoff):
trace "decodePrune: read backoff", backoff = control.backoff
ok(control) ok(control)
proc decodeIHave*(pb: ProtoBuffer): ProtoResult[ControlIHave] {. proc decodeIHave*(pb: ProtoBuffer): ProtoResult[ControlIHave] {.