From d4d8ebbaeb04ac9fa65fdd16e9ed4464aa4ace2f Mon Sep 17 00:00:00 2001
From: Ferdinand Schober <ferdinand.schober@fau.de>
Date: Sun, 12 Feb 2023 22:37:18 +0100
Subject: [PATCH] add session detection

---
 src/backend.rs              |  6 ++++++
 src/backend/x11/consumer.rs | 10 +++++-----
 src/backend/x11/producer.rs | 10 ++++++++++
 src/main.rs                 | 35 +++++++++++++++++++++++++++++------
 4 files changed, 50 insertions(+), 11 deletions(-)

diff --git a/src/backend.rs b/src/backend.rs
index c5cd6c2..5f65327 100644
--- a/src/backend.rs
+++ b/src/backend.rs
@@ -1,3 +1,9 @@
 pub mod windows;
 pub mod wayland;
 pub mod x11;
+
+#[derive(Clone, Copy, Debug)]
+pub enum Backend {
+    X11,
+    WAYLAND,
+}
diff --git a/src/backend/x11/consumer.rs b/src/backend/x11/consumer.rs
index 1a5b064..3130af6 100644
--- a/src/backend/x11/consumer.rs
+++ b/src/backend/x11/consumer.rs
@@ -33,13 +33,13 @@ pub fn run(event_rx: Receiver<(Event, ClientHandle)>, _clients: Vec<Client>) {
                     crate::event::PointerEvent::Motion { time: _, relative_x, relative_y } => {
                         relative_motion(display, relative_x as i32, relative_y as i32);
                     },
-                    crate::event::PointerEvent::Button { .. } => todo!(),
-                    crate::event::PointerEvent::Axis { .. } => todo!(),
-                    crate::event::PointerEvent::Frame {  } => todo!(),
+                    crate::event::PointerEvent::Button { .. } => {},
+                    crate::event::PointerEvent::Axis { .. } => {},
+                    crate::event::PointerEvent::Frame {  } => {},
                 }
             },
-            Event::Keyboard(_) => todo!(),
-            Event::Release() => todo!(),
+            Event::Keyboard(_) => {},
+            Event::Release() => {},
         }
     }
 }
diff --git a/src/backend/x11/producer.rs b/src/backend/x11/producer.rs
index e69de29..6082101 100644
--- a/src/backend/x11/producer.rs
+++ b/src/backend/x11/producer.rs
@@ -0,0 +1,10 @@
+use std::sync::mpsc::SyncSender;
+
+use crate::event::Event;
+use crate::request::Server;
+use crate::client::Client;
+
+
+pub fn run(_produce_tx: SyncSender<(Event, u32)>, _request_server: Server, _clients: Vec<Client>) {
+    todo!()
+}
diff --git a/src/main.rs b/src/main.rs
index 51356a9..678891b 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,8 +1,8 @@
-use std::{net::SocketAddr, sync::mpsc, thread};
+use std::{net::SocketAddr, sync::mpsc, thread, env};
 
 use lan_mouse::{
     client::{ClientManager, Position},
-    config, dns, event, request,
+    config, dns, event, request, backend::Backend,
 };
 
 #[cfg(windows)]
@@ -10,6 +10,7 @@ use lan_mouse::backend::windows;
 
 #[cfg(unix)]
 use lan_mouse::backend::wayland;
+use lan_mouse::backend::x11;
 
 fn add_client(client_manager: &mut ClientManager, client: &config::Client, pos: Position) {
     let ip = match client.ip {
@@ -65,26 +66,48 @@ pub fn main() {
 
     let clients = client_manager.get_clients();
 
+    #[cfg(unix)]
+    let backend = match env::var("XDG_SESSION_TYPE") {
+        Ok(session_type) => match session_type.as_str() {
+            "x11" => Backend::X11,
+            "wayland" => Backend::WAYLAND,
+            _ => panic!("unknown XDG_SESSION_TYPE"),
+        }
+        Err(_) => panic!("could not detect session type"),
+    };
+    println!("using backend: {}", match backend {
+        Backend::X11 => "x11",
+        Backend::WAYLAND => "wayland",
+    });
+
+
     // start producing and consuming events
     let event_producer = thread::Builder::new()
         .name("event producer".into())
-        .spawn(|| {
+        .spawn(move || {
             #[cfg(windows)]
             windows::producer::run(produce_tx, request_server, clients);
+
             #[cfg(unix)]
-            wayland::producer::run(produce_tx, request_server, clients);
+            match backend {
+                Backend::X11 => x11::producer::run(produce_tx, request_server, clients),
+                Backend::WAYLAND => wayland::producer::run(produce_tx, request_server, clients),
+            }
         })
         .unwrap();
 
     let clients = client_manager.get_clients();
     let event_consumer = thread::Builder::new()
         .name("event consumer".into())
-        .spawn(|| {
+        .spawn(move || {
             #[cfg(windows)]
             windows::consumer::run(consume_rx, clients);
 
             #[cfg(unix)]
-            wayland::consumer::run(consume_rx, clients);
+            match backend {
+                Backend::X11 => x11::consumer::run(consume_rx, clients),
+                Backend::WAYLAND => wayland::consumer::run(consume_rx, clients),
+            }
         })
         .unwrap();