Complete Redis cache driver refactor with enhanced tagging

.env.example

@@ -0,0 +1,13 @@
+# Redis Integration Tests
+# Copy this file to .env and configure to run integration tests locally.
+# These tests are skipped by default. Set RUN_REDIS_INTEGRATION_TESTS=true to enable.
+
+# Enable/disable Redis integration tests
+RUN_REDIS_INTEGRATION_TESTS=false
+
+# Redis connection settings
+# Defaults work for standard local Redis (localhost:6379, no auth, DB 8)
+REDIS_HOST=127.0.0.1
+REDIS_PORT=6379
+REDIS_AUTH=
+REDIS_DB=8

.github/workflows/tests.yml

@@ -29,11 +29,71 @@ jobs:
       - name: Checkout code
         uses: actions/checkout@v4
 
+      - name: Cache Composer dependencies
+        uses: actions/cache@v4
+        with:
+          path: /root/.composer/cache
+          key: composer-${{ matrix.php }}-${{ hashFiles('composer.lock') }}
+          restore-keys: composer-${{ matrix.php }}-
+
       - name: Install dependencies
         run: |
             COMPOSER_MEMORY_LIMIT=-1 composer install --prefer-dist -n -o
 
       - name: Execute tests
         run: |
             PHP_CS_FIXER_IGNORE_ENV=1 vendor/bin/php-cs-fixer fix --dry-run --diff
-            vendor/bin/phpunit -c phpunit.xml.dist
+            vendor/bin/phpunit -c phpunit.xml.dist --exclude-group redis-integration
+
+  redis_integration_tests:
+    runs-on: ubuntu-latest
+    if: "!contains(github.event.head_commit.message, '[skip ci]') && !contains(github.event.head_commit.message, '[ci skip]')"
+
+    strategy:
+      fail-fast: false
+      matrix:
+        include:
+          - redis: "redis:8"
+            name: "Redis 8"
+          - redis: "valkey/valkey:9"
+            name: "Valkey 9"
+
+    name: Integration (${{ matrix.name }})
+
+    services:
+      redis:
+        image: ${{ matrix.redis }}
+        options: >-
+          --health-cmd "redis-cli ping"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+        ports:
+          - 6379:6379
+
+    container:
+      image: phpswoole/swoole:6.1.4-php8.4
+
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+
+      - name: Cache Composer dependencies
+        uses: actions/cache@v4
+        with:
+          path: /root/.composer/cache
+          key: composer-8.4-${{ hashFiles('composer.lock') }}
+          restore-keys: composer-8.4-
+
+      - name: Install dependencies
+        run: |
+            COMPOSER_MEMORY_LIMIT=-1 composer install --prefer-dist -n -o
+
+      - name: Execute Redis integration tests
+        env:
+          RUN_REDIS_INTEGRATION_TESTS: true
+          REDIS_HOST: redis
+          REDIS_PORT: 6379
+          REDIS_DB: 8
+        run: |
+            vendor/bin/phpunit -c phpunit.xml.dist --group redis-integration

.gitignore

@@ -1,5 +1,7 @@
 .idea
+/.env
 /.phpunit.cache
+/.tmp
 /vendor
 composer.lock
 /phpunit.xml

phpunit.xml.dist

@@ -1,5 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <phpunit backupGlobals="false"
+         bootstrap="tests/bootstrap.php"
          beStrictAboutTestsThatDoNotTestAnything="false"
          colors="true"
          processIsolation="false"

src/cache/publish/cache.php

@@ -49,6 +49,7 @@
         'redis' => [
             'driver' => 'redis',
             'connection' => 'default',
+            'tag_mode' => env('REDIS_CACHE_TAG_MODE', 'all'), // Redis 8.0+ and PhpRedis 6.3.0+ required for 'any'
             'lock_connection' => 'default',
         ],
 

src/cache/src/CacheManager.php

@@ -237,6 +237,7 @@ protected function createRedisDriver(array $config): Repository
         $connection = $config['connection'] ?? 'default';
 
         $store = new RedisStore($redis, $this->getPrefix($config), $connection);
+        $store->setTagMode($config['tag_mode'] ?? 'all');
 
         return $this->repository(
             $store->setLockConnection($config['lock_connection'] ?? $connection),

src/cache/src/ConfigProvider.php

@@ -10,6 +10,9 @@
 use Hypervel\Cache\Contracts\Store;
 use Hypervel\Cache\Listeners\CreateSwooleTable;
 use Hypervel\Cache\Listeners\CreateTimer;
+use Hypervel\Cache\Redis\Console\BenchmarkCommand;
+use Hypervel\Cache\Redis\Console\DoctorCommand;
+use Hypervel\Cache\Redis\Console\PruneStaleTagsCommand;
 
 class ConfigProvider
 {
@@ -25,8 +28,11 @@ public function __invoke(): array
                 CreateTimer::class,
             ],
             'commands' => [
+                BenchmarkCommand::class,
                 ClearCommand::class,
+                DoctorCommand::class,
                 PruneDbExpiredCommand::class,
+                PruneStaleTagsCommand::class,
             ],
             'publish' => [
                 [

src/cache/src/Redis/AllTagSet.php

@@ -0,0 +1,76 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Hypervel\Cache\Redis;
+
+use Hyperf\Collection\LazyCollection;
+use Hypervel\Cache\Contracts\Store;
+use Hypervel\Cache\RedisStore;
+use Hypervel\Cache\TagSet;
+
+class AllTagSet extends TagSet
+{
+    /**
+     * The cache store implementation.
+     *
+     * @var RedisStore
+     */
+    protected Store $store;
+
+    /**
+     * Add a reference entry to the tag set's underlying sorted set.
+     */
+    public function addEntry(string $key, int $ttl = 0, ?string $updateWhen = null): void
+    {
+        $this->store->allTagOps()->addEntry()->execute($key, $ttl, $this->tagIds(), $updateWhen);
+    }
+
+    /**
+     * Get all of the cache entry keys for the tag set.
+     */
+    public function entries(): LazyCollection
+    {
+        return $this->store->allTagOps()->getEntries()->execute($this->tagIds());
+    }
+
+    /**
+     * Flush the tag from the cache.
+     */
+    public function flushTag(string $name): string
+    {
+        return $this->resetTag($name);
+    }
+
+    /**
+     * Reset the tag and return the new tag identifier.
+     */
+    public function resetTag(string $name): string
+    {
+        $this->store->forget($this->tagKey($name));
+
+        return $this->tagId($name);
+    }
+
+    /**
+     * Get the unique tag identifier for a given tag.
+     *
+     * Delegates to StoreContext which delegates to TagMode (single source of truth).
+     * Format: "_all:tag:{name}:entries"
+     */
+    public function tagId(string $name): string
+    {
+        return $this->store->getContext()->tagId($name);
+    }
+
+    /**
+     * Get the tag identifier key for a given tag.
+     *
+     * Same as tagId() - the identifier without cache prefix.
+     * Used with store->forget() which adds the prefix.
+     */
+    public function tagKey(string $name): string
+    {
+        return $this->store->getContext()->tagId($name);
+    }
+}