apeirogond 0.35.0

Daemon for Apeirogon, a cross-platform software KVM
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

// SPDX-License-Identifier: GPL-3.0-or-later

use a7n_core::hotkey::{HotkeyMatcher, ShakeDetector};

use super::{Action, Cursor, Daemon, EdgeResistance, Inject, landing_point};

impl Daemon {
    pub(in crate::daemon) async fn sync_grab(&mut self) {
        self.sync_local_inputs().await;
        self.input
            .grab(
                self.input.focus.is_driven()
                    || matches!(self.input.focus.cursor(), Cursor::Driving(_)),
            )
            .await;
    }

    pub(in crate::daemon) async fn sync_local_inputs(&mut self) {
        let inputs = if matches!(self.input.focus.cursor(), Cursor::Driving(_)) {
            self.input.local_inputs.clone()
        } else {
            Vec::new()
        };
        if let Some(capture) = &self.input.capture {
            if capture
                .control
                .send(a7n_platform::input::CaptureControl::LocalInputs(inputs))
                .await
                .is_err()
            {
                self.input.closed();
            }
        }
    }

    pub(in crate::daemon) async fn input_actions(&mut self, actions: Vec<Action>) {
        for action in actions {
            match action {
                Action::EndedDriven => {
                    let change = self.input.idle_cursor.ended_driven();
                    self.input.cursor_visibility(change).await;
                }
                Action::Send { peer, body } => self.send_input(peer, body),
                Action::Release(events) => {
                    self.input.reset_edge_state();
                    for event in events {
                        self.input.inject(Inject::Event(event)).await;
                    }
                }
                Action::Cursor(cursor) => {
                    let change = self
                        .input
                        .idle_cursor
                        .driving(matches!(cursor, Cursor::Driving(_)));
                    self.input.cursor_visibility(change).await;
                    self.input.shake = ShakeDetector::new(self.config.hotkeys.shake);
                    self.input.reset_edge_state();
                    if let Cursor::Driving(peer) = cursor {
                        self.input.counter.reset();
                        self.snapshot_remap(peer);
                    }
                    self.input.resistance = EdgeResistance::new(0);
                    self.sync_grab().await;
                }
                Action::Driven {
                    owner,
                    landing,
                    resistance_px,
                } => {
                    let change = self.input.idle_cursor.driving(false);
                    self.input.cursor_visibility(change).await;
                    self.input.reset_edge_state();
                    self.input.hotkeys = HotkeyMatcher::new(self.config.bindings());
                    self.input.shake = ShakeDetector::new(self.config.hotkeys.shake);
                    self.input.tracker.reset();
                    self.configure_input_scales(owner);
                    self.input.resistance = EdgeResistance::new(resistance_px);
                    self.sync_grab().await;
                    if let (Some(landing), Some(injector)) = (landing, &self.input.injector) {
                        let (x, y) = landing_point(injector.bounds, &injector.monitors, &landing);
                        self.input.inject(Inject::Warp { x, y }).await;
                        self.input.sink.landing(x, y);
                    }
                }
            }
        }
    }
}