Backward compatiblity with older redis versions (#133)

* Redis(NG) adapter: Added replicate command for backward compatiblity with redis version < 5

Signed-off-by: Immanuel Klinkenberg <drieschel@yahoo.de>

* Fixed blackbox tests

Signed-off-by: Immanuel Klinkenberg <drieschel@yahoo.de>

* Added PHPStan ignore error lines

Signed-off-by: Immanuel Klinkenberg <drieschel@yahoo.de>

* Test on multiple redis versions

---------

Signed-off-by: Immanuel Klinkenberg <drieschel@yahoo.de>
Co-authored-by: Lukas Kämmerling <github@lukas-kaemmerling.de>

.github/workflows/tests.yml

@@ -11,9 +11,9 @@ jobs:
         os: [ ubuntu-latest ]
         php: [ 7.4, 8.0, 8.1, 8.2 ]
         dependency-version: [ prefer-lowest, prefer-stable ]
-        redis-version: [ 6 ]
+        redis-version: [ 5, 6, 7 ]
 
-    name: P${{ matrix.php }} - ${{ matrix.dependency-version }} - ${{ matrix.os }}
+    name: P${{ matrix.php }} - ${{ matrix.dependency-version }} - ${{ matrix.os }} - ${{ matrix.redis-version }}
 
     env:
       # The hostname used to communicate with the Redis service container

src/Prometheus/CollectorRegistry.php

@@ -83,7 +83,7 @@ public function wipeStorage(): void
      */
     public function getMetricFamilySamples(bool $sortMetrics = true): array
     {
-        return $this->storageAdapter->collect($sortMetrics);
+        return $this->storageAdapter->collect($sortMetrics);  /** @phpstan-ignore-line */
     }
 
     /**

src/Prometheus/Storage/Redis.php

@@ -123,6 +123,7 @@ public function wipeStorage(): void
 
         $this->redis->eval(
             <<<LUA
+redis.replicate_commands()
 local cursor = "0"
 repeat 
     local results = redis.call('SCAN', cursor, 'MATCH', ARGV[1])

src/Prometheus/Storage/RedisNg.php

@@ -123,6 +123,7 @@ public function wipeStorage(): void
 
         $this->redis->eval(
             <<<LUA
+redis.replicate_commands()
 local cursor = "0"
 repeat 
     local results = redis.call('SCAN', cursor, 'MATCH', ARGV[1])
@@ -474,7 +475,7 @@ private function collectHistograms(): array
      *
      * @return string
      */
-    private function removePrefixFromKey(string $key): string
+    private function removePrefixFromKey(string $key): string  /** @phpstan-ignore-line */
     {
         // @phpstan-ignore-next-line false positive, phpstan thinks getOptions returns int
         if ($this->redis->getOption(\Redis::OPT_PREFIX) === null) {

tests/Test/BlackBoxTest.php

@@ -45,7 +45,7 @@ public function gaugesShouldBeOverwritten(): void
 
         ];
 
-        Promise\settle($promises)->wait();
+        Promise\Utils::settle($promises)->wait();
         $end = microtime(true);
         echo "\ntime: " . ($end - $start) . "\n";
 
@@ -84,7 +84,7 @@ public function countersShouldIncrementAtomically($increment): void
             $n += $increment;
         }
 
-        Promise\settle($promises)->wait();
+        Promise\Utils::settle($promises)->wait();
         $end = microtime(true);
         echo "\ntime: " . ($end - $start) . "\n";
 
@@ -124,7 +124,7 @@ public function histogramsShouldIncrementAtomically(): void
             $this->client->getAsync('/examples/some_histogram.php?c=9&adapter=' . $this->adapter),
         ];
 
-        Promise\settle($promises)->wait();
+        Promise\Utils::settle($promises)->wait();
         $end = microtime(true);
         echo "\ntime: " . ($end - $start) . "\n";
 
@@ -168,7 +168,7 @@ public function summariesShouldIncrementAtomically(): void
             $this->client->getAsync('/examples/some_summary.php?c=10&adapter=' . $this->adapter),
         ];
 
-        Promise\settle($promises)->wait();
+        Promise\Utils::settle($promises)->wait();
         $end = microtime(true);
         echo "\ntime: " . ($end - $start) . "\n";