1 use crate::{community::send_community_websocket, PerformCrud};
2 use actix_web::web::Data;
3 use lemmy_api_common::{blocking, community::*, get_local_user_view_from_jwt, is_admin};
4 use lemmy_apub::CommunityType;
5 use lemmy_db_queries::{source::community::Community_, Crud};
6 use lemmy_db_schema::source::{
8 moderator::{ModRemoveCommunity, ModRemoveCommunityForm},
10 use lemmy_db_views_actor::{
11 community_moderator_view::CommunityModeratorView,
12 community_view::CommunityView,
14 use lemmy_utils::{utils::naive_from_unix, ApiError, ConnectionId, LemmyError};
15 use lemmy_websocket::{LemmyContext, UserOperationCrud};
17 #[async_trait::async_trait(?Send)]
18 impl PerformCrud for DeleteCommunity {
19 type Response = CommunityResponse;
23 context: &Data<LemmyContext>,
24 websocket_id: Option<ConnectionId>,
25 ) -> Result<CommunityResponse, LemmyError> {
26 let data: &DeleteCommunity = &self;
27 let local_user_view = get_local_user_view_from_jwt(&data.auth, context.pool()).await?;
29 // Fetch the community mods
30 let community_id = data.community_id;
31 let community_mods = blocking(context.pool(), move |conn| {
32 CommunityModeratorView::for_community(conn, community_id)
36 // Make sure deleter is the top mod
37 if local_user_view.person.id != community_mods[0].moderator.id {
38 return Err(ApiError::err("no_community_edit_allowed").into());
42 let community_id = data.community_id;
43 let deleted = data.deleted;
44 let updated_community = match blocking(context.pool(), move |conn| {
45 Community::update_deleted(conn, community_id, deleted)
49 Ok(community) => community,
50 Err(_e) => return Err(ApiError::err("couldnt_update_community").into()),
55 updated_community.send_delete(context).await?;
57 updated_community.send_undo_delete(context).await?;
60 let community_id = data.community_id;
61 let person_id = local_user_view.person.id;
62 let community_view = blocking(context.pool(), move |conn| {
63 CommunityView::read(conn, community_id, Some(person_id))
67 let res = CommunityResponse { community_view };
69 send_community_websocket(
73 UserOperationCrud::DeleteCommunity,
80 #[async_trait::async_trait(?Send)]
81 impl PerformCrud for RemoveCommunity {
82 type Response = CommunityResponse;
86 context: &Data<LemmyContext>,
87 websocket_id: Option<ConnectionId>,
88 ) -> Result<CommunityResponse, LemmyError> {
89 let data: &RemoveCommunity = &self;
90 let local_user_view = get_local_user_view_from_jwt(&data.auth, context.pool()).await?;
92 // Verify its an admin (only an admin can remove a community)
93 is_admin(&local_user_view)?;
96 let community_id = data.community_id;
97 let removed = data.removed;
98 let updated_community = match blocking(context.pool(), move |conn| {
99 Community::update_removed(conn, community_id, removed)
103 Ok(community) => community,
104 Err(_e) => return Err(ApiError::err("couldnt_update_community").into()),
108 let expires = data.expires.map(naive_from_unix);
109 let form = ModRemoveCommunityForm {
110 mod_person_id: local_user_view.person.id,
111 community_id: data.community_id,
112 removed: Some(removed),
113 reason: data.reason.to_owned(),
116 blocking(context.pool(), move |conn| {
117 ModRemoveCommunity::create(conn, &form)
123 updated_community.send_remove(context).await?;
125 updated_community.send_undo_remove(context).await?;
128 let community_id = data.community_id;
129 let person_id = local_user_view.person.id;
130 let community_view = blocking(context.pool(), move |conn| {
131 CommunityView::read(conn, community_id, Some(person_id))
135 let res = CommunityResponse { community_view };
137 send_community_websocket(
141 UserOperationCrud::RemoveCommunity,