|
|
@ -110,7 +110,6 @@ impl ActivityHandler for CollectionRemove {
|
|
|
|
|
|
|
|
|
|
|
|
#[tracing::instrument(skip_all)]
|
|
|
|
#[tracing::instrument(skip_all)]
|
|
|
|
async fn verify(&self, context: &Data<Self::DataType>) -> Result<(), LemmyError> {
|
|
|
|
async fn verify(&self, context: &Data<Self::DataType>) -> Result<(), LemmyError> {
|
|
|
|
insert_received_activity(&self.id, context).await?;
|
|
|
|
|
|
|
|
verify_is_public(&self.to, &self.cc)?;
|
|
|
|
verify_is_public(&self.to, &self.cc)?;
|
|
|
|
let community = self.community(context).await?;
|
|
|
|
let community = self.community(context).await?;
|
|
|
|
verify_person_in_community(&self.actor, &community, context).await?;
|
|
|
|
verify_person_in_community(&self.actor, &community, context).await?;
|
|
|
@ -120,6 +119,7 @@ impl ActivityHandler for CollectionRemove {
|
|
|
|
|
|
|
|
|
|
|
|
#[tracing::instrument(skip_all)]
|
|
|
|
#[tracing::instrument(skip_all)]
|
|
|
|
async fn receive(self, context: &Data<Self::DataType>) -> Result<(), LemmyError> {
|
|
|
|
async fn receive(self, context: &Data<Self::DataType>) -> Result<(), LemmyError> {
|
|
|
|
|
|
|
|
insert_received_activity(&self.id, context).await?;
|
|
|
|
let (community, collection_type) =
|
|
|
|
let (community, collection_type) =
|
|
|
|
Community::get_by_collection_url(&mut context.pool(), &self.target.into()).await?;
|
|
|
|
Community::get_by_collection_url(&mut context.pool(), &self.target.into()).await?;
|
|
|
|
match collection_type {
|
|
|
|
match collection_type {
|
|
|
|