fix: debug wallet service with new logs

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" }
+yttrium = { git = "https://github.com/reown-com/yttrium.git", branch = "fix/logging" }
 
 # Async
 async-trait = "0.1.82"
@@ -66,7 +66,7 @@ ipnet = "2.5"
 pnet_datalink = "0.31"
 
 tracing = "0.1"
-tracing-subscriber = { version = "0.3", features = ["json", "ansi"] }
+tracing-subscriber = { version = "0.3", features = ["json", "ansi", "env-filter"] }
 
 cerberus = { git = "https://github.com/WalletConnect/cerberus.git", tag = "v0.13.1" }
 parquet = { git = "https://github.com/WalletConnect/arrow-rs.git", rev = "99a1cc3", default-features = false, features = ["flate2"] }

src/handlers/wallet/prepare_calls.rs

@@ -12,12 +12,7 @@ use alloy::providers::{Provider, ReqwestProvider};
 use alloy::sol_types::SolCall;
 use alloy::sol_types::SolValue;
 use alloy::transports::Transport;
-use axum::{
-    extract::State,
-    response::{IntoResponse, Response},
-    Json,
-};
-use hyper::StatusCode;
+use axum::extract::State;
 use serde::{Deserialize, Serialize};
 use std::sync::Arc;
 use thiserror::Error;
@@ -150,24 +145,6 @@ pub enum PrepareCallsInternalError {
     GetSessionContextError(InternalGetSessionContextError),
 }
 
-impl IntoResponse for PrepareCallsError {
-    fn into_response(self) -> Response {
-        match self {
-            Self::InternalError(e) => {
-                error!("HTTP server error: (prepare_calls) {e:?}");
-                StatusCode::INTERNAL_SERVER_ERROR.into_response()
-            }
-            e => (
-                StatusCode::BAD_REQUEST,
-                Json(serde_json::json!({
-                    "error": e.to_string(),
-                })),
-            )
-                .into_response(),
-        }
-    }
-}
-
 pub async fn handler(
     state: State<Arc<AppState>>,
     project_id: String,

src/handlers/wallet/send_prepared_calls.rs

@@ -17,13 +17,8 @@ use alloy::network::Ethereum;
 use alloy::primitives::{Bytes, U64};
 use alloy::providers::ReqwestProvider;
 use axum::extract::{Path, Query};
-use axum::{
-    extract::State,
-    response::{IntoResponse, Response},
-    Json,
-};
+use axum::{extract::State, response::IntoResponse, Json};
 use hyper::body::to_bytes;
-use hyper::StatusCode;
 use parquet::data_type::AsBytes;
 use serde::{Deserialize, Serialize};
 use std::sync::Arc;
@@ -142,24 +137,6 @@ pub enum SendPreparedCallsInternalError {
     SendUserOperation(eyre::Error),
 }
 
-impl IntoResponse for SendPreparedCallsError {
-    fn into_response(self) -> Response {
-        match self {
-            Self::InternalError(e) => {
-                error!("HTTP server error: (prepare_calls) {e:?}");
-                StatusCode::INTERNAL_SERVER_ERROR.into_response()
-            }
-            e => (
-                StatusCode::BAD_REQUEST,
-                Json(serde_json::json!({
-                    "error": e.to_string(),
-                })),
-            )
-                .into_response(),
-        }
-    }
-}
-
 pub async fn handler(
     state: State<Arc<AppState>>,
     project_id: String,

src/main.rs

@@ -1,8 +1,8 @@
 use {
     dotenv::dotenv,
     rpc_proxy::{env::Config, error},
-    std::str::FromStr,
-    tracing_subscriber::fmt::format::FmtSpan,
+    tracing::level_filters::LevelFilter,
+    tracing_subscriber::{fmt::format::FmtSpan, EnvFilter},
 };
 
 #[global_allocator]
@@ -17,8 +17,11 @@ async fn main() -> error::RpcResult<()> {
         .expect("Failed to load config, please ensure all env variables are defined.");
 
     tracing_subscriber::fmt()
-        .with_max_level(
-            tracing::Level::from_str(config.server.log_level.as_str()).expect("Invalid log level"),
+        .with_env_filter(
+            EnvFilter::builder()
+                .with_default_directive(LevelFilter::ERROR.into())
+                .parse(&config.server.log_level)
+                .expect("Invalid log level"),
         )
         .with_span_events(FmtSpan::CLOSE)
         .with_ansi(false)

terraform/ecs/cluster.tf

@@ -76,6 +76,7 @@ resource "aws_ecs_task_definition" "app_task" {
       essential = true,
 
       environment = [
+        { name = "RPC_PROXY_LOG_LEVEL", value = var.log_level },
         { name = "RPC_PROXY_PORT", value = tostring(var.port) },
         { name = "RPC_PROXY_PROMETHEUS_PORT", value = tostring(local.otel_port) },