Support adding schema validation

To support the '$jsonSchema' operation on collections

Author: paulinevos

src/Schema/Blueprint.php

@@ -117,6 +117,20 @@ public function hasIndex($indexOrColumns = null)
         return false;
     }
 
+    public function jsonSchema(
+        array $schema = [],
+        ?string $validationLevel = null,
+        ?string $validationAction = null,
+    ): void {
+        $this->connection->getDatabase()->modifyCollection($this->collection->getCollectionName(), [
+            'validator' => [
+                '$jsonSchema' => $schema,
+            ],
+            'validationLevel' => $validationLevel,
+            'validationAction' => $validationAction,
+        ]);
+    }
+
     /**
      * @param  string|array $indexOrColumns
      *

tests/SchemaTest.php

@@ -63,6 +63,39 @@ public function testCreateWithOptions(): void
         $this->assertEquals(1024, $collection['options']['size']);
     }
 
+    public function testCreateWithSchemaValidator(): void
+    {
+        $schema = [
+            'bsonType' => 'object',
+            'required' => [ 'username' ],
+            'properties' => [
+                'username' => [
+                    'bsonType' => 'string',
+                    'description' => 'must be a string and is required',
+                ],
+            ],
+        ];
+
+        Schema::create(self::COLL_2, function (Blueprint $collection) use ($schema) {
+            $collection->string('username');
+            $collection->jsonSchema(schema: $schema, validationAction: 'warn');
+        });
+
+        $this->assertTrue(Schema::hasCollection(self::COLL_2));
+        $this->assertTrue(Schema::hasTable(self::COLL_2));
+
+        $collection = Schema::getCollection(self::COLL_2);
+        $this->assertEquals(
+            ['$jsonSchema' => $schema],
+            $collection['options']['validator'],
+        );
+
+        $this->assertEquals(
+            'warn',
+            $collection['options']['validationAction'],
+        );
+    }
+
     public function testDrop(): void
     {
         Schema::create(self::COLL_1);