feat(wm): delete stale sub socket files

LGUG2Z · Oct 13, 2024 · c577592 · c577592
1 parent 6f27de8
commit c577592
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/komorebi/src/lib.rs b/komorebi/src/lib.rs
@@ -316,6 +316,13 @@ pub fn notify_subscribers(notification: &str) -> Result<()> {
     for socket in stale_sockets {
         tracing::warn!("removing stale subscription: {socket}");
         sockets.remove(&socket);
+        let socket_path = DATA_DIR.join(socket);
+        if let Err(error) = std::fs::remove_file(&socket_path) {
+            tracing::error!(
+                "could not remove stale subscriber socket file at {}: {error}",
+                socket_path.display()
+            )
+        }
     }
 
     let mut stale_pipes = vec![];