Merge pull request #201 from hoodie/renovate/zbus-4.x

fix(deps): update rust crate zbus to v4

.github/workflows/ci.yml

@@ -20,7 +20,7 @@ jobs:
         rust:
           - stable
           - beta 
-          - stable minus 6 releases
+          - stable minus 2 releases
         feature:
           - d
           - d,images

Cargo.toml

@@ -24,7 +24,7 @@ include = [
 dbus = { version = "0.9", optional = true }
 lazy_static = { version = "1", optional = true }
 image = { version = "0.24", optional = true }
-zbus = { version = "3.10", optional = true }
+zbus = { version = "4.1", optional = true }
 serde = { version = "1", optional = true }
 log = "0.4"
 env_logger ={ version ="0.10", optional = true }

src/notification.rs

@@ -452,7 +452,7 @@ impl Notification {
         windows::show_notification(self)
     }
 
-    /// Wraps `show()` but prints notification to stdout.
+    /// Wraps [`show()`] but prints notification to stdout.
     #[cfg(all(unix, not(target_os = "macos")))]
     #[deprecated = "this was never meant to be public API"]
     pub fn show_debug(&mut self) -> Result<xdg::NotificationHandle> {

src/xdg/zbus_rs.rs

@@ -155,6 +155,7 @@ async fn send_notification_via_connection_at_bus(
         )
         .await?
         .body()
+        .deserialize()
         .unwrap();
     Ok(reply)
 }
@@ -193,7 +194,8 @@ pub async fn get_capabilities_at_bus(bus: NotificationBus) -> Result<Vec<String>
             &(),
         )
         .await?
-        .body()?;
+        .body()
+        .deserialize()?;
     Ok(info)
 }
 
@@ -212,7 +214,8 @@ pub async fn get_server_information_at_bus(bus: NotificationBus) -> Result<xdg::
             &(),
         )
         .await?
-        .body()?;
+        .body()
+        .deserialize()?;
 
     Ok(info)
 }
@@ -255,29 +258,28 @@ async fn wait_for_action_signal(
     proxy.add_match_rule(close_signal_rule).await.unwrap();
 
     while let Ok(Some(msg)) = zbus::MessageStream::from(connection).try_next().await {
-        if let Ok(header) = msg.header() {
-            if let Ok(zbus::MessageType::Signal) = header.message_type() {
-                match header.member() {
-                    Ok(Some(name)) if name == "ActionInvoked" => {
-                        match msg.body::<(u32, String)>() {
-                            Ok((nid, action)) if nid == id => {
-                                handler.call(&ActionResponse::Custom(&action));
-                                break;
-                            }
-                            _ => {}
+        let header = msg.header();
+        if let zbus::MessageType::Signal = header.message_type() {
+            match header.member() {
+                Some(name) if name == "ActionInvoked" => {
+                    match msg.body().deserialize::<(u32, String)>() {
+                        Ok((nid, action)) if nid == id => {
+                            handler.call(&ActionResponse::Custom(&action));
+                            break;
                         }
+                        _ => {}
                     }
-                    Ok(Some(name)) if name == "NotificationClosed" => {
-                        match msg.body::<(u32, u32)>() {
-                            Ok((nid, reason)) if nid == id => {
-                                handler.call(&ActionResponse::Closed(reason.into()));
-                                break;
-                            }
-                            _ => {}
+                }
+                Some(name) if name == "NotificationClosed" => {
+                    match msg.body().deserialize::<(u32, u32)>() {
+                        Ok((nid, reason)) if nid == id => {
+                            handler.call(&ActionResponse::Closed(reason.into()));
+                            break;
                         }
+                        _ => {}
                     }
-                    Ok(_) | Err(_) => {}
                 }
+                _ => {}
             }
         }
     }