Extract starting registry watcher to separate function

src/utils/daemon.rs

@@ -15,6 +15,33 @@ use std::sync::Arc;
 use std::time::Duration;
 use std::{env, thread};
 
+fn start_registry_watcher(pool: Pool, build_queue: Arc<BuildQueue>) -> Result<(), Error> {
+    thread::Builder::new()
+        .name("registry index reader".to_string())
+        .spawn(move || {
+            // space this out to prevent it from clashing against the queue-builder thread on launch
+            thread::sleep(Duration::from_secs(30));
+            loop {
+                let opts = opts();
+                let mut doc_builder = DocBuilder::new(opts, pool.clone(), build_queue.clone());
+
+                if doc_builder.is_locked() {
+                    debug!("Lock file exists, skipping checking new crates");
+                } else {
+                    debug!("Checking new crates");
+                    match doc_builder.get_new_crates() {
+                        Ok(n) => debug!("{} crates added to queue", n),
+                        Err(e) => error!("Failed to get new crates: {}", e),
+                    }
+                }
+
+                thread::sleep(Duration::from_secs(60));
+            }
+        })?;
+
+    Ok(())
+}
+
 pub fn start_daemon(
     config: Arc<Config>,
     db: Pool,
@@ -37,32 +64,7 @@ pub fn start_daemon(
 
     if enable_registry_watcher {
         // check new crates every minute
-        let cloned_db = db.clone();
-        let cloned_build_queue = build_queue.clone();
-        thread::Builder::new()
-            .name("registry index reader".to_string())
-            .spawn(move || {
-                // space this out to prevent it from clashing against the queue-builder thread on launch
-                thread::sleep(Duration::from_secs(30));
-                loop {
-                    let opts = opts();
-                    let mut doc_builder =
-                        DocBuilder::new(opts, cloned_db.clone(), cloned_build_queue.clone());
-
-                    if doc_builder.is_locked() {
-                        debug!("Lock file exists, skipping checking new crates");
-                    } else {
-                        debug!("Checking new crates");
-                        match doc_builder.get_new_crates() {
-                            Ok(n) => debug!("{} crates added to queue", n),
-                            Err(e) => error!("Failed to get new crates: {}", e),
-                        }
-                    }
-
-                    thread::sleep(Duration::from_secs(60));
-                }
-            })
-            .unwrap();
+        start_registry_watcher(db.clone(), build_queue.clone())?;
     }
 
     // build new crates every minute