X-Git-Url: http://these/git/?a=blobdiff_plain;f=crates%2Fapub%2Fsrc%2Factivities%2Fcommunity%2Fannounce.rs;h=cc30a89f393185ba29b62346bb3c70c2b955eafd;hb=3d08e6c1fc30683c5b575c751a8f6a6bca0fc7ee;hp=2784039bca7a7b0f184922243532cd2d115dcc6a;hpb=76c43780112e2aec0d9250f79adba8c307734601;p=lemmy.git diff --git a/crates/apub/src/activities/community/announce.rs b/crates/apub/src/activities/community/announce.rs index 2784039b..cc30a89f 100644 --- a/crates/apub/src/activities/community/announce.rs +++ b/crates/apub/src/activities/community/announce.rs @@ -1,7 +1,7 @@ use crate::{ activities::{generate_activity_id, send_lemmy_activity, verify_activity, verify_is_public}, activity_lists::AnnouncableActivities, - http::{is_activity_already_known, ActivityCommonFields}, + http::ActivityCommonFields, insert_activity, objects::community::ApubCommunity, protocol::activities::{community::announce::AnnounceActivity, CreateOrUpdateType}, @@ -109,9 +109,6 @@ impl ActivityHandler for AnnounceActivity { let object_value = serde_json::to_value(&self.object)?; let object_data: ActivityCommonFields = serde_json::from_value(object_value.to_owned())?; - if is_activity_already_known(context.pool(), &object_data.id).await? { - return Ok(()); - } insert_activity(&object_data.id, object_value, false, true, context.pool()).await?; } }