Pheanstalk\Command\ListTubesCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getAction()	0	3	1
A	getGroup()	0	3	1
A	getResponseParser()	0	3	1
A	parseResponse()	0	16	2

<?php

namespace Pheanstalk\Command;

use Doctrine\Common\Collections\ArrayCollection;
use Pheanstalk\ResponseParser;
use Pheanstalk\Structure\Tube;

/**
 * The 'list-tubes' command.
 *
 * List all existing tubes.
 *
 * @author  Valentin Corre
 * @package Pheanstalk
 * @license http://www.opensource.org/licenses/mit-license.php
 */
class ListTubesCommand extends AbstractCommand implements ResponseParser
{
    /**
     * @inheritDoc
     */
    public function getGroup(): string
    {
        return 'queuepool';
    }

    /**
     * @inheritDoc
     */
    public function getAction(): string
    {
        return 'list';
    }

    /**
     * @inheritDoc
     */
    public function getResponseParser()
    {
        return $this;
    }

    /**
     * @inheritDoc
     */
    public function parseResponse($responseLine, $responseData)
    {
        $responseData = $responseData['queue'];
        $queues = [];
        foreach ($responseData as $queue) {
            $queue = $queue['@attributes'] ?? $queue;
            $queueObject = new Tube($queue['name'], $queue['concurrency']);
            $queueObject
                ->setId($queue['id'])
                ->setDynamic($queue['dynamic'])
                ->setScheduler($queue['scheduler'])
            ;
            $queues[] = $queueObject;
        }

        return new ArrayCollection($queues);
    }
}