Build evaluation loop

Author: TrueDoctor

desktop/src/app.rs

@@ -73,23 +73,6 @@ impl ApplicationHandler<CustomEvent> for WinitApp {
 		self.cef_context.work();
 
 		let (_has_run, texture) = futures::executor::block_on(graphite_editor::node_graph_executor::run_node_graph());
-		if _has_run {
-			let mut responses = VecDeque::new();
-			let err = self.editor.poll_node_graph_evaluation(&mut responses);
-			if let Err(e) = err {
-				tracing::error!("Error poling node graph: {}", e);
-			}
-			let frontend_messages = responses
-				.into_iter()
-				.flat_map(|response| if let Message::Frontend(frontend) = response { Some(frontend) } else { None })
-				.collect();
-			self.send_messages_to_editor(frontend_messages);
-		}
-		if let Some(texture) = texture
-			&& let Some(graphics_state) = &mut self.graphics_state
-		{
-			graphics_state.bind_viewport_texture(texture.texture.as_ref());
-		}
 
 		event_loop.set_control_flow(ControlFlow::WaitUntil(wait_until));
 	}
@@ -225,6 +208,24 @@ impl ApplicationHandler<CustomEvent> for WinitApp {
 				}
 				self.dispatch_message(message);
 			}
+			CustomEvent::NodeGraphRan { texture } => {
+				if let Some(texture) = texture
+					&& let Some(graphics_state) = &mut self.graphics_state
+				{
+					graphics_state.bind_viewport_texture(texture.texture.as_ref());
+				}
+				let mut responses = VecDeque::new();
+				let err = self.editor.poll_node_graph_evaluation(&mut responses);
+				if let Err(e) = err {
+					if e != "No active document" {
+						tracing::error!("Error poling node graph: {}", e);
+					}
+				}
+
+				for message in responses {
+					self.dispatch_message(message);
+				}
+			}
 		}
 	}
 

desktop/src/main.rs

@@ -1,6 +1,6 @@
-use std::fmt::Debug;
 use std::process::exit;
 use std::time::Instant;
+use std::{fmt::Debug, time::Duration};
 
 use graphite_editor::messages::prelude::Message;
 use tracing_subscriber::EnvFilter;
@@ -22,6 +22,7 @@ pub(crate) enum CustomEvent {
 	UiUpdate(wgpu::Texture),
 	ScheduleBrowserWork(Instant),
 	MessageReceived { message: Message },
+	NodeGraphRan { texture: Option<graphene_application_io::ImageTexture> },
 }
 
 fn main() {
@@ -55,6 +56,21 @@ fn main() {
 
 	tracing::info!("Cef initialized successfully");
 
+	let rendering_loop_proxy = event_loop.create_proxy();
+	let target_fps = 60;
+	std::thread::spawn(move || {
+		loop {
+			let last_render = Instant::now();
+			let (has_run, texture) = futures::executor::block_on(graphite_editor::node_graph_executor::run_node_graph());
+			if has_run {
+				rendering_loop_proxy.send_event(CustomEvent::NodeGraphRan { texture });
+			}
+			let frame_time = Duration::from_secs_f32((target_fps as f32).recip());
+			let sleep = last_render + frame_time - Instant::now();
+			std::thread::sleep(sleep);
+		}
+	});
+
 	let mut winit_app = WinitApp::new(cef_context, window_size_sender, wgpu_context);
 
 	event_loop.run_app(&mut winit_app).unwrap();