oxygengine_input_device_web/
keyboard.rs1use backend::closure::WebClosure;
2use core::{ecs::Universe, Scalar};
3use input::device::InputDevice;
4use std::{any::Any, cell::RefCell, collections::HashSet, rc::Rc};
5use wasm_bindgen::{prelude::*, JsCast};
6use web_sys::*;
7
8pub type KeyCode = (char, String);
10
11pub struct WebKeyboardInputDevice {
12 element: EventTarget,
13 keys: Rc<RefCell<HashSet<String>>>,
14 sequence: Rc<RefCell<Vec<KeyCode>>>,
15 last_sequence: Vec<KeyCode>,
16 key_down_closure: WebClosure,
17 key_up_closure: WebClosure,
18}
19
20unsafe impl Send for WebKeyboardInputDevice {}
21unsafe impl Sync for WebKeyboardInputDevice {}
22
23impl WebKeyboardInputDevice {
24 pub fn new(element: EventTarget) -> Self {
25 Self {
26 element,
27 keys: Default::default(),
28 sequence: Rc::new(RefCell::new(Vec::with_capacity(128))),
29 last_sequence: Vec::with_capacity(128),
30 key_down_closure: Default::default(),
31 key_up_closure: Default::default(),
32 }
33 }
34
35 pub fn last_sequence(&self) -> &[KeyCode] {
36 &self.last_sequence
37 }
38}
39
40impl InputDevice for WebKeyboardInputDevice {
41 fn name(&self) -> &str {
42 "keyboard"
43 }
44
45 fn on_register(&mut self) {
46 {
47 let keys = self.keys.clone();
48 let sequence = self.sequence.clone();
49 let closure = Closure::wrap(Box::new(move |event: KeyboardEvent| {
50 let code = event.code();
51 let key = event.key();
52 keys.borrow_mut().insert(code.clone());
53 match key.len() {
54 1 => sequence
55 .borrow_mut()
56 .push((key.chars().next().unwrap(), code)),
57 2..=std::usize::MAX => sequence.borrow_mut().push((0 as char, code)),
58 _ => {}
59 }
60 }) as Box<dyn FnMut(_)>);
61 self.element
62 .add_event_listener_with_callback("keydown", closure.as_ref().unchecked_ref())
63 .unwrap();
64 self.key_down_closure = WebClosure::acquire(closure);
65 }
66 {
67 let keys = self.keys.clone();
68 let closure = Closure::wrap(Box::new(move |event: KeyboardEvent| {
69 keys.borrow_mut().remove(&event.code());
70 }) as Box<dyn FnMut(_)>);
71 self.element
72 .add_event_listener_with_callback("keyup", closure.as_ref().unchecked_ref())
73 .unwrap();
74 self.key_up_closure = WebClosure::acquire(closure);
75 }
76 }
77
78 fn on_unregister(&mut self) {
79 self.key_down_closure.release();
80 self.key_up_closure.release();
81 }
82
83 fn process(&mut self, _: &mut Universe) {
84 self.last_sequence.clear();
85 self.last_sequence.append(&mut self.sequence.borrow_mut());
86 }
87
88 fn query_axis(&self, name: &str) -> Option<Scalar> {
89 Some(if self.keys.borrow().contains(name) {
90 1.0
91 } else {
92 0.0
93 })
94 }
95
96 fn query_trigger(&self, name: &str) -> Option<bool> {
97 Some(self.keys.borrow().contains(name))
98 }
99
100 fn query_text(&self) -> Option<String> {
101 Some(self.last_sequence.iter().map(|(c, _)| c).collect())
102 }
103
104 fn as_any(&self) -> &dyn Any {
105 self
106 }
107}