tornadocontrib/web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updated error_response

Browse Source
This commit is contained in:
yenicelik 2023-05-21 20:27:46 -04:00
parent 46afe8b1e4
commit 29678b025e
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
web3_proxy/src/stats/influxdb_queries.rs
View File

@ -75,6 +75,7 @@ pub async fn query_user_stats<'a>(
"_measurement".to_string(), "_measurement".to_string(),
"archive_needed".to_string(), "archive_needed".to_string(),
"chain_id".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 // Include a hashmap to go from rpc_secret_key_id to the rpc_secret_key
@ -190,14 +191,14 @@ pub async fn query_user_stats<'a>(
|> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value") |> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value")
|> drop(columns: ["balance"]) |> drop(columns: ["balance"])
|> map(fn: (r) => ({{ r with "error_response": if r.error_response == "true" then r.frontend_requests else 0}})) |> map(fn: (r) => ({{ r with "error_response": if r.error_response == "true" then r.frontend_requests else 0}}))
|> group(columns: ["_time", "_measurement", "archive_needed", "chain_id", "method", "rpc_secret_key_id"]) |> group(columns: ["_time", "_measurement", "archive_needed", "chain_id", "error_response", "method", "rpc_secret_key_id"])
|> sort(columns: ["frontend_requests"]) |> sort(columns: ["frontend_requests"])
|> map(fn:(r) => ({{ r with "sum_credits_used": float(v: r["sum_credits_used"]) }})) |> map(fn:(r) => ({{ r with "sum_credits_used": float(v: r["sum_credits_used"]) }}))
|> cumulativeSum(columns: ["error_response", "backend_requests", "cache_hits", "cache_misses", "frontend_requests", "sum_credits_used", "sum_request_bytes", "sum_response_bytes", "sum_response_millis"]) |> cumulativeSum(columns: ["backend_requests", "cache_hits", "cache_misses", "frontend_requests", "sum_credits_used", "sum_request_bytes", "sum_response_bytes", "sum_response_millis"])
|> sort(columns: ["frontend_requests"], desc: true) |> sort(columns: ["frontend_requests"], desc: true)
|> limit(n: 1) |> limit(n: 1)
|> group() |> group()
|> sort(columns: ["_time", "_measurement", "archive_needed", "chain_id", "method", "rpc_secret_key_id"], desc: true) |> sort(columns: ["_time", "_measurement", "archive_needed", "chain_id", "error_response", "method", "rpc_secret_key_id"], desc: true)
"#); "#);
info!("Raw query to db is: {:?}", query); info!("Raw query to db is: {:?}", query);
@ -441,10 +442,16 @@ pub async fn query_user_stats<'a>(
} }
} else if key == "error_response" { } else if key == "error_response" {
match value { match value {
influxdb2_structmap::value::Value::Long(inner) => { influxdb2_structmap::value::Value::String(inner) => {
out.insert( out.insert(
"error_response".to_owned(), "error_response".to_owned(),
serde_json::Value::Number(inner.into()), if inner == "true" {
serde_json::Value::Bool(true)
} else if inner == "false" {
serde_json::Value::Bool(false)
} else {
serde_json::Value::String("error".to_owned())
},
); );
} }
_ => { _ => {