From eb4897542866548f7c825a17812398723ec0b933 Mon Sep 17 00:00:00 2001 From: Zomatree Date: Tue, 1 Jul 2025 20:22:53 +0100 Subject: [PATCH] chore: bump livekit dep --- crates/core/database/Cargo.toml | 6 +++--- crates/core/database/src/voice/mod.rs | 18 +++++------------- crates/daemons/voice-ingress/Cargo.toml | 6 +++--- crates/delta/Cargo.toml | 4 ++-- 4 files changed, 13 insertions(+), 21 deletions(-) diff --git a/crates/core/database/Cargo.toml b/crates/core/database/Cargo.toml index a574409e..7794b0d7 100644 --- a/crates/core/database/Cargo.toml +++ b/crates/core/database/Cargo.toml @@ -103,6 +103,6 @@ authifier = { version = "1.0.15", features = ["rocket_impl"] } amqprs = { version = "1.7.0" } # Voice -livekit-api = "0.4.1" -livekit-protocol = "0.3.6" -livekit-runtime = { version = "0.3.1", features = ["tokio"] } \ No newline at end of file +livekit-api = "0.4.4" +livekit-protocol = "0.4.0" +livekit-runtime = { version = "0.3.1", features = ["tokio"] } diff --git a/crates/core/database/src/voice/mod.rs b/crates/core/database/src/voice/mod.rs index eb7ffdf1..ea41a3fd 100644 --- a/crates/core/database/src/voice/mod.rs +++ b/crates/core/database/src/voice/mod.rs @@ -40,9 +40,7 @@ pub async fn set_channel_node(channel: &str, node: &str) -> Result<()> { .await? .set(format!("node:{channel}"), node) .await - .to_internal_error()?; - - Ok(()) + .to_internal_error() } pub async fn get_channel_node(channel: &str) -> Result> { @@ -144,7 +142,7 @@ pub async fn create_voice_state( voice_state.screensharing, ) .set(format!("camera:{unique_key}"), voice_state.camera) - .query_async(&mut get_connection().await?.into_inner()) + .query_async::<_, ()>(&mut get_connection().await?.into_inner()) .await .to_internal_error()?; @@ -170,9 +168,7 @@ pub async fn delete_voice_state( ]) .query_async(&mut get_connection().await?.into_inner()) .await - .to_internal_error()?; - - Ok(()) + .to_internal_error() } pub async fn update_voice_state_tracks( @@ -236,9 +232,7 @@ pub async fn update_voice_state( pipeline .query_async(&mut get_connection().await?.into_inner()) .await - .to_internal_error()?; - - Ok(()) + .to_internal_error() } pub async fn get_voice_channel_members(channel_id: &str) -> Result>> { @@ -322,9 +316,7 @@ pub async fn move_user(user: &str, from: &str, to: &str) -> Result<()> { user, ) .await - .to_internal_error()?; - - Ok(()) + .to_internal_error() } pub async fn sync_voice_permissions(db: &Database, voice_client: &VoiceClient, channel: &Channel, server: Option<&Server>, role_id: Option<&str>) -> Result<()> { diff --git a/crates/daemons/voice-ingress/Cargo.toml b/crates/daemons/voice-ingress/Cargo.toml index 93eee95b..21393e26 100644 --- a/crates/daemons/voice-ingress/Cargo.toml +++ b/crates/daemons/voice-ingress/Cargo.toml @@ -39,6 +39,6 @@ revolt-database = { path = "../../core/database" } revolt-permissions = { path = "../../core/permissions" } # voice -livekit-api = "0.4.1" -livekit-protocol = "0.3.6" -livekit-runtime = { version = "0.3.1", features = ["tokio"] } \ No newline at end of file +livekit-api = "0.4.4" +livekit-protocol = "0.4.0" +livekit-runtime = { version = "0.3.1", features = ["tokio"] } diff --git a/crates/delta/Cargo.toml b/crates/delta/Cargo.toml index 20844b95..05ac9115 100644 --- a/crates/delta/Cargo.toml +++ b/crates/delta/Cargo.toml @@ -83,8 +83,8 @@ revolt-result = { path = "../core/result", features = ["rocket", "okapi"] } revolt-permissions = { path = "../core/permissions", features = ["schemas"] } # voice -livekit-api = "0.4.1" -livekit-protocol = "0.3.6" +livekit-api = "0.4.4" +livekit-protocol = "0.4.0" [build-dependencies] vergen = "7.5.0"