use gtk::prelude::*; use kifu_core::{CoreApp, CoreRequest, CoreResponse}; use kifu_gtk::{ ui::{NewGame, PlayingField}, CoreApi, }; use std::sync::{Arc, RwLock}; fn perftrace(trace_name: &str, f: F) -> A where F: FnOnce() -> A, { let start = std::time::Instant::now(); let result = f(); let end = std::time::Instant::now(); println!("[Trace: {}] {:?}", trace_name, end - start); return result; } fn handle_response(api: CoreApi, window: gtk::ApplicationWindow, message: CoreResponse) { let playing_field = Arc::new(RwLock::new(None)); match message { CoreResponse::NewGameView(view) => { let api = api.clone(); let new_game = NewGame::new(api, view); window.set_child(Some(&new_game)); } CoreResponse::PlayingFieldView(view) => { let api = api.clone(); let mut playing_field = playing_field.write().unwrap(); if playing_field.is_none() { let field = PlayingField::new(api, view); window.set_child(Some(&field)); *playing_field = Some(field); } else { playing_field.as_ref().map(|field| field.update_view(view)); } } } } fn main() { gio::resources_register_include!("com.luminescent-dreams.kifu-gtk.gresource") .expect("Failed to register resources"); let runtime = Arc::new( tokio::runtime::Builder::new_multi_thread() .enable_all() .build() .unwrap(), ); let core = CoreApp::new(); let core_handle = runtime.spawn({ let core = core.clone(); async move { core.run().await; } }); let app = gtk::Application::builder() .application_id("com.luminescent-dreams.kifu-gtk") .build(); app.connect_activate({ let runtime = runtime.clone(); move |app| { let (gtk_tx, gtk_rx) = gtk::glib::MainContext::channel::(gtk::glib::PRIORITY_DEFAULT); let api = CoreApi { gtk_tx, rt: runtime.clone(), core: core.clone(), }; let window = gtk::ApplicationWindow::new(app); window.present(); gtk_rx.attach(None, { let api = api.clone(); move |message| { perftrace("handle_response", || { handle_response(api.clone(), window.clone(), message) }); Continue(true) } }); api.dispatch(CoreRequest::NewGame); } }); println!("running the gtk loop"); app.run(); let _ = runtime.block_on(async { core_handle.await }); }