Cargo.toml

@@ -2,8 +2,10 @@
 name = "snot"
 version = "0.1.0"
 edition = "2021"
-authors = ["candifloss <candifloss.cc>"]
 
 [dependencies]
-dbus = "0.9.7"
+zbus = "4.4.0"
 rson_rs = "0.2.1"
+tokio = {version = "^1.39.2", features = ["full"] }
+futures = "0.3"
+futures-util = "0.3"

src/main.rs

@@ -1,32 +1,39 @@
-struct Notif {
+use zbus::{Connection, MessageStream, MatchRule, fdo};
-    app_name: String,
+use zbus::zvariant::{OwnedValue, Type};
-    replace_id: u32,
+
-    ico: String,            //It's string, right?
+#[derive(Debug)]
-    summary: String,
+struct Notification {
-    body: String,
+    // ... fields
-    //Actions
+    //
-    //Hints
-    expir_timeout: i32,
 }
 
-// Summary should be generally <= 40 chars, as per the specification.
+#[tokio::main]
-fn truncate_summary(notif: &mut Notif) {
+async fn main() -> Result<(), zbus::Error> {
-    if notif.summary.len() > 40 {
+    let conn = Connection::new_session()?;
-        notif.summary.truncate(39);
-        notif.summary.push_str("…");
-    }
-}
 
-fn main() {
+    // Create a match rule to filter for notification signals
-    let mut not = Notif {
+    let match_rule = MatchRule::new_signal()
-        app_name: "snot".to_string(),
+        .interface("org.freedesktop.Notifications")
-        replace_id: 0,
+        .member("Notify")
-        ico: "alert".to_string(),
+        .build()?;
-        summary: "This is a very long suuummmaaarrryyy! Don't you believe me????".to_string(),
+
-        body: "short body(hehe)".to_string(),
+    // Add the match rule to the connection
-        expir_timeout: 0
+    conn.add_match(&match_rule)?;
+
+    let stream = MessageStream::new(&conn)?;
+
+    while let Some(msg) = stream.next().await? {
+        // Extract notification data from the message
+        // ...
+
+        // Create a Notification struct
+        let notification = Notification {
+            // ...
         };
-    truncate_summary(&mut not); //Limit the summary length
 
-    println!("{}",not.summary);
+        // Handle the notification
+        println!("Received notification: {:?}", notification);
+    }
+
+    Ok(())
 }