feat: add Redis username authentication support (#66)

formbay-sanil · web-flow · commit 0f95012aa967 · 2025-08-19T19:42:31.000+02:00
- Add username config option to Redis configuration
- Support both username+password and password-only auth methods
- Maintain backward compatibility with existing password-only setups
- Improve error messages for authentication failures

Signed-off-by: Sanil Shrestha &lt;sanil.shrestha@formbay.com.au&gt;
diff --git a/src/Handlers/RedisHandler.php b/src/Handlers/RedisHandler.php
@@ -40,9 +40,12 @@ public function __construct(protected QueueConfig $config)
             if (! $this->redis->connect($config->redis['host'], ($config->redis['host'][0] === '/' ? 0 : $config->redis['port']), $config->redis['timeout'])) {
                 throw new CriticalError('Queue: Redis connection failed. Check your configuration.');
             }
+            if (isset($config->redis['username'], $config->redis['password']) && ! $this->redis->auth([$config->redis['username'], $config->redis['password']])) {
+                throw new CriticalError('Queue: Redis authentication failed. Check your username and password.');
+            }
 
             if (isset($config->redis['password']) && ! $this->redis->auth($config->redis['password'])) {
-                throw new CriticalError('Queue: Redis authentication failed.');
+                throw new CriticalError('Queue: Redis authentication failed. Check your password.');
             }
 
             if (isset($config->redis['database']) && ! $this->redis->select($config->redis['database'])) {

Original file line number	Diff line number	Diff line change
`@@ -40,9 +40,12 @@ public function __construct(protected QueueConfig $config)`
`40`	`40`	`if (! $this->redis->connect($config->redis['host'], ($config->redis['host'][0] === '/' ? 0 : $config->redis['port']), $config->redis['timeout'])) {`
`41`	`41`	`throw new CriticalError('Queue: Redis connection failed. Check your configuration.');`
`42`	`42`	`}`
	`43`	`+ if (isset($config->redis['username'], $config->redis['password']) && ! $this->redis->auth([$config->redis['username'], $config->redis['password']])) {`
	`44`	`+ throw new CriticalError('Queue: Redis authentication failed. Check your username and password.');`
	`45`	`+ }`
`43`	`46`
`44`	`47`	`if (isset($config->redis['password']) && ! $this->redis->auth($config->redis['password'])) {`
`45`		`- throw new CriticalError('Queue: Redis authentication failed.');`
	`48`	`+ throw new CriticalError('Queue: Redis authentication failed. Check your password.');`
`46`	`49`	`}`
`47`	`50`
`48`	`51`	`if (isset($config->redis['database']) && ! $this->redis->select($config->redis['database'])) {`