feat: wallet get calls status

Cargo.toml

@@ -13,7 +13,7 @@ build = "build.rs"
 [dependencies]
 wc = { git = "https://github.com/WalletConnect/utils-rs.git", tag = "v0.9.0", features = ["alloc", "analytics", "future", "http", "metrics", "geoip", "geoblock", "rate_limit"] }
 relay_rpc = { git = "https://github.com/WalletConnect/WalletConnectRust.git", tag = "v0.32.0", features = ["cacao"] }
-yttrium = { git = "https://github.com/reown-com/yttrium.git", rev = "5b0c319" }
+yttrium = { git = "https://github.com/reown-com/yttrium.git", branch = "fix/support-get-calls-status" }
 
 # Async
 async-trait = "0.1.82"

src/analytics/message_info.rs

@@ -69,6 +69,7 @@ pub enum MessageSource {
     SessionCoSignSigValidate,
     WalletPrepareCalls,
     WalletSendPreparedCalls,
+    WalletGetCallsStatus,
 }
 
 #[cfg(test)]

src/env/mod.rs

@@ -273,6 +273,7 @@ mod test {
                     pimlico_api_key: "PIMLICO_API_KEY".to_string(),
                     solscan_api_v1_token: "SOLSCAN_API_V1_TOKEN".to_string(),
                     solscan_api_v2_token: "SOLSCAN_API_V2_TOKEN".to_string(),
+                    override_bundler_urls: None,
                 },
                 rate_limiting: RateLimitingConfig {
                     max_tokens: Some(100),

src/env/server.rs

@@ -1,5 +1,5 @@
 use {
-    crate::{utils, utils::network::NetworkInterfaceError},
+    crate::utils::{self, network::NetworkInterfaceError},
     serde::Deserialize,
     serde_piecewise_default::DeserializePiecewiseDefault,
     std::net::IpAddr,

src/handlers/bundler.rs

@@ -4,6 +4,7 @@ use {
         error::RpcError, providers::SupportedBundlerOps, state::AppState,
         utils::crypto::disassemble_caip2,
     },
+    alloy::rpc::json_rpc::Id,
     axum::{
         extract::{Query, State},
         response::{IntoResponse, Response},
@@ -30,8 +31,8 @@ pub struct BundlerQueryParams {
 
 #[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize, Deserialize)]
 pub struct BundlerJsonRpcRequest {
-    pub id: u64,
-    pub jsonrpc: String,
+    pub id: Id,
+    pub jsonrpc: Arc<str>,
     pub method: SupportedBundlerOps,
     pub params: serde_json::Value,
 }
@@ -62,7 +63,7 @@ async fn handler_internal(
         .bundler_rpc_call(
             &evm_chain_id,
             request_payload.id,
-            &request_payload.jsonrpc,
+            request_payload.jsonrpc,
             &request_payload.method,
             request_payload.params,
         )

src/handlers/identity.rs

@@ -517,7 +517,7 @@ impl JsonRpcClient for SelfProvider {
             self.query.clone(),
             self.headers.clone(),
             serde_json::to_vec(&crypto::JsonRpcRequest {
-                id,
+                id: id.into(),
                 jsonrpc: crypto::JSON_RPC_VERSION.clone(),
                 method: method.to_owned().into(),
                 params,

src/handlers/wallet/call_id.rs

@@ -0,0 +1,26 @@
+use alloy::primitives::{Bytes, B256, U64};
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Clone, PartialEq, Eq)]
+pub struct CallId(pub CallIdInner);
+
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+pub struct CallIdInner {
+    pub chain_id: U64,
+    pub user_op_hash: B256,
+}
+
+impl Serialize for CallId {
+    fn serialize<S: serde::Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
+        Bytes::from(serde_json::to_vec(&self.0).map_err(serde::ser::Error::custom)?)
+            .serialize(serializer)
+    }
+}
+
+impl<'de> Deserialize<'de> for CallId {
+    fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
+        let bytes = Bytes::deserialize(deserializer)?;
+        let inner = serde_json::from_slice(&bytes).map_err(serde::de::Error::custom)?;
+        Ok(Self(inner))
+    }
+}