chore: prepare release 1.21.6

Author: arch3rPro

CHANGELOG-zh.md

@@ -5,6 +5,24 @@
 格式基于 [Keep a Changelog](https://keepachangelog.com/zh-CN/1.1.0/)，
 版本号遵循 [语义化版本](https://semver.org/lang/zh-CN/)。
 
+## [1.21.6] - 2026-05-30
+
+### 发布概览
+- **远程管理与插件安装稳定性补丁** — 收敛远程主机状态持久化、插件安装进度和全局工作区刷新行为。
+
+### 用户可见更新
+- **远程主机状态持久化** — 远程管理切换主机或重新进入页面后，会恢复上次检测到的远程环境和 CLI 状态。
+- **连接状态语义优化** — 主机卡片改为显示“上次连接成功”，避免误解为 SSH 长连接仍在保持。
+- **插件安装进度优化** — Claude 插件安装 Skills 时，成功、部分成功和失败状态都会保留中文进度信息。
+- **插件卸载确认修复** — 删除已安装插件 Skills 现在会等待确认弹窗，不会在确认前先删除。
+- **全局工作区刷新修复** — Agent 详情页不再因为文件访问或元数据事件触发无意义刷新。
+
+### 开发者与治理更新
+- **远程状态迁移** — 远程主机记录新增远程系统、Shell、主目录、CLI 可用性和 CLI 版本持久化字段。
+- **连接状态回写** — 远程扫描、安装、删除、更新和详情读取命令都会在成功或失败后刷新主机连接状态。
+- **克隆超时处理** — 插件仓库克隆改为按“无进度空闲超时”判断，不再固定 120 秒后失败。
+- **回归覆盖** — 新增文件监听事件过滤测试，并保持远程管理、插件市场、迁移和前端构建验证通过。
+
 ## [1.21.5] - 2026-05-29
 
 ### 发布概览

CHANGELOG.md

@@ -5,6 +5,24 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.21.6] - 2026-05-30
+
+### Release Overview
+- **Remote Management and Plugin Install Stability Patch** — Tightens remote host state persistence, plugin install progress, and Global Workspace refresh behavior.
+
+### User-facing
+- **Remote Host Status Persistence** — Remote Management now restores the last detected host environment and CLI state after switching hosts or returning to the page.
+- **Clear Connection Semantics** — Host cards now show "Last connected" instead of implying a live SSH session is still open.
+- **Plugin Install Progress** — Claude plugin skill installation now keeps localized progress visible through success, partial success, and failure states.
+- **Safer Plugin Uninstall** — Removing installed plugin skills now waits for the confirmation dialog before deleting anything.
+- **Global Workspace Refresh Fix** — Agent detail pages no longer refresh from file access or metadata-only watcher events.
+
+### Developer & Governance
+- **Remote State Migration** — Added persisted remote OS, shell, home directory, CLI availability, and CLI version fields to host records.
+- **Connection Status Updates** — Remote scan, install, delete, update, and detail commands now refresh host connection state on success and failure.
+- **Clone Timeout Handling** — Plugin repository cloning now uses an idle no-progress timeout instead of failing after a fixed 120 seconds.
+- **Regression Coverage** — Added focused coverage for file watcher event filtering and kept remote management, marketplace, migration, and build checks passing.
+
 ## [1.21.5] - 2026-05-29
 
 ### Release Overview

package-lock.json

@@ -1,7 +1,7 @@
 {
   "name": "skills-manager-plus",
   "private": true,
-  "version": "1.21.5",
+  "version": "1.21.6",
   "type": "module",
   "scripts": {
     "dev": "vite",

package.json

@@ -1,6 +1,6 @@
 [package]
 name = "skills-manager-plus"
-version = "1.21.5"
+version = "1.21.6"
 description = "Skills-Manager-Plus - AI Agent Skills Central Manager"
 authors = ["tianliang"]
 license = "MIT"

src-tauri/Cargo.lock

@@ -355,18 +355,33 @@ fn install_plugin_skills_with_progress(
         let mut skipped = 0usize;
         let mut failed: Vec<String> = Vec::new();
 
-        for skill_name in &skill_names {
+        let total = skill_names.len();
+        for (index, skill_name) in skill_names.iter().enumerate() {
+            let progress_prefix = format!("{}/{}|{}", index + 1, total, skill_name);
+            if let Some(callback) = progress.as_ref() {
+                callback("installing", &progress_prefix);
+            }
+
             if existing_names.contains(skill_name) {
                 skipped += 1;
+                if let Some(callback) = progress.as_ref() {
+                    callback("install_skipped", &progress_prefix);
+                }
                 continue;
             }
 
             let Some(source_dir) = find_skill_dir_in_repo(&temp_dir, skill_name) else {
                 failed.push(skill_name.clone());
+                if let Some(callback) = progress.as_ref() {
+                    callback("install_failed", &progress_prefix);
+                }
                 continue;
             };
             if !skill_metadata::is_valid_skill_dir(&source_dir) {
                 failed.push(skill_name.clone());
+                if let Some(callback) = progress.as_ref() {
+                    callback("install_failed", &progress_prefix);
+                }
                 continue;
             }
 
@@ -375,12 +390,18 @@ fn install_plugin_skills_with_progress(
             let install_result = if dest_existed {
                 if !skill_metadata::is_valid_skill_dir(&dest_dir) {
                     skipped += 1;
+                    if let Some(callback) = progress.as_ref() {
+                        callback("install_skipped", &progress_prefix);
+                    }
                     continue;
                 }
                 match install_result_for_existing_skill_dir(skill_name, &dest_dir) {
                     Ok(result) => result,
                     Err(e) => {
                         failed.push(format!("{}: {}", skill_name, e.message));
+                        if let Some(callback) = progress.as_ref() {
+                            callback("install_failed", &progress_prefix);
+                        }
                         continue;
                     }
                 }
@@ -393,6 +414,9 @@ fn install_plugin_skills_with_progress(
                     Ok(result) => result,
                     Err(e) => {
                         failed.push(format!("{}: {}", skill_name, e));
+                        if let Some(callback) = progress.as_ref() {
+                            callback("install_failed", &progress_prefix);
+                        }
                         continue;
                     }
                 }
@@ -412,6 +436,9 @@ fn install_plugin_skills_with_progress(
                         let _ = std::fs::remove_dir_all(&dest_dir);
                     }
                     failed.push(format!("{}: {}", skill_name, e.message));
+                    if let Some(callback) = progress.as_ref() {
+                        callback("install_failed", &progress_prefix);
+                    }
                     continue;
                 }
             };
@@ -424,6 +451,9 @@ fn install_plugin_skills_with_progress(
                             let _ = std::fs::remove_dir_all(&dest_dir);
                         }
                         failed.push(format!("{}: {}", skill_name, e.message));
+                        if let Some(callback) = progress.as_ref() {
+                            callback("install_failed", &progress_prefix);
+                        }
                         continue;
                     }
                 };
@@ -438,12 +468,19 @@ fn install_plugin_skills_with_progress(
 
             if let Err(e) = store.insert_plugin_install(&install_rec) {
                 failed.push(format!("{}: {}", skill_name, e));
+                if let Some(callback) = progress.as_ref() {
+                    callback("install_failed", &progress_prefix);
+                }
                 continue;
             }
 
             installed += 1;
         }
 
+        if let Some(callback) = progress.as_ref() {
+            callback("done", &format!("{installed}|{skipped}|{}", failed.len()));
+        }
+
         Ok(BatchPluginInstallResult {
             installed,
             skipped,

src-tauri/Cargo.toml

@@ -19,10 +19,11 @@ use crate::core::{
         get_cached_remote_skill_detail, get_remote_host, get_remote_skill_detail,
         insert_remote_operation_log, install_center_skill_to_remote, list_remote_agent_paths,
         list_remote_hosts, list_remote_operation_logs, list_remote_skill_snapshots,
-        parse_ssh_config, scan_remote_host, update_remote_host, update_remote_skill_from_center,
-        CredentialRefUpdate, RemoteAgentPathRecord, RemoteAuthType, RemoteHostInput,
-        RemoteHostRecord, RemoteOperationLogRecord, RemoteSkillDetail, RemoteSkillSnapshot,
-        SshConfigHost,
+        parse_ssh_config, scan_remote_host_with_environment, update_remote_host,
+        update_remote_host_connection_status, update_remote_host_environment,
+        update_remote_skill_from_center, CredentialRefUpdate, RemoteAgentPathRecord,
+        RemoteAuthType, RemoteHostInput, RemoteHostRecord, RemoteOperationLogRecord,
+        RemoteSkillDetail, RemoteSkillSnapshot, SshConfigHost,
     },
     skill_store::SkillStore,
 };
@@ -252,11 +253,13 @@ pub async fn remote_test_connection(
         let started_at = chrono::Utc::now().timestamp_millis();
         let result = (|| {
             let config = build_connection_config(&store, &id, password, passphrase)?;
-            let executor = SshSftpExecutor::connect(&config).map_err(AppError::network)?;
+            let executor = connect_remote_executor(&store, &id, &config, started_at)?;
             executor.test_connection().map_err(AppError::network)
         })();
         match result {
             Ok(environment) => {
+                update_remote_host_environment(&store, &id, started_at, &environment)
+                    .map_err(AppError::db)?;
                 let summary_json = serde_json::to_string(&serde_json::json!({
                     "os": &environment.os,
                     "shell": &environment.shell,
@@ -283,6 +286,8 @@ pub async fn remote_test_connection(
             Err(err) => {
                 let error_code = error_kind_code(&err.kind).to_string();
                 let error_message = err.message.clone();
+                let _ =
+                    update_remote_host_connection_status(&store, &id, None, Some(&error_message));
                 let _ = insert_remote_operation_log(
                     &store,
                     &remote_operation_log(
@@ -314,11 +319,13 @@ pub async fn remote_install_cli(
         let started_at = chrono::Utc::now().timestamp_millis();
         let result = (|| {
             let config = build_connection_config(&store, &id, password, passphrase)?;
-            let executor = SshSftpExecutor::connect(&config).map_err(AppError::network)?;
+            let executor = connect_remote_executor(&store, &id, &config, started_at)?;
             install_remote_cli(&executor)
         })();
         match result {
             Ok(report) => {
+                update_remote_host_environment(&store, &id, started_at, &report.environment)
+                    .map_err(AppError::db)?;
                 let summary_json = serde_json::to_string(&serde_json::json!({
                     "asset_name": &report.asset_name,
                     "install_path": &report.install_path,
@@ -345,6 +352,8 @@ pub async fn remote_install_cli(
             Err(err) => {
                 let error_code = error_kind_code(&err.kind).to_string();
                 let error_message = err.message.clone();
+                let _ =
+                    update_remote_host_connection_status(&store, &id, None, Some(&error_message));
                 let _ = insert_remote_operation_log(
                     &store,
                     &remote_operation_log(
@@ -379,13 +388,18 @@ pub async fn remote_scan_host(
                 .map_err(AppError::db)?
                 .ok_or_else(|| AppError::not_found("Remote host not found"))?;
             let config = build_connection_config_for_host(&store, &host, password, passphrase)?;
-            let executor = SshSftpExecutor::connect(&config).map_err(AppError::network)?;
-            scan_remote_host(&store, &executor, &host, &config).map_err(AppError::network)
+            let executor = connect_remote_executor(&store, &id, &config, started_at)?;
+            scan_remote_host_with_environment(&store, &executor, &host, &config)
+                .map_err(AppError::network)
         })();
         match result {
-            Ok(snapshots) => {
+            Ok((snapshots, environment)) => {
+                update_remote_host_environment(&store, &id, started_at, &environment)
+                    .map_err(AppError::db)?;
                 let summary_json = serde_json::to_string(&serde_json::json!({
                     "snapshot_count": snapshots.len(),
+                    "cli_available": environment.cli_available,
+                    "cli_version": environment.cli_version,
                 }))
                 .ok();
                 insert_remote_operation_log(
@@ -406,6 +420,8 @@ pub async fn remote_scan_host(
             Err(err) => {
                 let error_code = error_kind_code(&err.kind).to_string();
                 let error_message = err.message.clone();
+                let _ =
+                    update_remote_host_connection_status(&store, &id, None, Some(&error_message));
                 let _ = insert_remote_operation_log(
                     &store,
                     &remote_operation_log(
@@ -436,11 +452,12 @@ pub async fn remote_delete_skill(
 ) -> Result<RemoteOperationLogRecord, AppError> {
     let store = store.inner().clone();
     tauri::async_runtime::spawn_blocking(move || {
+        let started_at = chrono::Utc::now().timestamp_millis();
         let host = get_remote_host(&store, &host_id)
             .map_err(AppError::db)?
             .ok_or_else(|| AppError::not_found("Remote host not found"))?;
         let config = build_connection_config_for_host(&store, &host, password, passphrase)?;
-        let executor = SshSftpExecutor::connect(&config).map_err(AppError::network)?;
+        let executor = connect_remote_executor(&store, &host_id, &config, started_at)?;
         delete_remote_skill(&store, &executor, &host_id, &agent_id, &skill_name)
             .map_err(AppError::network)
     })
@@ -458,11 +475,12 @@ pub async fn remote_install_center_skill(
 ) -> Result<RemoteOperationLogRecord, AppError> {
     let store = store.inner().clone();
     tauri::async_runtime::spawn_blocking(move || {
+        let started_at = chrono::Utc::now().timestamp_millis();
         let host = get_remote_host(&store, &host_id)
             .map_err(AppError::db)?
             .ok_or_else(|| AppError::not_found("Remote host not found"))?;
         let config = build_connection_config_for_host(&store, &host, password, passphrase)?;
-        let executor = SshSftpExecutor::connect(&config).map_err(AppError::network)?;
+        let executor = connect_remote_executor(&store, &host_id, &config, started_at)?;
         install_center_skill_to_remote(&store, &executor, &host_id, &agent_id, &skill_id)
             .map_err(AppError::network)
     })
@@ -480,11 +498,12 @@ pub async fn remote_update_skill(
 ) -> Result<RemoteOperationLogRecord, AppError> {
     let store = store.inner().clone();
     tauri::async_runtime::spawn_blocking(move || {
+        let started_at = chrono::Utc::now().timestamp_millis();
         let host = get_remote_host(&store, &host_id)
             .map_err(AppError::db)?
             .ok_or_else(|| AppError::not_found("Remote host not found"))?;
         let config = build_connection_config_for_host(&store, &host, password, passphrase)?;
-        let executor = SshSftpExecutor::connect(&config).map_err(AppError::network)?;
+        let executor = connect_remote_executor(&store, &host_id, &config, started_at)?;
         update_remote_skill_from_center(&store, &executor, &host_id, &agent_id, &skill_name)
             .map_err(AppError::network)
     })
@@ -513,7 +532,8 @@ pub async fn remote_get_skill_detail(
             .map_err(AppError::db)?
             .ok_or_else(|| AppError::not_found("Remote host not found"))?;
         let config = build_connection_config_for_host(&store, &host, password, passphrase)?;
-        let executor = SshSftpExecutor::connect(&config).map_err(AppError::network)?;
+        let started_at = chrono::Utc::now().timestamp_millis();
+        let executor = connect_remote_executor(&store, &host_id, &config, started_at)?;
         get_remote_skill_detail(&store, &executor, &host_id, &agent_id, &skill_name)
             .map_err(AppError::network)
     })
@@ -721,6 +741,31 @@ fn build_connection_config_for_host(
     })
 }
 
+fn connect_remote_executor(
+    store: &SkillStore,
+    host_id: &str,
+    config: &RemoteConnectionConfig,
+    connected_at: i64,
+) -> Result<SshSftpExecutor, AppError> {
+    match SshSftpExecutor::connect(config) {
+        Ok(executor) => {
+            update_remote_host_connection_status(store, host_id, Some(connected_at), None)
+                .map_err(AppError::db)?;
+            Ok(executor)
+        }
+        Err(error) => {
+            let app_error = AppError::network(error);
+            let _ = update_remote_host_connection_status(
+                store,
+                host_id,
+                None,
+                Some(&app_error.message),
+            );
+            Err(app_error)
+        }
+    }
+}
+
 fn resolve_secret(
     store: &SkillStore,
     provided_secret: Option<String>,