zaaarf/upub
1
0
Fork 0
forked from alemi/upub
Code Pull requests Activity

feat(web): optimized fetching more

Browse source
This commit is contained in:
əlemi 2024-04-16 06:42:16 +02:00
parent 1e6d11b5dc
commit 3fde41eb97
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
web/src/context.rs
View file

@ -1,4 +1,4 @@
use std::sync::Arc;
use std::{collections::BTreeSet, sync::Arc};
use apb::{Activity, ActivityMut, Base, Collection, CollectionPage};
use dashmap::DashMap;
@ -166,6 +166,7 @@ impl Timeline {
let mut out = self.feed();
let mut sub_tasks = Vec::new();
let mut gonna_fetch = BTreeSet::new();
for activity in activities {
// save embedded object if present
@ -175,7 +176,10 @@ impl Timeline {
}
} else { // try fetching it
if let Some(object_id) = activity.object().id() {
sub_tasks.push(fetch_and_update("objects", object_id, auth));
if !gonna_fetch.contains(&object_id) {
gonna_fetch.insert(object_id.clone());
sub_tasks.push(fetch_and_update("objects", object_id, auth));
}
}
}
@ -191,7 +195,10 @@ impl Timeline {
if let Some(uid) = activity.actor().id() {
if CACHE.get(&uid).is_none() {
sub_tasks.push(fetch_and_update("users", uid, auth));
if !gonna_fetch.contains(&uid) {
gonna_fetch.insert(uid.clone());
sub_tasks.push(fetch_and_update("users", uid, auth));
}
}
}
}