Zenstruck\ScheduleBundle\Schedule\Task\TaskRunContext

Complexity

Total Complexity

9

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	task()	0	3	1
A	setResult()	0	11	2
A	__toString()	0	3	1
A	isFailure()	0	3	1
A	result()	0	5	1
A	scheduleRunContext()	0	3	1
A	isSuccessful()	0	3	1
A	__construct()	0	6	1

<?php

namespace Zenstruck\ScheduleBundle\Schedule\Task;

use Zenstruck\ScheduleBundle\Schedule\RunContext;
use Zenstruck\ScheduleBundle\Schedule\ScheduleRunContext;
use Zenstruck\ScheduleBundle\Schedule\Task;

/**
 * @author Kevin Bond <kevinbond@gmail.com>
 */
final class TaskRunContext extends RunContext
{
    private $scheduleRunContext;
    private $task;

    private $result;

    public function __construct(ScheduleRunContext $scheduleRunContext, Task $task)
    {
        $this->scheduleRunContext = $scheduleRunContext;
        $this->task = $task;

        parent::__construct();
    }

    public function __toString(): string
    {
        return "{$this->task()->getType()}: {$this->task()}";
    }

    public function scheduleRunContext(): ScheduleRunContext
    {
        return $this->scheduleRunContext;
    }

    public function task(): Task
    {
        return $this->task;
    }

    public function result(): Result
    {
        $this->ensureHasRun();

        return $this->result;
    }

    public function setResult(Result $result): void
    {
        $resultTask = $result->getTask();

        if ($resultTask->getId() !== $this->task()->getId()) {
            throw new \LogicException(\sprintf("The result's task (%s: %s) does not match the context's task (%s: %s).", $resultTask->getType(), $resultTask, $this->task()->getType(), $this->task()));
        }

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

        $this->result = $result;
    }

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

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