default spec

Merge branch '1.6.x' of github.com:appwrite/appwrite into feat-custom-cf-hostnames
Merge pull request #9006 from appwrite/fix-team-invite-session-creation
2026-05-26 13:51:13 +00:00 · 2024-11-22 17:18:19 +00:00 · 2024-11-22 12:42:38 +04:00 · 2024-11-22 09:38:40 +01:00 · 2024-11-22 09:21:54 +01:00 · 2024-11-21 22:44:24 +13:00
39 changed files with 2780 additions and 756 deletions
@@ -0,0 +1,33 @@
+name: "Console SDK Preview"
+
+on:
+  pull_request:
+    paths:
+      - 'app/config/specs/*-latest-console.json'
+
+
+jobs:
+  setup:
+    name: Setup & Build Console SDK
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+        
+      - name: Load and Start Appwrite
+        run: |
+          docker compose build
+          docker compose up -d
+          docker compose exec appwrite sdks --platform=console --sdk=web --version=latest --git=no
+          sudo chown -R $USER:$USER ./app/sdks/console-web
+          
+      - uses: actions/setup-node@v4
+        with:
+          node-version: 20
+
+      - name: Build and Publish SDK
+        working-directory: ./app/sdks/console-web
+        run: |
+            npm install
+            npm run build
+            npx pkg-pr-new publish --comment=update
@@ -127,6 +127,11 @@ jobs:
            Messaging,
            Migrations
          ]
+        tables-mode: [
+          'Project',
+          'Shared V1',
+          'Shared V2',
+        ]

    steps:
      - name: checkout
@@ -145,11 +150,26 @@ jobs:
          docker compose up -d
          sleep 30

-      - name: Run ${{matrix.service}} Tests
-        run: docker compose exec -T appwrite test /usr/src/code/tests/e2e/Services/${{matrix.service}} --debug
-
-      - name: Run ${{matrix.service}} Shared Tables Tests
-        run: _APP_DATABASE_SHARED_TABLES=database_db_main docker compose exec -T appwrite test /usr/src/code/tests/e2e/Services/${{matrix.service}} --debug
+      - name: Run ${{ matrix.service }} tests with ${{ matrix.tables-mode }} table mode
+        run: |
+          if [ "${{ matrix.tables-mode }}" == "Shared V1" ]; then
+            echo "Using shared tables V1"
+            export _APP_DATABASE_SHARED_TABLES=database_db_main
+            export _APP_DATABASE_SHARED_TABLES_V1=database_db_main
+          elif [ "${{ matrix.tables-mode }}" == "Shared V2" ]; then
+            echo "Using shared tables V2"
+            export _APP_DATABASE_SHARED_TABLES=database_db_main
+            export _APP_DATABASE_SHARED_TABLES_V1=
+          else
+            echo "Using project tables"
+            export _APP_DATABASE_SHARED_TABLES=
+            export _APP_DATABASE_SHARED_TABLES_V1=
+          fi
+      
+          docker compose exec -T \
+            -e _APP_DATABASE_SHARED_TABLES \
+            -e _APP_DATABASE_SHARED_TABLES_V1 \
+            appwrite test /usr/src/code/tests/e2e/Services/${{ matrix.service }} --debug

  benchmarking:
    name: Benchmark
@@ -16,3 +16,4 @@ dev/yasd_init.php
 .phpunit.result.cache
 Makefile
 appwrite.json
+/.zed/
@@ -12,7 +12,7 @@ RUN composer install --ignore-platform-reqs --optimize-autoloader \
    --no-plugins --no-scripts --prefer-dist \
    `if [ "$TESTING" != "true" ]; then echo "--no-dev"; fi`

-FROM appwrite/base:0.9.3 AS final
+FROM appwrite/base:0.9.5 AS final

 LABEL maintainer="team@appwrite.io"

@@ -114,8 +114,9 @@ CLI::setResource('getProjectDB', function (Group $pools, Database $dbForConsole,

        if (isset($databases[$dsn->getHost()])) {
            $database = $databases[$dsn->getHost()];
+            $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));

-            if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+            if (\in_array($dsn->getHost(), $sharedTables)) {
                $database
                    ->setSharedTables(true)
                    ->setTenant($project->getInternalId())
@@ -136,10 +137,10 @@ CLI::setResource('getProjectDB', function (Group $pools, Database $dbForConsole,
            ->getResource();

        $database = new Database($dbAdapter, $cache);
-
        $databases[$dsn->getHost()] = $database;
+        $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));

-        if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+        if (\in_array($dsn->getHost(), $sharedTables)) {
            $database
                ->setSharedTables(true)
                ->setTenant($project->getInternalId())
@@ -686,7 +686,7 @@ return [
    ],
    Exception::ATTRIBUTE_LIMIT_EXCEEDED => [
        'name' => Exception::ATTRIBUTE_LIMIT_EXCEEDED,
-        'description' => 'The maximum number of attributes has been reached.',
+        'description' => 'The maximum number or size of attributes for this collection has been reached.',
        'code' => 400,
    ],
    Exception::ATTRIBUTE_VALUE_INVALID => [
@@ -11,7 +11,7 @@ const TEMPLATE_RUNTIMES = [
    ],
    'DART' => [
        'name' => 'dart',
-        'versions' => ['3.5', '3.3', '3.1', '3.0', '2.19', '2.18', '2.17', '2.16', '2.16']
+        'versions' => ['3.5', '3.3', '3.1', '3.0', '2.19', '2.18', '2.17', '2.16']
    ],
    'GO' => [
        'name' => 'go',
@@ -2784,7 +2784,7 @@
                "tags": [
                    "account"
                ],
-                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour. If you are on a mobile device you can leave the URL parameter empty, so that the login completion will be handled by your Appwrite instance by default.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
+                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
                "responses": {
                    "201": {
                        "description": "Token",
@@ -2795,7 +2795,7 @@
                "tags": [
                    "account"
                ],
-                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour. If you are on a mobile device you can leave the URL parameter empty, so that the login completion will be handled by your Appwrite instance by default.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
+                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
                "responses": {
                    "201": {
                        "description": "Token",
@@ -20672,7 +20672,7 @@
        },
        "\/projects\/{projectId}\/auth\/memberships-privacy": {
            "patch": {
-                "summary": "Update project team sensitive attributes",
+                "summary": "Update project memberships privacy attributes",
                "operationId": "projectsUpdateMembershipsPrivacy",
                "tags": [
                    "projects"
@@ -36077,17 +36077,17 @@
                        "description": "Whether or not to send session alert emails to users.",
                        "x-example": true
                    },
-                    "membershipsUserName": {
+                    "authMembershipsUserName": {
                        "type": "boolean",
                        "description": "Whether or not to show user names in the teams membership response.",
                        "x-example": true
                    },
-                    "membershipsUserEmail": {
+                    "authMembershipsUserEmail": {
                        "type": "boolean",
                        "description": "Whether or not to show user emails in the teams membership response.",
                        "x-example": true
                    },
-                    "membershipsMfa": {
+                    "authMembershipsMfa": {
                        "type": "boolean",
                        "description": "Whether or not to show user MFA status in the teams membership response.",
                        "x-example": true
@@ -36297,9 +36297,9 @@
                    "authPersonalDataCheck",
                    "authMockNumbers",
                    "authSessionAlerts",
-                    "membershipsUserName",
-                    "membershipsUserEmail",
-                    "membershipsMfa",
+                    "authMembershipsUserName",
+                    "authMembershipsUserEmail",
+                    "authMembershipsMfa",
                    "oAuthProviders",
                    "platforms",
                    "webhooks",
@@ -2451,7 +2451,7 @@
                "tags": [
                    "account"
                ],
-                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour. If you are on a mobile device you can leave the URL parameter empty, so that the login completion will be handled by your Appwrite instance by default.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
+                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
                "responses": {
                    "201": {
                        "description": "Token",
@@ -2922,7 +2922,7 @@
                "tags": [
                    "account"
                ],
-                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour. If you are on a mobile device you can leave the URL parameter empty, so that the login completion will be handled by your Appwrite instance by default.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
+                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
                "responses": {
                    "201": {
                        "description": "Token",
@@ -2949,7 +2949,7 @@
                "tags": [
                    "account"
                ],
-                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour. If you are on a mobile device you can leave the URL parameter empty, so that the login completion will be handled by your Appwrite instance by default.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
+                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
                "responses": {
                    "201": {
                        "description": "Token",
@@ -21138,7 +21138,7 @@
        },
        "\/projects\/{projectId}\/auth\/memberships-privacy": {
            "patch": {
-                "summary": "Update project team sensitive attributes",
+                "summary": "Update project memberships privacy attributes",
                "operationId": "projectsUpdateMembershipsPrivacy",
                "consumes": [
                    "application\/json"
@@ -36591,17 +36591,17 @@
                    "description": "Whether or not to send session alert emails to users.",
                    "x-example": true
                },
-                "membershipsUserName": {
+                "authMembershipsUserName": {
                    "type": "boolean",
                    "description": "Whether or not to show user names in the teams membership response.",
                    "x-example": true
                },
-                "membershipsUserEmail": {
+                "authMembershipsUserEmail": {
                    "type": "boolean",
                    "description": "Whether or not to show user emails in the teams membership response.",
                    "x-example": true
                },
-                "membershipsMfa": {
+                "authMembershipsMfa": {
                    "type": "boolean",
                    "description": "Whether or not to show user MFA status in the teams membership response.",
                    "x-example": true
@@ -36815,9 +36815,9 @@
                "authPersonalDataCheck",
                "authMockNumbers",
                "authSessionAlerts",
-                "membershipsUserName",
-                "membershipsUserEmail",
-                "membershipsMfa",
+                "authMembershipsUserName",
+                "authMembershipsUserEmail",
+                "authMembershipsMfa",
                "oAuthProviders",
                "platforms",
                "webhooks",
@@ -2604,7 +2604,7 @@
                "tags": [
                    "account"
                ],
-                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour. If you are on a mobile device you can leave the URL parameter empty, so that the login completion will be handled by your Appwrite instance by default.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
+                "description": "Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST \/v1\/account\/sessions\/token](https:\/\/appwrite.io\/docs\/references\/cloud\/client-web\/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour.\n\nA user is limited to 10 active sessions at a time by default. [Learn more about session limits](https:\/\/appwrite.io\/docs\/authentication-security#limits).\n",
                "responses": {
                    "201": {
                        "description": "Token",
@@ -20,7 +20,6 @@ use Utopia\Audit\Audit;
 use Utopia\Config\Config;
 use Utopia\Database\Database;
 use Utopia\Database\Document;
-use Utopia\Database\Exception as DatabaseException;
 use Utopia\Database\Exception\Authorization as AuthorizationException;
 use Utopia\Database\Exception\Conflict as ConflictException;
 use Utopia\Database\Exception\Duplicate as DuplicateException;
@@ -153,7 +152,7 @@ function createAttribute(string $databaseId, string $collectionId, Document $att
    } catch (DuplicateException) {
        throw new Exception(Exception::ATTRIBUTE_ALREADY_EXISTS);
    } catch (LimitException) {
-        throw new Exception(Exception::ATTRIBUTE_LIMIT_EXCEEDED, 'Attribute limit exceeded');
+        throw new Exception(Exception::ATTRIBUTE_LIMIT_EXCEEDED);
    } catch (\Throwable $e) {
        $dbForProject->purgeCachedDocument('database_' . $db->getInternalId(), $collectionId);
        $dbForProject->purgeCachedCollection('database_' . $db->getInternalId() . '_collection_' . $collection->getInternalId());
@@ -197,7 +196,7 @@ function createAttribute(string $databaseId, string $collectionId, Document $att
            throw new Exception(Exception::ATTRIBUTE_ALREADY_EXISTS);
        } catch (LimitException) {
            $dbForProject->deleteDocument('attributes', $attribute->getId());
-            throw new Exception(Exception::ATTRIBUTE_LIMIT_EXCEEDED, 'Attribute limit exceeded');
+            throw new Exception(Exception::ATTRIBUTE_LIMIT_EXCEEDED);
        } catch (\Throwable $e) {
            $dbForProject->purgeCachedDocument('database_' . $db->getInternalId(), $relatedCollection->getId());
            $dbForProject->purgeCachedCollection('database_' . $db->getInternalId() . '_collection_' . $relatedCollection->getInternalId());
@@ -393,23 +392,35 @@ function updateAttribute(
            throw new Exception(Exception::ATTRIBUTE_INVALID_RESIZE);
        } catch (NotFoundException) {
            throw new Exception(Exception::ATTRIBUTE_NOT_FOUND);
+        } catch (LimitException) {
+            throw new Exception(Exception::ATTRIBUTE_LIMIT_EXCEEDED);
        }
    }

    if (!empty($newKey) && $key !== $newKey) {
-        // Delete attribute and recreate since we can't modify IDs
-        $original = clone $attribute;
-
-        $dbForProject->deleteDocument('attributes', $attribute->getId());
+        $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);
+
+            if ($found !== false) {
+                $attributes[$found] = $newKey;
+                $index->setAttribute('attributes', $attributes);
+                $dbForProject->updateDocument('indexes', $index->getId(), $index);
+            }
        }
    } else {
        $attribute = $dbForProject->updateDocument('attributes', $db->getInternalId() . '_' . $collection->getInternalId() . '_' . $key, $attribute);
@@ -2587,7 +2598,6 @@ App::post('/v1/databases/:databaseId/collections/:collectionId/indexes')

            $attributeStatus = $oldAttributes[$attributeIndex]['status'];
            $attributeType = $oldAttributes[$attributeIndex]['type'];
-            $attributeSize = $oldAttributes[$attributeIndex]['size'];
            $attributeArray = $oldAttributes[$attributeIndex]['array'] ?? false;

            if ($attributeType === Database::VAR_RELATIONSHIP) {
@@ -2601,10 +2611,6 @@ App::post('/v1/databases/:databaseId/collections/:collectionId/indexes')

            $lengths[$i] = null;

-            if ($attributeType === Database::VAR_STRING) {
-                $lengths[$i] = $attributeSize; // set attribute size as index length only for strings
-            }
-
            if ($attributeArray === true) {
                $lengths[$i] = Database::ARRAY_INDEX_LENGTH;
                $orders[$i] = null;
@@ -2627,7 +2633,8 @@ App::post('/v1/databases/:databaseId/collections/:collectionId/indexes')

        $validator = new IndexValidator(
            $collection->getAttribute('attributes'),
-            $dbForProject->getAdapter()->getMaxIndexLength()
+            $dbForProject->getAdapter()->getMaxIndexLength(),
+            $dbForProject->getAdapter()->getInternalIndexesKeys(),
        );
        if (!$validator->isValid($index)) {
            throw new Exception(Exception::INDEX_INVALID, $validator->getDescription());
@@ -122,6 +122,10 @@ App::post('/v1/projects')

        $projectId = ($projectId == 'unique()') ? ID::unique() : $projectId;

+        if ($projectId === 'console') {
+            throw new Exception(Exception::PROJECT_RESERVED_PROJECT, "'console' is a reserved project.");
+        }
+
        $databases = Config::getParam('pools-database', []);

        $databaseOverride = System::getEnv('_APP_DATABASE_OVERRIDE');
@@ -132,16 +136,14 @@ App::post('/v1/projects')
            $dsn = $databases[array_rand($databases)];
        }

-        if ($projectId === 'console') {
-            throw new Exception(Exception::PROJECT_RESERVED_PROJECT, "'console' is a reserved project.");
-        }
-
        // TODO: Temporary until all projects are using shared tables.
-        if ($dsn === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+        $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+
+        if (\in_array($dsn, $sharedTables)) {
            $schema = 'appwrite';
            $database = 'appwrite';
            $namespace = System::getEnv('_APP_DATABASE_SHARED_NAMESPACE', '');
-            $dsn = $schema . '://' . System::getEnv('_APP_DATABASE_SHARED_TABLES', '') . '?database=' . $database;
+            $dsn = $schema . '://' . $dsn . '?database=' . $database;

            if (!empty($namespace)) {
                $dsn .= '&namespace=' . $namespace;
@@ -195,47 +197,92 @@ App::post('/v1/projects')

        $adapter = $pools->get($dsn->getHost())->pop()->getResource();
        $dbForProject = new Database($adapter, $cache);
+        $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+        $sharedTablesV1 = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES_V1', ''));

-        if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
-            $dbForProject
-                ->setSharedTables(true)
-                ->setTenant($project->getInternalId())
-                ->setNamespace($dsn->getParam('namespace'));
-        } else {
-            $dbForProject
-                ->setSharedTables(false)
-                ->setTenant(null)
-                ->setNamespace('_' . $project->getInternalId());
-        }
+        $projectTables = !\in_array($dsn->getHost(), $sharedTables);
+        $sharedTablesV1 = \in_array($dsn->getHost(), $sharedTablesV1);
+        $sharedTablesV2 = !$projectTables && !$sharedTablesV1;
+        $sharedTables = $sharedTablesV1 || $sharedTablesV2;

-        $dbForProject->create();
-
-        $audit = new Audit($dbForProject);
-        $audit->setup();
-
-        $abuse = new TimeLimit('', 0, 1, $dbForProject);
-        $abuse->setup();
-
-        /** @var array $collections */
-        $collections = Config::getParam('collections', [])['projects'] ?? [];
-
-        foreach ($collections as $key => $collection) {
-            if (($collection['$collection'] ?? '') !== Database::METADATA) {
-                continue;
+        if (!$sharedTablesV2) {
+            if ($sharedTables) {
+                $dbForProject
+                    ->setSharedTables(true)
+                    ->setTenant($sharedTablesV1 ? $project->getInternalId() : null)
+                    ->setNamespace($dsn->getParam('namespace'));
+            } else {
+                $dbForProject
+                    ->setSharedTables(false)
+                    ->setTenant(null)
+                    ->setNamespace('_' . $project->getInternalId());
            }

-            $attributes = \array_map(function (array $attribute) {
-                return new Document($attribute);
-            }, $collection['attributes']);
-
-            $indexes = \array_map(function (array $index) {
-                return new Document($index);
-            }, $collection['indexes']);
+            $create = true;

            try {
-                $dbForProject->createCollection($key, $attributes, $indexes);
+                $dbForProject->create();
            } catch (Duplicate) {
-                // Collection already exists
+                $create = false;
+            }
+
+            if ($create || $projectTables) {
+                $audit = new Audit($dbForProject);
+                $audit->setup();
+
+                $abuse = new TimeLimit('', 0, 1, $dbForProject);
+                $abuse->setup();
+            }
+
+            if (!$create && $sharedTablesV1) {
+                $attributes = \array_map(fn ($attribute) => new Document($attribute), Audit::ATTRIBUTES);
+                $indexes = \array_map(fn (array $index) => new Document($index), Audit::INDEXES);
+                $dbForProject->createDocument(Database::METADATA, new Document([
+                    '$id' => ID::custom('audit'),
+                    '$permissions' => [Permission::create(Role::any())],
+                    'name' => 'audit',
+                    'attributes' => $attributes,
+                    'indexes' => $indexes,
+                    'documentSecurity' => true
+                ]));
+
+                $attributes = \array_map(fn ($attribute) => new Document($attribute), TimeLimit::ATTRIBUTES);
+                $indexes = \array_map(fn (array $index) => new Document($index), TimeLimit::INDEXES);
+                $dbForProject->createDocument(Database::METADATA, new Document([
+                    '$id' => ID::custom('abuse'),
+                    '$permissions' => [Permission::create(Role::any())],
+                    'name' => 'abuse',
+                    'attributes' => $attributes,
+                    'indexes' => $indexes,
+                    'documentSecurity' => true
+                ]));
+            }
+
+            if ($create || $sharedTablesV1) {
+                /** @var array $collections */
+                $collections = Config::getParam('collections', [])['projects'] ?? [];
+
+                foreach ($collections as $key => $collection) {
+                    if (($collection['$collection'] ?? '') !== Database::METADATA) {
+                        continue;
+                    }
+
+                    $attributes = \array_map(fn ($attribute) => new Document($attribute), $collection['attributes']);
+                    $indexes = \array_map(fn (array $index) => new Document($index), $collection['indexes']);
+
+                    try {
+                        $dbForProject->createCollection($key, $attributes, $indexes);
+                    } catch (Duplicate) {
+                        $dbForProject->createDocument(Database::METADATA, new Document([
+                            '$id' => ID::custom($key),
+                            '$permissions' => [Permission::create(Role::any())],
+                            'name' => $key,
+                            'attributes' => $attributes,
+                            'indexes' => $indexes,
+                            'documentSecurity' => true
+                        ]));
+                    }
+                }
            }
        }

@@ -68,19 +68,19 @@ App::post('/v1/storage/buckets')
    ->param('enabled', true, new Boolean(true), 'Is bucket enabled? When set to \'disabled\', users cannot access the files in this bucket but Server SDKs with and API key can still access the bucket. No files are lost when this is toggled.', true)
    ->param('maximumFileSize', fn (array $plan) => empty($plan['fileSize']) ? (int) System::getEnv('_APP_STORAGE_LIMIT', 0) : $plan['fileSize'] * 1000 * 1000, fn (array $plan) => new Range(1, empty($plan['fileSize']) ? (int) System::getEnv('_APP_STORAGE_LIMIT', 0) : $plan['fileSize'] * 1000 * 1000), 'Maximum file size allowed in bytes. Maximum allowed value is ' . Storage::human(System::getEnv('_APP_STORAGE_LIMIT', 0), 0) . '.', true, ['plan'])
    ->param('allowedFileExtensions', [], new ArrayList(new Text(64), APP_LIMIT_ARRAY_PARAMS_SIZE), 'Allowed file extensions. Maximum of ' . APP_LIMIT_ARRAY_PARAMS_SIZE . ' extensions are allowed, each 64 characters long.', true)
-    ->param('compression', Compression::NONE, new WhiteList([Compression::NONE, Compression::GZIP, Compression::ZSTD]), 'Compression algorithm choosen for compression. Can be one of ' . Compression::NONE . ',  [' . Compression::GZIP . '](https://en.wikipedia.org/wiki/Gzip), or [' . Compression::ZSTD . '](https://en.wikipedia.org/wiki/Zstd), For file size above ' . Storage::human(APP_STORAGE_READ_BUFFER, 0) . ' compression is skipped even if it\'s enabled', true)
+    ->param('compression', Compression::NONE, new WhiteList([Compression::NONE, Compression::GZIP, Compression::ZSTD], true), 'Compression algorithm choosen for compression. Can be one of ' . Compression::NONE . ',  [' . Compression::GZIP . '](https://en.wikipedia.org/wiki/Gzip), or [' . Compression::ZSTD . '](https://en.wikipedia.org/wiki/Zstd), For file size above ' . Storage::human(APP_STORAGE_READ_BUFFER, 0) . ' compression is skipped even if it\'s enabled', true)
    ->param('encryption', true, new Boolean(true), 'Is encryption enabled? For file size above ' . Storage::human(APP_STORAGE_READ_BUFFER, 0) . ' encryption is skipped even if it\'s enabled', true)
    ->param('antivirus', true, new Boolean(true), 'Is virus scanning enabled? For file size above ' . Storage::human(APP_LIMIT_ANTIVIRUS, 0) . ' AntiVirus scanning is skipped even if it\'s enabled', true)
    ->inject('response')
    ->inject('dbForProject')
    ->inject('queueForEvents')
-    ->action(function (string $bucketId, string $name, ?array $permissions, bool $fileSecurity, bool $enabled, int $maximumFileSize, array $allowedFileExtensions, string $compression, bool $encryption, bool $antivirus, Response $response, Database $dbForProject, Event $queueForEvents) {
+    ->action(function (string $bucketId, string $name, ?array $permissions, bool $fileSecurity, bool $enabled, int $maximumFileSize, array $allowedFileExtensions, ?string $compression, bool $encryption, bool $antivirus, Response $response, Database $dbForProject, Event $queueForEvents) {

        $bucketId = $bucketId === 'unique()' ? ID::unique() : $bucketId;

        // Map aggregate permissions into the multiple permissions they represent.
        $permissions = Permission::aggregate($permissions);
-
+        $compression ??= Compression::NONE;
        try {
            $files = (Config::getParam('collections', [])['buckets'] ?? [])['files'] ?? [];
            if (empty($files)) {
@@ -254,13 +254,13 @@ App::put('/v1/storage/buckets/:bucketId')
    ->param('enabled', true, new Boolean(true), 'Is bucket enabled? When set to \'disabled\', users cannot access the files in this bucket but Server SDKs with and API key can still access the bucket. No files are lost when this is toggled.', true)
    ->param('maximumFileSize', fn (array $plan) => empty($plan['fileSize']) ? (int) System::getEnv('_APP_STORAGE_LIMIT', 0) : $plan['fileSize'] * 1000 * 1000, fn (array $plan) => new Range(1, empty($plan['fileSize']) ? (int) System::getEnv('_APP_STORAGE_LIMIT', 0) : $plan['fileSize'] * 1000 * 1000), 'Maximum file size allowed in bytes. Maximum allowed value is ' . Storage::human(System::getEnv('_APP_STORAGE_LIMIT', 0), 0) . '.', true, ['plan'])
    ->param('allowedFileExtensions', [], new ArrayList(new Text(64), APP_LIMIT_ARRAY_PARAMS_SIZE), 'Allowed file extensions. Maximum of ' . APP_LIMIT_ARRAY_PARAMS_SIZE . ' extensions are allowed, each 64 characters long.', true)
-    ->param('compression', Compression::NONE, new WhiteList([Compression::NONE, Compression::GZIP, Compression::ZSTD]), 'Compression algorithm choosen for compression. Can be one of ' . Compression::NONE . ', [' . Compression::GZIP . '](https://en.wikipedia.org/wiki/Gzip), or [' . Compression::ZSTD . '](https://en.wikipedia.org/wiki/Zstd), For file size above ' . Storage::human(APP_STORAGE_READ_BUFFER, 0) . ' compression is skipped even if it\'s enabled', true)
+    ->param('compression', Compression::NONE, new WhiteList([Compression::NONE, Compression::GZIP, Compression::ZSTD], true), 'Compression algorithm choosen for compression. Can be one of ' . Compression::NONE . ', [' . Compression::GZIP . '](https://en.wikipedia.org/wiki/Gzip), or [' . Compression::ZSTD . '](https://en.wikipedia.org/wiki/Zstd), For file size above ' . Storage::human(APP_STORAGE_READ_BUFFER, 0) . ' compression is skipped even if it\'s enabled', true)
    ->param('encryption', true, new Boolean(true), 'Is encryption enabled? For file size above ' . Storage::human(APP_STORAGE_READ_BUFFER, 0) . ' encryption is skipped even if it\'s enabled', true)
    ->param('antivirus', true, new Boolean(true), 'Is virus scanning enabled? For file size above ' . Storage::human(APP_LIMIT_ANTIVIRUS, 0) . ' AntiVirus scanning is skipped even if it\'s enabled', true)
    ->inject('response')
    ->inject('dbForProject')
    ->inject('queueForEvents')
-    ->action(function (string $bucketId, string $name, ?array $permissions, bool $fileSecurity, bool $enabled, ?int $maximumFileSize, array $allowedFileExtensions, string $compression, bool $encryption, bool $antivirus, Response $response, Database $dbForProject, Event $queueForEvents) {
+    ->action(function (string $bucketId, string $name, ?array $permissions, bool $fileSecurity, bool $enabled, ?int $maximumFileSize, array $allowedFileExtensions, ?string $compression, bool $encryption, bool $antivirus, Response $response, Database $dbForProject, Event $queueForEvents) {
        $bucket = $dbForProject->getDocument('buckets', $bucketId);

        if ($bucket->isEmpty()) {
@@ -273,6 +273,7 @@ App::put('/v1/storage/buckets/:bucketId')
        $enabled ??= $bucket->getAttribute('enabled', true);
        $encryption ??= $bucket->getAttribute('encryption', true);
        $antivirus ??= $bucket->getAttribute('antivirus', true);
+        $compression ??= $bucket->getAttribute('compression', Compression::NONE);

        // Map aggregate permissions into the multiple permissions they represent.
        $permissions = Permission::aggregate($permissions);
@@ -805,8 +805,11 @@ App::get('/v1/teams/:teamId/memberships')
        }, $membershipsPrivacy);

        $memberships = array_map(function ($membership) use ($dbForProject, $team, $membershipsPrivacy) {
+            $user = !empty(array_filter($membershipsPrivacy))
+                ? $dbForProject->getDocument('users', $membership->getAttribute('userId'))
+                : new Document();
+
            if ($membershipsPrivacy['mfa']) {
-                $user = $dbForProject->getDocument('users', $membership->getAttribute('userId'));
                $mfa = $user->getAttribute('mfa', false);

                if ($mfa) {
@@ -888,9 +891,11 @@ App::get('/v1/teams/:teamId/memberships/:membershipId')
            return $privacy || $isPrivilegedUser || $isAppUser;
        }, $membershipsPrivacy);

-        if ($membershipsPrivacy['mfa']) {
-            $user = $dbForProject->getDocument('users', $membership->getAttribute('userId'));
+        $user = !empty(array_filter($membershipsPrivacy))
+            ? $dbForProject->getDocument('users', $membership->getAttribute('userId'))
+            : new Document();

+        if ($membershipsPrivacy['mfa']) {
            $mfa = $user->getAttribute('mfa', false);

            if ($mfa) {
@@ -1055,7 +1060,8 @@ App::patch('/v1/teams/:teamId/memberships/:membershipId/status')
            throw new Exception(Exception::TEAM_INVITE_MISMATCH, 'Invite does not belong to current user (' . $user->getAttribute('email') . ')');
        }

-        if ($user->isEmpty()) {
+        $hasSession = !$user->isEmpty();
+        if (!$hasSession) {
            $user->setAttributes($dbForProject->getDocument('users', $userId)->getArrayCopy()); // Get user
        }

@@ -1074,39 +1080,64 @@ App::patch('/v1/teams/:teamId/memberships/:membershipId/status')

        Authorization::skip(fn () => $dbForProject->updateDocument('users', $user->getId(), $user->setAttribute('emailVerification', true)));

-        // Log user in
+        // Create session for the user if not logged in
+        if (!$hasSession) {
+            Authorization::setRole(Role::user($user->getId())->toString());

-        Authorization::setRole(Role::user($user->getId())->toString());
+            $detector = new Detector($request->getUserAgent('UNKNOWN'));
+            $record = $geodb->get($request->getIP());
+            $authDuration = $project->getAttribute('auths', [])['duration'] ?? Auth::TOKEN_EXPIRATION_LOGIN_LONG;
+            $expire = DateTime::addSeconds(new \DateTime(), $authDuration);
+            $secret = Auth::tokenGenerator();
+            $session = new Document(array_merge([
+                '$id' => ID::unique(),
+                '$permissions' => [
+                    Permission::read(Role::user($user->getId())),
+                    Permission::update(Role::user($user->getId())),
+                    Permission::delete(Role::user($user->getId())),
+                ],
+                'userId' => $user->getId(),
+                'userInternalId' => $user->getInternalId(),
+                'provider' => Auth::SESSION_PROVIDER_EMAIL,
+                'providerUid' => $user->getAttribute('email'),
+                'secret' => Auth::hash($secret), // One way hash encryption to protect DB leak
+                'userAgent' => $request->getUserAgent('UNKNOWN'),
+                'ip' => $request->getIP(),
+                'factors' => ['email'],
+                'countryCode' => ($record) ? \strtolower($record['country']['iso_code']) : '--',
+                'expire' => DateTime::addSeconds(new \DateTime(), $authDuration)
+            ], $detector->getOS(), $detector->getClient(), $detector->getDevice()));

-        $detector = new Detector($request->getUserAgent('UNKNOWN'));
-        $record = $geodb->get($request->getIP());
-        $authDuration = $project->getAttribute('auths', [])['duration'] ?? Auth::TOKEN_EXPIRATION_LOGIN_LONG;
-        $expire = DateTime::addSeconds(new \DateTime(), $authDuration);
-        $secret = Auth::tokenGenerator();
-        $session = new Document(array_merge([
-            '$id' => ID::unique(),
-            'userId' => $user->getId(),
-            'userInternalId' => $user->getInternalId(),
-            'provider' => Auth::SESSION_PROVIDER_EMAIL,
-            'providerUid' => $user->getAttribute('email'),
-            'secret' => Auth::hash($secret), // One way hash encryption to protect DB leak
-            'userAgent' => $request->getUserAgent('UNKNOWN'),
-            'ip' => $request->getIP(),
-            'factors' => ['email'],
-            'countryCode' => ($record) ? \strtolower($record['country']['iso_code']) : '--',
-            'expire' => DateTime::addSeconds(new \DateTime(), $authDuration)
-        ], $detector->getOS(), $detector->getClient(), $detector->getDevice()));
+            $session = $dbForProject->createDocument('sessions', $session);

-        $session = $dbForProject->createDocument('sessions', $session
-            ->setAttribute('$permissions', [
-                Permission::read(Role::user($user->getId())),
-                Permission::update(Role::user($user->getId())),
-                Permission::delete(Role::user($user->getId())),
-            ]));
+            Authorization::setRole(Role::user($userId)->toString());

-        $dbForProject->purgeCachedDocument('users', $user->getId());
+            if (!Config::getParam('domainVerification')) {
+                $response->addHeader('X-Fallback-Cookies', \json_encode([Auth::$cookieName => Auth::encodeSession($user->getId(), $secret)]));
+            }

-        Authorization::setRole(Role::user($userId)->toString());
+            $response
+                ->addCookie(
+                    name: Auth::$cookieName . '_legacy',
+                    value: Auth::encodeSession($user->getId(), $secret),
+                    expire: (new \DateTime($expire))->getTimestamp(),
+                    path: '/',
+                    domain: Config::getParam('cookieDomain'),
+                    secure: ('https' === $protocol),
+                    httponly: true
+                )
+                ->addCookie(
+                    name: Auth::$cookieName,
+                    value: Auth::encodeSession($user->getId(), $secret),
+                    expire: (new \DateTime($expire))->getTimestamp(),
+                    path: '/',
+                    domain: Config::getParam('cookieDomain'),
+                    secure: ('https' === $protocol),
+                    httponly: true,
+                    sameSite: Config::getParam('cookieSamesite')
+                )
+            ;
+        }

        $membership = $dbForProject->updateDocument('memberships', $membership->getId(), $membership);

@@ -1120,22 +1151,11 @@ App::patch('/v1/teams/:teamId/memberships/:membershipId/status')
            ->setParam('membershipId', $membership->getId())
        ;

-        if (!Config::getParam('domainVerification')) {
-            $response
-                ->addHeader('X-Fallback-Cookies', \json_encode([Auth::$cookieName => Auth::encodeSession($user->getId(), $secret)]))
-            ;
-        }
-
-        $response
-            ->addCookie(Auth::$cookieName . '_legacy', Auth::encodeSession($user->getId(), $secret), (new \DateTime($expire))->getTimestamp(), '/', Config::getParam('cookieDomain'), ('https' == $protocol), true, null)
-            ->addCookie(Auth::$cookieName, Auth::encodeSession($user->getId(), $secret), (new \DateTime($expire))->getTimestamp(), '/', Config::getParam('cookieDomain'), ('https' == $protocol), true, Config::getParam('cookieSamesite'))
-        ;
-
        $response->dynamic(
            $membership
-            ->setAttribute('teamName', $team->getAttribute('name'))
-            ->setAttribute('userName', $user->getAttribute('name'))
-            ->setAttribute('userEmail', $user->getAttribute('email')),
+                ->setAttribute('teamName', $team->getAttribute('name'))
+                ->setAttribute('userName', $user->getAttribute('name'))
+                ->setAttribute('userEmail', $user->getAttribute('email')),
            Response::MODEL_MEMBERSHIP
        );
    });
@@ -63,7 +63,7 @@ function router(App $utopia, Database $dbForConsole, callable $getProjectDB, Swo
        }

        if (System::getEnv('_APP_OPTIONS_ROUTER_PROTECTION', 'disabled') === 'enabled') {
-            if ($host !== 'localhost' && $host !== APP_HOSTNAME_INTERNAL) { // localhost allowed for proxy, APP_HOSTNAME_INTERNAL allowed for migrations
+            if ($host !== 'localhost' && $host !== APP_HOSTNAME_INTERNAL && $host !== System::getEnv('_APP_CONSOLE_DOMAIN', '')) {
                throw new AppwriteException(AppwriteException::GENERAL_ACCESS_FORBIDDEN, 'Router protection does not allow accessing Appwrite over this domain. Please add it as custom domain to your project or disable _APP_OPTIONS_ROUTER_PROTECTION environment variable.');
            }
        }
@@ -12,10 +12,12 @@ use Swoole\Process;
 use Utopia\Abuse\Adapters\Database\TimeLimit;
 use Utopia\App;
 use Utopia\Audit\Audit;
+use Utopia\Cache\Cache;
 use Utopia\CLI\Console;
 use Utopia\Config\Config;
 use Utopia\Database\Database;
 use Utopia\Database\Document;
+use Utopia\Database\Exception\Duplicate;
 use Utopia\Database\Helpers\ID;
 use Utopia\Database\Helpers\Permission;
 use Utopia\Database\Helpers\Role;
@@ -60,8 +62,6 @@ include __DIR__ . '/controllers/general.php';

 $http->on(Constant::EVENT_START, function (Server $http) use ($payloadSize, $register) {
    $app = new App('UTC');
-    $app->setCompression(true);
-    $app->setCompressionMinSize(intval(System::getEnv('_APP_COMPRESSION_MIN_SIZE_BYTES', '1024'))); // 1KB

    go(function () use ($register, $app) {
        $pools = $register->get('pools');
@@ -91,9 +91,9 @@ $http->on(Constant::EVENT_START, function (Server $http) use ($payloadSize, $reg
        Console::success('[Setup] - Server database init started...');

        try {
-            Console::success('[Setup] - Creating database: appwrite...');
+            Console::success('[Setup] - Creating console database...');
            $dbForConsole->create();
-        } catch (\Throwable $e) {
+        } catch (Duplicate) {
            Console::success('[Setup] - Skip: metadata table already exists');
        }

@@ -118,34 +118,10 @@ $http->on(Constant::EVENT_START, function (Server $http) use ($payloadSize, $reg
                continue;
            }

-            Console::success('[Setup] - Creating collection: ' . $collection['$id'] . '...');
+            Console::success('[Setup] - Creating console collection: ' . $collection['$id'] . '...');

-            $attributes = [];
-            $indexes = [];
-
-            foreach ($collection['attributes'] as $attribute) {
-                $attributes[] = new Document([
-                    '$id' => ID::custom($attribute['$id']),
-                    'type' => $attribute['type'],
-                    'size' => $attribute['size'],
-                    'required' => $attribute['required'],
-                    'signed' => $attribute['signed'],
-                    'array' => $attribute['array'],
-                    'filters' => $attribute['filters'],
-                    'default' => $attribute['default'] ?? null,
-                    'format' => $attribute['format'] ?? ''
-                ]);
-            }
-
-            foreach ($collection['indexes'] as $index) {
-                $indexes[] = new Document([
-                    '$id' => ID::custom($index['$id']),
-                    'type' => $index['type'],
-                    'attributes' => $index['attributes'],
-                    'lengths' => $index['lengths'],
-                    'orders' => $index['orders'],
-                ]);
-            }
+            $attributes = \array_map(fn ($attribute) => new Document($attribute), $collection['attributes']);
+            $indexes = \array_map(fn (array $index) => new Document($index), $collection['indexes']);

            $dbForConsole->createCollection($key, $attributes, $indexes);
        }
@@ -180,36 +156,55 @@ $http->on(Constant::EVENT_START, function (Server $http) use ($payloadSize, $reg
                throw new Exception('Files collection is not configured.');
            }

-            $attributes = [];
-            $indexes = [];
-
-            foreach ($files['attributes'] as $attribute) {
-                $attributes[] = new Document([
-                    '$id' => ID::custom($attribute['$id']),
-                    'type' => $attribute['type'],
-                    'size' => $attribute['size'],
-                    'required' => $attribute['required'],
-                    'signed' => $attribute['signed'],
-                    'array' => $attribute['array'],
-                    'filters' => $attribute['filters'],
-                    'default' => $attribute['default'] ?? null,
-                    'format' => $attribute['format'] ?? ''
-                ]);
-            }
-
-            foreach ($files['indexes'] as $index) {
-                $indexes[] = new Document([
-                    '$id' => ID::custom($index['$id']),
-                    'type' => $index['type'],
-                    'attributes' => $index['attributes'],
-                    'lengths' => $index['lengths'],
-                    'orders' => $index['orders'],
-                ]);
-            }
+            $attributes = \array_map(fn ($attribute) => new Document($attribute), $files['attributes']);
+            $indexes = \array_map(fn (array $index) => new Document($index), $files['indexes']);

            $dbForConsole->createCollection('bucket_' . $bucket->getInternalId(), $attributes, $indexes);
        }

+        $projectCollections = $collections['projects'];
+        $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+        $sharedTablesV1 = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES_V1', ''));
+        $sharedTablesV2 = \array_diff($sharedTables, $sharedTablesV1);
+
+        $cache = $app->getResource('cache');
+
+        foreach ($sharedTablesV2 as $hostname) {
+            $adapter = $pools
+                ->get($hostname)
+                ->pop()
+                ->getResource();
+
+            $dbForProject = (new Database($adapter, $cache))
+                ->setDatabase('appwrite')
+                ->setSharedTables(true)
+                ->setTenant(null)
+                ->setNamespace(System::getEnv('_APP_DATABASE_SHARED_NAMESPACE', ''));
+
+            try {
+                Console::success('[Setup] - Creating project database: ' . $hostname . '...');
+                $dbForProject->create();
+            } catch (Duplicate) {
+                Console::success('[Setup] - Skip: metadata table already exists');
+            }
+
+            foreach ($projectCollections as $key => $collection) {
+                if (($collection['$collection'] ?? '') !== Database::METADATA) {
+                    continue;
+                }
+                if (!$dbForProject->getCollection($key)->isEmpty()) {
+                    continue;
+                }
+
+                $attributes = \array_map(fn ($attribute) => new Document($attribute), $collection['attributes']);
+                $indexes = \array_map(fn (array $index) => new Document($index), $collection['indexes']);
+
+                Console::success('[Setup] - Creating project collection: ' . $collection['$id'] . '...');
+
+                $dbForProject->createCollection($key, $attributes, $indexes);
+            }
+        }
+
        $pools->reclaim();

        Console::success('[Setup] - Server database init completed...');
@@ -225,7 +220,7 @@ $http->on(Constant::EVENT_START, function (Server $http) use ($payloadSize, $reg
    });
 });

-$http->on('request', function (SwooleRequest $swooleRequest, SwooleResponse $swooleResponse) use ($register) {
+$http->on(Constant::EVENT_REQUEST, function (SwooleRequest $swooleRequest, SwooleResponse $swooleResponse) use ($register) {
    App::setResource('swooleRequest', fn () => $swooleRequest);
    App::setResource('swooleResponse', fn () => $swooleResponse);

@@ -153,9 +153,9 @@ const APP_SOCIAL_DEV = 'https://dev.to/appwrite';
 const APP_SOCIAL_STACKSHARE = 'https://stackshare.io/appwrite';
 const APP_SOCIAL_YOUTUBE = 'https://www.youtube.com/c/appwrite?sub_confirmation=1';
 const APP_HOSTNAME_INTERNAL = 'appwrite';
-const APP_FUNCTION_SPECIFICATION_DEFAULT = Specification::S_1VCPU_512MB;
-const APP_FUNCTION_CPUS_DEFAULT = 0.5;
-const APP_FUNCTION_MEMORY_DEFAULT = 512;
+const APP_FUNCTION_SPECIFICATION_DEFAULT = Specification::S_4VCPU_4GB;
+const APP_FUNCTION_CPUS_DEFAULT = 4;
+const APP_FUNCTION_MEMORY_DEFAULT = 4096;
 const APP_PLATFORM_SERVER = 'server';
 const APP_PLATFORM_CLIENT = 'client';
 const APP_PLATFORM_CONSOLE = 'console';
@@ -1425,14 +1425,9 @@ App::setResource('dbForProject', function (Group $pools, Database $dbForConsole,
        ->setTimeout(APP_DATABASE_TIMEOUT_MILLISECONDS)
        ->setMaxQueryValues(APP_DATABASE_QUERY_MAX_VALUES);

-    try {
-        $dsn = new DSN($project->getAttribute('database'));
-    } catch (\InvalidArgumentException) {
-        // TODO: Temporary until all projects are using shared tables
-        $dsn = new DSN('mysql://' . $project->getAttribute('database'));
-    }
+    $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));

-    if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+    if (\in_array($dsn->getHost(), $sharedTables)) {
        $database
            ->setSharedTables(true)
            ->setTenant($project->getInternalId())
@@ -1487,7 +1482,9 @@ App::setResource('getProjectDB', function (Group $pools, Database $dbForConsole,
                ->setTimeout(APP_DATABASE_TIMEOUT_MILLISECONDS)
                ->setMaxQueryValues(APP_DATABASE_QUERY_MAX_VALUES);

-            if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+            $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+
+            if (\in_array($dsn->getHost(), $sharedTables)) {
                $database
                    ->setSharedTables(true)
                    ->setTenant($project->getInternalId())
@@ -29,6 +29,7 @@ use Utopia\Database\Validator\Authorization;
 use Utopia\DSN\DSN;
 use Utopia\Logger\Log;
 use Utopia\System\System;
+use Utopia\Telemetry\Adapter\None as NoTelemetry;
 use Utopia\WebSocket\Adapter;
 use Utopia\WebSocket\Server;

@@ -92,7 +93,9 @@ if (!function_exists('getProjectDB')) {

        $database = new Database($adapter, getCache());

-        if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+        $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+
+        if (\in_array($dsn->getHost(), $sharedTables)) {
            $database
                ->setSharedTables(true)
                ->setTenant($project->getInternalId())
@@ -142,6 +145,13 @@ if (!function_exists('getRealtime')) {
    }
 }

+if (!function_exists('getTelemetry')) {
+    function getTelemetry(int $workerId): Utopia\Telemetry\Adapter
+    {
+        return new NoTelemetry();
+    }
+}
+
 $realtime = getRealtime();

 /**
@@ -274,6 +284,12 @@ $server->onStart(function () use ($stats, $register, $containerId, &$statsDocume
 $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats, $realtime, $logError) {
    Console::success('Worker ' . $workerId . ' started successfully');

+    $telemetry = getTelemetry($workerId);
+    $register->set('telemetry', fn () => $telemetry);
+    $register->set('telemetry.connectionCounter', fn () => $telemetry->createUpDownCounter('realtime.server.open_connections'));
+    $register->set('telemetry.connectionCreatedCounter', fn () => $telemetry->createCounter('realtime.server.connection.created'));
+    $register->set('telemetry.messageSentCounter', fn () => $telemetry->createCounter('realtime.server.message.sent'));
+
    $attempts = 0;
    $start = time();

@@ -416,6 +432,7 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
                );

                if (($num = count($receivers)) > 0) {
+                    $register->get('telemetry.messageSentCounter')->add($num);
                    $stats->incr($event['project'], 'messages', $num);
                }
            });
@@ -519,6 +536,9 @@ $server->onOpen(function (int $connection, SwooleRequest $request) use ($server,
            ]
        ]));

+        $register->get('telemetry.connectionCounter')->add(1);
+        $register->get('telemetry.connectionCreatedCounter')->add(1);
+
        $stats->set($project->getId(), [
            'projectId' => $project->getId(),
            'teamId' => $project->getAttribute('teamId')
@@ -592,9 +612,12 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
        }

        switch ($message['type']) {
-            /**
-             * This type is used to authenticate.
-             */
+            case 'ping':
+                $server->send([$connection], json_encode([
+                    'type' => 'pong'
+                ]));
+
+                break;
            case 'authentication':
                if (!array_key_exists('session', $message['data'])) {
                    throw new Exception(Exception::REALTIME_MESSAGE_FORMAT_INVALID, 'Payload is not valid.');
@@ -652,12 +675,14 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
    }
 });

-$server->onClose(function (int $connection) use ($realtime, $stats) {
+$server->onClose(function (int $connection) use ($realtime, $stats, $register) {
    if (array_key_exists($connection, $realtime->connections)) {
        $stats->decr($realtime->connections[$connection]['projectId'], 'connectionsTotal');
    }
    $realtime->unsubscribe($connection);

+    $register->get('telemetry.connectionCounter')->add(-1);
+
    Console::info('Connection close: ' . $connection);
 });

@@ -93,7 +93,9 @@ Server::setResource('dbForProject', function (Cache $cache, Registry $register,
        $dsn = new DSN('mysql://' . $project->getAttribute('database'));
    }

-    if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+    $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+
+    if (\in_array($dsn->getHost(), $sharedTables)) {
        $database
            ->setSharedTables(true)
            ->setTenant($project->getInternalId())
@@ -126,7 +128,9 @@ Server::setResource('getProjectDB', function (Group $pools, Database $dbForConso
        if (isset($databases[$dsn->getHost()])) {
            $database = $databases[$dsn->getHost()];

-            if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+            $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+
+            if (\in_array($dsn->getHost(), $sharedTables)) {
                $database
                    ->setSharedTables(true)
                    ->setTenant($project->getInternalId())
@@ -150,7 +154,9 @@ Server::setResource('getProjectDB', function (Group $pools, Database $dbForConso

        $databases[$dsn->getHost()] = $database;

-        if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+        $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+
+        if (\in_array($dsn->getHost(), $sharedTables)) {
            $database
                ->setSharedTables(true)
                ->setTenant($project->getInternalId())
@@ -277,6 +283,50 @@ Server::setResource(
    fn () => fn (Document $project, string $resourceType, ?string $resourceId) => false
 );

+Server::setResource('logError', function (Registry $register, Document $project) {
+    return function (Throwable $error, string $namespace, string $action, ?array $extras) use ($register, $project) {
+        $logger = $register->get('logger');
+
+        if ($logger) {
+            $version = System::getEnv('_APP_VERSION', 'UNKNOWN');
+
+            $log = new Log();
+            $log->setNamespace($namespace);
+            $log->setServer(\gethostname());
+            $log->setVersion($version);
+            $log->setType(Log::TYPE_ERROR);
+            $log->setMessage($error->getMessage());
+
+            $log->addTag('code', $error->getCode());
+            $log->addTag('verboseType', get_class($error));
+            $log->addTag('projectId', $project->getId() ?? '');
+
+            $log->addExtra('file', $error->getFile());
+            $log->addExtra('line', $error->getLine());
+            $log->addExtra('trace', $error->getTraceAsString());
+
+
+            foreach ($extras as $key => $value) {
+                $log->addExtra($key, $value);
+            }
+
+            $log->setAction($action);
+
+            $isProduction = System::getEnv('_APP_ENV', 'development') === 'production';
+            $log->setEnvironment($isProduction ? Log::ENVIRONMENT_PRODUCTION : Log::ENVIRONMENT_STAGING);
+
+            try {
+                $responseCode = $logger->addLog($log);
+                Console::info('Error log pushed with status code: ' . $responseCode);
+            } catch (Throwable $th) {
+                Console::error('Error pushing log: ' . $th->getMessage());
+            }
+        }
+
+        Console::warning("Failed: {$error->getMessage()}");
+        Console::warning($error->getTraceAsString());
+    };
+}, ['register', 'project']);

 $pools = $register->get('pools');
 $platform = new Appwrite();
@@ -45,13 +45,13 @@
        "ext-sockets": "*",
        "appwrite/php-runtimes": "0.16.*",
        "appwrite/php-clamav": "2.0.*",
-        "utopia-php/abuse": "0.43.0",
+        "utopia-php/abuse": "0.43.*",
        "utopia-php/analytics": "0.10.*",
-        "utopia-php/audit": "0.43.0",
+        "utopia-php/audit": "0.43.*",
        "utopia-php/cache": "0.11.*",
        "utopia-php/cli": "0.15.*",
        "utopia-php/config": "0.2.*",
-        "utopia-php/database": "0.53.16",
+        "utopia-php/database": "0.53.20",
        "utopia-php/domains": "0.5.*",
        "utopia-php/dsn": "0.2.1",
        "utopia-php/framework": "0.33.*",
@@ -70,6 +70,7 @@
        "utopia-php/storage": "0.18.*",
        "utopia-php/swoole": "0.8.*",
        "utopia-php/system": "0.9.*",
+        "utopia-php/telemetry": "0.1.*",
        "utopia-php/vcs": "0.8.*",
        "utopia-php/websocket": "0.1.*",
        "matomo/device-detector": "6.1.*",
@@ -96,6 +97,10 @@
    "config": {
        "platform": {
            "php": "8.3"
+        },
+        "allow-plugins": {
+            "php-http/discovery": false,
+            "tbachert/spi": false
        }
    }
 }
@@ -193,6 +193,8 @@ services:
      - _APP_EXPERIMENT_LOGGING_PROVIDER
      - _APP_EXPERIMENT_LOGGING_CONFIG
      - _APP_DATABASE_SHARED_TABLES
+      - _APP_DATABASE_SHARED_TABLES_V1
+      - _APP_DATABASE_SHARED_NAMESPACE

  appwrite-console:
    <<: *x-logging
@@ -382,6 +384,7 @@ services:
      - _APP_EXECUTOR_SECRET
      - _APP_EXECUTOR_HOST
      - _APP_DATABASE_SHARED_TABLES
+      - _APP_DATABASE_SHARED_TABLES_V1

  appwrite-worker-databases:
    entrypoint: worker-databases
@@ -1,3 +1,3 @@
-Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST /v1/account/sessions/token](https://appwrite.io/docs/references/cloud/client-web/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour. If you are on a mobile device you can leave the URL parameter empty, so that the login completion will be handled by your Appwrite instance by default.
+Sends the user an email with a secret key for creating a session. If the provided user ID has not been registered, a new user will be created. When the user clicks the link in the email, the user is redirected back to the URL you provided with the secret key and userId values attached to the URL query string. Use the query string parameters to submit a request to the [POST /v1/account/sessions/token](https://appwrite.io/docs/references/cloud/client-web/account#createSession) endpoint to complete the login process. The link sent to the user's email address is valid for 1 hour.

 A user is limited to 10 active sessions at a time by default. [Learn more about session limits](https://appwrite.io/docs/authentication-security#limits).
@@ -25,6 +25,9 @@ use Appwrite\Spec\Swagger2;
 use Utopia\CLI\Console;
 use Utopia\Config\Config;
 use Utopia\Platform\Action;
+use Utopia\Validator\Nullable;
+use Utopia\Validator\Text;
+use Utopia\Validator\WhiteList;

 class SDKs extends Action
 {
@@ -37,23 +40,35 @@ class SDKs extends Action
    {
        $this
            ->desc('Generate Appwrite SDKs')
-            ->callback(fn () => $this->action());
+            ->param('platform', null, new Nullable(new Text(256)), 'Selected Platform', optional: true)
+            ->param('sdk', null, new Nullable(new Text(256)), 'Selected SDK', optional:true)
+            ->param('version', null, new Nullable(new Text(256)), 'Selected SDK', optional:true)
+            ->param('git', null, new Nullable(new WhiteList(['yes', 'no'])), 'Should we use git push?', optional: true)
+            ->param('production', null, new Nullable(new WhiteList(['yes', 'no'])), 'Should we push to production?', optional:true)
+            ->param('message', null, new Nullable(new Text(256)), 'Commit Message', optional:true)
+            ->callback([$this, 'action']);
    }

-    public function action(): void
+    public function action(?string $selectedPlatform, ?string $selectedSDK, ?string $version, ?string $git, ?string $production, ?string $message)
    {
-        $platforms = Config::getParam('platforms');
-        $selectedPlatform = Console::confirm('Choose Platform ("' . APP_PLATFORM_CLIENT . '", "' . APP_PLATFORM_SERVER . '", "' . APP_PLATFORM_CONSOLE . '" or "*" for all):');
-        $selectedSDK = \strtolower(Console::confirm('Choose SDK ("*" for all):'));
-        $version = Console::confirm('Choose an Appwrite version');
-        $git = (Console::confirm('Should we use git push? (yes/no)') == 'yes');
-        $production = ($git) ? (Console::confirm('Type "Appwrite" to push code to production git repos') == 'Appwrite') : false;
-        $message = ($git) ? Console::confirm('Please enter your commit message:') : '';
+        $selectedPlatform ??= Console::confirm('Choose Platform ("' . APP_PLATFORM_CLIENT . '", "' . APP_PLATFORM_SERVER . '", "' . APP_PLATFORM_CONSOLE . '" or "*" for all):');
+        $selectedSDK ??= \strtolower(Console::confirm('Choose SDK ("*" for all):'));
+        $version ??= Console::confirm('Choose an Appwrite version');
+
+        $git ??= Console::confirm('Should we use git push? (yes/no)');
+        $git = $git === 'yes';
+
+        if ($git) {
+            $production ??= Console::confirm('Type "Appwrite" to push code to production git repos');
+            $production = $production === 'Appwrite';
+            $message ??= Console::confirm('Please enter your commit message:');
+        }

        if (!in_array($version, ['0.6.x', '0.7.x', '0.8.x', '0.9.x', '0.10.x', '0.11.x', '0.12.x', '0.13.x', '0.14.x', '0.15.x', '1.0.x', '1.1.x', '1.2.x', '1.3.x', '1.4.x', '1.5.x', '1.6.x', 'latest'])) {
            throw new \Exception('Unknown version given');
        }

+        $platforms = Config::getParam('platforms');
        foreach ($platforms as $key => $platform) {
            if ($selectedPlatform !== $key && $selectedPlatform !== '*') {
                continue;
@@ -22,6 +22,7 @@ use Utopia\Database\Exception\Structure;
 use Utopia\Database\Helpers\ID;
 use Utopia\Database\Query;
 use Utopia\Domains\Domain;
+use Utopia\Fetch\Client;
 use Utopia\Locale\Locale;
 use Utopia\Logger\Log;
 use Utopia\Platform\Action;
@@ -43,16 +44,18 @@ class Certificates extends Action
        $this
            ->desc('Certificates worker')
            ->inject('message')
+            ->inject('project')
            ->inject('dbForConsole')
            ->inject('queueForMails')
            ->inject('queueForEvents')
            ->inject('queueForFunctions')
            ->inject('log')
-            ->callback(fn (Message $message, Database $dbForConsole, Mail $queueForMails, Event $queueForEvents, Func $queueForFunctions, Log $log) => $this->action($message, $dbForConsole, $queueForMails, $queueForEvents, $queueForFunctions, $log));
+            ->callback(fn (Message $message, Document $project, Database $dbForConsole, Mail $queueForMails, Event $queueForEvents, Func $queueForFunctions, Log $log) => $this->action($message, $project, $dbForConsole, $queueForMails, $queueForEvents, $queueForFunctions, $log));
    }

    /**
     * @param Message $message
+     * @param Document $project
     * @param Database $dbForConsole
     * @param Mail $queueForMails
     * @param Event $queueForEvents
@@ -62,7 +65,7 @@ class Certificates extends Action
     * @throws Throwable
     * @throws \Utopia\Database\Exception
     */
-    public function action(Message $message, Database $dbForConsole, Mail $queueForMails, Event $queueForEvents, Func $queueForFunctions, Log $log): void
+    public function action(Message $message, Document $project, Database $dbForConsole, Mail $queueForMails, Event $queueForEvents, Func $queueForFunctions, Log $log): void
    {
        $payload = $message->getPayload() ?? [];

@@ -76,7 +79,7 @@ class Certificates extends Action

        $log->addTag('domain', $domain->get());

-        $this->execute($domain, $dbForConsole, $queueForMails, $queueForEvents, $queueForFunctions, $log, $skipRenewCheck);
+        $this->execute($domain, $project, $dbForConsole, $queueForMails, $queueForEvents, $queueForFunctions, $log, $skipRenewCheck);
    }

    /**
@@ -90,7 +93,7 @@ class Certificates extends Action
     * @throws Throwable
     * @throws \Utopia\Database\Exception
     */
-    private function execute(Domain $domain, Database $dbForConsole, Mail $queueForMails, Event $queueForEvents, Func $queueForFunctions, Log $log, bool $skipRenewCheck = false): void
+    private function execute(Domain $domain, Document $project, Database $dbForConsole, Mail $queueForMails, Event $queueForEvents, Func $queueForFunctions, Log $log, bool $skipRenewCheck = false): void
    {
        /**
         * 1. Read arguments and validate domain
@@ -155,16 +158,26 @@ class Certificates extends Action
            // Prepare folder name for certbot. Using this helps prevent miss-match in LetsEncrypt configuration when renewing certificate
            $folder = ID::unique();

-            // Generate certificate files using Let's Encrypt
-            $letsEncryptData = $this->issueCertificate($folder, $domain->get(), $email);
+            try {
+                // Generate certificate files using Let's Encrypt
+                $letsEncryptData = $this->issueCertificate($folder, $domain->get(), $email);
+
+                // Give certificates to Traefik
+                $this->applyCertificateFiles($folder, $domain->get(), $letsEncryptData);
+            } catch (\Throwable $th) {
+                Console::error('Failed to generate Lets Encrypt certificate');
+            }

            // Command succeeded, store all data into document
            $logs = 'Certificate successfully generated.';
            $certificate->setAttribute('logs', \mb_strcut($logs, 0, 1000000));// Limit to 1MB

-
-            // Give certificates to Traefik
-            $this->applyCertificateFiles($folder, $domain->get(), $letsEncryptData);
+            try {
+                // TEMP: add custom hostnames to cloudflare
+                $this->addCustomHostnameToRegistrar($project, $domain->get());
+            } catch (\Throwable $th) {
+                Console::error('Failed to add custom hostname to registrar: ' . $th->getMessage());
+            }

            // Update certificate info stored in database
            $certificate->setAttribute('renewDate', $this->getRenewDate($domain->get()));
@@ -197,6 +210,35 @@ class Certificates extends Action
        }
    }

+    /**
+     * Add custom hostname to Cloudflare registrar
+     *
+     * @param Document $project
+     * @param string $hostname
+     * @return void
+     * @throws Exception
+     */
+    private function addCustomHostnameToRegistrar(Document $project, string $hostname): void
+    {
+        $client = new Client();
+        $client
+            ->addHeader('content-type', Client::CONTENT_TYPE_APPLICATION_JSON)
+             ->addHeader('Authorization', 'Bearer ' . System::getEnv('_APP_SYSTEM_CLOUDFLARE_TOKEN'));
+
+        $response = $client->fetch("https://api.cloudflare.com/client/v4/zones/b2d0e62383d3c0f6299efab107af2c7a/custom_hostnames", Client::METHOD_POST, [
+            'hostname' => $hostname,
+            'ssl' => [
+                "method" => "http",
+                "type" => "dv",
+                "wildcard" => false
+            ]
+        ]);
+
+        if ($response->getStatusCode() !== 201) {
+            throw new Exception('Failed to add custom hostname to Cloudflare: ' . $response->getBody());
+        }
+    }
+
    /**
     * Save certificate data into database.
     *
@@ -92,6 +92,7 @@ class Databases extends Action
     * @throws Authorization
     * @throws Conflict
     * @throws \Exception
+     * @throws \Throwable
     */
    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', []);
        $project = $dbForConsole->getDocument('projects', $projectId);

-
        try {
            switch ($type) {
                case Database::VAR_RELATIONSHIP:
@@ -170,7 +170,6 @@ class Databases extends Action

            $dbForProject->updateDocument('attributes', $attribute->getId(), $attribute->setAttribute('status', 'available'));
        } catch (\Throwable $e) {
-            // TODO: Send non DatabaseExceptions to Sentry
            Console::error($e->getMessage());

            if ($e instanceof DatabaseException) {
@@ -193,15 +192,17 @@ class Databases extends Action
                    $relatedAttribute->setAttribute('status', 'failed')
                );
            }
+
+            throw $e;
        } finally {
            $this->trigger($database, $collection, $attribute, $project, $projectId, $events);
-        }

-        if ($type === Database::VAR_RELATIONSHIP && $options['twoWay']) {
-            $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $relatedCollection->getId());
-        }
+            if ($type === Database::VAR_RELATIONSHIP && $options['twoWay']) {
+                $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $relatedCollection->getId());
+            }

-        $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collectionId);
+            $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collectionId);
+        }
    }

    /**
@@ -215,6 +216,7 @@ class Databases extends Action
     * @throws Authorization
     * @throws Conflict
     * @throws \Exception
+     * @throws \Throwable
     **/
    private function deleteAttribute(Document $database, Document $collection, Document $attribute, Document $project, Database $dbForConsole, Database $dbForProject): void
    {
@@ -248,113 +250,114 @@ class Databases extends Action
        // - stuck: attribute was available but cannot be removed

        try {
-            if ($status !== 'failed') {
-                if ($type === Database::VAR_RELATIONSHIP) {
-                    if ($options['twoWay']) {
-                        $relatedCollection = $dbForProject->getDocument('database_' . $database->getInternalId(), $options['relatedCollection']);
-                        if ($relatedCollection->isEmpty()) {
-                            throw new DatabaseException('Collection not found');
+            try {
+                if ($status !== 'failed') {
+                    if ($type === Database::VAR_RELATIONSHIP) {
+                        if ($options['twoWay']) {
+                            $relatedCollection = $dbForProject->getDocument('database_' . $database->getInternalId(), $options['relatedCollection']);
+                            if ($relatedCollection->isEmpty()) {
+                                throw new DatabaseException('Collection not found');
+                            }
+                            $relatedAttribute = $dbForProject->getDocument('attributes', $database->getInternalId() . '_' . $relatedCollection->getInternalId() . '_' . $options['twoWayKey']);
                        }
-                        $relatedAttribute = $dbForProject->getDocument('attributes', $database->getInternalId() . '_' . $relatedCollection->getInternalId() . '_' . $options['twoWayKey']);
-                    }

-                    if (!$dbForProject->deleteRelationship('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId(), $key)) {
-                        $dbForProject->updateDocument('attributes', $relatedAttribute->getId(), $relatedAttribute->setAttribute('status', 'stuck'));
-                        throw new DatabaseException('Failed to delete Relationship');
+                        if (!$dbForProject->deleteRelationship('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId(), $key)) {
+                            $dbForProject->updateDocument('attributes', $relatedAttribute->getId(), $relatedAttribute->setAttribute('status', 'stuck'));
+                            throw new DatabaseException('Failed to delete Relationship');
+                        }
+                    } elseif (!$dbForProject->deleteAttribute('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId(), $key)) {
+                        throw new DatabaseException('Failed to delete Attribute');
                    }
-                } elseif (!$dbForProject->deleteAttribute('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId(), $key)) {
-                    throw new DatabaseException('Failed to delete Attribute');
                }
-            }

-            $dbForProject->deleteDocument('attributes', $attribute->getId());
+                $dbForProject->deleteDocument('attributes', $attribute->getId());

-            if (!$relatedAttribute->isEmpty()) {
-                $dbForProject->deleteDocument('attributes', $relatedAttribute->getId());
-            }
-        } catch (\Throwable $e) {
-            // TODO: Send non DatabaseExceptions to Sentry
-            Console::error($e->getMessage());
-
-            if ($e instanceof DatabaseException) {
-                $attribute->setAttribute('error', $e->getMessage());
                if (!$relatedAttribute->isEmpty()) {
-                    $relatedAttribute->setAttribute('error', $e->getMessage());
+                    $dbForProject->deleteDocument('attributes', $relatedAttribute->getId());
+                }
+            } catch (\Throwable $e) {
+                Console::error($e->getMessage());
+
+                if ($e instanceof DatabaseException) {
+                    $attribute->setAttribute('error', $e->getMessage());
+                    if (!$relatedAttribute->isEmpty()) {
+                        $relatedAttribute->setAttribute('error', $e->getMessage());
+                    }
                }
-            }
-            $dbForProject->updateDocument(
-                'attributes',
-                $attribute->getId(),
-                $attribute->setAttribute('status', 'stuck')
-            );
-            if (!$relatedAttribute->isEmpty()) {
                $dbForProject->updateDocument(
                    'attributes',
-                    $relatedAttribute->getId(),
-                    $relatedAttribute->setAttribute('status', 'stuck')
+                    $attribute->getId(),
+                    $attribute->setAttribute('status', 'stuck')
                );
+                if (!$relatedAttribute->isEmpty()) {
+                    $dbForProject->updateDocument(
+                        'attributes',
+                        $relatedAttribute->getId(),
+                        $relatedAttribute->setAttribute('status', 'stuck')
+                    );
+                }
+
+                throw $e;
+            } finally {
+                $this->trigger($database, $collection, $attribute, $project, $projectId, $events);
            }
-        } finally {
-            $this->trigger($database, $collection, $attribute, $project, $projectId, $events);
-        }

-        // The underlying database removes/rebuilds indexes when attribute is removed
-        // Update indexes table with changes
-        /** @var Document[] $indexes */
-        $indexes = $collection->getAttribute('indexes', []);
+            // The underlying database removes/rebuilds indexes when attribute is removed
+            // Update indexes table with changes
+            /** @var Document[] $indexes */
+            $indexes = $collection->getAttribute('indexes', []);

-        foreach ($indexes as $index) {
-            /** @var string[] $attributes */
-            $attributes = $index->getAttribute('attributes');
-            $lengths = $index->getAttribute('lengths');
-            $orders = $index->getAttribute('orders');
+            foreach ($indexes as $index) {
+                /** @var string[] $attributes */
+                $attributes = $index->getAttribute('attributes');
+                $lengths = $index->getAttribute('lengths');
+                $orders = $index->getAttribute('orders');

-            $found = \array_search($key, $attributes);
+                $found = \array_search($key, $attributes);

-            if ($found !== false) {
-                // If found, remove entry from attributes, lengths, and orders
-                // array_values wraps array_diff to reindex array keys
-                // when found attribute is removed from array
-                $attributes = \array_values(\array_diff($attributes, [$attributes[$found]]));
-                $lengths = \array_values(\array_diff($lengths, isset($lengths[$found]) ? [$lengths[$found]] : []));
-                $orders = \array_values(\array_diff($orders, isset($orders[$found]) ? [$orders[$found]] : []));
+                if ($found !== false) {
+                    // If found, remove entry from attributes, lengths, and orders
+                    // array_values wraps array_diff to reindex array keys
+                    // when found attribute is removed from array
+                    $attributes = \array_values(\array_diff($attributes, [$attributes[$found]]));
+                    $lengths = \array_values(\array_diff($lengths, isset($lengths[$found]) ? [$lengths[$found]] : []));
+                    $orders = \array_values(\array_diff($orders, isset($orders[$found]) ? [$orders[$found]] : []));

-                if (empty($attributes)) {
-                    $dbForProject->deleteDocument('indexes', $index->getId());
-                } else {
-                    $index
-                        ->setAttribute('attributes', $attributes, Document::SET_TYPE_ASSIGN)
-                        ->setAttribute('lengths', $lengths, Document::SET_TYPE_ASSIGN)
-                        ->setAttribute('orders', $orders, Document::SET_TYPE_ASSIGN);
-
-                    // Check if an index exists with the same attributes and orders
-                    $exists = false;
-                    foreach ($indexes as $existing) {
-                        if (
-                            $existing->getAttribute('key') !== $index->getAttribute('key') // Ignore itself
-                            && $existing->getAttribute('attributes') === $index->getAttribute('attributes')
-                            && $existing->getAttribute('orders') === $index->getAttribute('orders')
-                        ) {
-                            $exists = true;
-                            break;
-                        }
-                    }
-
-                    if ($exists) { // Delete the duplicate if created, else update in db
-                        $this->deleteIndex($database, $collection, $index, $project, $dbForConsole, $dbForProject);
+                    if (empty($attributes)) {
+                        $dbForProject->deleteDocument('indexes', $index->getId());
                    } else {
-                        $dbForProject->updateDocument('indexes', $index->getId(), $index);
+                        $index
+                            ->setAttribute('attributes', $attributes, Document::SET_TYPE_ASSIGN)
+                            ->setAttribute('lengths', $lengths, Document::SET_TYPE_ASSIGN)
+                            ->setAttribute('orders', $orders, Document::SET_TYPE_ASSIGN);
+
+                        // Check if an index exists with the same attributes and orders
+                        $exists = false;
+                        foreach ($indexes as $existing) {
+                            if (
+                                $existing->getAttribute('key') !== $index->getAttribute('key') // Ignore itself
+                                && $existing->getAttribute('attributes') === $index->getAttribute('attributes')
+                                && $existing->getAttribute('orders') === $index->getAttribute('orders')
+                            ) {
+                                $exists = true;
+                                break;
+                            }
+                        }
+
+                        if ($exists) { // Delete the duplicate if created, else update in db
+                            $this->deleteIndex($database, $collection, $index, $project, $dbForConsole, $dbForProject);
+                        } else {
+                            $dbForProject->updateDocument('indexes', $index->getId(), $index);
+                        }
                    }
                }
            }
-        }
+        } finally {
+            $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collectionId);

-        $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collectionId);
-        $dbForProject->purgeCachedCollection('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId());
-
-        if (!$relatedCollection->isEmpty() && !$relatedAttribute->isEmpty()) {
-            $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $relatedCollection->getId());
-            $dbForProject->purgeCachedCollection('database_' . $database->getInternalId() . '_collection_' . $relatedCollection->getInternalId());
+            if (!$relatedCollection->isEmpty() && !$relatedAttribute->isEmpty()) {
+                $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $relatedCollection->getId());
+            }
        }
    }

@@ -370,6 +373,7 @@ class Databases extends Action
     * @throws Conflict
     * @throws Structure
     * @throws DatabaseException
+     * @throws \Throwable
     */
    private function createIndex(Document $database, Document $collection, Document $index, Document $project, Database $dbForConsole, Database $dbForProject): void
    {
@@ -401,9 +405,7 @@ class Databases extends Action
            }
            $dbForProject->updateDocument('indexes', $index->getId(), $index->setAttribute('status', 'available'));
        } catch (\Throwable $e) {
-            // TODO: Send non DatabaseExceptions to Sentry
            Console::error($e->getMessage());
-
            if ($e instanceof DatabaseException) {
                $index->setAttribute('error', $e->getMessage());
            }
@@ -412,11 +414,12 @@ class Databases extends Action
                $index->getId(),
                $index->setAttribute('status', 'failed')
            );
+
+            throw $e;
        } finally {
            $this->trigger($database, $collection, $index, $project, $projectId, $events);
+            $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collectionId);
        }
-
-        $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collectionId);
    }

    /**
@@ -431,6 +434,7 @@ class Databases extends Action
     * @throws Conflict
     * @throws Structure
     * @throws DatabaseException
+     * @throws \Throwable
     */
    private function deleteIndex(Document $database, Document $collection, Document $index, Document $project, Database $dbForConsole, Database $dbForProject): void
    {
@@ -459,7 +463,6 @@ class Databases extends Action
            $dbForProject->deleteDocument('indexes', $index->getId());
            $index->setAttribute('status', 'deleted');
        } catch (\Throwable $e) {
-            // TODO: Send non DatabaseExceptions to Sentry
            Console::error($e->getMessage());

            if ($e instanceof DatabaseException) {
@@ -470,11 +473,13 @@ class Databases extends Action
                $index->getId(),
                $index->setAttribute('status', 'stuck')
            );
+
+            throw $e;
+
        } finally {
            $this->trigger($database, $collection, $index, $project, $projectId, $events);
+            $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collection->getId());
        }
-
-        $dbForProject->purgeCachedDocument('database_' . $database->getInternalId(), $collection->getId());
    }

    /**
@@ -495,29 +495,30 @@ class Deletes extends Action

        $limit = \count($projectCollectionIds) + 25;

+        $sharedTables = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES', ''));
+        $sharedTablesV1 = \explode(',', System::getEnv('_APP_DATABASE_SHARED_TABLES_V1', ''));
+
+        $projectTables = !\in_array($dsn->getHost(), $sharedTables);
+        $sharedTablesV1 = \in_array($dsn->getHost(), $sharedTablesV1);
+        $sharedTablesV2 = !$projectTables && !$sharedTablesV1;
+        $sharedTables = $sharedTablesV1 || $sharedTablesV2;
+
        while (true) {
            $collections = $dbForProject->listCollections($limit);

            foreach ($collections as $collection) {
-                if ($dsn->getHost() !== System::getEnv('_APP_DATABASE_SHARED_TABLES', '') || !\in_array($collection->getId(), $projectCollectionIds)) {
-                    try {
+                try {
+                    if ($projectTables || !\in_array($collection->getId(), $projectCollectionIds)) {
                        $dbForProject->deleteCollection($collection->getId());
-                    } catch (Throwable $e) {
-                        Console::error('Error deleting '.$collection->getId().' '.$e->getMessage());
-
-                        /**
-                         * Ignore junction tables;
-                         */
-                        if (!preg_match('/^_\d+_\d+$/', $collection->getId())) {
-                            throw $e;
-                        }
+                    } else {
+                        $this->deleteByGroup($collection->getId(), [], database: $dbForProject);
                    }
-                } else {
-                    $this->deleteByGroup($collection->getId(), [], database: $dbForProject);
+                } catch (Throwable $e) {
+                    Console::error('Error deleting '.$collection->getId().' '.$e->getMessage());
                }
            }

-            if ($dsn->getHost() === System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
+            if ($sharedTables) {
                $collectionsIds = \array_map(fn ($collection) => $collection->getId(), $collections);

                if (empty(\array_diff($collectionsIds, $projectCollectionIds))) {
@@ -571,10 +572,17 @@ class Deletes extends Action
        ], $dbForConsole);

        // Delete metadata table
-        if ($dsn->getHost() !== System::getEnv('_APP_DATABASE_SHARED_TABLES', '')) {
-            $dbForProject->deleteCollection('_metadata');
-        } else {
-            $this->deleteByGroup('_metadata', [], $dbForProject);
+        if ($projectTables) {
+            $dbForProject->deleteCollection(Database::METADATA);
+        } elseif ($sharedTablesV1) {
+            $this->deleteByGroup(Database::METADATA, [], $dbForProject);
+        } elseif ($sharedTablesV2) {
+            $queries = \array_map(
+                fn ($id) => Query::notEqual('$id', $id),
+                $projectCollectionIds
+            );
+
+            $this->deleteByGroup(Database::METADATA, $queries, $dbForProject);
        }

        // Delete all storage directories
@@ -16,7 +16,6 @@ use Utopia\Database\Exception\Conflict;
 use Utopia\Database\Exception\Restricted;
 use Utopia\Database\Exception\Structure;
 use Utopia\Database\Helpers\ID;
-use Utopia\Logger\Log;
 use Utopia\Migration\Destination;
 use Utopia\Migration\Destinations\Appwrite as DestinationAppwrite;
 use Utopia\Migration\Exception as MigrationException;
@@ -37,6 +36,8 @@ class Migrations extends Action

    protected Document $project;

+    protected $logError;
+
    public static function getName(): string
    {
        return 'migrations';
@@ -52,14 +53,14 @@ class Migrations extends Action
            ->inject('message')
            ->inject('dbForProject')
            ->inject('dbForConsole')
-            ->inject('log')
-            ->callback(fn (Message $message, Database $dbForProject, Database $dbForConsole, Log $log) => $this->action($message, $dbForProject, $dbForConsole, $log));
+            ->inject('logError')
+            ->callback(fn (Message $message, Database $dbForProject, Database $dbForConsole, callable $logError) => $this->action($message, $dbForProject, $dbForConsole, $logError));
    }

    /**
     * @throws Exception
     */
-    public function action(Message $message, Database $dbForProject, Database $dbForConsole, Log $log): void
+    public function action(Message $message, Database $dbForProject, Database $dbForConsole, callable $logError): void
    {
        $payload = $message->getPayload() ?? [];

@@ -78,6 +79,7 @@ class Migrations extends Action
        $this->dbForProject = $dbForProject;
        $this->dbForConsole = $dbForConsole;
        $this->project = $project;
+        $this->logError = $logError;

        /**
         * Handle Event execution.
@@ -86,10 +88,7 @@ class Migrations extends Action
            return;
        }

-        $log->addTag('migrationId', $migration->getId());
-        $log->addTag('projectId', $project->getId());
-
-        $this->processMigration($migration, $log);
+        $this->processMigration($migration);
    }

    /**
@@ -259,7 +258,7 @@ class Migrations extends Action
     * @throws \Utopia\Database\Exception
     * @throws Exception
     */
-    protected function processMigration(Document $migration, Log $log): void
+    protected function processMigration(Document $migration): void
    {
        $project = $this->project;
        $projectDocument = $this->dbForConsole->getDocument('projects', $project->getId());
@@ -268,8 +267,6 @@ class Migrations extends Action
        $transfer = $source = $destination = null;

        try {
-            $migration = $this->dbForProject->getDocument('migrations', $migration->getId());
-
            if (
                $migration->getAttribute('source') === SourceAppwrite::getName() &&
                empty($migration->getAttribute('credentials', []))
@@ -287,8 +284,6 @@ class Migrations extends Action
            $migration->setAttribute('status', 'processing');
            $this->updateMigrationDocument($migration, $projectDocument);

-            $log->addTag('type', $migration->getAttribute('source'));
-
            $source = $this->processSource($migration);
            $destination = $this->processDestination($migration, $tempAPIKey->getAttribute('secret'));

@@ -326,7 +321,6 @@ class Migrations extends Action

                $errorMessages = [];
                foreach ($sourceErrors as $error) {
-                    /** @var $sourceErrors $error */
                    $message = "Error occurred while fetching '{$error->getResourceName()}:{$error->getResourceId()}' from source with message: '{$error->getMessage()}'";
                    if ($error->getPrevious()) {
                        $message .= " Message: ".$error->getPrevious()->getMessage() . " File: ".$error->getPrevious()->getFile() . " Line: ".$error->getPrevious()->getLine();
@@ -346,7 +340,6 @@ class Migrations extends Action
                }

                $migration->setAttribute('errors', $errorMessages);
-                $log->addExtra('migrationErrors', json_encode($errorMessages));
                $this->updateMigrationDocument($migration, $projectDocument);

                return;
@@ -361,7 +354,6 @@ class Migrations extends Action
            if (! $migration->isEmpty()) {
                $migration->setAttribute('status', 'failed');
                $migration->setAttribute('stage', 'finished');
-                $migration->setAttribute('errors', [$th->getMessage()]);

                return;
            }
@@ -381,7 +373,6 @@ class Migrations extends Action
                }

                $migration->setAttribute('errors', $errorMessages);
-                $log->addTag('migrationErrors', json_encode($errorMessages));
            }
        } finally {
            if (! $tempAPIKey->isEmpty()) {
@@ -396,7 +387,23 @@ class Migrations extends Action
                $destination->error();
                $source->error();

-                throw new Exception('Migration failed');
+                foreach ($source->getErrors() as $error) {
+                    call_user_func($this->logError, $error, 'appwrite-worker', 'appwrite-queue-' . self::getName(), [
+                        'migrationId' => $migration->getId() ?? '',
+                        'source' => $migration->getAttribute('source') ?? '',
+                        'resourceName' => $error->getResourceName(),
+                        'resourceGroup' => $error->getResourceGroup()
+                    ]);
+                }
+
+                foreach ($destination->getErrors() as $error) {
+                    call_user_func($this->logError, $error, 'appwrite-worker', 'appwrite-queue-' . self::getName(), [
+                        'migrationId' => $migration->getId() ?? '',
+                        'source' => $migration->getAttribute('source') ?? '',
+                        'resourceName' => $error->getResourceName(),
+                        'resourceGroup' => $error->getResourceGroup()
+                    ]);
+                }
            }

            if ($migration->getAttribute('status', '') === 'completed') {
@@ -323,6 +323,7 @@ class OpenAPI3 extends Format
                    case 'Utopia\Validator\JSON':
                    case 'Utopia\Validator\Mock':
                    case 'Utopia\Validator\Assoc':
+                    case 'Appwrite\Functions\Validator\Payload':
                        $param['default'] = (empty($param['default'])) ? new \stdClass() : $param['default'];
                        $node['schema']['type'] = 'object';
                        $node['schema']['x-example'] = '{}';
@@ -349,6 +349,7 @@ class Swagger2 extends Format
                    case 'Utopia\Validator\JSON':
                    case 'Utopia\Validator\Mock':
                    case 'Utopia\Validator\Assoc':
+                    case 'Appwrite\Functions\Validator\Payload':
                        $node['type'] = 'object';
                        $node['default'] = (empty($param['default'])) ? new \stdClass() : $param['default'];
                        $node['x-example'] = '{}';
@@ -94,7 +94,7 @@ class Func extends Model
            ])
            ->addRule('schedule', [
                'type' => self::TYPE_STRING,
-                'description' => 'Function execution schedult in CRON format.',
+                'description' => 'Function execution schedule in CRON format.',
                'default' => '',
                'example' => '5 4 * * *',
            ])
@@ -1362,7 +1362,7 @@ class DatabasesCustomServerTest extends Scope
        ]);

        $this->assertEquals(400, $tooWide['headers']['status-code']);
-        $this->assertEquals('Attribute limit exceeded', $tooWide['body']['message']);
+        $this->assertEquals('attribute_limit_exceeded', $tooWide['body']['type']);
    }

    public function testIndexLimitException()
@@ -3727,11 +3727,11 @@ class ProjectsConsoleClientTest extends Scope
            'x-appwrite-project' => $this->getProject()['$id'],
        ], $this->getHeaders()), [
            'teamId' => ID::unique(),
-            'name' => 'Amating Team',
+            'name' => 'Amazing Team',
        ]);

        $this->assertEquals(201, $team['headers']['status-code']);
-        $this->assertEquals('Amating Team', $team['body']['name']);
+        $this->assertEquals('Amazing Team', $team['body']['name']);
        $this->assertNotEmpty($team['body']['$id']);

        $teamId = $team['body']['$id'];
@@ -3794,6 +3794,115 @@ class ProjectsConsoleClientTest extends Scope
        return $data;
    }

+    public function testDeleteSharedProject(): void
+    {
+        $team = $this->client->call(Client::METHOD_POST, '/teams', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'teamId' => ID::unique(),
+            'name' => 'Amazing Team',
+        ]);
+
+        $teamId = $team['body']['$id'];
+
+        // Ensure deleting one project does not affect another project
+        $project1 = $this->client->call(Client::METHOD_POST, '/projects', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'projectId' => ID::unique(),
+            'name' => 'Amazing Project 1',
+            'teamId' => $teamId,
+            'region' => 'default'
+        ]);
+
+        $project2 = $this->client->call(Client::METHOD_POST, '/projects', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'projectId' => ID::unique(),
+            'name' => 'Amazing Project 2',
+            'teamId' => $teamId,
+            'region' => 'default'
+        ]);
+
+        $project1Id = $project1['body']['$id'];
+        $project2Id = $project2['body']['$id'];
+
+        // Create user in each project
+        $key1 = $this->client->call(Client::METHOD_POST, '/projects/' . $project1Id . '/keys', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'name' => 'Key Test',
+            'scopes' => ['users.read', 'users.write'],
+        ]);
+
+        $user1 = $this->client->call(Client::METHOD_POST, '/users', [
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $project1Id,
+            'x-appwrite-key' => $key1['body']['secret'],
+        ], [
+            'userId' => ID::unique(),
+            'email' => 'test1@appwrite.io',
+            'password' => 'password',
+        ]);
+
+        $this->assertEquals(201, $user1['headers']['status-code']);
+
+        $key2 = $this->client->call(Client::METHOD_POST, '/projects/' . $project2Id . '/keys', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'name' => 'Key Test',
+            'scopes' => ['users.read', 'users.write'],
+        ]);
+
+        $user2 = $this->client->call(Client::METHOD_POST, '/users', [
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $project2Id,
+            'x-appwrite-key' => $key2['body']['secret'],
+        ], [
+            'userId' => ID::unique(),
+            'email' => 'test2@appwrite.io',
+            'password' => 'password',
+        ]);
+
+        $this->assertEquals(201, $user2['headers']['status-code']);
+
+        // Delete project 1
+        $project1 = $this->client->call(Client::METHOD_DELETE, '/projects/' . $project1Id, array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()));
+
+        $this->assertEquals(204, $project1['headers']['status-code']);
+
+        \sleep(3);
+
+        // Ensure project 2 user is still there
+        $user2 = $this->client->call(Client::METHOD_GET, '/users/' . $user2['body']['$id'], [
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $project2Id,
+            'x-appwrite-key' => $key2['body']['secret'],
+        ]);
+
+        $this->assertEquals(200, $user2['headers']['status-code']);
+
+        // Create another user in project 2 in case read hits stale cache
+        $user3 = $this->client->call(Client::METHOD_POST, '/users', [
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $project2Id,
+            'x-appwrite-key' => $key2['body']['secret'],
+        ], [
+            'userId' => ID::unique(),
+            'email' => 'test3@appwrite.io'
+        ]);
+
+        $this->assertEquals(201, $user3['headers']['status-code']);
+    }
+
    /**
     * @depends testCreateProject
     */
@@ -111,6 +111,30 @@ class RealtimeCustomClientTest extends Scope
        $client->close();
    }

+    public function testPingPong()
+    {
+        $client = $this->getWebsocket(['files'], [
+            'origin' => 'http://localhost'
+        ]);
+        $response = json_decode($client->receive(), true);
+
+        $this->assertArrayHasKey('type', $response);
+        $this->assertArrayHasKey('data', $response);
+        $this->assertEquals('connected', $response['type']);
+        $this->assertNotEmpty($response['data']);
+        $this->assertCount(1, $response['data']['channels']);
+        $this->assertContains('files', $response['data']['channels']);
+
+        $client->send(\json_encode([
+            'type' => 'ping'
+        ]));
+
+        $response = json_decode($client->receive(), true);
+        $this->assertEquals('pong', $response['type']);
+
+        $client->close();
+    }
+
    public function testManualAuthentication()
    {
        $user = $this->getUser();
@@ -559,6 +559,76 @@ trait TeamsBaseClient
        return $data;
    }

+
+    /**
+     * @depends testCreateTeam
+     */
+    public function testUpdateMembershipWithSession(array $data): void
+    {
+        $teamUid = $data['teamUid'] ?? '';
+
+        // create user
+        $response = $this->client->call(Client::METHOD_POST, '/account', [
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], [
+            'userId' => 'unique()',
+            'email' => uniqid() . 'foe@localhost.test',
+            'password' => 'password',
+            'name' => 'test'
+        ]);
+
+        $this->assertEquals(201, $response['headers']['status-code']);
+        $user = $response['body'];
+
+        // create session
+        $response = $this->client->call(Client::METHOD_POST, '/account/sessions', [
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], [
+            'email' => $user['email'],
+            'password' => 'password'
+        ]);
+
+        $this->assertEquals(201, $response['headers']['status-code']);
+
+        $session = $response['cookies']['a_session_' . $this->getProject()['$id']];
+
+        $response = $this->client->call(Client::METHOD_POST, '/teams/' . $teamUid . '/memberships', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+        ], $this->getHeaders()), [
+            'email' => $user['email'],
+            'roles' => ['developer'],
+            'url' => 'http://localhost:5000/join-us#title'
+        ]);
+
+        $this->assertEquals(201, $response['headers']['status-code']);
+
+        $lastEmail = $this->getLastEmail();
+
+        $secret = substr($lastEmail['text'], strpos($lastEmail['text'], '&secret=', 0) + 8, 256);
+        $membershipUid = substr($lastEmail['text'], strpos($lastEmail['text'], '?membershipId=', 0) + 14, 20);
+        $userUid = substr($lastEmail['text'], strpos($lastEmail['text'], '&userId=', 0) + 8, 20);
+
+        $response = $this->client->call(Client::METHOD_PATCH, '/teams/' . $teamUid . '/memberships/' . $membershipUid . '/status', [
+            'origin' => 'http://localhost',
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $this->getProject()['$id'],
+            'cookie' => 'a_session_' . $this->getProject()['$id'] . '=' . $session,
+        ], [
+            'secret' => $secret,
+            'userId' => $userUid,
+        ]);
+
+        $this->assertEquals(200, $response['headers']['status-code']);
+        $this->assertNotEmpty($response['body']['$id']);
+        $this->assertNotEmpty($response['body']['userId']);
+        $this->assertNotEmpty($response['body']['teamId']);
+        $this->assertCount(1, $response['body']['roles']);
+        $this->assertEmpty($response['cookies']);
+    }
+
    /**
     * @depends testUpdateTeamMembership
     */
@@ -648,7 +718,7 @@ trait TeamsBaseClient
        ], $this->getHeaders()));

        $this->assertEquals(200, $response['headers']['status-code']);
-        $this->assertEquals(3, $response['body']['total']);
+        $this->assertEquals(4, $response['body']['total']);

        $ownerMembershipUid = $response['body']['memberships'][0]['$id'];

@@ -703,7 +773,7 @@ trait TeamsBaseClient
        ], $this->getHeaders()));

        $this->assertEquals(200, $response['headers']['status-code']);
-        $this->assertEquals(2, $response['body']['total']);
+        $this->assertEquals(3, $response['body']['total']);

        /**
         * Test for when the owner tries to delete their membership
@@ -83,6 +83,38 @@ class TeamsCustomClientTest extends Scope
        $this->assertNotEmpty($response['body']['memberships'][0]['userName']);
        $this->assertNotEmpty($response['body']['memberships'][0]['userEmail']);
        $this->assertArrayHasKey('mfa', $response['body']['memberships'][0]);
+
+        /**
+         * Update project settings to show only MFA
+         */
+        $response = $this->client->call(Client::METHOD_PATCH, '/projects/' . $this->getProject()['$id'] . '/auth/memberships-privacy', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => 'console',
+            'cookie' => 'a_session_console=' . $this->getRoot()['session'],
+        ]), [
+            'userName' => false,
+            'userEmail' => false,
+            'mfa' => true,
+        ]);
+
+        $this->assertEquals(200, $response['headers']['status-code']);
+
+        /**
+         * Test that sensitive fields are not shown
+         */
+        $response = $this->client->call(Client::METHOD_GET, '/teams/' . $teamUid . '/memberships', array_merge([
+            'content-type' => 'application/json',
+            'x-appwrite-project' => $projectId,
+        ], $this->getHeaders()));
+
+        $this->assertEquals(200, $response['headers']['status-code']);
+        $this->assertIsInt($response['body']['total']);
+        $this->assertNotEmpty($response['body']['memberships'][0]['$id']);
+
+        // Assert that sensitive fields are present
+        $this->assertEmpty($response['body']['memberships'][0]['userName']);
+        $this->assertEmpty($response['body']['memberships'][0]['userEmail']);
+        $this->assertArrayHasKey('mfa', $response['body']['memberships'][0]);
    }

    /**
Author	SHA1	Message	Date
loks0n	633e898042	default spec	2024-11-22 17:18:19 +00:00
Christy Jacob	a7faf656a8	Merge branch '1.6.x' of github.com:appwrite/appwrite into feat-custom-cf-hostnames	2024-11-22 12:42:38 +04:00
Christy JacobandGitHub	7ccc74bae2	Merge pull request #9006 from appwrite/fix-team-invite-session-creation fix: team invites with existing session	2024-11-22 09:38:40 +01:00
Christy JacobandGitHub	44a0469d18	Merge branch '1.6.x' into fix-team-invite-session-creation	2024-11-22 09:21:54 +01:00
Jake Barnby	e1b71df757	Merge remote-tracking branch 'origin/1.6.x' into feat-custom-cf-hostnames	2024-11-21 22:44:24 +13:00
Christy JacobandGitHub	34d8a0504b	Merge pull request #9013 from appwrite/feat-db-create-on-server-start Improved shared tables V2	2024-11-21 10:41:52 +01:00
Jake Barnby	f9e518b2b0	Fix shared tables v2 deletes	2024-11-21 16:49:49 +13:00
Jake Barnby	8410710005	Remove redundant DSN construction	2024-11-21 16:47:12 +13:00
Jake Barnby	018c865d04	Skip all project db calls on project create if shared tables v2	2024-11-21 16:46:36 +13:00
Jake Barnby	415dedc135	Create V2 shared tables databases on server start	2024-11-21 16:46:10 +13:00
Jake Barnby	b673c54cf9	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-11-21 14:25:14 +13:00
loks0nandJake Barnby	d257fdb045	chore: remove redundant compression	2024-11-21 14:24:56 +13:00
Jake Barnby	2f77d53380	Merge remote-tracking branch 'origin/1.6.x' into feat-custom-cf-hostnames	2024-11-21 14:20:28 +13:00
Steven NguyenandJake Barnby	f6e7c12b02	Merge pull request #8922 from appwrite/lohanidamodar-patch-4 Improve compression param checks	2024-11-21 14:17:52 +13:00
Christy JacobandJake Barnby	908adebf74	Merge pull request #8964 from appwrite/debug-whitelist-console debug: whitelist console	2024-11-21 14:11:20 +13:00
Jake Barnby	e276532950	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-11-21 14:09:42 +13:00
Christy JacobandJake Barnby	6e6899c1e9	Merge pull request #8988 from appwrite/fix-deletes Fix project type delete checks	2024-11-21 14:09:02 +13:00
Christy JacobandJake Barnby	f490d4edaf	Merge pull request #8797 from appwrite/feat-migration Feat migration # Conflicts: # composer.lock	2024-11-21 14:08:20 +13:00
Torsten Dittmann	0b11e0cc92	fix: gitignore merge conflict leftover	2024-11-20 11:52:27 +01:00
Torsten DittmannandGitHub	a5d43ddf71	Merge pull request #9011 from appwrite/sync-1.6.x sync: 1.6.x	2024-11-20 11:48:37 +01:00
Torsten Dittmann	15a5f8690d	sync: 1.6.x with main	2024-11-20 11:33:38 +01:00
Torsten Dittmann	9901c781b7	Merge branch 'main' of https://github.com/appwrite/appwrite into sync-1.6.x	2024-11-20 11:31:52 +01:00
Fabian Gruber	d32a1c35ab	chore: update base to 0.9.5	2024-11-19 17:20:09 +01:00
Torsten Dittmann	c97a94ec98	chore: run formatter	2024-11-19 17:18:51 +01:00
Torsten Dittmann	5f56c45c6c	fix: team invites with existing session	2024-11-19 17:18:51 +01:00
Eldad A. FuxandGitHub	ee3d34310a	Merge pull request #9005 from appwrite/base-0.9.5 chore: update base to 0.9.5	2024-11-19 17:15:43 +01:00
Fabian Gruber	877a978451	chore: update base to 0.9.5	2024-11-19 16:42:16 +01:00
Christy JacobandGitHub	218598e856	Merge pull request #9004 from appwrite/revert-8962-feat-fix-web-routes Revert "feat fix web routes"	2024-11-19 10:38:51 +01:00
Christy JacobandGitHub	fc3fa77056	Revert "feat fix web routes"	2024-11-19 13:35:37 +04:00
Jake BarnbyandGitHub	d49b0540fd	Merge pull request #8978 from appwrite/unset-index-length Unset index length	2024-11-18 17:05:00 +13:00
Torsten DittmannandGitHub	8e02115828	ci: console sdk previews (#8990 )	2024-11-15 13:27:46 +01:00
Christy JacobandGitHub	9a7e5a3153	Merge pull request #8988 from appwrite/fix-deletes Fix project type delete checks	2024-11-15 13:14:14 +01:00
Jake Barnby	a470e2b517	Output test mode	2024-11-15 18:55:52 +13:00
Jake Barnby	6851461a3b	Fix workflow	2024-11-15 18:40:06 +13:00
Jake Barnby	24079a836b	Fix project type delete checks	2024-11-15 18:37:16 +13:00
Steven NguyenandGitHub	3a748fbd35	Merge pull request #8972 from appwrite/fix-remove-duplicate-dart-216-runtime-template Remove duplicate dart-2.16 runtime template	2024-11-14 12:33:33 -08:00
fogelito	7e7a4658cd	revert lock	2024-11-14 14:20:28 +02:00
fogelito	abf97e391e	formatting	2024-11-14 14:19:33 +02:00
fogelito	d8799e5a9c	Remove comment	2024-11-14 14:13:28 +02:00
fogelito	217e471a41	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into unset-index-length	2024-11-14 14:12:03 +02:00
fogelito	72e491ac69	Remove unsetting index length for strings	2024-11-14 14:11:36 +02:00
Jake BarnbyandGitHub	bdb0b188ef	Merge pull request #8971 from appwrite/fix-alter-attributes Fix Patch attribute	2024-11-14 20:55:59 +13:00
Jake BarnbyandGitHub	191f884772	Merge pull request #8959 from appwrite/fix-send-migration-errors-individually Send migration errors individually	2024-11-14 19:57:27 +13:00
Steven NguyenandGitHub	45f85d6b4d	fix: remove duplicate dart-2.16 runtime template	2024-11-13 11:30:48 -08:00
fogelito	8f845aef53	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into fix-alter-attributes # Conflicts: # src/Appwrite/Platform/Workers/Databases.php	2024-11-13 18:34:57 +02:00
fogelito	68e96e9851	comment	2024-11-13 18:32:20 +02:00
Fabian Gruber	a3bd8b1e4e	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-11-13 14:11:49 +01:00
Eldad A. FuxandGitHub	c6cf27bd6f	Merge pull request #8960 from appwrite/PLA-1854 feat: add telemetry	2024-11-13 14:08:45 +01:00
fogelito	71f2c6c131	Remove purgeCachedCollection	2024-11-13 14:55:56 +02:00
Fabian Gruber	1db71a46ea	chore: use telemetry 0.1.0	2024-11-13 13:52:41 +01:00
Fabian Gruber	8124f6998e	feat: add telemetry	2024-11-13 13:52:41 +01:00
Torsten DittmannandGitHub	7f06b0ec76	Merge pull request #8969 from appwrite/fix-memberships-privacy-mfa fix: memberships privacy mfa	2024-11-13 12:36:57 +01:00
loks0n	ca533f40c9	fix: memberships-privacy mfa only	2024-11-13 10:45:50 +01:00
Bradley Schofield	54db5655a1	Run Linter	2024-11-13 13:42:49 +09:00
Bradley Schofield	91cc0e627a	Address Comments	2024-11-13 10:29:43 +09:00
Bradley Schofield	f1af8b330e	Merge remote-tracking branch 'origin/1.6.x' into fix-send-migration-errors-individually	2024-11-13 09:13:15 +09:00
Bradley Schofield	29e7d1f7d0	Address Comments	2024-11-13 09:13:00 +09:00
Steven NguyenandGitHub	97bcccba85	Merge pull request #8963 from appwrite/remove-inaccurate-doc Remove inaccurate info about leaving the URL parameter empty	2024-11-12 15:43:56 -08:00
Christy JacobandGitHub	69b4ef4df1	Merge pull request #8964 from appwrite/debug-whitelist-console debug: whitelist console	2024-11-12 17:51:57 +01:00
Ebenezer DonandGitHub	7f3a342940	Remove inaccurate info about leaving the URL parameter empty	2024-11-12 16:44:20 +00:00
loks0n	dad8f597ca	debug: whitelist console	2024-11-12 16:05:51 +01:00
Torsten DittmannandGitHub	cca5606b70	Merge pull request #8943 from appwrite/feat-realtime-ping-pong feat: realtime ping pong	2024-11-12 14:09:58 +01:00
Luke B. SilverandGitHub	90f18c57ac	Merge pull request #8962 from appwrite/feat-fix-web-routes feat fix web routes	2024-11-12 12:42:30 +01:00
loks0n	6e7dd26f75	feat: fix web routes	2024-11-12 12:37:15 +01:00
Christy JacobandGitHub	9151abc951	Merge pull request #8797 from appwrite/feat-migration Feat migration	2024-11-12 10:27:24 +01:00
Jake Barnby	714f6b62ac	Merge remote-tracking branch 'origin/feat-custom-cf-hostnames' into feat-migration	2024-11-12 21:45:04 +13:00
Jake Barnby	316693798e	Merge remote-tracking branch 'origin/1.6.x' into feat-custom-cf-hostnames	2024-11-12 21:44:50 +13:00
Jake Barnby	c7f92fbb02	Merge remote-tracking branch 'origin/feat-custom-cf-hostnames' into feat-migration	2024-11-12 21:43:52 +13:00
Jake Barnby	e715f9e90c	Remove redundant V1 tests	2024-11-12 20:52:25 +13:00
Bradley Schofield	1337ea77b1	Fix Optionals	2024-11-12 16:18:09 +09:00
Jake Barnby	f6ea6d2fc5	Fix matrix	2024-11-12 19:15:33 +13:00
Jake Barnby	e626c2ad45	Run in all table modes in parallel	2024-11-12 19:14:46 +13:00
Bradley Schofield	a460a41fe5	Run Linter	2024-11-12 11:33:13 +09:00
Bradley Schofield	b62640489d	Fire logs for each individual migration error	2024-11-12 11:29:19 +09:00
Jake Barnby	3b19ef6b1e	Remove V2 tests	2024-11-12 15:00:23 +13:00
Jake Barnby	c1a3b29a97	Temp test all shared tables versions	2024-11-12 14:37:03 +13:00
Jake Barnby	aa2385ffb9	Merge branch 'revert-revert-8946-chore-update-database' into feat-migration # Conflicts: # composer.json # composer.lock	2024-11-12 13:36:05 +13:00
Jake Barnby	8b99517dd0	Merge remote-tracking branch 'origin/1.6.x' into feat-migration	2024-11-12 13:34:54 +13:00
Jake Barnby	33037a3ae5	Update database	2024-11-12 13:34:40 +13:00
Jake BarnbyandGitHub	f9e671419b	Merge pull request #8944 from appwrite/database-worker-errors Database worker errors	2024-11-12 13:23:24 +13:00
fogelito	fcf018580c	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into database-worker-errors	2024-11-11 18:53:36 +02:00
fogelito	8cca88f2b8	Remove Sentry comment	2024-11-11 18:52:15 +02:00
fogelito	bae6e465fa	updateAttributes	2024-11-11 18:46:47 +02:00
Jake Barnby	b0852aeca3	Update database	2024-11-11 23:15:00 +13:00
Jake Barnby	09da4378c6	Merge remote-tracking branch 'origin/1.6.x' into feat-migration	2024-11-11 23:13:35 +13:00
Jake BarnbyandGitHub	3846903b9d	Merge pull request #8956 from appwrite/fix-migration-id-null Remove double fetch from migrations worker	2024-11-11 22:13:57 +13:00
Bradley Schofield	d9e2ecff54	Remove get document from worker	2024-11-11 16:45:17 +09:00
Jake Barnby	a85b43654c	Reapply "Update database" This reverts commit `b1a1ad618a`.	2024-11-11 15:22:57 +13:00
fogelito	06e3afcf88	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into database-worker-errors	2024-11-10 16:42:34 +02:00
fogelito	0ef28eba17	Merge remote-tracking branch 'origin/database-worker-errors' into database-worker-errors	2024-11-10 16:38:04 +02:00
fogelito	e5730506eb	Remove var dumps	2024-11-10 16:37:44 +02:00
Christy Jacob	76216c3bf6	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-11-09 16:01:16 +00:00
loks0n	c8c4576bbc	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-11-09 13:07:15 +01:00
loks0n	dac8766eb4	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-11-08 22:02:31 +01:00
loks0n	f6de256220	chore: composer update	2024-11-08 21:50:33 +01:00
loks0n	2f9b44930f	Revert "Merge pull request #8946 from appwrite/chore-update-database" This reverts commit `c0bd1664be`, reversing changes made to `b42dd86451`.	2024-11-08 21:48:27 +01:00
loks0n	627df0d11f	chore: remove redundant compression	2024-11-08 20:24:55 +01:00
loks0n	fcd323baa4	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-11-08 20:24:35 +01:00
loks0n	0009b73b06	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-11-08 16:53:22 +01:00
Jake Barnby	3b82719b73	Merge remote-tracking branch 'origin/1.6.x' into database-worker-errors	2024-11-08 23:33:31 +13:00
Jake Barnby	030e26b223	Merge remote-tracking branch 'origin/1.6.x' into feat-custom-cf-hostnames	2024-11-08 23:33:10 +13:00
fogelito	06274764c6	Remove extra lines	2024-11-08 07:12:23 +02:00
Jake Barnby	9e69e41e02	Update lock	2024-11-08 17:04:29 +13:00
Jake Barnby	773fa6ffd6	Update lock	2024-11-08 16:34:07 +13:00
Jake Barnby	21bff77c50	Merge remote-tracking branch 'origin/feat-custom-cf-hostnames' into feat-migration # Conflicts: # composer.json # composer.lock	2024-11-08 16:32:55 +13:00
loks0n	472f167b4a	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-11-07 20:31:41 +01:00
fogelito	fb40970eba	line	2024-11-07 17:35:03 +02:00
fogelito	cd0d1d94db	Add to finally	2024-11-07 17:27:56 +02:00
fogelito	19667f78a9	Add try catch on delete Attribute	2024-11-07 17:23:46 +02:00
fogelito	a6779caa5e	Trigger sentry	2024-11-07 14:28:39 +02:00
Torsten Dittmann	cddd16b753	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-realtime-ping-pong	2024-11-07 13:10:23 +01:00
Torsten Dittmann	f91f382baf	style: remove unnecessary comment	2024-11-07 12:08:11 +01:00
Torsten Dittmann	4ee9e9730f	feat: realtime ping pong	2024-11-07 12:05:37 +01:00
Fabian Gruber	b4c986839e	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-11-06 12:40:56 +01:00
Damodar LohaniandGitHub	d425c9f071	Merge pull request #8930 from appwrite/pathc-update-utopia-storage upgrade utopia storage	2024-11-06 16:01:56 +05:45
Damodar Lohani	e219ee2d84	upgrade utopia storage	2024-11-06 10:02:11 +00:00
Jake Barnby	e66d0216c6	Merge remote-tracking branch 'origin/1.6.x' into feat-custom-cf-hostnames	2024-11-06 17:02:06 +13:00
Steven NguyenandGitHub	e3e20d2923	Merge pull request #8922 from appwrite/lohanidamodar-patch-4 Improve compression param checks	2024-11-05 17:35:39 -08:00
loks0n	e0c503e249	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-11-05 19:47:29 +01:00
Jake Barnby	228cabab3a	Merge remote-tracking branch 'origin/1.6.x' into feat-custom-cf-hostnames	2024-11-05 23:38:24 +13:00
Damodar Lohani	028c5366c2	make compression nullable and assign default in action - also update the `update bucket` endpoint	2024-11-05 08:12:58 +00:00
Damodar LohaniandGitHub	cca0c3ae45	Make compression param whitelist strict	2024-11-05 12:59:11 +05:45
Jake Barnby	0b85a64dab	Merge remote-tracking branch 'origin/1.6.x' into feat-custom-cf-hostnames	2024-11-04 22:44:25 +13:00
Jake Barnby	1633acbdc3	Merge remote-tracking branch 'origin/feat-custom-cf-hostnames' into feat-migration # Conflicts: # composer.json # composer.lock	2024-11-01 16:16:06 +13:00
Jake BarnbyandGitHub	75e8635563	Merge pull request #8904 from appwrite/1.6.x Merge 1.6.x into feat-custom-cf-hostnames	2024-10-31 22:12:38 +13:00
Jake Barnby	83e94629dc	Merge remote-tracking branch 'origin/feat-custom-cf-hostnames' into feat-migration	2024-10-31 21:49:49 +13:00
Fabian Gruber	6e3160c502	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-10-29 16:15:54 +01:00
Fabian Gruber	104ec3188f	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-10-29 15:36:38 +01:00
Fabian Gruber	b47a4703c4	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-10-25 13:39:12 +02:00
Fabian Gruber	4ceff430f9	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-10-24 12:49:26 +02:00
Christy JacobandGitHub	5603516d88	Merge branch '1.6.x' into feat-custom-cf-hostnames	2024-10-23 23:56:43 +04:00
Jake Barnby	013d95ebf3	Update audit and abuse	2024-10-23 18:42:00 +13:00
Jake Barnby	eca8d116c2	Fix attributes	2024-10-23 18:10:41 +13:00
Jake Barnby	8210808db0	Improve logic	2024-10-23 18:00:06 +13:00
Jake Barnby	4a003f2826	Force create audit/abuse metadata documents for shared tables v1	2024-10-23 17:41:44 +13:00
Christy Jacob	54f39494c0	Merge branch '1.6.x' of https://github.com/appwrite/appwrite into feat-custom-cf-hostnames	2024-10-22 19:51:03 +00:00
Christy Jacob	ae4edf119f	chore: linter	2024-10-22 19:49:10 +00:00
Fabian GruberandChristy Jacob	a56293e018	chore: replace 'Expires' with 'Cache-Control: private' header to avoid CDN caching	2024-10-22 12:18:58 +00:00
Jake Barnby	a0c58317bd	Merge remote-tracking branch 'origin/1.6.x' into feat-migration # Conflicts: # composer.json # composer.lock	2024-10-22 15:13:45 +13:00
Jake Barnby	d979c0c914	Create metadata document from outside if duplicate on shared tables V1	2024-10-21 22:43:47 +13:00
Christy Jacob	5ea83b8827	chore: update cert generation	2024-10-18 23:45:42 +00:00
Christy Jacob	6fe7d92fea	chore: update cert generation	2024-10-18 22:32:03 +00:00
Christy Jacob	28b02a4ba8	chore: fix bug	2024-10-18 21:18:20 +00:00
Christy Jacob	f4d456fa4c	chore: updat certs logic	2024-10-18 20:52:29 +00:00
Fabian Gruber	687252b15b	fix adding custom hostname & error logging	2024-10-18 22:21:53 +02:00
Fabian Gruber	f21b1c87a6	fix missing ssl object	2024-10-18 22:07:36 +02:00
Fabian Gruber	ccbde6c470	fix zone id	2024-10-18 21:44:36 +02:00
Torsten Dittmann	f189c41421	temp: custom cloudflare hostnames	2024-10-18 21:39:16 +02:00
Jake BarnbyandGitHub	5fcb990b1c	Merge branch '1.6.x' into feat-migration	2024-10-15 21:17:15 +13:00
Jake Barnby	30bd25d134	Update lock	2024-10-15 20:19:19 +13:00
Jake Barnby	36d2b84301	Update lock	2024-10-15 18:09:54 +13:00
Jake Barnby	78b9be2e78	Lint	2024-10-14 14:55:18 +13:00
Jake Barnby	a3b7cf84d5	Allow shared tables V1 and V2	2024-10-14 14:50:56 +13:00
Jake Barnby	add6a60af4	Remove redundant files	2024-10-14 14:33:53 +13:00
Jake Barnby	4543c182b5	Merge remote-tracking branch 'origin/1.6.x' into feat-migration # Conflicts: # Dockerfile # composer.json # composer.lock # src/Appwrite/Platform/Workers/Deletes.php	2024-10-14 14:29:04 +13:00
Jake Barnby	d18a67e6d8	Update packages	2024-09-12 23:06:47 +12:00
Jake Barnby	25d44b5b4c	Update generator	2024-09-12 23:04:44 +12:00
Jake Barnby	ee7de0cb41	Update database	2024-09-12 23:02:12 +12:00
Jake Barnby	28642b9f04	Shared tables array	2024-09-12 17:06:16 +12:00
Jake Barnby	c18308c024	Update database	2024-08-27 17:43:29 +12:00
Jake Barnby	1eafbf2ee2	Update database	2024-08-19 21:21:20 +12:00
Jake Barnby	b98bcdd4a1	Update database	2024-08-19 18:27:45 +12:00
Jake Barnby	4c8cd5b6c6	Update audit, abuse, database	2024-08-19 14:52:15 +12:00
Jake Barnby	5b37a91b46	Merge remote-tracking branch 'origin/1.5.x' into feat-migration	2024-08-13 22:11:18 +12:00
Jake Barnby	52647cef23	Merge remote-tracking branch 'origin/feat-single-shared-metadata-docs' into feat-migration # Conflicts: # composer.json # composer.lock	2024-08-13 22:10:57 +12:00
Jake Barnby	11ec31aefb	Update database	2024-08-13 21:49:25 +12:00
Jake Barnby	73ca1efbeb	Catch duplicate db on project create	2024-08-13 21:49:14 +12:00
Jake Barnby	340aa48d93	Catch duplicate on console db create	2024-08-13 21:14:52 +12:00
Jake Barnby	8ff72b341e	Don't set tenant for project collections creation	2024-08-12 23:46:34 +12:00
Jake Barnby	a23402075e	Update database	2024-08-12 17:45:43 +12:00
Jake Barnby	6b86ed0117	Merge remote-tracking branch 'origin/1.5.x' into feat-migration # Conflicts: # composer.lock	2024-08-07 22:10:04 +12:00
Jake Barnby	e2a45cec8e	Merge branch '1.5.x' into feat-migration # Conflicts: # composer.json # composer.lock	2024-08-05 21:13:42 +12:00
Jake Barnby	ec2eb2bfa3	Revert to utopia database instead of extension	2024-07-02 19:10:02 +12:00
Jake Barnby	10adfc5124	Add mirror override	2024-07-02 14:55:13 +12:00
Jake Barnby	5f7aae0e60	Add missing import	2024-06-21 13:43:01 +12:00
Jake Barnby	4952608b8d	Merge remote-tracking branch 'origin/refactor-usage-sn' into feat-migration	2024-06-21 13:39:51 +12:00
Jake Barnby	42ebefef92	Merge remote-tracking branch 'origin/refactor-usage-sn' into feat-migration	2024-06-19 19:32:30 +12:00
Jake Barnby	03d33601b0	Override find	2024-06-14 13:08:30 +12:00