Redis Streams

composer.json

@@ -26,6 +26,7 @@
     "require": {
         "php": ">=8.3",
         "php-amqplib/php-amqplib": "^3.7",
+        "dragonmantank/cron-expression": "^3.0",
         "utopia-php/console": "0.0.*",
         "utopia-php/framework": "0.33.*",
         "utopia-php/telemetry": "*",

docker-compose.yml

@@ -10,6 +10,7 @@ services:
       - swoole
       - swoole-amqp
       - swoole-redis-cluster
+      - swoole-redis-streams
       - workerman
 
   swoole:
@@ -35,6 +36,17 @@ services:
       redis-cluster-0:
         condition: service_healthy
 
+  swoole-redis-streams:
+    container_name: swoole-redis-streams
+    build: ./tests/Queue/servers/SwooleRedisStreams/.
+    command: php /usr/src/code/tests/Queue/servers/SwooleRedisStreams/worker.php
+    volumes:
+      - ./vendor:/usr/src/code/vendor
+      - ./src:/usr/src/code/src
+      - ./tests:/usr/src/code/tests
+    depends_on:
+      - redis
+
   swoole-amqp:
     container_name: swoole-amqp
     build: ./tests/Queue/servers/AMQP/.
@@ -61,8 +73,6 @@ services:
   redis:
     container_name: redis
     image: "redis:alpine"
-    ports:
-      - "6379:6379"
 
   redis-cluster-0:
     image: docker.io/bitnamilegacy/redis-cluster:7.4

phpstan.neon

@@ -6,4 +6,12 @@ parameters:
         - tests
 
     scanDirectories:
-        - vendor/swoole
+        - vendor/swoole
+
+    # phpredis stubs don't include Redis Streams methods (xAdd, xGroup, etc.)
+    # These methods exist at runtime but PHPStan's stubs are incomplete
+    # See: https://github.com/phpredis/phpredis-stubs/issues
+    ignoreErrors:
+        -
+            message: '#Call to an undefined method RedisCluster::(x(Add|Group|ReadGroup|Ack|Pending|Claim|AutoClaim|Del|Len|Trim|Info|Range|RevRange)|eval)\(\)#'
+            path: src/Queue/Connection/RedisStreamCluster.php

phpunit.xml

@@ -12,5 +12,8 @@
         <testsuite name="E2E">
             <directory>./tests/Queue/E2E/Adapter</directory>
         </testsuite>
+        <testsuite name="Unit">
+            <directory>./tests/Queue/Unit</directory>
+        </testsuite>
     </testsuites>
 </phpunit>