RedisSentinel\Laravel\Database

Complexity

Total Complexity

6

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	createSingleClients()	0	14	2
A	setUpdateSentinels()	0	10	4

<?php

namespace RedisSentinel\Laravel;

use Illuminate\Support\Arr;
use Predis\Client;
use Illuminate\Redis\Database as LaravelRedisDatabase;
use Predis\Connection\Aggregate\SentinelReplication;
use Predis\Connection\ConnectionInterface;

class Database extends LaravelRedisDatabase
{
    /**
     * Create an array of single connection or sentinel clients
     *
     * @param  array  $servers
     * @param  array  $options
     * @return array
     */
    protected function createSingleClients(array $servers, array $options = [])
    {
        $clients = [];

        foreach ($servers as $key => $server) {
            $options = array_merge($options, Arr::pull($server, 'options'));

            $clients[$key] = new Client($server, $options);

            $this->setUpdateSentinels(($clients[$key])->getConnection(), $options);
        }

        return $clients;
    }


    /**
     * Sets the update sentinels flag on the connection if configured and possible.
     *
     * @param $connection ConnectionInterface
     * @param $options array
     */
    private function setUpdateSentinels($connection, $options)
    {
        if (isset($options['update_sentinels'])
                && boolval($options['update_sentinels']) === true
                && $connection instanceof SentinelReplication) {

            // is not defined on the ConnectionInterface so make sure we've got the right thing.
            $connection->setUpdateSentinels(true);
        }
    }
}