feat(migration): 0.9.x
This commit is contained in:
parent
e413a4e4f0
commit
787059e88d
4 changed files with 91 additions and 4 deletions
|
@ -14,16 +14,18 @@ $cli
|
||||||
->task('migrate')
|
->task('migrate')
|
||||||
->action(function () use ($register) {
|
->action(function () use ($register) {
|
||||||
Console::success('Starting Data Migration');
|
Console::success('Starting Data Migration');
|
||||||
|
$db = $register->get('db', true);
|
||||||
|
$cache = $register->get('cache', true);
|
||||||
|
|
||||||
$consoleDB = new Database();
|
$consoleDB = new Database();
|
||||||
$consoleDB
|
$consoleDB
|
||||||
->setAdapter(new RedisAdapter(new MySQLAdapter($register), $register))
|
->setAdapter(new RedisAdapter(new MySQLAdapter($db, $cache), $cache))
|
||||||
->setNamespace('app_console') // Main DB
|
->setNamespace('app_console') // Main DB
|
||||||
->setMocks(Config::getParam('collections', []));
|
->setMocks(Config::getParam('collections', []));
|
||||||
|
|
||||||
$projectDB = new Database();
|
$projectDB = new Database();
|
||||||
$projectDB
|
$projectDB
|
||||||
->setAdapter(new RedisAdapter(new MySQLAdapter($register), $register))
|
->setAdapter(new RedisAdapter(new MySQLAdapter($db, $cache), $cache))
|
||||||
->setMocks(Config::getParam('collections', []));
|
->setMocks(Config::getParam('collections', []));
|
||||||
|
|
||||||
$console = $consoleDB->getDocument('console');
|
$console = $consoleDB->getDocument('console');
|
||||||
|
@ -36,7 +38,7 @@ $cli
|
||||||
$projects = [$console];
|
$projects = [$console];
|
||||||
$count = 0;
|
$count = 0;
|
||||||
|
|
||||||
$migration = new Version\V07($register->get('db')); //TODO: remove hardcoded version and move to dynamic migration
|
$migration = new Version\V08($register->get('db')); //TODO: remove hardcoded version and move to dynamic migration
|
||||||
|
|
||||||
while ($sum > 0) {
|
while ($sum > 0) {
|
||||||
foreach ($projects as $project) {
|
foreach ($projects as $project) {
|
||||||
|
|
|
@ -13,7 +13,6 @@ class V07 extends Migration
|
||||||
{
|
{
|
||||||
public function execute(): void
|
public function execute(): void
|
||||||
{
|
{
|
||||||
$db = $this->db;
|
|
||||||
$project = $this->project;
|
$project = $this->project;
|
||||||
Console::log('Migrating project: ' . $project->getAttribute('name') . ' (' . $project->getId() . ')');
|
Console::log('Migrating project: ' . $project->getAttribute('name') . ' (' . $project->getId() . ')');
|
||||||
|
|
||||||
|
|
53
src/Appwrite/Migration/Version/V08.php
Normal file
53
src/Appwrite/Migration/Version/V08.php
Normal file
|
@ -0,0 +1,53 @@
|
||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Appwrite\Migration\Version;
|
||||||
|
|
||||||
|
use Appwrite\Migration\Migration;
|
||||||
|
use Utopia\Config\Config;
|
||||||
|
use Utopia\CLI\Console;
|
||||||
|
use Appwrite\Database\Database;
|
||||||
|
use Appwrite\Database\Document;
|
||||||
|
|
||||||
|
class V08 extends Migration
|
||||||
|
{
|
||||||
|
public function execute(): void
|
||||||
|
{
|
||||||
|
$project = $this->project;
|
||||||
|
Console::log('Migrating project: ' . $project->getAttribute('name') . ' (' . $project->getId() . ')');
|
||||||
|
|
||||||
|
$this->forEachDocument([$this, 'fixDocument']);
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function fixDocument(Document $document)
|
||||||
|
{
|
||||||
|
switch ($document->getAttribute('$collection')) {
|
||||||
|
/**
|
||||||
|
* Rename env attribute to runtime.
|
||||||
|
*/
|
||||||
|
case Database::SYSTEM_COLLECTION_FUNCTIONS:
|
||||||
|
if ($document->isSet('env')) {
|
||||||
|
$document
|
||||||
|
->setAttribute('runtime', $document->getAttribute('env', $document->getAttribute('env', '')))
|
||||||
|
->removeAttribute('env');
|
||||||
|
}
|
||||||
|
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
foreach ($document as &$attr) {
|
||||||
|
if ($attr instanceof Document) {
|
||||||
|
$attr = $this->fixDocument($attr);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (\is_array($attr)) {
|
||||||
|
foreach ($attr as &$child) {
|
||||||
|
if ($child instanceof Document) {
|
||||||
|
$child = $this->fixDocument($child);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return $document;
|
||||||
|
}
|
||||||
|
}
|
33
tests/unit/Migration/MigrationV08Test.php
Normal file
33
tests/unit/Migration/MigrationV08Test.php
Normal file
|
@ -0,0 +1,33 @@
|
||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Appwrite\Tests;
|
||||||
|
|
||||||
|
use ReflectionClass;
|
||||||
|
use Appwrite\Database\Database;
|
||||||
|
use Appwrite\Database\Document;
|
||||||
|
use Appwrite\Auth\Auth;
|
||||||
|
use Appwrite\Migration\Version\V08;
|
||||||
|
|
||||||
|
class MigrationV08Test extends MigrationTest
|
||||||
|
{
|
||||||
|
public function setUp(): void
|
||||||
|
{
|
||||||
|
$this->pdo = new \PDO('sqlite::memory:');
|
||||||
|
$this->migration = new V08($this->pdo);
|
||||||
|
$reflector = new ReflectionClass('Appwrite\Migration\Version\V08');
|
||||||
|
$this->method = $reflector->getMethod('fixDocument');
|
||||||
|
$this->method->setAccessible(true);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testMigration()
|
||||||
|
{
|
||||||
|
$document = $this->fixDocument(new Document([
|
||||||
|
'$id' => 'unique',
|
||||||
|
'$collection' => Database::SYSTEM_COLLECTION_FUNCTIONS,
|
||||||
|
'env' => 'node-16'
|
||||||
|
]));
|
||||||
|
|
||||||
|
$this->assertEquals($document->getAttribute('env', null), null);
|
||||||
|
$this->assertEquals($document->getAttribute('runtime', null), 'node-16');
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in a new issue