*Update dist
This commit is contained in:
parent
0a335997bf
commit
9333ab7a38
|
@ -123,11 +123,11 @@ class DHTFlood extends events_1.default {
|
||||||
const { id, messageNumber } = this;
|
const { id, messageNumber } = this;
|
||||||
let topicString = this.topic.toString("hex");
|
let topicString = this.topic.toString("hex");
|
||||||
let peers = [...this.swarm.peers.values()]
|
let peers = [...this.swarm.peers.values()]
|
||||||
.filter((peerInfo) => peerInfo.topics.includes(topicString))
|
.filter((peerInfo) => peerInfo._seenTopics.has(topicString))
|
||||||
.map((peerInfo) => peerInfo.publicKey);
|
.map((peerInfo) => peerInfo.publicKey);
|
||||||
for (const peer of peers) {
|
for (const peer of peers) {
|
||||||
const conn = this.swarm._allConnections.get(peer);
|
const conn = this.swarm._allConnections.get(peer);
|
||||||
if (conn) {
|
if (!conn) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
const message = this.setupPeer(conn);
|
const message = this.setupPeer(conn);
|
||||||
|
|
Loading…
Reference in New Issue