BasicTaskFactory.php

Go to the documentation of this file.

<?php

namespace ILIAS\BackgroundTasks\Implementation\Tasks;

use ILIAS\BackgroundTasks\Dependencies\Injector;
use ILIAS\BackgroundTasks\Exceptions\InvalidArgumentException;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\BasicScalarValueFactory;
use ILIAS\BackgroundTasks\Task;
use ILIAS\BackgroundTasks\Task\TaskFactory;
use ILIAS\BackgroundTasks\Value;

class BasicTaskFactory implements TaskFactory
{
    use BasicScalarValueFactory;

    protected \ILIAS\BackgroundTasks\Dependencies\Injector $injector;

    public function __construct(Injector $injector)
    {
        $this->injector = $injector;
    }

    public function createTask(string $class_name, ?array $input = null): Task
    {
        if (!class_exists($class_name)) {
            return new NotFoundUserInteraction();
        }
        $task = $this->injector->createInstance($class_name);
        if ($input) {
            $wrappedInput = array_map(function ($i): \ILIAS\BackgroundTasks\Value {
                if ($i instanceof Task) {
                    return $i->getOutput();
                }
                if ($i instanceof Value) {
                    return $i;
                }

                return $this->wrapValue($i);
            }, $input);

            $task->setInput($wrappedInput);
        }

        return $task;
    }
}