Fix code warnings

Angelillo15 · May 23, 2024 · 005b9ed · 005b9ed
1 parent e4025e2
commit 005b9ed
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 14 deletions.
diff --git a/src/managers/channel.rs b/src/managers/channel.rs
@@ -1,4 +1,4 @@
-use serde::{Serialize, Serializer};
+use serde::{Serialize};
 use uuid::Uuid;
 
 use crate::utils::get_current_time_in_seconds;

diff --git a/src/managers/mod.rs b/src/managers/mod.rs
@@ -1,4 +1,4 @@
-use actix::{Handler, Message, Recipient};
+use actix::{Message};
 use serde::{Deserialize, Serialize};
 
 pub mod channel;

diff --git a/src/services/ws.rs b/src/services/ws.rs
@@ -1,17 +1,17 @@
-use std::sync::mpsc::channel;
-use std::sync::{Arc, Mutex};
 
-use actix::{Actor, Addr, AsyncContext, Message, Recipient, StreamHandler};
+
+
+use actix::{Actor, AsyncContext, Recipient, StreamHandler};
 use actix_web::web::Data;
 use actix_web::{get, web, Error, HttpRequest, HttpResponse};
 use actix_web_actors::ws;
 use log::{debug, error};
-use serde::{Deserialize, Serialize};
+use serde::{Deserialize};
 use uuid::Uuid;
 
-use crate::managers::channel_manager::ChannelManager;
-use crate::managers::{recipient_manager, ConnectedMessage, PropagateMessage};
-use crate::{AppState, RecipientManager};
+
+use crate::managers::{ConnectedMessage, PropagateMessage};
+use crate::{AppState};
 
 #[derive(Clone)]
 pub struct Handler {
@@ -80,7 +80,7 @@ impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for Handler {
 
                     if recipient_manager.recipients.len() == 0 {
                         let channel_manager = app_state.channel_manager.clone();
-                        let mut channel_manager = channel_manager.lock().unwrap();
+                        let channel_manager = channel_manager.lock().unwrap();
                         let uuid = Uuid::parse_str(&self.uuid).unwrap();
                         channel_manager.mark_channel_as_inactive(uuid);
                     }
@@ -123,7 +123,7 @@ async fn index(
     let channel_manager = app_state.channel_manager.clone();
 
     {
-        let mut channel_manager = channel_manager.lock().unwrap();
+        let channel_manager = channel_manager.lock().unwrap();
 
         if !channel_manager.channel_exists(id.clone()) {
             return Ok(HttpResponse::NotFound().finish());

diff --git a/src/tasks/delete_unused_channels_task.rs b/src/tasks/delete_unused_channels_task.rs
@@ -2,7 +2,7 @@ use std::env;
 
 use actix_web::web::Data;
 use chrono::Utc;
-use log::{debug, info};
+use log::{debug};
 use tokio_schedule::{every, Job};
 
 use crate::AppState;
@@ -26,7 +26,7 @@ pub async fn delete_unused_channels_task(app_data: Data<AppState>) {
     let current_time = get_current_time_in_seconds();
 
     {
-        let mut channel_manager = app_data.channel_manager.lock().unwrap();
+        let channel_manager = app_data.channel_manager.lock().unwrap();
 
         for (id, channel) in channel_manager
             .channels
@@ -45,7 +45,7 @@ pub async fn delete_unused_channels_task(app_data: Data<AppState>) {
     }
 
     {
-        let mut channel_manager = app_data.channel_manager.lock().unwrap();
+        let channel_manager = app_data.channel_manager.lock().unwrap();
 
         for id in channels_to_delete {
             channel_manager