FileDataRCHandling.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
use ILIAS\Filesystem\Stream\Streams;
use ILIAS\ResourceStorage\Identification\ResourceCollectionIdentification;
use ILIAS\ResourceStorage\Collection\ResourceCollection;
 
trait FileDataRCHandling
{
    protected function getCurrentCollection(
        array $path_to_files,
        ilMailAttachmentStakeholder $stakeholder
    ): \ILIAS\ResourceStorage\Collection\ResourceCollection {
        set_error_handler(static function ($severity, $message, $file, $line): void {
            throw new ErrorException($message, $severity, 0, $file, $line);
        });
 
        try {
            global $DIC;
            $file_system = $DIC->filesystem()->storage();
            $rcid = $this->storage->collection()->id();
            $collection = $this->storage->collection()->get($rcid);
            foreach ($path_to_files as $path_to_file) {
                $base_dir = (new \ILIAS\FileDelivery\Setup\BaseDirObjective())::get();
                $path_to_file = str_replace($base_dir, '/', $path_to_file);
                $rid = $this->storage->manage()->stream(
                    $file_system->readStream($path_to_file),
                    $stakeholder,
                    md5(basename($path_to_file))
                );
                $collection->add($rid);
            }
            $this->storage->collection()->store($collection);
        } catch (Exception $e) {
            throw new Exception("Storing file into collection failed: " . $e->getMessage());
        } finally {
            restore_error_handler();
        }
 
        return $collection;
    }
 
    public function filesFromLegacyToIRSS(array $mail_data): array
    {
        $files = [];
        $path_to_files = [];
        foreach ($mail_data['attachments'] as $file) {
            $path_to_files[] = $this->fdm->getAbsoluteAttachmentPoolPathByFilename($file);
        }
        $collection = $this->getCurrentCollection($path_to_files, new ilMailAttachmentStakeholder());
        foreach ($collection->getResourceIdentifications() as $rcid) {
            $files[] = $rcid->serialize();
        }
 
        return $files;
    }
 
    public function getIdforCollection(array $mail_data): ?ResourceCollectionIdentification
    {
        $files = [];
        $path_to_files = [];
        foreach ($mail_data as $attachment) {
            $path_to_files[] = $this->fdm->getAbsoluteAttachmentPoolPathByFilename($attachment);
        }
        $collection = $this->getCurrentCollection($path_to_files, new ilMailAttachmentStakeholder());
        $rcid = $collection->getIdentification();
 
        return $rcid;
    }
 
    public function FilesFromIRSSToLegacy(ResourceCollectionIdentification $identification): array
    {
        $files = [];
        $collection = $this->storage->collection()->get($identification);
        $all_ids = $collection->getResourceIdentifications();
        foreach ($all_ids as $id) {
            $files[] = $id->serialize();
        }
 
        return $files;
    }
 
    protected function handleAttachments(array $attachments): array
    {
        $files = [];
        foreach ($attachments as $attachment) {
            $info = $this->upload_handler->getInfoResult($attachment);
            if ($info->getFileIdentifier() !== 'unknown') {
                $src = $this->upload_handler->getStreamConsumer($attachment);
                $stored = $this->fdm->storeAsAttachment(
                    $info->getName(),
                    (string) $src->getStream()
                );
                if ($stored === false) {
                    throw new Exception("File '" . $info->getName() . "' could not be stored");
                }
                $files[] = ilFileUtils::_sanitizeFilemame($info->getName());
                $this->upload_handler->removeFileForIdentifier($attachment);
            }
        }
 
        return $files;
    }
}