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