Predis::execute() - Code Metrics - Inspection of "Add support for QSTAT command (#40)" - mariano/disque-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( c0fcd4...3f6cab )

by Mariano

created 2017-03-07 13:57 UTC

Predis::execute() A

↳ Parent: Predis

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	10
ccs	6
cts	6
cp	1
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	6
nc	2
nop	1
crap	2

<?php
namespace Disque\Connection;

use Disque\Command\CommandInterface;
use Predis\Client as PredisClient;

class Predis extends BaseConnection implements ConnectionInterface
{
    /**
     * Client
     *
     * @var \Predis\Client
     */
    protected $client;

    /**
     * @inheritdoc
     */
    public function connect($connectionTimeout = null, $responseTimeout = null)

    {
        parent::connect($connectionTimeout, $responseTimeout);

        $this->client = $this->buildClient($this->host, $this->port);
        $this->client->connect();
    }

    /**
     * @inheritdoc
     */
    public function disconnect()
    {
        if (!$this->isConnected()) {
            return;
        }
        $this->client->disconnect();
        $this->client = null;
    }

    /**
     * @inheritdoc
     */
    public function isConnected()
    {
        return (isset($this->client) && $this->client->isConnected());
    }

    /**
     * @inheritdoc
     */
    public function execute(CommandInterface $command)
    {
        if (!$this->isConnected()) {
            throw new ConnectionException('No connection established');
        }
        return $this->client->executeRaw(array_merge(
            [$command->getCommand()],
            $command->getArguments()
        ));
    }

    /**
     * Build Predis client
     *
     * @param string $host Host
     * @param int $port Port
     * @return Predis\Client Client
     */
    protected function buildClient($host, $port)
    {
        return new PredisClient(['scheme' => 'tcp'] + compact('host', 'port'));
    }
}


1		<?php
2		namespace Disque\Connection;
3
4		use Disque\Command\CommandInterface;
5		use Predis\Client as PredisClient;
6
7		class Predis extends BaseConnection implements ConnectionInterface
8		{
9		/**
10		* Client
11		*
12		* @var \Predis\Client
13		*/
14		protected $client;
15
16		/**
17		* @inheritdoc
18		*/
19	1	public function connect($connectionTimeout = null, $responseTimeout = null)
20
21		{
22	1	parent::connect($connectionTimeout, $responseTimeout);
23
24	1	$this->client = $this->buildClient($this->host, $this->port);
25	1	$this->client->connect();
26	1	}
27
28		/**
29		* @inheritdoc
30		*/
31	8	public function disconnect()
32		{
33	8	if (!$this->isConnected()) {
34	8	return;
35		}
36	1	$this->client->disconnect();
37	1	$this->client = null;
38	1	}
39
40		/**
41		* @inheritdoc
42		*/
43	8	public function isConnected()
44		{
45	8	return (isset($this->client) && $this->client->isConnected());
46		}
47
48		/**
49		* @inheritdoc
50		*/
51	3	public function execute(CommandInterface $command)
52		{
53	3	if (!$this->isConnected()) {
54	1	throw new ConnectionException('No connection established');
55		}
56	2	return $this->client->executeRaw(array_merge(
57	2	[$command->getCommand()],
58	2	$command->getArguments()
59		));
60		}
61
62		/**
63		* Build Predis client
64		*
65		* @param string $host Host
66		* @param int $port Port
67		* @return Predis\Client Client
68		*/
69		protected function buildClient($host, $port)
70		{
71		return new PredisClient(['scheme' => 'tcp'] + compact('host', 'port'));
72		}
73		}
74

mariano / disque-php

Push — master ( c0fcd4...3f6cab )

Predis::execute() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like