Pheanstalk\Command\CreateScheduleCommand

Complexity

Total Complexity

6

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

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

<?php

namespace Pheanstalk\Command;

use Pheanstalk\Exception;
use Pheanstalk\Response;
use Pheanstalk\Structure\TimeSchedule;
use Pheanstalk\Structure\Workflow;
use Pheanstalk\XmlResponseParser;

/**
 * The 'CreateSchedule' command.
 *
 * Inserts a new workflow_schedule into the client.
 *
 *
 * @author  Valentin Corre
 * @package Pheanstalk
 * @license http://www.opensource.org/licenses/mit-license.php
 */
class CreateScheduleCommand extends AbstractCommand implements \Pheanstalk\ResponseParser
{

    const FAILURE_TYPE_CONTINUE = "CONTINUE";
    const FAILURE_TYPE_SUSPEND = "SUSPEND";

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

    private $schedule;

    private $onFailure;

    /** @var bool $active */
    private $active;

    /** @var string|null $comment */
    private $comment;

    /**
     * CreateScheduleCommand constructor.
     *
     * @param Workflow     $workflow
     * @param TimeSchedule $schedule
     * @param string       $onFailure
     * @param bool         $active
     * @param string|null         $comment
     */
    public function __construct(Workflow $workflow, TimeSchedule $schedule, $onFailure = self::FAILURE_TYPE_CONTINUE, $active = true, $comment = null)
    {
        $this->workflow = $workflow;
        $this->schedule = $schedule;
        $this->onFailure = $onFailure ?? self::FAILURE_TYPE_CONTINUE;
        $this->active = $active ?? true;
        $this->comment = $comment ?? $this->workflow->getComment();
    }

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

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

    /**
     * @inheritDoc
     */
    public function getFilters(): array
    {
        return[
            'workflow_id' => $this->workflow->getId(),
            'schedule' => $this->schedule->__toString(),
            "onfailure" => $this->onFailure,
            'active' => $this->active,
            'comment' => $this->comment,
            'node' => "any"
        ];
    }

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

    /**
     * @inheritDoc
     */
    public function parseResponse($responseLine, $responseData)
    {
        return (int) $responseData['@attributes']['schedule-id'];
    }
}