2 use actix_web::web::Data;
3 use lemmy_api_common::{
4 request::purge_image_from_pictrs,
5 site::{PurgeCommunity, PurgeItemResponse},
6 utils::{blocking, get_local_user_view_from_jwt, is_admin, purge_image_posts_for_community},
11 moderator::{AdminPurgeCommunity, AdminPurgeCommunityForm},
15 use lemmy_utils::{error::LemmyError, ConnectionId};
16 use lemmy_websocket::LemmyContext;
18 #[async_trait::async_trait(?Send)]
19 impl Perform for PurgeCommunity {
20 type Response = PurgeItemResponse;
22 #[tracing::instrument(skip(context, _websocket_id))]
25 context: &Data<LemmyContext>,
26 _websocket_id: Option<ConnectionId>,
27 ) -> Result<Self::Response, LemmyError> {
28 let data: &Self = self;
30 get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
32 // Only let admins purge an item
33 is_admin(&local_user_view)?;
35 let community_id = data.community_id;
37 // Read the community to get its images
38 let community = blocking(context.pool(), move |conn| {
39 Community::read(conn, community_id)
43 if let Some(banner) = community.banner {
44 purge_image_from_pictrs(context.client(), &context.settings(), &banner)
49 if let Some(icon) = community.icon {
50 purge_image_from_pictrs(context.client(), &context.settings(), &icon)
55 purge_image_posts_for_community(
63 blocking(context.pool(), move |conn| {
64 Community::delete(conn, community_id)
69 let reason = data.reason.to_owned();
70 let form = AdminPurgeCommunityForm {
71 admin_person_id: local_user_view.person.id,
75 blocking(context.pool(), move |conn| {
76 AdminPurgeCommunity::create(conn, &form)
80 Ok(PurgeItemResponse { success: true })