InsertMany write model and it's usage in Collection::insertMany()

Author: Petr Buchyn

src/Collection.php

@@ -18,6 +18,7 @@
 use Tequila\MongoDB\Traits\ResolveReadWriteOptionsTrait;
 use Tequila\MongoDB\Write\Model\DeleteMany;
 use Tequila\MongoDB\Write\Model\DeleteOne;
+use Tequila\MongoDB\Write\Model\InsertMany;
 use Tequila\MongoDB\Write\Model\InsertOne;
 use Tequila\MongoDB\Write\Model\ReplaceOne;
 use Tequila\MongoDB\Write\Model\UpdateMany;
@@ -427,13 +428,8 @@ public function getNamespace()
      */
     public function insertMany($documents, array $options = [])
     {
-        $models = [];
-
-        foreach ($documents as $document) {
-            $models[] = new InsertOne($document);
-        }
-
-        $bulkWriteResult = $this->bulkWrite($models, $options);
+        $writeModel = new InsertMany($documents);
+        $bulkWriteResult = $this->bulkWrite([$writeModel], $options);
 
         return new InsertManyResult($bulkWriteResult);
     }

src/Write/Model/InsertMany.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace Tequila\MongoDB\Write\Model;
+
+use Tequila\MongoDB\BulkWrite;
+use Tequila\MongoDB\Exception\InvalidArgumentException;
+use Tequila\MongoDB\WriteModelInterface;
+use function Tequila\MongoDB\ensureValidDocument;
+use function Tequila\MongoDB\getType;
+
+class InsertMany implements WriteModelInterface
+{
+    /**
+     * @var array
+     */
+    private $documents = [];
+
+    /**
+     * @param array $documents
+     */
+    public function __construct(array $documents)
+    {
+        foreach ($documents as $position => $document) {
+            if (!is_array($document) && !is_object($document)) {
+                throw new InvalidArgumentException(
+                    sprintf(
+                        'Each document must be an array or an object, %s given in $documents[%s].',
+                        getType($document),
+                        $position
+                    )
+                );
+            }
+
+            try {
+                ensureValidDocument($document);
+            } catch(InvalidArgumentException $e) {
+                throw new InvalidArgumentException(
+                    sprintf(
+                        'Invalid document at $documents[%s]: %s',
+                        $position,
+                        $e->getMessage()
+                    )
+                );
+            }
+        }
+
+        $this->documents = $documents;
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function writeToBulk(BulkWrite $bulk)
+    {
+        foreach ($this->documents as $document) {
+            $bulk->insert($document);
+        }
+    }
+}