summaryrefslogtreecommitdiffstats
path: root/server/src
diff options
context:
space:
mode:
Diffstat (limited to 'server/src')
-rw-r--r--server/src/api/community.rs117
-rw-r--r--server/src/api/mod.rs2
-rw-r--r--server/src/api/post.rs6
-rw-r--r--server/src/api/site.rs80
-rw-r--r--server/src/api/user.rs6
-rw-r--r--server/src/db/comment.rs7
-rw-r--r--server/src/db/community.rs10
-rw-r--r--server/src/websocket/server.rs10
8 files changed, 230 insertions, 8 deletions
diff --git a/server/src/api/community.rs b/server/src/api/community.rs
index 74058488..37bc20db 100644
--- a/server/src/api/community.rs
+++ b/server/src/api/community.rs
@@ -111,6 +111,13 @@ pub struct GetFollowedCommunitiesResponse {
communities: Vec<CommunityFollowerView>
}
+#[derive(Serialize, Deserialize)]
+pub struct TransferCommunity {
+ community_id: i32,
+ user_id: i32,
+ auth: String
+}
+
impl Perform<GetCommunityResponse> for Oper<GetCommunity> {
fn perform(&self) -> Result<GetCommunityResponse, Error> {
let data: &GetCommunity = &self.data;
@@ -148,7 +155,11 @@ impl Perform<GetCommunityResponse> for Oper<GetCommunity> {
}
};
- let admins = UserView::admins(&conn)?;
+ let site_creator_id = Site::read(&conn, 1)?.creator_id;
+ let mut admins = UserView::admins(&conn)?;
+ let creator_index = admins.iter().position(|r| r.id == site_creator_id).unwrap();
+ let creator_user = admins.remove(creator_index);
+ admins.insert(0, creator_user);
// Return the jwt
Ok(
@@ -577,3 +588,107 @@ impl Perform<AddModToCommunityResponse> for Oper<AddModToCommunity> {
)
}
}
+
+impl Perform<GetCommunityResponse> for Oper<TransferCommunity> {
+ fn perform(&self) -> Result<GetCommunityResponse, Error> {
+ let data: &TransferCommunity = &self.data;
+ let conn = establish_connection();
+
+ let claims = match Claims::decode(&data.auth) {
+ Ok(claims) => claims.claims,
+ Err(_e) => {
+ return Err(APIError::err(&self.op, "not_logged_in"))?
+ }
+ };
+
+ let user_id = claims.id;
+
+ let read_community = Community::read(&conn, data.community_id)?;
+
+ // Make sure user is the creator
+ if read_community.creator_id != user_id {
+ return Err(APIError::err(&self.op, "not_an_admin"))?
+ }
+
+ let community_form = CommunityForm {
+ name: read_community.name,
+ title: read_community.title,
+ description: read_community.description,
+ category_id: read_community.category_id,
+ creator_id: data.user_id,
+ removed: None,
+ deleted: None,
+ nsfw: read_community.nsfw,
+ updated: Some(naive_now())
+ };
+
+ let _updated_community = match Community::update(&conn, data.community_id, &community_form) {
+ Ok(community) => community,
+ Err(_e) => {
+ return Err(APIError::err(&self.op, "couldnt_update_community"))?
+ }
+ };
+
+ // You also have to re-do the community_moderator table, reordering it.
+ let mut community_mods = CommunityModeratorView::for_community(&conn, data.community_id)?;
+ let creator_index = community_mods.iter().position(|r| r.user_id == data.user_id).unwrap();
+ let creator_user = community_mods.remove(creator_index);
+ community_mods.insert(0, creator_user);
+
+ CommunityModerator::delete_for_community(&conn, data.community_id)?;
+
+ for cmod in &community_mods {
+
+ let community_moderator_form = CommunityModeratorForm {
+ community_id: cmod.community_id,
+ user_id: cmod.user_id
+ };
+
+ let _inserted_community_moderator = match CommunityModerator::join(&conn, &community_moderator_form) {
+ Ok(user) => user,
+ Err(_e) => {
+ return Err(APIError::err(&self.op, "community_moderator_already_exists"))?
+ }
+ };
+ }
+
+ // Mod tables
+ let form = ModAddCommunityForm {
+ mod_user_id: user_id,
+ other_user_id: data.user_id,
+ community_id: data.community_id,
+ removed: Some(false),
+ };
+ ModAddCommunity::create(&conn, &form)?;
+
+ let community_view = match CommunityView::read(&conn, data.community_id, Some(user_id)) {
+ Ok(community) => community,
+ Err(_e) => {
+ return Err(APIError::err(&self.op, "couldnt_find_community"))?
+ }
+ };
+
+ let moderators = match CommunityModeratorView::for_community(&conn, data.community_id) {
+ Ok(moderators) => moderators,
+ Err(_e) => {
+ return Err(APIError::err(&self.op, "couldnt_find_community"))?
+ }
+ };
+
+ let site_creator_id = Site::read(&conn, 1)?.creator_id;
+ let mut admins = UserView::admins(&conn)?;
+ let creator_index = admins.iter().position(|r| r.id == site_creator_id).unwrap();
+ let creator_user = admins.remove(creator_index);
+ admins.insert(0, creator_user);
+
+ // Return the jwt
+ Ok(
+ GetCommunityResponse {
+ op: self.op.to_string(),
+ community: community_view,
+ moderators: moderators,
+ admins: admins,
+ }
+ )
+ }
+}
diff --git a/server/src/api/mod.rs b/server/src/api/mod.rs
index 3a4a0865..ac11d30c 100644
--- a/server/src/api/mod.rs
+++ b/server/src/api/mod.rs
@@ -22,7 +22,7 @@ pub mod site;
#[derive(EnumString,ToString,Debug)]
pub enum UserOperation {
- Login, Register, CreateCommunity, CreatePost, ListCommunities, ListCategories, GetPost, GetCommunity, CreateComment, EditComment, SaveComment, CreateCommentLike, GetPosts, CreatePostLike, EditPost, SavePost, EditCommunity, FollowCommunity, GetFollowedCommunities, GetUserDetails, GetReplies, GetModlog, BanFromCommunity, AddModToCommunity, CreateSite, EditSite, GetSite, AddAdmin, BanUser, Search, MarkAllAsRead, SaveUserSettings
+ Login, Register, CreateCommunity, CreatePost, ListCommunities, ListCategories, GetPost, GetCommunity, CreateComment, EditComment, SaveComment, CreateCommentLike, GetPosts, CreatePostLike, EditPost, SavePost, EditCommunity, FollowCommunity, GetFollowedCommunities, GetUserDetails, GetReplies, GetModlog, BanFromCommunity, AddModToCommunity, CreateSite, EditSite, GetSite, AddAdmin, BanUser, Search, MarkAllAsRead, SaveUserSettings, TransferCommunity, TransferSite
}
#[derive(Fail, Debug)]
diff --git a/server/src/api/post.rs b/server/src/api/post.rs
index c5985f46..8fc24ac1 100644
--- a/server/src/api/post.rs
+++ b/server/src/api/post.rs
@@ -200,7 +200,11 @@ impl Perform<GetPostResponse> for Oper<GetPost> {
let moderators = CommunityModeratorView::for_community(&conn, post_view.community_id)?;
- let admins = UserView::admins(&conn)?;
+ let site_creator_id = Site::read(&conn, 1)?.creator_id;
+ let mut admins = UserView::admins(&conn)?;
+ let creator_index = admins.iter().position(|r| r.id == site_creator_id).unwrap();
+ let creator_user = admins.remove(creator_index);
+ admins.insert(0, creator_user);
// Return the jwt
Ok(
diff --git a/server/src/api/site.rs b/server/src/api/site.rs
index c98539be..7827913b 100644
--- a/server/src/api/site.rs
+++ b/server/src/api/site.rs
@@ -83,6 +83,12 @@ pub struct GetSiteResponse {
banned: Vec<UserView>,
}
+#[derive(Serialize, Deserialize)]
+pub struct TransferSite {
+ user_id: i32,
+ auth: String
+}
+
impl Perform<ListCategoriesResponse> for Oper<ListCategories> {
fn perform(&self) -> Result<ListCategoriesResponse, Error> {
let _data: &ListCategories = &self.data;
@@ -251,7 +257,14 @@ impl Perform<GetSiteResponse> for Oper<GetSite> {
Err(_e) => None
};
- let admins = UserView::admins(&conn)?;
+ let mut admins = UserView::admins(&conn)?;
+ if site_view.is_some() {
+ let site_creator_id = site_view.to_owned().unwrap().creator_id;
+ let creator_index = admins.iter().position(|r| r.id == site_creator_id).unwrap();
+ let creator_user = admins.remove(creator_index);
+ admins.insert(0, creator_user);
+ }
+
let banned = UserView::banned(&conn)?;
Ok(
@@ -399,3 +412,68 @@ impl Perform<SearchResponse> for Oper<Search> {
)
}
}
+
+impl Perform<GetSiteResponse> for Oper<TransferSite> {
+ fn perform(&self) -> Result<GetSiteResponse, Error> {
+ let data: &TransferSite = &self.data;
+ let conn = establish_connection();
+
+ let claims = match Claims::decode(&data.auth) {
+ Ok(claims) => claims.claims,
+ Err(_e) => {
+ return Err(APIError::err(&self.op, "not_logged_in"))?
+ }
+ };
+
+ let user_id = claims.id;
+
+ let read_site = Site::read(&conn, 1)?;
+
+ // Make sure user is the creator
+ if read_site.creator_id != user_id {
+ return Err(APIError::err(&self.op, "not_an_admin"))?
+ }
+
+ let site_form = SiteForm {
+ name: read_site.name,
+ description: read_site.description,
+ creator_id: data.user_id,
+ updated: Some(naive_now()),
+ };
+
+ match Site::update(&conn, 1, &site_form) {
+ Ok(site) => site,
+ Err(_e) => {
+ return Err(APIError::err(&self.op, "couldnt_update_site"))?
+ }
+ };
+
+ // Mod tables
+ let form = ModAddForm {
+ mod_user_id: user_id,
+ other_user_id: data.user_id,
+ removed: Some(false),
+ };
+
+ ModAdd::create(&conn, &form)?;
+
+ let site_view = SiteView::read(&conn)?;
+
+ let mut admins = UserView::admins(&conn)?;
+ let creator_index = admins.iter().position(|r| r.id == site_view.creator_id).unwrap();
+ let creator_user = admins.remove(creator_index);
+ admins.insert(0, creator_user);
+
+ let banned = UserView::banned(&conn)?;
+
+ Ok(
+ GetSiteResponse {
+ op: self.op.to_string(),
+ site: Some(site_view),
+ admins: admins,
+ banned: banned,
+ }
+ )
+ }
+}
+
diff --git a/server/src/api/user.rs b/server/src/api/user.rs
index 425cc1cb..d8610fa9 100644
--- a/server/src/api/user.rs
+++ b/server/src/api/user.rs
@@ -432,7 +432,11 @@ impl Perform<AddAdminResponse> for Oper<AddAdmin> {
ModAdd::create(&conn, &form)?;
- let admins = UserView::admins(&conn)?;
+ let site_creator_id = Site::read(&conn, 1)?.creator_id;
+ let mut admins = UserView::admins(&conn)?;
+ let creator_index = admins.iter().position(|r| r.id == site_creator_id).unwrap();
+ let creator_user = admins.remove(creator_index);
+ admins.insert(0, creator_user);
Ok(
AddAdminResponse {
diff --git a/server/src/db/comment.rs b/server/src/db/comment.rs
index ce0b5a63..7901357f 100644
--- a/server/src/db/comment.rs
+++ b/server/src/db/comment.rs
@@ -103,9 +103,10 @@ impl Likeable <CommentLikeForm> for CommentLike {
}
fn remove(conn: &PgConnection, comment_like_form: &CommentLikeForm) -> Result<usize, Error> {
use crate::schema::comment_like::dsl::*;
- diesel::delete(comment_like
- .filter(comment_id.eq(comment_like_form.comment_id))
- .filter(user_id.eq(comment_like_form.user_id)))
+ diesel::delete(
+ comment_like
+ .filter(comment_id.eq(comment_like_form.comment_id))
+ .filter(user_id.eq(comment_like_form.user_id)))
.execute(conn)
}
}
diff --git a/server/src/db/community.rs b/server/src/db/community.rs
index dd6ea94b..e07b5c00 100644
--- a/server/src/db/community.rs
+++ b/server/src/db/community.rs
@@ -101,6 +101,16 @@ impl Joinable<CommunityModeratorForm> for CommunityModerator {
}
}
+impl CommunityModerator {
+ pub fn delete_for_community(conn: &PgConnection, for_community_id: i32) -> Result<usize, Error> {
+ use crate::schema::community_moderator::dsl::*;
+ diesel::delete(
+ community_moderator
+ .filter(community_id.eq(for_community_id)))
+ .execute(conn)
+ }
+}
+
#[derive(Identifiable, Queryable, Associations, PartialEq, Debug)]
#[belongs_to(Community)]
#[table_name = "community_user_ban"]
diff --git a/server/src/websocket/server.rs b/server/src/websocket/server.rs
index c0dee267..b4cbce3a 100644
--- a/server/src/websocket/server.rs
+++ b/server/src/websocket/server.rs
@@ -490,5 +490,15 @@ fn parse_json_message(chat: &mut ChatServer, msg: StandardMessage) -> Result<Str
let res = Oper::new(user_operation, search).perform()?;
Ok(serde_json::to_string(&res)?)
},
+ UserOperation::TransferCommunity => {
+ let transfer_community: TransferCommunity = serde_json::from_str(data)?;
+ let res = Oper::new(user_operation, transfer_community).perform()?;
+ Ok(serde_json::to_string(&res)?)
+ },
+ UserOperation::TransferSite => {
+ let transfer_site: TransferSite = serde_json::from_str(data)?;
+ let res = Oper::new(user_operation, transfer_site).perform()?;
+ Ok(serde_json::to_string(&res)?)
+ },
}
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-06-21 02:26:18 +0000