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