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\Value;
 
class ConcatenationJob extends AbstractJob
{
    public function run(array $input, Observer $observer): Value
    {
        $list = $input[0]->getList();
        $values = array_map(
            fn($a) => $a->getValue(),
            $list
        );
 
        $string_value = new StringValue();
        $string_value->setValue(implode(', ', $values));
 
        return $string_value;
    }
 
    public function isStateless(): bool
    {
        return true;
    }
 
    public function getId(): string
    {
        return static::class;
    }
 
    public function getInputTypes(): array
    {
        return [new ListType(ScalarValue::class)];
    }
 
    public function getOutputType(): Type
    {
        return new SingleType(StringValue::class);
    }
 
    public function getExpectedTimeOfTaskInSeconds(): int
    {
        return 1;
    }
}