class.ilPollImagesMigration.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

use ILIAS\Setup\Environment;
use ILIAS\Setup\Migration;
use ILIAS\Poll\Image\Repository\Stakeholder\Handler as ilPollImageRepositoryStakeholder;

class ilPollImagesMigration implements Migration
{
    protected ilDBInterface $db;

    public function getLabel(): string
    {
        return "PollImagesMigration";
    }

    public function getDefaultAmountOfStepsPerRun(): int
    {
        return 5;
    }

    public function getPreconditions(
        Environment $environment
    ): array {
        return [
            new ilIniFilesLoadedObjective(),
            new ilDatabaseInitializedObjective(),
            new ilDatabaseUpdatedObjective(),
        ];
    }

    public function prepare(
        Environment $environment
    ): void {
        $this->db = $environment->getResource(Environment::RESOURCE_DATABASE);
    }

    public function step(
        Environment $environment
    ): void {
        $res = $this->db->query("SELECT id, image FROM il_poll WHERE migrated = 0 LIMIT 1");
        $row = $res->fetchAssoc();
        $image = $row["image"] ?? "";
        $id = (int) $row["id"];

        if ($image === "") {
            $this->db->manipulate("UPDATE il_poll SET migrated = 1 WHERE id = " . $this->db->quote($id, ilDBConstants::T_INTEGER));
            return;
        }

        $file_path = $this->getImageFullPath($image, $id);
        $thumbnail_path = $this->getThumbnailImagePath($image, $id);
        $org_path = $this->getOrgImagePath($image, $id);
        $stakeholder = (new ilPollImageRepositoryStakeholder())->withUserId(6);
        $irss_helper = new ilResourceStorageMigrationHelper($stakeholder, $environment);
        $rid = $irss_helper->movePathToStorage($file_path, 6, null, null, false);
        $rid_thumbnail = $irss_helper->movePathToStorage($thumbnail_path, 6, null, null, false);
        $org_thumbnail = $irss_helper->movePathToStorage($org_path, 6, null, null, false);

        $res_existing = $this->db->query("SELECT * FROM il_poll_image WHERE object_id = " . $this->db->quote($id, ilDBConstants::T_INTEGER));
        $row_existing = $res_existing->fetchAssoc();
        if (is_null($row_existing)) {
            $this->db->manipulate(
                "INSERT INTO il_poll_image (object_id, rid) VALUES "
                . " (" . $this->db->quote($id, ilDBConstants::T_INTEGER)
                . ", " . $this->db->quote($rid->serialize(), ilDBConstants::T_TEXT) . ")"
            );
        }

        if (!is_null($row_existing)) {
            $irss_helper->getResourceBuilder()->remove($irss_helper->getResourceBuilder()->get($rid), $stakeholder);
        }
        $irss_helper->getResourceBuilder()->remove($irss_helper->getResourceBuilder()->get($rid_thumbnail), $stakeholder);
        $irss_helper->getResourceBuilder()->remove($irss_helper->getResourceBuilder()->get($org_thumbnail), $stakeholder);

        $this->db->manipulate("UPDATE il_poll SET migrated = 1 WHERE id = " . $this->db->quote($id, ilDBConstants::T_INTEGER));
    }

    public function getRemainingAmountOfSteps(): int
    {
        $res = $this->db->query(
            'SELECT COUNT(*) AS count FROM il_poll WHERE migrated = 0'
        );
        $row = $this->db->fetchAssoc($res);
        return (int) $row['count'];
    }

    public function getImageFullPath(string $img, int $id): ?string
    {
        return $this->getLegacyPath($id) . '/' . $img;
    }

    protected function getThumbnailImagePath(string $img, int $id): string
    {
        return $this->getLegacyPath($id) . "/thb_" . $img;
    }

    protected function getOrgImagePath(string $img, int $id): string
    {
        return $this->getLegacyPath($id) . "/org_" . $img;
    }

    protected function getLegacyPath(int $a_id): string
    {
        $path = 'sec/ilPoll/' . ilFileSystemAbstractionStorage::createPathFromId($a_id, 'poll');
        return rtrim(CLIENT_WEB_DIR, '/') . '/' . rtrim($path, '/');
    }
}