RUST-8 Serialize validator option properly in create collection operations

Author: Utkarsh Mehta

src/db/options.rs

@@ -61,6 +61,7 @@ pub struct CreateCollectionOptions {
     /// collection. Expressions can be specified using any query operators except `$near`,
     /// `$nearSphere`, `$text`, and `$where`.
     #[builder(default)]
+    #[serde(rename = "validator")]
     pub validation: Option<Document>,
 
     /// Specifies how strictly the database should apply the validation rules to existing documents

src/operation/create/test.rs

@@ -1,5 +1,5 @@
 use crate::{
-    bson::doc,
+    bson::{doc, Bson},
     cmap::{CommandResponse, StreamDescription},
     concern::WriteConcern,
     error::{ErrorKind, WriteFailure},
@@ -44,6 +44,36 @@ async fn build() {
     );
 }
 
+#[cfg_attr(feature = "tokio-runtime", tokio::test)]
+#[cfg_attr(feature = "async-std-runtime", async_std::test)]
+async fn build_validator() {
+    let query = doc! { "x": { "$gt": 1 } };
+    let op = Create::new(
+        Namespace {
+            db: "test_db".to_string(),
+            coll: "test_coll".to_string(),
+        },
+        Some(CreateCollectionOptions {
+            validation: Some(query.clone()),
+            ..Default::default()
+        }),
+    );
+
+    let description = StreamDescription::new_testing();
+    let cmd = op.build(&description).unwrap();
+
+    assert_eq!(cmd.name.as_str(), "create");
+    assert_eq!(cmd.target_db.as_str(), "test_db");
+    assert_eq!(cmd.read_pref.as_ref(), None);
+    assert_eq!(
+        cmd.body,
+        doc! {
+            "create": "test_coll",
+            "validator": Bson::Document(query)
+        }
+    );
+}
+
 #[cfg_attr(feature = "tokio-runtime", tokio::test)]
 #[cfg_attr(feature = "async-std-runtime", async_std::test)]
 async fn handle_success() {