| |
| |
|
|
| use regex::Regex; |
| use once_cell::sync::Lazy; |
|
|
| static DURATION_RE: Lazy<Regex> = Lazy::new(|| { |
| Regex::new(r"([\d.]+)\s*(ms|s|m|h)").unwrap() |
| }); |
|
|
| |
| pub fn parse_duration_ms(duration_str: &str) -> Option<u64> { |
| let mut total_ms: f64 = 0.0; |
| let mut matched = false; |
|
|
| for cap in DURATION_RE.captures_iter(duration_str) { |
| matched = true; |
| let value: f64 = cap[1].parse().ok()?; |
| let unit = &cap[2]; |
|
|
| match unit { |
| "ms" => total_ms += value, |
| "s" => total_ms += value * 1000.0, |
| "m" => total_ms += value * 60.0 * 1000.0, |
| "h" => total_ms += value * 60.0 * 60.0 * 1000.0, |
| _ => {} |
| } |
| } |
|
|
| if !matched { |
| return None; |
| } |
|
|
| Some(total_ms.round() as u64) |
| } |
|
|
| |
| pub fn parse_retry_delay(error_text: &str) -> Option<u64> { |
| use serde_json::Value; |
|
|
| let json: Value = serde_json::from_str(error_text).ok()?; |
| let details = json.get("error")?.get("details")?.as_array()?; |
|
|
| |
| for detail in details { |
| if let Some(type_str) = detail.get("@type").and_then(|v| v.as_str()) { |
| if type_str.contains("RetryInfo") { |
| if let Some(retry_delay) = detail.get("retryDelay").and_then(|v| v.as_str()) { |
| return parse_duration_ms(retry_delay); |
| } |
| } |
| } |
| } |
|
|
| |
| for detail in details { |
| if let Some(quota_delay) = detail |
| .get("metadata") |
| .and_then(|m| m.get("quotaResetDelay")) |
| .and_then(|v| v.as_str()) |
| { |
| return parse_duration_ms(quota_delay); |
| } |
| } |
|
|
| None |
| } |
|
|
| #[cfg(test)] |
| mod tests { |
| use super::*; |
|
|
| #[test] |
| fn test_parse_duration_ms() { |
| assert_eq!(parse_duration_ms("1.5s"), Some(1500)); |
| assert_eq!(parse_duration_ms("200ms"), Some(200)); |
| assert_eq!(parse_duration_ms("1h16m0.667s"), Some(4560667)); |
| assert_eq!(parse_duration_ms("invalid"), None); |
| } |
|
|
| #[test] |
| fn test_parse_retry_delay() { |
| let error_json = r#"{ |
| "error": { |
| "details": [{ |
| "@type": "type.googleapis.com/google.rpc.RetryInfo", |
| "retryDelay": "1.203608125s" |
| }] |
| } |
| }"#; |
|
|
| assert_eq!(parse_retry_delay(error_json), Some(1204)); |
| } |
| } |
|
|
