don't throw on missing peer

2019-10-03 13:29:28 -06:00 · 2019-10-03 13:29:28 -06:00 · f190c155d3
parent 3b9d34116d
commit f190c155d3
1 changed files with 1 additions and 1 deletions
--- a/libp2p/protocols/pubsub/floodsub.nim
+++ b/libp2p/protocols/pubsub/floodsub.nim
@ -88,7 +88,7 @@ proc rpcHandler(f: FloodSub,

        # forward the message to all peers interested in it
        for p in toSendPeers:
-          if f.peers[p].id != peer.id:
+          if p in f.peers and f.peers[p].id != peer.id:
            await f.peers[p].send(@[RPCMsg(messages: m.messages)])

 proc handleConn(f: FloodSub,