Pheanstalk\Command\GetWorkflowInstancesCommand

Complexity

Total Complexity

17

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getResponseParser()	0	3	1
B	parseResponse()	0	30	9
A	__construct()	0	5	1
A	getGroup()	0	3	2
A	getFilters()	0	15	2
A	getAction()	0	3	2

<?php

namespace Pheanstalk\Command;

use Doctrine\Common\Collections\ArrayCollection;
use Pheanstalk\Structure\Workflow;
use Pheanstalk\Structure\WorkflowInstance;

/**
 * The 'GetWorkflow' command.
 *
 * Retrieve a workflow by its id, if there is no workflow for the id given in the construct, returns false
 *
 * @author  Valentin Corre
 * @package Pheanstalk
 * @license http://www.opensource.org/licenses/mit-license.php
 */
class GetWorkflowInstancesCommand extends AbstractCommand implements \Pheanstalk\ResponseParser
{

    const FILTER_EXECUTING = 'EXECUTING';
    const FILTER_TERMINATED = 'TERMINATED';

    const FILTERS = [
        self::FILTER_EXECUTING,
        self::FILTER_TERMINATED
    ];

    /** @var Workflow $workflow */
    private $workflow;

    /** @var string $status */
    private $status;

    /** @var int $page */
    private $page;

    /**
     * GetWorkflowCommand constructor.
     *
     * @param Workflow $workflow
     */
    public function __construct(?Workflow $workflow, $status = self::FILTER_EXECUTING, int $page = 1)
    {
        $this->workflow = $workflow;
        $this->status = $status;
        $this->page = $page;
    }

    /**
     * @inheritDoc
     */
    public function getGroup(): string
    {
        return ($this->status === self::FILTER_EXECUTING) ? 'status' : 'instances';
    }

    /**
     * @inheritDoc
     */
    public function getAction(): string
    {
        return ($this->status === self::FILTER_EXECUTING) ? 'query' : 'list';
    }

    /**
     * @inheritDoc
     */
    public function getFilters(): array
    {
        $limit = 30;
        $offset = ($this->page - 1) * $limit;
        $filters = [
            'type' => "workflows",
            'filter_status' => $this->status,
            'offset' => $offset,
            'limit' => $limit
        ];
        if (!empty($this->workflow)) {
            $filters['filter_workflow'] = $this->workflow->getName();
        }

        return $filters;
    }

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

    /**
     * @inheritDoc
     */
    public function parseResponse($responseLine, $responseData)
    {

        if (!(isset($responseData['workflow']))) {
            return new ArrayCollection([]);
        }

        $instances = $responseData['workflow'];
        $instances = isset($instances['tags']) ? [$instances['@attributes']] : $instances;
        $workflowInstances = new ArrayCollection([]);
        foreach ($instances as $instance) {
            $instance = $instance['@attributes'] ?? $instance;
            if (isset($instance['start_time'])) {
                $instance['start_time'] = new \DateTime($instance['start_time']);
            }
            if (isset($instance['end_time'])) {
                $instance['end_time'] = new \DateTime($instance['end_time']);
            }
            foreach ($instance as $key => $val) {
                if (ctype_digit($val)) {
                    $instance[$key] = (int) $instance[$key];
                }
            }
            $workflowInstances[] = new WorkflowInstance($instance);
        }
        $collection['rows'] = (int) (isset($responseData['@attributes']['rows'])) ?

$collection was never initialized. Although not strictly required by PHP, it is generally a good practice to add $collection = array(); before regardless.

            (int) $responseData['@attributes']['rows'] : $workflowInstances->count();
        $collection['page'] = $this->page;
        $collection['workflow_instances'] = $workflowInstances;
        return new ArrayCollection($collection);
    }
}