Phloppy\Client\Cluster

Complexity

Total Complexity

3

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	5
Bugs	1	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
A	meet()	0	21	3

<?php
namespace Phloppy\Client;

use Phloppy\Exception;
use Phloppy\Exception\CommandException;
use Phloppy\Stream\StreamException;

/**
 * Disque cluster commands.
 *
 * @see http://redis.io/commands#cluster
 */
class Cluster extends AbstractClient {


    /**
     * Introduce the provided nodes to the connected Disque instance.
     *
     * @param string[] $nodeUrls
     *
     * @return string[]
     * @see http://redis.io/commands/cluster-meet
     */
    public function meet(array $nodeUrls)
    {
        $current = $this->stream->getNodeUrl();

        return array_filter($nodeUrls, function($url) use ($current) {
            if ($url === $current) {
                return true;
            }

            $parts = parse_url($url);

            try {
                $response = $this->send(['CLUSTER', 'MEET', $parts['host'], (int) $parts['port']]);
                $this->log->debug('CLUSTER MEET', ['host' => $url, 'response' => $response]);
                return 'OK' === $response;
            } catch (Exception $e) {
                $this->log->error($e->getMessage(), array('url' => $url, 'exception' => $e));
                return false;
            }
        });
    }
}