make shred path required

Author: 0xNineteen

tinydancer/src/main.rs

@@ -151,10 +151,10 @@ async fn main() -> Result<()> {
                 tui_monitor,
                 log_path: config_file.log_path,
                 archive_config: {
-                    archive_path.map(|path| ArchiveConfig {
+                    archive_path.map(|path| Ok(ArchiveConfig {
                         shred_archive_duration,
                         archive_path: path,
-                    })
+                    })).unwrap_or(Err(anyhow!("shred path not provided...")))?
                 },
             };
 

tinydancer/src/sampler.rs

@@ -54,7 +54,7 @@ pub struct SampleService {
 }
 pub struct SampleServiceConfig {
     pub cluster: Cluster,
-    pub archive_config: Option<ArchiveConfig>,
+    pub archive_config: ArchiveConfig,
     pub instance: Arc<rocksdb::DB>,
     pub status_sampler: Arc<Mutex<ClientStatus>>,
 }
@@ -101,13 +101,11 @@ impl ClientService<SampleServiceConfig> for SampleService {
             // verify shreds + store in db in shred_archiver
             threads.push(tokio::spawn(shred_verify_loop(shred_rx, verified_shred_tx)));
 
-            if let Some(archive_config) = config.archive_config {
-                threads.push(tokio::spawn(shred_archiver(
-                    verified_shred_rx,
-                    archive_config,
-                    config.instance,
-                )));
-            }
+            threads.push(tokio::spawn(shred_archiver(
+                verified_shred_rx,
+                config.archive_config,
+                config.instance,
+            )));
 
             for thread in threads {
                 thread.await.unwrap().unwrap();

tinydancer/src/tinydancer.rs

@@ -46,7 +46,7 @@ pub struct TinyDancerConfig {
     pub rpc_endpoint: Cluster,
     pub sample_qty: u64,
     pub enable_ui_service: bool,
-    pub archive_config: Option<ArchiveConfig>,
+    pub archive_config: ArchiveConfig,
     pub tui_monitor: bool,
     pub log_path: String,
 }
@@ -104,7 +104,7 @@ impl TinyDancer {
         // setup db
         let db = rocksdb::DB::open_cf(
             &opts,
-            archive_config.clone().unwrap().archive_path,
+            archive_config.clone().archive_path,
             vec![SHRED_CF],
         )
         .unwrap();