chore: Fix clippy violations from Cargo.toml (#15216)

/cc @maxdeviant 
Release Notes:

- N/A
This commit is contained in:
Piotr Osiewicz 2024-07-25 20:22:01 +02:00 committed by GitHub
parent d755d29577
commit 86456ce379
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
25 changed files with 94 additions and 93 deletions

View file

@ -1,7 +1,7 @@
use crate::{ConnectionState, RoomUpdate, Sid};
use anyhow::{anyhow, Context, Result};
use async_trait::async_trait;
use collections::{BTreeMap, HashMap, HashSet};
use collections::{btree_map::Entry as BTreeEntry, hash_map::Entry, BTreeMap, HashMap, HashSet};
use futures::Stream;
use gpui::{BackgroundExecutor, ImageSource};
use live_kit_server::{proto, token};
@ -35,18 +35,18 @@ impl TestServer {
executor: BackgroundExecutor,
) -> Result<Arc<TestServer>> {
let mut servers = SERVERS.lock();
if servers.contains_key(&url) {
Err(anyhow!("a server with url {:?} already exists", url))
} else {
if let BTreeEntry::Vacant(e) = servers.entry(url.clone()) {
let server = Arc::new(TestServer {
url: url.clone(),
url,
api_key,
secret_key,
rooms: Default::default(),
executor,
});
servers.insert(url, server.clone());
e.insert(server.clone());
Ok(server)
} else {
Err(anyhow!("a server with url {:?} already exists", url))
}
}
@ -77,11 +77,11 @@ impl TestServer {
#[cfg(any(test, feature = "test-support"))]
self.executor.simulate_random_delay().await;
let mut server_rooms = self.rooms.lock();
if server_rooms.contains_key(&room) {
Err(anyhow!("room {:?} already exists", room))
} else {
server_rooms.insert(room, Default::default());
if let Entry::Vacant(e) = server_rooms.entry(room.clone()) {
e.insert(Default::default());
Ok(())
} else {
Err(anyhow!("room {:?} already exists", room))
}
}
@ -108,13 +108,7 @@ impl TestServer {
let mut server_rooms = self.rooms.lock();
let room = (*server_rooms).entry(room_name.to_string()).or_default();
if room.client_rooms.contains_key(&identity) {
Err(anyhow!(
"{:?} attempted to join room {:?} twice",
identity,
room_name
))
} else {
if let Entry::Vacant(e) = room.client_rooms.entry(identity.clone()) {
for track in &room.video_tracks {
client_room
.0
@ -141,8 +135,14 @@ impl TestServer {
))
.unwrap();
}
room.client_rooms.insert(identity, client_room);
e.insert(client_room);
Ok(())
} else {
Err(anyhow!(
"{:?} attempted to join room {:?} twice",
identity,
room_name
))
}
}