Update 1.4 migration
This commit is contained in:
parent
6bb04ca95e
commit
280e066fd4
1 changed files with 555 additions and 10 deletions
|
@ -2,8 +2,6 @@
|
||||||
|
|
||||||
namespace Appwrite\Migration\Version;
|
namespace Appwrite\Migration\Version;
|
||||||
|
|
||||||
use Appwrite\Auth\Auth;
|
|
||||||
use Utopia\Config\Config;
|
|
||||||
use Appwrite\Migration\Migration;
|
use Appwrite\Migration\Migration;
|
||||||
use Utopia\CLI\Console;
|
use Utopia\CLI\Console;
|
||||||
use Utopia\Database\Database;
|
use Utopia\Database\Database;
|
||||||
|
@ -42,6 +40,22 @@ class V19 extends Migration
|
||||||
|
|
||||||
Console::info('Migrating Documents');
|
Console::info('Migrating Documents');
|
||||||
$this->forEachDocument([$this, 'fixDocument']);
|
$this->forEachDocument([$this, 'fixDocument']);
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteAttribute('projects', 'domains');
|
||||||
|
$this->projectDB->deleteCachedCollection('projects');
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'domains' from projects: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteAttribute('functions', 'schedule');
|
||||||
|
$this->projectDB->deleteCachedCollection('functions');
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'schedule' from functions: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
// TODO: delete builds stderr and stdout
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -76,24 +90,452 @@ class V19 extends Migration
|
||||||
*/
|
*/
|
||||||
private function migrateCollections(): void
|
private function migrateCollections(): void
|
||||||
{
|
{
|
||||||
foreach ($this->collections as $collection) {
|
$internalProjectId = $this->project->getInternalId();
|
||||||
|
$collectionType = match ($internalProjectId) {
|
||||||
|
'console' => 'console',
|
||||||
|
default => 'projects',
|
||||||
|
};
|
||||||
|
$collections = $this->collections[$collectionType];
|
||||||
|
foreach ($collections as $collection) {
|
||||||
$id = $collection['$id'];
|
$id = $collection['$id'];
|
||||||
|
|
||||||
|
|
||||||
|
if ($id === 'schedules' && $internalProjectId === 'console') {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
Console::log("Migrating Collection \"{$id}\"");
|
Console::log("Migrating Collection \"{$id}\"");
|
||||||
|
|
||||||
$this->projectDB->setNamespace("_{$this->project->getInternalId()}");
|
$this->projectDB->setNamespace("_{$this->project->getInternalId()}");
|
||||||
|
|
||||||
switch ($id) {
|
switch ($id) {
|
||||||
case 'projects':
|
case '_metadata':
|
||||||
|
$this->createCollection('identities');
|
||||||
|
$this->createCollection('migrations');
|
||||||
|
$this->createCollection('statsLogger'); // TODO: should we do this now?
|
||||||
|
break;
|
||||||
|
case 'attributes':
|
||||||
|
case 'indexes':
|
||||||
try {
|
try {
|
||||||
/**
|
$this->projectDB->updateAttribute($id, 'databaseInternalId', required: true);
|
||||||
* Create 'passwordHistory' attribute
|
|
||||||
*/
|
|
||||||
$this->createAttributeFromCollection($this->projectDB, $id, 'smtp');
|
|
||||||
$this->createAttributeFromCollection($this->projectDB, $id, 'templates');
|
|
||||||
$this->projectDB->deleteCachedCollection($id);
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
} catch (\Throwable $th) {
|
} catch (\Throwable $th) {
|
||||||
Console::warning("'SMTP and Templates' from {$id}: {$th->getMessage()}");
|
Console::warning("'databaseInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'collectionInternalId', required: true);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'collectionInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'error');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'error' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'buckets':
|
||||||
|
// Recreate indexes so they're the right size
|
||||||
|
$indexesToDelete = [
|
||||||
|
'_key_name',
|
||||||
|
];
|
||||||
|
foreach ($indexesToDelete as $index) {
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteIndex($id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$indexesToCreate = [
|
||||||
|
...$indexesToDelete
|
||||||
|
];
|
||||||
|
foreach ($indexesToCreate as $index) {
|
||||||
|
try {
|
||||||
|
$this->createIndexFromCollection($this->projectDB, $id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'builds':
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'deploymentInternalId');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'deploymentInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'logs');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'logs' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'certificates':
|
||||||
|
try {
|
||||||
|
$this->projectDB->renameAttribute($id, 'log', 'logs');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'errors' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'logs', size: 1000000);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'errors' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'databases':
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'enabled');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'enabled' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'deployments':
|
||||||
|
$attributesToCreate = [
|
||||||
|
'resourceInternalId',
|
||||||
|
'buildInternalId',
|
||||||
|
'type',
|
||||||
|
];
|
||||||
|
foreach ($attributesToCreate as $attribute) {
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, $attribute);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("$attribute from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Recreate indexes so they're the right size
|
||||||
|
$indexesToDelete = [
|
||||||
|
'_key_entrypoint',
|
||||||
|
'_key_resource',
|
||||||
|
'_key_resource_type',
|
||||||
|
'_key_buildId',
|
||||||
|
];
|
||||||
|
foreach ($indexesToDelete as $index) {
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteIndex($id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$indexesToCreate = [
|
||||||
|
'_key_resource',
|
||||||
|
'_key_resource_type',
|
||||||
|
'_key_buildId',
|
||||||
|
];
|
||||||
|
foreach ($indexesToCreate as $index) {
|
||||||
|
try {
|
||||||
|
$this->createIndexFromCollection($this->projectDB, $id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'executions':
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'functionInternalId');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'functionInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'deploymentInternalId');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'deploymentInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->renameAttribute($id, 'stderr', 'errors');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'errors' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->renameAttribute($id, 'stdout', 'logs');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'logs' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->renameAttribute($id, 'statusCode', 'responseStatusCode');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'responseStatusCode' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'files':
|
||||||
|
// Recreate indexes so they're the right size
|
||||||
|
$indexesToDelete = [
|
||||||
|
'_key_name',
|
||||||
|
'_key_signature',
|
||||||
|
'_key_mimeType',
|
||||||
|
];
|
||||||
|
foreach ($indexesToDelete as $index) {
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteIndex($id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$indexesToCreate = [
|
||||||
|
...$indexesToDelete
|
||||||
|
];
|
||||||
|
foreach ($indexesToCreate as $index) {
|
||||||
|
try {
|
||||||
|
$this->createIndexFromCollection($this->projectDB, $id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'functions':
|
||||||
|
$attributesToCreate = [
|
||||||
|
'live',
|
||||||
|
'installationId',
|
||||||
|
'installationInternalId',
|
||||||
|
'providerRepositoryId',
|
||||||
|
'repositoryId',
|
||||||
|
'repositoryInternalId',
|
||||||
|
'providerBranch',
|
||||||
|
'providerRootDirectory',
|
||||||
|
'providerSilentMode',
|
||||||
|
'logging',
|
||||||
|
'deploymentInternalId',
|
||||||
|
'scheduleInternalId',
|
||||||
|
'scheduleId',
|
||||||
|
'version',
|
||||||
|
'entrypoint',
|
||||||
|
'commands',
|
||||||
|
];
|
||||||
|
foreach ($attributesToCreate as $attribute) {
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, $attribute);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$attribute' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Recreate indexes so they're the right size
|
||||||
|
$indexesToDelete = [
|
||||||
|
'_key_name',
|
||||||
|
'_key_runtime',
|
||||||
|
'_key_deployment',
|
||||||
|
];
|
||||||
|
foreach ($indexesToDelete as $index) {
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteIndex($id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$indexesToCreate = [
|
||||||
|
...$indexesToDelete,
|
||||||
|
'_key_installationId',
|
||||||
|
'_key_installationInternalId',
|
||||||
|
'_key_providerRepositoryId',
|
||||||
|
'_key_repositoryId',
|
||||||
|
'_key_repositoryInternalId',
|
||||||
|
];
|
||||||
|
foreach ($indexesToCreate as $index) {
|
||||||
|
try {
|
||||||
|
$this->createIndexFromCollection($this->projectDB, $id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'memberships':
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'teamInternalId', required: true);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'teamInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
// Intentional fall through to update memberships.userInternalId
|
||||||
|
case 'sessions':
|
||||||
|
case 'tokens':
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'userInternalId', required: true);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'userInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'domains':
|
||||||
|
case 'keys':
|
||||||
|
case 'platforms':
|
||||||
|
case 'webhooks':
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'projectInternalId', required: true);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'projectInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'projects':
|
||||||
|
$attributesToCreate = [
|
||||||
|
'database',
|
||||||
|
'smtp',
|
||||||
|
'templates',
|
||||||
|
];
|
||||||
|
foreach ($attributesToCreate as $attribute) {
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, $attribute);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$attribute' from {$id}: {$th->getMessage()}");
|
||||||
|
Console::warning($th->getTraceAsString());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'schedules':
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'resourceInternalId');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'resourceInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'stats':
|
||||||
|
// TODO: should we do this now?
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'value', signed: true);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'teamInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteAttribute($id, 'type');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'teamInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteIndex($id, '_key_metric_period_time');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'_key_metric_period_time' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->createIndexFromCollection($this->projectDB, $id, '_key_metric_period_time');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'teamInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'teams':
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'teamInternalId', required: true);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'teamInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'users':
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'labels');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'labels' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'accessedAt');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'accessedAt' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->updateAttribute($id, 'search', filters: ['userSearch']);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'search' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->createIndexFromCollection($this->projectDB, $id, '_key_accessedAt');
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'_key_accessedAt' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'variables':
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteIndex($id, '_key_function');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'_key_function' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->deleteIndex($id, '_key_uniqueKey');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'_key_function' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'resourceType');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'resourceType' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->renameAttribute($id, 'functionInternalId', 'resourceInternalId');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'resourceInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->projectDB->renameAttribute($id, 'functionId', 'resourceId');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'resourceInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
$indexesToCreate = [
|
||||||
|
'_key_resourceInternalId',
|
||||||
|
'_key_resourceId',
|
||||||
|
'_key_resourceType',
|
||||||
|
'_key_uniqueKey',
|
||||||
|
];
|
||||||
|
foreach ($indexesToCreate as $index) {
|
||||||
|
try {
|
||||||
|
$this->createIndexFromCollection($this->projectDB, $id, $index);
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'$index' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
|
@ -117,6 +559,76 @@ class V19 extends Migration
|
||||||
protected function fixDocument(Document $document): Document
|
protected function fixDocument(Document $document): Document
|
||||||
{
|
{
|
||||||
switch ($document->getCollection()) {
|
switch ($document->getCollection()) {
|
||||||
|
case '_metadata':
|
||||||
|
// TODO: function schedules
|
||||||
|
|
||||||
|
// TODO: migrate statsLogger?
|
||||||
|
break;
|
||||||
|
case 'attributes':
|
||||||
|
case 'indexes':
|
||||||
|
$status = $document->getAttribute('status', '');
|
||||||
|
if ($status === 'failed') {
|
||||||
|
$document->setAttribute('error', 'Unknown problem');
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'builds':
|
||||||
|
$deploymentId = $document->getAttribute('deploymentId');
|
||||||
|
$deployment = $this->projectDB->getDocument('deployments', $deploymentId);
|
||||||
|
$document->setAttribute('deploymentInternalId', $deployment->getInternalId());
|
||||||
|
|
||||||
|
// TODO: how to combine stderr & stdout > logs?
|
||||||
|
break;
|
||||||
|
case 'collections':
|
||||||
|
case 'databases':
|
||||||
|
$document->setAttribute('enabled', true);
|
||||||
|
break;
|
||||||
|
case 'deployments':
|
||||||
|
$resourceId = $document->getAttribute('resourceId');
|
||||||
|
$function = $this->projectDB->getDocument('functions', $resourceId);
|
||||||
|
$document->setAttribute('resourceInternalId', $function->getInternalId());
|
||||||
|
|
||||||
|
$buildId = $document->getAttribute('buildId');
|
||||||
|
if (!empty($buildId)) {
|
||||||
|
$build = $this->projectDB->getDocument('builds', $buildId);
|
||||||
|
$document->setAttribute('buildInternalId', $build->getInternalId());
|
||||||
|
}
|
||||||
|
|
||||||
|
$document->setAttribute('type', 'manual');
|
||||||
|
break;
|
||||||
|
case 'executions':
|
||||||
|
$functionId = $document->getAttribute('functionId');
|
||||||
|
$function = $this->projectDB->getDocument('functions', $functionId);
|
||||||
|
$document->setAttribute('functionInternalId', $function->getInternalId());
|
||||||
|
|
||||||
|
$deploymentId = $document->getAttribute('deploymentId');
|
||||||
|
$deployment = $this->projectDB->getDocument('deployments', $deploymentId);
|
||||||
|
$document->setAttribute('deploymentInternalId', $deployment->getInternalId());
|
||||||
|
break;
|
||||||
|
case 'functions':
|
||||||
|
$document->setAttribute('live', true);
|
||||||
|
$document->setAttribute('logging', true);
|
||||||
|
$document->setAttribute('version', 'v2');
|
||||||
|
$deploymentId = $document->getAttribute('deployment');
|
||||||
|
if (!empty($deploymentId)) {
|
||||||
|
$deployment = $this->projectDB->getDocument('deployments', $deploymentId);
|
||||||
|
$document->setAttribute('deploymentInternalId', $deployment->getInternalId());
|
||||||
|
$document->setAttribute('entrypoint', $deployment->getAttribute('entrypoint'));
|
||||||
|
}
|
||||||
|
|
||||||
|
$schedule = $this->consoleDB->createDocument('schedules', new Document([
|
||||||
|
'region' => App::getEnv('_APP_REGION', 'default'), // Todo replace with projects region
|
||||||
|
'resourceType' => 'function',
|
||||||
|
'resourceId' => $document->getId(),
|
||||||
|
'resourceInternalId' => $document->getInternalId(),
|
||||||
|
'resourceUpdatedAt' => DateTime::now(),
|
||||||
|
'projectId' => $this->project->getId(),
|
||||||
|
'schedule' => $document->getAttribute('schedule'),
|
||||||
|
'active' => !empty($document->getAttribute('schedule')) && !empty($document->getAttribute('deployment')),
|
||||||
|
]));
|
||||||
|
|
||||||
|
$document->setAttribute('scheduleId', $schedule->getId());
|
||||||
|
$document->setAttribute('scheduleInternalId', $schedule->getInternalId());
|
||||||
|
break;
|
||||||
case 'projects':
|
case 'projects':
|
||||||
/**
|
/**
|
||||||
* Bump version number.
|
* Bump version number.
|
||||||
|
@ -126,6 +638,32 @@ class V19 extends Migration
|
||||||
$document->setAttribute('smtp', []);
|
$document->setAttribute('smtp', []);
|
||||||
$document->setAttribute('templates', []);
|
$document->setAttribute('templates', []);
|
||||||
|
|
||||||
|
break;
|
||||||
|
case 'rules':
|
||||||
|
$status = 'created';
|
||||||
|
if ($document->getAttribute('verification', false)) {
|
||||||
|
$status = 'verified';
|
||||||
|
}
|
||||||
|
|
||||||
|
$ruleDocument = new Document([
|
||||||
|
'projectId' => $this->project->getId(),
|
||||||
|
'projectInternalId' => $this->project->getInternalId(),
|
||||||
|
'domain' => $document->getAttribute('domain'),
|
||||||
|
'resourceType' => 'api',
|
||||||
|
'resourceInternalId' => '',
|
||||||
|
'resourceId' => '',
|
||||||
|
'status' => $status,
|
||||||
|
'certificateId' => $document->getAttribute('certificateId'),
|
||||||
|
]);
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->consoleDB->createDocument('rules', $ruleDocument);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("Error migrating domain {$document->getAttribute('domain')}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
break;
|
||||||
|
default:
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -173,6 +711,13 @@ class V19 extends Migration
|
||||||
Console::log("Migrating Bucket {$id} {$bucket->getId()} ({$bucket->getAttribute('name')})");
|
Console::log("Migrating Bucket {$id} {$bucket->getId()} ({$bucket->getAttribute('name')})");
|
||||||
$this->alterPermissionIndex($id);
|
$this->alterPermissionIndex($id);
|
||||||
$this->alterUidType($id);
|
$this->alterUidType($id);
|
||||||
|
|
||||||
|
try {
|
||||||
|
$this->createAttributeFromCollection($this->projectDB, $id, 'bucketInternalId');
|
||||||
|
$this->projectDB->deleteCachedCollection($id);
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
Console::warning("'bucketInternalId' from {$id}: {$th->getMessage()}");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue