aboutsummaryrefslogtreecommitdiff
path: root/server
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2024-03-18 10:46:39 +0100
committermetamuffin <metamuffin@disroot.org>2024-03-18 10:46:39 +0100
commit7d410d53274fdd6840261c286bc2785222256436 (patch)
tree807ac6f960f4c8c9d026111311ec8d8490002157 /server
parent0825cb66e63a0af09f0c0945542d412091010f73 (diff)
downloadkeks-meet-7d410d53274fdd6840261c286bc2785222256436.tar
keks-meet-7d410d53274fdd6840261c286bc2785222256436.tar.bz2
keks-meet-7d410d53274fdd6840261c286bc2785222256436.tar.zst
clippy
Diffstat (limited to 'server')
-rw-r--r--server/src/assets.rs4
-rw-r--r--server/src/idgen.rs9
-rw-r--r--server/src/logic.rs5
-rw-r--r--server/src/main.rs8
4 files changed, 11 insertions, 15 deletions
diff --git a/server/src/assets.rs b/server/src/assets.rs
index d4c1ded..4ddb3a5 100644
--- a/server/src/assets.rs
+++ b/server/src/assets.rs
@@ -63,9 +63,7 @@ struct GrassFs;
#[cfg(debug_assertions)]
impl GrassFs {
pub fn map(p: &std::path::Path) -> std::path::PathBuf {
- std::path::PathBuf::try_from("../client-web/style")
- .unwrap()
- .join(p.file_name().unwrap())
+ std::path::PathBuf::from("../client-web/style").join(p.file_name().unwrap())
}
}
#[cfg(debug_assertions)]
diff --git a/server/src/idgen.rs b/server/src/idgen.rs
index 216b682..ac40b93 100644
--- a/server/src/idgen.rs
+++ b/server/src/idgen.rs
@@ -5,17 +5,10 @@
*/
use tokio::sync::RwLock;
+#[derive(Default)]
pub struct IdGenerator {
x: RwLock<u64>,
}
-
-impl Default for IdGenerator {
- fn default() -> Self {
- Self {
- x: Default::default(),
- }
- }
-}
impl IdGenerator {
pub async fn generate(&self) -> u64 {
// TODO: dummy implementation; ideal would be encrypting the counter
diff --git a/server/src/logic.rs b/server/src/logic.rs
index b16e605..b660914 100644
--- a/server/src/logic.rs
+++ b/server/src/logic.rs
@@ -17,6 +17,7 @@ use std::{
use tokio::sync::{mpsc::Sender, RwLock};
use warp::ws::WebSocket;
+#[allow(clippy::redundant_closure)]
static CLIENTS: LazyLock<RwLock<HashMap<Client, Sender<ClientboundPacket>>>> =
LazyLock::new(|| Default::default());
@@ -141,7 +142,7 @@ impl State {
let mut w = self.watches.write().await;
let r = self.rooms.read().await;
- for e in list.to_owned() {
+ for e in list.iter().cloned() {
w.entry(e.to_string()).or_default().insert(client);
if let Some(r) = r.get(&e) {
client
@@ -170,7 +171,7 @@ impl State {
impl Client {
pub async fn send(&self, packet: ClientboundPacket) {
- if let Some(s) = CLIENTS.read().await.get(&self) {
+ if let Some(s) = CLIENTS.read().await.get(self) {
s.send(packet).await.unwrap();
} else {
warn!("invalid recipient {self:?}")
diff --git a/server/src/main.rs b/server/src/main.rs
index 306aa98..56566db 100644
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -4,6 +4,7 @@
Copyright (C) 2023 metamuffin <metamuffin.org>
*/
#![feature(lazy_cell)]
+#![allow(clippy::let_with_type_underscore)]
pub mod assets;
pub mod config;
pub mod idgen;
@@ -137,9 +138,12 @@ async fn run() {
async fn handle_rejection(err: Rejection) -> Result<impl Reply, Infallible> {
let code = if err.is_not_found() {
StatusCode::NOT_FOUND
- } else if let Some(_) = err.find::<warp::filters::body::BodyDeserializeError>() {
+ } else if err
+ .find::<warp::filters::body::BodyDeserializeError>()
+ .is_some()
+ {
StatusCode::BAD_REQUEST
- } else if let Some(_) = err.find::<warp::reject::MethodNotAllowed>() {
+ } else if err.find::<warp::reject::MethodNotAllowed>().is_some() {
StatusCode::METHOD_NOT_ALLOWED
} else {
error!("unhandled rejection: {:?}", err);