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 = blocking(context.pool(), move |conn| {
45 Community::update_deleted(conn, community_id, deleted)
48 .map_err(|_| ApiError::err("couldnt_update_community"))?;
53 .send_delete(local_user_view.person.to_owned(), context)
57 .send_undo_delete(local_user_view.person.to_owned(), context)
61 let community_id = data.community_id;
62 let person_id = local_user_view.person.id;
63 let community_view = blocking(context.pool(), move |conn| {
64 CommunityView::read(conn, community_id, Some(person_id))
68 let res = CommunityResponse { community_view };
70 send_community_websocket(
74 UserOperationCrud::DeleteCommunity,
81 #[async_trait::async_trait(?Send)]
82 impl PerformCrud for RemoveCommunity {
83 type Response = CommunityResponse;
87 context: &Data<LemmyContext>,
88 websocket_id: Option<ConnectionId>,
89 ) -> Result<CommunityResponse, LemmyError> {
90 let data: &RemoveCommunity = self;
91 let local_user_view = get_local_user_view_from_jwt(&data.auth, context.pool()).await?;
93 // Verify its an admin (only an admin can remove a community)
94 is_admin(&local_user_view)?;
97 let community_id = data.community_id;
98 let removed = data.removed;
99 let updated_community = blocking(context.pool(), move |conn| {
100 Community::update_removed(conn, community_id, removed)
103 .map_err(|_| ApiError::err("couldnt_update_community"))?;
106 let expires = data.expires.map(naive_from_unix);
107 let form = ModRemoveCommunityForm {
108 mod_person_id: local_user_view.person.id,
109 community_id: data.community_id,
110 removed: Some(removed),
111 reason: data.reason.to_owned(),
114 blocking(context.pool(), move |conn| {
115 ModRemoveCommunity::create(conn, &form)
121 updated_community.send_remove(context).await?;
123 updated_community.send_undo_remove(context).await?;
126 let community_id = data.community_id;
127 let person_id = local_user_view.person.id;
128 let community_view = blocking(context.pool(), move |conn| {
129 CommunityView::read(conn, community_id, Some(person_id))
133 let res = CommunityResponse { community_view };
135 send_community_websocket(
139 UserOperationCrud::RemoveCommunity,