From 2368ed605ab28c992af8e1619ef4137b63029279 Mon Sep 17 00:00:00 2001 From: Kenny Lopez Date: Mon, 17 Aug 2026 19:12:55 +0100 Subject: [PATCH] Fix Huddle CI lint failures Co-authored-by: Kenny Lopez Co-authored-by: Princess Donut Signed-off-by: Kenny Lopez --- crates/buzz-relay/src/audio/room.rs | 21 +++++++++++---------- mobile/lib/shared/relay/relay_session.dart | 3 +-- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/crates/buzz-relay/src/audio/room.rs b/crates/buzz-relay/src/audio/room.rs index 5a688094c..cf70a0c61 100644 --- a/crates/buzz-relay/src/audio/room.rs +++ b/crates/buzz-relay/src/audio/room.rs @@ -78,6 +78,16 @@ pub struct RosterDelta { pub left: Option, } +/// Successful local admission: peer ID, routing index, audio/control receivers, +/// and the authoritative roster revision assigned to the join. +pub type PeerAdmission = ( + Uuid, + u8, + mpsc::Receiver, + mpsc::Receiver, + u64, +); + /// Reason a peer was refused entry to a room. #[derive(Debug, Clone, Copy, PartialEq, Eq)] pub enum AdmissionError { @@ -229,16 +239,7 @@ impl Room { &self, pubkey: String, requested_version: u8, - ) -> Result< - ( - Uuid, - u8, - mpsc::Receiver, - mpsc::Receiver, - u64, - ), - AdmissionError, - > { + ) -> Result { let mut g = self.guard.lock().map_err( |_| AdmissionError::Ended, /* poisoned ≈ shutting down */ )?; diff --git a/mobile/lib/shared/relay/relay_session.dart b/mobile/lib/shared/relay/relay_session.dart index c861b706d..77e10e66e 100644 --- a/mobile/lib/shared/relay/relay_session.dart +++ b/mobile/lib/shared/relay/relay_session.dart @@ -75,8 +75,7 @@ class _BufferedEvent { _BufferedEvent(this.subId, this.event); } -/// Manages websocket subscriptions, event batching, reconnection with replay, -/// and pending event tracking. Equivalent to the desktop's RelayClientSession. +/// Manages websocket subscriptions, batching, reconnection, and pending events. typedef RelaySocketFactory = RelaySocket Function({ required String wsUrl,