Pheanstalk\Command\KillCommand

Complexity

Total Complexity

6

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getResponseParser()	0	3	1
A	getAction()	0	3	1
A	getGroup()	0	3	1
A	getFilters()	0	9	2

<?php

namespace Pheanstalk\Command;

use Pheanstalk\Exception\ServerException;
use Pheanstalk\Parser\RequestOkResponseParser;
use Pheanstalk\Structure\TaskInstance;
use Pheanstalk\Structure\WorkflowInstance;

/**
 * The 'Kill' command.
 *
 * Kills a running workflow instance
 *
 *
 * @author  Valentin Corre
 * @package Pheanstalk
 * @license http://www.opensource.org/licenses/mit-license.php
 */
class KillCommand extends AbstractCommand
{

    /** @var WorkflowInstance $workflowInstance */
    private $workflowInstance;

    /** @var TaskInstance $taskInstance */
    private $taskInstance;

    /**
     * Kills a running task instance
     *
     * @param WorkflowInstance $workflowInstance     The WorkflowInstance
     */
    public function __construct(WorkflowInstance $workflowInstance, TaskInstance $taskInstance)
    {
        $this->workflowInstance = $workflowInstance;
        $this->taskInstance = $taskInstance;
    }

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

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

    /**
     * @inheritDoc
     */
    public function getFilters(): array
    {
        $pid = $this->taskInstance->getPid();
        if (empty($pid)) {
            throw new ServerException("Pid Should not be empty");
        }
        return [
            'id' => $this->workflowInstance->getId(),
            'pid' => $pid,
        ];
    }

    /**
     * @inheritDoc
     */
    public function getResponseParser()
    {
        return new RequestOkResponseParser();
    }
}