class.ilFileDataForumDraftsRCImplementation.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

use ILIAS\ResourceStorage\Collection\ResourceCollection;
use ILIAS\ResourceStorage\Identification\ResourceIdentification;

class ilFileDataForumDraftsRCImplementation implements ilFileDataForumInterface
{
    public const FORUM_PATH_RCID = 'RCID';
    private \ILIAS\ResourceStorage\Services $irss;
    private \ILIAS\FileUpload\FileUpload $upload;
    private array $collection_cache = [];
    private array $posting_cache = [];
    private ilForumPostingFileStakeholder $stakeholder;

    public function __construct(
        private readonly int $obj_id = 0,
        private int $draft_id = 0
    ) {
        global $DIC;
        $this->irss = $DIC->resourceStorage();
        $this->upload = $DIC->upload();
        $this->stakeholder = new ilForumPostingFileStakeholder();
    }

    private function getCurrentDraft(bool $use_cache = true): ilForumPostDraft
    {
        return $this->getDraftById($this->draft_id, $use_cache);
    }

    private function getDraftById(int $draft_id, bool $use_cache = true): ilForumPostDraft
    {
        if ($use_cache && isset($this->posting_cache[$draft_id])) {
            return $this->posting_cache[$draft_id];
        }

        return $this->posting_cache[$draft_id] = ilForumPostDraft::newInstanceByDraftId($draft_id);
    }

    private function getCurrentCollection(): ResourceCollection
    {
        if (isset($this->collection_cache[$this->draft_id])) {
            return $this->collection_cache[$this->draft_id];
        }

        return $this->collection_cache[$this->draft_id] = $this->irss->collection()->get(
            $this->irss->collection()->id(
                $this->getCurrentDraft()->getRCID()
            )
        );
    }

    private function getResourceIdByHash(string $hash): ?ResourceIdentification
    {
        foreach ($this->getCurrentCollection()->getResourceIdentifications() as $identification) {
            $revision = $this->irss->manage()->getCurrentRevision($identification);
            if ($revision->getTitle() === $hash) {
                return $identification;
            }
        }

        return null;
    }

    public function getObjId(): int
    {
        return $this->obj_id;
    }

    public function getPosId(): int
    {
        return $this->draft_id;
    }

    public function setPosId(int $posting_id): void
    {
        $this->draft_id = $posting_id;
    }

    public function getForumPath(): string
    {
        return self::FORUM_PATH_RCID;
    }

    public function getFilesOfPost(): array
    {
        $files = [];
        foreach ($this->getCurrentCollection()->getResourceIdentifications() as $identification) {
            $revision = $this->irss->manage()->getCurrentRevision($identification);
            $info = $revision->getInformation();
            $files[$revision->getTitle()] = [
                'path' => $this->irss->consume()->stream($identification)->getStream()->getMetadata('uri'),
                'md5' => $revision->getTitle(),
                'name' => $info->getTitle(),
                'size' => $info->getSize(),
                'ctime' => $info->getCreationDate()->format('Y-m-d H:i:s')
            ];
        }

        return $files;
    }

    public function moveFilesOfPost(int $new_frm_id = 0): bool
    {
        // nothing to do here since collections are related to the post
        return true;
    }

    public function ilClone(int $new_obj_id, int $new_posting_id): bool
    {
        $current_collection_id = $this->getCurrentCollection()->getIdentification();
        $new_collection_id = $this->irss->collection()->clone($current_collection_id);
        $new_draft = $this->getDraftById($new_posting_id);
        $new_draft->setRCID($new_collection_id->serialize());
        $new_draft->update();

        return true;
    }

    public function delete(array $posting_ids_to_delete = null): bool
    {
        // Each element of $posting_ids_to_delete represents a "Draft Id", NOT a "Posting Id"
        if ($posting_ids_to_delete === null) {
            return true;
        }

        foreach ($posting_ids_to_delete as $draft_id) {
            $this->irss->collection()->remove(
                $this->irss->collection()->id(
                    $this->getDraftById($draft_id)->getRCID()
                ),
                $this->stakeholder,
                true
            );
        }

        return true;
    }

    public function storeUploadedFiles(): bool
    {
        if (!$this->upload->hasBeenProcessed()) {
            $this->upload->process();
        }
        $collection = $this->getCurrentCollection();

        foreach ($this->upload->getResults() as $result) {
            if (!$result->isOK()) {
                continue;
            }
            $rid = $this->irss->manage()->upload(
                $result,
                $this->stakeholder,
                md5($result->getName())
            );
            $collection->add($rid);
        }
        $this->irss->collection()->store($collection);
        $draft = $this->getCurrentDraft(false);
        $draft->setRCID($collection->getIdentification()->serialize());
        $draft->update();

        return true;
    }

    public function unlinkFile(string $filename): bool
    {
        throw new DomainException('Not implemented');
    }

    public function getFileDataByMD5Filename(string $hashed_filename): ?array
    {
        foreach ($this->getCurrentCollection()->getResourceIdentifications() as $identification) {
            $revision = $this->irss->manage()->getCurrentRevision($identification);
            if ($revision->getTitle() === $hashed_filename) {
                $info = $revision->getInformation();
                return [
                    'path' => '',
                    'filename' => $info->getTitle(),
                    'clean_filename' => $info->getTitle()
                ];
            }
        }

        return null;
    }

    public function unlinkFilesByMD5Filenames($hashed_filename_or_filenames): bool
    {
        $hashes = is_array($hashed_filename_or_filenames)
            ? $hashed_filename_or_filenames
            : [$hashed_filename_or_filenames];

        foreach ($hashes as $hash) {
            $identification = $this->getResourceIdByHash($hash);
            if ($identification !== null) {
                $this->irss->manage()->remove($identification, $this->stakeholder);
            }
        }
        return true;
    }

    public function deliverFile(string $file): void
    {
        $rid = $this->getResourceIdByHash($file);
        if ($rid !== null) {
            $this->irss->consume()->download($rid)->run();
        }
    }

    public function deliverZipFile(): bool
    {
        // https://mantis.ilias.de/view.php?id=39910
        $zip_filename = \ILIAS\FileDelivery\Delivery::returnASCIIFileName(
            $this->getCurrentDraft()->getPostSubject() . '.zip'
        );
        $rcid = $this->getCurrentCollection()->getIdentification();

        $this->irss->consume()->downloadCollection($rcid, $zip_filename)
                   ->useRevisionTitlesForFileNames(false)
                   ->run();

        return true;
    }
}