retrom-plugin-standalone 0.7.20

Retrom plugin to facilitate standlone mode features.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

mod commands;
mod desktop;
mod error;

use desktop::Standalone;
pub use error::{Error, Result};
use retrom_plugin_config::ConfigExt;
use tauri::{
    plugin::{Builder, TauriPlugin},
    Manager, Runtime,
};
use tokio::runtime::Handle;

/// Extensions to [`tauri::App`], [`tauri::AppHandle`] and [`tauri::Window`] to access the standalone APIs.
pub trait StandaloneExt<R: Runtime> {
    fn standalone(&self) -> &Standalone<R>;
}

impl<R: Runtime, T: Manager<R>> crate::StandaloneExt<R> for T {
    fn standalone(&self) -> &Standalone<R> {
        self.state::<Standalone<R>>().inner()
    }
}

/// Initializes the plugin.
/// [TODO:description]
pub fn init<R: Runtime>() -> TauriPlugin<R> {
    Builder::new("standalone")
        .invoke_handler(tauri::generate_handler![
            commands::enable_standalone_mode,
            commands::disable_standalone_mode
        ])
        .setup(|app, api| {
            let standalone = desktop::init(app, api)?;
            app.manage(standalone);

            let app = app.clone();
            let (tx, rx) = std::sync::mpsc::channel();

            tauri::async_runtime::spawn_blocking(|| {
                tauri::async_runtime::block_on(async move {
                    let standalone = app.standalone();

                    let client_config = app.config_manager().get_config().await;

                    let is_standalone = client_config.server.is_some_and(|c| c.standalone());
                    if is_standalone {
                        if let Err(why) = standalone.start_server().await {
                            tracing::error!("Failed to start standalone server: {:#?}", why);
                        }
                    }

                    tx.send(()).unwrap();
                })
            });

            rx.recv().expect("Failed to receive from channel");

            Ok(())
        })
        .on_event(|app, event| {
            if let tauri::RunEvent::ExitRequested { .. } = event {
                tokio::task::block_in_place(move || {
                    Handle::current().block_on(async move {
                        let standalone = app.standalone();
                        if let Err(why) = standalone.stop_server().await {
                            tracing::error!("Failed to stop standalone server: {}", why);
                        }
                    });
                });
            }
        })
        .build()
}