apeirogond 0.22.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

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

use a7n_platform::input::{Captured, GESTURE_CHORDS_SUPPORTED, Inject};
use a7n_proto::MachineId;
use a7n_proto::v1::{Capability, Gesture, InputEvent, input_event::Event};

use super::Daemon;

impl Daemon {
    pub(super) fn peer_accepts_gestures(&self, peer: MachineId) -> bool {
        self.links
            .by_peer
            .get(&peer)
            .is_some_and(|link| link.capabilities.contains(&Capability::Gestures))
    }

    pub(super) fn gesture_allowed(&self, peer: MachineId, event: &InputEvent) -> bool {
        !matches!(event.event, Some(Event::Gesture(_))) || self.peer_accepts_gestures(peer)
    }

    pub(super) fn log_driving_gesture(&self, peer: MachineId, event: &Captured) {
        let Captured::Input(input) = event else {
            return;
        };
        if matches!(input.event, Some(Event::Gesture(_))) && self.gesture_allowed(peer, input) {
            crate::log::event!("kind=gesture_swipe");
        }
    }

    pub(super) async fn inject_gesture(&mut self, peer: MachineId, gesture: i32) {
        if !self.peer_accepts_gestures(peer) {
            return;
        }
        if !GESTURE_CHORDS_SUPPORTED {
            self.input
                .inject(Inject::Event(InputEvent {
                    event: Some(Event::Gesture(gesture)),
                }))
                .await;
            return;
        }
        let Ok(gesture) = Gesture::try_from(gesture) else {
            return;
        };
        let keys: Vec<_> = self.input.gestures.events(gesture).collect();
        if keys.is_empty() {
            return;
        }
        self.input.inject(Inject::Chord(keys)).await;
    }
}