Add cache reconnection test

Author: premtsd-code

tests/e2e/Adapter/Scopes/GeneralTests.php

@@ -4,6 +4,8 @@
 
 use Exception;
 use Throwable;
+use Utopia\Cache\Adapter\Redis as RedisAdapter;
+use Utopia\Cache\Cache;
 use Utopia\CLI\Console;
 use Utopia\Database\Database;
 use Utopia\Database\Document;
@@ -697,6 +699,72 @@ public function testCacheFallback(): void
         $this->assertCount(1, $database->find('testRedisFallback', [Query::equal('string', ['text📝'])]));
     }
 
+    public function testCacheReconnect(): void
+    {
+        /** @var Database $database */
+        $database = $this->getDatabase();
+
+        if (!$database->getAdapter()->getSupportForCacheSkipOnFailure()) {
+            $this->expectNotToPerformAssertions();
+            return;
+        }
+
+        // Create new cache with reconnection enabled
+        $redis = new \Redis();
+        $redis->connect('redis', 6379);
+        $cache = new Cache((new RedisAdapter($redis))->setMaxRetries(2));
+        $database->setCache($cache);
+
+        $database->getAuthorization()->cleanRoles();
+        $database->getAuthorization()->addRole(Role::any()->toString());
+
+        $database->createCollection('testCacheReconnect', attributes: [
+            new Document([
+                '$id' => ID::custom('title'),
+                'type' => Database::VAR_STRING,
+                'size' => 255,
+                'required' => true,
+            ])
+        ], permissions: [
+            Permission::read(Role::any()),
+            Permission::create(Role::any()),
+            Permission::update(Role::any()),
+            Permission::delete(Role::any())
+        ]);
+
+        $database->createDocument('testCacheReconnect', new Document([
+            '$id' => 'reconnect_doc',
+            'title' => 'Test Document',
+        ]));
+
+        // Cache the document
+        $doc = $database->getDocument('testCacheReconnect', 'reconnect_doc');
+        $this->assertEquals('Test Document', $doc->getAttribute('title'));
+
+        // Bring down Redis
+        $stdout = '';
+        $stderr = '';
+        Console::execute('docker ps -a --filter "name=utopia-redis" --format "{{.Names}}" | xargs -r docker stop', "", $stdout, $stderr);
+        sleep(1);
+
+        // Bring back Redis
+        Console::execute('docker ps -a --filter "name=utopia-redis" --format "{{.Names}}" | xargs -r docker start', "", $stdout, $stderr);
+        sleep(3);
 
+        // Cache should reconnect - read should work
+        $doc = $database->getDocument('testCacheReconnect', 'reconnect_doc');
+        $this->assertEquals('Test Document', $doc->getAttribute('title'));
 
+        // Update should work after reconnect
+        $database->updateDocument('testCacheReconnect', 'reconnect_doc', new Document([
+            '$id' => 'reconnect_doc',
+            'title' => 'Updated Title',
+        ]));
+
+        $doc = $database->getDocument('testCacheReconnect', 'reconnect_doc');
+        $this->assertEquals('Updated Title', $doc->getAttribute('title'));
+
+        // Cleanup
+        $database->deleteCollection('testCacheReconnect');
+    }
 }