MediaObjectRepository.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
namespace ILIAS\MediaObjects;
 
use ilDBInterface;
use ILIAS\Repository\IRSS\IRSSWrapper;
use ILIAS\FileUpload\DTO\UploadResult;
use ILIAS\Filesystem\Stream\ZIPStream;
use ILIAS\Filesystem\Stream\FileStream;
use ILIAS\ResourceStorage\Resource\StorableResource;
use ILIAS\ResourceStorage\Identification\ResourceIdentification;
 
class MediaObjectRepository
{
    public function __construct(
        protected ilDBInterface $db,
        protected IRSSWrapper $irss
    ) {
    }
 
    public function create(
        int $id,
        string $title,
        \ilMobStakeholder $stakeholder,
        int $from_mob_id = 0
    ): void {
        $rid = "";
        if ($from_mob_id > 0) {
            $from_rid = $this->getRidForMobId($from_mob_id);
            if ($from_rid !== "") {
                $rid = $this->irss->cloneContainer($from_rid);
            }
        }
        if ($rid === "") {
            $rid = $this->irss->createContainer(
                $stakeholder,
                "mob.zip"
            );
        }
        $this->db->insert('mob_data', [
            'id' => ['integer', $id],
            'rid' => ['text', $rid],
            'last_change' => ['integer', time()]
        ]);
    }
 
    public function getById(int $id): ?array
    {
        $set = $this->db->queryF(
            'SELECT * FROM mob_data WHERE id = %s',
            ['integer'],
            [$id]
        );
 
        $record = $this->db->fetchAssoc($set);
        if ($record) {
            return [
                'id' => (int) $record['id'],
                'rid' => (string) $record['rid'],
                'last_change' => (int) $record['last_change']
            ];
        }
 
        return null;
    }
 
    public function delete(int $id): void
    {
        $this->db->manipulateF(
            'DELETE FROM mob_data WHERE id = %s',
            ['integer'],
            [$id]
        );
    }
 
    protected function getRidForMobId(int $mob_id): string
    {
        $set = $this->db->queryF(
            "SELECT * FROM mob_data " .
            " WHERE id = %s ",
            ["integer"],
            [$mob_id]
        );
        if ($rec = $this->db->fetchAssoc($set)) {
            return $rec["rid"] ?? "";
        }
        return "";
    }
 
    public function getLastChangeTimestamp(int $mob_id): int
    {
        $set = $this->db->queryF(
            "SELECT last_change FROM mob_data " .
            " WHERE id = %s ",
            ["integer"],
            [$mob_id]
        );
        if ($rec = $this->db->fetchAssoc($set)) {
            return (int) ($rec["last_change"] ?? 0);
        }
        return 0;
    }
 
    public function updateLastChangeTimestamp(int $mob_id, int $timestamp): void
    {
        $this->db->update(
            'mob_data',
            ['last_change' => ['integer', $timestamp]],
            ['id' => ['integer', $mob_id]]
        );
    }
 
    public function addFileFromLegacyUpload(int $mob_id, string $tmp_name, string $target_path = ""): void
    {
        if ($rid = $this->getRidForMobId($mob_id)) {
            if ($target_path === "") {
                $target_path = "/";
            }
            $this->irss->importFileFromLegacyUploadToContainer(
                $rid,
                $tmp_name,
                $target_path
            );
        }
    }
 
    public function addFileFromUpload(
        int $mob_id,
        UploadResult $result,
        string $path = "/"
    ): void {
        if ($rid = $this->getRidForMobId($mob_id)) {
            $this->irss->importFileFromUploadResultToContainer(
                $rid,
                $result,
                $path
            );
        }
    }
 
    public function addFileFromLocal(int $mob_id, string $tmp_name, string $path): void
    {
        if ($rid = $this->getRidForMobId($mob_id)) {
            $this->irss->addLocalFileToContainer(
                $rid,
                $tmp_name,
                $path
            );
        }
    }
 
    public function addLocalDirectory(int $mob_id, string $dir): void
    {
        if ($rid = $this->getRidForMobId($mob_id)) {
            $this->irss->addDirectoryToContainer(
                $rid,
                $dir
            );
        }
    }
 
    public function getLocalSrc(int $mob_id, string $location): string
    {
        $rid = $this->getRidForMobId($mob_id);
        if ($rid === "") {
            return "";
        }
        return $this->irss->getContainerUri($rid, $location);
    }
 
    public function hasLocalFile(int $mob_id, string $location): bool
    {
        $rid = $this->getRidForMobId($mob_id);
        if ($rid === "") {
            return false;
        }
        return $this->irss->hasContainerEntry($rid, $location);
    }
 
    public function getLocationStream(
        int $mob_id,
        string $location
    ): ZIPStream {
        return $this->irss->getStreamOfContainerEntry(
            $this->getRidForMobId($mob_id),
            $location
        );
    }
 
    public function getLocationContent(
        int $mob_id,
        string $location
    ): string {
        $content = "";
        if (str_starts_with($location, "/")) {
            $location = substr($location, 1);
        }
        if ($this->irss->hasContainerEntry($this->getRidForMobId($mob_id), $location)) {
            $content = stream_get_contents($this->getLocationStream($mob_id, $location)->detach());
        }
        return $content;
    }
 
    public function getInfoOfEntry(
        int $mob_id,
        string $path
    ): array {
        return $this->irss->getContainerEntryInfo(
            $this->getRidForMobId($mob_id),
            $path
        );
    }
 
    public function deliverEntry(
        int $mob_id,
        string $path
    ): void {
        $this->irss->deliverContainerEntry(
            $this->getRidForMobId($mob_id),
            $path
        );
    }
 
    public function getContainerPath(
        int $mob_id
    ): string {
        return $this->irss->getResourcePath($this->getRidForMobId($mob_id));
    }
 
    public function addStream(
        int $mob_id,
        string $location,
        FileStream $stream
    ): void {
        $this->irss->addStreamToContainer(
            $this->getRidForMobId($mob_id),
            $stream,
            $location
        );
    }
 
    public function addString(
        int $mob_id,
        string $location,
        string $content
    ): void {
        $this->irss->addStringToContainer(
            $this->getRidForMobId($mob_id),
            $content,
            $location
        );
    }
 
    public function getContainerResource(
        int $mob_id
    ): ?StorableResource {
        return $this->irss->getResource($this->getRidForMobId($mob_id));
    }
 
    public function getContainerResourceId(
        int $mob_id
    ): ?ResourceIdentification {
        return $this->irss->getResourceIdForIdString($this->getRidForMobId($mob_id));
    }
 
    public function removeLocation(
        int $mob_id,
        string $location
    ): void {
        $this->irss->removePathFromContainer($this->getRidForMobId($mob_id), $location);
    }
 
    public function getFilesOfPath(
        int $mob_id,
        string $dir_path
    ): array {
        return $this->irss->getContainerEntriesOfPath(
            $this->getRidForMobId($mob_id),
            $dir_path
        );
    }
 
}