[cargo] Clean

ntfy-daemon/src/credentials.rs

@@ -1,6 +1,4 @@
-use std::cell::RefCell;
 use std::collections::HashMap;
-use std::rc::Rc;
 use std::sync::{Arc, RwLock};
 
 use async_trait::async_trait;

ntfy-daemon/src/http_client.rs

@@ -1,14 +1,12 @@
 use anyhow::Result;
 use async_trait::async_trait;
 use reqwest::{header::HeaderMap, Client, Request, RequestBuilder, Response, ResponseBuilderExt};
-use serde_json::{json, Value};
 use std::collections::{HashMap, VecDeque};
 use std::sync::Arc;
 use std::time::Duration;
 use tokio::sync::RwLock;
 use tokio::time;
 
-use crate::models;
 use crate::output_tracker::OutputTrackerAsync;
 
 // Structure to store request information for verification

ntfy-daemon/src/listener.rs

@@ -4,13 +4,13 @@ use std::time::Duration;
 use futures::{StreamExt, TryStreamExt};
 use serde::{Deserialize, Serialize};
 use tokio::io::AsyncBufReadExt;
-use tokio::task::{self, spawn_local, LocalSet};
+use tokio::task::{spawn_local, LocalSet};
 use tokio::{
     select,
     sync::{mpsc, oneshot},
 };
 use tokio_stream::wrappers::LinesStream;
-use tracing::{debug, error, info, warn, Instrument, Span};
+use tracing::{debug, error, info, warn, Instrument};
 
 use crate::credentials::Credentials;
 use crate::http_client::HttpClient;

ntfy-daemon/src/message_repo/mod.rs

@@ -1,5 +1,4 @@
 use std::sync::{Arc, RwLock};
-use std::{cell::RefCell, rc::Rc};
 
 use rusqlite::{params, Connection, Result};
 use tracing::info;

ntfy-daemon/src/models.rs

@@ -388,7 +388,7 @@ impl NullNotifier {
     }
 }
 impl NotificationProxy for NullNotifier {
-    fn send(&self, n: Notification) -> anyhow::Result<()> {
+    fn send(&self, _n: Notification) -> anyhow::Result<()> {
         Ok(())
     }
 }

ntfy-daemon/src/ntfy.rs

@@ -1,14 +1,12 @@
 use crate::actor_utils::send_command;
-use crate::models::NullNetworkMonitor;
-use crate::models::NullNotifier;
 use anyhow::{anyhow, Context};
 use futures::future::join_all;
 use futures::StreamExt;
 use std::{collections::HashMap, future::Future, sync::Arc};
 use tokio::select;
 use tokio::{
-    sync::{broadcast, mpsc, oneshot, RwLock},
-    task::{spawn_local, LocalSet},
+    sync::{mpsc, oneshot, RwLock},
+    task::LocalSet,
 };
 use tracing::{error, info};
 
@@ -16,7 +14,7 @@ use crate::{
     http_client::HttpClient,
     message_repo::Db,
     models::{self, Account},
-    ListenerActor, ListenerCommand, ListenerConfig, ListenerHandle, SharedEnv, SubscriptionHandle,
+    ListenerConfig, ListenerHandle, SharedEnv, SubscriptionHandle,
 };
 
 const CONNECT_TIMEOUT: std::time::Duration = std::time::Duration::from_secs(15);