Chamilo\CoreBundle\EventSubscriber\InstallDbGuardSubscriber

Complexity

Total Complexity

25

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	1	1
A	redirectToInstaller()	0	4	1
A	detectSettingsTable()	0	10	2
A	getSubscribedEvents()	0	3	1
D	onKernelRequest()	0	85	20

<?php

declare(strict_types=1);

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

namespace Chamilo\CoreBundle\EventSubscriber;

use Doctrine\DBAL\Connection;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\RedirectResponse;
use Symfony\Component\HttpKernel\Event\RequestEvent;
use Symfony\Component\HttpKernel\KernelEvents;

final class InstallDbGuardSubscriber implements EventSubscriberInterface
{
    private const VERSION_KEY = 'chamilo_database_version';

    public function __construct(private readonly Connection $connection) {}

    public static function getSubscribedEvents(): array
    {
        return [KernelEvents::REQUEST => ['onKernelRequest', 2048]];
    }

    public function onKernelRequest(RequestEvent $event): void
    {
        if (!$event->isMainRequest() || PHP_SAPI === 'cli') {
            return;
        }

        $request = $event->getRequest();
        $path = $request->getPathInfo();

        if (
            str_starts_with($path, '/main/install/')
            || str_starts_with($path, '/_wdt')
            || str_starts_with($path, '/_profiler')
            || str_starts_with($path, '/build/')
            || str_starts_with($path, '/bundles/')
            || str_starts_with($path, '/favicon')
        ) {
            return;
        }

        $installedFlag = (string) (
            $request->server->get('APP_INSTALLED')
            ?? $_ENV['APP_INSTALLED']
            ?? getenv('APP_INSTALLED')
            ?? '0'
        );
        $installedFlag = trim($installedFlag, " \t\n\r\0\x0B'\"");

        if ($installedFlag !== '1') {
            $this->redirectToInstaller($event);
            return;
        }

        // Cache "healthy" per PHP-FPM worker
        static $isHealthy = false;
        if ($isHealthy) {
            return;
        }

        // Cache which settings table to use per PHP-FPM worker
        static $settingsTable = null;

        try {
            // If DB is down/unreachable, this will fail quickly
            $this->connection->executeQuery($this->connection->getDatabasePlatform()->getDummySelectSQL());

            if ($settingsTable === null) {
                $settingsTable = $this->detectSettingsTable();
                if ($settingsTable === null) {
                    $this->redirectToInstaller($event);
                    return;
                }
            }

            // Cheap proof: at least 1 row
            $hasRow = $this->connection->fetchOne("SELECT 1 FROM {$settingsTable} LIMIT 1");
            if ($hasRow === false || $hasRow === null) {
                $this->redirectToInstaller($event);
                return;
            }

            // Read DB version (try common column names; only runs until first success)
            $version = null;
            foreach (['selected_value', 'value', 'c_value'] as $col) {
                try {
                    $version = $this->connection->fetchOne(
                        "SELECT {$col} FROM {$settingsTable} WHERE variable = :var LIMIT 1",
                        ['var' => self::VERSION_KEY]
                    );
                    if (!empty($version)) {
                        break;
                    }
                } catch (\Throwable) {
                    // Try next column
                }
            }

            if (empty($version)) {
                $this->redirectToInstaller($event);
                return;
            }

            $isHealthy = true;
        } catch (\Throwable) {
            $this->redirectToInstaller($event);
        }
    }

    private function detectSettingsTable(): ?string
    {
        // Fallback to settings
        try {
            $this->connection->fetchOne('SELECT 1 FROM settings LIMIT 1');
            return 'settings';
        } catch (\Throwable) {

Consider adding a comment why this CATCH block is empty.

        }

        return null;
    }

    private function redirectToInstaller(RequestEvent $event): void
    {
        $event->setResponse(new RedirectResponse('/main/install/index.php', 302));
        $event->stopPropagation();
    }
}