diff --git a/src/app/janus.rs b/src/app/janus.rs index 21ef7c5c..e788e88f 100644 --- a/src/app/janus.rs +++ b/src/app/janus.rs @@ -1244,9 +1244,12 @@ async fn handle_status_event_impl( 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, diff --git a/src/db/janus_rtc_stream.rs b/src/db/janus_rtc_stream.rs index 6c8c1c3d..026eec79 100644 --- a/src/db/janus_rtc_stream.rs +++ b/src/db/janus_rtc_stream.rs @@ -90,6 +90,11 @@ impl Object { pub(crate) fn created_at(&self) -> DateTime { self.created_at } + + pub(crate) fn set_time(&mut self, time: Option