Allow auth in redis-transport (#16)

* allow auth in redis-transport

* Allow only messenger 4.2.* to avoid conflicts

* Fix auth variable in RedisStreamTransport construct

Author: wachterjohannes

Transport/RedisStreamTransport.php

@@ -65,15 +65,20 @@ class RedisStreamTransport implements TransportInterface
      * @var SerializerInterface
      */
     private $serializer;
+    /**
+     * @var string|null
+     */
+    private $auth;
 
-    public function __construct(string $host, int $port, string $stream, string $group = '', string $consumer = '', ?SerializerInterface $serializer = null)
+    public function __construct(string $host, int $port, string $stream, string $group = '', string $consumer = '', ?SerializerInterface $serializer = null, ?string $auth = null)
     {
         $this->host = $host;
         $this->port = $port;
         $this->stream = $stream;
         $this->group = $group;
         $this->consumer = $consumer;
         $this->serializer = $serializer ?? Serializer::create();
+        $this->auth = $auth;
     }
 
     public function receive(callable $handler): void
@@ -111,6 +116,9 @@ private function getRedis(): Redis
     {
         $this->redis = new Redis();
         $this->redis->connect($this->host, $this->port);
+        if ($this->auth) {
+            $this->redis->auth($this->auth);
+        }
 
         return $this->redis;
     }

Transport/RedisStreamTransportFactory.php

@@ -33,8 +33,9 @@ public function createTransport(string $dsn, array $options): TransportInterface
         $stream = $dsnParts[1];
         $group = $dsnParts[2] ?? '';
         $consumer = $dsnParts[3] ?? '';
+        $auth = $parsedUrl['user'] ?? null;
 
-        return new RedisStreamTransport($parsedUrl['host'], $parsedUrl['port'], $stream, $group, $consumer);
+        return new RedisStreamTransport($parsedUrl['host'], $parsedUrl['port'], $stream, $group, $consumer, null, $auth);
     }
 
     public function supports(string $dsn, array $options): bool

composer.json

@@ -5,8 +5,8 @@
     "license": "MIT",
     "require": {
         "php": "^7.1",
-        "ext-redis": "^4.2",
-        "symfony/messenger": "^4.2",
+        "ext-redis": "^4.2 || ^5.0",
+        "symfony/messenger": "4.2.*",
         "symfony/config": "^3.4 || ^4.0",
         "symfony/dependency-injection": "^3.4 || ^4.0",
         "symfony/serializer": "^3.4 || ^4.0",