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;
    }
}