dominus

One damus client to rule them all
git clone git://jb55.com/dominus
Log | Files | Refs | README

commit ad1a1dd774a628dfa38a329d481618c52a0661f7
parent 1db61f1adee9cd2ee5c93ea3aa0efbe6335b46be
Author: William Casarin <jb55@jb55.com>
Date:   Tue, 29 Nov 2022 19:01:04 -0800

no idea why this is working now

Diffstat:
Msrc/app.rs | 3+--
Asrc/bin/main.rs | 8++++++++
Msrc/lib.rs | 356++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
Dsrc/main.rs | 362-------------------------------------------------------------------------------
4 files changed, 363 insertions(+), 366 deletions(-)

diff --git a/src/app.rs b/src/app.rs @@ -21,8 +21,7 @@ type ImageCache<'a> = HashMap<UrlKey<'a>, Promise<ehttp::Result<RetainedImage>>> /// We derive Deserialize/Serialize so we can persist app state on shutdown. #[derive(serde::Deserialize, serde::Serialize)] -#[serde(default)] // if we add new fields, give them default values when - // deserializing old state +#[serde(default)] // if we add new fields, give them default values when deserializing old state pub struct Damus<'a> { // Example stuff: label: String, diff --git a/src/bin/main.rs b/src/bin/main.rs @@ -0,0 +1,8 @@ +use damus::WinitEvent; + +fn main() { + #[cfg(debug_assertions)] + simple_logger::init().unwrap(); + let event_loop = winit::event_loop::EventLoopBuilder::<WinitEvent>::with_user_event().build(); + damus::main(event_loop); +} diff --git a/src/lib.rs b/src/lib.rs @@ -1,6 +1,358 @@ -#![warn(clippy::all, rust_2018_idioms)] - mod app; mod event; + pub use app::Damus; pub use event::Event; + +use ::egui::FontDefinitions; +use chrono::Timelike; +use egui_wgpu_backend::{RenderPass, ScreenDescriptor}; +use egui_winit_platform::{Platform, PlatformDescriptor}; +use log::{error, warn}; +use std::iter; +use std::time::Instant; +use wgpu::CompositeAlphaMode; +use winit::event::Event::*; +use winit::event_loop::ControlFlow; +use winit::event_loop::EventLoop; + +#[cfg(target_os = "android")] +use winit::{ + event::StartCause, platform::android::EventLoopBuilderExtAndroid, + platform::run_return::EventLoopExtRunReturn, +}; + +/// A custom event type for the winit app. +#[derive(Debug, Clone, Copy)] +pub enum WinitEvent { + RequestRedraw, +} + +/// This is the repaint signal type that egui needs for requesting a repaint from another thread. +/// It sends the custom RequestRedraw event to the winit event loop. +struct ExampleRepaintSignal(std::sync::Mutex<winit::event_loop::EventLoopProxy<WinitEvent>>); + +impl epi::backend::RepaintSignal for ExampleRepaintSignal { + fn request_repaint(&self) { + self.0 + .lock() + .unwrap_or_else(|e| { + panic!( + "Failed to lock guard at {} line {} with error\n{}", + file!(), + line!(), + e + ) + }) + .send_event(WinitEvent::RequestRedraw) + .ok(); + } +} + +#[cfg(target_os = "android")] +#[no_mangle] +fn android_main(app: winit::platform::android::activity::AndroidApp) { + #[cfg(debug_assertions)] + { + std::env::set_var("RUST_BACKTRACE", "full"); + android_logger::init_once( + android_logger::Config::default().with_min_level(log::Level::Trace), + ); + } + let event_loop = winit::event_loop::EventLoopBuilder::<WinitEvent>::with_user_event() + .with_android_app(app) + .build(); + main(event_loop); +} +pub fn main(mut event_loop: EventLoop<WinitEvent>) { + //'Cannot get the native window, it's null and will always be null before Event::Resumed and after Event::Suspended. Make sure you only call this function between those events.', ..../winit-c2fdb27092aba5a7/418cc44/src/platform_impl/android/mod.rs:1028:13 + warn!("Winit build window at {} line {}", file!(), line!()); + let window = winit::window::WindowBuilder::new() + .with_decorations(!cfg!(android)) /* !cfg!(android) */ + .with_resizable(!cfg!(android)) + .with_transparent(false) + .with_title("egui-wgpu_winit example") + .build(&event_loop) + .unwrap_or_else(|e| { + panic!( + "Failed to init window at {} line {} with error\n{:?}", + file!(), + line!(), + e + ) + }); + + warn!("WGPU new instance at {} line {}", file!(), line!()); + let mut instance = wgpu::Instance::new(wgpu::Backends::PRIMARY); + + let mut size = window.inner_size(); + let outer_size = window.outer_size(); + + warn!("outer_size = {:?}", outer_size); + warn!("size = {:?}", size); + + warn!("Create platform at {} line {}", file!(), line!()); + // We use the egui_winit_platform crate as the platform. + let mut platform = Platform::new(PlatformDescriptor { + physical_width: size.width as u32, + physical_height: size.height as u32, + scale_factor: window.scale_factor(), + font_definitions: FontDefinitions::default(), + style: Default::default(), + }); + + #[cfg(target_os = "android")] + let mut platform = { + //Just find the actual screen size on android + event_loop.run_return(|main_event, tgt, control_flow| { + control_flow.set_poll(); + warn!( + "Got event: {:?} at {} line {}", + &main_event, + file!(), + line!() + ); + match main_event { + NewEvents(e) => match e { + StartCause::ResumeTimeReached { .. } => {} + StartCause::WaitCancelled { .. } => {} + StartCause::Poll => {} + StartCause::Init => {} + }, + WindowEvent { + window_id, + ref event, + } => { + if let winit::event::WindowEvent::Resized(r) = event { + size = *r; + } + } + DeviceEvent { .. } => {} + UserEvent(_) => {} + Suspended => { + control_flow.set_poll(); + } + Resumed => { + if let Some(primary_mon) = tgt.primary_monitor() { + size = primary_mon.size(); + window.set_inner_size(size); + warn!( + "Set to new size: {:?} at {} line {}", + &size, + file!(), + line!() + ); + } else if let Some(other_mon) = tgt.available_monitors().next() { + size = other_mon.size(); + window.set_inner_size(size); + warn!( + "Set to new size: {:?} at {} line {}", + &size, + file!(), + line!() + ); + } + control_flow.set_exit(); + } + MainEventsCleared => {} + RedrawRequested(rdr) => {} + RedrawEventsCleared => {} + LoopDestroyed => {} + }; + platform.handle_event(&main_event); + }); + + warn!("Recreate platform at {} line {}", file!(), line!()); + // We use the egui_winit_platform crate as the platform. + Platform::new(PlatformDescriptor { + physical_width: size.width as u32, + physical_height: size.height as u32, + scale_factor: window.scale_factor(), + font_definitions: FontDefinitions::default(), + style: Default::default(), + }) + }; + + warn!("WGPU new surface at {} line {}", file!(), line!()); + let mut surface = unsafe { instance.create_surface(&window) }; + + warn!("instance request_adapter at {} line {}", file!(), line!()); + // WGPU 0.11+ support force fallback (if HW implementation not supported), set it to true or false (optional). + let adapter = pollster::block_on(instance.request_adapter(&wgpu::RequestAdapterOptions { + power_preference: wgpu::PowerPreference::HighPerformance, + compatible_surface: Some(&surface), + force_fallback_adapter: false, + })) + .unwrap_or_else(|| panic!("Failed get adapter at {} line {}", file!(), line!())); + + warn!("adapter request_device at {} line {}", file!(), line!()); + let (device, queue) = pollster::block_on(adapter.request_device( + &wgpu::DeviceDescriptor { + features: wgpu::Features::default(), + limits: wgpu::Limits::default(), + label: None, + }, + None, + )) + .unwrap_or_else(|e| { + panic!( + "Failed to request device at {} line {} with error\n{:?}", + file!(), + line!(), + e + ) + }); + + let surface_format = surface.get_supported_formats(&adapter)[0]; + let mut surface_config = wgpu::SurfaceConfiguration { + usage: wgpu::TextureUsages::RENDER_ATTACHMENT, + format: surface_format, + width: size.width as u32, + height: size.height as u32, + present_mode: wgpu::PresentMode::AutoNoVsync, + alpha_mode: CompositeAlphaMode::Auto, + }; + + warn!("surface configure at {} line {}", file!(), line!()); + surface.configure(&device, &surface_config); + + warn!("RenderPass new at {} line {}", file!(), line!()); + // We use the egui_wgpu_backend crate as the render backend. + let mut egui_rpass = RenderPass::new(&device, surface_format, 1); + + warn!("DemoWindows default at {} line {}", file!(), line!()); + // Display the demo application that ships with egui. + let mut app = Damus::new(); + app.add_test_events(); + + let start_time = Instant::now(); + + let mut in_bad_state = false; + + warn!("Enter the loop"); + event_loop.run(move |event, _, control_flow| { + // Pass the winit events to the platform integration. + warn!("Got event: {:?} at {} line {}", &event, file!(), line!()); + platform.handle_event(&event); + match event { + RedrawRequested(..) => { + platform.update_time(start_time.elapsed().as_secs_f64()); + + let output_frame = match surface.get_current_texture() { + Ok(frame) => frame, + Err(wgpu::SurfaceError::Outdated) => { + // This error occurs when the app is minimized on Windows. + // Silently return here to prevent spamming the console with: + error!("The underlying surface has changed, and therefore the swap chain must be updated"); + in_bad_state = true; + return; + } + Err(wgpu::SurfaceError::Lost) => { + // This error occurs when the app is minimized on Windows. + // Silently return here to prevent spamming the console with: + error!("LOST surface, drop frame. Originally: \"The swap chain has been lost and needs to be recreated\""); + in_bad_state = true; + return; + } + Err(e) => { + error!("Dropped frame with error: {}", e); + return; + } + }; + let output_view = output_frame + .texture + .create_view(&wgpu::TextureViewDescriptor::default()); + + // Begin to draw the UI frame. + platform.begin_frame(); + + // Draw the demo application. + app.ui(&platform.context()); + + // End the UI frame. We could now handle the output and draw the UI with the backend. + let full_output = platform.end_frame(Some(&window)); + let paint_jobs = platform.context().tessellate(full_output.shapes); + + let mut encoder = device.create_command_encoder(&wgpu::CommandEncoderDescriptor { + label: Some("encoder"), + }); + + // Upload all resources for the GPU. + let screen_descriptor = ScreenDescriptor { + physical_width: surface_config.width, + physical_height: surface_config.height, + scale_factor: window.scale_factor() as f32 + }; + let tdelta: egui::TexturesDelta = full_output.textures_delta; + egui_rpass + .add_textures(&device, &queue, &tdelta) + .expect("add texture ok"); + egui_rpass.update_buffers(&device, &queue, &paint_jobs, &screen_descriptor); + + // Record all render passes. + egui_rpass + .execute( + &mut encoder, + &output_view, + &paint_jobs, + &screen_descriptor, + Some(wgpu::Color::BLACK), + ) + .unwrap_or_else(|e| panic!("Failed to render pass at {} line {} with error\n{:?}", file!(), line!(), e)); + // Submit the commands. + queue.submit(iter::once(encoder.finish())); + + // Redraw egui + output_frame.present(); + + egui_rpass + .remove_textures(tdelta) + .expect("remove texture ok"); + + // Support reactive on windows only, but not on linux. + // if _output.needs_repaint { + // *control_flow = ControlFlow::Poll; + // } else { + // *control_flow = ControlFlow::Wait; + // } + } + MainEventsCleared | UserEvent(WinitEvent::RequestRedraw) => { + window.request_redraw(); + } + WindowEvent { event, .. } => match event { + winit::event::WindowEvent::Resized(size) => { + // Resize with 0 width and height is used by winit to signal a minimize event on Windows. + // See: https://github.com/rust-windowing/winit/issues/208 + // This solves an issue where the app would panic when minimizing on Windows. + if size.width > 0 && size.height > 0 { + surface_config.width = size.width; + surface_config.height = size.height; + surface.configure(&device, &surface_config); + } + } + winit::event::WindowEvent::CloseRequested => { + *control_flow = ControlFlow::Exit; + } + _ => {} + }, + Resumed => { + if in_bad_state { + //https://github.com/gfx-rs/wgpu/issues/2302 + warn!("WGPU new surface at {} line {}", file!(), line!()); + surface = unsafe { instance.create_surface(&window) }; + warn!("surface configure at {} line {}", file!(), line!()); + surface.configure(&device, &surface_config); + in_bad_state = false; + } + }, + Suspended => (), + _ => (), + } + }); +} + +/// Time of day as seconds since midnight. Used for clock in demo app. +pub fn seconds_since_midnight() -> f64 { + let time = chrono::Local::now().time(); + time.num_seconds_from_midnight() as f64 + 1e-9 * (time.nanosecond() as f64) +} diff --git a/src/main.rs b/src/main.rs @@ -1,362 +0,0 @@ -use ::egui::FontDefinitions; -use chrono::Timelike; -use damus::Damus; -use egui_wgpu_backend::{RenderPass, ScreenDescriptor}; -use egui_winit_platform::{Platform, PlatformDescriptor}; -use log::{error, warn}; -use std::iter; -use std::time::Instant; -use wgpu::CompositeAlphaMode; -use winit::event::Event::*; -use winit::event_loop::ControlFlow; -use winit::event_loop::EventLoop; - -#[cfg(target_os = "android")] -use winit::{ - event::StartCause, platform::android::EventLoopBuilderExtAndroid, - platform::run_return::EventLoopExtRunReturn, -}; - -/// A custom event type for the winit app. -#[derive(Debug, Clone, Copy)] -pub enum Event { - RequestRedraw, -} - -/// This is the repaint signal type that egui needs for requesting a repaint from another thread. -/// It sends the custom RequestRedraw event to the winit event loop. -struct ExampleRepaintSignal(std::sync::Mutex<winit::event_loop::EventLoopProxy<Event>>); - -impl epi::backend::RepaintSignal for ExampleRepaintSignal { - fn request_repaint(&self) { - self.0 - .lock() - .unwrap_or_else(|e| { - panic!( - "Failed to lock guard at {} line {} with error\n{}", - file!(), - line!(), - e - ) - }) - .send_event(Event::RequestRedraw) - .ok(); - } -} - -#[cfg(target_os = "android")] -#[no_mangle] -fn android_main(app: winit::platform::android::activity::AndroidApp) { - #[cfg(debug_assertions)] - { - std::env::set_var("RUST_BACKTRACE", "full"); - android_logger::init_once( - android_logger::Config::default().with_min_level(log::Level::Trace), - ); - } - let event_loop = winit::event_loop::EventLoopBuilder::<Event>::with_user_event() - .with_android_app(app) - .build(); - run_evloop(event_loop); -} - -fn main() { - #[cfg(debug_assertions)] - simple_logger::init().unwrap(); - let event_loop = winit::event_loop::EventLoopBuilder::<Event>::with_user_event().build(); - run_evloop(event_loop); -} - -pub fn run_evloop(mut event_loop: EventLoop<Event>) { - //'Cannot get the native window, it's null and will always be null before Event::Resumed and after Event::Suspended. Make sure you only call this function between those events.', ..../winit-c2fdb27092aba5a7/418cc44/src/platform_impl/android/mod.rs:1028:13 - warn!("Winit build window at {} line {}", file!(), line!()); - let window = winit::window::WindowBuilder::new() - .with_decorations(!cfg!(android)) /* !cfg!(android) */ - .with_resizable(!cfg!(android)) - .with_transparent(false) - .with_title("egui-wgpu_winit example") - .build(&event_loop) - .unwrap_or_else(|e| { - panic!( - "Failed to init window at {} line {} with error\n{:?}", - file!(), - line!(), - e - ) - }); - - warn!("WGPU new instance at {} line {}", file!(), line!()); - let mut instance = wgpu::Instance::new(wgpu::Backends::PRIMARY); - - let mut size = window.inner_size(); - let outer_size = window.outer_size(); - - warn!("outer_size = {:?}", outer_size); - warn!("size = {:?}", size); - - warn!("Create platform at {} line {}", file!(), line!()); - // We use the egui_winit_platform crate as the platform. - let mut platform = Platform::new(PlatformDescriptor { - physical_width: size.width as u32, - physical_height: size.height as u32, - scale_factor: window.scale_factor(), - font_definitions: FontDefinitions::default(), - style: Default::default(), - }); - - #[cfg(target_os = "android")] - let mut platform = { - //Just find the actual screen size on android - event_loop.run_return(|main_event, tgt, control_flow| { - control_flow.set_poll(); - warn!( - "Got event: {:?} at {} line {}", - &main_event, - file!(), - line!() - ); - match main_event { - NewEvents(e) => match e { - StartCause::ResumeTimeReached { .. } => {} - StartCause::WaitCancelled { .. } => {} - StartCause::Poll => {} - StartCause::Init => {} - }, - WindowEvent { - window_id, - ref event, - } => { - if let winit::event::WindowEvent::Resized(r) = event { - size = *r; - } - } - DeviceEvent { .. } => {} - UserEvent(_) => {} - Suspended => { - control_flow.set_poll(); - } - Resumed => { - if let Some(primary_mon) = tgt.primary_monitor() { - size = primary_mon.size(); - window.set_inner_size(size); - warn!( - "Set to new size: {:?} at {} line {}", - &size, - file!(), - line!() - ); - } else if let Some(other_mon) = tgt.available_monitors().next() { - size = other_mon.size(); - window.set_inner_size(size); - warn!( - "Set to new size: {:?} at {} line {}", - &size, - file!(), - line!() - ); - } - control_flow.set_exit(); - } - MainEventsCleared => {} - RedrawRequested(rdr) => {} - RedrawEventsCleared => {} - LoopDestroyed => {} - }; - platform.handle_event(&main_event); - }); - - warn!("Recreate platform at {} line {}", file!(), line!()); - // We use the egui_winit_platform crate as the platform. - Platform::new(PlatformDescriptor { - physical_width: size.width as u32, - physical_height: size.height as u32, - scale_factor: window.scale_factor(), - font_definitions: FontDefinitions::default(), - style: Default::default(), - }) - }; - - warn!("WGPU new surface at {} line {}", file!(), line!()); - let mut surface = unsafe { instance.create_surface(&window) }; - - warn!("instance request_adapter at {} line {}", file!(), line!()); - // WGPU 0.11+ support force fallback (if HW implementation not supported), set it to true or false (optional). - let adapter = pollster::block_on(instance.request_adapter(&wgpu::RequestAdapterOptions { - power_preference: wgpu::PowerPreference::HighPerformance, - compatible_surface: Some(&surface), - force_fallback_adapter: false, - })) - .unwrap_or_else(|| panic!("Failed get adapter at {} line {}", file!(), line!())); - - warn!("adapter request_device at {} line {}", file!(), line!()); - let (device, queue) = pollster::block_on(adapter.request_device( - &wgpu::DeviceDescriptor { - features: wgpu::Features::default(), - limits: wgpu::Limits::default(), - label: None, - }, - None, - )) - .unwrap_or_else(|e| { - panic!( - "Failed to request device at {} line {} with error\n{:?}", - file!(), - line!(), - e - ) - }); - - let surface_format = surface.get_supported_formats(&adapter)[0]; - let mut surface_config = wgpu::SurfaceConfiguration { - usage: wgpu::TextureUsages::RENDER_ATTACHMENT, - format: surface_format, - width: size.width as u32, - height: size.height as u32, - present_mode: wgpu::PresentMode::AutoNoVsync, - alpha_mode: CompositeAlphaMode::Auto, - }; - - warn!("surface configure at {} line {}", file!(), line!()); - surface.configure(&device, &surface_config); - - warn!("RenderPass new at {} line {}", file!(), line!()); - // We use the egui_wgpu_backend crate as the render backend. - let mut egui_rpass = RenderPass::new(&device, surface_format, 1); - - warn!("DemoWindows default at {} line {}", file!(), line!()); - // Display the demo application that ships with egui. - let mut app = egui_demo_lib::DemoWindows::default(); - //let mut app = Damus::new(); - //app.add_test_events(); - - let start_time = Instant::now(); - - let mut in_bad_state = false; - - warn!("Enter the loop"); - event_loop.run(move |event, _, control_flow| { - // Pass the winit events to the platform integration. - warn!("Got event: {:?} at {} line {}", &event, file!(), line!()); - platform.handle_event(&event); - match event { - RedrawRequested(..) => { - platform.update_time(start_time.elapsed().as_secs_f64()); - - let output_frame = match surface.get_current_texture() { - Ok(frame) => frame, - Err(wgpu::SurfaceError::Outdated) => { - // This error occurs when the app is minimized on Windows. - // Silently return here to prevent spamming the console with: - error!("The underlying surface has changed, and therefore the swap chain must be updated"); - in_bad_state = true; - return; - } - Err(wgpu::SurfaceError::Lost) => { - // This error occurs when the app is minimized on Windows. - // Silently return here to prevent spamming the console with: - error!("LOST surface, drop frame. Originally: \"The swap chain has been lost and needs to be recreated\""); - in_bad_state = true; - return; - } - Err(e) => { - error!("Dropped frame with error: {}", e); - return; - } - }; - let output_view = output_frame - .texture - .create_view(&wgpu::TextureViewDescriptor::default()); - - // Begin to draw the UI frame. - platform.begin_frame(); - - // Draw the demo application. - app.ui(&platform.context()); - - // End the UI frame. We could now handle the output and draw the UI with the backend. - let full_output = platform.end_frame(Some(&window)); - let paint_jobs = platform.context().tessellate(full_output.shapes); - - let mut encoder = device.create_command_encoder(&wgpu::CommandEncoderDescriptor { - label: Some("encoder"), - }); - - // Upload all resources for the GPU. - let screen_descriptor = ScreenDescriptor { - physical_width: surface_config.width, - physical_height: surface_config.height, - scale_factor: window.scale_factor() as f32 - }; - let tdelta: egui::TexturesDelta = full_output.textures_delta; - egui_rpass - .add_textures(&device, &queue, &tdelta) - .expect("add texture ok"); - egui_rpass.update_buffers(&device, &queue, &paint_jobs, &screen_descriptor); - - // Record all render passes. - egui_rpass - .execute( - &mut encoder, - &output_view, - &paint_jobs, - &screen_descriptor, - Some(wgpu::Color::BLACK), - ) - .unwrap_or_else(|e| panic!("Failed to render pass at {} line {} with error\n{:?}", file!(), line!(), e)); - // Submit the commands. - queue.submit(iter::once(encoder.finish())); - - // Redraw egui - output_frame.present(); - - egui_rpass - .remove_textures(tdelta) - .expect("remove texture ok"); - - // Support reactive on windows only, but not on linux. - // if _output.needs_repaint { - // *control_flow = ControlFlow::Poll; - // } else { - // *control_flow = ControlFlow::Wait; - // } - } - MainEventsCleared | UserEvent(Event::RequestRedraw) => { - window.request_redraw(); - } - WindowEvent { event, .. } => match event { - winit::event::WindowEvent::Resized(size) => { - // Resize with 0 width and height is used by winit to signal a minimize event on Windows. - // See: https://github.com/rust-windowing/winit/issues/208 - // This solves an issue where the app would panic when minimizing on Windows. - if size.width > 0 && size.height > 0 { - surface_config.width = size.width; - surface_config.height = size.height; - surface.configure(&device, &surface_config); - } - } - winit::event::WindowEvent::CloseRequested => { - *control_flow = ControlFlow::Exit; - } - _ => {} - }, - Resumed => { - if in_bad_state { - //https://github.com/gfx-rs/wgpu/issues/2302 - warn!("WGPU new surface at {} line {}", file!(), line!()); - surface = unsafe { instance.create_surface(&window) }; - warn!("surface configure at {} line {}", file!(), line!()); - surface.configure(&device, &surface_config); - in_bad_state = false; - } - }, - Suspended => (), - _ => (), - } - }); -} - -/// Time of day as seconds since midnight. Used for clock in demo app. -pub fn seconds_since_midnight() -> f64 { - let time = chrono::Local::now().time(); - time.num_seconds_from_midnight() as f64 + 1e-9 * (time.nanosecond() as f64) -}