Update lock

# Conflicts:
#	composer.lock

.env

@@ -110,3 +110,6 @@ _APP_MESSAGE_PUSH_TEST_DSN=
 _APP_WEBHOOK_MAX_FAILED_ATTEMPTS=10
 _APP_PROJECT_REGIONS=default
 _APP_FUNCTIONS_CREATION_ABUSE_LIMIT=5000
+_APP_SLOW_QUERIES_MAX_HITS=5
+_APP_SLOW_QUERIES_TIMEOUT=15000
+_APP_SLOW_QUERIES_BLOCK=enabled

app/config/collections/common.php

@@ -2637,4 +2637,93 @@ return [
             ]
         ]
     ],
+    'slowQueries' => [
+        '$collection' => ID::custom(Database::METADATA),
+        '$id' => ID::custom('slowQueries'),
+        'name' => 'slowQueries',
+        'attributes' => [
+            [
+                '$id' => ID::custom('blocked'),
+                'type' => Database::VAR_BOOLEAN,
+                'format' => '',
+                'size' => 0,
+                'signed' => true,
+                'required' => true,
+                'default' => false,
+                'array' => false,
+                'filters' => [],
+            ],
+            [
+                '$id' => ID::custom('count'),
+                'type' => Database::VAR_INTEGER,
+                'format' => '',
+                'size' => 0,
+                'signed' => true,
+                'required' => true,
+                'default' => null,
+                'array' => false,
+                'filters' => [],
+            ],
+            [
+                '$id' => ID::custom('queries'),
+                'type' => Database::VAR_STRING,
+                'format' => '',
+                'size' => 410002,
+                'signed' => false,
+                'required' => true,
+                'default' => [],
+                'array' => false,
+                'filters' => ['json'],
+            ],
+            [
+                '$id' => ID::custom('path'),
+                'type' => Database::VAR_STRING,
+                'format' => '',
+                'size' => 2500,
+                'signed' => false,
+                'required' => true,
+                'default' => null,
+                'array' => false,
+                'filters' => [],
+            ],
+            [
+                '$id' => ID::custom('databaseId'),
+                'type' => Database::VAR_STRING,
+                'signed' => true,
+                'size' => Database::LENGTH_KEY,
+                'format' => '',
+                'filters' => [],
+                'required' => true,
+                'default' => null,
+                'array' => false,
+            ],
+            [
+                '$id' => ID::custom('collectionId'),
+                'type' => Database::VAR_STRING,
+                'signed' => true,
+                'size' => Database::LENGTH_KEY,
+                'format' => '',
+                'filters' => [],
+                'required' => true,
+                'default' => null,
+                'array' => false,
+            ],
+        ],
+        'indexes' => [
+            [
+                '$id' => '_key_database_id',
+                'type' => Database::INDEX_KEY,
+                'attributes' => ['databaseId', 'collectionId'],
+                'lengths' => [],
+                'orders' => []
+            ],
+            [
+                '$id' => '_key_blocked',
+                'type' => Database::INDEX_KEY,
+                'attributes' => ['blocked', 'databaseId', 'collectionId'],
+                'lengths' => [],
+                'orders' => []
+            ]
+        ],
+    ],
 ];

app/config/errors.php

@@ -1023,4 +1023,16 @@ return [
         'description' => 'Target has an invalid provider type.',
         'code' => 400,
     ],
+
+    /* Slow queries */
+    Exception::QUERY_BLOCKED => [
+        'name' => Exception::QUERY_BLOCKED,
+        'description' => 'Request blocked after exceeding the maximum number of timeouts',
+        'code' => 403,
+    ],
+    Exception::QUERY_TIMEOUT => [
+        'name' => Exception::QUERY_TIMEOUT,
+        'description' => 'Request timed out, this query will be blocked if it keeps timing out, try adjusting the "queries" parameter or adding indexes for the queried attributes.',
+        'code' => 408,
+    ],
 ];

app/controllers/api/databases.php

@@ -32,6 +32,7 @@ use Utopia\Database\Exception\NotFound as NotFoundException;
 use Utopia\Database\Exception\Query as QueryException;
 use Utopia\Database\Exception\Restricted as RestrictedException;
 use Utopia\Database\Exception\Structure as StructureException;
+use Utopia\Database\Exception\Timeout as TimeoutException;
 use Utopia\Database\Exception\Truncate as TruncateException;
 use Utopia\Database\Helpers\ID;
 use Utopia\Database\Helpers\Permission;
@@ -449,6 +450,88 @@ App::init()
         }
     });
 
+App::init()
+    ->groups(['timeout'])
+    ->inject('request')
+    ->inject('dbForProject')
+    ->action(function (Request $request, Database $dbForProject) {
+        $key = md5(json_encode([
+            $request->getMethod(),
+            $request->getURI(), // Contains databaseId & collectionId
+            $request->getParam('queries')
+        ]));
+
+        /** @var Document $document */
+        $document = Authorization::skip(fn () => $dbForProject->getDocument(
+            'slowQueries',
+            $key
+        ));
+
+        if ($document->getAttribute('blocked')) {
+            throw new Exception(Exception::QUERY_BLOCKED);
+        }
+    });
+
+App::error()
+    ->groups(['timeout'])
+    ->inject('error')
+    ->inject('request')
+    ->inject('dbForProject')
+    ->action(function (Throwable $error, Request $request, Database $dbForProject) {
+        if (!$error instanceof TimeoutException) {
+            return;
+        }
+
+        $route = Request::getRoute();
+        $collectionId = $route->getParamValue('collectionId');
+        $databaseId = $route->getParamValue('databaseId');
+        $queries = $request->getParam('queries', []);
+
+        $key = md5(json_encode([
+            $request->getMethod(),
+            $request->getURI(),
+            $queries
+        ]));
+
+        /** @var Document $document */
+        $document = Authorization::skip(fn () => $dbForProject->getDocument(
+            'slowQueries',
+            $key
+        ));
+
+        if ($document->isEmpty()) {
+            $document = Authorization::skip(fn () => $dbForProject->createDocument('slowQueries', new Document([
+                '$id' => $key,
+                'blocked' => false,
+                'count' => 1,
+                'queries' => $queries,
+                'databaseId' => $databaseId,
+                'collectionId' => $collectionId,
+                'path' => $request->getURI()
+            ])));
+        } else {
+            $document->setAttribute('count', $document->getAttribute('count') + 1);
+            $max = intval(App::getEnv('_APP_SLOW_QUERIES_MAX_HITS', 5));
+
+            if ($document->getAttribute('count') >= $max) {
+                $document->setAttribute('blocked', true);
+            }
+
+            $document = Authorization::skip(fn () => $dbForProject->updateDocument(
+                'slowQueries',
+                $document->getId(),
+                $document
+            ));
+        }
+
+        // Set the correct exception to pass to the next shutdown hook
+        if ($document->getAttribute('blocked')) {
+            App::setResource('error', fn () => new Exception(Exception::QUERY_BLOCKED));
+        } else {
+            App::setResource('error', fn () => new Exception(Exception::QUERY_TIMEOUT));
+        }
+    });
+
 App::post('/v1/databases')
     ->desc('Create database')
     ->groups(['api', 'database'])
@@ -924,8 +1007,7 @@ App::get('/v1/databases/:databaseId/collections')
     ->param('search', '', new Text(256), 'Search term to filter your list results. Max length: 256 chars.', true)
     ->inject('response')
     ->inject('dbForProject')
-    ->inject('mode')
-    ->action(function (string $databaseId, array $queries, string $search, Response $response, Database $dbForProject, string $mode) {
+    ->action(function (string $databaseId, array $queries, string $search, Response $response, Database $dbForProject) {
 
         $database = Authorization::skip(fn () => $dbForProject->getDocument('databases', $databaseId));
 
@@ -1217,8 +1299,7 @@ App::delete('/v1/databases/:databaseId/collections/:collectionId')
     ->inject('dbForProject')
     ->inject('queueForDatabase')
     ->inject('queueForEvents')
-    ->inject('mode')
-    ->action(function (string $databaseId, string $collectionId, Response $response, Database $dbForProject, EventDatabase $queueForDatabase, Event $queueForEvents, string $mode) {
+    ->action(function (string $databaseId, string $collectionId, Response $response, Database $dbForProject, EventDatabase $queueForDatabase, Event $queueForEvents) {
 
         $database = Authorization::skip(fn () => $dbForProject->getDocument('databases', $databaseId));
 
@@ -3370,7 +3451,7 @@ App::post('/v1/databases/:databaseId/collections/:collectionId/documents')
 App::get('/v1/databases/:databaseId/collections/:collectionId/documents')
     ->alias('/v1/database/collections/:collectionId/documents', ['databaseId' => 'default'])
     ->desc('List documents')
-    ->groups(['api', 'database'])
+    ->groups(['api', 'database', 'timeout'])
     ->label('scope', 'documents.read')
     ->label('resourceType', RESOURCE_TYPE_DATABASES)
     ->label('sdk', new Method(
@@ -3389,11 +3470,12 @@ App::get('/v1/databases/:databaseId/collections/:collectionId/documents')
     ->param('databaseId', '', new UID(), 'Database ID.')
     ->param('collectionId', '', new UID(), 'Collection ID. You can create a new collection using the Database service [server integration](https://appwrite.io/docs/server/databases#databasesCreateCollection).')
     ->param('queries', [], new ArrayList(new Text(APP_LIMIT_ARRAY_ELEMENT_SIZE), APP_LIMIT_ARRAY_PARAMS_SIZE), 'Array of query strings generated using the Query class provided by the SDK. [Learn more about queries](https://appwrite.io/docs/queries). Maximum of ' . APP_LIMIT_ARRAY_PARAMS_SIZE . ' queries are allowed, each ' . APP_LIMIT_ARRAY_ELEMENT_SIZE . ' characters long.', true)
+    ->inject('request')
     ->inject('response')
     ->inject('dbForProject')
     ->inject('mode')
     ->inject('queueForUsage')
-    ->action(function (string $databaseId, string $collectionId, array $queries, Response $response, Database $dbForProject, string $mode, Usage $queueForUsage) {
+    ->action(function (string $databaseId, string $collectionId, array $queries, Request $request, Response $response, Database $dbForProject, string $mode, Usage $queueForUsage) {
         $database = Authorization::skip(fn () => $dbForProject->getDocument('databases', $databaseId));
         $isAPIKey = Auth::isAppUser(Authorization::getRoles());
         $isPrivilegedUser = Auth::isPrivilegedUser(Authorization::getRoles());
@@ -3440,9 +3522,17 @@ App::get('/v1/databases/:databaseId/collections/:collectionId/documents')
             $cursor->setValue($cursorDocument);
         }
 
+        $timeout = App::getEnv('_APP_SLOW_QUERIES') === 'enabled'
+            ? App::getEnv('_APP_SLOW_QUERIES_TIMEOUT')
+            : null;
+
+        if (App::isDevelopment() && intval($request->getHeader('x-appwrite-timeout')) > 0) {
+            $timeout = intval($request->getHeader('x-appwrite-timeout'));
+            $dbForProject->setTimeout($timeout);
+        }
+
         $documents = $dbForProject->find('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId(), $queries);
         $total = $dbForProject->count('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId(), $queries, APP_LIMIT_COUNT);
-
         $operations = 0;
 
         // Add $collectionId and $databaseId for all documents
@@ -4441,3 +4531,113 @@ App::get('/v1/databases/:databaseId/collections/:collectionId/usage')
             'documents'   =>  $usage[$metrics[0]]['data'],
         ]), Response::MODEL_USAGE_COLLECTION);
     });
+
+App::get('/v1/databases/:databaseId/slow-queries')
+    ->desc('List slow queries')
+    ->groups(['api', 'database'])
+    ->label('docs', false)
+    ->label('scope', 'documents.read')
+    ->label('sdk', new Method(
+        namespace: 'databases',
+        name: 'listSlowQueries',
+        description: '/docs/references/databases/list-slow-queries.md',
+        auth: [AuthType::ADMIN],
+        responses: [
+            new SDKResponse(
+                code: Response::STATUS_CODE_OK,
+                model: Response::MODEL_SLOW_QUERY_LIST,
+            )
+        ]
+    ))
+    ->param('databaseId', '', new UID(), 'Database ID.')
+    ->param('queries', [], new ArrayList(new Text(APP_LIMIT_ARRAY_ELEMENT_SIZE), APP_LIMIT_ARRAY_PARAMS_SIZE), 'Array of query strings generated using the Query class provided by the SDK. [Learn more about queries](https://appwrite.io/docs/databases#querying-documents). Maximum of ' . APP_LIMIT_ARRAY_PARAMS_SIZE . ' queries are allowed, each ' . APP_LIMIT_ARRAY_ELEMENT_SIZE . ' characters long.', true)
+    ->inject('response')
+    ->inject('dbForProject')
+    ->action(function ($databaseId, array $queries, Response $response, Database $dbForProject) {
+        $queries = Query::parseQueries($queries);
+        $queries[] = Query::equal('databaseId', [$databaseId]);
+
+        $cursor = Query::getByType($queries, [Query::TYPE_CURSOR_AFTER, Query::TYPE_CURSOR_BEFORE]);
+        $cursor = reset($cursor);
+        if ($cursor) {
+            $documentId = $cursor->getValue();
+            $cursorDocument = $dbForProject->getDocument('slowQueries', $documentId);
+            if ($cursorDocument->isEmpty()) {
+                throw new Exception(Exception::GENERAL_CURSOR_NOT_FOUND, "Slow query '{$documentId}' for the 'cursor' value not found.");
+            }
+            $cursor->setValue($cursorDocument);
+        }
+
+        $response->dynamic(new Document([
+            'documents' => $dbForProject->find('slowQueries', $queries),
+            'total' => $dbForProject->count('slowQueries', Query::groupByType($queries)['filters'], APP_LIMIT_COUNT),
+        ]), Response::MODEL_DOCUMENT_LIST);
+    });
+
+App::get('/v1/databases/:databaseId/slow-queries/:slowQueryId')
+    ->desc('Get slow query')
+    ->groups(['api', 'database'])
+    ->label('docs', false)
+    ->label('scope', 'documents.read')
+    ->label('usage.metric', 'documents.{scope}.requests.read')
+    ->label('sdk.auth', [APP_AUTH_TYPE_ADMIN])
+    ->label('sdk', new Method(
+        namespace: 'databases',
+        name: 'getSlowQuery',
+        description: '/docs/references/databases/get-slow-query.md',
+        auth: [AuthType::ADMIN],
+        responses: [
+            new SDKResponse(
+                code: Response::STATUS_CODE_OK,
+                model: Response::MODEL_SLOW_QUERY,
+            )
+        ]
+    ))
+    ->param('databaseId', '', new UID(), 'Database ID.')
+    ->param('slowQueryId', '', new UID(), 'Document ID.')
+    ->inject('response')
+    ->inject('dbForProject')
+    ->action(function (string $databaseId, string $slowQueryId, Response $response, Database $dbForProject) {
+        $document = $dbForProject->getDocument('slowQueries', $slowQueryId);
+
+        if ($document->isEmpty() || $document->getAttribute('databaseId') !== $databaseId) {
+            throw new Exception(Exception::DOCUMENT_NOT_FOUND);
+        }
+
+        $response->dynamic($document, Response::MODEL_SLOW_QUERY);
+    });
+
+App::delete('/v1/databases/:databaseId/slow-queries/:slowQueryId')
+    ->desc('Delete slow query')
+    ->desc('List  Documents')
+    ->groups(['api', 'database'])
+    ->label('scope', 'documents.write')
+    ->label('usage.metric', 'documents.{scope}.requests.delete')
+    ->label('docs', false)
+    ->label('sdk', new Method(
+        namespace: 'databases',
+        name: 'deleteSlowQuery',
+        description: '/docs/references/databases/delete-slow-query.md',
+        auth: [AuthType::ADMIN],
+        responses: [
+            new SDKResponse(
+                code: Response::STATUS_CODE_NOCONTENT,
+                model: Response::MODEL_NONE,
+            )
+        ]
+    ))
+    ->param('databaseId', '', new UID(), 'Database ID.')
+    ->param('slowQueryId', '', new UID(), 'Document ID.')
+    ->inject('response')
+    ->inject('dbForProject')
+    ->action(function (string $databaseId, string $slowQueryId, Response $response, Database $dbForProject) {
+        $document = $dbForProject->getDocument('slowQueries', $slowQueryId);
+
+        if ($document->isEmpty() || $document->getAttribute('databaseId') !== $databaseId) {
+            throw new Exception(Exception::DOCUMENT_NOT_FOUND);
+        }
+
+        $dbForProject->deleteDocument('slowQueries', $slowQueryId);
+
+        $response->noContent();
+    });

app/views/install/compose.phtml

@@ -163,6 +163,9 @@ $image = $this->getParam('image', '');
       - _APP_MIGRATIONS_FIREBASE_CLIENT_ID
       - _APP_MIGRATIONS_FIREBASE_CLIENT_SECRET
       - _APP_ASSISTANT_OPENAI_API_KEY
+      - _APP_SLOW_QUERIES_MAX_HITS
+      - _APP_SLOW_QUERIES_TIMEOUT
+      - _APP_SLOW_QUERIES
 
   appwrite-console:
     <<: *x-logging

composer.json

@@ -30,7 +30,7 @@
         }
     },
     "require": {
-        "php": ">=8.0.0",
+        "php": ">=8.3",
         "ext-curl": "*",
         "ext-imagick": "*",
         "ext-mbstring": "*",

composer.lock

@@ -4,7 +4,7 @@
         "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
         "This file is @generated automatically"
     ],
-    "content-hash": "e8d26e7e836db255ba42cf55c3798c97",
+    "content-hash": "1112973adf57691665674ee76d7dc3ec",
     "packages": [
         {
             "name": "adhocore/jwt",
@@ -2453,16 +2453,16 @@
         },
         {
             "name": "symfony/http-client",
-            "version": "v7.2.2",
+            "version": "v7.2.3",
             "source": {
                 "type": "git",
                 "url": "https://github.com/symfony/http-client.git",
-                "reference": "339ba21476eb184290361542f732ad12c97591ec"
+                "reference": "7ce6078c79a4a7afff931c413d2959d3bffbfb8d"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/symfony/http-client/zipball/339ba21476eb184290361542f732ad12c97591ec",
-                "reference": "339ba21476eb184290361542f732ad12c97591ec",
+                "url": "https://api.github.com/repos/symfony/http-client/zipball/7ce6078c79a4a7afff931c413d2959d3bffbfb8d",
+                "reference": "7ce6078c79a4a7afff931c413d2959d3bffbfb8d",
                 "shasum": ""
             },
             "require": {
@@ -2528,7 +2528,7 @@
                 "http"
             ],
             "support": {
-                "source": "https://github.com/symfony/http-client/tree/v7.2.2"
+                "source": "https://github.com/symfony/http-client/tree/v7.2.3"
             },
             "funding": [
                 {
@@ -2544,7 +2544,7 @@
                     "type": "tidelift"
                 }
             ],
-            "time": "2024-12-30T18:35:15+00:00"
+            "time": "2025-01-28T15:51:35+00:00"
         },
         {
             "name": "symfony/http-client-contracts",
@@ -8507,7 +8507,7 @@
     "prefer-stable": false,
     "prefer-lowest": false,
     "platform": {
-        "php": ">=8.0.0",
+        "php": ">=8.3",
         "ext-curl": "*",
         "ext-imagick": "*",
         "ext-mbstring": "*",

docker-compose.yml

@@ -196,6 +196,9 @@ services:
       - _APP_DATABASE_SHARED_TABLES_V1
       - _APP_DATABASE_SHARED_NAMESPACE
       - _APP_FUNCTIONS_CREATION_ABUSE_LIMIT
+      - _APP_SLOW_QUERIES_MAX_HITS
+      - _APP_SLOW_QUERIES_TIMEOUT
+      - _APP_SLOW_QUERIES
 
   appwrite-console:
     <<: *x-logging

docs/references/databases/delete-slow-query.md

@@ -0,0 +1 @@
+Delete a slow query by its unique ID.

docs/references/databases/get-slow-query.md

@@ -0,0 +1 @@
+Get a slow query by its unique ID. This endpoint response returns a JSON object with the document data.

docs/references/databases/list-slow-queries.md

@@ -0,0 +1 @@
+Get a list of all the slow queries documents in a given database. You can use the query params to filter your results.

src/Appwrite/Extend/Exception.php

@@ -261,6 +261,11 @@ class Exception extends \Exception
     public const MIGRATION_IN_PROGRESS             = 'migration_in_progress';
     public const MIGRATION_PROVIDER_ERROR          = 'migration_provider_error';
 
+
+    /** Timeout */
+    public const QUERY_BLOCKED                     = 'query_blocked';
+    public const QUERY_TIMEOUT                     = 'query_timeout';
+
     /** Realtime */
     public const REALTIME_MESSAGE_FORMAT_INVALID   = 'realtime_message_format_invalid';
     public const REALTIME_TOO_MANY_MESSAGES        = 'realtime_too_many_messages';

src/Appwrite/Utopia/Response.php

@@ -84,6 +84,7 @@ use Appwrite\Utopia\Response\Model\ProviderRepository;
 use Appwrite\Utopia\Response\Model\Rule;
 use Appwrite\Utopia\Response\Model\Runtime;
 use Appwrite\Utopia\Response\Model\Session;
+use Appwrite\Utopia\Response\Model\SlowQuery;
 use Appwrite\Utopia\Response\Model\Specification;
 use Appwrite\Utopia\Response\Model\Subscriber;
 use Appwrite\Utopia\Response\Model\Target;
@@ -111,7 +112,6 @@ use Appwrite\Utopia\Response\Model\Webhook;
 use Exception;
 use JsonException;
 use Swoole\Http\Response as SwooleHTTPResponse;
-// Keep last
 use Utopia\Database\Document;
 use Utopia\Swoole\Response as SwooleResponse;
 
@@ -152,6 +152,10 @@ class Response extends SwooleResponse
     public const MODEL_DOCUMENT = 'document';
     public const MODEL_DOCUMENT_LIST = 'documentList';
 
+    public const MODEL_SLOW_QUERY = 'slowQuery';
+
+    public const MODEL_SLOW_QUERY_LIST = 'slowQueryList';
+
     // Database Attributes
     public const MODEL_ATTRIBUTE = 'attribute';
     public const MODEL_ATTRIBUTE_LIST = 'attributeList';
@@ -384,6 +388,7 @@ class Response extends SwooleResponse
             ->setModel(new BaseList('Migrations Firebase Projects List', self::MODEL_MIGRATION_FIREBASE_PROJECT_LIST, 'projects', self::MODEL_MIGRATION_FIREBASE_PROJECT))
             ->setModel(new BaseList('Specifications List', self::MODEL_SPECIFICATION_LIST, 'specifications', self::MODEL_SPECIFICATION))
             ->setModel(new BaseList('VCS Content List', self::MODEL_VCS_CONTENT_LIST, 'contents', self::MODEL_VCS_CONTENT))
+            ->setModel(new BaseList('Slow Query List', self::MODEL_SLOW_QUERY_LIST, 'slowQueries', self::MODEL_SLOW_QUERY))
             // Entities
             ->setModel(new Database())
             ->setModel(new Collection())
@@ -482,6 +487,7 @@ class Response extends SwooleResponse
             ->setModel(new Migration())
             ->setModel(new MigrationReport())
             ->setModel(new MigrationFirebaseProject())
+            ->setModel(new SlowQuery())
             // Tests (keep last)
             ->setModel(new Mock());
 
@@ -773,7 +779,7 @@ class Response extends SwooleResponse
     /**
      * Function to add a response filter, the order of filters are first in - first out.
      *
-     * @param $filter the response filter to set
+     * @param $filter Filter The response filter to set
      *
      * @return void
      */

src/Appwrite/Utopia/Response/Model/SlowQuery.php

@@ -0,0 +1,76 @@
+<?php
+
+namespace Appwrite\Utopia\Response\Model;
+
+use Appwrite\Utopia\Response;
+use Appwrite\Utopia\Response\Model;
+
+class SlowQuery extends Model
+{
+    public function __construct()
+    {
+        $this
+            ->addRule('$id', [
+                'type' => self::TYPE_STRING,
+                'description' => 'Slow Query ID.',
+                'default' => '',
+                'example' => '5e5ea5c16897e',
+            ])
+            ->addRule('$createdAt', [
+                'type' => self::TYPE_DATETIME,
+                'description' => 'Slow query creation date in ISO 8601 format.',
+                'default' => '',
+                'example' => self::TYPE_DATETIME_EXAMPLE,
+            ])
+            ->addRule('$updatedAt', [
+                'type' => self::TYPE_DATETIME,
+                'description' => 'Slow query update date in ISO 8601 format.',
+                'default' => '',
+                'example' => self::TYPE_DATETIME_EXAMPLE,
+            ])
+            ->addRule('blocked', [
+                'type' => self::TYPE_BOOLEAN,
+                'description' => 'Is this slow query blocked from execution?',
+                'default' => false,
+                'example' => true,
+            ])
+            ->addRule('count', [
+                'type' => self::TYPE_INTEGER,
+                'description' => 'The number of times this slow query has executed.',
+                'default' => 0,
+                'example' => 5,
+            ])
+            ->addRule('queries', [
+                'type' => self::TYPE_STRING,
+                'description' => 'The slow query itself.',
+                'default' => '',
+                'example' => '["limit(10000)"]',
+            ])
+            ->addRule('path', [
+                'type' => self::TYPE_STRING,
+                'description' => 'The path of the endpoint that executed this slow query.',
+                'default' => '',
+                'example' => '/v1/databases/123/collections',
+            ]);
+    }
+
+    /**
+     * Get Name
+     *
+     * @return string
+     */
+    public function getName(): string
+    {
+        return 'Slow Queries';
+    }
+
+    /**
+     * Get Type
+     *
+     * @return string
+     */
+    public function getType(): string
+    {
+        return Response::MODEL_SLOW_QUERY;
+    }
+}

tests/e2e/Services/Databases/DatabasesBase.php

@@ -12,7 +12,6 @@ use Utopia\Database\Helpers\Permission;
 use Utopia\Database\Helpers\Role;
 use Utopia\Database\Query;
 use Utopia\Database\Validator\Datetime as DatetimeValidator;
-use Utopia\Validator\JSON;
 
 trait DatabasesBase
 {
@@ -1334,7 +1333,7 @@ trait DatabasesBase
             'content-type' => 'application/json',
             'x-appwrite-project' => $this->getProject()['$id'],
             'x-appwrite-key' => $this->getProject()['apiKey']
-        ]), []);
+        ]));
 
         $this->assertIsArray($movies['body']['indexes']);
         $this->assertCount(8, $movies['body']['indexes']);
@@ -4787,16 +4786,22 @@ trait DatabasesBase
             ]);
         }
 
-        $response = $this->client->call(Client::METHOD_GET, '/databases/' . $data['databaseId'] . '/collections/' . $data['$id'] . '/documents', array_merge([
-            'content-type' => 'application/json',
-            'x-appwrite-project' => $this->getProject()['$id'],
-            'x-appwrite-timeout' => 1,
-        ], $this->getHeaders()), [
-            'queries' => [
+        $docs = [];
+        for ($i = 0; $i <= 5; $i++) {  // _APP_SLOW_QUERIES_MAX_HITS = 5
+            $docs[] = $this->client->call(Client::METHOD_GET, '/databases/' . $data['databaseId'] . '/collections/' . $data['$id'] . '/documents', array_merge([
+                'content-type' => 'application/json',
+                'x-appwrite-project' => $this->getProject()['$id'],
+                'x-appwrite-timeout' => 1,
+            ], $this->getHeaders()), [
                 Query::notEqual('longtext', 'appwrite')->toString(),
-            ],
-        ]);
+            ]);
+        }
 
-        $this->assertEquals(408, $response['headers']['status-code']);
+        $this->assertEquals(408, $docs[0]['headers']['status-code']); // create
+        $this->assertEquals(408, $docs[1]['headers']['status-code']); // update
+        $this->assertEquals(408, $docs[2]['headers']['status-code']); // update
+        $this->assertEquals(408, $docs[3]['headers']['status-code']); // update
+        $this->assertEquals(403, $docs[4]['headers']['status-code']); // update
+        $this->assertEquals(403, $docs[5]['headers']['status-code']); // blocked
     }
 }

tests/e2e/Services/Databases/DatabasesConsoleClientTest.php

@@ -94,7 +94,19 @@ class DatabasesConsoleClientTest extends Scope
         $this->assertEquals(201, $tvShows['headers']['status-code']);
         $this->assertEquals($tvShows['body']['name'], 'TvShows');
 
-        return ['moviesId' => $movies['body']['$id'], 'databaseId' => $databaseId, 'tvShowsId' => $tvShows['body']['$id']];
+        $this->client->call(Client::METHOD_PUT, '/databases/' . $databaseId, array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'name' => 'Database Updated',
+            'enabled' => true,
+        ]);
+
+        return [
+            'moviesId' => $movies['body']['$id'],
+            'databaseId' => $databaseId,
+            'tvShowsId' => $tvShows['body']['$id']
+        ];
     }
 
     /**
@@ -331,4 +343,130 @@ class DatabasesConsoleClientTest extends Scope
         $this->assertLessThanOrEqual(1, count($logs['body']['logs']));
         $this->assertIsNumeric($logs['body']['total']);
     }
+
+    public function testTimeouts(): array
+    {
+        $database = $this->client->call(Client::METHOD_POST, '/databases', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'databaseId' => ID::unique(),
+            'name' => 'slowQueriesDatabase',
+        ]);
+
+        $databaseId = $database['body']['$id'];
+
+        $collection = $this->client->call(Client::METHOD_POST, '/databases/' . $databaseId . '/collections', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+            'x-appwrite-key' => $this->getProject()['apiKey']
+        ]), [
+            'collectionId' => ID::unique(),
+            'name' => 'Slow Queries',
+            'documentSecurity' => true,
+            'permissions' => [
+                Permission::create(Role::user($this->getUser()['$id'])),
+            ],
+        ]);
+
+        $collectionId = $collection['body']['$id'];
+
+        $this->assertEquals(201, $collection['headers']['status-code']);
+
+        $longtext = $this->client->call(Client::METHOD_POST, '/databases/' . $databaseId . '/collections/' . $collectionId . '/attributes/string', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+            'x-appwrite-key' => $this->getProject()['apiKey']
+        ]), [
+            'key' => 'longtext',
+            'size' => 100000000,
+            'required' => false,
+            'default' => null,
+        ]);
+
+        $this->assertEquals($longtext['headers']['status-code'], 202);
+
+        for ($i = 0; $i <= 1; $i++) {
+            $this->client->call(Client::METHOD_POST, '/databases/' . $databaseId . '/collections/' . $collectionId . '/documents', array_merge([
+                'content-type' => 'application/json',
+                'x-appwrite-project' => $this->getProject()['$id'],
+            ], $this->getHeaders()), [
+                'documentId' => ID::unique(),
+                'data' => [
+                    'longtext' => file_get_contents(__DIR__ . '/../../../resources/longtext.txt'),
+                ],
+                'permissions' => [
+                    Permission::read(Role::user($this->getUser()['$id'])),
+                    Permission::update(Role::user($this->getUser()['$id'])),
+                    Permission::delete(Role::user($this->getUser()['$id'])),
+                ]
+            ]);
+        }
+
+        $docs = [];
+        for ($i = 0; $i <= 5; $i++) { // _APP_SLOW_QUERIES_MAX_HITS = 5
+            $docs[] = $this->client->call(Client::METHOD_GET, '/databases/' . $databaseId . '/collections/' . $collectionId . '/documents', array_merge([
+                'content-type' => 'application/json',
+                'x-appwrite-project' => $this->getProject()['$id'],
+                'x-appwrite-timeout' => 1,
+            ], $this->getHeaders()), [
+                'queries' => [
+                    Query::notEqual('longtext', 'appwrite')->toString(),
+                ],
+            ]);
+        }
+
+        $this->assertEquals(408, $docs[0]['headers']['status-code']); // insert
+        $this->assertEquals(408, $docs[1]['headers']['status-code']); // update
+        $this->assertEquals(408, $docs[2]['headers']['status-code']); // update
+        $this->assertEquals(408, $docs[3]['headers']['status-code']); // update
+        $this->assertEquals(403, $docs[4]['headers']['status-code']); // update
+        $this->assertEquals(403, $docs[5]['headers']['status-code']); // blocked
+
+        return [
+            'databaseId' => $databaseId,
+            'collectionId' => $collectionId
+        ];
+    }
+
+    /**
+     * @depends testTimeouts
+     */
+    public function testConsoleTimeouts($data): void
+    {
+        $documents = $this->client->call(Client::METHOD_GET, '/databases/' . $data['databaseId'] . '/slow-queries', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'queries' => [
+                Query::equal('collectionId', $data['$id'])->toString(),
+                Query::equal('blocked', [true])->toString(),
+                Query::orderAsc('$updatedAt')->toString(),
+            ]
+        ]);
+
+        $this->assertEquals(200, $documents['headers']['status-code']);
+        $this->assertEquals(1, $documents['body']['total']);
+        $this->assertEquals(true, $documents['body']['documents'][0]['blocked']);
+        $this->assertEquals(5, $documents['body']['documents'][0]['count']);
+
+        $doc = $this->client->call(Client::METHOD_GET, '/databases/' . $data['databaseId'] . '/slow-queries/' . $documents['body']['documents'][0]['$id'], array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), []);
+        $this->assertEquals(200, $doc['headers']['status-code']);
+        $this->assertEquals($doc['body']['queries'][0], 'notEqual("longtext", "appwrite")');
+
+        $response = $this->client->call(Client::METHOD_DELETE, '/databases/' . $data['databaseId'] . '/slow-queries/' . $documents['body']['documents'][0]['$id'], array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), []);
+        $this->assertEquals(204, $response['headers']['status-code']);
+
+        $doc = $this->client->call(Client::METHOD_GET, '/databases/' . $data['databaseId'] . '/slow-queries/' . $documents['body']['documents'][0]['$id'], array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), []);
+        $this->assertEquals(404, $doc['headers']['status-code']);
+    }
 }