feat: Optimize KPM file processing logic, use is_some_and method to simplify extension checking, and enhance readability and stability of event processing.

userspace/ksud/src/init_event.rs

@@ -103,7 +103,7 @@ pub fn on_post_data_fs() -> Result<()> {
 
     for entry in std::fs::read_dir(kpm::KPM_DIR)? {
         let path = entry?.path();
-        if path.extension().map_or(false, |ext| ext == "kpm") {
+        if path.extension().is_some_and(|ext| ext == "kpm") {
             let _ = kpm::load_kpm(&path);
         }
     }

userspace/ksud/src/kpm.rs

@@ -37,26 +37,26 @@ pub fn start_kpm_watcher() -> Result<()> {
     Ok(())
 }
 
-// 处理 KPM 文件事件
-fn handle_kpm_event(event: notify::Event) {
-    if event.kind.is_create() {
+pub fn handle_kpm_event(event: notify::Event) {
+    match event.kind {
+        notify::EventKind::Create(_) => {
             event.paths.iter().for_each(|path| {
-            if path.extension().map_or(false, |ext| ext == "kpm") {
+                if path.extension().is_some_and(|ext| ext == "kpm") {
                     let _ = load_kpm(path);
                 }
             });
         }
-
-    if event.kind.is_remove() {
+        notify::EventKind::Remove(_) => {
             event.paths.iter().for_each(|path| {
                 if let Some(name) = path.file_stem() {
                     let _ = unload_kpm(name.to_string_lossy().as_ref());
                 }
             });
         }
+        _ => {}
+    }
 }
 
-// 加载 KPM 模块
 pub fn load_kpm(path: &Path) -> Result<()> {
     let status = std::process::Command::new(KPMMGR_PATH)
         .args(["load", path.to_str().unwrap(), ""])
@@ -68,35 +68,38 @@ pub fn load_kpm(path: &Path) -> Result<()> {
     Ok(())
 }
 
-// 卸载 KPM 模块并删除文件
 pub fn unload_kpm(name: &str) -> Result<()> {
     let status = std::process::Command::new(KPMMGR_PATH)
         .args(["unload", name])
-        .status()?;
+        .status()
+        .map_err(|e| anyhow!("Failed to execute kpmmgr: {}", e))?;
 
-    if status.success() {
     let kpm_path = Path::new(KPM_DIR).join(format!("{}.kpm", name));
     if kpm_path.exists() {
-            if let Err(e) = fs::remove_file(&kpm_path) {
-                log::error!("Failed to delete KPM file: {}", e);
+        fs::remove_file(&kpm_path)
+            .map_err(|e| anyhow!("Failed to delete KPM file: {}", e))
+            .map(|_| log::info!("Deleted KPM file: {}", kpm_path.display()))?;
+    }
+
+    if status.success() {
+        log::info!("Successfully unloaded KPM: {}", name);
     } else {
-                log::info!("Deleted KPM files: {}", kpm_path.display());
-            }
-        }
-        log::info!("Uninstalled KPM: {}", name);
+        log::warn!("KPM unloading may have failed: {}", name);
     }
+    
     Ok(())
 }
 
-// 删除所有 KPM 模块
 pub fn remove_all_kpms() -> Result<()> {
     ensure_kpm_dir()?;
     
     for entry in fs::read_dir(KPM_DIR)? {
         let path = entry?.path();
-        if path.extension().map_or(false, |ext| ext == "kpm") {
+        if path.extension().is_some_and(|ext| ext == "kpm") {
             if let Some(name) = path.file_stem() {
-                let _ = unload_kpm(name.to_string_lossy().as_ref());
+                unload_kpm(name.to_string_lossy().as_ref())
+                    .unwrap_or_else(|e| log::error!("Failed to remove KPM: {}", e));
+                let _ = fs::remove_file(&path);
             }
         }
     }