Skip to content

gs1.1 flood publishing #89

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
wemeetagain merged 3 commits into from
Jun 18, 2020
Merged

gs1.1 flood publishing #89

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
b582120
chore: update getGossipPeers
wemeetagain Jun 17, 2020
5854d26
feat: add flood publishing
wemeetagain Jun 17, 2020
0a49b20
chore: tweak non-flood-publish behavior
wemeetagain Jun 17, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
chore: tweak non-flood-publish behavior
  • Loading branch information
@wemeetagain
wemeetagain committed Jun 17, 2020
commit 0a49b20000864bc46122b2f4b7cd0753258752ba
47 changes: 25 additions & 22 deletions ts/index.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -551,24 +551,25 @@ class Gossipsub extends BasicPubsub {
this.messageCache.put(msgObj)

const tosend = new Set<Peer>()
if (this._options.floodPublish) {
// flood-publish behavior
// send to _all_ peers meeting the publishThreshold
this.peers.forEach((peer, id) => {
const score = this.score.score(id)
if (score >= this._options.scoreThresholds.publishThreshold) {
tosend.add(peer)
}
})
} else {
// non-flood-publish behavior
// send to subscribed floodsub peers
// and some mesh peers
msgObj.topicIDs.forEach((topic) => {
const peersInTopic = this.topics.get(topic)
if (!peersInTopic) {
return
}
msgObj.topicIDs.forEach((topic) => {
const peersInTopic = this.topics.get(topic)
if (!peersInTopic) {
return
}

if (this._options.floodPublish) {
// flood-publish behavior
// send to _all_ peers meeting the publishThreshold
peersInTopic.forEach(peer => {
const score = this.score.score(peer.id.toB58String())
if (score >= this._options.scoreThresholds.publishThreshold) {
tosend.add(peer)
}
})
} else {
// non-flood-publish behavior
// send to subscribed floodsub peers
// and some mesh peers above publishThreshold

// floodsub peers
peersInTopic.forEach((peer) => {
Expand All @@ -583,8 +584,10 @@ class Gossipsub extends BasicPubsub {
// We are not in the mesh for topic, use fanout peers
meshPeers = this.fanout.get(topic)
if (!meshPeers) {
// If we are not in the fanout, then pick any peers in topic
const peers = getGossipPeers(this, topic, constants.GossipsubD)
// If we are not in the fanout, then pick peers in topic above the publishThreshold
const peers = getGossipPeers(this, topic, constants.GossipsubD, peer => {
return this.score.score(peer.id.toB58String()) >= this._options.scoreThresholds.publishThreshold
})

if (peers.size > 0) {
meshPeers = peers
Expand All @@ -600,8 +603,8 @@ class Gossipsub extends BasicPubsub {
meshPeers!.forEach((peer) => {
tosend.add(peer)
})
})
}
}
})
// Publish messages to peers
tosend.forEach((peer) => {
if (peer.id.toB58String() === msgObj.from) {
Expand Down