nutomic/ibis
1
0
Fork 0
mirror of https://github.com/Nutomic/ibis.git synced 2024-11-22 17:51:08 +00:00
Code Projects Releases Packages Activity

Fix all tests

Browse source
This commit is contained in:
Felix Ableitner 2024-11-12 12:16:59 +01:00
parent 639ca1704f
commit 5f306e6600
3 changed files with 27 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/backend/federation/activities/update_remote_article.rs
View file

@ -80,7 +80,7 @@ impl ActivityHandler for UpdateRemoteArticle {
Ok(()) Ok(())
} }
/// Received on article origin instances /// Received on article origin instance
async fn receive(self, data: &Data<Self::DataType>) -> Result<(), Self::Error> { async fn receive(self, data: &Data<Self::DataType>) -> Result<(), Self::Error> {
let local_article = DbArticle::read_from_ap_id(&self.object.object, data)?; let local_article = DbArticle::read_from_ap_id(&self.object.object, data)?;
let patch = Patch::from_str(&self.object.content)?; let patch = Patch::from_str(&self.object.content)?;

10
src/backend/federation/objects/articles_collection.rs
View file

@ -79,15 +79,19 @@ impl Collection for DbArticleCollection {
_owner: &Self::Owner, _owner: &Self::Owner,
data: &Data<Self::DataType>, data: &Data<Self::DataType>,
) -> Result<Self, Self::Error> { ) -> Result<Self, Self::Error> {
join_all(apub.items.into_iter().map(|article| async { let articles =
apub.items
.into_iter()
.filter(|i| !i.id.is_local(data))
.map(|article| async {
let id = article.id.clone(); let id = article.id.clone();
let res = DbArticle::from_json(article, data).await; let res = DbArticle::from_json(article, data).await;
if let Err(e) = &res { if let Err(e) = &res {
warn!("Failed to synchronize article {id}: {e}"); warn!("Failed to synchronize article {id}: {e}");
} }
res res
})) });
.await; join_all(articles).await;
Ok(DbArticleCollection(())) Ok(DbArticleCollection(()))
} }

10
src/backend/federation/objects/instance_collection.rs
View file

@ -79,15 +79,19 @@ impl Collection for DbInstanceCollection {
_owner: &Self::Owner, _owner: &Self::Owner,
data: &Data<Self::DataType>, data: &Data<Self::DataType>,
) -> Result<Self, Self::Error> { ) -> Result<Self, Self::Error> {
join_all(apub.items.into_iter().map(|instance| async { let instances =
apub.items
.into_iter()
.filter(|i| !i.id.is_local(data))
.map(|instance| async {
let id = instance.id.clone(); let id = instance.id.clone();
let res = DbInstance::from_json(instance, data).await; let res = DbInstance::from_json(instance, data).await;
if let Err(e) = &res { if let Err(e) = &res {
warn!("Failed to synchronize article {id}: {e}"); warn!("Failed to synchronize article {id}: {e}");
} }
res res
})) });
.await; join_all(instances).await;
Ok(DbInstanceCollection(())) Ok(DbInstanceCollection(()))
} }