forked from StrafesNET/roblox-bot-player
paste strafe client code
This commit is contained in:
@@ -0,0 +1,68 @@
|
|||||||
|
use crate::window::Instruction;
|
||||||
|
use strafesnet_common::integer;
|
||||||
|
use strafesnet_common::instruction::TimedInstruction;
|
||||||
|
use strafesnet_common::session::Time as SessionTime;
|
||||||
|
|
||||||
|
pub struct App<'a>{
|
||||||
|
root_time:std::time::Instant,
|
||||||
|
window_thread:crate::compat_worker::QNWorker<'a,TimedInstruction<Instruction,SessionTime>>,
|
||||||
|
}
|
||||||
|
impl<'a> App<'a>{
|
||||||
|
pub fn new(
|
||||||
|
root_time:std::time::Instant,
|
||||||
|
window_thread:crate::compat_worker::QNWorker<'a,TimedInstruction<Instruction,SessionTime>>,
|
||||||
|
)->App<'a>{
|
||||||
|
Self{
|
||||||
|
root_time,
|
||||||
|
window_thread,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
fn send_timed_instruction(&mut self,instruction:Instruction){
|
||||||
|
let time=integer::Time::from_nanos(self.root_time.elapsed().as_nanos() as i64);
|
||||||
|
self.window_thread.send(TimedInstruction{time,instruction}).unwrap();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
impl winit::application::ApplicationHandler for App<'_>{
|
||||||
|
fn resumed(&mut self,_event_loop:&winit::event_loop::ActiveEventLoop){
|
||||||
|
//
|
||||||
|
}
|
||||||
|
|
||||||
|
fn window_event(
|
||||||
|
&mut self,
|
||||||
|
event_loop:&winit::event_loop::ActiveEventLoop,
|
||||||
|
_window_id:winit::window::WindowId,
|
||||||
|
event:winit::event::WindowEvent,
|
||||||
|
){
|
||||||
|
match event{
|
||||||
|
winit::event::WindowEvent::KeyboardInput{
|
||||||
|
event:winit::event::KeyEvent{
|
||||||
|
logical_key:winit::keyboard::Key::Named(winit::keyboard::NamedKey::Escape),
|
||||||
|
state:winit::event::ElementState::Pressed,
|
||||||
|
..
|
||||||
|
},
|
||||||
|
..
|
||||||
|
}
|
||||||
|
|winit::event::WindowEvent::CloseRequested=>{
|
||||||
|
event_loop.exit();
|
||||||
|
},
|
||||||
|
_=>(),
|
||||||
|
}
|
||||||
|
self.send_timed_instruction(Instruction::WindowEvent(event));
|
||||||
|
}
|
||||||
|
|
||||||
|
fn device_event(
|
||||||
|
&mut self,
|
||||||
|
_event_loop:&winit::event_loop::ActiveEventLoop,
|
||||||
|
_device_id:winit::event::DeviceId,
|
||||||
|
event:winit::event::DeviceEvent,
|
||||||
|
){
|
||||||
|
self.send_timed_instruction(Instruction::DeviceEvent(event));
|
||||||
|
}
|
||||||
|
|
||||||
|
fn about_to_wait(
|
||||||
|
&mut self,
|
||||||
|
_event_loop:&winit::event_loop::ActiveEventLoop
|
||||||
|
){
|
||||||
|
self.send_timed_instruction(Instruction::WindowEvent(winit::event::WindowEvent::RedrawRequested));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -0,0 +1,116 @@
|
|||||||
|
use std::io::Read;
|
||||||
|
|
||||||
|
#[cfg(any(feature="roblox",feature="source"))]
|
||||||
|
use strafesnet_deferred_loader::deferred_loader::LoadFailureMode;
|
||||||
|
|
||||||
|
#[expect(dead_code)]
|
||||||
|
#[derive(Debug)]
|
||||||
|
pub enum ReadError{
|
||||||
|
#[cfg(feature="roblox")]
|
||||||
|
Roblox(strafesnet_rbx_loader::ReadError),
|
||||||
|
#[cfg(feature="source")]
|
||||||
|
Source(strafesnet_bsp_loader::ReadError),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
StrafesNET(strafesnet_snf::Error),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
StrafesNETMap(strafesnet_snf::map::Error),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
StrafesNETBot(strafesnet_snf::bot::Error),
|
||||||
|
Io(std::io::Error),
|
||||||
|
UnknownFileFormat,
|
||||||
|
}
|
||||||
|
impl std::fmt::Display for ReadError{
|
||||||
|
fn fmt(&self,f:&mut std::fmt::Formatter<'_>)->std::fmt::Result{
|
||||||
|
write!(f,"{self:?}")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
impl std::error::Error for ReadError{}
|
||||||
|
|
||||||
|
pub enum ReadFormat{
|
||||||
|
#[cfg(feature="roblox")]
|
||||||
|
Roblox(strafesnet_rbx_loader::Model),
|
||||||
|
#[cfg(feature="source")]
|
||||||
|
Source(strafesnet_bsp_loader::Bsp),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
SNFM(strafesnet_common::map::CompleteMap),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
SNFB(strafesnet_snf::bot::Segment),
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn read<R:Read+std::io::Seek>(input:R)->Result<ReadFormat,ReadError>{
|
||||||
|
let mut buf=std::io::BufReader::new(input);
|
||||||
|
let peek=std::io::BufRead::fill_buf(&mut buf).map_err(ReadError::Io)?[0..4].to_owned();
|
||||||
|
// reading the entire file is way faster than round tripping the disk constantly
|
||||||
|
let mut entire_file=Vec::new();
|
||||||
|
buf.read_to_end(&mut entire_file).map_err(ReadError::Io)?;
|
||||||
|
let cursor=std::io::Cursor::new(entire_file);
|
||||||
|
match peek.as_slice(){
|
||||||
|
#[cfg(feature="roblox")]
|
||||||
|
b"<rob"=>Ok(ReadFormat::Roblox(strafesnet_rbx_loader::read(cursor).map_err(ReadError::Roblox)?)),
|
||||||
|
#[cfg(feature="source")]
|
||||||
|
b"VBSP"=>Ok(ReadFormat::Source(strafesnet_bsp_loader::read(cursor).map_err(ReadError::Source)?)),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
b"SNFM"=>Ok(ReadFormat::SNFM(
|
||||||
|
strafesnet_snf::read_map(cursor).map_err(ReadError::StrafesNET)?
|
||||||
|
.into_complete_map().map_err(ReadError::StrafesNETMap)?
|
||||||
|
)),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
b"SNFB"=>Ok(ReadFormat::SNFB(
|
||||||
|
strafesnet_snf::read_bot(cursor).map_err(ReadError::StrafesNET)?
|
||||||
|
.read_all().map_err(ReadError::StrafesNETBot)?
|
||||||
|
)),
|
||||||
|
_=>Err(ReadError::UnknownFileFormat),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[expect(dead_code)]
|
||||||
|
#[derive(Debug)]
|
||||||
|
pub enum LoadError{
|
||||||
|
ReadError(ReadError),
|
||||||
|
File(std::io::Error),
|
||||||
|
#[cfg(feature="roblox")]
|
||||||
|
LoadRoblox(strafesnet_rbx_loader::LoadError),
|
||||||
|
#[cfg(feature="source")]
|
||||||
|
LoadSource(strafesnet_bsp_loader::LoadError),
|
||||||
|
}
|
||||||
|
impl std::fmt::Display for LoadError{
|
||||||
|
fn fmt(&self,f:&mut std::fmt::Formatter<'_>)->std::fmt::Result{
|
||||||
|
write!(f,"{self:?}")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
impl std::error::Error for LoadError{}
|
||||||
|
|
||||||
|
pub enum LoadFormat{
|
||||||
|
#[cfg(any(feature="snf",feature="roblox",feature="source"))]
|
||||||
|
Map(strafesnet_common::map::CompleteMap),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
Bot(strafesnet_snf::bot::Segment),
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn load<P:AsRef<std::path::Path>>(path:P)->Result<LoadFormat,LoadError>{
|
||||||
|
//blocking because it's simpler...
|
||||||
|
let file=std::fs::File::open(path).map_err(LoadError::File)?;
|
||||||
|
match read(file).map_err(LoadError::ReadError)?{
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
ReadFormat::SNFB(bot)=>Ok(LoadFormat::Bot(bot)),
|
||||||
|
#[cfg(feature="snf")]
|
||||||
|
ReadFormat::SNFM(map)=>Ok(LoadFormat::Map(map)),
|
||||||
|
#[cfg(feature="roblox")]
|
||||||
|
ReadFormat::Roblox(model)=>{
|
||||||
|
let mut place=strafesnet_rbx_loader::Place::from(model);
|
||||||
|
let script_errors=place.run_scripts().unwrap();
|
||||||
|
for error in script_errors{
|
||||||
|
println!("Script error: {error}");
|
||||||
|
}
|
||||||
|
let (map,errors)=place.to_snf(LoadFailureMode::DefaultToNone).map_err(LoadError::LoadRoblox)?;
|
||||||
|
if errors.count()!=0{
|
||||||
|
print!("Errors encountered while loading the map:\n{}",errors);
|
||||||
|
}
|
||||||
|
Ok(LoadFormat::Map(map))
|
||||||
|
},
|
||||||
|
#[cfg(feature="source")]
|
||||||
|
ReadFormat::Source(bsp)=>Ok(LoadFormat::Map(
|
||||||
|
bsp.to_snf(LoadFailureMode::DefaultToNone,&[]).map_err(LoadError::LoadSource)?
|
||||||
|
)),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -3,4 +3,9 @@ mod file;
|
|||||||
mod setup;
|
mod setup;
|
||||||
mod window;
|
mod window;
|
||||||
|
|
||||||
fn main() {}
|
|
||||||
|
const TITLE:&'static str=concat!("Roblox Bot Player v",env!("CARGO_PKG_VERSION"));
|
||||||
|
|
||||||
|
fn main(){
|
||||||
|
setup::setup_and_start(TITLE);
|
||||||
|
}
|
||||||
|
|||||||
@@ -0,0 +1,199 @@
|
|||||||
|
fn optional_features()->wgpu::Features{
|
||||||
|
wgpu::Features::TEXTURE_COMPRESSION_ASTC
|
||||||
|
|wgpu::Features::TEXTURE_COMPRESSION_ETC2
|
||||||
|
}
|
||||||
|
fn required_features()->wgpu::Features{
|
||||||
|
wgpu::Features::TEXTURE_COMPRESSION_BC
|
||||||
|
}
|
||||||
|
fn required_downlevel_capabilities()->wgpu::DownlevelCapabilities{
|
||||||
|
wgpu::DownlevelCapabilities{
|
||||||
|
flags:wgpu::DownlevelFlags::empty(),
|
||||||
|
shader_model:wgpu::ShaderModel::Sm5,
|
||||||
|
..wgpu::DownlevelCapabilities::default()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
struct SetupContextPartial1{
|
||||||
|
backends:wgpu::Backends,
|
||||||
|
instance:wgpu::Instance,
|
||||||
|
}
|
||||||
|
fn create_window(title:&str,event_loop:&winit::event_loop::EventLoop<()>)->Result<winit::window::Window,winit::error::OsError>{
|
||||||
|
let mut attr=winit::window::WindowAttributes::default();
|
||||||
|
attr=attr.with_title(title);
|
||||||
|
event_loop.create_window(attr)
|
||||||
|
}
|
||||||
|
fn create_instance()->SetupContextPartial1{
|
||||||
|
let backends=wgpu::Backends::from_env().unwrap_or_default();
|
||||||
|
SetupContextPartial1{
|
||||||
|
backends,
|
||||||
|
instance:Default::default(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
impl SetupContextPartial1{
|
||||||
|
fn create_surface<'a>(self,window:&'a winit::window::Window)->Result<SetupContextPartial2<'a>,wgpu::CreateSurfaceError>{
|
||||||
|
Ok(SetupContextPartial2{
|
||||||
|
backends:self.backends,
|
||||||
|
surface:self.instance.create_surface(window)?,
|
||||||
|
instance:self.instance,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
struct SetupContextPartial2<'a>{
|
||||||
|
backends:wgpu::Backends,
|
||||||
|
instance:wgpu::Instance,
|
||||||
|
surface:wgpu::Surface<'a>,
|
||||||
|
}
|
||||||
|
impl<'a> SetupContextPartial2<'a>{
|
||||||
|
fn pick_adapter(self)->SetupContextPartial3<'a>{
|
||||||
|
//TODO: prefer adapter that implements optional features
|
||||||
|
//let optional_features=optional_features();
|
||||||
|
let required_features=required_features();
|
||||||
|
|
||||||
|
//no helper function smh gotta write it myself
|
||||||
|
let adapters=pollster::block_on(self.instance.enumerate_adapters(self.backends));
|
||||||
|
|
||||||
|
let chosen_adapter=adapters.into_iter()
|
||||||
|
// reverse because we want to select adapters that appear first in ties,
|
||||||
|
// and max_by_key selects the last equal element in the iterator.
|
||||||
|
.rev()
|
||||||
|
.filter(|adapter|
|
||||||
|
adapter.is_surface_supported(&self.surface)
|
||||||
|
&&adapter.features().contains(required_features)
|
||||||
|
)
|
||||||
|
.max_by_key(|adapter|match adapter.get_info().device_type{
|
||||||
|
wgpu::DeviceType::IntegratedGpu=>3,
|
||||||
|
wgpu::DeviceType::DiscreteGpu=>4,
|
||||||
|
wgpu::DeviceType::VirtualGpu=>2,
|
||||||
|
wgpu::DeviceType::Other|wgpu::DeviceType::Cpu=>1,
|
||||||
|
});
|
||||||
|
|
||||||
|
let adapter=chosen_adapter.expect("No suitable GPU adapters found on the system!");
|
||||||
|
|
||||||
|
let adapter_info=adapter.get_info();
|
||||||
|
println!("Using {} ({:?})", adapter_info.name, adapter_info.backend);
|
||||||
|
|
||||||
|
let required_downlevel_capabilities=required_downlevel_capabilities();
|
||||||
|
let downlevel_capabilities=adapter.get_downlevel_capabilities();
|
||||||
|
assert!(
|
||||||
|
downlevel_capabilities.shader_model >= required_downlevel_capabilities.shader_model,
|
||||||
|
"Adapter does not support the minimum shader model required to run this example: {:?}",
|
||||||
|
required_downlevel_capabilities.shader_model
|
||||||
|
);
|
||||||
|
assert!(
|
||||||
|
downlevel_capabilities
|
||||||
|
.flags
|
||||||
|
.contains(required_downlevel_capabilities.flags),
|
||||||
|
"Adapter does not support the downlevel capabilities required to run this example: {:?}",
|
||||||
|
required_downlevel_capabilities.flags - downlevel_capabilities.flags
|
||||||
|
);
|
||||||
|
SetupContextPartial3{
|
||||||
|
surface:self.surface,
|
||||||
|
adapter,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
struct SetupContextPartial3<'a>{
|
||||||
|
surface:wgpu::Surface<'a>,
|
||||||
|
adapter:wgpu::Adapter,
|
||||||
|
}
|
||||||
|
impl<'a> SetupContextPartial3<'a>{
|
||||||
|
fn request_device(self)->SetupContextPartial4<'a>{
|
||||||
|
let optional_features=optional_features();
|
||||||
|
let required_features=required_features();
|
||||||
|
|
||||||
|
// Make sure we use the texture resolution limits from the adapter, so we can support images the size of the surface.
|
||||||
|
let needed_limits=strafesnet_graphics::graphics::required_limits().using_resolution(self.adapter.limits());
|
||||||
|
|
||||||
|
let (device, queue)=pollster::block_on(self.adapter
|
||||||
|
.request_device(
|
||||||
|
&wgpu::DeviceDescriptor{
|
||||||
|
label:None,
|
||||||
|
required_features:(optional_features&self.adapter.features())|required_features,
|
||||||
|
required_limits:needed_limits,
|
||||||
|
memory_hints:wgpu::MemoryHints::Performance,
|
||||||
|
trace:wgpu::Trace::Off,
|
||||||
|
experimental_features:wgpu::ExperimentalFeatures::disabled(),
|
||||||
|
},
|
||||||
|
))
|
||||||
|
.expect("Unable to find a suitable GPU adapter!");
|
||||||
|
|
||||||
|
SetupContextPartial4{
|
||||||
|
surface:self.surface,
|
||||||
|
adapter:self.adapter,
|
||||||
|
device,
|
||||||
|
queue,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
struct SetupContextPartial4<'a>{
|
||||||
|
surface:wgpu::Surface<'a>,
|
||||||
|
adapter:wgpu::Adapter,
|
||||||
|
device:wgpu::Device,
|
||||||
|
queue:wgpu::Queue,
|
||||||
|
}
|
||||||
|
impl<'a> SetupContextPartial4<'a>{
|
||||||
|
fn configure_surface(self,size:&'a winit::dpi::PhysicalSize<u32>)->SetupContext<'a>{
|
||||||
|
let mut config=self.surface
|
||||||
|
.get_default_config(&self.adapter, size.width, size.height)
|
||||||
|
.expect("Surface isn't supported by the adapter.");
|
||||||
|
let surface_view_format=config.format.add_srgb_suffix();
|
||||||
|
config.view_formats.push(surface_view_format);
|
||||||
|
config.present_mode=wgpu::PresentMode::AutoNoVsync;
|
||||||
|
self.surface.configure(&self.device, &config);
|
||||||
|
|
||||||
|
SetupContext{
|
||||||
|
surface:self.surface,
|
||||||
|
device:self.device,
|
||||||
|
queue:self.queue,
|
||||||
|
config,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
pub struct SetupContext<'a>{
|
||||||
|
pub surface:wgpu::Surface<'a>,
|
||||||
|
pub device:wgpu::Device,
|
||||||
|
pub queue:wgpu::Queue,
|
||||||
|
pub config:wgpu::SurfaceConfiguration,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn setup_and_start(title:&str){
|
||||||
|
let event_loop=winit::event_loop::EventLoop::new().unwrap();
|
||||||
|
|
||||||
|
println!("Initializing the surface...");
|
||||||
|
|
||||||
|
let partial_1=create_instance();
|
||||||
|
|
||||||
|
let window=create_window(title,&event_loop).unwrap();
|
||||||
|
|
||||||
|
let partial_2=partial_1.create_surface(&window).unwrap();
|
||||||
|
|
||||||
|
let partial_3=partial_2.pick_adapter();
|
||||||
|
|
||||||
|
let partial_4=partial_3.request_device();
|
||||||
|
|
||||||
|
let size=window.inner_size();
|
||||||
|
|
||||||
|
let setup_context=partial_4.configure_surface(&size);
|
||||||
|
|
||||||
|
//dedicated thread to ping request redraw back and resize the window doesn't seem logical
|
||||||
|
|
||||||
|
//the thread that spawns the physics thread
|
||||||
|
let mut window_thread=crate::window::worker(
|
||||||
|
&window,
|
||||||
|
setup_context,
|
||||||
|
);
|
||||||
|
|
||||||
|
for arg in std::env::args().skip(1){
|
||||||
|
window_thread.send(strafesnet_common::instruction::TimedInstruction{
|
||||||
|
time:strafesnet_common::integer::Time::ZERO,
|
||||||
|
instruction:crate::window::Instruction::WindowEvent(winit::event::WindowEvent::DroppedFile(arg.into())),
|
||||||
|
}).unwrap();
|
||||||
|
};
|
||||||
|
|
||||||
|
println!("Entering event loop...");
|
||||||
|
let mut app=crate::app::App::new(
|
||||||
|
std::time::Instant::now(),
|
||||||
|
window_thread
|
||||||
|
);
|
||||||
|
event_loop.run_app(&mut app).unwrap();
|
||||||
|
}
|
||||||
|
|||||||
@@ -0,0 +1,284 @@
|
|||||||
|
use strafesnet_common::instruction::TimedInstruction;
|
||||||
|
use strafesnet_common::session::Time as SessionTime;
|
||||||
|
use strafesnet_common::physics::{MiscInstruction,SetControlInstruction};
|
||||||
|
use crate::file::LoadFormat;
|
||||||
|
use crate::physics_worker::Instruction as PhysicsWorkerInstruction;
|
||||||
|
use strafesnet_session::session::{self,SessionInputInstruction,SessionControlInstruction,SessionPlaybackInstruction};
|
||||||
|
use strafesnet_settings::directories::Directories;
|
||||||
|
|
||||||
|
pub enum Instruction{
|
||||||
|
WindowEvent(winit::event::WindowEvent),
|
||||||
|
DeviceEvent(winit::event::DeviceEvent),
|
||||||
|
}
|
||||||
|
|
||||||
|
//holds thread handles to dispatch to
|
||||||
|
struct WindowContext<'a>{
|
||||||
|
manual_mouse_lock:bool,
|
||||||
|
mouse_pos:glam::DVec2,
|
||||||
|
simulation_paused:bool,
|
||||||
|
screen_size:glam::UVec2,
|
||||||
|
window:&'a winit::window::Window,
|
||||||
|
physics_thread:crate::compat_worker::QNWorker<'a,TimedInstruction<PhysicsWorkerInstruction,SessionTime>>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl WindowContext<'_>{
|
||||||
|
fn get_middle_of_screen(&self)->winit::dpi::PhysicalPosition<u32>{
|
||||||
|
winit::dpi::PhysicalPosition::new(self.screen_size.x/2,self.screen_size.y/2)
|
||||||
|
}
|
||||||
|
fn free_mouse(&mut self){
|
||||||
|
self.manual_mouse_lock=false;
|
||||||
|
match self.window.set_cursor_position(self.get_middle_of_screen()){
|
||||||
|
Ok(())=>(),
|
||||||
|
Err(e)=>println!("Could not set cursor position: {:?}",e),
|
||||||
|
}
|
||||||
|
match self.window.set_cursor_grab(winit::window::CursorGrabMode::None){
|
||||||
|
Ok(())=>(),
|
||||||
|
Err(e)=>println!("Could not release cursor: {:?}",e),
|
||||||
|
}
|
||||||
|
self.window.set_cursor_visible(true);
|
||||||
|
}
|
||||||
|
fn lock_mouse(&mut self){
|
||||||
|
//if cursor is outside window don't lock but apparently there's no get pos function
|
||||||
|
//let pos=window.get_cursor_pos();
|
||||||
|
match self.window.set_cursor_grab(winit::window::CursorGrabMode::Locked){
|
||||||
|
Ok(())=>(),
|
||||||
|
Err(_)=>{
|
||||||
|
match self.window.set_cursor_grab(winit::window::CursorGrabMode::Confined){
|
||||||
|
Ok(())=>(),
|
||||||
|
Err(e)=>{
|
||||||
|
self.manual_mouse_lock=true;
|
||||||
|
println!("Could not confine cursor: {:?}",e)
|
||||||
|
},
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
self.window.set_cursor_visible(false);
|
||||||
|
}
|
||||||
|
fn window_event(&mut self,time:SessionTime,event:winit::event::WindowEvent){
|
||||||
|
match event{
|
||||||
|
winit::event::WindowEvent::DroppedFile(path)=>{
|
||||||
|
match crate::file::load(path.as_path()){
|
||||||
|
Ok(LoadFormat::Map(map))=>self.physics_thread.send(TimedInstruction{time,instruction:PhysicsWorkerInstruction::ChangeMap(map)}).unwrap(),
|
||||||
|
Ok(LoadFormat::Bot(bot))=>self.physics_thread.send(TimedInstruction{time,instruction:PhysicsWorkerInstruction::LoadReplay(bot)}).unwrap(),
|
||||||
|
Err(e)=>println!("Failed to load file: {e}"),
|
||||||
|
}
|
||||||
|
},
|
||||||
|
winit::event::WindowEvent::Focused(state)=>{
|
||||||
|
// don't unpause if manually paused
|
||||||
|
if self.simulation_paused{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
//pause unpause
|
||||||
|
self.physics_thread.send(TimedInstruction{
|
||||||
|
time,
|
||||||
|
instruction:PhysicsWorkerInstruction::SessionControl(SessionControlInstruction::SetPaused(!state)),
|
||||||
|
}).unwrap();
|
||||||
|
//recalculate pressed keys on focus
|
||||||
|
},
|
||||||
|
winit::event::WindowEvent::KeyboardInput{
|
||||||
|
event:winit::event::KeyEvent{state,logical_key,repeat:false,..},
|
||||||
|
..
|
||||||
|
}=>{
|
||||||
|
match (logical_key,state){
|
||||||
|
(winit::keyboard::Key::Named(winit::keyboard::NamedKey::Tab),winit::event::ElementState::Pressed)=>self.free_mouse(),
|
||||||
|
(winit::keyboard::Key::Named(winit::keyboard::NamedKey::Tab),winit::event::ElementState::Released)=>self.lock_mouse(),
|
||||||
|
(winit::keyboard::Key::Named(winit::keyboard::NamedKey::F11),winit::event::ElementState::Pressed)=>{
|
||||||
|
if self.window.fullscreen().is_some(){
|
||||||
|
self.window.set_fullscreen(None);
|
||||||
|
}else{
|
||||||
|
self.window.set_fullscreen(Some(winit::window::Fullscreen::Borderless(None)));
|
||||||
|
}
|
||||||
|
},
|
||||||
|
(winit::keyboard::Key::Named(winit::keyboard::NamedKey::Escape),winit::event::ElementState::Pressed)=>{
|
||||||
|
self.manual_mouse_lock=false;
|
||||||
|
match self.window.set_cursor_grab(winit::window::CursorGrabMode::None){
|
||||||
|
Ok(())=>(),
|
||||||
|
Err(e)=>println!("Could not release cursor: {:?}",e),
|
||||||
|
}
|
||||||
|
self.window.set_cursor_visible(true);
|
||||||
|
},
|
||||||
|
(keycode,state)=>{
|
||||||
|
let s=state.is_pressed();
|
||||||
|
|
||||||
|
// internal variants for this scope
|
||||||
|
enum SessionInstructionSubset{
|
||||||
|
Input(SessionInputInstruction),
|
||||||
|
Control(SessionControlInstruction),
|
||||||
|
Playback(SessionPlaybackInstruction),
|
||||||
|
}
|
||||||
|
macro_rules! input_ctrl{
|
||||||
|
($variant:ident,$state:expr)=>{
|
||||||
|
Some(SessionInstructionSubset::Input(SessionInputInstruction::SetControl(SetControlInstruction::$variant($state))))
|
||||||
|
};
|
||||||
|
}
|
||||||
|
macro_rules! input_misc{
|
||||||
|
($variant:ident,$state:expr)=>{
|
||||||
|
s.then_some(SessionInstructionSubset::Input(SessionInputInstruction::Misc(MiscInstruction::$variant)))
|
||||||
|
};
|
||||||
|
}
|
||||||
|
macro_rules! session_ctrl{
|
||||||
|
($variant:ident,$state:expr)=>{
|
||||||
|
s.then_some(SessionInstructionSubset::Control(SessionControlInstruction::$variant))
|
||||||
|
};
|
||||||
|
}
|
||||||
|
macro_rules! session_playback{
|
||||||
|
($variant:ident,$state:expr)=>{
|
||||||
|
s.then_some(SessionInstructionSubset::Playback(SessionPlaybackInstruction::$variant))
|
||||||
|
};
|
||||||
|
}
|
||||||
|
impl From<SessionInstructionSubset> for PhysicsWorkerInstruction{
|
||||||
|
fn from(value:SessionInstructionSubset)->Self{
|
||||||
|
match value{
|
||||||
|
SessionInstructionSubset::Input(session_input_instruction)=>PhysicsWorkerInstruction::SessionInput(session_input_instruction),
|
||||||
|
SessionInstructionSubset::Control(session_control_instruction)=>PhysicsWorkerInstruction::SessionControl(session_control_instruction),
|
||||||
|
SessionInstructionSubset::Playback(session_playback_instruction)=>PhysicsWorkerInstruction::SessionPlayback(session_playback_instruction),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if let Some(session_instruction)=match keycode{
|
||||||
|
winit::keyboard::Key::Named(winit::keyboard::NamedKey::Space)=>input_ctrl!(SetJump,s),
|
||||||
|
winit::keyboard::Key::Named(winit::keyboard::NamedKey::Shift)=>input_ctrl!(SetSprint,s),
|
||||||
|
// TODO: bind system so playback pausing can use spacebar
|
||||||
|
winit::keyboard::Key::Named(winit::keyboard::NamedKey::Enter)=>if s{
|
||||||
|
let paused=!self.simulation_paused;
|
||||||
|
self.simulation_paused=paused;
|
||||||
|
if paused{
|
||||||
|
self.free_mouse();
|
||||||
|
}else{
|
||||||
|
self.lock_mouse();
|
||||||
|
}
|
||||||
|
Some(SessionInstructionSubset::Control(SessionControlInstruction::SetPaused(paused)))
|
||||||
|
}else{None},
|
||||||
|
winit::keyboard::Key::Named(winit::keyboard::NamedKey::ArrowUp)=>session_playback!(IncreaseTimescale,s),
|
||||||
|
winit::keyboard::Key::Named(winit::keyboard::NamedKey::ArrowDown)=>session_playback!(DecreaseTimescale,s),
|
||||||
|
winit::keyboard::Key::Named(winit::keyboard::NamedKey::ArrowLeft)=>session_playback!(SkipBack,s),
|
||||||
|
winit::keyboard::Key::Named(winit::keyboard::NamedKey::ArrowRight)=>session_playback!(SkipForward,s),
|
||||||
|
winit::keyboard::Key::Character(key)=>match key.as_str(){
|
||||||
|
"W"|"w"=>input_ctrl!(SetMoveForward,s),
|
||||||
|
"A"|"a"=>input_ctrl!(SetMoveLeft,s),
|
||||||
|
"S"|"s"=>input_ctrl!(SetMoveBack,s),
|
||||||
|
"D"|"d"=>input_ctrl!(SetMoveRight,s),
|
||||||
|
"E"|"e"=>input_ctrl!(SetMoveUp,s),
|
||||||
|
"Q"|"q"=>input_ctrl!(SetMoveDown,s),
|
||||||
|
"Z"|"z"=>input_ctrl!(SetZoom,s),
|
||||||
|
"R"|"r"=>s.then(||{
|
||||||
|
//mouse needs to be reset since the position is absolute
|
||||||
|
self.mouse_pos=glam::DVec2::ZERO;
|
||||||
|
SessionInstructionSubset::Input(SessionInputInstruction::Mode(session::ImplicitModeInstruction::ResetAndRestart))
|
||||||
|
}),
|
||||||
|
"F"|"f"=>input_misc!(PracticeFly,s),
|
||||||
|
"B"|"b"=>session_ctrl!(CopyRecordingIntoReplayAndSpectate,s),
|
||||||
|
"X"|"x"=>session_ctrl!(StopSpectate,s),
|
||||||
|
"N"|"n"=>session_ctrl!(SaveReplay,s),
|
||||||
|
"J"|"j"=>session_ctrl!(LoadIntoReplayState,s),
|
||||||
|
_=>None,
|
||||||
|
},
|
||||||
|
_=>None,
|
||||||
|
}{
|
||||||
|
self.physics_thread.send(TimedInstruction{
|
||||||
|
time,
|
||||||
|
instruction:session_instruction.into(),
|
||||||
|
}).unwrap();
|
||||||
|
}
|
||||||
|
},
|
||||||
|
}
|
||||||
|
},
|
||||||
|
winit::event::WindowEvent::Resized(size)=>{
|
||||||
|
self.physics_thread.send(
|
||||||
|
TimedInstruction{
|
||||||
|
time,
|
||||||
|
instruction:PhysicsWorkerInstruction::Resize(size)
|
||||||
|
}
|
||||||
|
).unwrap();
|
||||||
|
},
|
||||||
|
winit::event::WindowEvent::RedrawRequested=>{
|
||||||
|
self.window.request_redraw();
|
||||||
|
self.physics_thread.send(
|
||||||
|
TimedInstruction{
|
||||||
|
time,
|
||||||
|
instruction:PhysicsWorkerInstruction::Render
|
||||||
|
}
|
||||||
|
).unwrap();
|
||||||
|
},
|
||||||
|
_=>(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn device_event(&mut self,time:SessionTime,event:winit::event::DeviceEvent){
|
||||||
|
match event{
|
||||||
|
winit::event::DeviceEvent::MouseMotion{
|
||||||
|
delta,
|
||||||
|
}=>{
|
||||||
|
if self.manual_mouse_lock{
|
||||||
|
match self.window.set_cursor_position(self.get_middle_of_screen()){
|
||||||
|
Ok(())=>(),
|
||||||
|
Err(e)=>println!("Could not set cursor position: {:?}",e),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
self.mouse_pos+=glam::dvec2(delta.0,delta.1);
|
||||||
|
self.physics_thread.send(TimedInstruction{
|
||||||
|
time,
|
||||||
|
instruction:PhysicsWorkerInstruction::SessionInput(SessionInputInstruction::Mouse(self.mouse_pos.as_ivec2())),
|
||||||
|
}).unwrap();
|
||||||
|
},
|
||||||
|
winit::event::DeviceEvent::MouseWheel {
|
||||||
|
delta,
|
||||||
|
}=>{
|
||||||
|
println!("mousewheel {:?}",delta);
|
||||||
|
if false{//self.physics.style.use_scroll{
|
||||||
|
self.physics_thread.send(TimedInstruction{
|
||||||
|
time,
|
||||||
|
instruction:PhysicsWorkerInstruction::SessionInput(SessionInputInstruction::SetControl(SetControlInstruction::SetJump(true))),//activates the immediate jump path, but the style modifier prevents controls&CONTROL_JUMP bit from being set to auto jump
|
||||||
|
}).unwrap();
|
||||||
|
}
|
||||||
|
},
|
||||||
|
_=>(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
pub fn worker<'a>(
|
||||||
|
window:&'a winit::window::Window,
|
||||||
|
setup_context:crate::setup::SetupContext<'a>,
|
||||||
|
)->crate::compat_worker::QNWorker<'a,TimedInstruction<Instruction,SessionTime>>{
|
||||||
|
// WindowContextSetup::new
|
||||||
|
#[cfg(feature="user-install")]
|
||||||
|
let directories=Directories::user().unwrap();
|
||||||
|
#[cfg(not(feature="user-install"))]
|
||||||
|
let directories=Directories::portable().unwrap();
|
||||||
|
|
||||||
|
let user_settings=directories.settings();
|
||||||
|
|
||||||
|
let mut graphics=strafesnet_graphics::graphics::GraphicsState::new(&setup_context.device,&setup_context.queue,&setup_context.config);
|
||||||
|
|
||||||
|
//WindowContextSetup::into_context
|
||||||
|
let screen_size=glam::uvec2(setup_context.config.width,setup_context.config.height);
|
||||||
|
let fov=user_settings.calculate_fov(1.0,&screen_size).as_vec2();
|
||||||
|
graphics.resize(&setup_context.device,&setup_context.config,fov);
|
||||||
|
let graphics_thread=crate::graphics_worker::new(graphics,setup_context.config,setup_context.surface,setup_context.device,setup_context.queue);
|
||||||
|
let mut window_context=WindowContext{
|
||||||
|
manual_mouse_lock:false,
|
||||||
|
mouse_pos:glam::DVec2::ZERO,
|
||||||
|
simulation_paused:false,
|
||||||
|
//make sure to update this!!!!!
|
||||||
|
screen_size,
|
||||||
|
window,
|
||||||
|
physics_thread:crate::physics_worker::new(
|
||||||
|
graphics_thread,
|
||||||
|
directories,
|
||||||
|
user_settings,
|
||||||
|
),
|
||||||
|
};
|
||||||
|
|
||||||
|
//WindowContextSetup::into_worker
|
||||||
|
crate::compat_worker::QNWorker::new(move |ins:TimedInstruction<Instruction,SessionTime>|{
|
||||||
|
match ins.instruction{
|
||||||
|
Instruction::WindowEvent(window_event)=>{
|
||||||
|
window_context.window_event(ins.time,window_event);
|
||||||
|
},
|
||||||
|
Instruction::DeviceEvent(device_event)=>{
|
||||||
|
window_context.device_event(ins.time,device_event);
|
||||||
|
},
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user