Speaking indicator

src/vc_server.rs

@@ -55,11 +55,19 @@ impl Server {
             };
             drop(clients);
 
-            *user.voice.lock().await = Some(crate::server::VoiceConnection {
+            let mut voice = user.voice.lock().await;
-                addr,
+
-                channel_id: channel_id.clone(),
+            if let Some(voice) = &mut *voice {
-                last_speaking_sent: Instant::now(),
+                voice.addr = addr;
-            });
+            } else {
+                *voice = Some(crate::server::VoiceConnection {
+                    addr,
+                    channel_id: channel_id.clone(),
+                    last_speaking_sent: Instant::now(),
+                });
+            }
+
+            drop(voice);
 
             self.relay_voice(&sender_pubkey, &channel_id, payload)
                 .await?;
@@ -104,11 +112,10 @@ impl Server {
 
             if now.duration_since(voice.last_speaking_sent).as_millis() >= 600 {
                 for conn in user.connections.lock().await.values() {
-                    let _ = conn
+                    conn.send(&ClientMethod::Speaking {
-                        .send(&ClientMethod::Speaking {
+                        pubkey: crate::crypto::to_string(sender),
-                            pubkey: crate::crypto::to_string(sender),
+                    })
-                        })
+                    .await?;
-                        .await;
                 }
 
                 voice.last_speaking_sent = now;