Merge pull request #22 from zss823158062/main

feat: 实现自动下载更新功能

Author: wutongci

src-tauri/src/commands/config_cmd.rs

@@ -22,9 +22,9 @@ pub struct CredentialSyncServiceState(pub Option<Arc<CredentialSyncService>>);
 
 /// 展开路径中的 ~ 为用户主目录
 fn expand_tilde(path: &str) -> String {
-    if path.starts_with("~/") {
+    if let Some(stripped) = path.strip_prefix("~/") {
         if let Some(home) = dirs::home_dir() {
-            return home.join(&path[2..]).to_string_lossy().to_string();
+            return home.join(stripped).to_string_lossy().to_string();
         }
     }
     path.to_string()
@@ -82,8 +82,7 @@ fn copy_and_rename_credential_file(
 
     // 对于 Kiro 凭证，需要合并 clientIdHash 文件中的 client_id/client_secret
     if provider_type == "kiro" {
-        let content =
-            fs::read_to_string(&source).map_err(|e| format!("读取凭证文件失败: {}", e))?;
+        let content = fs::read_to_string(source).map_err(|e| format!("读取凭证文件失败: {}", e))?;
         let mut creds: serde_json::Value =
             serde_json::from_str(&content).map_err(|e| format!("解析凭证文件失败: {}", e))?;
 
@@ -200,9 +199,9 @@ fn copy_and_rename_credential_file(
                 tracing::error!(
                     "[KIRO] IdC 认证方式缺少 clientId/clientSecret，无法创建有效的凭证副本"
                 );
-                return Err(format!(
-                    "IdC 认证凭证不完整：缺少 clientId/clientSecret。\n\n💡 解决方案：\n1. 确保 ~/.aws/sso/cache/ 目录下有对应的 clientIdHash 文件\n2. 如果使用 AWS IAM Identity Center，请确保已完成完整的 SSO 登录流程\n3. 或者尝试使用 Social 认证方式的凭证"
-                ));
+                return Err(
+                    "IdC 认证凭证不完整：缺少 clientId/clientSecret。\n\n💡 解决方案：\n1. 确保 ~/.aws/sso/cache/ 目录下有对应的 clientIdHash 文件\n2. 如果使用 AWS IAM Identity Center，请确保已完成完整的 SSO 登录流程\n3. 或者尝试使用 Social 认证方式的凭证".to_string()
+                );
             } else {
                 tracing::warn!("[KIRO] 未找到 client_id/client_secret，将使用 social 认证方式");
             }
@@ -214,7 +213,7 @@ fn copy_and_rename_credential_file(
         fs::write(&target_path, merged_content).map_err(|e| format!("写入凭证文件失败: {}", e))?;
     } else {
         // 其他类型直接复制
-        fs::copy(&source, &target_path).map_err(|e| format!("复制凭证文件失败: {}", e))?;
+        fs::copy(source, &target_path).map_err(|e| format!("复制凭证文件失败: {}", e))?;
     }
 
     // 返回新的文件路径
@@ -1117,7 +1116,7 @@ pub async fn get_antigravity_auth_url_and_wait(
     );
 
     // 从凭证中获取 project_id
-    let project_id = result.credentials.projectId.clone();
+    let project_id = result.credentials.project_id.clone();
 
     // 添加到凭证池
     let credential = pool_service.0.add_credential(
@@ -1165,7 +1164,7 @@ pub async fn start_antigravity_oauth_login(
     );
 
     // 从凭证中获取 project_id
-    let project_id = result.credentials.projectId.clone();
+    let project_id = result.credentials.project_id.clone();
 
     // 添加到凭证池
     let credential = pool_service.0.add_credential(

src-tauri/src/commands/provider_pool_cmd.rs

@@ -65,14 +65,7 @@ pub async fn get_route_curl_examples(
         .map_err(|e| e.to_string())?;
 
     // 查找匹配的路由
-    let route = routes.iter().find(|r| r.selector == selector).or_else(|| {
-        // 如果是默认路由
-        if selector == "default" {
-            None // 返回 None 让下面的代码生成默认示例
-        } else {
-            None
-        }
-    });
+    let route = routes.iter().find(|r| r.selector == selector);
 
     // P0 安全修复：curl 示例使用占位符，不暴露真实 API Key
     let api_key = "${PROXYCAST_API_KEY}";

src-tauri/src/commands/route_cmd.rs

@@ -116,9 +116,9 @@ fn read_kiro_credential_info(creds_file_path: &str) -> Result<(String, Option<St
 
 /// 展开路径中的 ~ 为用户主目录
 fn expand_tilde(path: &str) -> String {
-    if path.starts_with("~/") {
+    if let Some(stripped) = path.strip_prefix("~/") {
         if let Some(home) = dirs::home_dir() {
-            return home.join(&path[2..]).to_string_lossy().to_string();
+            return home.join(stripped).to_string_lossy().to_string();
         }
     }
     path.to_string()

src-tauri/src/commands/usage_cmd.rs

@@ -500,7 +500,8 @@ mod base64 {
     }
 }
 
-pub use self::base64::{decode as base64_decode, encode as base64_encode};
+pub use self::base64::decode as base64_decode;
+pub use self::base64::encode as base64_encode;
 
 #[cfg(test)]
 mod unit_tests {

src-tauri/src/config/export.rs

@@ -17,12 +17,11 @@ pub use hot_reload::{
 pub use import::{ImportOptions, ImportService, ValidationResult};
 pub use path_utils::{collapse_tilde, contains_tilde, expand_tilde};
 pub use types::{
-    generate_secure_api_key, is_default_api_key, AmpConfig, AmpModelMapping, ApiKeyEntry, Config,
-    CredentialEntry, CredentialPoolConfig, CustomProviderConfig, GeminiApiKeyEntry,
-    IFlowCredentialEntry, InjectionRuleConfig, InjectionSettings, LoggingConfig, ProviderConfig,
-    ProvidersConfig, QuotaExceededConfig, RemoteManagementConfig, RetrySettings, RoutingConfig,
-    RoutingRuleConfig, ServerConfig, TlsConfig, VertexApiKeyEntry, VertexModelAlias,
-    DEFAULT_API_KEY,
+    AmpConfig, AmpModelMapping, ApiKeyEntry, Config, CredentialEntry, CredentialPoolConfig,
+    CustomProviderConfig, GeminiApiKeyEntry, IFlowCredentialEntry, InjectionRuleConfig,
+    InjectionSettings, LoggingConfig, ProviderConfig, ProvidersConfig, QuotaExceededConfig,
+    RemoteManagementConfig, RetrySettings, RoutingConfig, ServerConfig, TlsConfig,
+    VertexApiKeyEntry, VertexModelAlias,
 };
 pub use yaml::{load_config, save_config, ConfigError, ConfigManager, YamlService};
 

src-tauri/src/config/mod.rs

@@ -44,9 +44,9 @@ pub fn expand_tilde<P: AsRef<Path>>(path: P) -> PathBuf {
     if path_str == "~" {
         // 仅 ~
         home_dir
-    } else if path_str.starts_with("~/") {
+    } else if let Some(rest) = path_str.strip_prefix("~/") {
         // ~/path 格式
-        let rest = &path_str[2..]; // 跳过 "~/"
+        // 跳过 "~/"
         home_dir.join(rest)
     } else {
         // ~user/path 格式，不支持，返回原路径

src-tauri/src/config/path_utils.rs

@@ -331,7 +331,7 @@ fn find_function_name(contents: &[GeminiContent], tool_id: &str) -> String {
 
 /// 清理参数中不需要的字段
 fn clean_parameters(params: Option<serde_json::Value>) -> Option<serde_json::Value> {
-    params.map(|v| clean_value(v))
+    params.map(clean_value)
 }
 
 fn clean_value(value: serde_json::Value) -> serde_json::Value {
@@ -489,8 +489,7 @@ pub fn convert_antigravity_to_openai_response(
                         content.push_str(text);
                     }
                     if let Some(fc) = part.get("functionCall") {
-                        let call_id =
-                            format!("call_{}", uuid::Uuid::new_v4().to_string()[..8].to_string());
+                        let call_id = format!("call_{}", &uuid::Uuid::new_v4().to_string()[..8]);
                         tool_calls.push(serde_json::json!({
                             "id": call_id,
                             "type": "function",

src-tauri/src/converter/openai_to_antigravity.rs

@@ -149,10 +149,11 @@ impl ProtocolSelector {
     /// 获取推荐的中间协议（用于不支持直接转换的情况）
     pub fn intermediate_protocol(source: Protocol, target: Protocol) -> Option<Protocol> {
         // 大多数情况下，OpenAI 是最好的中间协议
-        if !Self::supports_direct_conversion(source, target) {
-            if source != Protocol::OpenAI && target != Protocol::OpenAI {
-                return Some(Protocol::OpenAI);
-            }
+        if !Self::supports_direct_conversion(source, target)
+            && source != Protocol::OpenAI
+            && target != Protocol::OpenAI
+        {
+            return Some(Protocol::OpenAI);
         }
         None
     }
@@ -172,11 +173,11 @@ impl ProtocolSelector {
     ) -> bool {
         // 工具调用在某些转换中需要特殊处理
         if has_tools {
-            match (source, target_provider) {
-                (Protocol::OpenAI, PoolProviderType::Kiro) => true,
-                (Protocol::Anthropic, PoolProviderType::Kiro) => true,
-                _ => false,
-            }
+            matches!(
+                (source, target_provider),
+                (Protocol::OpenAI, PoolProviderType::Kiro)
+                    | (Protocol::Anthropic, PoolProviderType::Kiro)
+            )
         } else if has_images {
             // 图片在某些 Provider 中需要特殊处理
             match target_provider {

src-tauri/src/converter/protocol_selector.rs

@@ -225,10 +225,10 @@ impl HealthChecker {
         let mut recovered = Vec::new();
 
         for cred in pool.all() {
-            if matches!(cred.status, CredentialStatus::Unhealthy { .. }) {
-                if pool.mark_active(&cred.id).is_ok() {
-                    recovered.push(cred.id.clone());
-                }
+            if matches!(cred.status, CredentialStatus::Unhealthy { .. })
+                && pool.mark_active(&cred.id).is_ok()
+            {
+                recovered.push(cred.id.clone());
             }
         }