Expose insert_many

Author: Cuihtlauac ALVARADO

lib/bson/bson.ml

@@ -32,8 +32,6 @@ end
 let some = Ctypes.allocate t
 let none = Ctypes.(from_voidp t null)
 
-let ptr_of_opt = Option.value ~default:none
-
 let get_version () =
   () |> C.Functions.get_version |> Ctypes_std_views.string_of_char_ptr
 

lib/bson/bson.mli

@@ -18,7 +18,6 @@ end
 
 val some : t_struct -> t
 val none : t
-val ptr_of_opt : t opt 
 val t : t_struct Ctypes_static.typ
 val get_version : unit -> string
 val get_major_version : unit -> int

lib/function_description.ml

@@ -120,6 +120,14 @@ module Functions (F : Ctypes.FOREIGN) = struct
         @-> ptr (const Bson.t)
         @-> ptr Bson.t @-> ptr Bson.Error.t @-> returning bool)
 
+    let insert_many =
+      foreign "mongoc_collection_insert_many"
+        (ptr Types_generated.Collection.t
+        @-> ptr (ptr (const Bson.t))
+        @-> size_t
+        @-> ptr (const Bson.t)
+        @-> ptr Bson.t @-> ptr Bson.Error.t @-> returning bool)
+
     let drop =
       foreign "mongoc_collection_drop"
         (ptr Types_generated.Collection.t

lib/mongoc.ml

@@ -91,6 +91,10 @@ and Collection : sig
     (Int64.t, Bson.Error.t) result
 
   val insert_one : ?opts:Bson.t -> t -> Bson.t -> (Bson.t, Bson.Error.t) result
+
+  val insert_many :
+    ?opts:Bson.t -> t -> Bson.t list -> (Bson.t, Bson.Error.t) result
+
   val drop : t -> (unit, Bson.Error.t) result
   val destroy : t -> unit
   val from_database : Database.t -> string -> t
@@ -124,6 +128,17 @@ end = struct
       Ok reply
     else Error error
 
+  let insert_many ?(opts : Bson.t option) (coll : t) (documents : Bson.t list) :
+      (Bson.t, Bson.Error.t) result =
+    let error = Ctypes.(make Bson.Error.t |> addr) in
+    let opts = Option.value ~default:Bson.none opts in
+    let reply = Ctypes.(make Bson.t |> addr) in
+    let length = documents |> List.length |> Unsigned.Size_t.of_int in
+    let documents = Ctypes.CArray.(of_list (ptr Bson.t) documents |> start) in
+    if C.Functions.Collection.insert_many coll documents length opts reply error
+    then Ok reply
+    else Error error
+
   let drop (coll : t) =
     let error = Ctypes.(make Bson.Error.t |> addr) in
     if C.Functions.Collection.drop coll error then Ok () else Error error

lib/mongoc.mli

@@ -99,6 +99,10 @@ and Collection : sig
     (Int64.t, Bson.Error.t) result
 
   val insert_one : ?opts:Bson.t -> t -> Bson.t -> (Bson.t, Bson.Error.t) result
+
+  val insert_many :
+    ?opts:Bson.t -> t -> Bson.t list -> (Bson.t, Bson.Error.t) result
+
   val drop : t -> (unit, Bson.Error.t) result
   val destroy : t -> unit
   val from_database : Database.t -> string -> t