Properly support RedisCluster

Signed-off-by: John Molakvoæ (skjnldsv) <skjnldsv@protonmail.com>

Author: skjnldsv

config/config.sample.php

@@ -1234,7 +1234,7 @@
 	'user' =>  '', // Optional, if not defined no password will be used.
 	'password' => '', // Optional, if not defined no password will be used.
 	'dbindex' => 0, // Optional, if undefined SELECT will not run and will use Redis Server's default DB Index.
-	// If redis is encrypted, provide certificates
+	// If redis in-transit encryption is enabled, provide certificates
 	// SSL context https://www.php.net/manual/en/context.ssl.php
 	'ssl_context' => [
 		'local_cert' => '/certs/redis.crt',

lib/private/RedisFactory.php

@@ -46,28 +46,29 @@ public function __construct(SystemConfig $config) {
 	}
 
 	private function create() {
-		$isCluster = !empty($this->config->getValue('redis.cluster', []));
-		$config = $this->config->getValue('redis', []);
+		$isCluster = in_array('redis.cluster', $this->config->getKeys());
+		$config = $isCluster
+			? $this->config->getValue('redis.cluster', [])
+			: $this->config->getValue('redis', []);
 
-		// Init cluster config if any
-		if ($isCluster) {
-			if (!class_exists('RedisCluster')) {
-				throw new \Exception('Redis Cluster support is not available');
-			}
-			// Replace config with the cluster config
-			$config = $this->config->getValue('redis.cluster', []);
+		if (empty($config)) {
+			throw new \Exception('Redis config is empty');
+		}
+
+		if ($isCluster && !class_exists('RedisCluster')) {
+			throw new \Exception('Redis Cluster support is not available');
 		}
 
 		if (isset($config['timeout'])) {
 			$timeout = $config['timeout'];
 		} else {
-			$timeout = null;
+			$timeout = 0.0;
 		}
 
 		if (isset($config['read_timeout'])) {
 			$readTimeout = $config['read_timeout'];
 		} else {
-			$readTimeout = null;
+			$readTimeout = 0.0;
 		}
 
 		$auth = null;
@@ -85,11 +86,7 @@ private function create() {
 
 		// cluster config
 		if ($isCluster) {
-			if ($connectionParameters !== null) {
-				$this->instance = new \RedisCluster(null, $config['seeds'], $timeout, $readTimeout, false, $auth, $connectionParameters);
-			} else {
-				$this->instance = new \RedisCluster(null, $config['seeds'], $timeout, $readTimeout, $auth);
-			}
+			$this->instance = new \RedisCluster(null, $config['seeds'], $timeout, $readTimeout, false, $auth, $connectionParameters);
 
 			if (isset($config['failover_mode'])) {
 				$this->instance->setOption(\RedisCluster::OPT_SLAVE_FAILOVER, $config['failover_mode']);
@@ -111,7 +108,8 @@ private function create() {
 				$port = null;
 			}
 
-			if (!empty($connectionParameters)) {
+			if ($connectionParameters !== null) {
+				// Non-clustered redis requires connection parameters to be wrapped inside `stream`
 				$connectionParameters = [
 					'stream' => $this->getSslContext($config)
 				];
@@ -134,7 +132,7 @@ private function create() {
 	 * Get the ssl context config
 	 *
 	 * @param Array $config the current config
-	 * @return Array
+	 * @return Array|null
 	 * @throws \UnexpectedValueException
 	 */
 	private function getSslContext($config) {
@@ -147,7 +145,7 @@ private function getSslContext($config) {
 			}
 			return $config['ssl_context'];
 		}
-		return [];
+		return null;
 	}
 
 	public function getInstance() {