diff --git a/src/Appwrite/Platform/Workers/Migrations.php b/src/Appwrite/Platform/Workers/Migrations.php index 043465b4b2..51d66c36e9 100644 --- a/src/Appwrite/Platform/Workers/Migrations.php +++ b/src/Appwrite/Platform/Workers/Migrations.php @@ -79,13 +79,6 @@ class Migrations extends Action $this->dbForProject = $dbForProject; $this->dbForConsole = $dbForConsole; - /** - * Handle Event execution. - */ - if (! empty($events)) { - return; - } - $log->addTag('projectId', $project->getId()); $this->processMigration($project, $migration, $log); diff --git a/src/Appwrite/Utopia/Response/Filters/V18.php b/src/Appwrite/Utopia/Response/Filters/V18.php new file mode 100644 index 0000000000..80936d9ce4 --- /dev/null +++ b/src/Appwrite/Utopia/Response/Filters/V18.php @@ -0,0 +1,34 @@ + 1.5.8 data format + public function parse(array $content, string $model): array + { + $parsedResponse = $content; + + $parsedResponse = match($model) { + Response::MODEL_MIGRATION => $this->parseMigration($parsedResponse), + default => $parsedResponse, + }; + + return $parsedResponse; + } + + protected function parseMigration(array $content) { + $content['stage'] = match($content['status']) { + 'pending' => 'init', + 'processing' => 'migrating', + 'completed' => 'finished', + 'failed' => 'finished', + default => 'processing', + }; + + return $content; + } +} \ No newline at end of file