feat: add config for archive

Author: 4rjunc

cli/src/cli.rs

@@ -271,7 +271,9 @@ impl Context{
     }
 
     pub fn open_primary_store_conn(&self) -> Result<TapeStore> {
-        Ok(tape_network::store::primary()?)
+        let rocksdb_config = self.config.storage.rocksdb.as_ref()
+            .ok_or_else(|| anyhow::anyhow!("RocksDB config not found"))?;
+        Ok(tape_network::store::primary(&rocksdb_config.primary_path)?)
     }
 
     pub fn open_secondary_store_conn_mine(&self) -> Result<TapeStore> {

cli/src/main.rs

@@ -87,7 +87,9 @@ async fn run_tape_cli() -> Result<()> {
         Commands::Web { .. } |
         Commands::Archive { .. } |
         Commands::Mine { .. } => {
-            TapeStore::try_init_store()?;
+            let rocksdb_config = context.config.storage.rocksdb.as_ref()
+              .ok_or_else(|| anyhow::anyhow!("RocksDB config not found"))?;
+            TapeStore::try_init_store(&rocksdb_config.primary_path)?;
             network::handle_network_commands(cli, context).await?;
         }
 

network/src/store/helpers.rs

@@ -1,9 +1,9 @@
 use super::{TapeStore, StoreError, consts::*};
 use std::{env, sync::Arc};
 
-pub fn primary() -> Result<TapeStore, StoreError> {
+pub fn primary(tape_store_primary_db: &str) -> Result<TapeStore, StoreError> {
     let current_dir = env::current_dir().map_err(StoreError::IoError)?;
-    let db_primary = current_dir.join(TAPE_STORE_PRIMARY_DB);
+    let db_primary = current_dir.join(tape_store_primary_db);
     std::fs::create_dir_all(&db_primary).map_err(StoreError::IoError)?;
     TapeStore::new(&db_primary)
 }

network/src/store/store.rs

@@ -25,8 +25,8 @@ impl TapeStore {
         Ok(Self { db })
     }
 
-    pub fn try_init_store() -> Result<(), StoreError> {
-        if let Ok(_store) = super::helpers::primary() {
+    pub fn try_init_store(tape_store_primary_db: &str) -> Result<(), StoreError> {
+        if let Ok(_store) = super::helpers::primary(tape_store_primary_db) {
             log::debug!("Primary store initialized successfully");
         }
         Ok(())
@@ -74,4 +74,3 @@ impl Drop for TapeStore {
         // RocksDB handles cleanup automatically
     }
 }
-