Bump embassy dependencies to newly released versions

Author: MathiasKoch

Cargo.toml

@@ -33,11 +33,11 @@ minicbor-serde = { version = "0.3.2", optional = true }
 serde-json-core = { version = "0.6" }
 shadow-derive = { path = "shadow_derive", version = "0.2.1" }
 embedded-storage-async = "0.4"
-embedded-mqtt = { git = "ssh://git@github.com/FactbirdHQ/embedded-mqtt", rev = "74eb53d" }
+embedded-mqtt = { git = "ssh://git@github.com/FactbirdHQ/embedded-mqtt", rev = "dc7c390" }
 
 futures = { version = "0.3.28", default-features = false }
 
-embassy-time = { version = "0.3" }
+embassy-time = { version = "0.4" }
 embassy-sync = "0.6"
 embassy-futures = "0.1"
 
@@ -62,7 +62,7 @@ tokio = { version = "1.33", default-features = false, features = [
 ] }
 tokio-native-tls = { version = "0.3.1" }
 embassy-futures = { version = "0.1.0" }
-embassy-time = { version = "0.3", features = ["log", "std", "generic-queue"] }
+embassy-time = { version = "0.4", features = ["log", "std", "generic-queue"] }
 embedded-io-adapters = { version = "0.6.0", features = ["tokio-1"] }
 
 ecdsa = { version = "0.16", features = ["pkcs8", "pem"] }

src/provisioning/mod.rs

@@ -136,8 +136,6 @@ impl FleetProvisioner {
     where
         C: DeserializeOwned,
     {
-        use embedded_mqtt::SliceBufferProvider;
-
         let mut create_subscription = Self::begin(mqtt, csr, payload_format).await?;
         let mut message = create_subscription
             .next()
@@ -146,11 +144,8 @@ impl FleetProvisioner {
 
         let ownership_token = match Topic::from_str(message.topic_name()) {
             Some(Topic::CreateKeysAndCertificateAccepted(format)) => {
-                let response = Self::deserialize::<
-                    CreateKeysAndCertificateResponse,
-                    M,
-                    SliceBufferProvider<'a>,
-                >(format, &mut message)?;
+                let response =
+                    Self::deserialize::<CreateKeysAndCertificateResponse>(format, &mut message)?;
 
                 credential_handler
                     .store_credentials(Credentials {
@@ -164,11 +159,10 @@ impl FleetProvisioner {
             }
 
             Some(Topic::CreateCertificateFromCsrAccepted(format)) => {
-                let response = Self::deserialize::<
-                    CreateCertificateFromCsrResponse,
-                    M,
-                    SliceBufferProvider<'a>,
-                >(format, &mut message)?;
+                let response = Self::deserialize::<CreateCertificateFromCsrResponse>(
+                    format,
+                    message.payload_mut(),
+                )?;
 
                 credential_handler
                     .store_credentials(Credentials {
@@ -186,7 +180,7 @@ impl FleetProvisioner {
                 Topic::CreateKeysAndCertificateRejected(format)
                 | Topic::CreateCertificateFromCsrRejected(format),
             ) => {
-                return Err(Self::handle_error(format, message).unwrap_err());
+                return Err(Self::handle_error(format, message.payload_mut()).unwrap_err());
             }
 
             t => {
@@ -259,18 +253,17 @@ impl FleetProvisioner {
 
         match Topic::from_str(message.topic_name()) {
             Some(Topic::RegisterThingAccepted(_, format)) => {
-                let response = Self::deserialize::<
-                    RegisterThingResponse<'_, C>,
-                    M,
-                    SliceBufferProvider<'a>,
-                >(format, &mut message)?;
+                let response = Self::deserialize::<RegisterThingResponse<'_, C>>(
+                    format,
+                    message.payload_mut(),
+                )?;
 
                 Ok(response.device_configuration)
             }
 
             // Error happened!
             Some(Topic::RegisterThingRejected(_, format)) => {
-                Err(Self::handle_error(format, message).unwrap_err())
+                Err(Self::handle_error(format, message.payload_mut()).unwrap_err())
             }
 
             t => {
@@ -387,37 +380,22 @@ impl FleetProvisioner {
         }
     }
 
-    fn deserialize<'a, R: Deserialize<'a>, M: RawMutex, B: BufferProvider>(
+    fn deserialize<'a, R: Deserialize<'a>>(
         payload_format: PayloadFormat,
-        message: &'a mut Message<'_, M, B>,
+        payload: &'a mut [u8],
     ) -> Result<R, Error> {
-        trace!(
-            "Accepted Topic {:?}. Payload len: {:?}",
-            payload_format,
-            message.payload().len()
-        );
-
         Ok(match payload_format {
             #[cfg(feature = "provision_cbor")]
-            PayloadFormat::Cbor => minicbor_serde::from_slice::<R>(message.payload_mut())?,
-            PayloadFormat::Json => serde_json_core::from_slice::<R>(message.payload())?.0,
+            PayloadFormat::Cbor => minicbor_serde::from_slice::<R>(payload)?,
+            PayloadFormat::Json => serde_json_core::from_slice::<R>(payload)?.0,
         })
     }
 
-    fn handle_error<M: RawMutex, B: BufferProvider>(
-        format: PayloadFormat,
-        mut message: Message<'_, M, B>,
-    ) -> Result<(), Error> {
-        error!(">> {:?}", message.topic_name());
-
+    fn handle_error(format: PayloadFormat, payload: &mut [u8]) -> Result<(), Error> {
         let response = match format {
             #[cfg(feature = "provision_cbor")]
-            PayloadFormat::Cbor => {
-                minicbor_serde::from_slice::<ErrorResponse>(message.payload_mut())?
-            }
-            PayloadFormat::Json => {
-                serde_json_core::from_slice::<ErrorResponse>(message.payload())?.0
-            }
+            PayloadFormat::Cbor => minicbor_serde::from_slice::<ErrorResponse>(payload)?,
+            PayloadFormat::Json => serde_json_core::from_slice::<ErrorResponse>(payload)?.0,
         };
 
         error!("{:?}", response);