CDRIVER-443 added validate to bulk_insert

Closes #113

Author: aherlihy

src/mongoc/mongoc-collection.c

@@ -1089,6 +1089,28 @@ mongoc_collection_insert_bulk (mongoc_collection_t           *collection,
       write_concern = collection->write_concern;
    }
 
+   if (!(flags & MONGOC_INSERT_NO_VALIDATE)) {
+      int i;
+
+      for (i = 0; i < n_documents; i++) {
+         if (!bson_validate (documents[i],
+                             (BSON_VALIDATE_UTF8 |
+                              BSON_VALIDATE_UTF8_ALLOW_NULL |
+                              BSON_VALIDATE_DOLLAR_KEYS |
+                              BSON_VALIDATE_DOT_KEYS),
+                             NULL)) {
+            bson_set_error (error,
+                            MONGOC_ERROR_BSON,
+                            MONGOC_ERROR_BSON_INVALID,
+                            "A document was corrupt or contained "
+                            "invalid characters . or $");
+            RETURN (false);
+         }
+      }
+   } else {
+      flags &= ~MONGOC_INSERT_NO_VALIDATE;
+   }
+
    bson_clear (&collection->gle);
 
    _mongoc_write_result_init (&result);

tests/test-mongoc-collection.c

@@ -190,6 +190,21 @@ test_insert_bulk (void)
    count = mongoc_collection_count (collection, MONGOC_QUERY_NONE, &q, 0, 0, NULL, &error);
    ASSERT (count == 6);
 
+   /* test validate */
+   for (i = 0; i < 10; i++) {
+      bson_destroy (&b[i]);
+      bson_init (&b[i]);
+      BSON_APPEND_INT32 (&b[i], "$invalid_dollar_prefixed_name", i);
+      bptr[i] = &b[i];
+   }
+   BEGIN_IGNORE_DEPRECATIONS;
+   r = mongoc_collection_insert_bulk (collection, MONGOC_INSERT_NONE,
+                                      (const bson_t **)bptr, 10, NULL, &error);
+   END_IGNORE_DEPRECATIONS;
+   ASSERT (!r);
+   ASSERT (error.domain == MONGOC_ERROR_BSON);
+   ASSERT (error.code == MONGOC_ERROR_BSON_INVALID);
+
    bson_destroy(&q);
    for (i = 0; i < 10; i++) {
       bson_destroy(&b[i]);