apollo_storage: add storage reader client

crates/apollo_storage/Cargo.toml

@@ -8,6 +8,7 @@ description = "A storage implementation for a Starknet node."
 
 [features]
 testing = ["starknet_api/testing", "tempfile", "tower"]
+storage_cli = ["clap", "reqwest"]
 
 [dependencies]
 apollo_config.workspace = true
@@ -19,6 +20,7 @@ byteorder.workspace = true
 cairo-lang-casm = { workspace = true, features = ["parity-scale-codec"] }
 cairo-lang-starknet-classes.workspace = true
 cairo-lang-utils.workspace = true
+clap = { workspace = true, features = ["derive"], optional = true }
 human_bytes.workspace = true
 indexmap = { workspace = true, features = ["serde"] }
 integer-encoding.workspace = true
@@ -30,13 +32,14 @@ page_size.workspace = true
 papyrus_common.workspace = true
 parity-scale-codec.workspace = true
 primitive-types.workspace = true
+reqwest = { workspace = true, features = ["json"], optional = true }
 serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true, features = ["arbitrary_precision"] }
 starknet-types-core = { workspace = true, features = ["papyrus-serialization"] }
 starknet_api.workspace = true
 tempfile = { workspace = true, optional = true }
 thiserror.workspace = true
-tokio.workspace = true
+tokio = { workspace = true, features = ["rt-multi-thread"] }
 tower = { workspace = true, optional = true }
 tracing = { workspace = true, features = ["log"] }
 validator = { workspace = true, features = ["derive"] }
@@ -74,3 +77,8 @@ workspace = true
 # Used in apollo_proc_macros for latency_histogram.
 [package.metadata.cargo-machete]
 ignored = ["papyrus_common"]
+
+
+[[bin]]
+name = "storage_cli"
+required-features = ["storage_cli"]

crates/apollo_storage/src/bin/storage_cli.rs

@@ -0,0 +1,48 @@
+#![cfg(feature = "storage_cli")]
+
+use std::net::Ipv4Addr;
+
+use apollo_storage::storage_reader_types::{StorageReaderRequest, StorageReaderResponse};
+use clap::Parser;
+use reqwest::Client;
+
+#[derive(Parser, Debug)]
+#[command(name = "storage_cli", about = "Run storage CLI.")]
+struct Args {
+    #[arg(long)]
+    storage_reader_port: u16,
+
+    /// JSON-encoded request (e.g., '{"Markers":"State"}')
+    #[arg(long)]
+    request_json: String,
+}
+
+#[tokio::main]
+async fn main() {
+    let args = Args::parse();
+
+    // Parse the string into a StorageReaderRequest
+    let request: StorageReaderRequest = serde_json::from_str(&args.request_json)
+        .expect("Failed to parse request JSON. Example: '{\"Markers\":\"State\"}'");
+
+    let client = Client::new();
+    let url = format!("http://{}:{}/storage/query", Ipv4Addr::LOCALHOST, args.storage_reader_port);
+
+    let response = client
+        .post(&url)
+        .json(&request)
+        .send()
+        .await
+        .expect("Failed to send request to storage reader");
+
+    if !response.status().is_success() {
+        let error_text = response.text().await.expect("Failed to read error response");
+        eprintln!("Error from storage reader: {}", error_text);
+        return;
+    }
+
+    let storage_response: StorageReaderResponse =
+        response.json().await.expect("Failed to parse response from storage reader");
+
+    println!("Response: {:?}", storage_response);
+}