Pheanstalk\Command\GetWorkflowInstancesDetailCommand

Complexity

Total Complexity

12

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Test Coverage

Coverage

93.1%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getGroup()	0	3	1
A	getFilters()	0	7	1
A	__construct()	0	4	1
A	getResponseParser()	0	3	1
B	parseResponse()	0	29	7
A	getAction()	0	3	1

<?php

namespace Pheanstalk\Command;

use Doctrine\Common\Collections\ArrayCollection;
use Pheanstalk\Structure\JobInstance;
use Pheanstalk\Structure\TaskInstance;
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 GetWorkflowInstancesDetailCommand extends GetWorkflowInstancesCommand
{
    /** @var WorkflowInstance $workflowInstance */
    private $workflowInstance;

    /**
     * GetWorkflowCommand constructor.
     *
     * @param Workflow $workflow
     */
    public function __construct(WorkflowInstance $workflowInstance)
    {
//        dump($workflowInstance);
        $this->workflowInstance = $workflowInstance;
    }

    /**
     * @inheritDoc
     */
    public function getGroup(): string
    {
        return 'instance';
    }

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

    /**
     * @inheritDoc
     */
    public function getFilters(): array
    {
        $filters = [
            'id' => $this->workflowInstance->getId(),
        ];

        return $filters;
    }

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

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

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

        $subjobs = $responseData['workflow']['subjobs'];
        $jobInstances = new ArrayCollection([]);
        foreach ($subjobs as $subjob) {
            $taskInstances = new ArrayCollection([]);
            foreach ($subjob['tasks'] as $tasks) {
                $task = $tasks['@attributes'];

                if (isset($task['execution_time'])) {
                    $task['execution_time'] = new \DateTime($task['execution_time']);
                }
                foreach ($task as $key => $val) {
                    if (ctype_digit($val)) {
                        $task[$key] = (int) $task[$key];
                    }
                }
                $taskInstances[] = new TaskInstance($task);
            }
            $jobInstances[] = new JobInstance($taskInstances);
        }
        $this->workflowInstance->setJobInstances($jobInstances);

        return $this->workflowInstance;
    }
}