Documentsdb(Schemaless support with mongodb adapter)

.github/workflows/tests.yml

@@ -84,6 +84,7 @@ jobs:
             SharedTables/MySQL,
             SharedTables/Postgres,
             SharedTables/SQLite,
+            Schemaless/MongoDB,
           ]
 
     steps:

src/Database/Adapter.php

@@ -1383,4 +1383,12 @@ abstract public function getSupportForUTCCasting(): bool;
     */
     abstract public function setUTCDatetime(string $value): mixed;
 
+    /**
+    * Set support for attributes
+    *
+    * @param bool $support
+    * @return bool
+    */
+    abstract public function setSupportForAttributes(bool $support): bool;
+
 }

src/Database/Adapter/Mongo.php

@@ -57,6 +57,7 @@ class Mongo extends Adapter
      */
     private ?array $session = null; // Store session array from startSession
     protected int $inTransaction = 0;
+    protected bool $supportForAttributes = true;
 
     /**
      * Constructor.
@@ -2585,7 +2586,13 @@ public function setUTCDatetime(string $value): mixed
      */
     public function getSupportForAttributes(): bool
     {
-        return true;
+        return $this->supportForAttributes;
+    }
+
+    public function setSupportForAttributes(bool $support): bool
+    {
+        $this->supportForAttributes = $support;
+        return $this->supportForAttributes;
     }
 
     /**

src/Database/Adapter/Pool.php

@@ -599,4 +599,9 @@ public function setUTCDatetime(string $value): mixed
     {
         return $this->delegate(__FUNCTION__, \func_get_args());
     }
+
+    public function setSupportForAttributes(bool $support): bool
+    {
+        return $this->delegate(__FUNCTION__, \func_get_args());
+    }
 }

src/Database/Adapter/SQL.php

@@ -2930,4 +2930,9 @@ public function decodePolygon(string $wkb): array
 
         return $rings;
     }
+
+    public function setSupportForAttributes(bool $support): bool
+    {
+        return true;
+    }
 }

tests/e2e/Adapter/MongoDBTest.php

@@ -51,6 +51,7 @@ public static function getDatabase(): Database
         );
 
         $database = new Database(new Mongo($client), $cache);
+        $database->getAdapter()->setSupportForAttributes(true);
         $database
             ->setDatabase($schema)
             ->setNamespace(static::$namespace = 'myapp_' . uniqid());

tests/e2e/Adapter/Schemaless/MongoDBTest.php

@@ -0,0 +1,110 @@
+<?php
+
+namespace Tests\E2E\Adapter;
+
+use Exception;
+use Redis;
+use Utopia\Cache\Adapter\Redis as RedisAdapter;
+use Utopia\Cache\Cache;
+use Utopia\Database\Adapter\Mongo;
+use Utopia\Database\Database;
+use Utopia\Mongo\Client;
+
+class MongoDBTest extends Base
+{
+    public static ?Database $database = null;
+    protected static string $namespace;
+
+    /**
+     * Return name of adapter
+     *
+     * @return string
+     */
+    public static function getAdapterName(): string
+    {
+        return "mongodb";
+    }
+
+    /**
+     * @return Database
+     * @throws Exception
+     */
+    public static function getDatabase(): Database
+    {
+        if (!is_null(self::$database)) {
+            return self::$database;
+        }
+
+        $redis = new Redis();
+        $redis->connect('redis', 6379);
+        $redis->flushAll();
+        $cache = new Cache(new RedisAdapter($redis));
+
+        $schema = 'utopiaTests'; // same as $this->testDatabase
+        $client = new Client(
+            $schema,
+            'mongo',
+            27017,
+            'root',
+            'password',
+            false
+        );
+
+        $database = new Database(new Mongo($client), $cache);
+        $database->getAdapter()->setSupportForAttributes(false);
+        $database
+            ->setDatabase($schema)
+            ->setNamespace(static::$namespace = 'myapp_' . uniqid());
+
+        if ($database->exists()) {
+            $database->delete();
+        }
+
+
+        $database->create();
+
+        return self::$database = $database;
+    }
+
+    /**
+     * @throws Exception
+     */
+    public function testCreateExistsDelete(): void
+    {
+        // Mongo creates databases on the fly, so exists would always pass. So we override this test to remove the exists check.
+        $this->assertNotNull(static::getDatabase()->create());
+        $this->assertEquals(true, static::getDatabase()->delete($this->testDatabase));
+        $this->assertEquals(true, static::getDatabase()->create());
+        $this->assertEquals(static::getDatabase(), static::getDatabase()->setDatabase($this->testDatabase));
+    }
+
+    public function testRenameAttribute(): void
+    {
+        $this->assertTrue(true);
+    }
+
+    public function testRenameAttributeExisting(): void
+    {
+        $this->assertTrue(true);
+    }
+
+    public function testUpdateAttributeStructure(): void
+    {
+        $this->assertTrue(true);
+    }
+
+    public function testKeywords(): void
+    {
+        $this->assertTrue(true);
+    }
+
+    protected static function deleteColumn(string $collection, string $column): bool
+    {
+        return true;
+    }
+
+    protected static function deleteIndex(string $collection, string $index): bool
+    {
+        return true;
+    }
+}

tests/e2e/Adapter/Scopes/IndexTests.php

@@ -269,10 +269,10 @@ public function testIndexValidation(): void
 
         $this->assertFalse($validator->isValid($newIndex));
 
-        if ($database->getAdapter()->getSupportForAttributes()) {
-            $this->assertEquals('Attribute "integer" cannot be part of a fulltext index, must be of type string', $validator->getDescription());
-        } elseif (!$database->getAdapter()->getSupportForMultipleFulltextIndexes()) {
+        if (!$database->getAdapter()->getSupportForMultipleFulltextIndexes()) {
             $this->assertEquals('There is already a fulltext index in the collection', $validator->getDescription());
+        } elseif ($database->getAdapter()->getSupportForAttributes()) {
+            $this->assertEquals('Attribute "integer" cannot be part of a fulltext index, must be of type string', $validator->getDescription());
         }
 
         try {