mirror of
https://github.com/feschber/lan-mouse.git
synced 2026-03-20 11:40:55 +03:00
Compare commits
5 Commits
latest
...
save-confi
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
87a078bce6 | ||
|
|
16c7a57b48 | ||
|
|
a29489cd40 | ||
|
|
18bba183ee | ||
|
|
6d16747c19 |
64
.github/workflows/cachix.yml
vendored
64
.github/workflows/cachix.yml
vendored
@@ -1,46 +1,40 @@
|
|||||||
name: Nix Binary Cache
|
name: Binary Cache
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
branches: ["main"]
|
|
||||||
pull_request:
|
|
||||||
branches: ["main"]
|
|
||||||
workflow_dispatch:
|
|
||||||
|
|
||||||
|
on: [push, pull_request, workflow_dispatch]
|
||||||
jobs:
|
jobs:
|
||||||
nix:
|
nix:
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
os:
|
os:
|
||||||
- ubuntu-latest
|
- ubuntu-latest
|
||||||
- macos-15-intel
|
- macos-15-intel
|
||||||
- macos-latest
|
- macos-14
|
||||||
name: "Build"
|
name: "Build"
|
||||||
runs-on: ${{ matrix.os }}
|
runs-on: ${{ matrix.os }}
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout
|
- name: Checkout
|
||||||
uses: actions/checkout@v4
|
uses: actions/checkout@v4
|
||||||
with:
|
with:
|
||||||
submodules: recursive
|
submodules: recursive
|
||||||
|
|
||||||
# - uses: DeterminateSystems/nix-installer-action@main
|
- uses: DeterminateSystems/nix-installer-action@main
|
||||||
# with:
|
with:
|
||||||
# logger: pretty
|
logger: pretty
|
||||||
# - uses: DeterminateSystems/magic-nix-cache-action@main
|
- uses: DeterminateSystems/magic-nix-cache-action@main
|
||||||
- uses: cachix/install-nix-action@v31
|
- uses: cachix/cachix-action@v14
|
||||||
- uses: cachix/cachix-action@v16
|
with:
|
||||||
with:
|
name: lan-mouse
|
||||||
name: lan-mouse
|
authToken: '${{ secrets.CACHIX_AUTH_TOKEN }}'
|
||||||
authToken: "${{ secrets.CACHIX_AUTH_TOKEN }}"
|
|
||||||
|
|
||||||
- name: Build lan-mouse (x86_64-linux)
|
- name: Build lan-mouse (x86_64-linux)
|
||||||
if: matrix.os == 'ubuntu-latest'
|
if: matrix.os == 'ubuntu-latest'
|
||||||
run: nix build --print-build-logs --show-trace .#packages.x86_64-linux.lan-mouse
|
run: nix build --print-build-logs --show-trace .#packages.x86_64-linux.lan-mouse
|
||||||
|
|
||||||
- name: Build lan-mouse (x86_64-darwin)
|
- name: Build lan-mouse (x86_64-darwin)
|
||||||
if: matrix.os == 'macos-15-intel'
|
if: matrix.os == 'macos-15-intel'
|
||||||
run: nix build --print-build-logs --show-trace .#packages.x86_64-darwin.lan-mouse
|
run: nix build --print-build-logs --show-trace .#packages.x86_64-darwin.lan-mouse
|
||||||
|
|
||||||
|
- name: Build lan-mouse (aarch64-darwin)
|
||||||
|
if: matrix.os == 'macos-14'
|
||||||
|
run: nix build --print-build-logs --show-trace .#packages.aarch64-darwin.lan-mouse
|
||||||
|
|
||||||
- name: Build lan-mouse (aarch64-darwin)
|
|
||||||
if: matrix.os == 'macos-latest'
|
|
||||||
run: nix build --print-build-logs --show-trace .#packages.aarch64-darwin.lan-mouse
|
|
||||||
|
|||||||
2
.github/workflows/pre-release.yml
vendored
2
.github/workflows/pre-release.yml
vendored
@@ -11,7 +11,7 @@ env:
|
|||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
linux-release-build:
|
linux-release-build:
|
||||||
runs-on: ubuntu-22.04
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
- name: install dependencies
|
- name: install dependencies
|
||||||
|
|||||||
218
.github/workflows/rust.yml
vendored
218
.github/workflows/rust.yml
vendored
@@ -10,87 +10,149 @@ env:
|
|||||||
CARGO_TERM_COLOR: always
|
CARGO_TERM_COLOR: always
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
fmt:
|
build-linux:
|
||||||
name: Formatting
|
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
- name: cargo fmt
|
- name: install dependencies
|
||||||
run: cargo fmt --check
|
run: |
|
||||||
|
sudo apt-get update
|
||||||
|
sudo apt-get install libx11-dev libxtst-dev
|
||||||
|
sudo apt-get install libadwaita-1-dev libgtk-4-dev
|
||||||
|
- name: Build
|
||||||
|
run: cargo build --verbose
|
||||||
|
- name: Run tests
|
||||||
|
run: cargo test --verbose
|
||||||
|
- name: Check Formatting
|
||||||
|
run: cargo fmt --check
|
||||||
|
- name: Clippy
|
||||||
|
run: cargo clippy --all-features --all-targets -- --deny warnings
|
||||||
|
- name: Upload build artifact
|
||||||
|
uses: actions/upload-artifact@v4
|
||||||
|
with:
|
||||||
|
name: lan-mouse
|
||||||
|
path: target/debug/lan-mouse
|
||||||
|
|
||||||
|
build-windows:
|
||||||
|
|
||||||
|
runs-on: windows-latest
|
||||||
|
|
||||||
ci:
|
|
||||||
name: ${{ matrix.job }} ${{ matrix.os }}
|
|
||||||
runs-on: ${{ matrix.os }}
|
|
||||||
strategy:
|
|
||||||
fail-fast: false
|
|
||||||
matrix:
|
|
||||||
os:
|
|
||||||
- ubuntu-latest
|
|
||||||
- windows-latest
|
|
||||||
- macos-latest
|
|
||||||
- macos-15-intel
|
|
||||||
job:
|
|
||||||
- build
|
|
||||||
- check
|
|
||||||
- clippy
|
|
||||||
- test
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
- uses: Swatinem/rust-cache@v2
|
- uses: actions/setup-python@v5
|
||||||
- name: Install Linux deps
|
with:
|
||||||
if: runner.os == 'Linux'
|
python-version: '3.11'
|
||||||
run: |
|
# needed for cache restore
|
||||||
sudo apt-get update
|
- name: create gtk dir
|
||||||
sudo apt-get install libx11-dev libxtst-dev libadwaita-1-dev libgtk-4-dev
|
run: mkdir C:\gtk-build\gtk\x64\release
|
||||||
- name: Install macOS dependencies
|
- uses: actions/cache@v3
|
||||||
if: runner.os == 'macOS'
|
id: cache
|
||||||
run: brew install gtk4 libadwaita imagemagick
|
with:
|
||||||
- name: Install Windows Dependencies - create gtk dir
|
path: c:/gtk-build/gtk/x64/release/**
|
||||||
if: runner.os == 'Windows'
|
key: gtk-windows-build
|
||||||
run: mkdir C:\gtk-build\gtk\x64\release
|
restore-keys: gtk-windows-build
|
||||||
- name: Install Windows Dependencies - install gtk from cache
|
- name: Update path
|
||||||
uses: actions/cache@v3
|
run: |
|
||||||
if: runner.os == 'Windows'
|
echo "PKG_CONFIG=C:\gtk-build\gtk\x64\release\bin\pkgconf.exe" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
|
||||||
id: cache
|
echo "C:\pkg-config-lite-0.28-1\bin" | Out-File -FilePath $env:GITHUB_PATH -Encoding utf8 -Append
|
||||||
with:
|
echo "C:\gtk-build\gtk\x64\release\bin" | Out-File -FilePath $env:GITHUB_PATH -Encoding utf8 -Append
|
||||||
path: c:/gtk-build/gtk/x64/release/**
|
echo $env:GITHUB_PATH
|
||||||
key: gtk-windows-build
|
echo $env:PATH
|
||||||
restore-keys: gtk-windows-build
|
- name: Install dependencies
|
||||||
- name: Install Windows Dependencies - update PATH
|
if: steps.cache.outputs.cache-hit != 'true'
|
||||||
if: runner.os == 'Windows'
|
run: |
|
||||||
run: |
|
# choco install msys2
|
||||||
echo "PKG_CONFIG=C:\gtk-build\gtk\x64\release\bin\pkgconf.exe" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
|
# choco install visualstudio2022-workload-vctools
|
||||||
echo "C:\pkg-config-lite-0.28-1\bin" | Out-File -FilePath $env:GITHUB_PATH -Encoding utf8 -Append
|
# choco install pkgconfiglite
|
||||||
echo "C:\gtk-build\gtk\x64\release\bin" | Out-File -FilePath $env:GITHUB_PATH -Encoding utf8 -Append
|
py -m venv .venv
|
||||||
echo $env:GITHUB_PATH
|
.venv\Scripts\activate.ps1
|
||||||
echo $env:PATH
|
py -m pip install gvsbuild
|
||||||
- name: Install Windows dependencies - build gtk
|
# see https://github.com/wingtk/gvsbuild/pull/1004
|
||||||
if: runner.os == 'Windows' && steps.cache.outputs.cache-hit != 'true'
|
Move-Item "C:\Program Files\Git\usr\bin" "C:\Program Files\Git\usr\notbin"
|
||||||
run: |
|
Move-Item "C:\Program Files\Git\bin" "C:\Program Files\Git\notbin"
|
||||||
# choco install msys2
|
gvsbuild build --msys-dir=C:\msys64 gtk4 libadwaita librsvg
|
||||||
# choco install visualstudio2022-workload-vctools
|
Move-Item "C:\Program Files\Git\usr\notbin" "C:\Program Files\Git\usr\bin"
|
||||||
# choco install pkgconfiglite
|
Move-Item "C:\Program Files\Git\notbin" "C:\Program Files\Git\bin"
|
||||||
py -m venv .venv
|
- name: Build
|
||||||
.venv\Scripts\activate.ps1
|
run: cargo build --verbose
|
||||||
py -m pip install gvsbuild
|
- name: Run tests
|
||||||
gvsbuild build --msys-dir=C:\msys64 gtk4 libadwaita librsvg
|
run: cargo test --verbose
|
||||||
- name: cargo build
|
- name: Check Formatting
|
||||||
if: matrix.job == 'build'
|
run: cargo fmt --check
|
||||||
run: cargo build
|
- name: Clippy
|
||||||
|
run: cargo clippy --all-features --all-targets -- --deny warnings
|
||||||
|
- name: Copy Gtk Dlls
|
||||||
|
run: Get-Childitem -Path "C:\\gtk-build\\gtk\\x64\\release\\bin\\*.dll" -File -Recurse | Copy-Item -Destination "target\\debug"
|
||||||
|
- name: Upload build artifact
|
||||||
|
uses: actions/upload-artifact@v4
|
||||||
|
with:
|
||||||
|
name: lan-mouse-windows
|
||||||
|
path: |
|
||||||
|
target/debug/lan-mouse.exe
|
||||||
|
target/debug/*.dll
|
||||||
|
|
||||||
- name: cargo check
|
build-macos:
|
||||||
if: matrix.job == 'check'
|
runs-on: macos-15-intel
|
||||||
run: cargo check --workspace --all-targets --all-features
|
steps:
|
||||||
|
- uses: actions/checkout@v4
|
||||||
|
- name: install dependencies
|
||||||
|
run: brew install gtk4 libadwaita imagemagick
|
||||||
|
- name: Build
|
||||||
|
run: cargo build --verbose
|
||||||
|
- name: Run tests
|
||||||
|
run: cargo test --verbose
|
||||||
|
- name: Check Formatting
|
||||||
|
run: cargo fmt --check
|
||||||
|
- name: Clippy
|
||||||
|
run: cargo clippy --all-features --all-targets -- --deny warnings
|
||||||
|
- name: Make icns
|
||||||
|
run: scripts/makeicns.sh
|
||||||
|
- name: Install cargo bundle
|
||||||
|
run: cargo install cargo-bundle
|
||||||
|
- name: Bundle
|
||||||
|
run: |
|
||||||
|
cargo bundle
|
||||||
|
scripts/copy-macos-dylib.sh
|
||||||
|
- name: Zip bundle
|
||||||
|
run: |
|
||||||
|
cd target/debug/bundle/osx
|
||||||
|
zip -r "Lan Mouse macOS (Intel).zip" "Lan Mouse.app"
|
||||||
|
- name: Upload build artifact
|
||||||
|
uses: actions/upload-artifact@v4
|
||||||
|
with:
|
||||||
|
name: Lan Mouse macOS (Intel)
|
||||||
|
path: target/debug/bundle/osx/Lan Mouse macOS (Intel).zip
|
||||||
|
|
||||||
- name: cargo test
|
build-macos-aarch64:
|
||||||
if: matrix.job == 'test'
|
runs-on: macos-14
|
||||||
run: cargo test --workspace --all-features
|
steps:
|
||||||
|
- uses: actions/checkout@v4
|
||||||
- name: cargo clippy
|
- name: install dependencies
|
||||||
if: matrix.job == 'clippy'
|
run: brew install gtk4 libadwaita imagemagick
|
||||||
run: cargo clippy --workspace --all-targets --all-features -- -D warnings
|
- name: Build
|
||||||
|
run: cargo build --verbose
|
||||||
- uses: clechasseur/rs-clippy-check@v4
|
- name: Run tests
|
||||||
if: matrix.job == 'clippy'
|
run: cargo test --verbose
|
||||||
with:
|
- name: Check Formatting
|
||||||
args: --workspace --all-targets --all-features
|
run: cargo fmt --check
|
||||||
|
- name: Clippy
|
||||||
|
run: cargo clippy --all-features --all-targets -- --deny warnings
|
||||||
|
- name: Make icns
|
||||||
|
run: scripts/makeicns.sh
|
||||||
|
- name: Install cargo bundle
|
||||||
|
run: cargo install cargo-bundle
|
||||||
|
- name: Bundle
|
||||||
|
run: |
|
||||||
|
cargo bundle
|
||||||
|
scripts/copy-macos-dylib.sh
|
||||||
|
- name: Zip bundle
|
||||||
|
run: |
|
||||||
|
cd target/debug/bundle/osx
|
||||||
|
zip -r "Lan Mouse macOS (ARM).zip" "Lan Mouse.app"
|
||||||
|
- name: Upload build artifact
|
||||||
|
uses: actions/upload-artifact@v4
|
||||||
|
with:
|
||||||
|
name: Lan Mouse macOS (ARM)
|
||||||
|
path: target/debug/bundle/osx/Lan Mouse macOS (ARM).zip
|
||||||
|
|||||||
2
.github/workflows/tagged-release.yml
vendored
2
.github/workflows/tagged-release.yml
vendored
@@ -7,7 +7,7 @@ on:
|
|||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
linux-release-build:
|
linux-release-build:
|
||||||
runs-on: ubuntu-22.04
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
- name: install dependencies
|
- name: install dependencies
|
||||||
|
|||||||
@@ -23,7 +23,6 @@ tokio = { version = "1.32.0", features = [
|
|||||||
"rt",
|
"rt",
|
||||||
"sync",
|
"sync",
|
||||||
"signal",
|
"signal",
|
||||||
"time",
|
|
||||||
] }
|
] }
|
||||||
once_cell = "1.19.0"
|
once_cell = "1.19.0"
|
||||||
async-trait = "0.1.81"
|
async-trait = "0.1.81"
|
||||||
|
|||||||
@@ -18,9 +18,7 @@ use core_graphics::{
|
|||||||
event_source::{CGEventSource, CGEventSourceStateID},
|
event_source::{CGEventSource, CGEventSourceStateID},
|
||||||
};
|
};
|
||||||
use futures_core::Stream;
|
use futures_core::Stream;
|
||||||
use input_event::{
|
use input_event::{BTN_LEFT, BTN_MIDDLE, BTN_RIGHT, Event, KeyboardEvent, PointerEvent};
|
||||||
BTN_BACK, BTN_FORWARD, BTN_LEFT, BTN_MIDDLE, BTN_RIGHT, Event, KeyboardEvent, PointerEvent,
|
|
||||||
};
|
|
||||||
use keycode::{KeyMap, KeyMapping};
|
use keycode::{KeyMap, KeyMapping};
|
||||||
use libc::c_void;
|
use libc::c_void;
|
||||||
use once_cell::unsync::Lazy;
|
use once_cell::unsync::Lazy;
|
||||||
@@ -306,28 +304,16 @@ fn get_events(
|
|||||||
})))
|
})))
|
||||||
}
|
}
|
||||||
CGEventType::OtherMouseDown => {
|
CGEventType::OtherMouseDown => {
|
||||||
let btn_num = ev.get_integer_value_field(EventField::MOUSE_EVENT_BUTTON_NUMBER);
|
|
||||||
let button = match btn_num {
|
|
||||||
3 => BTN_BACK,
|
|
||||||
4 => BTN_FORWARD,
|
|
||||||
_ => BTN_MIDDLE,
|
|
||||||
};
|
|
||||||
result.push(CaptureEvent::Input(Event::Pointer(PointerEvent::Button {
|
result.push(CaptureEvent::Input(Event::Pointer(PointerEvent::Button {
|
||||||
time: 0,
|
time: 0,
|
||||||
button,
|
button: BTN_MIDDLE,
|
||||||
state: 1,
|
state: 1,
|
||||||
})))
|
})))
|
||||||
}
|
}
|
||||||
CGEventType::OtherMouseUp => {
|
CGEventType::OtherMouseUp => {
|
||||||
let btn_num = ev.get_integer_value_field(EventField::MOUSE_EVENT_BUTTON_NUMBER);
|
|
||||||
let button = match btn_num {
|
|
||||||
3 => BTN_BACK,
|
|
||||||
4 => BTN_FORWARD,
|
|
||||||
_ => BTN_MIDDLE,
|
|
||||||
};
|
|
||||||
result.push(CaptureEvent::Input(Event::Pointer(PointerEvent::Button {
|
result.push(CaptureEvent::Input(Event::Pointer(PointerEvent::Button {
|
||||||
time: 0,
|
time: 0,
|
||||||
button,
|
button: BTN_MIDDLE,
|
||||||
state: 0,
|
state: 0,
|
||||||
})))
|
})))
|
||||||
}
|
}
|
||||||
@@ -660,7 +646,6 @@ unsafe fn configure_cf_settings() -> Result<(), MacosCaptureCreationError> {
|
|||||||
let event_source = CGEventSource::new(CGEventSourceStateID::CombinedSessionState)
|
let event_source = CGEventSource::new(CGEventSourceStateID::CombinedSessionState)
|
||||||
.map_err(|_| MacosCaptureCreationError::EventSourceCreation)?;
|
.map_err(|_| MacosCaptureCreationError::EventSourceCreation)?;
|
||||||
CGEventSourceSetLocalEventsSuppressionInterval(event_source, 0.05);
|
CGEventSourceSetLocalEventsSuppressionInterval(event_source, 0.05);
|
||||||
// FIXME Memory Leak
|
|
||||||
|
|
||||||
// This is a private settings that allows the cursor to be hidden while in the background.
|
// This is a private settings that allows the cursor to be hidden while in the background.
|
||||||
// It is used by Barrier and other apps.
|
// It is used by Barrier and other apps.
|
||||||
|
|||||||
@@ -1,8 +1,7 @@
|
|||||||
use futures::{StreamExt, future};
|
use futures::{StreamExt, future};
|
||||||
use std::{
|
use std::{
|
||||||
env, fs, io,
|
io,
|
||||||
os::{fd::OwnedFd, unix::net::UnixStream},
|
os::{fd::OwnedFd, unix::net::UnixStream},
|
||||||
path::PathBuf,
|
|
||||||
sync::{
|
sync::{
|
||||||
Arc, Mutex, RwLock,
|
Arc, Mutex, RwLock,
|
||||||
atomic::{AtomicBool, Ordering},
|
atomic::{AtomicBool, Ordering},
|
||||||
@@ -51,45 +50,10 @@ pub(crate) struct LibeiEmulation<'a> {
|
|||||||
session: Session<'a, RemoteDesktop<'a>>,
|
session: Session<'a, RemoteDesktop<'a>>,
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Get the path to the RemoteDesktop token file
|
|
||||||
fn get_token_file_path() -> PathBuf {
|
|
||||||
let cache_dir = env::var("XDG_CACHE_HOME")
|
|
||||||
.ok()
|
|
||||||
.map(PathBuf::from)
|
|
||||||
.unwrap_or_else(|| {
|
|
||||||
let home = env::var("HOME").expect("HOME not set");
|
|
||||||
PathBuf::from(home).join(".cache")
|
|
||||||
});
|
|
||||||
|
|
||||||
cache_dir.join("lan-mouse").join("remote-desktop.token")
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Read the RemoteDesktop token from file
|
|
||||||
fn read_token() -> Option<String> {
|
|
||||||
let token_path = get_token_file_path();
|
|
||||||
match fs::read_to_string(&token_path) {
|
|
||||||
Ok(token) => Some(token.trim().to_string()),
|
|
||||||
Err(_) => None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Write the RemoteDesktop token to file
|
|
||||||
fn write_token(token: &str) -> io::Result<()> {
|
|
||||||
let token_path = get_token_file_path();
|
|
||||||
if let Some(parent) = token_path.parent() {
|
|
||||||
fs::create_dir_all(parent)?;
|
|
||||||
}
|
|
||||||
|
|
||||||
fs::write(&token_path, token)?;
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn get_ei_fd<'a>()
|
async fn get_ei_fd<'a>()
|
||||||
-> Result<(RemoteDesktop<'a>, Session<'a, RemoteDesktop<'a>>, OwnedFd), ashpd::Error> {
|
-> Result<(RemoteDesktop<'a>, Session<'a, RemoteDesktop<'a>>, OwnedFd), ashpd::Error> {
|
||||||
let remote_desktop = RemoteDesktop::new().await?;
|
let remote_desktop = RemoteDesktop::new().await?;
|
||||||
|
|
||||||
let restore_token = read_token();
|
|
||||||
|
|
||||||
log::debug!("creating session ...");
|
log::debug!("creating session ...");
|
||||||
let session = remote_desktop.create_session().await?;
|
let session = remote_desktop.create_session().await?;
|
||||||
|
|
||||||
@@ -98,20 +62,13 @@ async fn get_ei_fd<'a>()
|
|||||||
.select_devices(
|
.select_devices(
|
||||||
&session,
|
&session,
|
||||||
DeviceType::Keyboard | DeviceType::Pointer,
|
DeviceType::Keyboard | DeviceType::Pointer,
|
||||||
restore_token.as_deref(),
|
None,
|
||||||
PersistMode::ExplicitlyRevoked,
|
PersistMode::ExplicitlyRevoked,
|
||||||
)
|
)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
log::info!("requesting permission for input emulation");
|
log::info!("requesting permission for input emulation");
|
||||||
let start_response = remote_desktop.start(&session, None).await?.response()?;
|
let _devices = remote_desktop.start(&session, None).await?.response()?;
|
||||||
|
|
||||||
// The restore token is only valid once, we need to re-save it each time
|
|
||||||
if let Some(token_str) = start_response.restore_token() {
|
|
||||||
if let Err(e) = write_token(token_str) {
|
|
||||||
log::warn!("failed to save RemoteDesktop token: {}", e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
let fd = remote_desktop.connect_to_eis(&session).await?;
|
let fd = remote_desktop.connect_to_eis(&session).await?;
|
||||||
Ok((remote_desktop, session, fd))
|
Ok((remote_desktop, session, fd))
|
||||||
|
|||||||
@@ -10,13 +10,10 @@ use core_graphics::event::{
|
|||||||
ScrollEventUnit,
|
ScrollEventUnit,
|
||||||
};
|
};
|
||||||
use core_graphics::event_source::{CGEventSource, CGEventSourceStateID};
|
use core_graphics::event_source::{CGEventSource, CGEventSourceStateID};
|
||||||
use input_event::{
|
use input_event::{BTN_LEFT, BTN_MIDDLE, BTN_RIGHT, Event, KeyboardEvent, PointerEvent, scancode};
|
||||||
BTN_BACK, BTN_FORWARD, BTN_LEFT, BTN_MIDDLE, BTN_RIGHT, Event, KeyboardEvent, PointerEvent,
|
|
||||||
scancode,
|
|
||||||
};
|
|
||||||
use keycode::{KeyMap, KeyMapping};
|
use keycode::{KeyMap, KeyMapping};
|
||||||
use std::cell::Cell;
|
use std::cell::Cell;
|
||||||
use std::collections::HashSet;
|
use std::ops::{Index, IndexMut};
|
||||||
use std::rc::Rc;
|
use std::rc::Rc;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
use std::time::{Duration, Instant};
|
use std::time::{Duration, Instant};
|
||||||
@@ -33,10 +30,10 @@ pub(crate) struct MacOSEmulation {
|
|||||||
event_source: CGEventSource,
|
event_source: CGEventSource,
|
||||||
/// task handle for key repeats
|
/// task handle for key repeats
|
||||||
repeat_task: Option<JoinHandle<()>>,
|
repeat_task: Option<JoinHandle<()>>,
|
||||||
/// current state of the mouse buttons (tracked by evdev button code)
|
/// current state of the mouse buttons
|
||||||
pressed_buttons: HashSet<u32>,
|
button_state: ButtonState,
|
||||||
/// button previously pressed (evdev button code)
|
/// button previously pressed
|
||||||
previous_button: Option<u32>,
|
previous_button: Option<CGMouseButton>,
|
||||||
/// timestamp of previous click (button down)
|
/// timestamp of previous click (button down)
|
||||||
previous_button_click: Option<Instant>,
|
previous_button_click: Option<Instant>,
|
||||||
/// click state, i.e. number of clicks in quick succession
|
/// click state, i.e. number of clicks in quick succession
|
||||||
@@ -47,13 +44,31 @@ pub(crate) struct MacOSEmulation {
|
|||||||
notify_repeat_task: Arc<Notify>,
|
notify_repeat_task: Arc<Notify>,
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Maps an evdev button code to the CGEventType used for drag events.
|
struct ButtonState {
|
||||||
fn drag_event_type(button: u32) -> CGEventType {
|
left: bool,
|
||||||
match button {
|
right: bool,
|
||||||
BTN_LEFT => CGEventType::LeftMouseDragged,
|
center: bool,
|
||||||
BTN_RIGHT => CGEventType::RightMouseDragged,
|
}
|
||||||
// middle, back, forward, and any other button all use OtherMouseDragged
|
|
||||||
_ => CGEventType::OtherMouseDragged,
|
impl Index<CGMouseButton> for ButtonState {
|
||||||
|
type Output = bool;
|
||||||
|
|
||||||
|
fn index(&self, index: CGMouseButton) -> &Self::Output {
|
||||||
|
match index {
|
||||||
|
CGMouseButton::Left => &self.left,
|
||||||
|
CGMouseButton::Right => &self.right,
|
||||||
|
CGMouseButton::Center => &self.center,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl IndexMut<CGMouseButton> for ButtonState {
|
||||||
|
fn index_mut(&mut self, index: CGMouseButton) -> &mut Self::Output {
|
||||||
|
match index {
|
||||||
|
CGMouseButton::Left => &mut self.left,
|
||||||
|
CGMouseButton::Right => &mut self.right,
|
||||||
|
CGMouseButton::Center => &mut self.center,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -63,9 +78,14 @@ impl MacOSEmulation {
|
|||||||
pub(crate) fn new() -> Result<Self, MacOSEmulationCreationError> {
|
pub(crate) fn new() -> Result<Self, MacOSEmulationCreationError> {
|
||||||
let event_source = CGEventSource::new(CGEventSourceStateID::CombinedSessionState)
|
let event_source = CGEventSource::new(CGEventSourceStateID::CombinedSessionState)
|
||||||
.map_err(|_| MacOSEmulationCreationError::EventSourceCreation)?;
|
.map_err(|_| MacOSEmulationCreationError::EventSourceCreation)?;
|
||||||
|
let button_state = ButtonState {
|
||||||
|
left: false,
|
||||||
|
right: false,
|
||||||
|
center: false,
|
||||||
|
};
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
event_source,
|
event_source,
|
||||||
pressed_buttons: HashSet::new(),
|
button_state,
|
||||||
previous_button: None,
|
previous_button: None,
|
||||||
previous_button_click: None,
|
previous_button_click: None,
|
||||||
button_click_state: 0,
|
button_click_state: 0,
|
||||||
@@ -241,14 +261,14 @@ impl Emulation for MacOSEmulation {
|
|||||||
mouse_location.x = new_mouse_x;
|
mouse_location.x = new_mouse_x;
|
||||||
mouse_location.y = new_mouse_y;
|
mouse_location.y = new_mouse_y;
|
||||||
|
|
||||||
// If any button is held, emit a drag event for it;
|
let mut event_type = CGEventType::MouseMoved;
|
||||||
// otherwise emit a normal mouse-moved event.
|
if self.button_state.left {
|
||||||
let event_type = self
|
event_type = CGEventType::LeftMouseDragged
|
||||||
.pressed_buttons
|
} else if self.button_state.right {
|
||||||
.iter()
|
event_type = CGEventType::RightMouseDragged
|
||||||
.next()
|
} else if self.button_state.center {
|
||||||
.map(|&btn| drag_event_type(btn))
|
event_type = CGEventType::OtherMouseDragged
|
||||||
.unwrap_or(CGEventType::MouseMoved);
|
};
|
||||||
let event = match CGEvent::new_mouse_event(
|
let event = match CGEvent::new_mouse_event(
|
||||||
self.event_source.clone(),
|
self.event_source.clone(),
|
||||||
event_type,
|
event_type,
|
||||||
@@ -270,12 +290,6 @@ impl Emulation for MacOSEmulation {
|
|||||||
button,
|
button,
|
||||||
state,
|
state,
|
||||||
} => {
|
} => {
|
||||||
// button number for OtherMouse events (3 = back, 4 = forward, etc.)
|
|
||||||
let cg_button_number: Option<i64> = match button {
|
|
||||||
BTN_BACK => Some(3),
|
|
||||||
BTN_FORWARD => Some(4),
|
|
||||||
_ => None,
|
|
||||||
};
|
|
||||||
let (event_type, mouse_button) = match (button, state) {
|
let (event_type, mouse_button) = match (button, state) {
|
||||||
(BTN_LEFT, 1) => (CGEventType::LeftMouseDown, CGMouseButton::Left),
|
(BTN_LEFT, 1) => (CGEventType::LeftMouseDown, CGMouseButton::Left),
|
||||||
(BTN_LEFT, 0) => (CGEventType::LeftMouseUp, CGMouseButton::Left),
|
(BTN_LEFT, 0) => (CGEventType::LeftMouseUp, CGMouseButton::Left),
|
||||||
@@ -283,29 +297,17 @@ impl Emulation for MacOSEmulation {
|
|||||||
(BTN_RIGHT, 0) => (CGEventType::RightMouseUp, CGMouseButton::Right),
|
(BTN_RIGHT, 0) => (CGEventType::RightMouseUp, CGMouseButton::Right),
|
||||||
(BTN_MIDDLE, 1) => (CGEventType::OtherMouseDown, CGMouseButton::Center),
|
(BTN_MIDDLE, 1) => (CGEventType::OtherMouseDown, CGMouseButton::Center),
|
||||||
(BTN_MIDDLE, 0) => (CGEventType::OtherMouseUp, CGMouseButton::Center),
|
(BTN_MIDDLE, 0) => (CGEventType::OtherMouseUp, CGMouseButton::Center),
|
||||||
(BTN_BACK, 1) | (BTN_FORWARD, 1) => {
|
|
||||||
(CGEventType::OtherMouseDown, CGMouseButton::Center)
|
|
||||||
}
|
|
||||||
(BTN_BACK, 0) | (BTN_FORWARD, 0) => {
|
|
||||||
(CGEventType::OtherMouseUp, CGMouseButton::Center)
|
|
||||||
}
|
|
||||||
_ => {
|
_ => {
|
||||||
log::warn!("invalid button event: {button},{state}");
|
log::warn!("invalid button event: {button},{state}");
|
||||||
return Ok(());
|
return Ok(());
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
// store button state using the evdev button code so
|
// store button state
|
||||||
// back, forward, and middle are tracked independently
|
self.button_state[mouse_button] = state == 1;
|
||||||
if state == 1 {
|
|
||||||
self.pressed_buttons.insert(button);
|
|
||||||
} else {
|
|
||||||
self.pressed_buttons.remove(&button);
|
|
||||||
}
|
|
||||||
|
|
||||||
// update double-click tracking using the evdev button
|
// update previous button state
|
||||||
// code so that back/forward don't alias with middle
|
|
||||||
if state == 1 {
|
if state == 1 {
|
||||||
if self.previous_button == Some(button)
|
if self.previous_button.is_some_and(|b| b.eq(&mouse_button))
|
||||||
&& self
|
&& self
|
||||||
.previous_button_click
|
.previous_button_click
|
||||||
.is_some_and(|i| i.elapsed() < DOUBLE_CLICK_INTERVAL)
|
.is_some_and(|i| i.elapsed() < DOUBLE_CLICK_INTERVAL)
|
||||||
@@ -314,7 +316,7 @@ impl Emulation for MacOSEmulation {
|
|||||||
} else {
|
} else {
|
||||||
self.button_click_state = 1;
|
self.button_click_state = 1;
|
||||||
}
|
}
|
||||||
self.previous_button = Some(button);
|
self.previous_button = Some(mouse_button);
|
||||||
self.previous_button_click = Some(Instant::now());
|
self.previous_button_click = Some(Instant::now());
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -336,13 +338,6 @@ impl Emulation for MacOSEmulation {
|
|||||||
EventField::MOUSE_EVENT_CLICK_STATE,
|
EventField::MOUSE_EVENT_CLICK_STATE,
|
||||||
self.button_click_state,
|
self.button_click_state,
|
||||||
);
|
);
|
||||||
// Set the button number for extra buttons (back=3, forward=4)
|
|
||||||
if let Some(btn_num) = cg_button_number {
|
|
||||||
event.set_integer_value_field(
|
|
||||||
EventField::MOUSE_EVENT_BUTTON_NUMBER,
|
|
||||||
btn_num,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
event.post(CGEventTapLocation::HID);
|
event.post(CGEventTapLocation::HID);
|
||||||
}
|
}
|
||||||
PointerEvent::Axis {
|
PointerEvent::Axis {
|
||||||
@@ -421,10 +416,7 @@ impl Emulation for MacOSEmulation {
|
|||||||
return Ok(());
|
return Ok(());
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
let is_modifier = update_modifiers(&self.modifier_state, key, state);
|
update_modifiers(&self.modifier_state, key, state);
|
||||||
if is_modifier {
|
|
||||||
modifier_event(self.event_source.clone(), self.modifier_state.get());
|
|
||||||
}
|
|
||||||
match state {
|
match state {
|
||||||
// pressed
|
// pressed
|
||||||
1 => self.spawn_repeat_task(code).await,
|
1 => self.spawn_repeat_task(code).await,
|
||||||
@@ -453,6 +445,21 @@ impl Emulation for MacOSEmulation {
|
|||||||
async fn terminate(&mut self) {}
|
async fn terminate(&mut self) {}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
trait ButtonEq {
|
||||||
|
fn eq(&self, other: &Self) -> bool;
|
||||||
|
}
|
||||||
|
|
||||||
|
impl ButtonEq for CGMouseButton {
|
||||||
|
fn eq(&self, other: &Self) -> bool {
|
||||||
|
matches!(
|
||||||
|
(self, other),
|
||||||
|
(CGMouseButton::Left, CGMouseButton::Left)
|
||||||
|
| (CGMouseButton::Right, CGMouseButton::Right)
|
||||||
|
| (CGMouseButton::Center, CGMouseButton::Center)
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
fn update_modifiers(modifiers: &Cell<XMods>, key: u32, state: u8) -> bool {
|
fn update_modifiers(modifiers: &Cell<XMods>, key: u32, state: u8) -> bool {
|
||||||
if let Ok(key) = scancode::Linux::try_from(key) {
|
if let Ok(key) = scancode::Linux::try_from(key) {
|
||||||
let mask = match key {
|
let mask = match key {
|
||||||
|
|||||||
@@ -12,5 +12,5 @@ log = "0.4.22"
|
|||||||
serde = { version = "1.0", features = ["derive"] }
|
serde = { version = "1.0", features = ["derive"] }
|
||||||
serde_json = "1.0.107"
|
serde_json = "1.0.107"
|
||||||
thiserror = "2.0.0"
|
thiserror = "2.0.0"
|
||||||
tokio = { version = "1.32.0", features = ["macros", "net", "io-util", "time"] }
|
tokio = { version = "1.32.0", features = ["net", "io-util", "time"] }
|
||||||
tokio-stream = { version = "0.1.15", features = ["io-util"] }
|
tokio-stream = { version = "0.1.15", features = ["io-util"] }
|
||||||
|
|||||||
@@ -5,8 +5,7 @@ use serde::{Deserialize, Serialize};
|
|||||||
use std::collections::HashMap;
|
use std::collections::HashMap;
|
||||||
use std::env::{self, VarError};
|
use std::env::{self, VarError};
|
||||||
use std::fmt::Display;
|
use std::fmt::Display;
|
||||||
use std::fs::{self, File};
|
use std::fs;
|
||||||
use std::io::Write;
|
|
||||||
use std::net::IpAddr;
|
use std::net::IpAddr;
|
||||||
use std::path::{Path, PathBuf};
|
use std::path::{Path, PathBuf};
|
||||||
use std::{collections::HashSet, io};
|
use std::{collections::HashSet, io};
|
||||||
@@ -420,7 +419,7 @@ impl Config {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if self.config_toml.is_none() {
|
if self.config_toml.is_none() {
|
||||||
self.config_toml = Some(Default::default());
|
self.config_toml = Default::default();
|
||||||
}
|
}
|
||||||
self.config_toml.as_mut().expect("config").clients =
|
self.config_toml.as_mut().expect("config").clients =
|
||||||
Some(clients.into_iter().map(|c| c.into()).collect::<Vec<_>>());
|
Some(clients.into_iter().map(|c| c.into()).collect::<Vec<_>>());
|
||||||
@@ -443,15 +442,10 @@ impl Config {
|
|||||||
pub fn write_back(&self) -> Result<(), io::Error> {
|
pub fn write_back(&self) -> Result<(), io::Error> {
|
||||||
log::info!("writing config to {:?}", &self.config_path);
|
log::info!("writing config to {:?}", &self.config_path);
|
||||||
/* load the current configuration file */
|
/* load the current configuration file */
|
||||||
let current_config = match fs::read_to_string(&self.config_path) {
|
let current_config = fs::read_to_string(&self.config_path)?;
|
||||||
Ok(c) => c.parse::<DocumentMut>().unwrap_or_default(),
|
let current_config = current_config.parse::<DocumentMut>().expect("fix me");
|
||||||
Err(e) => {
|
|
||||||
log::info!("{:?} {e} => creating new config", self.config_path());
|
|
||||||
Default::default()
|
|
||||||
}
|
|
||||||
};
|
|
||||||
let _current_config =
|
let _current_config =
|
||||||
toml_edit::de::from_document::<ConfigToml>(current_config).unwrap_or_default();
|
toml_edit::de::from_document::<ConfigToml>(current_config).expect("fixme");
|
||||||
|
|
||||||
/* the new config */
|
/* the new config */
|
||||||
let new_config = self.config_toml.clone().unwrap_or_default();
|
let new_config = self.config_toml.clone().unwrap_or_default();
|
||||||
@@ -467,11 +461,7 @@ impl Config {
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
/* write new config to file */
|
/* write new config to file */
|
||||||
if let Some(p) = self.config_path().parent() {
|
fs::write(&self.config_path, new_config)?;
|
||||||
fs::create_dir_all(p)?;
|
|
||||||
}
|
|
||||||
let mut f = File::create(self.config_path())?;
|
|
||||||
f.write_all(new_config.as_bytes())?;
|
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user