CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-07-02 21:20:58 +12:00
Code Issues Projects Releases Wiki Activity

fix: buckets

Browse source
This commit is contained in:
Torsten Dittmann 2022-06-24 16:04:42 +02:00
parent 5c12350248
commit 016d6939d5
1 changed files with 50 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

57
src/Appwrite/Migration/Version/V14.php
View file

@ -59,6 +59,43 @@ class V14 extends Migration
}
}
/**
* Migrates all Files.
* @param \Utopia\Database\Document $bucket
* @return void
* @throws \Exception
*/
protected function migrateBucketFiles(Document $bucket): void
{
$nextFile = null;
do {
$documents = $this->projectDB->find("bucket_{$bucket->getInternalId()}", limit: $this->limit, cursor: $nextFile);
$count = count($documents);
foreach ($documents as $document) {
go(function (Document $bucket, Document $document) {
try {
/**
* Migrate $createdAt.
*/
if (empty($document->getCreatedAt())) {
$document->setAttribute('$createdAt', $document->getAttribute('dateCreated'));
$this->projectDB->updateDocument("bucket_{$bucket->getInternalId()}", $document->getId(), $document);
}
} catch (\Throwable $th) {
Console::warning($th->getMessage());
}
}, $bucket, $document);
}
if ($count !== $this->limit) {
$nextCollection = null;
} else {
$nextCollection = end($documents);
}
} while (!is_null($nextCollection));
}
/**
* Migrates all Database Collections.
* @return void
@ -538,13 +575,13 @@ class V14 extends Migration
/**
* Migrate dateCreated to $createdAt.
*/
if (is_null($document->getCreatedAt())) {
if (empty($document->getCreatedAt())) {
$document->setAttribute('$createdAt', $document->getAttribute('dateCreated'));
}
/**
* Migrate dateUpdated to $updatedAt.
*/
if (is_null($document->getUpdatedAt())) {
if (empty($document->getUpdatedAt())) {
$document->setAttribute('$updatedAt', $document->getAttribute('dateUpdated'));
}
/**
@ -560,13 +597,14 @@ class V14 extends Migration
/**
* Migrate dateCreated to $createdAt.
*/
if (is_null($document->getCreatedAt())) {
if (empty($document->getCreatedAt())) {
$document->setAttribute('$createdAt', $document->getAttribute('dateCreated'));
}
/**
* Migrate dateUpdated to $updatedAt.
*/
if (is_null($document->getUpdatedAt())) {
if (empty($document->getUpdatedAt())) {
$document->setAttribute('$updatedAt', $document->getAttribute('dateUpdated'));
}
@ -576,6 +614,11 @@ class V14 extends Migration
$internalId = $this->projectDB->getDocument('buckets', $document->getId())->getInternalId();
$this->createNewMetaData("bucket_{$internalId}");
/**
* Migrate all Storage Bucket Files.
*/
$this->migrateBucketFiles($document);
break;
case 'users':
/**
@ -590,13 +633,13 @@ class V14 extends Migration
/**
* Migrate dateCreated to $createdAt.
*/
if (is_null($document->getCreatedAt())) {
if (empty($document->getCreatedAt())) {
$document->setAttribute('$createdAt', $document->getAttribute('dateCreated'));
}
/**
* Migrate dateUpdated to $updatedAt.
*/
if (is_null($document->getUpdatedAt())) {
if (empty($document->getUpdatedAt())) {
$document->setAttribute('$updatedAt', $document->getAttribute('dateUpdated'));
}
@ -607,7 +650,7 @@ class V14 extends Migration
/**
* Migrate dateCreated to $createdAt.
*/
if (is_null($document->getCreatedAt())) {
if (empty($document->getCreatedAt())) {
$document->setAttribute('$createdAt', $document->getAttribute('dateCreated'));
}