Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-06 06:48:22 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

chore: fix warning in database worker

Browse source
This commit is contained in:
Chirag Aggarwal 2025-02-18 12:51:19 +00:00
parent 235a357ca3
commit 9f7aaf7029
2 changed files with 16 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/Appwrite/Event/Event.php
View file

@ -234,8 +234,9 @@ class Event
}
/**
* Get targets for this event.
* Set targets for this event.
*
* @param array $targets
* @return array
*/
public function setTargets(array $targets): self

28
src/Appwrite/Platform/Workers/Databases.php
View file

@ -197,7 +197,7 @@ class Databases extends Action
throw $e;
} finally {
$this->trigger($database, $collection, $project, $attribute, null, $attribute, $event, $queueForRealtime);
$this->trigger($database, $collection, $project, $event, $queueForRealtime, $attribute);
if (! $relatedCollection->isEmpty()) {
$dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $relatedCollection->getId());
@ -304,7 +304,7 @@ class Databases extends Action
throw $e;
} finally {
$this->trigger($database, $collection, $project, $attribute, null, $attribute, $event, $queueForRealtime);
$this->trigger($database, $collection, $project, $event, $queueForRealtime, $attribute);
}
// The underlying database removes/rebuilds indexes when attribute is removed
@ -418,7 +418,7 @@ class Databases extends Action
throw $e;
} finally {
$this->trigger($database, $collection, $project, null, $index, $index, $event, $queueForRealtime);
$this->trigger($database, $collection, $project, $event, $queueForRealtime, null, $index);
$dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collectionId);
}
}
@ -474,7 +474,7 @@ class Databases extends Action
throw $e;
} finally {
$this->trigger($database, $collection, $project, null, $index, $index, $event, $queueForRealtime);
$this->trigger($database, $collection, $project, $event, $queueForRealtime, null, $index);
$dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collection->getId());
}
}
@ -586,21 +586,19 @@ class Databases extends Action
* @param Document $database
* @param Document $collection
* @param Document $project
* @param Realtime $queueForRealtime
* @param Document|null $attribute
* @param Document|null $index
* @param Document $payload
* @param Realtime $queueForRealtime
* @return void
*/
protected function trigger(
Document $database,
Document $collection,
Document $project,
string $event,
Realtime $queueForRealtime,
Document|null $attribute = null,
Document|null $index = null,
Document $payload,
string $event,
Realtime $queueForRealtime
): void {
$queueForRealtime
->setProject($project)
@ -610,14 +608,16 @@ class Databases extends Action
->setParam('collectionId', $collection->getId());
if ($attribute !== null) {
$queueForRealtime->setParam('attributeId', $attribute->getId());
$queueForRealtime
->setParam('attributeId', $attribute->getId())
->setPayload($attribute->getArrayCopy());
}
if ($index !== null) {
$queueForRealtime->setParam('indexId', $index->getId());
$queueForRealtime
->setParam('indexId', $index->getId())
->setPayload($index->getArrayCopy());
}
$queueForRealtime
->setPayload($payload->getArrayCopy())
->trigger();
$queueForRealtime->trigger();
}
}