CollectResources.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
namespace ILIAS\TestQuestionPool\ExportImport\Foundation\Normalize\Processors;
 
use ILIAS\ResourceStorage\Identification\ResourceIdentification;
use ILIAS\ResourceStorage\Resource\StorableResource;
use ILIAS\ResourceStorage\Services as IRSS;
use ILIAS\TestQuestionPool\ExportImport\Foundation\Normalize\Processors\NormalizeCarry;
use ILIAS\TestQuestionPool\ExportImport\Foundation\Normalize\Processors\DenormalizeCarry;
use ILIAS\TestQuestionPool\ExportImport\Foundation\Queue\Processor;
use Psr\Log\LoggerInterface;
 
class CollectResources implements Processor
{
    private array $resources = [];
 
    private array $import_mapping = [];
 
    public function __construct(
        private readonly IRSS $irss,
        private readonly LoggerInterface $log
    ) {
    }
 
    public function getResources(): array
    {
        return $this->resources;
    }
 
    public function storeMapping(string $old_id, ResourceIdentification $new_id): void
    {
        $this->import_mapping[$old_id] = $new_id;
    }
 
    public function process(object $carry): void
    {
        if ($carry instanceof NormalizeCarry && $carry->value() instanceof ResourceIdentification) {
            $this->handleNormalization($carry->value());
        }
 
        if (
            $carry instanceof DenormalizeCarry
            && $carry->expected() === ResourceIdentification::class
            && $carry->hasResult()
        ) {
            $carry->setResult($this->replaceRid($carry->result()));
        }
    }
 
    private function handleNormalization(ResourceIdentification $rid): void
    {
        $this->resources[$rid->serialize()] = $this->irss->manage()->getResource($rid);
    }
 
    private function replaceRid(ResourceIdentification $rid): ResourceIdentification
    {
        $id = $rid->serialize();
        if (!isset($this->import_mapping[$id])) {
            $this->log->warning("Unresolved resource id {$id}");
            return $rid;
        }
 
        $this->log->debug("Replaced resource id {$id} with {$this->import_mapping[$id]->serialize()}");
        return $this->import_mapping[$id];
    }
}