LumeWeb
/
dht-flood
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:9333ab7a38b5c9204e7ca3ff2b0324cdea28fcd7
Branches Tags
LumeWeb:master
..
compare: LumeWeb:9cd5e798d91bfb5ffe9665894421e22372852f8f
Branches Tags
LumeWeb:master

No commits in common. "9333ab7a38b5c9204e7ca3ff2b0324cdea28fcd7" and "9cd5e798d91bfb5ffe9665894421e22372852f8f" have entirely different histories.
9333ab7a38 ... 9cd5e798d9

2 changed files with 4 additions and 4 deletions
Show Stats Expand all files Collapse all files

4
dist/index.js vendored
View File

@ -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._seenTopics.has(topicString)) .filter((peerInfo) => peerInfo.topics.includes(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);

4
src/index.ts
View File

@ -162,12 +162,12 @@ export default class DHTFlood extends EventEmitter {
let topicString = this.topic.toString("hex"); let topicString = this.topic.toString("hex");
let peers: Buffer[] = [...this.swarm.peers.values()] let peers: Buffer[] = [...this.swarm.peers.values()]
.filter((peerInfo: any) => peerInfo._seenTopics.has(topicString)) .filter((peerInfo: any) => peerInfo.topics.includes(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;
} }