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

Trigger sentry

Browse source
This commit is contained in:
fogelito 2024-11-07 14:28:39 +02:00
parent 0a8f62fd09
commit a6779caa5e
1 changed files with 19 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -92,6 +92,7 @@ class Databases extends Action
* @throws Authorization * @throws Authorization
* @throws Conflict * @throws Conflict
* @throws \Exception * @throws \Exception
* @throws \Throwable
*/ */
private function createAttribute(Document $database, Document $collection, Document $attribute, Document $project, Database $dbForConsole, Database $dbForProject): void private function createAttribute(Document $database, Document $collection, Document $attribute, Document $project, Database $dbForConsole, Database $dbForProject): void
{ {
@ -134,7 +135,6 @@ class Databases extends Action
$options = $attribute->getAttribute('options', []); $options = $attribute->getAttribute('options', []);
$project = $dbForConsole->getDocument('projects', $projectId); $project = $dbForConsole->getDocument('projects', $projectId);
try { try {
switch ($type) { switch ($type) {
case Database::VAR_RELATIONSHIP: case Database::VAR_RELATIONSHIP:
@ -170,7 +170,6 @@ class Databases extends Action
$dbForProject->updateDocument('attributes', $attribute->getId(), $attribute->setAttribute('status', 'available')); $dbForProject->updateDocument('attributes', $attribute->getId(), $attribute->setAttribute('status', 'available'));
} catch (\Throwable $e) { } catch (\Throwable $e) {
// TODO: Send non DatabaseExceptions to Sentry
Console::error($e->getMessage()); Console::error($e->getMessage());
if ($e instanceof DatabaseException) { if ($e instanceof DatabaseException) {
@ -193,6 +192,9 @@ class Databases extends Action
$relatedAttribute->setAttribute('status', 'failed') $relatedAttribute->setAttribute('status', 'failed')
); );
} }
// TODO: Send non DatabaseExceptions to Sentry
throw $e;
} finally { } finally {
$this->trigger($database, $collection, $attribute, $project, $projectId, $events); $this->trigger($database, $collection, $attribute, $project, $projectId, $events);
} }
@ -215,6 +217,7 @@ class Databases extends Action
* @throws Authorization * @throws Authorization
* @throws Conflict * @throws Conflict
* @throws \Exception * @throws \Exception
* @throws \Throwable
**/ **/
private function deleteAttribute(Document $database, Document $collection, Document $attribute, Document $project, Database $dbForConsole, Database $dbForProject): void private function deleteAttribute(Document $database, Document $collection, Document $attribute, Document $project, Database $dbForConsole, Database $dbForProject): void
{ {
@ -273,7 +276,6 @@ class Databases extends Action
$dbForProject->deleteDocument('attributes', $relatedAttribute->getId()); $dbForProject->deleteDocument('attributes', $relatedAttribute->getId());
} }
} catch (\Throwable $e) { } catch (\Throwable $e) {
// TODO: Send non DatabaseExceptions to Sentry
Console::error($e->getMessage()); Console::error($e->getMessage());
if ($e instanceof DatabaseException) { if ($e instanceof DatabaseException) {
@ -294,6 +296,9 @@ class Databases extends Action
$relatedAttribute->setAttribute('status', 'stuck') $relatedAttribute->setAttribute('status', 'stuck')
); );
} }
// TODO: Send non DatabaseExceptions to Sentry
throw $e;
} finally { } finally {
$this->trigger($database, $collection, $attribute, $project, $projectId, $events); $this->trigger($database, $collection, $attribute, $project, $projectId, $events);
} }
@ -370,6 +375,7 @@ class Databases extends Action
* @throws Conflict * @throws Conflict
* @throws Structure * @throws Structure
* @throws DatabaseException * @throws DatabaseException
* @throws \Throwable
*/ */
private function createIndex(Document $database, Document $collection, Document $index, Document $project, Database $dbForConsole, Database $dbForProject): void private function createIndex(Document $database, Document $collection, Document $index, Document $project, Database $dbForConsole, Database $dbForProject): void
{ {
@ -401,7 +407,7 @@ class Databases extends Action
} }
$dbForProject->updateDocument('indexes', $index->getId(), $index->setAttribute('status', 'available')); $dbForProject->updateDocument('indexes', $index->getId(), $index->setAttribute('status', 'available'));
} catch (\Throwable $e) { } catch (\Throwable $e) {
// TODO: Send non DatabaseExceptions to Sentry
Console::error($e->getMessage()); Console::error($e->getMessage());
if ($e instanceof DatabaseException) { if ($e instanceof DatabaseException) {
@ -412,6 +418,9 @@ class Databases extends Action
$index->getId(), $index->getId(),
$index->setAttribute('status', 'failed') $index->setAttribute('status', 'failed')
); );
// TODO: Send non DatabaseExceptions to Sentry
throw $e;
} finally { } finally {
$this->trigger($database, $collection, $index, $project, $projectId, $events); $this->trigger($database, $collection, $index, $project, $projectId, $events);
} }
@ -431,6 +440,7 @@ class Databases extends Action
* @throws Conflict * @throws Conflict
* @throws Structure * @throws Structure
* @throws DatabaseException * @throws DatabaseException
* @throws \Throwable
*/ */
private function deleteIndex(Document $database, Document $collection, Document $index, Document $project, Database $dbForConsole, Database $dbForProject): void private function deleteIndex(Document $database, Document $collection, Document $index, Document $project, Database $dbForConsole, Database $dbForProject): void
{ {
@ -459,7 +469,6 @@ class Databases extends Action
$dbForProject->deleteDocument('indexes', $index->getId()); $dbForProject->deleteDocument('indexes', $index->getId());
$index->setAttribute('status', 'deleted'); $index->setAttribute('status', 'deleted');
} catch (\Throwable $e) { } catch (\Throwable $e) {
// TODO: Send non DatabaseExceptions to Sentry
Console::error($e->getMessage()); Console::error($e->getMessage());
if ($e instanceof DatabaseException) { if ($e instanceof DatabaseException) {
@ -470,10 +479,15 @@ class Databases extends Action
$index->getId(), $index->getId(),
$index->setAttribute('status', 'stuck') $index->setAttribute('status', 'stuck')
); );
// TODO: Send non DatabaseExceptions to Sentry ?
throw $e;
} finally { } finally {
$this->trigger($database, $collection, $index, $project, $projectId, $events); $this->trigger($database, $collection, $index, $project, $projectId, $events);
} }
// Do we want this in finally?
$dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collection->getId()); $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collection->getId());
} }