ConcatenationJob.php

Go to the documentation of this file.

<?php
 
namespace ILIAS\BackgroundTasks\Implementation\Tasks\Aggregation;
 
use ILIAS\BackgroundTasks\Implementation\Tasks\AbstractJob;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\ScalarValue;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\StringValue;
use ILIAS\BackgroundTasks\Observer;
use ILIAS\BackgroundTasks\Types\ListType;
use ILIAS\BackgroundTasks\Types\SingleType;
use ILIAS\BackgroundTasks\Types\Type;
use ILIAS\BackgroundTasks\ValueType;
 
class ConcatenationJob extends AbstractJob
{
 
    public function run(array $input, Observer $observer)
    {
        $list = $input[0]->getList();
        $values = array_map(
            function ($a) {
                return $a->getValue();
            },
            $list
        );
 
        $string_value = new StringValue();
        $string_value->setValue(implode(', ', $values));
 
        return $string_value;
    }
 
 
    public function isStateless()
    {
        return true;
    }
 
 
    public function getId()
    {
        return get_called_class();
    }
 
 
    public function getInputTypes()
    {
        return [new ListType(ScalarValue::class)];
    }
 
 
    public function getOutputType()
    {
        return new SingleType(StringValue::class);
    }
 
 
    public function getExpectedTimeOfTaskInSeconds()
    {
        return 1;
    }
}