chore(CHANGELOG): update with the AstarteObject changes

Signed-off-by: Joshua Chapman <joshua.chapman@secomind.com>

Author: joshuachp

CHANGELOG.md

@@ -11,10 +11,16 @@ adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 - Introduce `webpki` feature to use Mozilla webpki root certificates rather than the native ones
   [#396](https://github.com/astarte-platform/astarte-device-sdk-rust/pull/396).
+- Add the AstarteObject struct for Object Datastream [#430].
 
 ### Changed
 
 - Bump MSRV to 1.78.0 [#395](https://github.com/astarte-platform/astarte-device-sdk-rust/pull/395).
+- Rename the AstarteAggregate derive macro to IntoAstarteObject [#430].
+- Remove the AstarteAggregate trait in favor of the AstarteObject [#430].
+- Change the send_object client methods to receive an AstarteObject argument [#430].
+
+[#430]: (https://github.com/astarte-platform/astarte-device-sdk-rust/pull/430)
 
 ## [0.9.6] - 2025-03-06
 

src/aggregate.rs

@@ -28,7 +28,7 @@ use crate::types::AstarteType;
 ///
 /// # Example
 ///
-/// Parse this data structure into a `HashMap` compatible with transmission of Astarte objects.
+/// Create the data structure `AstarteObject` used to transmit of Astarte objects.
 ///
 /// ```
 /// use astarte_device_sdk::aggregate::AstarteObject;
@@ -169,7 +169,7 @@ impl Value {
         }
     }
 
-    /// Take out of the enum an [`HashMap`] if the aggregate is [`Object`](Value::Object).
+    /// Take out of the enum an [`AstarteObject`] if the aggregate is [`Object`](Value::Object).
     pub fn take_object(self) -> Option<AstarteObject> {
         if let Self::Object(v) = self {
             Some(v)

src/client.rs

@@ -106,6 +106,8 @@ pub trait Client {
     ///     store::memory::MemoryStore, builder::DeviceBuilder,
     ///     transport::mqtt::MqttConfig, types::AstarteType, prelude::*,
     /// };
+    /// # #[cfg(feature = "derive")]
+    /// use astarte_device_sdk::IntoAstarteObject;
     /// # #[cfg(not(feature = "derive"))]
     /// # use astarte_device_sdk_derive::IntoAstarteObject;
     /// use chrono::{TimeZone, Utc};

src/lib.rs

@@ -87,11 +87,12 @@ mod test {
     use crate::transport::mqtt::payload::Payload as MqttPayload;
     use crate::transport::mqtt::test::{mock_mqtt_connection, notify_success};
     use crate::transport::mqtt::Mqtt;
+    #[cfg(feature = "derive")]
+    use crate::IntoAstarteObject;
     use crate::{
         self as astarte_device_sdk, Client, DeviceClient, DeviceConnection, EventLoop, Interface,
     };
     use crate::{types::AstarteType, Value};
-    use astarte_device_sdk::IntoAstarteObject;
     #[cfg(not(feature = "derive"))]
     use astarte_device_sdk_derive::IntoAstarteObject;
 

src/prelude.rs

@@ -36,3 +36,6 @@ pub mod properties {
 
 pub use device::*;
 pub use properties::*;
+
+#[cfg(feature = "derive")]
+pub use crate::IntoAstarteObject;

src/store/sqlite/statements.rs

@@ -197,9 +197,11 @@ impl ReadConnection {
     pub(crate) fn connect(db_file: impl AsRef<Path>) -> Result<Self, SqliteError> {
         let flags = OpenFlags::SQLITE_OPEN_READ_ONLY | OpenFlags::SQLITE_OPEN_NO_MUTEX;
 
-        let mut connection =
+        let connection =
             Connection::open_with_flags(db_file, flags).map_err(SqliteError::Connection)?;
 
+        #[cfg(feature = "sqlite-trace")]
+        let mut connection = connection;
         #[cfg(feature = "sqlite-trace")]
         connection.trace(Some(trace_sqlite));