Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

updateAttributes

Browse Source
This commit is contained in:
fogelito
2024-11-11 18:46:47 +02:00
parent 59c233b1e5
commit bae6e465fa
1 changed files with 30 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/controllers/api/databases.php
+30 -8
View File
@@ -396,20 +396,37 @@ function updateAttribute(
}
}
if (!empty($newKey) && $key !== $newKey) {
// Delete attribute and recreate since we can't modify IDs
$original = clone $attribute;
$purge = false;
$dbForProject->deleteDocument('attributes', $attribute->getId());
if (!empty($newKey) && $key !== $newKey) {
$originalUid = $attribute->getId();
$attribute
->setAttribute('$id', ID::custom($db->getInternalId() . '_' . $collection->getInternalId() . '_' . $newKey))
->setAttribute('key', $newKey);
try {
$attribute = $dbForProject->createDocument('attributes', $attribute);
} catch (DatabaseException|PDOException) {
$attribute = $dbForProject->createDocument('attributes', $original);
$dbForProject->updateDocument('attributes', $originalUid, $attribute);
/**
* @var Document $index
*/
foreach ($collection->getAttribute('indexes') as $index) {
/**
* @var string[] $attributes
*/
$attributes = $index->getAttribute('attributes', []);
$found = \array_search($key, $attributes);
var_dump($attributes);
var_dump('found===');
var_dump($found);
if ($found !== false) {
$attributes[$found] = $newKey;
$index->setAttribute('attributes', $attributes);
$dbForProject->updateDocument('indexes', $index->getId(), $index);
$purge = true;
}
}
} else {
$attribute = $dbForProject->updateDocument('attributes', $db->getInternalId() . '_' . $collection->getInternalId() . '_' . $key, $attribute);
@@ -417,6 +434,11 @@ function updateAttribute(
$dbForProject->purgeCachedDocument('database_' . $db->getInternalId(), $collection->getId());
if($purge){
// I think we are missing this?
$dbForProject->purgeCachedCollection('database_' . $db->getInternalId() . '_collection_' . $collection->getInternalId());
}
$queueForEvents
->setContext('collection', $collection)
->setContext('database', $db)