ListTubesCommand::getResponseParser()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 3
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 2
CRAP Score 1

Importance

Changes 1
Bugs 0 Features 0
Metric Value
eloc 1
c 1
b 0
f 0
dl 0
loc 3
ccs 2
cts 2
cp 1
rs 10
cc 1
nc 1
nop 0
crap 1
1
<?php
2
3
namespace Pheanstalk\Command;
4
5
use Doctrine\Common\Collections\ArrayCollection;
6
use Pheanstalk\ResponseParser;
7
use Pheanstalk\Structure\Tube;
8
9
/**
10
 * The 'list-tubes' command.
11
 *
12
 * List all existing tubes.
13
 *
14
 * @author  Valentin Corre
15
 * @package Pheanstalk
16
 * @license http://www.opensource.org/licenses/mit-license.php
17
 */
18
class ListTubesCommand extends AbstractCommand implements ResponseParser
19
{
20
    /**
21
     * @inheritDoc
22
     */
23 10
    public function getGroup(): string
24
    {
25 10
        return 'queuepool';
26
    }
27
28
    /**
29
     * @inheritDoc
30
     */
31 10
    public function getAction(): string
32
    {
33 10
        return 'list';
34
    }
35
36
    /**
37
     * @inheritDoc
38
     */
39 1
    public function getResponseParser()
40
    {
41 1
        return $this;
42
    }
43
44
    /**
45
     * @inheritDoc
46
     */
47 10
    public function parseResponse($responseLine, $responseData)
48
    {
49 10
        $responseData = $responseData['queue'];
50 10
        $queues = [];
51 10
        foreach ($responseData as $queue) {
52 10
            $queue = $queue['@attributes'] ?? $queue;
53 10
            $queueObject = new Tube($queue['name'], $queue['concurrency']);
54
            $queueObject
55 10
                ->setId($queue['id'])
56 10
                ->setDynamic($queue['dynamic'])
57 10
                ->setScheduler($queue['scheduler'])
58
            ;
59 10
            $queues[] = $queueObject;
60
        }
61
62 10
        return new ArrayCollection($queues);
63
    }
64
}
65