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

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

//! The in-process command seam consumed by the #23 IPC server.

use std::net::SocketAddr;

use a7n_core::pairing::PairingCode;
pub(crate) use a7n_ipc::StatusInfo as Status;
use a7n_proto::MachineId;
use tokio::sync::oneshot;

use crate::daemon::DaemonError;
use crate::pin_store::Entry;

pub(crate) type Reply<T> = oneshot::Sender<Result<T, DaemonError>>;

#[derive(Debug)]
pub(crate) enum Command {
    ReloadConfig(Reply<()>),
    RecordTriggerKey(Reply<String>),
    Shutdown(Reply<()>),
    SetPaused {
        paused: bool,
        reply: Reply<()>,
    },
    Switch {
        machine: MachineId,
        reply: Reply<Option<String>>,
    },
    Wake {
        machine: MachineId,
        reply: Reply<()>,
    },
    Status(Reply<Status>),
    SendFiles {
        peer: MachineId,
        paths: Vec<std::path::PathBuf>,
        reply: Reply<(u64, usize)>,
    },
    FilesAccept {
        peer: MachineId,
        offer_id: u64,
        reply: Reply<()>,
    },
    FilesReject {
        peer: MachineId,
        reply: Reply<()>,
    },
    CancelTransfer {
        id: u64,
        reply: Reply<()>,
    },
    ClipboardStatus(Reply<a7n_ipc::ClipboardInfo>),
    ClipboardAccept {
        machine: MachineId,
        generation: u64,
        reply: Reply<()>,
    },
    ClipboardReject(Reply<()>),
    GetLayout(Reply<a7n_ipc::LayoutInfo>),
    SetLayout {
        placed: Vec<a7n_ipc::LayoutPlacement>,
        reply: Reply<()>,
    },
    PairHost(Reply<PairingCode>),
    PairJoin {
        addr: SocketAddr,
        code: PairingCode,
        reply: Reply<Entry>,
    },
    Unpair {
        machine: MachineId,
        reply: Reply<()>,
    },
    Connect {
        addr: SocketAddr,
        reply: Reply<()>,
    },
    RequestPermission {
        permission: a7n_platform::permissions::Permission,
        reply: Reply<()>,
    },
}