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

fix get desired events

Browse Source
This commit is contained in:
Mike Dilger 2022-12-29 08:10:24 +13:00
parent 0fa10a8e1c
commit 8520afdd28
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/overlord/mod.rs
View File

@ -8,7 +8,7 @@ use crate::globals::{Globals, GLOBALS};
use crate::settings::Settings; use crate::settings::Settings;
use minion::Minion; use minion::Minion;
use nostr_types::{ use nostr_types::{
Event, EventKind, Nip05, PreEvent, PrivateKey, PublicKey, PublicKeyHex, Unixtime, Url, Event, EventKind, Id, Nip05, PreEvent, PrivateKey, PublicKey, PublicKeyHex, Unixtime, Url,
}; };
use relay_picker::{BestRelay, RelayPicker}; use relay_picker::{BestRelay, RelayPicker};
use std::collections::HashMap; use std::collections::HashMap;
@ -483,7 +483,8 @@ impl Overlord {
} }
async fn get_missing_events(&mut self) -> Result<(), Error> { async fn get_missing_events(&mut self) -> Result<(), Error> {
let (desired_events_map, desired_events_vec) = Globals::get_desired_events().await?; let (desired_events_map, orphans): (HashMap<Url, Vec<Id>>, Vec<Id>) =
Globals::get_desired_events().await?;
let desired_count = GLOBALS.desired_events.read().await.len(); let desired_count = GLOBALS.desired_events.read().await.len();
@ -493,14 +494,14 @@ impl Overlord {
info!("Seeking {} events", desired_count); info!("Seeking {} events", desired_count);
let urls = self.urls_watching.clone(); let urls: Vec<Url> = desired_events_map.keys().map(|u| u.to_owned()).collect();
for url in urls.iter() { for url in urls.iter() {
// Get all the ones slated for this relay // Get all the ones slated for this relay
let mut ids = desired_events_map.get(url).cloned().unwrap_or_default(); let mut ids = desired_events_map.get(url).cloned().unwrap_or_default();
// Add the orphans // Add the orphans
ids.extend(&desired_events_vec); ids.extend(&orphans);
if ids.is_empty() { if ids.is_empty() {
continue; continue;