uds

rklipd/Cargo.lock

@@ -1303,6 +1303,8 @@ dependencies = [
  "directories",
  "image",
  "rusqlite",
+ "serde",
+ "serde_json",
  "uuid",
  "wayland-clipboard-listener",
 ]
@@ -1370,6 +1372,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "9a8e94ea7f378bd32cbbd37198a4a91436180c5bb472411e48b5ec2e2124ae9e"
 dependencies = [
  "serde_core",
+ "serde_derive",
 ]
 
 [[package]]

rklipd/Cargo.toml

@@ -11,6 +11,8 @@ uuid = {version = "1.22.0", features = ["v4", "serde"]}
 rusqlite = "0.38.0"
 wayland-clipboard-listener = "0.6.0"
 directories = "6.0.0"
+serde = { version = "1.0.228", features = ["derive"] }
+serde_json = "1.0.149"
 
 [features]
 x11 = []

rklipd/src/ipc.rs

@@ -0,0 +1,74 @@
+use crate::database::Database;
+use crate::models::ClipboardData;
+use serde::{Deserialize, Serialize};
+use std::fs;
+use std::io::{Read, Write};
+use std::os::unix::net::UnixListener;
+use std::path::Path;
+use std::sync::{Arc, Mutex};
+
+// --- LE CONTRAT (Protocole) ---
+#[derive(Serialize, Deserialize, Debug)]
+pub enum IpcRequest {
+    GetHistory { limit: usize },
+}
+
+#[derive(Serialize, Deserialize, Debug)]
+pub enum IpcResponse {
+    History(Vec<String>),
+}
+
+pub fn start_server(db: Arc<Mutex<Database>>, socket_path: &Path) {
+    if socket_path.exists() {
+        let _ = fs::remove_file(socket_path);
+    }
+
+    let listener = match UnixListener::bind(socket_path) {
+        Ok(l) => l,
+        Err(e) => {
+            eprintln!("Error while creating socket {}", e);
+            return;
+        }
+    };
+    println!("ipc server listening {:?}", socket_path);
+
+    for stream in listener.incoming() {
+        match stream {
+            Ok(mut stream) => {
+                let db_clone = Arc::clone(&db);
+
+                std::thread::spawn(move || {
+                    let mut buffer = String::new();
+
+                    if stream.read_to_string(&mut buffer).is_ok() {
+                        if let Ok(request) = serde_json::from_str::<IpcRequest>(&buffer) {
+                            match request {
+                                IpcRequest::GetHistory { limit } => {
+                                    let db_lock = db_clone.lock().unwrap();
+
+                                    // TODO Implem read_history(limit)
+                                    let history = db_lock.read_history().unwrap_or_default();
+
+                                    let items: Vec<String> = history
+                                        .into_iter()
+                                        .rev()
+                                        .take(limit)
+                                        .map(|entry| match entry.content {
+                                            ClipboardData::Text(t) => t,
+                                            ClipboardData::Image(img) => format!("{}.jpg", img.id),
+                                        })
+                                        .collect();
+
+                                    let response = IpcResponse::History(items);
+                                    let response_json = serde_json::to_string(&response).unwrap();
+                                    let _ = stream.write_all(response_json.as_bytes());
+                                }
+                            }
+                        }
+                    }
+                });
+            }
+            Err(e) => eprintln!("Erreur de connexion IPC: {}", e),
+        }
+    }
+}

rklipd/src/main.rs

@@ -5,6 +5,7 @@ use std::sync::{Arc, Mutex};
 
 mod clipboard;
 mod database;
+mod ipc;
 mod models;
 mod monitor;
 mod ws;
@@ -18,8 +19,13 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     let db = Arc::new(Mutex::new(Database::init(&dir_path_str)?));
 
-    // println!("{:#?}", db.lock().unwrap().read_history());
+    let socket_path = dir_path.join("rklip.sock");
+    let db_for_ipc = Arc::clone(&db);
+    std::thread::spawn(move || {
+        crate::ipc::start_server(db_for_ipc, &socket_path);
+    });
 
+    println!("rklipd starting...");
     monitor::start(db, clipboard)?;
 
     Ok(())