Zenstruck\ScheduleBundle\Schedule\ScheduleRunContext

Complexity

Total Complexity

30

Size/Duplication

Total Lines	166
Duplicated Lines	0 %

Test Coverage

Coverage

95.38%

Importance

Changes	1
Bugs	0	Features	1

15 Methods

Rating	Name	Duplication	Size	Complexity
A	isSuccessful()	0	3	2
A	getSkipped()	0	15	4
A	getResults()	0	5	1
A	skipReason()	0	3	1
A	setResults()	0	12	2
A	__toString()	0	3	1
A	dueTasks()	0	3	1
A	__construct()	0	6	2
A	getSuccessful()	0	15	4
A	skip()	0	3	1
A	isFailure()	0	3	1
A	getRun()	0	15	4
A	isSkipped()	0	3	1
A	schedule()	0	3	1
A	getFailures()	0	15	4

<?php

namespace Zenstruck\ScheduleBundle\Schedule;

use Zenstruck\ScheduleBundle\Schedule;
use Zenstruck\ScheduleBundle\Schedule\Exception\SkipSchedule;
use Zenstruck\ScheduleBundle\Schedule\Task\Result;

/**
 * @author Kevin Bond <kevinbond@gmail.com>
 */
final class ScheduleRunContext extends RunContext
{
    private $schedule;
    private $dueTasks;

    private $results;
    private $skipReason;

    private $successful;
    private $failures;
    private $skipped;
    private $run;

    public function __construct(Schedule $schedule, Task ...$forcedTasks)
    {
        $this->schedule = $schedule;
        $this->dueTasks = empty($forcedTasks) ? $schedule->due() : $forcedTasks;

        parent::__construct();
    }

    public function __toString(): string
    {
        return 'The Schedule';
    }

    public function schedule(): Schedule
    {
        return $this->schedule;
    }

    /**
     * @return Task[]
     */
    public function dueTasks(): array
    {
        return $this->dueTasks;
    }

    public function setResults(Result ...$results): void
    {
        $resultCount = \count($results);
        $dueCount = \count($this->dueTasks());

        if ($resultCount !== $dueCount) {
            throw new \LogicException(\sprintf('The number of results (%d) does not match the number of due tasks (%d).', $resultCount, $dueCount));
        }

        $this->markAsRun(\memory_get_peak_usage(true));

        $this->results = $results;
    }

    public function skip(SkipSchedule $exception): void
    {
        $this->skipReason = $exception->getMessage();
    }

    public function skipReason(): ?string
    {
        return $this->skipReason;
    }

    /**
     * @return Result[]
     */
    public function getResults(): array
    {
        $this->ensureHasRun();

        return $this->results;
    }

    public function isSuccessful(): bool
    {
        return $this->isSkipped() || 0 === \count($this->getFailures());
    }

    public function isFailure(): bool
    {
        return !$this->isSuccessful();
    }

    public function isSkipped(): bool
    {
        return null !== $this->skipReason;
    }

    /**
     * @return Result[]
     */
    public function getSuccessful(): array
    {
        if (null !== $this->successful) {
            return $this->successful;
        }

        $this->successful = [];

        foreach ($this->getResults() as $result) {
            if ($result->isSuccessful()) {
                $this->successful[] = $result;
            }
        }

        return $this->successful;
    }

    /**
     * @return Result[]
     */
    public function getFailures(): array
    {
        if (null !== $this->failures) {
            return $this->failures;
        }

        $this->failures = [];

        foreach ($this->getResults() as $result) {
            if ($result->isFailure()) {
                $this->failures[] = $result;
            }
        }

        return $this->failures;
    }

    /**
     * @return Result[]
     */
    public function getSkipped(): array
    {
        if (null !== $this->skipped) {
            return $this->skipped;
        }

        $this->skipped = [];

        foreach ($this->getResults() as $result) {
            if ($result->isSkipped()) {
                $this->skipped[] = $result;
            }
        }

        return $this->skipped;
    }

    /**
     * @return Result[]
     */
    public function getRun(): array
    {
        if (null !== $this->run) {
            return $this->run;
        }

        $this->run = [];

        foreach ($this->getResults() as $result) {
            if ($result->hasRun()) {
                $this->run[] = $result;
            }
        }

        return $this->run;
    }
}