PreProcessorManagerImpl.php

Go to the documentation of this file.

<?php

namespace ILIAS\FileUpload\Processor;

use ILIAS\Filesystem\Stream\FileStream;
use ILIAS\FileUpload\DTO\Metadata;
use ILIAS\FileUpload\DTO\ProcessingStatus;
use Psr\Http\Message\StreamInterface;

final class PreProcessorManagerImpl implements PreProcessorManager
{
    private array $processors = [];

    public function with(PreProcessor $processor): void
    {
        $this->processors[] = $processor;
    }


    public function process(FileStream $stream, Metadata $metadata): ProcessingStatus
    {
        try {
            $result = null;
            foreach ($this->processors as $processor) {
                $stream->rewind();
                $result = $processor->process($stream, $metadata);
                if ($result->getCode() === ProcessingStatus::REJECTED || $result->getCode() === ProcessingStatus::DENIED) {
                    return $result;
                }
            }

            if (is_null($result)) {
                $result = new ProcessingStatus(ProcessingStatus::OK, 'No processors were registered.');
            }

            return $result;
        } catch (\Exception $ex) {
            return new ProcessingStatus(ProcessingStatus::REJECTED, 'Processor failed with exception message "' . $ex->getMessage() . '"');
        }
    }
}