crates/apub/src/activities/community/update.rs

   1 use crate::{
   2   activities::{
   3     community::send_activity_in_community,
   4     generate_activity_id,
   5     verify_is_public,
   6     verify_mod_action,
   7     verify_person_in_community,
   8   },
   9   activity_lists::AnnouncableActivities,
  10   objects::{community::ApubCommunity, person::ApubPerson},
  11   protocol::{activities::community::update::UpdateCommunity, InCommunity},
  12   ActorType,
  13 };
  14 use activitypub_federation::{
  15   core::object_id::ObjectId,
  16   data::Data,
  17   traits::{ActivityHandler, ApubObject},
  18 };
  19 use activitystreams_kinds::{activity::UpdateType, public};
  20 use lemmy_db_schema::{source::community::Community, traits::Crud};
  21 use lemmy_utils::error::LemmyError;
  22 use lemmy_websocket::{send::send_community_ws_message, LemmyContext, UserOperationCrud};
  23 use url::Url;
  24
  25 impl UpdateCommunity {
  26   #[tracing::instrument(skip_all)]
  27   pub async fn send(
  28     community: ApubCommunity,
  29     actor: &ApubPerson,
  30     context: &LemmyContext,
  31   ) -> Result<(), LemmyError> {
  32     let id = generate_activity_id(
  33       UpdateType::Update,
  34       &context.settings().get_protocol_and_hostname(),
  35     )?;
  36     let update = UpdateCommunity {
  37       actor: ObjectId::new(actor.actor_id()),
  38       to: vec![public()],
  39       object: Box::new(community.clone().into_apub(context).await?),
  40       cc: vec![community.actor_id()],
  41       kind: UpdateType::Update,
  42       id: id.clone(),
  43       audience: Some(ObjectId::new(community.actor_id())),
  44     };
  45
  46     let activity = AnnouncableActivities::UpdateCommunity(update);
  47     send_activity_in_community(activity, actor, &community, vec![], true, context).await
  48   }
  49 }
  50
  51 #[async_trait::async_trait(?Send)]
  52 impl ActivityHandler for UpdateCommunity {
  53   type DataType = LemmyContext;
  54   type Error = LemmyError;
  55
  56   fn id(&self) -> &Url {
  57     &self.id
  58   }
  59
  60   fn actor(&self) -> &Url {
  61     self.actor.inner()
  62   }
  63
  64   #[tracing::instrument(skip_all)]
  65   async fn verify(
  66     &self,
  67     context: &Data<LemmyContext>,
  68     request_counter: &mut i32,
  69   ) -> Result<(), LemmyError> {
  70     verify_is_public(&self.to, &self.cc)?;
  71     let community = self.community(context, request_counter).await?;
  72     verify_person_in_community(&self.actor, &community, context, request_counter).await?;
  73     verify_mod_action(
  74       &self.actor,
  75       self.object.id.inner(),
  76       community.id,
  77       context,
  78       request_counter,
  79     )
  80     .await?;
  81     ApubCommunity::verify(
  82       &self.object,
  83       &community.actor_id.clone().into(),
  84       context,
  85       request_counter,
  86     )
  87     .await?;
  88     Ok(())
  89   }
  90
  91   #[tracing::instrument(skip_all)]
  92   async fn receive(
  93     self,
  94     context: &Data<LemmyContext>,
  95     request_counter: &mut i32,
  96   ) -> Result<(), LemmyError> {
  97     let community = self.community(context, request_counter).await?;
  98
  99     let community_update_form = self.object.into_update_form();
 100
 101     let updated_community =
 102       Community::update(context.pool(), community.id, &community_update_form).await?;
 103
 104     send_community_ws_message(
 105       updated_community.id,
 106       UserOperationCrud::EditCommunity,
 107       None,
 108       None,
 109       context,
 110     )
 111     .await?;
 112     Ok(())
 113   }
 114 }