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

Delete with worker

Browse source
This commit is contained in:
Jake Barnby 2025-09-12 02:05:19 +12:00
parent 1403868d05
commit 38dc92bfa7
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
2 changed files with 17 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Delete.php
View file

@ -2,6 +2,7 @@
namespace Appwrite\Platform\Modules\Databases\Http\Databases\Transactions;
use Appwrite\Event\Delete as DeleteEvent;
use Appwrite\Extend\Exception;
use Appwrite\SDK\AuthType;
use Appwrite\SDK\ContentType;
@ -9,7 +10,6 @@ use Appwrite\SDK\Method;
use Appwrite\SDK\Response as SDKResponse;
use Appwrite\Utopia\Response as UtopiaResponse;
use Utopia\Database\Database;
use Utopia\Database\Query;
use Utopia\Database\Validator\UID;
use Utopia\Swoole\Response as SwooleResponse;
@ -51,10 +51,11 @@ class Delete extends Action
->param('transactionId', '', new UID(), 'Transaction ID.')
->inject('response')
->inject('dbForProject')
->inject('queueForDeletes')
->callback($this->action(...));
}
public function action(string $transactionId, UtopiaResponse $response, Database $dbForProject): void
public function action(string $transactionId, UtopiaResponse $response, Database $dbForProject, DeleteEvent $queueForDeletes): void
{
$transaction = $dbForProject->getDocument('transactions', $transactionId);
@ -62,13 +63,11 @@ class Delete extends Action
throw new Exception(Exception::TRANSACTION_NOT_FOUND);
}
if (!$dbForProject->deleteDocument('transactions', $transactionId)) {
throw new Exception(Exception::GENERAL_SERVER_ERROR, 'Failed to remove transaction from DB');
}
$dbForProject->deleteDocument('transactions', $transactionId);
$dbForProject->deleteDocuments('transactionLogs', [
Query::equal('transactionInternalId', [$transaction->getSequence()]),
]);
$queueForDeletes
->setType(DELETE_TYPE_DOCUMENT)
->setDocument($transaction);
$response->noContent();
}

30
src/Appwrite/Platform/Modules/Databases/Http/Databases/Transactions/Update.php
View file

@ -333,8 +333,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
if ($documentId && !isset($data['$id'])) {
$data['$id'] = $documentId;
}
@ -358,8 +357,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
$dependent = isset($state[$collectionId][$documentId]);
if ($dependent) {
@ -397,8 +395,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
$dependent = isset($state[$collectionId][$documentId]);
if ($dependent) {
@ -428,8 +425,7 @@ class Update extends Action
string $documentId,
\DateTime $createdAt,
array &$state
): void
{
): void {
$dependent = isset($state[$collectionId][$documentId]);
if ($dependent) {
@ -461,8 +457,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
$dependent = isset($state[$collectionId][$documentId]);
if ($dependent) {
@ -499,8 +494,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
$dependent = isset($state[$collectionId][$documentId]);
if ($dependent) {
@ -536,8 +530,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
$dbForProject->withRequestTimestamp($createdAt, function () use ($dbForProject, $collectionId, $data, &$state) {
$dbForProject->createDocuments(
$collectionId,
@ -561,8 +554,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
$queries = Query::parseQueries($data['queries'] ?? []);
$dbForProject->updateDocuments(
@ -596,8 +588,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
// Run bulk upsert without timestamp wrapper, checking manually in callback
$dbForProject->upsertDocuments(
$collectionId,
@ -633,8 +624,7 @@ class Update extends Action
array $data,
\DateTime $createdAt,
array &$state
): void
{
): void {
$queries = Query::parseQueries($data['queries'] ?? []);
$dbForProject->deleteDocuments(