rust: Add has_changes for Changeset

rust/src/api.rs

@@ -209,6 +209,7 @@ impl Server {
         if let AttributeChange::Multi { add, .. } = entry {
             add.push(value);
         }
+
         Ok(self)
     }
 

rust/src/commit.rs

@@ -45,6 +45,26 @@ pub trait IntoAttributeValue {
     fn into_attribute_value(self) -> AttributeValue;
 }
 
+impl Changeset {
+    pub fn has_changes(&self) -> bool {
+        self.attributes
+            .iter()
+            .filter(|(_, change)| {
+                if let AttributeChange::Multi { add, remove } = change {
+                    return add.len() + remove.len() > 0;
+                }
+
+                if let AttributeChange::Update { new, old } = change {
+                    return new.ne(old);
+                }
+
+                true
+            })
+            .find(|_| true)
+            .is_some()
+    }
+}
+
 impl Commit {
     pub fn new() -> Self {
         Self {
@@ -69,6 +89,10 @@ impl Commit {
                     return new.ne(old);
                 }
 
+                if let AttributeChange::Multi { add, remove } = change {
+                    return add.len() + remove.len() > 0;
+                }
+
                 true
             })
             .collect();

rust/src/new_object.rs

@@ -57,7 +57,7 @@ impl NewObject {
             return true;
         }
 
-        self.server.has_changes()
+        self.server.has_changes() || self.deferred_changes.has_changes()
     }
 
     ///

rust/src/query.rs

@@ -1,6 +1,6 @@
 use std::collections::HashSet;
 
-use crate::api::{commit_changes, CommitResponse, query_objects, QueryResponse, Server};
+use crate::api::{commit_changes, query_objects, CommitResponse, QueryResponse, Server};
 use crate::commit::{AttributeChange, Changeset, Commit};
 use crate::filter::{AttributeFilter, IntoFilterValue};
 
@@ -58,7 +58,7 @@ impl QueryBuilder {
         self
     }
 
-    pub fn restrict<S: ToString, I: IntoIterator<Item=S>>(mut self, attributes: I) -> Self {
+    pub fn restrict<S: ToString, I: IntoIterator<Item = S>>(mut self, attributes: I) -> Self {
         self.0.restrict = HashSet::from_iter(attributes.into_iter().map(|v| v.to_string()));
 
         self
@@ -90,16 +90,6 @@ impl Server {
     }
 
     pub fn has_changes(&self) -> bool {
-        self.changes
-            .attributes
-            .iter()
-            .filter(|(_, change)| {
-                if let AttributeChange::Update { new, old } = change {
-                    return new.ne(old);
-                }
-
-                true
-            })
-            .find(|_| true).is_some()
+        self.changes.has_changes()
     }
 }