CachedRepository.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\ILIASObject\Properties\CoreProperties;

use ILIAS\ILIASObject\Properties\ObjectTypeSpecificProperties\Factory as ObjectTypeSpecificPropertiesFactory;
use ILIAS\ResourceStorage\Services as ResourceStorageService;

class CachedRepository implements Repository
{
    private const CORE_PROPERTIES_TABLE = 'object_data';
    private const DESCRIPTION_TABLE = 'object_description';

    private array $data_cache = [];

    public function __construct(
        private readonly \ilDBInterface $database,
        private readonly \ilObjectDefinition $obj_definition,
        private readonly ResourceStorageService $storage_services,
        private readonly TileImage\Stakeholder $storage_stakeholder,
        private readonly TileImage\FlavourDefinition $flavour_definition,
        private readonly ObjectTypeSpecificPropertiesFactory $object_type_specific_properties_factory
    ) {
    }

    public function preload(array $object_ids): void
    {
        $this->data_cache += $this->retrieveDataForObjectIds($object_ids);
    }

    public function resetPreloadedData(): void
    {
        $this->data_cache = [];
    }

    public function getFor(?int $object_id, ?string $type = null): CoreProperties
    {
        if ($object_id === null
            || $object_id === 0) {
            return $this->getDefaultCoreProperties($type);
        }

        if (!isset($this->data_cache[$object_id])) {
            $this->data_cache[$object_id] = $this->retrieveDataForObjectId($object_id);
        }

        $data = $this->data_cache[$object_id];

        $object_type_specific_properties = $this->object_type_specific_properties_factory->getForObjectTypeString($data['type']);
        $providers = null;
        $modifications = null;
        if ($object_type_specific_properties !== null) {
            $providers = $object_type_specific_properties->getProviders();
            $modifications = $object_type_specific_properties->getModifications();
        }
        return new CoreProperties(
            new TitleAndDescription(
                array_shift($data),
                array_shift($data),
                $modifications
            ),
            new Online(array_shift($data)),
            new TileImage\Property(
                new TileImage\TileImage(
                    $object_id,
                    $data['type'],
                    array_shift($data),
                    $this->storage_services,
                    $this->storage_stakeholder,
                    $this->flavour_definition,
                    $providers
                )
            ),
            $data
        );
    }

    public function store(CoreProperties $properties): CoreProperties
    {
        if ($properties->getObjectId() === null || $properties->getOwner() === null) {
            throw new \Exception('The current configuration cannot be saved.');
        }

        if ($properties->getPropertyTileImage()->getDeletedFlag()) {
            $this->deleteOldTileImage($properties->getPropertyTileImage()->getTileImage());
            $properties = $properties->withPropertyTileImage(
                $properties->getPropertyTileImage()->withTileImage(
                    $properties->getPropertyTileImage()->getTileImage()->withRid(null)
                )
            );
        }

        $where = [
            'obj_id' => [\ilDBConstants::T_INTEGER, $properties->getObjectId()]
        ];

        $storage_array = [
            'type' => [\ilDBConstants::T_TEXT, $properties->getType()],
            'title' => [\ilDBConstants::T_TEXT, $properties->getPropertyTitleAndDescription()->getTitle()],
            'description' => [\ilDBConstants::T_TEXT, $properties->getPropertyTitleAndDescription()->getDescription()],
            'owner' => [\ilDBConstants::T_INTEGER, $properties->getOwner()],
            'create_date' => [\ilDBConstants::T_DATETIME, $properties->getCreateDate()?->format('Y-m-d H:i:s')],
            'last_update' => [\ilDBConstants::T_DATETIME, (new \DateTimeImmutable('now', new \DateTimeZone('UTC')))->format('Y-m-d H:i:s')],
            'import_id' => [\ilDBConstants::T_TEXT, $properties->getImportId()],
            'offline' => [\ilDBConstants::T_INTEGER, (int) !$properties->getPropertyIsOnline()->getIsOnline()],
            'tile_image_rid' => [\ilDBConstants::T_TEXT, $properties->getPropertyTileImage()->getTileImage()->getRid()]
        ];
        $this->database->update(self::CORE_PROPERTIES_TABLE, $storage_array, $where);

        if ($this->obj_definition->isRBACObject($properties->getType())) {
            $this->storeLongDescription($properties->getPropertyTitleAndDescription()->getLongDescription(), $where);
        }

        unset($this->data_cache[$properties->getObjectId()]);

        return $properties;
    }

    private function deleteOldTileImage(TileImage\TileImage $tile_image): void
    {
        if ($tile_image->getRid() === null) {
            return;
        }

        $i = $this->storage_services->manage()->find($tile_image->getRid());
        if ($i === null) {
            return;
        }

        $this->storage_services->manage()->remove(
            $i,
            $this->storage_stakeholder
        );
    }

    private function getDefaultCoreProperties(?string $type): CoreProperties
    {
        return (new CoreProperties(
            new TitleAndDescription(),
            new Online(),
            new TileImage\Property()
        ))->withType($type);
    }

    protected function retrieveDataForObjectId(int $object_id): array
    {
        $where = 'WHERE obj.obj_id=' . $this->database->quote($object_id, 'integer');
        $data = $this->retrieveDataForWhereClause($where);

        if ($data === []) {
            throw new \Exception('The object with the following id does not exist: '
                . (string) $object_id);
        }

        return $data[$object_id];
    }

    protected function retrieveDataForObjectIds(array $object_ids): array
    {
        $where = 'WHERE ' . $this->database->in('obj.obj_id', $object_ids, false, \ilDBConstants::T_INTEGER);
        return $this->retrieveDataForWhereClause($where);
    }

    protected function retrieveDataForWhereClause(string $where): array
    {
        $query = 'SELECT '
            . 'obj.obj_id, obj.type, obj.title, obj.description, obj.owner,' . PHP_EOL
            . 'obj.create_date, obj.last_update, obj.import_id, obj.offline,' . PHP_EOL
            . 'obj.tile_image_rid, descr.description' . PHP_EOL
            . 'FROM ' . self::CORE_PROPERTIES_TABLE . ' AS obj' . PHP_EOL
            . 'LEFT JOIN ' . self::DESCRIPTION_TABLE . ' AS descr' . PHP_EOL
            . 'ON obj.obj_id = descr.obj_id' . PHP_EOL
            . $where;

        $statement = $this->database->query($query);
        $num_rows = $this->database->numRows($statement);

        if ($num_rows === 0) {
            return [];
        }

        $data = [];
        while ($row = $this->database->fetchAssoc($statement)) {
            $data[$row['obj_id']] = [
                'title' => $row['title'],
                'long_description' => $row['description'] ?? '',
                'is_online' => !((bool) $row['offline']),
                'tile_image_rid' => $row['tile_image_rid'],
                'object_id' => $row['obj_id'],
                'type' => $row['type'],
                'owner' => $row['owner'],
                'import_id' => $row['import_id'],
                'create_date' => $row['create_date'] !== null ? new \DateTimeImmutable($row['create_date']) : null,
                'update_date' => $row['last_update'] !== null ? new \DateTimeImmutable($row['last_update']) : null
            ];
        }

        return $data;
    }

    protected function storeLongDescription(string $long_description, array $where): void
    {
        $description_array = [
            'description' => [\ilDBConstants::T_TEXT, $long_description]
        ];
        $this->database->update(self::DESCRIPTION_TABLE, $description_array, $where);
    }
}