事件组件

Author: Silwings-git

components.d.ts

@@ -8,7 +8,9 @@ export {}
 /* prettier-ignore */
 declare module 'vue' {
   export interface GlobalComponents {
+    ElHelp: typeof import('element-plus/es')['ElHelp']
     ElOption: typeof import('element-plus/es')['ElOption']
     ElSelect: typeof import('element-plus/es')['ElSelect']
+    ElTooltip: typeof import('element-plus/es')['ElTooltip']
   }
 }

package-lock.json

@@ -11,6 +11,7 @@
   },
   "dependencies": {
     "@fortawesome/fontawesome-free": "^6.7.2",
+    "@icon-park/vue-next": "^1.4.2",
     "@tauri-apps/api": "^2.2.0",
     "@tauri-apps/plugin-autostart": "^2.2.0",
     "@tauri-apps/plugin-dialog": "^2.2.0",

package.json

@@ -1,18 +1,25 @@
 use anyhow::Result;
 use rand::{Rng, distributions::Alphanumeric};
-use tauri::{AppHandle, Emitter, State};
-use tracing::info;
+use tauri::{AppHandle, Emitter, Manager, State};
+use tracing::{debug, info};
 
 use crate::{
-    DatabaseManager,
+    DatabaseManager, check_launch_then_exit,
     db::{
         launcher,
         launcher_resource::{self, LauncherResource},
     },
     error::OneClickLaunchError,
+    events::{
+        payloads::{LauncherLaunched, LauncherLaunchedPayload},
+        types::{EventDispatcher, EventSystem},
+    },
     open_using_default_program,
 };
 
+pub const LAUNCHER_LAUNCHED_EVENT: &str = "launcher_launched";
+pub const LAUNCHER_BASIC_INFO_UPDATED_EVENT: &str = "launcher_basic_info_updated";
+
 /// 创建新的启动器
 #[tauri::command]
 pub async fn craete_launcher(
@@ -22,7 +29,7 @@ pub async fn craete_launcher(
 ) -> Result<i64, OneClickLaunchError> {
     let name = name.unwrap_or_else(generate_default_launcher_name);
     let launcher_id = launcher::create(&db.pool, &name, None).await?;
-    let _ = app.emit("launcher_basic_info_updated", "");
+    let _ = app.emit(LAUNCHER_BASIC_INFO_UPDATED_EVENT, "");
     Ok(launcher_id)
 }
 
@@ -50,7 +57,7 @@ pub async fn modify_launcher_name(
     name: String,
 ) -> Result<(), OneClickLaunchError> {
     launcher::modify_launcher_name(&db.pool, launcher_id, &name).await?;
-    let _ = app.emit("launcher_basic_info_updated", "");
+    let _ = app.emit(LAUNCHER_BASIC_INFO_UPDATED_EVENT, "");
     Ok(())
 }
 
@@ -79,7 +86,7 @@ pub async fn copy_launcher(
 
     tx.commit().await?;
 
-    let _ = app.emit("launcher_basic_info_updated", "");
+    let _ = app.emit(LAUNCHER_BASIC_INFO_UPDATED_EVENT, "");
 
     Ok(new_launcher_id)
 }
@@ -147,7 +154,7 @@ pub async fn delete_launcher(
 
     tx.commit().await?;
 
-    let _ = app.emit("launcher_basic_info_updated", "");
+    let _ = app.emit(LAUNCHER_BASIC_INFO_UPDATED_EVENT, "");
 
     Ok(())
 }
@@ -173,7 +180,7 @@ pub async fn modify_launcher_sort(
 
     tx.commit().await?;
 
-    let _ = app.emit("launcher_basic_info_updated", "");
+    let _ = app.emit(LAUNCHER_BASIC_INFO_UPDATED_EVENT, "");
 
     Ok(())
 }
@@ -236,6 +243,13 @@ pub async fn launch(
 
     launch_launcher_resources(&app, &resources);
 
+    // app.emit(
+    //     LAUNCHER_LAUNCHED_EVENT,
+    //     LauncherLaunchedPayload { launcher_id },
+    // )?;
+
+    EventDispatcher::<LauncherLaunched>::send_event(&app, LauncherLaunchedPayload { launcher_id })?;
+
     Ok(())
 }
 
@@ -249,3 +263,30 @@ pub fn launch_launcher_resources(app: &AppHandle, resources: &[LauncherResource]
         }
     }
 }
+
+pub fn de(app: AppHandle) {
+    // 监听 `event-name`（无论其在什么窗口中触发）
+    let app_handle = app; // 获取 AppHandle
+
+    EventSystem::register_listener(&app_handle.clone(), LauncherLaunched, move |_payload| {
+        let inner_app_handle = app_handle.clone();
+        tauri::async_runtime::spawn(async move {
+            let db = inner_app_handle.state::<DatabaseManager>();
+            if let Ok(_exit @ true) = check_launch_then_exit(&db.pool).await {
+                debug!("监听到启动器启动完成事件, 已设置启动后退出, 正在退出程序.");
+                inner_app_handle.exit(0);
+            }
+        });
+    });
+
+    //   let _id = app.listen(launcher_api::LAUNCHER_LAUNCHED_EVENT, move |_event| {
+    //       let inner_app_handle = app_handle.clone();
+    //       tauri::async_runtime::spawn(async move {
+    //           let db = inner_app_handle.state::<DatabaseManager>();
+    //           if let Ok(_exit @ true) = check_launch_then_exit(&db.pool).await {
+    //               debug!("监听到启动器启动完成事件, 已设置启动后退出, 正在退出程序.");
+    //               inner_app_handle.exit(0);
+    //           }
+    //       });
+    //   });
+}

src-tauri/src/api/launcher_api.rs

@@ -18,6 +18,9 @@ pub enum OneClickLaunchError {
 
     #[error("{0}")]
     TauriError(#[from] tauri::Error),
+
+    #[error("Unable to convert from {0} to Event")]
+    EventConvertError(String),
 }
 
 // we must manually implement serde::Serialize

src-tauri/src/error.rs

@@ -0,0 +1,2 @@
+pub mod payloads;
+pub mod types;

src-tauri/src/events.rs

@@ -0,0 +1,17 @@
+use serde::{Deserialize, Serialize};
+
+use super::types::Event;
+
+pub struct LauncherLaunched;
+#[derive(Serialize, Deserialize, Clone)]
+pub struct LauncherLaunchedPayload {
+    pub launcher_id: i64,
+}
+
+impl Event for LauncherLaunched {
+    type Payload = LauncherLaunchedPayload;
+
+    fn name() -> &'static str {
+        "launcher_launched"
+    }
+}

src-tauri/src/events/payloads.rs

@@ -0,0 +1,59 @@
+use std::marker::PhantomData;
+
+use serde::{Deserialize, Serialize};
+use tauri::{AppHandle, Emitter, Listener};
+use tracing::error;
+
+use crate::error::OneClickLaunchError;
+
+// #[derive(serde::Deserialize, serde::Serialize, Debug, Clone)]
+// pub enum Event {
+//     LauncherLaunched { launcher_id: i64 },
+//     LauncherBasicInfoUpdated { launcher_id: i64 },
+// }
+
+// impl Event {
+//     pub fn name(&self) -> &'static str {
+//         match self {
+//             Event::LauncherLaunched { .. } => "launcher_launched",
+//             Event::LauncherBasicInfoUpdated { .. } => "launcher_basic_info_updated",
+//         }
+//     }
+// }
+
+pub trait Event {
+    type Payload: Serialize + for<'a> Deserialize<'a> + Clone;
+
+    fn name() -> &'static str;
+}
+
+// 事件发送器
+pub struct EventDispatcher<E: Event> {
+    _marker: PhantomData<E>,
+}
+
+impl<E: Event> EventDispatcher<E> {
+    pub fn send_event(app: &AppHandle, payload: E::Payload) -> Result<(), OneClickLaunchError> {
+        app.emit(E::name(), payload)?;
+        Ok(())
+    }
+}
+
+// 事件监听器注册系统
+pub struct EventSystem;
+
+impl EventSystem {
+    pub fn register_listener<E, F>(app: &AppHandle, _event: E, callback: F)
+    where
+        E: Event + 'static,
+        F: Fn(E::Payload) + Send + 'static,
+    {
+        app.listen(E::name(), move |e| {
+            if let Ok(payload) = serde_json::from_str(e.payload()) {
+                callback(payload);
+            } else {
+                error!("{}事件payload反序列化失败.原始数据: {}", "", e.payload());
+            }
+        });
+    }
+}

src-tauri/src/events/types.rs

@@ -1,21 +1,24 @@
 use crate::error::OneClickLaunchError;
 use anyhow::Result;
+use api::launcher_api::de;
 use api::{launcher_api, setting_api, window_api};
 use db::{launcher, launcher_resource, settings};
 use lazy_static::lazy_static;
+use sqlx::{Executor, Sqlite};
 use sqlx::{SqlitePool, sqlite::SqlitePoolOptions};
 use std::path::PathBuf;
 use std::sync::Mutex;
 use std::{env, fs};
-use tauri::Emitter;
 use tauri::tray::{MouseButton, MouseButtonState, TrayIcon, TrayIconEvent};
 use tauri::{AppHandle, Manager, tray::TrayIconBuilder};
+use tauri::{Emitter, Listener};
 use tauri_plugin_autostart::MacosLauncher;
 use tauri_plugin_opener::OpenerExt;
 use tracing::{debug, info};
 mod api;
 mod db;
 pub mod error;
+mod events;
 
 lazy_static! {
     static ref AUTO_START_FLAG: String = "--auto".to_string();
@@ -72,7 +75,7 @@ fn get_db_path() -> Result<PathBuf> {
     if !db_path.exists() {
         // 创建空的数据库文件
         fs::File::create(&db_path)?;
-        println!("Database file created at {:?}", db_path);
+        info!("Database file created at {:?}", db_path);
     }
 
     Ok(db_path)
@@ -116,6 +119,20 @@ async fn query_auto_start_launcher_ids(
     Mutex::new(auto_start_resources)
 }
 
+async fn check_launch_then_exit<'a, E>(executor: E) -> Result<bool, OneClickLaunchError>
+where
+    E: Executor<'a, Database = Sqlite>,
+{
+    match settings::read(executor, "launch_then_exit").await {
+        Ok(Some(setting)) => Ok(string_to_bool(&setting.value)),
+        _ => Ok(false),
+    }
+}
+
+fn string_to_bool(s: &str) -> bool {
+    matches!(s.trim().to_lowercase().as_str(), "true")
+}
+
 #[cfg_attr(mobile, tauri::mobile_entry_point)]
 pub async fn run() -> Result<()> {
     let db_manager = init_db().await?;
@@ -150,7 +167,7 @@ pub async fn run() -> Result<()> {
                         }
                     }
                     _ => {
-                        // println!("unhandled event {event:?}");
+                        debug!("unhandled event {event:?}");
                     }
                 })
                 .on_menu_event(|app, event| match event.id.as_ref() {
@@ -173,6 +190,20 @@ pub async fn run() -> Result<()> {
 
             app.manage(window_context);
 
+            // 监听 `event-name`（无论其在什么窗口中触发）
+            let app_handle = app.handle().clone(); // 获取 AppHandle
+            de(app_handle);
+            // let _id = app.listen(launcher_api::LAUNCHER_LAUNCHED_EVENT, move |_event| {
+            //     let inner_app_handle = app_handle.clone();
+            //     tauri::async_runtime::spawn(async move {
+            //         let db = inner_app_handle.state::<DatabaseManager>();
+            //         if let Ok(_exit @ true) = check_launch_then_exit(&db.pool).await {
+            //             debug!("监听到启动器启动完成事件, 已设置启动后退出, 正在退出程序.");
+            //             inner_app_handle.exit(0);
+            //         }
+            //     });
+            // });
+
             // 检查是否包含 `--auto` 参数
             if args.contains(&AUTO_START_FLAG) {
                 if let Ok(mut data) = auto_start_resources.lock() {

src-tauri/src/lib.rs

@@ -58,4 +58,54 @@ export default defineComponent({
     color: rgba(188, 190, 196);
 }
 
+.dark .el-select-dropdown {
+    background-color: rgba(30, 31, 34);
+    color: rgba(188, 190, 196);
+}
+
+.dark .el-select-dropdown__item.is-hovering {
+    background-color: #020913;
+}
+
+.dark .el-tag {
+    background-color: rgba(30, 31, 34);
+    color: rgba(188, 190, 196);
+}
+
+/* 公共样式 */
+input[type="checkbox"] {
+    width: 16px;
+    height: 16px;
+    border: 1px solid #ccc;
+    border-radius: 3px;
+    background-color: #f0f0f0;
+    cursor: pointer;
+    outline: none;
+}
+
+/* 勾选标记 */
+input[type="checkbox"]:checked::after,
+.dark input[type="checkbox"]:checked::after {
+    content: "✔";
+    display: block;
+    text-align: center;
+    color: #fff;
+    font-size: 12px;
+    line-height: 16px;
+}
+
+/* 深色主题样式 */
+.dark input[type="checkbox"] {
+    appearance: none;
+    -webkit-appearance: none;
+    -moz-appearance: none;
+    border-color: #bcbec4;
+    background-color: #1e1f22;
+}
+
+.dark input[type="checkbox"]:checked {
+    background-color: #ccc;
+    border-color: #ccc;
+}
+
 </style>