feat(getter): add manager RPC methods and wire database init into api::init

- api.rs: call database::init_db() inside init() so DB is ready after first RPC call
- rpc/data.rs: add manager request/response types (App/Hub CRUD, ignore, virtual apps, extra hub)
- rpc/server.rs: register global APP_MANAGER + HUB_MANAGER (OnceCell<Arc<RwLock<...>>>)
  initialised during 'init' RPC; expose 14 new manager methods:
  manager_get_apps, manager_save_app, manager_delete_app, manager_get_app_status,
  manager_set_virtual_apps, manager_renew_all,
  manager_get_hubs, manager_save_hub, manager_delete_hub,
  manager_hub_ignore_app, manager_set_applications_mode,
  manager_get_extra_hubs, manager_save_extra_hub, manager_delete_extra_hub

Author: xz-dev

src/api.rs

@@ -3,6 +3,7 @@ use std::path::Path;
 
 use crate::cache::init_cache_manager_with_expire;
 use crate::core::config::world::{init_world_list, world_list};
+use crate::database;
 use crate::error::Result;
 use crate::websdk::repo::api;
 
@@ -16,6 +17,8 @@ pub async fn init(data_dir: &Path, cache_dir: &Path, global_expire_time: u64) ->
     // cache
     let local_cache_path = cache_dir.join("local_cache");
     init_cache_manager_with_expire(local_cache_path.as_path(), global_expire_time).await;
+    // database
+    database::init_db(data_dir)?;
     Ok(())
 }
 

src/manager/app_manager.rs

@@ -10,14 +10,7 @@ use crate::database::get_db;
 use crate::database::models::app::AppRecord;
 use crate::error::Result;
 
-/// Update event emitted when an app's status changes during a renew cycle.
-#[derive(Debug, Clone)]
-pub struct UpdateEvent {
-    pub app_id: String,
-    pub status: AppStatus,
-}
-
-pub type UpdateCallback = Arc<dyn Fn(UpdateEvent) + Send + Sync>;
+pub type UpdateCallback = Arc<dyn Fn(usize, usize) + Send + Sync>;
 
 /// Manages all tracked apps and their version data.
 ///
@@ -30,8 +23,6 @@ pub struct AppManager {
     /// In-memory version maps keyed by app record id
     version_maps: Arc<RwLock<HashMap<String, VersionMap>>>,
     data_getter: Arc<DataGetter>,
-    /// Optional callback invoked on each status change during renew
-    update_callback: Option<UpdateCallback>,
 }
 
 impl AppManager {
@@ -43,14 +34,9 @@ impl AppManager {
             virtual_apps: Arc::new(RwLock::new(vec![])),
             version_maps: Arc::new(RwLock::new(HashMap::new())),
             data_getter: Arc::new(DataGetter::new()),
-            update_callback: None,
         })
     }
 
-    pub fn set_update_callback(&mut self, cb: UpdateCallback) {
-        self.update_callback = Some(cb);
-    }
-
     /// Replace the virtual app list (installed Android packages).
     pub async fn set_virtual_apps(&self, apps: Vec<AppRecord>) {
         *self.virtual_apps.write().await = apps;
@@ -125,7 +111,7 @@ impl AppManager {
     pub async fn renew_all(
         &self,
         hubs: &[crate::database::models::hub::HubRecord],
-        progress_cb: Option<&dyn Fn(usize, usize)>,
+        progress_cb: Option<UpdateCallback>,
     ) {
         let apps = self.get_saved_apps().await;
         let total = apps.len();
@@ -159,13 +145,9 @@ impl AppManager {
             let hub = hub.clone();
             let getter = self.data_getter.clone();
             let version_maps = self.version_maps.clone();
-            let _apps_map = self.apps.clone();
             let sem = semaphore.clone();
             let completed = completed.clone();
-            let cb_arc: Option<Arc<dyn Fn(usize, usize) + Send + Sync>> = progress_cb.map(|_| {
-                // Can't capture non-Send closure; skip progress in async context
-                Arc::new(|_: usize, _: usize| {}) as Arc<dyn Fn(usize, usize) + Send + Sync>
-            });
+            let cb = progress_cb.clone();
 
             let handle = tokio::spawn(async move {
                 let _permit = sem.acquire().await.unwrap();
@@ -213,9 +195,9 @@ impl AppManager {
                         });
                         vm.set_error(&hub.uuid);
                     }
-                    completed.fetch_add(1, std::sync::atomic::Ordering::SeqCst);
-                    if let Some(ref cb) = cb_arc {
-                        cb(completed.load(std::sync::atomic::Ordering::SeqCst), total);
+                    let done = completed.fetch_add(1, std::sync::atomic::Ordering::SeqCst) + 1;
+                    if let Some(ref f) = cb {
+                        f(done, total);
                     }
                 }
             });
@@ -232,7 +214,6 @@ impl AppManager {
 mod tests {
     use super::*;
     use crate::database;
-    use std::collections::HashMap;
 
     #[test]
     fn test_app_record_save_and_load() {
@@ -251,13 +232,6 @@ mod tests {
 
     #[tokio::test]
     async fn test_version_map_get_status_no_data() {
-        let dir = tempfile::tempdir().unwrap();
-        // Use Database directly to avoid global init conflict
-        let db = database::Database::open(dir.path()).unwrap();
-        let app = AppRecord::new("App".to_string(), HashMap::new());
-        db.upsert_app(&app).unwrap();
-
-        // Simulate with a fresh VersionMap
         let mut vm = VersionMap::new(None, None);
         let status = get_release_status(&mut vm, Some("1.0.0"), None, true);
         // Empty version map + is_saved → NetworkError (no hub_status entries)

src/rpc/data.rs

@@ -249,3 +249,94 @@ impl ToRpcParams for RpcUnregisterDownloaderRequest<'_> {
         to_raw_value(&self).map(Some)
     }
 }
+
+// ============================================================================
+// Manager RPC Data Structures
+// ============================================================================
+
+use crate::database::models::app::AppRecord;
+use crate::database::models::extra_hub::ExtraHubRecord;
+use crate::database::models::hub::HubRecord;
+use crate::manager::app_status::AppStatus;
+
+/// Response wrapping a list of apps with their current status.
+#[derive(Serialize, Deserialize, Debug, Clone)]
+pub struct AppWithStatus {
+    pub record: AppRecord,
+    pub status: AppStatus,
+}
+
+/// Request to save/update an app record.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcSaveAppRequest {
+    pub record: AppRecord,
+}
+
+/// Request to delete an app by record id.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcDeleteAppRequest {
+    pub record_id: String,
+}
+
+/// Request to get a single app by record id.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcGetAppRequest {
+    pub record_id: String,
+}
+
+/// Request to save/update a hub record.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcSaveHubRequest {
+    pub record: HubRecord,
+}
+
+/// Request to delete a hub by UUID.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcDeleteHubRequest {
+    pub hub_uuid: String,
+}
+
+/// Request to get a hub by UUID.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcGetHubRequest {
+    pub hub_uuid: String,
+}
+
+/// Request to set the applications mode for a hub.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcSetApplicationsModeRequest {
+    pub hub_uuid: String,
+    pub enable: bool,
+}
+
+/// Request to ignore/unignore an app in a hub.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcHubIgnoreAppRequest {
+    pub hub_uuid: String,
+    pub app_id: HashMap<String, Option<String>>,
+    pub ignore: bool,
+}
+
+/// Request to set virtual (installed) apps list from Android.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcSetVirtualAppsRequest {
+    pub apps: Vec<AppRecord>,
+}
+
+/// Request to get app status.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcGetAppStatusRequest {
+    pub record_id: String,
+}
+
+/// Request to save/update an ExtraHub record.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcSaveExtraHubRequest {
+    pub record: ExtraHubRecord,
+}
+
+/// Request to get an ExtraHub by id.
+#[derive(Serialize, Deserialize, Debug)]
+pub struct RpcGetExtraHubRequest {
+    pub id: String,
+}