feat: wip say

src/handler/file.rs

@@ -229,11 +229,24 @@ pub mod say {
             return;
         }
 
+        let username = client.user().unwrap().username.clone();
+
+        let file = data_str(json, "file").unwrap();
+        let file = no_room_path(&room, &file);
         let message = data_str(json, "message").unwrap();
 
-        room.broadcast_json(&serde_json::json!({
+        let peers = room.peers_by_file(&room, &file);
+
+        let params = &serde_json::json!({
             "method": METHOD,
+            "username": username,  // Who speak this message?
+            "file": file,
             "message": message,
-        }));
+            "status": "success",
+        });
+
+        for (_addr, _sender) in peers.iter() {
+            let _ = _sender.send(params.to_string());
+        }
     }
 }

src/room.rs

@@ -65,6 +65,28 @@ impl Room {
         &mut self.peers
     }
 
+    /// Return peers by file.
+    ///
+    /// # Arguments
+    ///
+    /// * `file` - The file path.
+    pub fn peers_by_file(&self, room: &Room, file: &String) -> HashMap<&SocketAddr, &UnboundedSender<String>> {
+        let file = no_room_path(&room, &file);
+
+        let mut data = HashMap::new();
+
+        for (addr, sender) in self.peers.iter() {
+            let client = self.get_client(addr).unwrap();
+            let path = no_room_path(&room, client.get_path());
+            if path == file {
+                continue;
+            }
+            data.insert(addr, sender);
+        }
+
+        data
+    }
+
     /// Return the sender.
     ///
     /// # Arguments