Chamilo\CoreBundle\Migrations\Schema\V200\Version20250306101000

Complexity

Total Complexity

12

Size/Duplication

Total Lines	110
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getDescription()	0	3	1
A	getPluginSettingsByUrl()	0	28	3
A	getPluginTitles()	0	9	1
A	down()	0	2	1
A	insertPlugin()	0	17	2
A	insertPluginSettingsByUrl()	0	10	2
A	up()	0	8	2

<?php

/* For licensing terms, see /license.txt */

declare(strict_types=1);

namespace Chamilo\CoreBundle\Migrations\Schema\V200;

use AppPlugin;
use Chamilo\CoreBundle\Entity\Plugin;
use Chamilo\CoreBundle\Migrations\AbstractMigrationChamilo;
use Doctrine\DBAL\Exception;
use Doctrine\DBAL\Schema\Schema;

final class Version20250306101000 extends AbstractMigrationChamilo
{
    public function getDescription(): string
    {
        return 'Migrate data from the settings table to the new plugin table.';
    }

    public function up(Schema $schema): void
    {
        foreach ($this->getPluginTitles() as $pluginTitle) {
            $pluginId = $this->insertPlugin($pluginTitle);

            $settingsByUrl = $this->getPluginSettingsByUrl($pluginTitle);

            $this->insertPluginSettingsByUrl($pluginId, $settingsByUrl);
        }
    }

    public function down(Schema $schema): void
    {
    }

    /**
     * @throws Exception
     */
    private function getPluginTitles(): array
    {
        return $this->connection
            ->executeQuery(
                "SELECT title FROM settings
                    WHERE category = 'plugins' AND type = 'setting' AND subkey IS NOT NULL AND variable <> 'status'
                    GROUP BY subkey"
            )
            ->fetchAllAssociative()
        ;
    }

    /**
     * @throws Exception
     */
    private function insertPlugin(string $pluginTitle): int
    {
        $pluginSource = in_array($pluginTitle, AppPlugin::getOfficialPlugins())
            ? Plugin::SOURCE_OFFICIAL
            : Plugin::SOURCE_THIRD_PARTY;

        $this->connection->insert(
            'plugin',
            [
                'title' => $pluginTitle,
                'installed' => 1,
                'installed_version' => '1.0.0',
                'source' => $pluginSource,
            ]
        );

        return $this->connection->lastInsertId();
    }

    /**
     * @throws Exception
     */
    private function getPluginSettingsByUrl(string $pluginTitle): array
    {
        $settingsByUrl = [];

        $pluginSettings = $this->connection
            ->executeQuery(
                "SELECT variable, selected_value, access_url
                        FROM settings
                        WHERE category = 'plugins'
                            AND type = 'setting'
                            AND subkey IS NOT NULL
                            AND variable <> 'status'
                            AND subkey = '$pluginTitle'"
            )
            ->fetchAllAssociative()
        ;

        foreach ($pluginSettings as $pluginSetting) {
            if (!isset($settingsByUrl[$pluginSetting['access_url']])) {
                $settingsByUrl[$pluginSetting['access_url']] = [];
            }

            $variable = str_replace($pluginSetting['title'].'_', '', $pluginSetting['variable']);

            $settingsByUrl[$pluginSetting['access_url']][$variable] = $pluginSetting['selected_value'];
        }

        return $settingsByUrl;
    }

    /**
     * @param int $pluginId
     * @param array<int, array<string, mixed>> $settingsByUrl
     *
     * @return void
     *
     * @throws Exception
     */
    private function insertPluginSettingsByUrl(int $pluginId, array $settingsByUrl): void
    {
        foreach ($settingsByUrl as $accessUrlId => $pluginSettings) {
            $this->connection->insert(
                'access_url_rel_plugin',
                [
                    'plugin_id' => $pluginId,
                    'url_id' => $accessUrlId,
                    'active' => 1,
                    'configuration' => json_encode($pluginSettings),
                ]
            );
        }
    }
}