fixed sweeper module

src/main.rs

@@ -17,7 +17,7 @@ use nyazoom_headers::ForwardedFor;
 
 use sanitize_filename_reader_friendly::sanitize;
 
-use std::{io, net::SocketAddr, path::Path, time::Duration};
+use std::{io, net::SocketAddr, path::Path};
 
 use tokio_util::{
     compat::FuturesAsyncWriteCompatExt,
@@ -65,7 +65,7 @@ async fn main() -> io::Result<()> {
 
     let state = cache::fetch_cache().await;
 
-    let _ = sweeper::spawn_sweeper();
+    sweeper::spawn_sweeper(state.clone());
 
     // Router Setup
     let app = Router::new()

src/sweeper.rs

@@ -1,10 +1,10 @@
-use tokio::task::JoinHandle;
+use std::time::Duration;
 
-pub fn spawn_sweeper() -> JoinHandle<!> {
+use crate::state::{AppState, AsyncRemoveRecord};
-    // Spawn a repeating task that will clean files periodically
+
-    tokio::spawn({
+/// Spawn a repeating task that will clean files periodically
-        let state = state.clone();
+pub fn spawn_sweeper(state: AppState) {
-        async move {
+    tokio::spawn(async move {
         loop {
             tokio::time::sleep(Duration::from_secs(15 * 60)).await;
             tracing::info!("Cleaning Sweep!");
@@ -18,6 +18,5 @@ pub fn spawn_sweeper() -> JoinHandle<!> {
                 }
             }
         }
-        }
+    });
-    })
 }