Zenstruck\ScheduleBundle\Tests\Fixture\MockScheduleBuilder

Complexity

Total Complexity

12

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	3	1
A	getRunner()	0	13	2
A	addHandler()	0	5	1
A	addTask()	0	5	1
A	addRunner()	0	5	1
A	addExtension()	0	5	1
A	addSubscriber()	0	5	1
A	addBuilder()	0	5	1
A	buildSchedule()	0	8	3

<?php

namespace Zenstruck\ScheduleBundle\Tests\Fixture;

use Symfony\Component\EventDispatcher\EventDispatcher;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Zenstruck\ScheduleBundle\Event\AfterScheduleEvent;
use Zenstruck\ScheduleBundle\EventListener\ScheduleBuilderSubscriber;
use Zenstruck\ScheduleBundle\Schedule;
use Zenstruck\ScheduleBundle\Schedule\Extension;
use Zenstruck\ScheduleBundle\Schedule\Extension\ExtensionHandler;
use Zenstruck\ScheduleBundle\Schedule\Extension\ExtensionHandlerRegistry;
use Zenstruck\ScheduleBundle\Schedule\Extension\Handler\SelfHandlingHandler;
use Zenstruck\ScheduleBundle\Schedule\ScheduleBuilder;
use Zenstruck\ScheduleBundle\Schedule\ScheduleRunner;
use Zenstruck\ScheduleBundle\Schedule\Task;
use Zenstruck\ScheduleBundle\Schedule\Task\Runner\SelfRunningTaskRunner;
use Zenstruck\ScheduleBundle\Schedule\Task\TaskRunner;

/**
 * @author Kevin Bond <kevinbond@gmail.com>
 */
final class MockScheduleBuilder implements ScheduleBuilder
{
    private $tasks = [];
    private $extensions = [];
    private $runners = [];
    private $subscribers = [];
    private $handlers = [];
    private $builders = [];

    public function addTask(Task $task): self
    {
        $this->tasks[] = $task;

        return $this;
    }

    public function addExtension(Extension $extension): self
    {
        $this->extensions[] = $extension;

        return $this;
    }

    public function addRunner(TaskRunner $runner): self
    {
        $this->runners[] = $runner;

        return $this;
    }

    public function addSubscriber(EventSubscriberInterface $subscriber): self
    {
        $this->subscribers[] = $subscriber;

        return $this;
    }

    public function addHandler(ExtensionHandler $handler): self
    {
        $this->handlers[] = $handler;

        return $this;
    }

    public function addBuilder(ScheduleBuilder $builder): self
    {
        $this->builders[] = $builder;

        return $this;
    }

    public function run(): AfterScheduleEvent
    {
        return $this->getRunner()();
    }

    public function getRunner(): ScheduleRunner
    {
        $dispatcher = new EventDispatcher();
        $dispatcher->addSubscriber(new ScheduleBuilderSubscriber(\array_merge($this->builders, [$this])));

        foreach ($this->subscribers as $subscriber) {
            $dispatcher->addSubscriber($subscriber);
        }

        $handlers = $this->handlers;
        $handlers[] = new SelfHandlingHandler();

        return new ScheduleRunner(\array_merge($this->runners, [new SelfRunningTaskRunner()]), new ExtensionHandlerRegistry($handlers), $dispatcher);
    }

    public function buildSchedule(Schedule $schedule): void
    {
        foreach ($this->tasks as $task) {
            $schedule->add($task);
        }

        foreach ($this->extensions as $extension) {
            $schedule->addExtension($extension);
        }
    }
}