fix: media session get current false positive (#226)

openstream-fm · Dec 21, 2023 · 840e8e7 · 840e8e7
2 parents d2300c0 + c6df3ef
commit 840e8e7
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/rs/packages/db/src/models/media_session/mod.rs b/rs/packages/db/src/models/media_session/mod.rs
@@ -114,7 +114,18 @@ impl MediaSession {
   pub async fn get_current_for_station(
     station_id: &str,
   ) -> Result<Option<MediaSession>, mongodb::error::Error> {
+
+    // TODO: improve this
+    let open_deployment_ids = crate::deployment::Deployment::cl().distinct(
+      crate::deployment::Deployment::KEY_ID, 
+      doc! {
+        crate::deployment::Deployment::KEY_STATE: crate::deployment::DeploymentState::KEY_ENUM_VARIANT_ACTIVE
+      },
+      None
+    ).await?;
+
     let filter = doc! {
+      MediaSession::KEY_DEPLOYMENT_ID: { "$in": open_deployment_ids },
       MediaSession::KEY_STATION_ID: station_id,
       MediaSession::KEY_STATE: MediaSessionState::KEY_ENUM_VARIANT_OPEN
     };