BasicTaskFactory.php

Go to the documentation of this file.

<?php
 
namespace ILIAS\BackgroundTasks\Implementation\Tasks;
 
use ILIAS\BackgroundTasks\Exceptions\InvalidArgumentException;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\BasicScalarValueFactory;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\ScalarValueFactory;
use ILIAS\BackgroundTasks\Task;
use ILIAS\BackgroundTasks\Task\TaskFactory;
use ILIAS\BackgroundTasks\Value;
use ILIAS\BackgroundTasks\Dependencies\Injector;
 
class BasicTaskFactory implements TaskFactory
{
    use BasicScalarValueFactory;
    protected $injector;
 
 
    public function __construct(Injector $injector)
    {
        $this->injector = $injector;
    }
 
 
    public function createTask($class_name, $input = null)
    {
        $task = $this->injector->createInstance($class_name);
        if (!$task instanceof Task) {
            throw new InvalidArgumentException("The given classname $class_name is not a task.");
        }
        if ($input) {
            $wrappedInput = array_map(function ($i) {
                if ($i instanceof Task) {
                    return $i->getOutput();
                }
                if ($i instanceof Value) {
                    return $i;
                }
 
                return $this->wrapValue($i);
            }, $input);
 
            $task->setInput($wrappedInput);
        }
 
        return $task;
    }
}