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