mirror of
https://github.com/mofeng-git/One-KVM.git
synced 2026-01-29 00:51:53 +08:00
refactoring
This commit is contained in:
@@ -44,11 +44,23 @@ class _ResetEvent(BaseEvent):
|
|||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
@dataclasses.dataclass(frozen=True)
|
||||||
|
class _ModifierEvent(BaseEvent):
|
||||||
|
modifier: keymap.OtgKey
|
||||||
|
state: bool
|
||||||
|
|
||||||
|
def __post_init__(self) -> None:
|
||||||
|
assert self.modifier.is_modifier
|
||||||
|
|
||||||
|
|
||||||
@dataclasses.dataclass(frozen=True)
|
@dataclasses.dataclass(frozen=True)
|
||||||
class _KeyEvent(BaseEvent):
|
class _KeyEvent(BaseEvent):
|
||||||
key: keymap.OtgKey
|
key: keymap.OtgKey
|
||||||
state: bool
|
state: bool
|
||||||
|
|
||||||
|
def __post_init__(self) -> None:
|
||||||
|
assert not self.key.is_modifier
|
||||||
|
|
||||||
|
|
||||||
# =====
|
# =====
|
||||||
class KeyboardProcess(BaseDeviceProcess):
|
class KeyboardProcess(BaseDeviceProcess):
|
||||||
@@ -74,8 +86,11 @@ class KeyboardProcess(BaseDeviceProcess):
|
|||||||
self._queue_event(_ResetEvent())
|
self._queue_event(_ResetEvent())
|
||||||
|
|
||||||
def send_key_event(self, key: str, state: bool) -> None:
|
def send_key_event(self, key: str, state: bool) -> None:
|
||||||
assert key in keymap.KEYMAP
|
otg_key = keymap.KEYMAP[key].otg
|
||||||
self._queue_event(_KeyEvent(key=keymap.KEYMAP[key].otg, state=state))
|
if otg_key.is_modifier:
|
||||||
|
self._queue_event(_ModifierEvent(otg_key, state))
|
||||||
|
else:
|
||||||
|
self._queue_event(_KeyEvent(otg_key, state))
|
||||||
|
|
||||||
# =====
|
# =====
|
||||||
|
|
||||||
@@ -84,6 +99,8 @@ class KeyboardProcess(BaseDeviceProcess):
|
|||||||
self.__process_clear_event()
|
self.__process_clear_event()
|
||||||
elif isinstance(event, _ResetEvent):
|
elif isinstance(event, _ResetEvent):
|
||||||
self.__process_clear_event(reopen=True)
|
self.__process_clear_event(reopen=True)
|
||||||
|
elif isinstance(event, _ModifierEvent):
|
||||||
|
self.__process_modifier_event(event)
|
||||||
elif isinstance(event, _KeyEvent):
|
elif isinstance(event, _KeyEvent):
|
||||||
self.__process_key_event(event)
|
self.__process_key_event(event)
|
||||||
|
|
||||||
@@ -94,41 +111,41 @@ class KeyboardProcess(BaseDeviceProcess):
|
|||||||
self._close_device()
|
self._close_device()
|
||||||
self.__send_current_state()
|
self.__send_current_state()
|
||||||
|
|
||||||
def __process_key_event(self, event: _KeyEvent) -> None:
|
def __process_modifier_event(self, event: _ModifierEvent) -> None:
|
||||||
if event.key.is_modifier:
|
if event.modifier in self.__pressed_modifiers:
|
||||||
if event.key in self.__pressed_modifiers:
|
# Ранее нажатый модификатор отжимаем
|
||||||
# Ранее нажатый модификатор отжимаем
|
self.__pressed_modifiers.remove(event.modifier)
|
||||||
self.__pressed_modifiers.remove(event.key)
|
if not self.__send_current_state():
|
||||||
if not self.__send_current_state():
|
return
|
||||||
return
|
if event.state:
|
||||||
if event.state:
|
# Нажимаем если нужно
|
||||||
# Нажимаем если нужно
|
self.__pressed_modifiers.add(event.modifier)
|
||||||
self.__pressed_modifiers.add(event.key)
|
self.__send_current_state()
|
||||||
self.__send_current_state()
|
|
||||||
|
|
||||||
else: # regular key
|
def __process_key_event(self, event: _KeyEvent) -> None:
|
||||||
if event.key in self.__pressed_keys:
|
if event.key in self.__pressed_keys:
|
||||||
# Ранее нажатую клавишу отжимаем
|
# Ранее нажатую клавишу отжимаем
|
||||||
self.__pressed_keys[self.__pressed_keys.index(event.key)] = None
|
self.__pressed_keys[self.__pressed_keys.index(event.key)] = None
|
||||||
if not self.__send_current_state():
|
if not self.__send_current_state():
|
||||||
return
|
return
|
||||||
elif event.state and None not in self.__pressed_keys:
|
elif event.state and None not in self.__pressed_keys:
|
||||||
# Если нужно нажать что-то новое, но свободных слотов нет - отжимаем всё
|
# Если нужно нажать что-то новое, но свободных слотов нет - отжимаем всё
|
||||||
self.__clear_keys()
|
self.__clear_keys()
|
||||||
if not self.__send_current_state():
|
if not self.__send_current_state():
|
||||||
return
|
return
|
||||||
if event.state:
|
if event.state:
|
||||||
# Нажимаем если нужно
|
# Нажимаем если нужно
|
||||||
self.__pressed_keys[self.__pressed_keys.index(None)] = event.key
|
self.__pressed_keys[self.__pressed_keys.index(None)] = event.key
|
||||||
self.__send_current_state()
|
self.__send_current_state()
|
||||||
|
|
||||||
|
# =====
|
||||||
|
|
||||||
def __send_current_state(self) -> bool:
|
def __send_current_state(self) -> bool:
|
||||||
ok = False
|
ok = False
|
||||||
if self._ensure_device():
|
if self._ensure_device():
|
||||||
modifiers = 0
|
modifiers = 0
|
||||||
for key in self.__pressed_modifiers:
|
for modifier in self.__pressed_modifiers:
|
||||||
assert key.is_modifier
|
modifiers |= modifier.code
|
||||||
modifiers |= key.code
|
|
||||||
|
|
||||||
assert len(self.__pressed_keys) == 6
|
assert len(self.__pressed_keys) == 6
|
||||||
keys = [
|
keys = [
|
||||||
|
|||||||
@@ -31,14 +31,6 @@ from .device import BaseEvent
|
|||||||
from .device import BaseDeviceProcess
|
from .device import BaseDeviceProcess
|
||||||
|
|
||||||
|
|
||||||
# =====
|
|
||||||
_BUTTONS = {
|
|
||||||
"left": 0x1,
|
|
||||||
"right": 0x2,
|
|
||||||
"middle": 0x4,
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
# =====
|
# =====
|
||||||
class _ClearEvent(BaseEvent):
|
class _ClearEvent(BaseEvent):
|
||||||
pass
|
pass
|
||||||
@@ -59,20 +51,12 @@ class _MoveEvent(BaseEvent):
|
|||||||
to_x: int
|
to_x: int
|
||||||
to_y: int
|
to_y: int
|
||||||
|
|
||||||
def __post_init__(self) -> None:
|
|
||||||
assert -32768 <= self.to_x <= 32767
|
|
||||||
assert -32768 <= self.to_y <= 32767
|
|
||||||
|
|
||||||
|
|
||||||
@dataclasses.dataclass(frozen=True)
|
@dataclasses.dataclass(frozen=True)
|
||||||
class _WheelEvent(BaseEvent):
|
class _WheelEvent(BaseEvent):
|
||||||
delta_x: int
|
delta_x: int
|
||||||
delta_y: int
|
delta_y: int
|
||||||
|
|
||||||
def __post_init__(self) -> None:
|
|
||||||
assert -127 <= self.delta_x <= 127
|
|
||||||
assert -127 <= self.delta_y <= 127
|
|
||||||
|
|
||||||
|
|
||||||
# =====
|
# =====
|
||||||
class MouseProcess(BaseDeviceProcess):
|
class MouseProcess(BaseDeviceProcess):
|
||||||
@@ -99,13 +83,23 @@ class MouseProcess(BaseDeviceProcess):
|
|||||||
self._queue_event(_ResetEvent())
|
self._queue_event(_ResetEvent())
|
||||||
|
|
||||||
def send_button_event(self, button: str, state: bool) -> None:
|
def send_button_event(self, button: str, state: bool) -> None:
|
||||||
assert button in _BUTTONS
|
code: int = {
|
||||||
self._queue_event(_ButtonEvent(code=_BUTTONS[button], state=state))
|
"left": 0x1,
|
||||||
|
"right": 0x2,
|
||||||
|
"middle": 0x4,
|
||||||
|
}[button]
|
||||||
|
self._queue_event(_ButtonEvent(code, state))
|
||||||
|
|
||||||
def send_move_event(self, to_x: int, to_y: int) -> None:
|
def send_move_event(self, to_x: int, to_y: int) -> None:
|
||||||
|
assert -32768 <= to_x <= 32767
|
||||||
|
assert -32768 <= to_y <= 32767
|
||||||
|
to_x = (to_x + 32768) // 2
|
||||||
|
to_y = (to_y + 32768) // 2
|
||||||
self._queue_event(_MoveEvent(to_x, to_y))
|
self._queue_event(_MoveEvent(to_x, to_y))
|
||||||
|
|
||||||
def send_wheel_event(self, delta_x: int, delta_y: int) -> None:
|
def send_wheel_event(self, delta_x: int, delta_y: int) -> None:
|
||||||
|
assert -127 <= delta_x <= 127
|
||||||
|
assert -127 <= delta_y <= 127
|
||||||
self._queue_event(_WheelEvent(delta_x, delta_y))
|
self._queue_event(_WheelEvent(delta_x, delta_y))
|
||||||
|
|
||||||
# =====
|
# =====
|
||||||
@@ -147,6 +141,8 @@ class MouseProcess(BaseDeviceProcess):
|
|||||||
def __process_wheel_event(self, event: _WheelEvent) -> None:
|
def __process_wheel_event(self, event: _WheelEvent) -> None:
|
||||||
self.__send_current_state(event.delta_x, event.delta_y)
|
self.__send_current_state(event.delta_x, event.delta_y)
|
||||||
|
|
||||||
|
# =====
|
||||||
|
|
||||||
def __send_current_state(self, delta_x: int, delta_y: int) -> bool:
|
def __send_current_state(self, delta_x: int, delta_y: int) -> bool:
|
||||||
ok = False
|
ok = False
|
||||||
if self._ensure_device():
|
if self._ensure_device():
|
||||||
@@ -167,6 +163,6 @@ class MouseProcess(BaseDeviceProcess):
|
|||||||
self.__y = 0
|
self.__y = 0
|
||||||
|
|
||||||
def __make_report(self, buttons: int, to_x: int, to_y: int, delta_x: int, delta_y: int) -> bytes:
|
def __make_report(self, buttons: int, to_x: int, to_y: int, delta_x: int, delta_y: int) -> bytes:
|
||||||
to_x = (to_x + 32768) // 2
|
# XXX: Delta Y before X: it's ok.
|
||||||
to_y = (to_y + 32768) // 2
|
# See /kvmd/apps/otg/hid/keyboard.py for details
|
||||||
return struct.pack("<BHHbb", buttons, to_x, to_y, delta_y, delta_x)
|
return struct.pack("<BHHbb", buttons, to_x, to_y, delta_y, delta_x)
|
||||||
|
|||||||
Reference in New Issue
Block a user