From ff6744c6d4c7de6d7f6998555a28e80b825c10b3 Mon Sep 17 00:00:00 2001
From: sprites0 <199826320+sprites0@users.noreply.github.com>
Date: Wed, 2 Jul 2025 10:45:31 +0000
Subject: [PATCH] fix: Fix local node source being ignored

---
 src/pseudo_peer/cli.rs | 24 ++++++++++++++++--------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/src/pseudo_peer/cli.rs b/src/pseudo_peer/cli.rs
index f4f53ae43..7cdc922e1 100644
--- a/src/pseudo_peer/cli.rs
+++ b/src/pseudo_peer/cli.rs
@@ -22,6 +22,12 @@ pub struct BlockSourceArgs {
 
 impl BlockSourceArgs {
     pub async fn parse(&self) -> eyre::Result<BlockSourceConfig> {
+        let config = self.create_base_config().await?;
+        let config = self.apply_node_source_config(config);
+        Ok(config)
+    }
+
+    async fn create_base_config(&self) -> eyre::Result<BlockSourceConfig> {
         if self.s3 {
             return Ok(BlockSourceConfig::s3_default().await);
         }
@@ -32,17 +38,19 @@ impl BlockSourceArgs {
             ));
         };
 
-        let mut config = if let Some(bucket) = value.strip_prefix("s3://") {
-            BlockSourceConfig::s3(bucket.to_string()).await
+        if let Some(bucket) = value.strip_prefix("s3://") {
+            Ok(BlockSourceConfig::s3(bucket.to_string()).await)
         } else {
-            BlockSourceConfig::local(value.to_string())
+            Ok(BlockSourceConfig::local(value.to_string()))
+        }
+    }
+
+    fn apply_node_source_config(&self, config: BlockSourceConfig) -> BlockSourceConfig {
+        let Some(block_source_from_node) = self.block_source_from_node.as_ref() else {
+            return config;
         };
 
-        if let Some(block_source_from_node) = self.block_source_from_node.as_ref() {
-            config = config.with_block_source_from_node(block_source_from_node.to_string());
-        }
-
-        Ok(config)
+        config.with_block_source_from_node(block_source_from_node.to_string())
     }
 }