From b6cab88c4eb5678f08af3422085273e769e93b3f Mon Sep 17 00:00:00 2001 From: yenicelik Date: Wed, 24 May 2023 13:35:10 +0200 Subject: [PATCH] removed joined_on variable that was not used --- web3_proxy/src/stats/influxdb_queries.rs | 18 +----------------- 1 file changed, 1 insertion(+), 17 deletions(-) diff --git a/web3_proxy/src/stats/influxdb_queries.rs b/web3_proxy/src/stats/influxdb_queries.rs index 6246ac54..4b597118 100644 --- a/web3_proxy/src/stats/influxdb_queries.rs +++ b/web3_proxy/src/stats/influxdb_queries.rs @@ -77,14 +77,6 @@ pub async fn query_user_stats<'a>( "opt_in_proxy" }; - let mut join_candidates: Vec = vec![ - "_time".to_string(), - "_measurement".to_string(), - "archive_needed".to_string(), - "chain_id".to_string(), - "error_response".to_string(), - ]; - // Include a hashmap to go from rpc_secret_key_id to the rpc_secret_key let mut rpc_key_id_to_key = HashMap::new(); @@ -140,9 +132,6 @@ pub async fn query_user_stats<'a>( )); } - // Make the tables join on the rpc_key_id as well: - join_candidates.push("rpc_secret_key_id".to_string()); - // Iterate, pop and add to string f!( r#"|> filter(fn: (r) => contains(value: r["rpc_secret_key_id"], set: {:?}))"#, @@ -177,13 +166,8 @@ pub async fn query_user_stats<'a>( let drop_method = match stat_response_type { StatType::Aggregated => f!(r#"|> drop(columns: ["method"])"#), - StatType::Detailed => { - // Make the tables join on the method column as well - join_candidates.push("method".to_string()); - "".to_string() - } + StatType::Detailed => "".to_string(), }; - let join_candidates = f!(r#"{:?}"#, join_candidates); let query = f!(r#" base = from(bucket: "{bucket}")