修复告警
This commit is contained in:
@@ -5,7 +5,6 @@ use std::path::PathBuf;
|
||||
use uuid::Uuid;
|
||||
|
||||
// 导入公共模块
|
||||
use crate::http_client;
|
||||
use crate::types::node_test::NodeTestResult;
|
||||
use crate::utils::node_tester;
|
||||
|
||||
|
||||
@@ -3,7 +3,7 @@ use serde::{Deserialize, Serialize};
|
||||
use tauri::command;
|
||||
|
||||
// 导入公共模块
|
||||
use crate::types::node_test::{NodeTestResult, TestStatus};
|
||||
use crate::types::node_test::NodeTestResult;
|
||||
use crate::utils::node_tester;
|
||||
|
||||
/// PackyCode 节点类型
|
||||
@@ -115,6 +115,7 @@ pub fn get_all_nodes() -> Vec<PackycodeNode> {
|
||||
}
|
||||
|
||||
/// 测试单个节点速度(仅测试网络延时,不需要认证)
|
||||
#[allow(dead_code)]
|
||||
async fn test_node_speed(node: &PackycodeNode) -> NodeTestResult {
|
||||
let url = format!("{}/", node.url.trim_end_matches('/'));
|
||||
let mut result = node_tester::test_node_connectivity(&url, 3000).await;
|
||||
|
||||
@@ -123,6 +123,7 @@ pub fn default_client() -> Result<Client> {
|
||||
///
|
||||
/// let client = fast_client()?;
|
||||
/// ```
|
||||
#[allow(dead_code)]
|
||||
pub fn fast_client() -> Result<Client> {
|
||||
create_client(
|
||||
ClientConfig::default()
|
||||
@@ -161,6 +162,7 @@ pub fn secure_client() -> Result<Client> {
|
||||
/// - 接受无效证书: 否
|
||||
/// - 使用代理: 是
|
||||
/// - User-Agent: "Claudia/1.0"
|
||||
#[allow(dead_code)]
|
||||
pub fn long_timeout_client() -> Result<Client> {
|
||||
create_client(ClientConfig::default().timeout(60))
|
||||
}
|
||||
|
||||
@@ -24,11 +24,13 @@ impl TestStatus {
|
||||
}
|
||||
|
||||
/// 判断测试是否失败
|
||||
#[allow(dead_code)]
|
||||
pub fn is_failure(&self) -> bool {
|
||||
!self.is_success()
|
||||
}
|
||||
|
||||
/// 转换为字符串
|
||||
#[allow(dead_code)]
|
||||
pub fn as_str(&self) -> &'static str {
|
||||
match self {
|
||||
TestStatus::Success => "success",
|
||||
@@ -88,6 +90,7 @@ impl NodeTestResult {
|
||||
/// assert!(result.status.is_success());
|
||||
/// assert_eq!(result.response_time_ms, Some(150));
|
||||
/// ```
|
||||
#[allow(dead_code)]
|
||||
pub fn success(url: String, response_time: u64) -> Self {
|
||||
Self {
|
||||
node_id: None,
|
||||
@@ -180,24 +183,28 @@ impl NodeTestResult {
|
||||
}
|
||||
|
||||
/// 设置节点 ID
|
||||
#[allow(dead_code)]
|
||||
pub fn with_node_id(mut self, node_id: String) -> Self {
|
||||
self.node_id = Some(node_id);
|
||||
self
|
||||
}
|
||||
|
||||
/// 设置节点名称
|
||||
#[allow(dead_code)]
|
||||
pub fn with_node_name(mut self, node_name: String) -> Self {
|
||||
self.node_name = Some(node_name);
|
||||
self
|
||||
}
|
||||
|
||||
/// 设置元数据
|
||||
#[allow(dead_code)]
|
||||
pub fn with_metadata(mut self, metadata: HashMap<String, serde_json::Value>) -> Self {
|
||||
self.metadata = Some(metadata);
|
||||
self
|
||||
}
|
||||
|
||||
/// 添加单个元数据项
|
||||
#[allow(dead_code)]
|
||||
pub fn add_metadata(mut self, key: String, value: serde_json::Value) -> Self {
|
||||
if self.metadata.is_none() {
|
||||
self.metadata = Some(HashMap::new());
|
||||
@@ -214,16 +221,19 @@ impl NodeTestResult {
|
||||
}
|
||||
|
||||
/// 判断测试是否失败
|
||||
#[allow(dead_code)]
|
||||
pub fn is_failure(&self) -> bool {
|
||||
self.status.is_failure()
|
||||
}
|
||||
|
||||
/// 获取响应时间(如果有)
|
||||
#[allow(dead_code)]
|
||||
pub fn response_time(&self) -> Option<u64> {
|
||||
self.response_time_ms
|
||||
}
|
||||
|
||||
/// 获取错误信息(如果有)
|
||||
#[allow(dead_code)]
|
||||
pub fn error(&self) -> Option<&str> {
|
||||
self.error_details.as_deref()
|
||||
}
|
||||
@@ -250,6 +260,7 @@ pub struct BatchTestSummary {
|
||||
|
||||
impl BatchTestSummary {
|
||||
/// 从测试结果列表生成统计摘要
|
||||
#[allow(dead_code)]
|
||||
pub fn from_results(results: &[NodeTestResult]) -> Self {
|
||||
let total = results.len();
|
||||
let success = results.iter().filter(|r| r.is_success()).count();
|
||||
@@ -286,6 +297,7 @@ impl BatchTestSummary {
|
||||
}
|
||||
|
||||
/// 获取成功率(百分比)
|
||||
#[allow(dead_code)]
|
||||
pub fn success_rate(&self) -> f64 {
|
||||
if self.total == 0 {
|
||||
0.0
|
||||
|
||||
@@ -22,6 +22,7 @@ use anyhow::Result;
|
||||
/// to_string_error(some_operation())
|
||||
/// }
|
||||
/// ```
|
||||
#[allow(dead_code)]
|
||||
pub fn to_string_error<T>(result: Result<T>) -> Result<T, String> {
|
||||
result.map_err(|e| e.to_string())
|
||||
}
|
||||
@@ -45,6 +46,7 @@ pub fn to_string_error<T>(result: Result<T>) -> Result<T, String> {
|
||||
/// )
|
||||
/// }
|
||||
/// ```
|
||||
#[allow(dead_code)]
|
||||
pub fn to_string_error_ctx<T>(result: Result<T>, context: &str) -> Result<T, String> {
|
||||
result.map_err(|e| format!("{}: {}", context, e))
|
||||
}
|
||||
@@ -63,6 +65,7 @@ pub fn to_string_error_ctx<T>(result: Result<T>, context: &str) -> Result<T, Str
|
||||
/// Ok("result".to_string())
|
||||
/// }
|
||||
/// ```
|
||||
#[allow(dead_code)]
|
||||
pub fn db_error_to_string(e: rusqlite::Error) -> String {
|
||||
match e {
|
||||
rusqlite::Error::QueryReturnedNoRows => "查询未返回任何行".to_string(),
|
||||
@@ -100,6 +103,7 @@ pub fn db_error_to_string(e: rusqlite::Error) -> String {
|
||||
/// response.text().await.map_err(http_error_to_string)
|
||||
/// }
|
||||
/// ```
|
||||
#[allow(dead_code)]
|
||||
pub fn http_error_to_string(e: reqwest::Error) -> String {
|
||||
if e.is_timeout() {
|
||||
format!("请求超时: {}", e)
|
||||
@@ -122,11 +126,13 @@ pub fn http_error_to_string(e: reqwest::Error) -> String {
|
||||
}
|
||||
|
||||
/// 将 serde_json::Error 转换为用户友好的错误消息
|
||||
#[allow(dead_code)]
|
||||
pub fn json_error_to_string(e: serde_json::Error) -> String {
|
||||
format!("JSON 解析错误: {}", e)
|
||||
}
|
||||
|
||||
/// 将 std::io::Error 转换为用户友好的错误消息
|
||||
#[allow(dead_code)]
|
||||
pub fn io_error_to_string(e: std::io::Error) -> String {
|
||||
use std::io::ErrorKind;
|
||||
|
||||
@@ -158,6 +164,7 @@ pub fn io_error_to_string(e: std::io::Error) -> String {
|
||||
/// let combined = combine_errors(&errors);
|
||||
/// // 输出: "发生 2 个错误: 错误 1: 连接失败; 错误 2: 超时"
|
||||
/// ```
|
||||
#[allow(dead_code)]
|
||||
pub fn combine_errors(errors: &[String]) -> String {
|
||||
if errors.is_empty() {
|
||||
"无错误".to_string()
|
||||
@@ -169,11 +176,13 @@ pub fn combine_errors(errors: &[String]) -> String {
|
||||
}
|
||||
|
||||
/// 创建带前缀的错误消息
|
||||
#[allow(dead_code)]
|
||||
pub fn prefixed_error(prefix: &str, error: &str) -> String {
|
||||
format!("{}: {}", prefix, error)
|
||||
}
|
||||
|
||||
/// 为错误添加建议
|
||||
#[allow(dead_code)]
|
||||
pub fn error_with_suggestion(error: &str, suggestion: &str) -> String {
|
||||
format!("{}。建议: {}", error, suggestion)
|
||||
}
|
||||
|
||||
@@ -132,6 +132,7 @@ pub async fn test_nodes_batch(urls: Vec<String>, timeout_ms: u64) -> Vec<NodeTes
|
||||
/// # Arguments
|
||||
/// * `urls` - 节点 URL 列表
|
||||
/// * `timeout_ms` - 每个节点的超时时间(毫秒)
|
||||
#[allow(dead_code)]
|
||||
pub async fn test_nodes_sequential(urls: Vec<String>, timeout_ms: u64) -> Vec<NodeTestResult> {
|
||||
let mut results = Vec::new();
|
||||
|
||||
@@ -168,11 +169,13 @@ pub fn find_fastest_node(results: &[NodeTestResult]) -> Option<&NodeTestResult>
|
||||
}
|
||||
|
||||
/// 过滤成功的节点
|
||||
#[allow(dead_code)]
|
||||
pub fn filter_successful_nodes(results: &[NodeTestResult]) -> Vec<&NodeTestResult> {
|
||||
results.iter().filter(|r| r.is_success()).collect()
|
||||
}
|
||||
|
||||
/// 过滤失败的节点
|
||||
#[allow(dead_code)]
|
||||
pub fn filter_failed_nodes(results: &[NodeTestResult]) -> Vec<&NodeTestResult> {
|
||||
results.iter().filter(|r| r.is_failure()).collect()
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user