crates/api/src/post/lock.rs

   1 use activitypub_federation::config::Data;
   2 use actix_web::web::Json;
   3 use lemmy_api_common::{
   4   build_response::build_post_response,
   5   context::LemmyContext,
   6   post::{LockPost, PostResponse},
   7   send_activity::{ActivityChannel, SendActivityData},
   8   utils::{
   9     check_community_ban,
  10     check_community_deleted_or_removed,
  11     is_mod_or_admin,
  12     local_user_view_from_jwt,
  13   },
  14 };
  15 use lemmy_db_schema::{
  16   source::{
  17     moderator::{ModLockPost, ModLockPostForm},
  18     post::{Post, PostUpdateForm},
  19   },
  20   traits::Crud,
  21 };
  22 use lemmy_utils::error::LemmyError;
  23
  24 #[tracing::instrument(skip(context))]
  25 pub async fn lock_post(
  26   data: Json<LockPost>,
  27   context: Data<LemmyContext>,
  28 ) -> Result<Json<PostResponse>, LemmyError> {
  29   let local_user_view = local_user_view_from_jwt(&data.auth, &context).await?;
  30
  31   let post_id = data.post_id;
  32   let orig_post = Post::read(&mut context.pool(), post_id).await?;
  33
  34   check_community_ban(
  35     local_user_view.person.id,
  36     orig_post.community_id,
  37     &mut context.pool(),
  38   )
  39   .await?;
  40   check_community_deleted_or_removed(orig_post.community_id, &mut context.pool()).await?;
  41
  42   // Verify that only the mods can lock
  43   is_mod_or_admin(
  44     &mut context.pool(),
  45     local_user_view.person.id,
  46     orig_post.community_id,
  47   )
  48   .await?;
  49
  50   // Update the post
  51   let post_id = data.post_id;
  52   let locked = data.locked;
  53   let post = Post::update(
  54     &mut context.pool(),
  55     post_id,
  56     &PostUpdateForm::builder().locked(Some(locked)).build(),
  57   )
  58   .await?;
  59
  60   // Mod tables
  61   let form = ModLockPostForm {
  62     mod_person_id: local_user_view.person.id,
  63     post_id: data.post_id,
  64     locked: Some(locked),
  65   };
  66   ModLockPost::create(&mut context.pool(), &form).await?;
  67
  68   let person_id = local_user_view.person.id;
  69   ActivityChannel::submit_activity(
  70     SendActivityData::LockPost(post, local_user_view.person, data.locked),
  71     &context,
  72   )
  73   .await?;
  74
  75   build_post_response(&context, orig_post.community_id, person_id, post_id).await
  76 }