Services.php

Go to the documentation of this file.

<?php declare(strict_types=1);
 
namespace ILIAS\MainMenu\Storage;
 
use Generator;
use ILIAS\FileUpload\DTO\UploadResult;
use ILIAS\MainMenu\Storage\Consumer\ConsumerFactory;
use ILIAS\MainMenu\Storage\Consumer\DownloadConsumer;
use ILIAS\MainMenu\Storage\Consumer\FileStreamConsumer;
use ILIAS\MainMenu\Storage\Consumer\InlineConsumer;
use ILIAS\MainMenu\Storage\Identification\ResourceIdentification;
use ILIAS\MainMenu\Storage\Information\Repository\InformationARRepository;
use ILIAS\MainMenu\Storage\Resource\Repository\ResourceARRepository;
use ILIAS\MainMenu\Storage\Resource\ResourceBuilder;
use ILIAS\MainMenu\Storage\Resource\Stakeholder\ResourceStakeholder;
use ILIAS\MainMenu\Storage\Revision\Repository\RevisionARRepository;
use ILIAS\MainMenu\Storage\Revision\Revision;
use ILIAS\MainMenu\Storage\StorageHandler\FileSystemStorageHandler;
use ILIAS\MainMenu\Storage\StorageHandler\StorageHandlerFactory;
use LogicException;
 
class Services
{
 
    private $consumer_factory;
    private $resource_builder;
 
 
    public function __construct()
    {
        $this->resource_builder = new ResourceBuilder(
            new FileSystemStorageHandler(),
            new RevisionARRepository(),
            new ResourceARRepository(),
            new InformationARRepository()
        );
        $this->consumer_factory = new ConsumerFactory(new StorageHandlerFactory());
    }
 
 
    public function upload(UploadResult $result, ResourceStakeholder $stakeholder, string $title = null) : ResourceIdentification
    {
        if ($result->isOK()) {
            $resource = $this->resource_builder->new($result);
 
            $this->resource_builder->store($resource);
 
            return $resource->getIdentification();
        } else {
            throw new LogicException("Can't handle UploadResult: " . $result->getStatus()->getMessage());
        }
    }
 
 
    public function find(string $identification) : ?ResourceIdentification
    {
        $resource_identification = new ResourceIdentification($identification);
 
        if ($this->resource_builder->has($resource_identification)) {
            return $resource_identification;
        }
 
        return null;
    }
 
 
    public function getRevision(ResourceIdentification $identification) : Revision
    {
        return $this->resource_builder->get($identification)->getCurrentRevision();
    }
 
 
    public function remove(ResourceIdentification $identification) : void
    {
        $this->resource_builder->remove($this->resource_builder->get($identification));
    }
 
 
    public function getAll() : Generator
    {
        foreach ($this->resource_builder->getAll() as $item) {
            yield $item->getIdentification();
        }
    }
 
 
    //
    // CONSUMERS
    //
 
    public function download(ResourceIdentification $identification) : DownloadConsumer
    {
        return $this->consumer_factory->download($this->resource_builder->get($identification));
    }
 
 
    public function inline(ResourceIdentification $identification) : InlineConsumer
    {
        return $this->consumer_factory->inline($this->resource_builder->get($identification));
    }
 
 
    public function stream(ResourceIdentification $identification) : FileStreamConsumer
    {
        return $this->consumer_factory->fileStream($this->resource_builder->get($identification));
    }
}