refactor: replace StorageManager abstraction with direct Laravel Redis usage

Problem:
- Complex abstraction layer (StorageManager + StorageDriver interface)
- Difficult prefix handling with phpredis
- Over-engineered for simple Redis operations

Solution:
- Created RedisMetricsStore - simple wrapper around Laravel's Redis facade
- Laravel handles all prefix logic automatically and consistently
- Removed need for separate driver implementations
- Same interface as before, but simpler implementation

Benefits:
- Leverages Laravel's Redis connection directly (no reinventing wheel)
- Consistent prefix behavior (Laravel handles it)
- Easier to debug (less abstraction layers)
- More maintainable (less custom code)
- Still supports configurable connection via queue-metrics.storage.connection

Implementation:
1. Created Support/RedisMetricsStore with StorageDriver-compatible interface
2. Updated ServiceProvider to use RedisMetricsStore instead of StorageManager
3. Updated all repositories to inject RedisMetricsStore
4. Updated MetricsQueryService to use new store

Next: Remove old Storage classes (will do after testing)

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: sylvesterdamgaard

src/LaravelQueueMetricsServiceProvider.php

@@ -47,7 +47,7 @@
 use PHPeek\LaravelQueueMetrics\Services\LaravelQueueInspector;
 use PHPeek\LaravelQueueMetrics\Services\MetricsQueryService;
 use PHPeek\LaravelQueueMetrics\Services\ServerMetricsService;
-use PHPeek\LaravelQueueMetrics\Storage\StorageManager;
+use PHPeek\LaravelQueueMetrics\Support\RedisMetricsStore;
 use PHPeek\LaravelQueueMetrics\Utilities\PercentileCalculator;
 use Gophpeek\SystemMetrics\SystemMetrics;
 use Spatie\LaravelPackageTools\Package;
@@ -77,30 +77,30 @@ public function packageRegistered(): void
             return $app->make(QueueMetricsConfig::class)->storage;
         });
 
-        // Register storage manager
-        $this->app->singleton(StorageManager::class, function ($app) {
-            return new StorageManager($app->make(StorageConfig::class));
+        // Register Redis metrics store - uses Laravel's Redis connection directly
+        $this->app->singleton(RedisMetricsStore::class, function () {
+            return new RedisMetricsStore();
         });
 
-        // Register repositories - all use StorageManager
+        // Register repositories - all use RedisMetricsStore
         $this->app->singleton(JobMetricsRepository::class, function ($app) {
-            return new RedisJobMetricsRepository($app->make(StorageManager::class));
+            return new RedisJobMetricsRepository($app->make(RedisMetricsStore::class));
         });
 
         $this->app->singleton(QueueMetricsRepository::class, function ($app) {
-            return new RedisQueueMetricsRepository($app->make(StorageManager::class));
+            return new RedisQueueMetricsRepository($app->make(RedisMetricsStore::class));
         });
 
         $this->app->singleton(WorkerRepository::class, function ($app) {
-            return new RedisWorkerRepository($app->make(StorageManager::class));
+            return new RedisWorkerRepository($app->make(RedisMetricsStore::class));
         });
 
         $this->app->singleton(BaselineRepository::class, function ($app) {
-            return new RedisBaselineRepository($app->make(StorageManager::class));
+            return new RedisBaselineRepository($app->make(RedisMetricsStore::class));
         });
 
         $this->app->singleton(WorkerHeartbeatRepository::class, function ($app) {
-            return new RedisWorkerHeartbeatRepository($app->make(StorageManager::class));
+            return new RedisWorkerHeartbeatRepository($app->make(RedisMetricsStore::class));
         });
 
         // Register system metrics

src/Repositories/RedisBaselineRepository.php

@@ -7,15 +7,15 @@
 use Carbon\Carbon;
 use PHPeek\LaravelQueueMetrics\DataTransferObjects\BaselineData;
 use PHPeek\LaravelQueueMetrics\Repositories\Contracts\BaselineRepository;
-use PHPeek\LaravelQueueMetrics\Storage\StorageManager;
+use PHPeek\LaravelQueueMetrics\Support\RedisMetricsStore;
 
 /**
  * Redis-based implementation of baseline repository.
  */
 final readonly class RedisBaselineRepository implements BaselineRepository
 {
     public function __construct(
-        private StorageManager $redis,
+        private RedisMetricsStore $redis,
     ) {}
 
     public function storeBaseline(BaselineData $baseline): void

src/Repositories/RedisJobMetricsRepository.php

@@ -7,15 +7,15 @@
 use Carbon\Carbon;
 use Illuminate\Redis\Connections\Connection;
 use PHPeek\LaravelQueueMetrics\Repositories\Contracts\JobMetricsRepository;
-use PHPeek\LaravelQueueMetrics\Storage\StorageManager;
+use PHPeek\LaravelQueueMetrics\Support\RedisMetricsStore;
 
 /**
  * Redis-based implementation of job metrics repository.
  */
 final readonly class RedisJobMetricsRepository implements JobMetricsRepository
 {
     public function __construct(
-        private StorageManager $redis,
+        private RedisMetricsStore $redis,
     ) {}
 
     public function recordStart(

src/Repositories/RedisQueueMetricsRepository.php

@@ -7,15 +7,15 @@
 use Carbon\Carbon;
 use Illuminate\Support\Facades\Queue;
 use PHPeek\LaravelQueueMetrics\Repositories\Contracts\QueueMetricsRepository;
-use PHPeek\LaravelQueueMetrics\Storage\StorageManager;
+use PHPeek\LaravelQueueMetrics\Support\RedisMetricsStore;
 
 /**
  * Redis-based implementation of queue metrics repository.
  */
 final readonly class RedisQueueMetricsRepository implements QueueMetricsRepository
 {
     public function __construct(
-        private StorageManager $redis,
+        private RedisMetricsStore $redis,
     ) {}
 
     /**

src/Repositories/RedisWorkerHeartbeatRepository.php

@@ -9,15 +9,15 @@
 use PHPeek\LaravelQueueMetrics\DataTransferObjects\WorkerHeartbeat;
 use PHPeek\LaravelQueueMetrics\Enums\WorkerState;
 use PHPeek\LaravelQueueMetrics\Repositories\Contracts\WorkerHeartbeatRepository;
-use PHPeek\LaravelQueueMetrics\Storage\StorageManager;
+use PHPeek\LaravelQueueMetrics\Support\RedisMetricsStore;
 
 /**
  * Redis-based implementation of worker heartbeat repository.
  */
 final readonly class RedisWorkerHeartbeatRepository implements WorkerHeartbeatRepository
 {
     public function __construct(
-        private StorageManager $redis,
+        private RedisMetricsStore $redis,
     ) {}
 
     public function recordHeartbeat(

src/Repositories/RedisWorkerRepository.php

@@ -7,15 +7,15 @@
 use Carbon\Carbon;
 use PHPeek\LaravelQueueMetrics\DataTransferObjects\WorkerStatsData;
 use PHPeek\LaravelQueueMetrics\Repositories\Contracts\WorkerRepository;
-use PHPeek\LaravelQueueMetrics\Storage\StorageManager;
+use PHPeek\LaravelQueueMetrics\Support\RedisMetricsStore;
 
 /**
  * Redis-based implementation of worker repository.
  */
 final readonly class RedisWorkerRepository implements WorkerRepository
 {
     public function __construct(
-        private StorageManager $redis,
+        private RedisMetricsStore $redis,
     ) {}
 
     public function registerWorker(

src/Services/MetricsQueryService.php

@@ -95,16 +95,14 @@ public function getOverview(): array
         $totalFailed = 0;
 
         // Scan Redis for all job metrics keys and aggregate
-        $manager = app(\PHPeek\LaravelQueueMetrics\Storage\StorageManager::class);
+        $store = app(\PHPeek\LaravelQueueMetrics\Support\RedisMetricsStore::class);
 
         // Laravel's Redis connection automatically adds prefix for KEYS command
         // So we only use our package prefix, not Laravel's Redis prefix
-        $pattern = $manager->key('jobs', '*', '*', '*');
-
-        $driver = $manager->driver();
+        $pattern = $store->key('jobs', '*', '*', '*');
 
         // Get all job metrics keys
-        $keys = $driver->scanKeys($pattern);
+        $keys = $store->scanKeys($pattern);
 
         // Laravel's Redis prefix for stripping
         $laravelPrefix = config('database.redis.options.prefix', '');
@@ -117,7 +115,7 @@ public function getOverview(): array
                 ? str_replace($laravelPrefix, '', $fullKey)
                 : $fullKey;
 
-            $data = $driver->getHash($relativeKey);
+            $data = $store->getHash($relativeKey);
             if (is_array($data)) {
                 $totalProcessed += (int) ($data['total_processed'] ?? 0);
                 $totalFailed += (int) ($data['total_failed'] ?? 0);

src/Support/MetricsKeyBuilder.php

@@ -0,0 +1,34 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PHPeek\LaravelQueueMetrics\Support;
+
+/**
+ * Helper for building Redis keys with consistent prefixing.
+ */
+final readonly class MetricsKeyBuilder
+{
+    private string $prefix;
+
+    public function __construct(?string $prefix = null)
+    {
+        $this->prefix = $prefix ?? config('queue-metrics.storage.prefix', 'queue_metrics');
+    }
+
+    /**
+     * Build a Redis key from segments.
+     */
+    public function key(string ...$segments): string
+    {
+        return $this->prefix . ':' . implode(':', $segments);
+    }
+
+    /**
+     * Get TTL for a given key type.
+     */
+    public function getTtl(string $type): int
+    {
+        return config("queue-metrics.storage.ttl.{$type}", 3600);
+    }
+}