ira 0.3.0

use crate::{
	client::ClientId,
	packet::{CreateInstance, Packet, TrustedPacket},
	physics::{InstanceHandle, PhysicsState},
	server::{self, InstanceId},
	DrumExt, GpuDrum, Instance, InstanceBuilder,
};

#[cfg(feature = "client")]
use crate::render::RenderState;

use std::{
	collections::BTreeMap,
	fmt,
	sync::{atomic::AtomicU32, mpsc, Arc},
	time::{self, Duration},
};

use glam::Vec2;
use ira_drum::Drum;
use rapier3d::data::Arena;
use tracing::info;
#[cfg(feature = "client")]
use winit::{
	application::ApplicationHandler,
	error::EventLoopError,
	event::{DeviceEvent, KeyEvent, WindowEvent},
	event_loop::{ActiveEventLoop, ControlFlow, EventLoop},
	keyboard::{KeyCode, PhysicalKey},
	window::{CursorGrabMode, Fullscreen, Window, WindowAttributes, WindowId},
};

/// Implemented by the application to handle user input,
/// physics, and rendering.
///
/// For networked games, implement the [`Network`] trait as well.
#[allow(unused_variables)]
pub trait App<M = ()> {
	/// Connects to the server. This is only called on clients.
	#[must_use]
	fn connect() -> std::net::TcpStream {
		std::net::TcpStream::connect("127.0.0.1:12345").unwrap()
	}

	/// Creates a new listener for the server to receive connections.
	#[must_use]
	fn listen() -> std::net::TcpListener {
		std::net::TcpListener::bind("127.0.0.1:12345").unwrap()
	}

	/// Called when a remote player joins the game. This should return
	/// the model id, and a builder for the instance.
	fn create_player(ctx: &mut Context<M>) -> (u32, InstanceBuilder);

	/// Called when a packet is received from the server.
	fn on_packet(ctx: &mut Context<M>, packet: TrustedPacket<M>) {}
	/// Called once at the start of the program, right after the window
	/// is created but before anything else is done.
	fn on_init() -> Drum;
	/// Called once when everything has been created on the GPU.
	fn on_ready(ctx: &mut Context<M>) -> Self;
	/// Called once per frame, right before rendering. Note that this
	/// will not be called if the `render` feature is not enabled.
	fn on_update(&mut self, ctx: &mut Context<M>, delta: Duration) {}
	/// Called every 1/60th of a second. If queued at the same time as an update,
	/// this will always be called first.
	fn on_fixed_update(&mut self, ctx: &mut Context<M>) {}
}

/// A game instance.
///
/// [`A`] is the application type (that implements [`App`]).
/// [`M`] is the custom message that can be sent between the client and server.
pub struct Game<A, M = ()> {
	state: Option<(Context<M>, A)>,
}

#[derive(Debug)]
pub enum Error {
	/// An error occurred while running the event loop.
	#[cfg(feature = "client")]
	EventLoop(EventLoopError),
}

#[cfg(feature = "client")]
impl From<EventLoopError> for Error {
	fn from(e: EventLoopError) -> Self {
		Self::EventLoop(e)
	}
}

impl<A, M> Default for Game<A, M> {
	fn default() -> Self {
		Self { state: None }
	}
}

impl<A: App<M>, M> Game<A, M> {
	/// Runs the application.
	///
	/// This function will block the current thread until the application is closed.
	///
	/// # Errors
	///
	/// See [`winit::error::EventLoopError`] for errors.
	#[cfg(feature = "client")]
	pub fn run(mut self) -> Result<(), Error>
	where
		M: bitcode::Encode + bitcode::DecodeOwned + fmt::Debug + Send + 'static,
	{
		let event_loop = EventLoop::new()?;

		event_loop.set_control_flow(ControlFlow::Poll);
		event_loop.run_app(&mut self)?;

		Ok(())
	}

	/// Runs the application.
	///
	/// This function will block the current thread until the application is closed.
	///
	/// # Errors
	///
	/// See [`Error`] for errors.
	#[cfg(not(feature = "client"))]
	pub fn run(self) -> Result<(), Error>
	where
		M: bitcode::Encode + bitcode::DecodeOwned + fmt::Debug + Send + 'static,
	{
		use tracing::info;

		let drum = A::on_init();
		let mut ctx = pollster::block_on(Context::<M>::new::<A>(drum));
		let mut app = A::on_ready(&mut ctx);

		info!("starting render loop");

		loop {
			ctx.render(&mut app);
		}
	}
}

/// The game context, containing all game-related data.
pub struct Context<M = ()> {
	last_frame: time::Instant,
	last_physics: time::Instant,

	pub physics: PhysicsState,

	pub(crate) desired_fps: f32,

	#[cfg(feature = "client")]
	pub(crate) pressed_keys: Vec<KeyCode>,
	#[cfg(feature = "client")]
	pub(crate) just_pressed: Vec<KeyCode>,
	#[cfg(feature = "client")]
	pub(crate) mouse_delta: Vec2,

	pub(crate) handles: BTreeMap<InstanceId, InstanceHandle>,
	pub(crate) instance_ids: BTreeMap<InstanceHandle, InstanceId>,
	pub(crate) clients: BTreeMap<ClientId, InstanceId>,

	pub instances: Arena<Instance>,

	/// Used to send messages to the thread that communicates with the server.
	/// If the "server" feature is enabled, this will be directly to the server.
	pub(crate) packet_tx: mpsc::Sender<Packet<M>>,
	/// Used to receive messages from the thread that communicates with the server.
	/// If the "server" feature is enabled, this will be directly from the server.
	pub(crate) packet_rx: mpsc::Receiver<TrustedPacket<M>>,

	pub(crate) next_instance_id: Arc<AtomicU32>,
	pub client_id: Option<ClientId>,
	pub instance_id: Option<InstanceId>,

	pub drum: GpuDrum,
	#[cfg(feature = "client")]
	pub render: RenderState,
}

impl<M> Context<M> {
	async fn new<A: App<M>>(#[cfg(feature = "client")] window: Window, drum: Drum) -> Self
	where
		M: bitcode::Encode + bitcode::DecodeOwned + fmt::Debug + Send + 'static,
	{
		#[cfg(feature = "client")]
		let render = RenderState::new(window, &drum).await;
		let physics = PhysicsState::default();

		let (server_packet_tx, packet_rx) = mpsc::channel();
		let (packet_tx, server_packet_rx) = mpsc::channel();

		let next_instance_id = Arc::new(AtomicU32::new(0));

		let drum = drum.into_gpu(
			#[cfg(feature = "client")]
			&render.device,
			#[cfg(feature = "client")]
			&render.queue,
		);

		let mut ctx = Self {
			#[cfg(feature = "client")]
			render,
			drum,
			last_frame: time::Instant::now(),
			last_physics: time::Instant::now(),
			physics,

			desired_fps: 120.0,

			#[cfg(feature = "client")]
			pressed_keys: Vec::new(),
			#[cfg(feature = "client")]
			just_pressed: Vec::new(),
			#[cfg(feature = "client")]
			mouse_delta: Vec2::ZERO,

			handles: BTreeMap::new(),
			instance_ids: BTreeMap::new(),
			instances: Arena::new(),
			clients: BTreeMap::new(),

			packet_tx,
			packet_rx,

			next_instance_id: Arc::clone(&next_instance_id),
			client_id: None,
			instance_id: None,
		};

		std::thread::spawn({
			let (model_id, builder) = A::create_player(&mut ctx);

			move || {
				server::run::<A, _>(
					server_packet_tx,
					server_packet_rx,
					next_instance_id,
					CreateInstance::from_builder(&builder, model_id),
				);
			}
		});

		ctx
	}

	#[cfg(feature = "client")]
	pub fn pressed(&self, key: KeyCode) -> bool {
		self.pressed_keys.contains(&key)
	}

	#[cfg(feature = "client")]
	pub fn just_pressed(&self, key: KeyCode) -> bool {
		self.just_pressed.contains(&key)
	}

	#[cfg(feature = "client")]
	pub fn mouse_delta(&self) -> Vec2 {
		self.mouse_delta
	}
}

impl<M> Context<M> {
	fn on_packet<A: App<M>>(ctx: &mut Context<M>, packet: TrustedPacket<M>) {
		let client_id = packet.client_id;

		match packet.inner {
			Packet::Custom(..) => {}
			Packet::CreateClient { instance_id } => {
				let (model_id, instance) = A::create_player(ctx);
				let instance = ctx.add_instance_local(model_id, instance);

				ctx.handles.insert(instance_id, instance);
				ctx.instance_ids.insert(instance, instance_id);
				ctx.clients.insert(client_id, instance_id);
			}
			Packet::DeleteClient => {
				let Some(instance_id) = ctx.clients.remove(&client_id) else {
					return;
				};

				ctx.remove_instance_local(instance_id);
			}
			Packet::CreateInstance { ref options, id } => {
				info!("creating instance {id:?} with options {options:?}");

				if Some(id) == ctx.instance_id {
					return;
				}

				let instance = ctx.add_instance_local(options.model_id, options.to_builder());

				ctx.handles.insert(id, instance);
				ctx.instance_ids.insert(instance, id);
			}
			Packet::DeleteInstance { id } => {
				ctx.remove_instance_local(id);
			}
			Packet::UpdateInstance { id, ref delta } => {
				let Some(&mut instance) = ctx.handles.get_mut(&id) else {
					return;
				};

				instance.update(ctx, |i, p| {
					delta.apply(p, i);
				});
			}
			Packet::Connected { instance_id } => {
				ctx.client_id = Some(client_id);
				ctx.instance_id = Some(instance_id);
			}
		}

		A::on_packet(ctx, packet);
	}

	fn render<A: App<M>>(
		&mut self,
		app: &mut A,
		#[cfg(feature = "client")] event_loop: &ActiveEventLoop,
	) {
		std::hint::spin_loop();

		while let Ok(packet) = self.packet_rx.try_recv() {
			Self::on_packet::<A>(self, packet);
		}

		let delta = self.last_physics.elapsed();

		// physics 60fps
		if delta.as_secs_f32() >= 1.0 / 60.0 {
			self.last_physics = time::Instant::now();
			self.physics_update();
			app.on_fixed_update(self);
		}

		#[cfg(feature = "client")]
		{
			let delta = self.last_frame.elapsed();

			if delta.as_secs_f32() < 1.0 / self.desired_fps {
				return;
			}

			self.last_frame = time::Instant::now();

			app.on_update(self, delta);
			#[cfg(feature = "client")]
			self.render.camera.update_view_proj(&self.render.queue);

			self.just_pressed.clear();
			self.mouse_delta = Vec2::ZERO;

			for model in &mut self.drum.models {
				model.update_instance_buffer(&self.render.device, &self.render.queue);
			}

			match self.render.render_frame(&self.drum) {
				Ok(..) => {}
				Err(wgpu::SurfaceError::Lost | wgpu::SurfaceError::Outdated) => {
					self.render.resize(self.render.window.inner_size());
				}
				Err(wgpu::SurfaceError::OutOfMemory) => event_loop.exit(),
				Err(wgpu::SurfaceError::Timeout) => log::warn!("surface timeout"),
			}
		}
	}
}

#[cfg(feature = "client")]
impl<A: App<M>, M> ApplicationHandler for Game<A, M>
where
	M: bitcode::Encode + bitcode::DecodeOwned + fmt::Debug + Send + 'static,
{
	fn resumed(&mut self, event_loop: &ActiveEventLoop) {
		let window = event_loop
			.create_window(WindowAttributes::default().with_title(
				#[cfg(feature = "server")]
				"Server",
				#[cfg(not(feature = "server"))]
				"Client",
			))
			.unwrap();

		let _ = window.set_cursor_grab(CursorGrabMode::Locked);
		window.set_cursor_visible(false);

		let drum = A::on_init();
		let mut ctx = pollster::block_on(Context::<M>::new::<A>(window, drum));
		let app = A::on_ready(&mut ctx);

		self.state = Some((ctx, app));
	}

	fn device_event(
		&mut self,
		_event_loop: &ActiveEventLoop,
		_device_id: winit::event::DeviceId,
		event: DeviceEvent,
	) {
		let Some((ctx, _)) = self.state.as_mut() else {
			return;
		};

		if let DeviceEvent::MouseMotion { delta } = event {
			ctx.mouse_delta += Vec2::from((delta.0 as f32, delta.1 as f32));
		}
	}

	fn about_to_wait(&mut self, event_loop: &ActiveEventLoop) {
		let Some((ctx, app)) = self.state.as_mut() else {
			return;
		};

		ctx.render(app, event_loop);
	}

	fn window_event(
		&mut self,
		event_loop: &ActiveEventLoop,
		window_id: WindowId,
		event: WindowEvent,
	) {
		let Some((ctx, app)) = self.state.as_mut() else {
			return;
		};

		if window_id != ctx.render.window.id() {
			return;
		}

		match event {
			WindowEvent::Resized(size) => {
				ctx.render.resize(size);
			}
			WindowEvent::RedrawRequested => {
				ctx.render(app, event_loop);
			}
			WindowEvent::CloseRequested => {
				event_loop.exit();
			}
			WindowEvent::KeyboardInput {
				event:
					KeyEvent {
						state,
						physical_key: PhysicalKey::Code(key),
						..
					},
				..
			} => {
				if state.is_pressed() {
					if !ctx.pressed_keys.contains(&key) {
						ctx.pressed_keys.push(key);
					}

					match key {
						KeyCode::F11 if ctx.render.window.fullscreen().is_none() => {
							ctx.render
								.window
								.set_fullscreen(Some(Fullscreen::Borderless(None)));
						}
						KeyCode::F11 => {
							ctx.render.window.set_fullscreen(None);
						}
						_ => {}
					}
				} else if let Some(index) = ctx.pressed_keys.iter().position(|&k| k == key) {
					ctx.pressed_keys.swap_remove(index);
				}
			}
			_ => {}
		}
	}
}