Fixing some minor websocket things.

diff --git a/lemmy_api/src/comment.rs b/lemmy_api/src/comment.rs
index fca5eb5dea1dad7d2a06eb4f0b1aa63b1574e577..fbbed6d62c18fa5a4a0fb338dc2e7d178bdd95cc 100644 (file)
--- a/lemmy_api/src/comment.rs
+++ b/lemmy_api/src/comment.rs
@@ -152,7 +152,7 @@ impl Perform for CreateComment {
       comment_view.comment.read = true;
     }
 
-    let mut res = CommentResponse {
+    let res = CommentResponse {
       comment_view,
       recipient_ids,
       form_id: data.form_id.to_owned(),
@@ -164,11 +164,6 @@ impl Perform for CreateComment {
       websocket_id,
     });
 
-    // strip out the recipient_ids, so that
-    // users don't get double notifs
-    // TODO Do this in a different way
-    res.recipient_ids = Vec::new();
-
     Ok(res)
   }
 }
@@ -233,7 +228,7 @@ impl Perform for EditComment {
     })
     .await??;
 
-    let mut res = CommentResponse {
+    let res = CommentResponse {
       comment_view,
       recipient_ids,
       form_id: data.form_id.to_owned(),
@@ -245,11 +240,6 @@ impl Perform for EditComment {
       websocket_id,
     });
 
-    // strip out the recipient_ids, so that
-    // users don't get double notifs
-    // TODO again
-    res.recipient_ids = Vec::new();
-
     Ok(res)
   }
 }
@@ -318,7 +308,7 @@ impl Perform for DeleteComment {
     )
     .await?;
 
-    let mut res = CommentResponse {
+    let res = CommentResponse {
       comment_view,
       recipient_ids,
       form_id: None, // TODO a comment delete might clear forms?
@@ -330,11 +320,6 @@ impl Perform for DeleteComment {
       websocket_id,
     });
 
-    // strip out the recipient_ids, so that
-    // users don't get double notifs
-    // TODO again
-    res.recipient_ids = Vec::new();
-
     Ok(res)
   }
 }
@@ -414,7 +399,7 @@ impl Perform for RemoveComment {
     )
     .await?;
 
-    let mut res = CommentResponse {
+    let res = CommentResponse {
       comment_view,
       recipient_ids,
       form_id: None, // TODO maybe this might clear other forms
@@ -426,11 +411,6 @@ impl Perform for RemoveComment {
       websocket_id,
     });
 
-    // strip out the recipient_ids, so that
-    // users don't get double notifs
-    // TODO again
-    res.recipient_ids = Vec::new();
-
     Ok(res)
   }
 }
@@ -602,7 +582,7 @@ impl Perform for CreateCommentLike {
     })
     .await??;
 
-    let mut res = CommentResponse {
+    let res = CommentResponse {
       comment_view: liked_comment,
       recipient_ids,
       form_id: None,
@@ -614,11 +594,6 @@ impl Perform for CreateCommentLike {
       websocket_id,
     });
 
-    // strip out the recipient_ids, so that
-    // users don't get double notifs
-    res.recipient_ids = Vec::new();
-    // TODO why
-
     Ok(res)
   }
 }

diff --git a/lemmy_api/src/community.rs b/lemmy_api/src/community.rs
index f01e07404b8d8f541ff297f8a303b739f8faca82..7cb7be7d8b192f766c628834117f33ed6e222728 100644 (file)
--- a/lemmy_api/src/community.rs
+++ b/lemmy_api/src/community.rs
@@ -853,15 +853,13 @@ fn send_community_websocket(
   websocket_id: Option<ConnectionId>,
   op: UserOperation,
 ) {
-  // TODO is there any way around this?
   // Strip out the user id and subscribed when sending to others
-  // let mut res_sent = res.clone();
-  // res_sent.community_view.user_id = None;
-  // res_sent.community.subscribed = None;
+  let mut res_sent = res.clone();
+  res_sent.community_view.subscribed = false;
 
   context.chat_server().do_send(SendCommunityRoomMessage {
     op,
-    response: res.to_owned(),
+    response: res_sent,
     community_id: res.community_view.community.id,
     websocket_id,
   });

diff --git a/lemmy_websocket/src/chat_server.rs b/lemmy_websocket/src/chat_server.rs
index f149d6e1e7dc12ac8c20817a704b78700bd6cf33..cdfac6c512b6af73f79ee06e5d509496e519d5a1 100644 (file)
--- a/lemmy_websocket/src/chat_server.rs
+++ b/lemmy_websocket/src/chat_server.rs
@@ -328,15 +328,14 @@ impl ChatServer {
     comment: &CommentResponse,
     websocket_id: Option<ConnectionId>,
   ) -> Result<(), LemmyError> {
-    let comment_reply_sent = comment.clone();
-    // TODO what is this here
-    // comment_reply_sent.comment_view.my_vote = None;
-    // comment_reply_sent.comment.user_id = None;
+    let mut comment_reply_sent = comment.clone();
 
-    let mut comment_post_sent = comment_reply_sent.clone();
-    comment_post_sent.recipient_ids = Vec::new();
+    // Strip out my specific user info
+    comment_reply_sent.comment_view.my_vote = None;
 
     // Send it to the post room
+    let mut comment_post_sent = comment_reply_sent.clone();
+    comment_post_sent.recipient_ids = Vec::new();
     self.send_post_room_message(
       user_operation,
       &comment_post_sent,
@@ -344,6 +343,17 @@ impl ChatServer {
       websocket_id,
     )?;
 
+    // Send it to the community too
+    self.send_community_room_message(user_operation, &comment_post_sent, 0, websocket_id)?;
+    self.send_community_room_message(
+      user_operation,
+      &comment_post_sent,
+      comment.comment_view.community.id,
+      websocket_id,
+    )?;
+
+    // Remove the form id here to separate mentions / user messages from post or community comments
+    comment_reply_sent.form_id = None;
     // Send it to the recipient(s) including the mentioned users
     for recipient_id in &comment_reply_sent.recipient_ids {
       self.send_user_room_message(
@@ -354,15 +364,6 @@ impl ChatServer {
       )?;
     }
 
-    // Send it to the community too
-    self.send_community_room_message(user_operation, &comment_post_sent, 0, websocket_id)?;
-    self.send_community_room_message(
-      user_operation,
-      &comment_post_sent,
-      comment.comment_view.community.id,
-      websocket_id,
-    )?;
-
     Ok(())
   }
 
@@ -375,19 +376,17 @@ impl ChatServer {
     let community_id = post_res.post_view.community.id;
 
     // Don't send my data with it
-    // TODO no idea what to do here
-    // let mut post_sent = post_res.clone();
-    // post_sent.post.my_vote = None;
-    // post_sent.post.user_id = None;
+    let mut post_sent = post_res.clone();
+    post_sent.post_view.my_vote = None;
 
     // Send it to /c/all and that community
-    self.send_community_room_message(user_operation, &post_res, 0, websocket_id)?;
-    self.send_community_room_message(user_operation, &post_res, community_id, websocket_id)?;
+    self.send_community_room_message(user_operation, &post_sent, 0, websocket_id)?;
+    self.send_community_room_message(user_operation, &post_sent, community_id, websocket_id)?;
 
     // Send it to the post room
     self.send_post_room_message(
       user_operation,
-      &post_res,
+      &post_sent,
       post_res.post_view.post.id,
       websocket_id,
     )?;