LemmyNet/lemmy
2
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2024-11-30 08:11:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

inbox_urls return vec

Browse source
This commit is contained in:
phiresky 2024-04-15 18:05:46 +02:00
parent 987174a6c1
commit a66aec69dd
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
crates/federate/src/worker.rs
View file

@ -290,7 +290,8 @@ impl InstanceWorker {
} }
Ok(()) Ok(())
} }
/// checks whether the highest successful id can be updated and writes to db if so /// Checks that sequential activities `last_successful_id + 1`, `last_successful_id + 2` etc have been sent successfully.
/// In that case updates `last_successful_id` and saves the state to the database if the time since the last save is greater than `SAVE_STATE_EVERY_TIME`.
async fn pop_successfuls_and_write( async fn pop_successfuls_and_write(
&mut self, &mut self,
successfuls: &mut BinaryHeap<SendSuccessInfo>, successfuls: &mut BinaryHeap<SendSuccessInfo>,
@ -355,7 +356,6 @@ impl InstanceWorker {
}))?; }))?;
return Ok(()); return Ok(());
} }
let inbox_urls = inbox_urls.into_iter().collect();
let initial_fail_count = self.state.fail_count; let initial_fail_count = self.state.fail_count;
let data = self.config.to_request_data(); let data = self.config.to_request_data();
let stop = self.stop.clone(); let stop = self.stop.clone();
@ -451,7 +451,7 @@ impl InstanceWorker {
/// most often this will return 0 values (if instance doesn't care about the activity) /// most often this will return 0 values (if instance doesn't care about the activity)
/// or 1 value (the shared inbox) /// or 1 value (the shared inbox)
/// > 1 values only happens for non-lemmy software /// > 1 values only happens for non-lemmy software
async fn get_inbox_urls(&mut self, activity: &SentActivity) -> Result<HashSet<Url>> { async fn get_inbox_urls(&mut self, activity: &SentActivity) -> Result<Vec<Url>> {
let mut inbox_urls: HashSet<Url> = HashSet::new(); let mut inbox_urls: HashSet<Url> = HashSet::new();
if activity.send_all_instances { if activity.send_all_instances {
@ -477,7 +477,7 @@ impl InstanceWorker {
.filter(|&u| (u.domain() == Some(&self.instance.domain))) .filter(|&u| (u.domain() == Some(&self.instance.domain)))
.map(|u| u.inner().clone()), .map(|u| u.inner().clone()),
); );
Ok(inbox_urls) Ok(inbox_urls.into_iter().collect())
} }
async fn update_communities(&mut self) -> Result<()> { async fn update_communities(&mut self) -> Result<()> {