X-Git-Url: http://these/git/?a=blobdiff_plain;f=server%2Fsrc%2Fwebsocket%2Fserver.rs;h=faa8041cea2d60ace233d074397516a2bbc428d6;hb=1336b4ed6023e7fcf0fd40be63569966ee4b1b45;hp=0f2d2d26fdb4d89700e1c34efcb9738eed8a6f6d;hpb=641e4c5d96d9d152bc75318b3ea08f789d920b2b;p=lemmy.git

diff --git a/server/src/websocket/server.rs b/server/src/websocket/server.rs
index 0f2d2d26..faa8041c 100644
--- a/server/src/websocket/server.rs
+++ b/server/src/websocket/server.rs
@@ -505,9 +505,6 @@ fn parse_json_message(chat: &mut ChatServer, msg: StandardMessage) -> Result<Str
 
   let user_operation: UserOperation = UserOperation::from_str(&op)?;
 
-  // TODO: none of the chat messages are going to work if stuff is submitted via http api,
-  //       need to move that handling elsewhere
-
   // A DDOS check
   chat.check_rate_limit_message(msg.id, false)?;
 
@@ -554,7 +551,9 @@ fn parse_json_message(chat: &mut ChatServer, msg: StandardMessage) -> Result<Str
     }
     UserOperation::GetCommunity => {
       let get_community: GetCommunity = serde_json::from_str(data)?;
+
       let mut res = Oper::new(get_community).perform(&conn)?;
+
       let community_id = res.community.id;
 
       chat.join_community_room(community_id, msg.id);
@@ -629,6 +628,7 @@ fn parse_json_message(chat: &mut ChatServer, msg: StandardMessage) -> Result<Str
     }
     UserOperation::GetPosts => {
       let get_posts: GetPosts = serde_json::from_str(data)?;
+
       if get_posts.community_id.is_none() {
         // 0 is the "all" community
         chat.join_community_room(0, msg.id);