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
 human_bytes.workspace = true
 indexmap = { workspace = true, features = ["serde"] }
 integer-encoding.workspace = true
@@ -30,6 +31,7 @@ page_size.workspace = true
 papyrus_common.workspace = true
 parity-scale-codec.workspace = true
 primitive-types.workspace = true
+reqwest.workspace = true
 serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true, features = ["arbitrary_precision"] }
 starknet-types-core = { workspace = true, features = ["papyrus-serialization"] }

crates/apollo_storage/Cargo.toml

@@ -0,0 +1,44 @@
+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://localhost:{}/storage/query", 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);
+}

crates/apollo_storage/src/bin/storage_cli.rs

@@ -189,7 +189,7 @@ impl<'env, K: KeyTrait + Debug, V: ValueSerde + Debug, T: DupSortTableType + Dup
 
         let sub_key = T::get_sub_key(key)?;
         if let Some(mut bytes) = bytes.strip_prefix(sub_key.as_slice()) {
-            let value = V::deserialize(&mut bytes).ok_or(DbError::InnerDeserialization)?;
+            let value = V::Value::deserialize(&mut bytes).ok_or(DbError::InnerDeserialization)?;
             return Ok(Some(value));
         }
         Ok(None)