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 $processors = [];
 
    public function with(PreProcessor $processor)
    {
        $this->processors[] = $processor;
    }
 
 
    public function process(FileStream $stream, Metadata $metadata)
    {
        try {
            $result = null;
            foreach ($this->processors as $processor) {
                $stream->rewind();
                $result = $processor->process($stream, $metadata);
                if ($result->getCode() === ProcessingStatus::REJECTED) {
                    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() . '"');
        }
    }
}