Pheanstalk\Structure\WorkflowInstance

Complexity

Total Complexity

38

Size/Duplication

Total Lines	386
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	11
Bugs	0	Features	0

34 Methods

Rating	Name	Duplication	Size	Complexity
A	getComment()	0	3	1
A	setRetryingTasks()	0	4	1
A	setName()	0	4	1
A	getScheduleId()	0	3	1
A	setHost()	0	4	1
A	getEvqid()	0	3	1
A	setErrors()	0	4	1
A	setEvqid()	0	4	1
A	getRunningTasks()	0	3	1
A	getStartTime()	0	3	1
A	getId()	0	3	1
A	updateStatus()	0	13	5
A	setComment()	0	4	1
A	setJobInstances()	0	4	1
A	getEndTime()	0	3	1
A	removeJobInstance()	0	4	1
A	setNodeName()	0	4	1
A	getErrors()	0	3	1
A	getNodeName()	0	3	1
A	setQueuedTasks()	0	4	1
A	getName()	0	3	1
A	setStartTime()	0	4	1
A	setId()	0	4	1
A	setRunningTasks()	0	4	1
A	getStatus()	0	3	1
A	__construct()	0	5	1
A	setEndTime()	0	4	1
A	getHost()	0	3	1
A	getJobInstances()	0	3	1
A	addJobInstance()	0	4	1
A	setStatus()	0	4	1
A	getRetryingTasks()	0	3	1
A	getQueuedTasks()	0	3	1
A	setScheduleId()	0	4	1

<?php


namespace Pheanstalk\Structure;

use Doctrine\Common\Collections\ArrayCollection;

class WorkflowInstance extends ParameterManipulations
{
    const STATUS_QUEUED = "QUEUED";
    const STATUS_RUNNING = "RUNNING";
    const STATUS_RETRYING = "RETRYING";
    const STATUS_FAILED = "FAILED";

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

    /** @var \DateTime|null $endTime */
    protected $endTime;

    /** @var int|null $errors */
    protected $errors;

    /** @var string|null $host */
    protected $host;

    /** @var int $id */
    protected $id;

    /** @var string $name */
    protected $name;

    /** @var string|null $nodeName */
    protected $nodeName;

    /** @var int|null $scheduleId */
    protected $scheduleId;

    /** @var \DateTime $startTime */
    protected $startTime;

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

    /** @var int|null $evqid */
    protected $evqid;

    /** @var int|null $queuedTasks */
    protected $queuedTasks;

    /** @var int|null $runningTasks */
    protected $runningTasks;

    /** @var int|null $retryingTasks */
    protected $retryingTasks;

    /** @var ArrayCollection */
    protected $jobInstances;

    /**
     * @inheritDoc
     */
    public function __construct(array $params)
    {
        $this->jobInstances = new ArrayCollection([]);
        parent::__construct($params);
        $this->updateStatus();
    }

    /**
     * @return null|string
     */
    public function getComment(): ?string
    {
        return $this->comment;
    }

    /**
     * @param string $comment
     *
     * @return WorkflowInstance
     */
    public function setComment(string $comment): WorkflowInstance
    {
        $this->comment = $comment;
        return $this;
    }

    /**
     * @return null|\DateTime
     */
    public function getEndTime(): ?\DateTime
    {
        return $this->endTime;
    }

    /**
     * @param \DateTime $endTime
     *
     * @return WorkflowInstance
     */
    public function setEndTime(\DateTime $endTime): WorkflowInstance
    {
        $this->endTime = $endTime;
        return $this;
    }

    /**
     * @return null|int
     */
    public function getErrors(): ?int
    {
        return $this->errors ?? 0;
    }

    /**
     * @param null|int $errors
     *
     * @return WorkflowInstance
     */
    public function setErrors(?int $errors): WorkflowInstance
    {
        $this->errors = $errors;
        return $this;
    }

    /**
     * @return null|string
     */
    public function getHost(): ?string
    {
        return $this->host;
    }

    /**
     * @param string $host
     *
     * @return WorkflowInstance
     */
    public function setHost(string $host): WorkflowInstance
    {
        $this->host = $host;
        return $this;
    }

    /**
     * @return int
     */
    public function getId(): int
    {
        return $this->id;
    }

    /**
     * @param int $id
     *
     * @return WorkflowInstance
     */
    public function setId(int $id): WorkflowInstance
    {
        $this->id = $id;
        return $this;
    }

    /**
     * @return string
     */
    public function getName(): string
    {
        return $this->name;
    }

    /**
     * @param string $name
     *
     * @return WorkflowInstance
     */
    public function setName(string $name): WorkflowInstance
    {
        $this->name = $name;
        return $this;
    }

    /**
     * @return null|string
     */
    public function getNodeName(): ?string
    {
        return $this->nodeName;
    }

    /**
     * @param string $nodeName
     *
     * @return WorkflowInstance
     */
    public function setNodeName(string $nodeName): WorkflowInstance
    {
        $this->nodeName = $nodeName;
        return $this;
    }

    /**
     * @return null|int
     */
    public function getScheduleId(): ?int
    {
        return $this->scheduleId;
    }

    /**
     * @param int $scheduleId
     *
     * @return WorkflowInstance
     */
    public function setScheduleId(int $scheduleId): WorkflowInstance
    {
        $this->scheduleId = $scheduleId;
        return $this;
    }

    /**
     * @return \DateTime
     */
    public function getStartTime(): \DateTime
    {
        return $this->startTime;
    }

    /**
     * @param \DateTime $startTime
     *
     * @return WorkflowInstance
     */
    public function setStartTime(\DateTime $startTime): WorkflowInstance
    {
        $this->startTime = $startTime;
        return $this;
    }

    /**
     * @return string
     */
    public function getStatus(): string
    {
        return $this->status;
    }

    /**
     * @return void
     */
    public function updateStatus()
    {
        if ($this->getRunningTasks() > 0) {
            $this->setStatus(self::STATUS_RUNNING);
        }
        if ($this->getQueuedTasks() > 0) {
            $this->setStatus(self::STATUS_QUEUED);
        }
        if ($this->getRetryingTasks() > 0) {
            $this->setStatus(self::STATUS_RETRYING);
        }
        if ($this->getErrors() > 0) {
            $this->setStatus(self::STATUS_FAILED);
        }
    }

    /**
     * @param string $status
     *
     * @return WorkflowInstance
     */
    public function setStatus(string $status): WorkflowInstance
    {
        $this->status = $status;
        return $this;
    }

    /**
     * @return int|null
     */
    public function getEvqid(): ?int
    {
        return $this->evqid;
    }

    /**
     * @param int|null $evqid
     *
     * @return WorkflowInstance
     */
    public function setEvqid(?int $evqid): WorkflowInstance
    {
        $this->evqid = $evqid;
        return $this;
    }

    /**
     * @return int|null
     */
    public function getQueuedTasks(): ?int
    {
        return $this->queuedTasks ?? 0;
    }

    /**
     * @param int|null $queuedTasks
     *
     * @return WorkflowInstance
     */
    public function setQueuedTasks(?int $queuedTasks): WorkflowInstance
    {
        $this->queuedTasks = $queuedTasks;
        return $this;
    }

    /**
     * @return int|null
     */
    public function getRunningTasks(): ?int
    {
        return $this->runningTasks ?? 0;
    }

    /**
     * @param int|null $runningTasks
     *
     * @return WorkflowInstance
     */
    public function setRunningTasks(?int $runningTasks): WorkflowInstance
    {
        $this->runningTasks = $runningTasks;
        return $this;
    }

    /**
     * @return int|null
     */
    public function getRetryingTasks(): ?int
    {
        return $this->retryingTasks ?? 0;
    }

    /**
     * @param int|null $retryingTasks
     *
     * @return WorkflowInstance
     */
    public function setRetryingTasks(?int $retryingTasks): WorkflowInstance
    {
        $this->retryingTasks = $retryingTasks;
        return $this;
    }

    /**
     * @return ArrayCollection
     */
    public function getJobInstances(): ArrayCollection
    {
        return $this->jobInstances;
    }

    /**
     * @param ArrayCollection $jobInstances
     *
     * @return WorkflowInstance
     */
    public function setJobInstances(ArrayCollection $jobInstances): WorkflowInstance
    {
        $this->jobInstances = $jobInstances;
        return $this;
    }

    /**
     * @param JobInstance $jobInstance
     *
     * @return WorkflowInstance
     */
    public function addJobInstance(JobInstance $jobInstance): WorkflowInstance
    {
        $this->jobInstances[] = $jobInstance;
        return $this;
    }

    /**
     * @param JobInstance $jobInstance
     *
     * @return WorkflowInstance
     */
    public function removeJobInstance(JobInstance $jobInstance): WorkflowInstance
    {
        $this->jobInstances->removeElement($jobInstance);
        return $this;
    }
}