diff options
| author | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-04-03 17:11:20 +0300 |
|---|---|---|
| committer | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-04-03 17:11:20 +0300 |
| commit | 5ed262a43ac7f264a1a7523b6d4507ba4a976604 (patch) | |
| tree | 8de14a54cf67bb8ee656c3536035f68c7703a01a /src/api | |
| parent | f159ef69ffe59fd327a4a4f3c4a53aaea567b32a (diff) | |
fix: isolate debug runtime paths and block duplicate herdr instances
Diffstat (limited to 'src/api')
| -rw-r--r-- | src/api/mod.rs | 42 |
1 files changed, 32 insertions, 10 deletions
diff --git a/src/api/mod.rs b/src/api/mod.rs index 2e7692a4..1a713323 100644 --- a/src/api/mod.rs +++ b/src/api/mod.rs @@ -71,19 +71,17 @@ pub fn socket_path() -> PathBuf { return PathBuf::from(path); } - if let Ok(dir) = std::env::var("XDG_RUNTIME_DIR") { - return PathBuf::from(dir).join("herdr.sock"); - } - - if let Ok(dir) = std::env::var("XDG_CONFIG_HOME") { - return PathBuf::from(dir).join("herdr/herdr.sock"); - } + let socket_name = if crate::config::app_dir_name() == "herdr" { + "herdr.sock" + } else { + "herdr-dev.sock" + }; - if let Ok(home) = std::env::var("HOME") { - return PathBuf::from(home).join(".config/herdr/herdr.sock"); + if let Ok(dir) = std::env::var("XDG_RUNTIME_DIR") { + return PathBuf::from(dir).join(socket_name); } - PathBuf::from("/tmp/herdr.sock") + crate::config::config_dir().join("herdr.sock") } pub struct ServerHandle { @@ -143,6 +141,30 @@ fn prepare_socket_path(path: &Path) -> std::io::Result<()> { fs::create_dir_all(parent)?; } + if !path.exists() { + return Ok(()); + } + + match UnixStream::connect(path) { + Ok(_) => { + return Err(std::io::Error::new( + std::io::ErrorKind::AddrInUse, + format!( + "herdr is already running (socket busy at {})", + path.display() + ), + )); + } + Err(err) + if matches!( + err.kind(), + std::io::ErrorKind::ConnectionRefused + | std::io::ErrorKind::NotFound + | std::io::ErrorKind::TimedOut + ) => {} + Err(err) => return Err(err), + } + if let Err(err) = fs::remove_file(path) { if err.kind() != std::io::ErrorKind::NotFound { return Err(err); |
