status-im
/
libp2p-dht
mirror of https://github.com/status-im/libp2p-dht.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

fixup

This commit is contained in:
Csaba Kiraly 2022-02-15 15:24:59 +01:00
parent be5d911cda
commit af168a8a24
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
eth/p2p/providers.nim
View File

@ -27,7 +27,7 @@ type
ProvidersMessage* = object
total*: uint32
enrs*: seq[Record]
enrs*: seq[PeerRecord]
func getField*(pb: ProtoBuffer, field: int,
nid: var NodeId): ProtoResult[bool] {.inline.} =
@ -92,7 +92,7 @@ proc registerAddProvider(p: ProvidersProtocol) =
proc sendAddProvider*(p: ProvidersProtocol, dst: Node, cId: NodeId, pr: PeerRecord) =
#type NodeDesc = tuple[ip: IpAddress, udpPort, tcpPort: Port, pk: PublicKey]
let msg = AddProviderMessage(cId: cId, prov: pr)
discard p.discovery.talkReq(dst, protoIdAddProvider, pr.encode())
discard p.discovery.talkReq(dst, protoIdAddProvider, msg.encode())
proc addProvider*(p: ProvidersProtocol, cId: NodeId, pr: PeerRecord): Future[seq[Node]] {.async.} =
result = await p.discovery.lookup(cId)