Prose test 12

Author: jmikola

tests/SpecTests/Crud/Prose12_BulkWriteExceedsMaxMessageSizeBytesTest.php

@@ -0,0 +1,76 @@
+<?php
+
+namespace MongoDB\Tests\SpecTests\Crud;
+
+use MongoDB\ClientBulkWrite;
+use MongoDB\Driver\Exception\BulkWriteCommandException;
+use MongoDB\Driver\Exception\InvalidArgumentException;
+use MongoDB\Tests\SpecTests\FunctionalTestCase;
+
+use function str_repeat;
+
+/**
+ * Prose test 12: MongoClient.bulkWrite returns an error if no operations can be added to ops
+ *
+ * @see https://github.com/mongodb/specifications/tree/master/source/crud/tests#12-mongoclientbulkwrite-returns-an-error-if-no-operations-can-be-added-to-ops
+ */
+class Prose12_BulkWriteExceedsMaxMessageSizeBytesTest extends FunctionalTestCase
+{
+    public function setUp(): void
+    {
+        parent::setUp();
+
+        if ($this->isServerless()) {
+            $this->markTestSkipped('bulkWrite command is not supported');
+        }
+
+        $this->skipIfServerVersion('<', '8.0', 'bulkWrite command is not supported');
+    }
+
+    public function testDocumentTooLarge(): void
+    {
+        $client = self::createTestClient();
+
+        $maxMessageSizeBytes = $this->getPrimaryServer()->getInfo()['maxMessageSizeBytes'] ?? null;
+        self::assertIsInt($maxMessageSizeBytes);
+
+        $collection = $client->selectCollection($this->getDatabaseName(), $this->getCollectionName());
+        $bulkWrite = ClientBulkWrite::createWithCollection($collection);
+        $bulkWrite->insertOne(['a' => str_repeat('b', $maxMessageSizeBytes)]);
+
+        try {
+            $client->bulkWrite($bulkWrite);
+            self::fail('Exception was not thrown');
+        } catch (BulkWriteCommandException $e) {
+            /* Note: although the client-side error occurs on the first operation, libmongoc still populates the partial
+             * result (see: CDRIVER-5969). This causes PHPC to proxy the underlying InvalidArgumentException behind
+             * BulkWriteCommandException. Until this is addressed, unwrap the error and check the partial result. */
+            self::assertInstanceOf(InvalidArgumentException::class, $e->getPrevious());
+            self::assertSame(0, $e->getPartialResult()->getInsertedCount());
+        }
+    }
+
+    public function testNamespaceTooLarge(): void
+    {
+        $client = self::createTestClient();
+
+        $maxMessageSizeBytes = $this->getPrimaryServer()->getInfo()['maxMessageSizeBytes'] ?? null;
+        self::assertIsInt($maxMessageSizeBytes);
+
+        $collectionName = str_repeat('c', $maxMessageSizeBytes);
+        $collection = $client->selectCollection($this->getDatabaseName(), $collectionName);
+        $bulkWrite = ClientBulkWrite::createWithCollection($collection);
+        $bulkWrite->insertOne(['a' => 'b']);
+
+        try {
+            $client->bulkWrite($bulkWrite);
+            self::fail('Exception was not thrown');
+        } catch (BulkWriteCommandException $e) {
+            /* Note: although the client-side error occurs on the first operation, libmongoc still populates the partial
+             * result (see: CDRIVER-5969). This causes PHPC to proxy the underlying InvalidArgumentException behind
+             * BulkWriteCommandException. Until this is addressed, unwrap the error and check the partial result. */
+            self::assertInstanceOf(InvalidArgumentException::class, $e->getPrevious());
+            self::assertSame(0, $e->getPartialResult()->getInsertedCount());
+        }
+    }
+}