回退为调用dumpsys修复兼容问题

fas-rs-fw/src/scheduler/topapp.rs

@@ -12,13 +12,10 @@
 *  See the License for the specific language governing permissions and
 *  limitations under the License. */
 use std::{
-    fs::{self, OpenOptions},
+    process::Command,
     time::{Duration, Instant},
 };
 
-use binder::binder_impl::IBinderInternal;
-
-const TOPAPP_TEMP: &str = "/dev/fas_rs_topapp_temp";
 const REFRESH_TIME: Duration = Duration::from_secs(2);
 
 pub struct TimedWatcher {
@@ -28,50 +25,39 @@ pub struct TimedWatcher {
 
 impl TimedWatcher {
     pub fn new() -> Self {
-        let cache = Vec::new();
+        let cache = Self::get_top_pids().unwrap_or_default();
 
-        let mut result = Self {
+        Self {
             cache,
             last_refresh: Instant::now(),
-        };
-
-        result.get_top_pids();
-        result
+        }
     }
 
     pub fn is_topapp(&mut self, pid: i32) -> bool {
         if self.last_refresh.elapsed() > REFRESH_TIME {
-            self.get_top_pids();
+            self.cache = Self::get_top_pids().unwrap_or_default();
             self.last_refresh = Instant::now();
         }
 
         self.cache.contains(&pid)
     }
 
-    fn get_top_pids(&mut self) {
-        let temp = OpenOptions::new()
-            .write(true)
-            .truncate(true)
-            .create(true)
-            .open(TOPAPP_TEMP)
-            .unwrap();
-
-        let Some(mut service) = binder::get_service("window") else {
-            return;
-        };
+    fn get_top_pids() -> Option<Vec<i32>> {
+        let dump = Command::new("dumpsys")
+            .args(["window", "visible-apps"])
+            .output()
+            .ok()?;
+        let dump = String::from_utf8_lossy(&dump.stdout).into_owned();
 
-        if service.dump(&temp, &["visible-apps"]).is_err() {
-            return;
-        }
-
-        let dump = fs::read_to_string(TOPAPP_TEMP).unwrap();
+        Some(Self::parse_top_app(&dump))
+    }
 
-        self.cache = dump
-            .lines()
+    fn parse_top_app(dump: &str) -> Vec<i32> {
+        dump.lines()
             .filter(|l| l.contains("Session{"))
             .filter_map(|l| l.split_whitespace().nth(3))
             .filter_map(|s| s.split(':').next())
             .map(|p| p.trim().parse().unwrap())
-            .collect();
+            .collect()
     }
 }