apollo_storage: add storage reader client

Author: nadin-Starkware

Cargo.lock

@@ -19,6 +19,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"] }
 human_bytes.workspace = true
 indexmap = { workspace = true, features = ["serde"] }
 integer-encoding.workspace = true
@@ -30,13 +31,14 @@ page_size.workspace = true
 papyrus_common.workspace = true
 parity-scale-codec.workspace = true
 primitive-types.workspace = true
+reqwest = { workspace = true, features = ["json"] }
 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"] }

crates/apollo_storage/Cargo.toml

@@ -0,0 +1,46 @@
+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 JSON 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://{Ipv4Addr::LOCALHOST}:{args.storage_reader_port}/storage/query");
+
+    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);
+}