terminate track actors after participants leave

Author: lherman-cs

pulsebeam/src/controller.rs

@@ -103,7 +103,7 @@ impl ControllerActor {
         offer: String,
     ) -> Result<String, ControllerError> {
         let offer = SdpOffer::from_sdp_string(&offer)?;
-        tracing::info!("{offer}");
+        tracing::debug!("{offer}");
         let mut rtc_config = RtcConfig::new()
             .clear_codecs()
             // TODO: enable bwe
@@ -151,7 +151,7 @@ impl ControllerActor {
             .await
             .map_err(|_| ControllerError::ServiceUnavailable)?;
 
-        tracing::info!("{answer}");
+        tracing::debug!("{answer}");
         Ok(answer.to_sdp_string())
     }
 

pulsebeam/src/participant.rs

@@ -161,6 +161,7 @@ impl actor::Actor for ParticipantActor {
                 self.handle_published_tracks(ctx, tracks.as_ref());
             }
             ParticipantControlMessage::TracksUnpublished(track_ids) => {
+                tracing::info!("tracks unpublished: {track_ids:?}");
                 for track_id in track_ids.keys() {
                     let track = if let Some(track) =
                         self.available_video_tracks.remove(&track_id.internal)

pulsebeam/src/room.rs

@@ -181,8 +181,13 @@ impl RoomActor {
             return;
         };
 
-        for track_id in participant.tracks.keys() {
+        // Explicitly terminate the tracks owned by the leaving participant.
+        // This prevents "zombie" track actors from causing race conditions if the participant rejoins quickly.
+        for (track_id, track_handle) in &participant.tracks {
+            // Remove the track from the central registry.
             self.state.tracks.remove(track_id);
+            // Terminate the track actor itself.
+            let _ = track_handle.terminate().await;
         }
 
         self.system_ctx