From 82acfacc1f250f52ce02d129cba23926a04cb8c4 Mon Sep 17 00:00:00 2001 From: Brad Stein Date: Sun, 3 May 2026 03:00:19 -0300 Subject: [PATCH] chore: bump bundled media release to 0.18.0 --- AGENTS.md | 2 +- Cargo.lock | 6 +++--- client/Cargo.toml | 2 +- common/Cargo.toml | 2 +- server/Cargo.toml | 2 +- server/src/main/relay_service.rs | 15 +++++---------- 6 files changed, 12 insertions(+), 17 deletions(-) diff --git a/AGENTS.md b/AGENTS.md index 72df1c6..56e7eb4 100644 --- a/AGENTS.md +++ b/AGENTS.md @@ -1,6 +1,6 @@ # Lesavka Agent Notes -## 0.17.39 Bundled Webcam A/V Migration Checklist +## 0.18.0 Bundled Webcam A/V Migration Checklist Context: manual Google Meet and mirrored-probe testing showed the split webcam and microphone uplink design is too fragile under real browser/device pressure. diff --git a/Cargo.lock b/Cargo.lock index 735a7fa..ca60a9f 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1652,7 +1652,7 @@ checksum = "09edd9e8b54e49e587e4f6295a7d29c3ea94d469cb40ab8ca70b288248a81db2" [[package]] name = "lesavka_client" -version = "0.17.39" +version = "0.18.0" dependencies = [ "anyhow", "async-stream", @@ -1686,7 +1686,7 @@ dependencies = [ [[package]] name = "lesavka_common" -version = "0.17.39" +version = "0.18.0" dependencies = [ "anyhow", "base64", @@ -1698,7 +1698,7 @@ dependencies = [ [[package]] name = "lesavka_server" -version = "0.17.39" +version = "0.18.0" dependencies = [ "anyhow", "base64", diff --git a/client/Cargo.toml b/client/Cargo.toml index 8f920c6..1a539ae 100644 --- a/client/Cargo.toml +++ b/client/Cargo.toml @@ -4,7 +4,7 @@ path = "src/main.rs" [package] name = "lesavka_client" -version = "0.17.39" +version = "0.18.0" edition = "2024" [dependencies] diff --git a/common/Cargo.toml b/common/Cargo.toml index 046b2ad..a1b11f2 100644 --- a/common/Cargo.toml +++ b/common/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "lesavka_common" -version = "0.17.39" +version = "0.18.0" edition = "2024" build = "build.rs" diff --git a/server/Cargo.toml b/server/Cargo.toml index 82c753e..2ae0fe3 100644 --- a/server/Cargo.toml +++ b/server/Cargo.toml @@ -10,7 +10,7 @@ bench = false [package] name = "lesavka_server" -version = "0.17.39" +version = "0.18.0" edition = "2024" autobins = false diff --git a/server/src/main/relay_service.rs b/server/src/main/relay_service.rs index 18cf840..2f57adc 100644 --- a/server/src/main/relay_service.rs +++ b/server/src/main/relay_service.rs @@ -35,20 +35,15 @@ struct BundledPlayoutClock { #[cfg(not(coverage))] impl BundledPlayoutClock { - fn ensure( - &mut self, - _bundle: &UpstreamMediaBundle, - events: &[BundledUpstreamEvent], - ) -> Option<(u64, tokio::time::Instant)> { + fn ensure(&mut self, events: &[BundledUpstreamEvent]) -> Option<(u64, tokio::time::Instant)> { if self.base_remote_pts_us.is_none() || self.epoch.is_none() { let base = events.iter().map(BundledUpstreamEvent::remote_pts_us).min()?; self.base_remote_pts_us = Some(base); self.epoch = Some(tokio::time::Instant::now() + bundled_upstream_playout_delay()); } - Some(( - self.base_remote_pts_us.unwrap_or_default(), - self.epoch.expect("bundled epoch initialized"), - )) + let base_remote_pts_us = self.base_remote_pts_us?; + let epoch = self.epoch?; + Some((base_remote_pts_us, epoch)) } } @@ -383,7 +378,7 @@ impl Relay for Handler { ); continue; } - let Some((base_remote_pts_us, epoch)) = clock.ensure(&bundle, &events) else { + let Some((base_remote_pts_us, epoch)) = clock.ensure(&events) else { continue; }; let mixed_bundle = timing_summary.mixed();