Commit 655ea5e2 authored by Herman Junge's avatar Herman Junge

Add queried peer ID to query event

parent b62d46c2
...@@ -444,7 +444,7 @@ func (dht *IpfsDHT) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo, ...@@ -444,7 +444,7 @@ func (dht *IpfsDHT) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo,
closer := pmes.GetCloserPeers() closer := pmes.GetCloserPeers()
clpeerInfos := pb.PBPeersToPeerInfos(closer) clpeerInfos := pb.PBPeersToPeerInfos(closer)
// see it we got the peer here // see if we got the peer here
for _, npi := range clpeerInfos { for _, npi := range clpeerInfos {
if npi.ID == id { if npi.ID == id {
return &dhtQueryResult{ return &dhtQueryResult{
...@@ -456,6 +456,7 @@ func (dht *IpfsDHT) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo, ...@@ -456,6 +456,7 @@ func (dht *IpfsDHT) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo,
notif.PublishQueryEvent(parent, &notif.QueryEvent{ notif.PublishQueryEvent(parent, &notif.QueryEvent{
Type: notif.PeerResponse, Type: notif.PeerResponse,
ID: p,
Responses: clpeerInfos, Responses: clpeerInfos,
}) })
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment