nostr/gossip
1
0
Fork 0
mirror of https://github.com/mikedilger/gossip.git synced 2024-09-20 03:57:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix multiple FetchMentions per relay

Browse Source
This commit is contained in:
Mike Dilger 2023-12-29 22:39:07 +13:00
parent dd292eba30
commit 42eb336ff2
1 changed files with 32 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
gossip-lib/src/overlord/mod.rs
View File

@ -244,29 +244,46 @@ impl Overlord {
}
async fn apply_relay_assignment(&mut self, assignment: RelayAssignment) -> Result<(), Error> {
// Subscribe to the general feed
self.engage_minion(
assignment.relay_url.clone(),
vec![
RelayJob {
reason: RelayConnectionReason::Follow,
payload: ToMinionPayload {
job_id: rand::random::<u64>(),
detail: ToMinionPayloadDetail::SubscribeGeneralFeed(
assignment.pubkeys.clone(),
),
},
let mut jobs = vec![
RelayJob {
reason: RelayConnectionReason::Follow,
payload: ToMinionPayload {
job_id: rand::random::<u64>(),
detail: ToMinionPayloadDetail::SubscribeGeneralFeed(
assignment.pubkeys.clone(),
),
},
},
];
// Until NIP-65 is in widespread use, we should listen for mentions
// of us on all these relays too
// Only do this if we aren't already doing it.
let mut fetch_mentions = true;
if let Some(jobs) = GLOBALS.connected_relays.get(&assignment.relay_url) {
for job in &*jobs {
if job.reason == RelayConnectionReason::FetchMentions {
fetch_mentions = false;
break;
}
}
}
if fetch_mentions {
jobs.push(
RelayJob {
// Until NIP-65 is in widespread use, we should listen for mentions
// of us on all these relays too
reason: RelayConnectionReason::FetchMentions,
payload: ToMinionPayload {
job_id: rand::random::<u64>(),
detail: ToMinionPayloadDetail::SubscribeMentions,
},
},
],
);
}
// Subscribe to the general feed
self.engage_minion(
assignment.relay_url.clone(),
jobs
)
.await?;