Fix rtc_stream.update event on stream stop (#116)

foxford · Jun 15, 2020 · 7e68204 · 7e68204
1 parent 93f49d8
commit 7e68204
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/src/app/janus.rs b/src/app/janus.rs
@@ -1084,7 +1084,7 @@ async fn handle_event_impl<C: Context>(
                 Ok(Box::new(stream::empty()))
             }
         }
-        IncomingEvent::Detached(ref inev) => {
+        IncomingEvent::HangUp(ref inev) => {
             let rtc_stream_id = Uuid::from_str(inev.opaque_id())
                 .map_err(|err| format!("Failed to parse opaque id as uuid: {}", err))
                 .status(ResponseStatus::BAD_REQUEST)?;
@@ -1121,7 +1121,7 @@ async fn handle_event_impl<C: Context>(
 
             Ok(Box::new(stream::empty()))
         }
-        IncomingEvent::HangUp(_)
+        IncomingEvent::Detached(_)
         | IncomingEvent::Media(_)
         | IncomingEvent::Timeout(_)
         | IncomingEvent::SlowLink(_) => {

diff --git a/src/backend/janus.rs b/src/backend/janus.rs
@@ -344,6 +344,12 @@ pub(crate) struct HangUpEvent {
     reason: String,
 }
 
+impl HangUpEvent {
+    pub(crate) fn opaque_id(&self) -> &str {
+        &self.opaque_id
+    }
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 
 // Audio or video bytes being received by plugin handle
@@ -389,12 +395,6 @@ pub(crate) struct DetachedEvent {
     opaque_id: String,
 }
 
-impl DetachedEvent {
-    pub(crate) fn opaque_id(&self) -> &str {
-        &self.opaque_id
-    }
-}
-
 ////////////////////////////////////////////////////////////////////////////////
 
 // Janus Gateway actual status