updates

.gitmodules

@@ -1,4 +1,4 @@
 [submodule "app/console"]
 	path = app/console
 	url = https://github.com/appwrite/console
-	branch = 3.2.16
+	branch = 1.5.x

composer.json

@@ -56,7 +56,7 @@
         "utopia-php/image": "0.6.*",
         "utopia-php/locale": "0.4.*",
         "utopia-php/logger": "0.3.*",
-        "utopia-php/messaging": "0.8.*",
+        "utopia-php/messaging": "0.9.*",
         "utopia-php/migration": "0.3.*",
         "utopia-php/orchestration": "0.9.*",
         "utopia-php/platform": "0.5.*",

src/Appwrite/Migration/Version/V20.php

@@ -71,26 +71,29 @@ class V20 extends Migration
             'console' => 'console',
             default => 'projects',
         };
+
+        $databases = $this->projectDB->find('databases', []);
+        foreach ($databases as $database) {
+            var_dump($database);
+        }
+
         $collections = $this->collections[$collectionType];
         foreach ($collections as $collection) {
             $id = $collection['$id'];
 
             Console::log("Migrating Collection \"{$id}\"");
 
-            $this->projectDB->setNamespace("_{$this->project->getInternalId()}");
-            $modifiedAttr = [];
+            $this->projectDB->setNamespace("_$internalProjectId");
+
+            // Support database array type migration
             foreach ($collection['attributes'] ?? [] as $attribute) {
-                if ($attribute['type'] === 'string' && $attribute['array'] === true) {
-                    $this->projectDB->updateAttribute($id, $attribute['$id']);
-                    $modifiedAttr[] = $attribute['$id'];
-                }
-            }
-            if (!empty($modified)) {
-                foreach ($collection['indexes'] ?? [] as $index) {
-                    $foundIndexes = array_intersect($modifiedAttr, $index['attributes']);
-                    if ($foundIndexes) {
-                        $this->projectDB->deleteIndex($id, $index['$id']);
+                if ($attribute['array'] === true) {
+                    foreach ($collection['indexes'] ?? [] as $index) {
+                        if (in_array($attribute['$id'], $index['attributes'])) {
+                            $this->projectDB->deleteIndex($id, $index['$id']);
+                        }
                     }
+                    $this->projectDB->updateAttribute($id, $attribute['$id'], Database::VAR_STRING);
                 }
             }
 

src/Appwrite/Platform/Tasks/Migrate.php

@@ -93,6 +93,7 @@ class Migrate extends Action
                     // TODO: Iterate through all project DBs
                     /** @var Database $projectDB */
                     $projectDB = $getProjectDB($project);
+                    var_dump($project);
                     $migration
                         ->setProject($project, $projectDB, $dbForConsole)
                         ->setPDO($register->get('db', true))