Queue::call() - Code Metrics - Inspection of "Add Queue::call()" - tarantool-php/queue - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 848ba6...466d1c )

by Eugene

created 2018-02-05 16:06 UTC

Queue::call() A

↳ Parent: Queue

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

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

<?php

/*
 * This file is part of the Tarantool Queue package.
 *
 * (c) Eugene Leonovich <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Tarantool\Queue;

use Tarantool\Client\Client;

class Queue
{
    private $client;
    private $name;

    /**
     * @param \Tarantool|\Tarantool\Client\Client $client
     * @param string $name
     *
     * @throws \InvalidArgumentException
     */
    public function __construct($client, $name)
    {
        if ($client instanceof Client) {
            $client = new ClientAdapter($client);
        } else if (!$client instanceof \Tarantool) {
if ($x instanceof DoesNotExist) {
    // Do something.
}
            throw new \InvalidArgumentException(sprintf(
                '%s() expects parameter 1 to be Tarantool or Tarantool\Client\Client, %s given.',
                __METHOD__, is_object($client) ? get_class($client) : gettype($client)
            ));
        }

        $this->client = $client;
        $this->name = $name;
    }

    /**
     * @return string
     */
    public function getName()
    {
        return $this->name;
    }

    /**
     * @param mixed $data
     * @param array $options
     *
     * @return Task
     */
    public function put($data, array $options = [])

    {
        $args = $options ? [$data, $options] : [$data];
        $result = $this->client->call("queue.tube.$this->name:put", $args);

        return Task::createFromTuple($result[0]);
    }

    /**
     * @param int|float|null $timeout
     *
     * @return Task|null
     */
    public function take($timeout = null)
    {
        $args = null === $timeout ? [] : [$timeout];
        $result = $this->client->call("queue.tube.$this->name:take", $args);

        return empty($result[0]) ? null : Task::createFromTuple($result[0]);
    }

    /**
     * @param int $taskId
     * @param int|float $increment
     *
     * @return Task|null
     */
    public function touch($taskId, $increment)
    {
        $result = $this->client->call("queue.tube.$this->name:touch", [$taskId, $increment]);

        return empty($result[0]) ? null : Task::createFromTuple($result[0]);
    }

    /**
     * @param int $taskId
     *
     * @return Task
     */
    public function ack($taskId)
    {
        $result = $this->client->call("queue.tube.$this->name:ack", [$taskId]);

        return Task::createFromTuple($result[0]);
    }

    /**
     * @param int $taskId
     * @param array $options
     *
     * @return Task
     */
    public function release($taskId, array $options = [])

    {
        $args = $options ? [$taskId, $options] : [$taskId];
        $result = $this->client->call("queue.tube.$this->name:release", $args);

        return Task::createFromTuple($result[0]);
    }

    /**
     * @param int $taskId
     *
     * @return Task
     */
    public function peek($taskId)
    {
        $result = $this->client->call("queue.tube.$this->name:peek", [$taskId]);

        return Task::createFromTuple($result[0]);
    }

    /**
     * @param int $taskId
     *
     * @return Task
     */
    public function bury($taskId)
    {
        $result = $this->client->call("queue.tube.$this->name:bury", [$taskId]);

        return Task::createFromTuple($result[0]);
    }

    /**
     * @param int $count
     *
     * @return int
     */
    public function kick($count)
    {
        $result = $this->client->call("queue.tube.$this->name:kick", [$count]);

        return $result[0][0];
    }

    /**
     * @param int $taskId
     *
     * @return Task
     */
    public function delete($taskId)
    {
        $result = $this->client->call("queue.tube.$this->name:delete", [$taskId]);

        return Task::createFromTuple($result[0]);
    }

    public function truncate()
    {
        $this->client->call("queue.tube.$this->name:truncate");
    }

    /**
     * @param string|null $path
     *
     * @return array|int
     *
     * @throws \InvalidArgumentException
     */
    public function stats($path = null)
    {
        $result = $this->client->call('queue.stats', [$this->name]);

        if (null === $path) {
            return $result[0][0];
        }

        $result = $result[0][0];
        foreach (explode('.', $path) as $key) {
            if (!isset($result[$key])) {
                throw new \InvalidArgumentException(sprintf('Invalid path "%s".', $path));
            }
            $result = $result[$key];
        }

        return $result;
    }

    /**
     * @param string $method
     * @param array $args
     *
     * @return array
     */
    public function call($method, array $args = [])
    {
        return $this->client->call("queue.tube.$this->name:$method", $args);
    }
}


Push — master ( 848ba6...466d1c )

Queue::call() A

Complexity

Size

Duplication

Code Coverage

Importance

1. Missing dependencies

2. Missing use statement

1			<?php
2
3			/*
4			* This file is part of the Tarantool Queue package.
5			*
6			* (c) Eugene Leonovich <[email protected]>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			namespace Tarantool\Queue;
13
14			use Tarantool\Client\Client;
15
16			class Queue
17			{
18			private $client;
19			private $name;
20
21			/**
22			* @param \Tarantool\|\Tarantool\Client\Client $client
23			* @param string $name
24			*
25			* @throws \InvalidArgumentException
26			*/
27	173		public function __construct($client, $name)
28			{
29	173		if ($client instanceof Client) {
30	171		$client = new ClientAdapter($client);
31	2		} else if (!$client instanceof \Tarantool) {
			0 ignored issues – show Bug introduced 2017-04-02 21:08 UTC by Report Bug Copy Issue Report The class `Tarantool` does not exist. Did you forget a USE statement, or did you not list all dependencies? This error could be the result of: 1. Missing dependencies PHP Analyzer uses your `composer.json` file (if available) to determine the dependencies of your project and to determine all the available classes and functions. It expects the `composer.json` to be in the root folder of your repository. Are you sure this class is defined by one of your dependencies, or did you maybe not list a dependency in either the `require` or `require-dev` section? 2. Missing use statement PHP does not complain about undefined classes in `ìnstanceof` checks. For example, the following PHP code will work perfectly fine: if ($x instanceof DoesNotExist) { // Do something. } If you have not tested against this specific condition, such errors might go unnoticed. Loading history...
32	2		throw new \InvalidArgumentException(sprintf(
33	2		'%s() expects parameter 1 to be Tarantool or Tarantool\Client\Client, %s given.',
34	2		__METHOD__, is_object($client) ? get_class($client) : gettype($client)
35			));
36			}
37
38	171		$this->client = $client;
39	171		$this->name = $name;
40	171		}
41
42			/**
43			* @return string
44			*/
45	1		public function getName()
46			{
47	1		return $this->name;
48			}
49
50			/**
51			* @param mixed $data
52			* @param array $options
53			*
54			* @return Task
55			*/
56	32	View Code Duplication	public function put($data, array $options = [])
			0 ignored issues – show Duplication introduced 2017-12-01 10:48 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
57			{
58	32		$args = $options ? [$data, $options] : [$data];
59	32		$result = $this->client->call("queue.tube.$this->name:put", $args);
60
61	32		return Task::createFromTuple($result[0]);
62			}
63
64			/**
65			* @param int\|float\|null $timeout
66			*
67			* @return Task\|null
68			*/
69	24		public function take($timeout = null)
70			{
71	24		$args = null === $timeout ? [] : [$timeout];
72	24		$result = $this->client->call("queue.tube.$this->name:take", $args);
73
74	24		return empty($result[0]) ? null : Task::createFromTuple($result[0]);
75			}
76
77			/**
78			* @param int $taskId
79			* @param int\|float $increment
80			*
81			* @return Task\|null
82			*/
83	6		public function touch($taskId, $increment)
84			{
85	6		$result = $this->client->call("queue.tube.$this->name:touch", [$taskId, $increment]);
86
87	6		return empty($result[0]) ? null : Task::createFromTuple($result[0]);
88			}
89
90			/**
91			* @param int $taskId
92			*
93			* @return Task
94			*/
95	8		public function ack($taskId)
96			{
97	8		$result = $this->client->call("queue.tube.$this->name:ack", [$taskId]);
98
99	4		return Task::createFromTuple($result[0]);
100			}
101
102			/**
103			* @param int $taskId
104			* @param array $options
105			*
106			* @return Task
107			*/
108	12	View Code Duplication	public function release($taskId, array $options = [])
			0 ignored issues – show Duplication introduced 2017-12-01 10:48 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
109			{
110	12		$args = $options ? [$taskId, $options] : [$taskId];
111	12		$result = $this->client->call("queue.tube.$this->name:release", $args);
112
113	8		return Task::createFromTuple($result[0]);
114			}
115
116			/**
117			* @param int $taskId
118			*
119			* @return Task
120			*/
121	12		public function peek($taskId)
122			{
123	12		$result = $this->client->call("queue.tube.$this->name:peek", [$taskId]);
124
125	8		return Task::createFromTuple($result[0]);
126			}
127
128			/**
129			* @param int $taskId
130			*
131			* @return Task
132			*/
133	8		public function bury($taskId)
134			{
135	8		$result = $this->client->call("queue.tube.$this->name:bury", [$taskId]);
136
137	4		return Task::createFromTuple($result[0]);
138			}
139
140			/**
141			* @param int $count
142			*
143			* @return int
144			*/
145	12		public function kick($count)
146			{
147	12		$result = $this->client->call("queue.tube.$this->name:kick", [$count]);
148
149	8		return $result[0][0];
150			}
151
152			/**
153			* @param int $taskId
154			*
155			* @return Task
156			*/
157	10		public function delete($taskId)
158			{
159	10		$result = $this->client->call("queue.tube.$this->name:delete", [$taskId]);
160
161	6		return Task::createFromTuple($result[0]);
162			}
163
164	8		public function truncate()
165			{
166	8		$this->client->call("queue.tube.$this->name:truncate");
167	8		}
168
169			/**
170			* @param string\|null $path
171			*
172			* @return array\|int
173			*
174			* @throws \InvalidArgumentException
175			*/
176	58		public function stats($path = null)
177			{
178	58		$result = $this->client->call('queue.stats', [$this->name]);
179
180	58		if (null === $path) {
181	8		return $result[0][0];
182			}
183
184	50		$result = $result[0][0];
185	50		foreach (explode('.', $path) as $key) {
186	50		if (!isset($result[$key])) {
187	36		throw new \InvalidArgumentException(sprintf('Invalid path "%s".', $path));
188			}
189	30		$result = $result[$key];
190			}
191
192	14		return $result;
193			}
194
195			/**
196			* @param string $method
197			* @param array $args
198			*
199			* @return array
200			*/
201	4		public function call($method, array $args = [])
202			{
203	4		return $this->client->call("queue.tube.$this->name:$method", $args);
204			}
205			}
206

tarantool-php / queue

Push — master ( 848ba6...466d1c )

Queue::call() A

Complexity

Size

Duplication

Code Coverage

Importance

1. Missing dependencies

2. Missing use statement

Duplication Side-by-Side

Filter issues like