bstein/lesavka
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: bump bundled media release to 0.18.0

Browse Source
This commit is contained in:
Brad Stein 2026-05-03 03:00:19 -03:00
parent fdb7e7ce37
commit 82acfacc1f
6 changed files with 12 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
AGENTS.md
View File

@ -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.

6
Cargo.lock generated
View File

@ -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",

2
client/Cargo.toml
View File

@ -4,7 +4,7 @@ path = "src/main.rs"
[package]
name = "lesavka_client"
version = "0.17.39"
version = "0.18.0"
edition = "2024"
[dependencies]

2
common/Cargo.toml
View File

@ -1,6 +1,6 @@
[package]
name = "lesavka_common"
version = "0.17.39"
version = "0.18.0"
edition = "2024"
build = "build.rs"

2
server/Cargo.toml
View File

@ -10,7 +10,7 @@ bench = false
[package]
name = "lesavka_server"
version = "0.17.39"
version = "0.18.0"
edition = "2024"
autobins = false

15
server/src/main/relay_service.rs
View File

@ -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();