move grpc client progress here

Cargo.toml

@@ -1,4 +1,4 @@
 [workspace]
 resolver = "2"
-members = ["secretrs", "secret-sdk-proto"]
+members = ["secretrs", "secret-sdk-proto", "secret-grpc"]
 exclude = ["proto-build"]

secret-grpc/Cargo.toml

@@ -0,0 +1,57 @@
+[package]
+name = "secret-grpc"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+# general
+tracing = "0.1.40"
+async-trait = "0.1.81"
+base64 = "0.22.1"
+hex = "0.4.3"
+hex-literal = "0.4.1"
+regex = "1.10.6"
+serde = "1.0.209"
+serde_json = { version = "1.0.127" }
+prost = "0.13.1"
+derive_more = { version = "1.0.0-beta", default-features = false, features = ["from"] }
+nanorand = { version = "0.7.0", features = ["getrandom", "zeroize"] }
+tokio = { version = "1.39.3", features = ["time"] }
+
+# crypto
+hkdf = "0.12.4"
+sha2 = "0.10.8"
+aes-siv = "0.7.0"
+x25519-dalek = { version = "2.0.1", features = ["static_secrets"] }
+
+# blockchain
+secretrs = { version = "0.1.2" }
+ibc-proto = "0.49.0"
+bip39 = "2.0.0"
+
+# errors
+thiserror = "1.0.63"
+
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
+tonic = { version = "0.12.2", features = ["tls", "tls-webpki-roots", "transport"] }
+
+[target.'cfg(target_arch = "wasm32")'.dependencies]
+tonic = { version = "0.12.2", default-features = false, features = ["codegen", "prost"] }
+tonic-web-wasm-client = "0.6.0"
+web-sys = { version = "0.3.70", features = ["Window"] }
+wasm-bindgen-futures = "0.4.43"
+getrandom = { version = "0.2.15", features = ["js"] }
+
+[dev-dependencies]
+tokio = { version = "1.39.3", features = ["rt", "sync", "time", "macros"] }
+tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
+color-eyre = "0.6.3"
+
+[target.'cfg(target_arch = "wasm32")'.dev-dependencies]
+wasm-bindgen-test = "0.3.43"
+web-sys = { version = "0.3.70", features = ["console"] }
+
+
+[[example]]
+name = "client"
+path = "examples/client.rs"

secret-grpc/examples/client.rs

@@ -0,0 +1,207 @@
+#![allow(unused)]
+
+use color_eyre::Result;
+use rsecret::{wallet::Wallet, CreateClientOptions, SecretNetworkClient, TxOptions};
+use secretrs::{
+    compute::ContractInfo,
+    proto::{
+        cosmos::{
+            base::{
+                query::v1beta1::PageRequest,
+                tendermint::v1beta1::{
+                    GetBlockByHeightResponse, GetLatestBlockRequest, GetLatestBlockResponse,
+                    GetLatestValidatorSetResponse, GetNodeInfoResponse, GetSyncingResponse,
+                    GetValidatorSetByHeightResponse,
+                },
+            },
+            staking::v1beta1::{BondStatus, QueryValidatorsRequest},
+            tx::v1beta1::OrderBy,
+        },
+        secret::compute::v1beta1::{
+            QueryByCodeIdRequest, QueryCodeResponse, QueryCodesResponse,
+            QueryContractHistoryResponse, QueryContractInfoResponse, QueryContractLabelResponse,
+            QuerySecretContractRequest,
+        },
+    },
+    tendermint::Block,
+    utils::EnigmaUtils,
+};
+use serde::{Deserialize, Serialize};
+use tracing::{debug, info, trace};
+use tracing_subscriber::{fmt::format::DefaultFields, EnvFilter};
+
+// const GRPC_URL: &str = "http://grpc.testnet.secretsaturn.net:9090";
+// const CHAIN_ID: &str = "pulsar-3";
+const GRPC_URL: &str = "https://secretnetwork-grpc.lavenderfive.com";
+// const GRPC_URL: &str = "http://grpc.mainnet.secretsaturn.net:9090";
+const CHAIN_ID: &str = "secret-4";
+
+#[tokio::main(flavor = "current_thread")]
+async fn main() -> Result<()> {
+    ::color_eyre::install()?;
+    ::tracing_subscriber::fmt()
+        .with_max_level(tracing::Level::INFO)
+        // .with_env_filter(EnvFilter::new("debug,h2=info"))
+        .with_line_number(false)
+        .with_file(false)
+        .without_time()
+        .pretty()
+        .init();
+
+    let options = CreateClientOptions::<EnigmaUtils, Wallet> {
+        url: GRPC_URL,
+        chain_id: CHAIN_ID,
+        ..Default::default()
+    };
+
+    let secretrs = SecretNetworkClient::connect(options).await?;
+    info!("SecretNetworkClient created");
+
+    let latest_block = secretrs.query.tendermint.get_latest_block().await?;
+    let latest_block_height = latest_block.header.height;
+    info!("{:?}", latest_block_height);
+
+    let validators = secretrs.all_validators().await?;
+    info!("Validators: {:?}", validators.len());
+
+    let validator_monikers: Vec<String> = validators
+        .into_iter()
+        .map(|v| v.description.unwrap_or_default().moniker)
+        .collect();
+    info!("{:?}", validator_monikers);
+
+    // let contract_address = "secret19gtpkk25r0c36gtlyrc6repd3q52ngmkpfszw3";
+    let contract_address = "secret1s09x2xvfd2lp2skgzm29w2xtena7s8fq98v852";
+    let code_hash = "9a00ca4ad505e9be7e6e6dddf8d939b7ec7e9ac8e109c8681f10db9cacb36d42";
+    let query = QueryMsg::TokenInfo {};
+
+    let secret_contract_response = secretrs
+        .query
+        .compute
+        .query_secret_contract(contract_address, code_hash, query)
+        .await?;
+    info!("{}", secret_contract_response);
+
+    // it works!
+    // let deserialized: QueryAnswer = serde_json::from_str(&secret_contract_response)?;
+    // println!(" {:?}", deserialized.magenta());
+
+    // it works!
+    // let QueryContractInfoResponse {
+    //     contract_address,
+    //     contract_info,
+    // } = secretrs
+    //     .query
+    //     .compute
+    //     .contract_info(contract_address)
+    //     .await?;
+    // let contract_info = ContractInfo::try_from(contract_info.unwrap())?;
+    // println!(" {:?}", contract_address.bright_white());
+    // println!(" {:?}", contract_info.bright_white());
+
+    // it works!
+    // let GetBlockByHeightResponse {
+    //     block_id,
+    //     block,
+    //     sdk_block,
+    // } = secretrs
+    //     .query
+    //     .tendermint
+    //     .get_block_by_height(4828567u32)
+    //     .await?;
+    // println!(" {:#?}", block_id.bright_green());
+    // println!(" {:#?}", block.green());
+    // println!(" {:#?}", sdk_block.bright_green());
+
+    // it works!
+    // let GetNodeInfoResponse {
+    //     default_node_info,
+    //     application_version,
+    // } = secretrs.query.tendermint.get_node_info().await?;
+    // println!(" {:#?}", default_node_info.bright_blue());
+    // println!(" {:#?}", application_version.blue());
+
+    // it works!
+    // let GetSyncingResponse { syncing } = secretrs.query.tendermint.get_syncing().await?;
+    // println!(" {:#?}", syncing.magenta());
+
+    // it works!
+    // let foo = secretrs
+    //     .get_tx(
+    //         // "95B29C83743756E7272C6F6117ADA63DE2E8B5C1434A6EEF994E167EE34EB050",
+    //         "CED96D9A9AF074619374E81FECDAFBA4E2F58FC1A680322F0E4C5A05F5D3E8C6",
+    //         None,
+    //     )
+    //     .await?;
+    // println!("{:#?}", foo.unwrap().green());
+
+    // it works!
+    // let bar = secretrs
+    //     .txs_query(
+    //         // "tx.hash='CED96D9A9AF074619374E81FECDAFBA4E2F58FC1A680322F0E4C5A05F5D3E8C6'",
+    //         "tx.height=4825000",
+    //         None,
+    //         None,
+    //         OrderBy::Asc,
+    //     )
+    //     .await?;
+    // println!("{:#?}", bar.unwrap().green());
+
+    // let foo = secretrs.query.auth.params().await?;
+    // println!("{:?}", foo);
+
+    // let msg = MsgSend {
+    //     from_address: "foo".parse()?,
+    //     to_address: "bar".parse()?,
+    //     amount: vec![],
+    // };
+    // let foo = secretrs.tx.bank.send(msg, TxOptions::default());
+
+    Ok(())
+}
+
+#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
+#[serde(rename_all = "snake_case")]
+pub enum QueryMsg {
+    TokenInfo {},
+    MemberCode { address: String, key: String },
+    ValidCodes { codes: Vec<String> },
+}
+
+#[derive(Serialize, Deserialize, Debug)]
+#[serde(rename_all = "snake_case")]
+pub enum QueryAnswer {
+    TokenInfo {
+        name: String,
+        symbol: String,
+        decimals: u8,
+        total_supply: String,
+    },
+    MemberCode {
+        code: String,
+    },
+    ValidCodes {
+        codes: Vec<String>,
+    },
+    ViewingKeyError {
+        msg: String,
+    },
+}
+
+/* gRPC-web experiment
+use http::Uri;
+use hyper::Client;
+use tonic_web::GrpcWebClientLayer;
+use secretrs::grpc_clients::TendermintServiceClient;
+
+let hyper_client = Client::builder().build_http();
+let svc = tower::ServiceBuilder::new()
+    .layer(GrpcWebClientLayer::new())
+    .service(hyper_client);
+
+let endpoint = "http://localhost:9091".parse::<Uri>()?;
+let mut client = TendermintServiceClient::with_origin(svc, endpoint);
+
+let res = client.get_latest_block(GetLatestBlockRequest {}).await?;
+debug!("{:#?}", res);
+*/

secret-grpc/examples/create_client.rs

@@ -0,0 +1,35 @@
+use color_eyre::Result;
+use tracing::info;
+
+use rsecret::{wallet::Wallet, CreateClientOptions, SecretNetworkClient};
+use secretrs::utils::EnigmaUtils;
+
+const GRPC_URL: &str = "https://secretnetwork-grpc.lavenderfive.com";
+const CHAIN_ID: &str = "secret-4";
+
+#[tokio::main(flavor = "current_thread")]
+async fn main() -> Result<()> {
+    ::color_eyre::install()?;
+    ::tracing_subscriber::fmt()
+        .with_max_level(tracing::Level::INFO)
+        .with_line_number(false)
+        .with_file(false)
+        .without_time()
+        .pretty()
+        .init();
+
+    let options = CreateClientOptions::<EnigmaUtils, Wallet> {
+        url: GRPC_URL,
+        chain_id: CHAIN_ID,
+        ..Default::default()
+    };
+
+    let secretrs = SecretNetworkClient::connect(options).await?;
+    info!("SecretNetworkClient created");
+
+    let latest_block = secretrs.query.tendermint.get_latest_block().await?;
+    let latest_block_height = latest_block.header.height;
+    info!("{:#?}", latest_block_height);
+
+    Ok(())
+}

secret-grpc/notes.md

@@ -0,0 +1,4 @@
+# Misc
+
+- break up the secret_client module
+- make a trait for 'TxProcessor', that can have default implementation for anything with an inner TxServiceClient to be able to prepare and sign and broadcast transactions. The ComputeServiceClient could overload the tx decoding methods to include decryption.