Send rtc_stream.update with closing time when the backend goes offline (

#158)

src/app/janus.rs

@@ -1244,9 +1244,12 @@ async fn handle_status_event_impl<C: Context>(
             Ok(streams_with_rtc)
         })?;
 
+        let now = Utc::now();
         let mut events = Vec::with_capacity(streams_with_rtc.len());
 
-        for (stream, rtc) in streams_with_rtc {
+        for (mut stream, rtc) in streams_with_rtc {
+            stream.set_time(stream.time().map(|t| (t.0, Bound::Excluded(now))));
+
             let event = endpoint::rtc_stream::update_event(
                 rtc.room_id(),
                 stream,

src/db/janus_rtc_stream.rs

@@ -90,6 +90,11 @@ impl Object {
     pub(crate) fn created_at(&self) -> DateTime<Utc> {
         self.created_at
     }
+
+    pub(crate) fn set_time(&mut self, time: Option<Time>) -> &mut Self {
+        self.time = time;
+        self
+    }
 }
 
 ////////////////////////////////////////////////////////////////////////////////