fix: send valid payload to clear presence

vyfor · Apr 14, 2024 · 5b49d82 · 5b49d82
1 parent 03dbd45
commit 5b49d82
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 2 deletions.
diff --git a/src/ipc/platform/unix_connection.rs b/src/ipc/platform/unix_connection.rs
@@ -44,6 +44,7 @@ impl Connection for RichClient {
             };
             pipe.write_all(&payload)?;
         }
+
         Ok(())
     }
 
@@ -65,6 +66,7 @@ impl Connection for RichClient {
             pipe.write_all(&utils::encode(2, 0))?;
             pipe.shutdown(std::net::Shutdown::Both)?;
         }
+
         Ok(())
     }
 
@@ -90,6 +92,17 @@ impl Connection for RichClient {
     }
 
     fn clear(&mut self) -> io::Result<()> {
-        self.write(1, None)
+        self.write(
+            1,
+            Some(
+                Packet {
+                    pid: std::process::id(),
+                    activity: None,
+                }
+                .to_json()
+                .unwrap()
+                .as_bytes(),
+            ),
+        )
     }
 }
diff --git a/src/ipc/platform/windows_connection.rs b/src/ipc/platform/windows_connection.rs
@@ -4,6 +4,7 @@ use std::os::windows::fs::OpenOptionsExt;
 
 use crate::ipc::client::{Connection, RichClient};
 use crate::ipc::utils;
+use crate::rpc::packet::Packet;
 
 impl Connection for RichClient {
     fn connect(client_id: u64) -> Result<Self, Box<dyn std::error::Error>> {
@@ -44,6 +45,7 @@ impl Connection for RichClient {
             };
             pipe.write_all(&payload)?;
         }
+
         Ok(())
     }
 
@@ -64,6 +66,7 @@ impl Connection for RichClient {
         if let Some(mut pipe) = self.pipe.take() {
             pipe.write_all(&utils::encode(2, 0))?;
         }
+
         Ok(())
     }
 
@@ -84,10 +87,22 @@ impl Connection for RichClient {
         if packet.activity != self.last_activity {
             return self.write(1, Some(packet.to_json().unwrap().as_bytes()));
         }
+
         Ok(())
     }
 
     fn clear(&mut self) -> io::Result<()> {
-        self.write(1, None)
+        self.write(
+            1,
+            Some(
+                Packet {
+                    pid: std::process::id(),
+                    activity: None,
+                }
+                .to_json()
+                .unwrap()
+                .as_bytes(),
+            ),
+        )
     }
 }