Throw BulkWriteException with write results on write errors

src/Client.php

@@ -1634,8 +1634,12 @@ private function parseResponse(string $response, int $responseLength): stdClass|
 
             // Check for write errors (duplicate key, etc.)
             if (\property_exists($result, 'writeErrors') && !empty($result->writeErrors)) {
-                throw new Exception(
+                throw new BulkWriteException(
                     $result->writeErrors[0]->errmsg,
+                    [
+                        'writeErrors' => $result->writeErrors,
+                        'nInserted' => $result->n ?? 0,
+                    ],
                     $result->writeErrors[0]->code
                 );
             }

src/Exception.php

@@ -243,7 +243,7 @@ class BulkWriteException extends Exception
 
     public function __construct(string $message, array $result, int $code = 0, ?\Throwable $previous = null)
     {
-        parent::__construct($message, $code, $previous);
+        parent::__construct($message, $code, $previous, [], $result['writeErrors'] ?? null);
         $this->result = $result;
     }
 

tests/MongoTest.php

@@ -5,6 +5,7 @@
 use MongoDB\BSON\ObjectId;
 use PHPUnit\Framework\TestCase;
 use Utopia\Mongo\Client;
+use Utopia\Mongo\BulkWriteException;
 use Utopia\Mongo\Exception;
 
 class MongoTest extends TestCase
@@ -477,4 +478,44 @@ public function testCountMethod()
             $this->getDatabase()->dropCollection($collectionName);
         }
     }
+
+    public function testInsertManyDuplicateThrowsBulkWriteException(): void
+    {
+        $collectionName = 'test_bulk_write_exception';
+        $this->getDatabase()->createCollection($collectionName);
+
+        try {
+            // Insert a doc with explicit _id
+            $this->getDatabase()->insert($collectionName, [
+                '_id' => 'dup_id',
+                'name' => 'Original',
+            ]);
+
+            // insertMany with a duplicate _id should throw BulkWriteException
+            try {
+                $this->getDatabase()->insertMany($collectionName, [
+                    ['_id' => 'dup_id', 'name' => 'Duplicate'],
+                    ['_id' => 'new_id', 'name' => 'New'],
+                ], ['ordered' => false]);
+
+                self::fail('Expected BulkWriteException');
+            } catch (BulkWriteException $e) {
+                // Should be a duplicate key error
+                self::assertSame(11000, $e->getCode());
+
+                $result = $e->getResult();
+                self::assertArrayHasKey('nInserted', $result);
+                self::assertArrayHasKey('writeErrors', $result);
+                self::assertSame(1, $result['nInserted']);
+            }
+
+            // 'new_id' should have been inserted despite the duplicate (ordered: false)
+            $found = $this->getDatabase()->find($collectionName, ['_id' => 'new_id']);
+            $docs = $found->cursor->firstBatch ?? [];
+            self::assertCount(1, $docs);
+            self::assertSame('New', $docs[0]->name);
+        } finally {
+            $this->getDatabase()->dropCollection($collectionName);
+        }
+    }
 }