Lamoda\RedisSentinel\RedisLocator

Complexity

Total Complexity

7

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getRedisConfig()	0	13	2
A	initMasterDiscovery()	0	25	4

<?php

declare(strict_types=1);

namespace Lamoda\RedisSentinel;

use PSRedis\Client;
use PSRedis\MasterDiscovery;

class RedisLocator
{
    /** @var array */
    private $redisConfig;

    /** @var array */
    private $redisSentinelConfig;

    /** @var MasterDiscovery */
    private $masterDiscovery;

    public function __construct(array $redisConfig, array $redisSentinelConfig)
    {
        $this->redisConfig = $redisConfig;
        $this->redisSentinelConfig = $redisSentinelConfig;

        $this->masterDiscovery = $this->initMasterDiscovery();
    }

    public function getRedisConfig(): RedisConfig
    {
        $redisConfig = $this->redisConfig;

        if ($this->masterDiscovery) {
            /** @var Client $master */
            $master = $this->masterDiscovery->getMaster();
            $redisConfig['host'] = $master->getIpAddress();
            $redisConfig['port'] = (int) $master->getPort();
        }

        return new RedisConfig($redisConfig);
    }

    private function initMasterDiscovery(): ?MasterDiscovery
    {
        $urls = trim((string) ($this->redisSentinelConfig['url'] ?? ''));
        if (empty($urls)) {
            return null;
        }

        $urls = preg_split('/[\s,;]+/', $urls);
        $masterDiscovery = new MasterDiscovery($this->redisSentinelConfig['redisName']);
        $backoffStrategy = new MasterDiscovery\BackoffStrategy\Incremental(100, 1.5);
        $backoffStrategy->setMaxAttempts(10);
        $masterDiscovery->setBackoffStrategy($backoffStrategy);
        foreach ($urls as $singleSentinelUrl) {
            $url = parse_url($singleSentinelUrl);
            if (false === $url) {
                throw new \InvalidArgumentException("Invalid Sentinel URL: $singleSentinelUrl");
            }
            $host = $url['host'] ?? $url['path'];
            $port = $url['port'] ?? 26379;
            $sentinel = new Client($host, $port);
            $masterDiscovery->addSentinel($sentinel);
        }

        return $masterDiscovery;
    }
}