Jellyfish\Scheduler\Job

Complexity

Total Complexity

8

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	isDue()	0	3	1
A	getCommand()	0	3	1
A	run()	0	13	3
A	getCronExpression()	0	3	1
A	__construct()	0	6	1
A	isRunning()	0	3	1

<?php

declare(strict_types=1);

namespace Jellyfish\Scheduler;

use Cron\CronExpression;
use DateTime;
use Jellyfish\Process\ProcessInterface;

class Job implements JobInterface
{
    /**
     * @var \Jellyfish\Process\ProcessInterface
     */
    protected $process;

    /**
     * @var \Cron\CronExpression
     */
    protected $cronExpression;

    /**
     * @param \Jellyfish\Process\ProcessInterface $process
     * @param \Cron\CronExpression $cronExpression
     */
    public function __construct(
        ProcessInterface $process,
        CronExpression $cronExpression
    ) {
        $this->process = $process;
        $this->cronExpression = $cronExpression;
    }

    /**
     * @return array
     */
    public function getCommand(): array
    {
        return $this->process->getCommand();
    }

    /**
     * @return \Cron\CronExpression
     */
    public function getCronExpression(): CronExpression
    {
        return $this->cronExpression;
    }

    /**
     * @param \DateTime $dateTime
     *
     * @return bool
     */
    protected function isDue(DateTime $dateTime): bool
    {
        return $this->cronExpression->isDue($dateTime);
    }

    /**
     * @param \DateTime|null $dateTime
     *
     * @return \Jellyfish\Scheduler\JobInterface
     *
     * @throws \Exception
     */
    public function run(?DateTime $dateTime = null): JobInterface
    {
        if ($dateTime === null) {
            $dateTime = new DateTime();
        }

        if (!$this->isDue($dateTime)) {
            return $this;
        }

        $this->process->start();

        return $this;
    }

    /**
     * @return bool
     */
    public function isRunning(): bool
    {
        return $this->process->isRunning();
    }
}