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

   1 use crate::{
   2   activities::{
   3     community::{announce::GetCommunity, 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   local_instance,
  11   objects::{community::ApubCommunity, person::ApubPerson},
  12   protocol::activities::community::update::UpdateCommunity,
  13   ActorType,
  14 };
  15 use activitypub_federation::{
  16   core::object_id::ObjectId,
  17   data::Data,
  18   traits::{ActivityHandler, ApubObject},
  19 };
  20 use activitystreams_kinds::{activity::UpdateType, public};
  21 use lemmy_db_schema::{source::community::Community, traits::Crud};
  22 use lemmy_utils::error::LemmyError;
  23 use lemmy_websocket::{send::send_community_ws_message, LemmyContext, UserOperationCrud};
  24 use url::Url;
  25
  26 impl UpdateCommunity {
  27   #[tracing::instrument(skip_all)]
  28   pub async fn send(
  29     community: ApubCommunity,
  30     actor: &ApubPerson,
  31     context: &LemmyContext,
  32   ) -> Result<(), LemmyError> {
  33     let id = generate_activity_id(
  34       UpdateType::Update,
  35       &context.settings().get_protocol_and_hostname(),
  36     )?;
  37     let update = UpdateCommunity {
  38       actor: ObjectId::new(actor.actor_id()),
  39       to: vec![public()],
  40       object: Box::new(community.clone().into_apub(context).await?),
  41       cc: vec![community.actor_id()],
  42       kind: UpdateType::Update,
  43       id: id.clone(),
  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.get_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.get_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 }
 115
 116 #[async_trait::async_trait(?Send)]
 117 impl GetCommunity for UpdateCommunity {
 118   #[tracing::instrument(skip_all)]
 119   async fn get_community(
 120     &self,
 121     context: &LemmyContext,
 122     request_counter: &mut i32,
 123   ) -> Result<ApubCommunity, LemmyError> {
 124     let cid = ObjectId::new(self.object.id.clone());
 125     cid
 126       .dereference(context, local_instance(context).await, request_counter)
 127       .await
 128   }
 129 }