ResourceDBRepository.php

Go to the documentation of this file.

<?php

namespace ILIAS\ResourceStorage\Resource\Repository;

use ILIAS\ResourceStorage\Identification\ResourceIdentification;
use ILIAS\ResourceStorage\Resource\StorableFileResource;
use ILIAS\ResourceStorage\Resource\StorableResource;
use ILIAS\ResourceStorage\Resource\ResourceType;
use ILIAS\ResourceStorage\Resource\StorableContainerResource;

class ResourceDBRepository implements ResourceRepository
{
    public const TABLE_NAME = 'il_resource';
    public const IDENTIFICATION = 'rid';

    protected array $cache = [];
    protected \ilDBInterface $db;

    public function __construct(\ilDBInterface $db)
    {
        $this->db = $db;
    }

    public function getNamesForLocking(): array
    {
        return [self::TABLE_NAME];
    }

    public function blank(
        ResourceIdentification $identification,
        ResourceType $type = ResourceType::SINGLE_FILE
    ): StorableResource {
        return match ($type) {
            ResourceType::SINGLE_FILE => new StorableFileResource($identification),
            ResourceType::CONTAINER => new StorableContainerResource($identification),
        };
    }

    public function get(ResourceIdentification $identification): StorableResource
    {
        $rid = $identification->serialize();

        if (isset($this->cache[$rid])) {
            return $this->cache[$rid];
        }

        $q = "SELECT storage_id, rtype FROM " . self::TABLE_NAME . " WHERE " . self::IDENTIFICATION . " = %s";
        $r = $this->db->queryF($q, ['text'], [$rid]);
        $d = $this->db->fetchObject($r);

        $resource = $this->blank($identification, ResourceType::from($d->rtype));
        $resource->setStorageID($d->storage_id);

        $this->cache[$rid] = $resource;

        return $resource;
    }

    public function has(ResourceIdentification $identification): bool
    {
        $rid = $identification->serialize();

        if (isset($this->cache[$rid])) {
            return true;
        }

        $q = "SELECT EXISTS(SELECT 1 FROM " . self::TABLE_NAME . " WHERE " . self::IDENTIFICATION . " = %s) AS found";
        $r = $this->db->queryF($q, ['text'], [$rid]);
        $d = $this->db->fetchAssoc($r);

        return (bool) $d['found'];
    }

    public function store(StorableResource $resource): void
    {
        $rid = $resource->getIdentification()->serialize();

        $this->db->replace(
            self::TABLE_NAME,
            [
                self::IDENTIFICATION => ['text', $rid]
            ],
            [
                'storage_id' => ['text', $resource->getStorageID()],
                'rtype' => ['text', $resource->getType()->value],
            ]
        );

        $this->cache[$rid] = $resource;
    }

    public function delete(StorableResource $resource): void
    {
        $rid = $resource->getIdentification()->serialize();
        $this->db->manipulateF(
            "DELETE FROM " . self::TABLE_NAME . " WHERE " . self::IDENTIFICATION . " = %s",
            ['text'],
            [$rid]
        );
        unset($this->cache[$rid]);
    }

    public function getAll(): \Generator
    {
        yield from [];
    }

    public function preload(array $identification_strings): void
    {
        $r = $this->db->query(
            "SELECT rid, storage_id, rtype FROM " . self::TABLE_NAME . " WHERE "
            . $this->db->in(self::IDENTIFICATION, $identification_strings, false, 'text')
        );
        while ($d = $this->db->fetchAssoc($r)) {
            $this->populateFromArray($d);
        }
    }

    public function populateFromArray(array $data): void
    {
        $resource = $this->blank(
            new ResourceIdentification($data['rid']),
            ResourceType::from($data['rtype'] ?? ResourceType::SINGLE_FILE->value)
        );
        $resource->setStorageID($data['storage_id']);
        $this->cache[$data['rid']] = $resource;
    }
}