refactor: extract method JobManger::push_opt

Author: josecelano

src/app.rs

@@ -139,43 +139,38 @@ fn start_torrent_repository_event_listener(
     app_container: &Arc<AppContainer>,
     job_manager: &mut JobManager,
 ) {
-    let opt_handle = jobs::torrent_repository::start_event_listener(config, app_container);
-
-    if let Some(handle) = opt_handle {
-        job_manager.push("torrent_repository_event_listener", handle);
-    }
+    job_manager.push_opt(
+        "torrent_repository_event_listener",
+        jobs::torrent_repository::start_event_listener(config, app_container),
+    );
 }
 
 fn start_tracker_core_event_listener(config: &Configuration, app_container: &Arc<AppContainer>, job_manager: &mut JobManager) {
-    let opt_handle = jobs::tracker_core::start_event_listener(config, app_container);
-
-    if let Some(handle) = opt_handle {
-        job_manager.push("tracker_core_event_listener", handle);
-    }
+    job_manager.push_opt(
+        "tracker_core_event_listener",
+        jobs::tracker_core::start_event_listener(config, app_container),
+    );
 }
 
 fn start_http_core_event_listener(config: &Configuration, app_container: &Arc<AppContainer>, job_manager: &mut JobManager) {
-    let opt_handle = jobs::http_tracker_core::start_event_listener(config, app_container);
-
-    if let Some(handle) = opt_handle {
-        job_manager.push("http_core_event_listener", handle);
-    }
+    job_manager.push_opt(
+        "http_core_event_listener",
+        jobs::http_tracker_core::start_event_listener(config, app_container),
+    );
 }
 
 fn start_udp_core_event_listener(config: &Configuration, app_container: &Arc<AppContainer>, job_manager: &mut JobManager) {
-    let opt_handle = jobs::udp_tracker_core::start_event_listener(config, app_container);
-
-    if let Some(handle) = opt_handle {
-        job_manager.push("udp_core_event_listener", handle);
-    }
+    job_manager.push_opt(
+        "udp_core_event_listener",
+        jobs::udp_tracker_core::start_event_listener(config, app_container),
+    );
 }
 
 fn start_udp_server_event_listener(config: &Configuration, app_container: &Arc<AppContainer>, job_manager: &mut JobManager) {
-    let opt_handle = jobs::udp_tracker_server::start_event_listener(config, app_container);
-
-    if let Some(handle) = opt_handle {
-        job_manager.push("udp_server_event_listener", handle);
-    }
+    job_manager.push_opt(
+        "udp_server_event_listener",
+        jobs::udp_tracker_server::start_event_listener(config, app_container),
+    );
 }
 
 async fn start_the_udp_instances(config: &Configuration, app_container: &Arc<AppContainer>, job_manager: &mut JobManager) {

src/bootstrap/jobs/manager.rs

@@ -36,6 +36,12 @@ impl JobManager {
         self.jobs.push(Job::new(name, handle));
     }
 
+    pub fn push_opt<N: Into<String>>(&mut self, name: N, handle: Option<JoinHandle<()>>) {
+        if let Some(handle) = handle {
+            self.push(name, handle);
+        }
+    }
+
     /// Waits sequentially for all jobs to complete, with a graceful timeout per
     /// job.
     pub async fn wait_for_all(mut self, grace_period: Duration) {