35474116988

Committed 19 Sep 2026 10:42PM UTC coverage: 64.702% (+0.06%) from 64.644%

Build Type

push

github

Committed by visavi

Commit Message

Опрос реестров модулей уходит в очередь

  Недоступный реестр держал страницу до десяти секунд таймаута, а каталог
  опрашивает их все разом. Теперь при настроенной очереди опрос ставится
  задачей (уникальной по реестру, без повторов), а на sync всё работает
  как прежде: кнопка обновляет реестр на месте, протухший кэш — после
  отправки ответа.

Coverage Stats

14 of 25 new or added lines in 4 files covered. (56.0%)

4654 of 7193 relevant lines covered (64.7%)

22.46 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

59.6

/app/Http/Controllers/Admin/ModuleController.php

<?php

declare(strict_types=1);

namespace App\Http\Controllers\Admin;

use App\Models\Module;
use App\Models\ModuleRegistry;
use App\Providers\ModuleServiceProvider;
use Illuminate\Http\RedirectResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Http;
use Illuminate\View\View;
use ZipArchive;

class ModuleController extends AdminController
{
    /**
     * Главная страница
     */
    public function index(): View
    {
        $modules = Module::query()->get();
        $moduleInstall = [];
        foreach ($modules as $module) {
            $moduleInstall[$module->name] = $module;
        }

        $registryModules = ModuleRegistry::getAvailableModules();

        $moduleNames = [];
        $modulesLoaded = glob(base_path('modules/*'), GLOB_ONLYDIR);
        foreach ($modulesLoaded as $module) {
            if (file_exists($module . '/module.php')) {
                $name = basename($module);
                $config = include $module . '/module.php';

                // Дата релиза берётся из реестра, но только если он описывает ровно ту
                // версию, что показана в карточке — иначе датой обновления Форума 1.1
                // стал бы релиз ещё не установленной 1.2. Для своих модулей и для
                // отставших версий остаётся дата файлов на диске: когда распаковали
                $shownVersion = $moduleInstall[$name]->version ?? ($config['version'] ?? null);
                $config['released_at'] = ($registryModules[$name]['version'] ?? null) === $shownVersion
                    ? ($registryModules[$name]['released_at'] ?? null)
                    : null;

                $config['released_at'] ??= date('Y-m-d', (int) filemtime($module . '/module.php'));

                $moduleNames[$name] = $config;
            }
        }

        $installed = array_intersect_key($moduleInstall, $moduleNames);
        $counts = [
            'all'           => count($moduleNames),
            'installed'     => count(array_filter($installed, fn ($m) => $m->active)),
            'disabled'      => count(array_filter($installed, fn ($m) => ! $m->active)),
            'not-installed' => count($moduleNames) - count($installed),
        ];

        $failedModules = ModuleServiceProvider::$failed;

        return view('admin/modules/index', compact('moduleInstall', 'moduleNames', 'counts', 'registryModules', 'failedModules'));
    }

    /**
     * Просмотр модуля
     */
    public function module(Request $request): View
    {
        $moduleName = (string) $request->input('module');
        $modulePath = base_path('modules/' . $moduleName);

        if (! preg_match('|^[A-Z][\w\-]+$|', $moduleName) || ! file_exists($modulePath)) {
            abort(200, __('admin.modules.module_not_found'));
        }

        $moduleConfig = include $modulePath . '/module.php';
        $module = Module::query()->where('name', $moduleName)->first();

        if (file_exists($modulePath . '/screenshots')) {
            $moduleConfig['screenshots'] = glob($modulePath . '/screenshots/*.{gif,png,jpg,jpeg,webp}', GLOB_BRACE);
        }

        if (file_exists($modulePath . '/database/migrations')) {
            $migrations = [];
            foreach (glob($modulePath . '/database/migrations/*.php') as $migration) {
                $migrations[basename($migration)] = file_get_contents($migration);
            }
            $moduleConfig['migrations'] = $migrations;
        }

        if (file_exists($modulePath . '/resources/assets')) {
            $moduleConfig['symlink'] = Module::getLinkNameByPath($modulePath);
        }

        if (file_exists($modulePath . '/config.php')) {
            $moduleConfig['config'] = file_get_contents($modulePath . '/config.php');
        }

        if (file_exists($modulePath . '/routes.php')) {
            $moduleConfig['routes'] = file_get_contents($modulePath . '/routes.php');
        }

        if (file_exists($modulePath . '/hooks.php')) {
            $moduleConfig['hooks'] = file_get_contents($modulePath . '/hooks.php');
        }

        if (file_exists($modulePath . '/helpers.php')) {
            $moduleConfig['helpers'] = file_get_contents($modulePath . '/helpers.php');
        }

        if (file_exists($modulePath . '/middleware.php')) {
            $moduleConfig['middleware'] = file_get_contents($modulePath . '/middleware.php');
        }

        foreach (['changelog.md', 'CHANGELOG.md'] as $changelog) {
            if (file_exists($modulePath . '/' . $changelog)) {
                // Убираем шапку "# Changelog" — на странице уже есть свой заголовок
                $moduleConfig['changelog'] = trim((string) preg_replace(
                    '/^#\s+changelog\s*/ui',
                    '',
                    file_get_contents($modulePath . '/' . $changelog)
                ));
                break;
            }
        }

        $registryInfo = ModuleRegistry::getAvailableModules()[$moduleName] ?? null;

        // Дата релиза берётся из реестра, но только если он описывает ровно ту
        // версию, что стоит на сайте — иначе датой установленной 1.1 стал бы
        // релиз ещё не поставленной 1.2. Иначе дата файла: когда распаковали
        $shownVersion = $module->version ?? ($moduleConfig['version'] ?? null);
        $moduleConfig['released_at'] = ($registryInfo['version'] ?? null) === $shownVersion
            ? ($registryInfo['released_at'] ?? null)
            : null;

        $moduleConfig['released_at'] ??= date('Y-m-d', (int) filemtime($modulePath . '/module.php'));

        return view('admin/modules/module', compact('module', 'moduleConfig', 'moduleName', 'registryInfo'));
    }

    /**
     * Установка модуля
     */
    public function install(Request $request): RedirectResponse
    {
        $moduleName = $request->input('module');
        $enable = int($request->input('enable'));
        $update = int($request->input('update'));
        $modulePath = base_path('modules/' . $moduleName);

        if (! preg_match('|^[A-Z][\w\-]+$|', $moduleName) || ! file_exists($modulePath)) {
            abort(200, __('admin.modules.module_not_found'));
        }

        $module = Module::query()->firstOrNew(['name' => $moduleName]);

        $moduleConfig = include $modulePath . '/module.php';

        if ($requires = $this->incompatibleWith($moduleConfig)) {
            return redirect('admin/modules/module?module=' . $moduleName)
                ->with('danger', __('admin.modules.requires') . ' ' . $requires . '!');
        }

        $result = $this->applyModule($module, $moduleConfig, (bool) $enable, (bool) $update);

        return redirect('admin/modules/module?module=' . $moduleName)
            ->with('success', $result);
    }

    /**
     * Раскладывает файлы модуля и фиксирует его состояние в БД
     */
    private function applyModule(Module $module, array $moduleConfig, bool $enable, bool $update): string
    {
        // Файлы на диск кладём только для активного модуля: свежая установка,
        // включение или обновление уже активного. Обновление выключенного модуля
        // не должно возвращать его файлы в public.
        if (! $module->exists || $enable || $module->active) {
            $module->createSymlink();
            $module->publish();
        }

        // Миграции применяем и выключенному: его таблицы при выключении остаются
        // (rollback только при полном удалении), а версия в БД поднимается в любом
        // случае — схема не должна отставать от того, что записано как версия
        $module->migrate();

        $result = __('admin.modules.module_success_installed');

        if ($module->exists) {
            if ($update) {
                $module->update([
                    'version' => $moduleConfig['version'],
                ]);
                $result = __('admin.modules.module_success_updated');
            }

            if ($enable) {
                $module->update([
                    'active' => true,
                ]);
                $result = __('admin.modules.module_success_enabled');
            }
        } else {
            $module->fill([
                'version' => $moduleConfig['version'],
            ])->save();
        }

        // Полная синхронизация активных модулей: порядок установки перестаёт
        // иметь значение (напр. перевод модуля-языка подмешается в Форум,
        // даже если Форум поставили позже). Сама сбрасывает кэш модулей.
        Module::syncAll();

        // После syncAll — пересборка увидит роуты нового модуля
        refreshCaches();

        return $result;
    }

    /**
     * Возвращает требуемую версию движка, если модуль с ней несовместим
     */
    private function incompatibleWith(array $moduleConfig): ?string
    {
        $requires = $moduleConfig['requires'] ?? null;

        return $requires && version_compare(ROTOR_VERSION, $requires, '<') ? $requires : null;
    }

    /**
     * Каталог модулей из реестров
     */
    public function marketplace(Request $request): View|RedirectResponse
    {
        $force = (bool) $request->input('refresh');

        // Реестров может быть несколько, и каждый недоступный стоит десять секунд
        // таймаута. С очередью страница открывается сразу, опрос идёт в фоне
        if ($force && ModuleRegistry::queueFetchAll()) {
            return redirect()->route('admin.modules.marketplace')
                ->with('success', __('admin.registries.registry_refresh_queued'));
        }

        $available = ModuleRegistry::getAvailableModules($force);

        $modules = Module::query()->get()->keyBy('name');
        $moduleNames = [];

        // Версии с диска: распакованный, но ещё не применённый релиз незачем
        // предлагать скачать заново — его хватает применить на странице модуля
        $localVersions = [];

        $modulesLoaded = glob(base_path('modules/*'), GLOB_ONLYDIR);
        foreach ($modulesLoaded as $module) {
            $name = basename($module);
            $moduleNames[] = $name;

            if (file_exists($module . '/module.php')) {
                $config = include $module . '/module.php';
                $localVersions[$name] = $config['version'] ?? null;
            }
        }

        $counts = ['all' => count($available), 'installed' => 0, 'disabled' => 0, 'not-installed' => 0];
        foreach ($available as $name => $info) {
            $localExists = in_array($name, $moduleNames, true);
            $installed = $modules->has($name) && $localExists;

            if ($installed) {
                $counts[$modules[$name]->active ? 'installed' : 'disabled']++;
            } else {
                $counts['not-installed']++;
            }
        }

        return view('admin/modules/marketplace', compact('available', 'modules', 'moduleNames', 'localVersions', 'counts'));
    }

    /**
     * Форма загрузки модуля
     */
    public function upload(): View
    {
        return view('admin/modules/upload');
    }

    /**
     * Установка модуля из ZIP-файла
     */
    public function uploadZip(Request $request): RedirectResponse
    {
        if (! $request->hasFile('zip') || ! $request->file('zip')->isValid()) {
            return redirect()->route('admin.modules.upload')
                ->with('danger', __('admin.modules.upload_invalid_file'));
        }

        try {
            $moduleName = $this->extractZip($request->file('zip')->getPathname());
        } catch (\Exception $e) {
            return redirect()->route('admin.modules.upload')
                ->with('danger', $e->getMessage());
        }

        // Ручная заливка уже установленного модуля — единственный случай, когда
        // версию применяет админ: подсказываем про «Применить обновление»
        $extracted = Module::query()->where('name', $moduleName)->exists()
            ? __('admin.modules.update_extracted')
            : __('admin.modules.upload_success_extracted');

        return redirect('/admin/modules/module?module=' . $moduleName)
            ->with('success', $extracted);
    }

    /**
     * Установка модуля по URL
     */
    public function download(Request $request): RedirectResponse
    {
        $url = trim($request->input('url', ''));

        if (! filter_var($url, FILTER_VALIDATE_URL) || ! in_array(parse_url($url, PHP_URL_SCHEME), ['http', 'https'], true)) {
            return redirect()->back()
                ->with('danger', __('admin.modules.download_invalid_url'));
        }

        $maxSize = (int) config('modules.download_max_size') * 1024 * 1024;

        $tempDir = storage_path('app/temp');
        if (! is_dir($tempDir)) {
            mkdir($tempDir, 0755, true);
        }
        $tempFile = $tempDir . '/rotor_module_' . uniqid() . '.zip';

        try {
            // Потоковая запись: лимит проверяется по мере чтения, тело не держим в памяти
            $response = Http::timeout(30)->withOptions(['stream' => true])->get($url);

            if (! $response->ok()) {
                return redirect()->back()
                    ->with('danger', __('admin.modules.download_failed'));
            }

            $stream = $response->toPsrResponse()->getBody();
            $handle = fopen($tempFile, 'wb');

            if ($handle === false) {
                return redirect()->back()
                    ->with('danger', __('admin.modules.download_failed'));
            }
            $written = 0;
            $tooLarge = false;

            while (! $stream->eof()) {
                $chunk = $stream->read(8192);
                $written += strlen($chunk);

                if ($written > $maxSize) {
                    $tooLarge = true;
                    break;
                }

                fwrite($handle, $chunk);
            }

            fclose($handle);

            if ($tooLarge) {
                @unlink($tempFile);

                return redirect()->back()
                    ->with('danger', __('admin.modules.download_too_large', ['size' => formatSize($maxSize)]));
            }

            if (file_get_contents($tempFile, false, null, 0, 4) !== "PK\x03\x04") {
                @unlink($tempFile);

                return redirect()->back()
                    ->with('danger', __('admin.modules.download_not_zip'));
            }

            try {
                $moduleName = $this->extractZip($tempFile);
            } finally {
                @unlink($tempFile);
            }
        } catch (\Exception $e) {
            @unlink($tempFile);

            return redirect()->back()
                ->with('danger', $e->getMessage());
        }

        $module = Module::query()->firstOrNew(['name' => $moduleName]);
        $moduleConfig = include base_path('modules/' . $moduleName . '/module.php');

        // Несовместимую версию не применяем, но файлы уже распакованы: модуль
        // остаётся в промежуточном состоянии, о чём и говорит сообщение
        if ($requires = $this->incompatibleWith($moduleConfig)) {
            return redirect('/admin/modules/module?module=' . $moduleName)
                ->with('danger', __('admin.modules.requires') . ' ' . $requires . '! ' . __('admin.modules.update_extracted'));
        }

        // Кнопка в каталоге называется «Установить» и «Обновить» — она это и делает.
        // Для обновления применить обязательно: распаковка уже заменила код
        // работающего модуля, без миграций сайт остался бы на новой версии со
        // старой схемой БД
        $result = $this->applyModule($module, $moduleConfig, false, true);

        return redirect('/admin/modules/module?module=' . $moduleName)
            ->with('success', $result);
    }

    /**
     * Распаковка ZIP-архива модуля
     */
    private function extractZip(string $zipPath): string
    {
        $zip = new ZipArchive();

        if ($zip->open($zipPath) !== true) {
            throw new \RuntimeException(__('admin.modules.zip_open_failed'));
        }

        $topDirs = [];
        for ($i = 0; $i < $zip->numFiles; $i++) {
            $name = $zip->getNameIndex($i);

            if (str_contains($name, '..')) {
                $zip->close();
                throw new \RuntimeException(__('admin.modules.zip_invalid_path'));
            }

            $parts = explode('/', $name);
            if ($parts[0] !== '') {
                $topDirs[$parts[0]] = true;
            }
        }

        if (count($topDirs) !== 1) {
            $zip->close();
            throw new \RuntimeException(__('admin.modules.zip_invalid_structure'));
        }

        $moduleName = array_key_first($topDirs);

        if (! preg_match('/^[A-Z][A-Za-z0-9]+$/', $moduleName)) {
            $zip->close();
            throw new \RuntimeException(__('admin.modules.zip_invalid_name'));
        }

        $targetPath = base_path('modules/' . $moduleName);

        // Существующий модуль уводим в резервную копию, чтобы чистая распаковка
        // не оставила старых файлов и можно было откатиться при сбое
        $backupPath = null;
        if (is_dir($targetPath)) {
            $backupPath = base_path('modules/.backup_' . $moduleName . '_' . time());
            if (! rename($targetPath, $backupPath)) {
                $zip->close();
                throw new \RuntimeException(__('admin.modules.zip_backup_failed'));
            }
        }

        if (! $zip->extractTo(base_path('modules/'))) {
            $zip->close();
            $this->restoreBackup($targetPath, $backupPath);
            throw new \RuntimeException(__('admin.modules.zip_extract_failed'));
        }
        $zip->close();

        $this->chmodRecursive($targetPath);

        if (! file_exists($targetPath . '/module.php')) {
            $this->restoreBackup($targetPath, $backupPath);
            throw new \RuntimeException(__('admin.modules.zip_no_module_file'));
        }

        if ($backupPath) {
            $this->deleteDirectory($backupPath);
        }

        // Файлы перезаписаны на диске, но opcache (revalidate_freq) ещё держит
        // старый module.php — без сброса кнопка обновления и новый код модуля
        // подхватятся только со следующим запросом после ревалидации
        if (function_exists('opcache_reset')) {
            opcache_reset();
        }

        return $moduleName;
    }

    /**
     * Удаление файлов модуля с диска
     */
    public function deleteFiles(Request $request): RedirectResponse
    {
        $moduleName = $request->input('module');
        $modulePath = base_path('modules/' . $moduleName);

        if (! preg_match('|^[A-Z][\w\-]+$|', $moduleName) || ! file_exists($modulePath)) {
            abort(200, __('admin.modules.module_not_found'));
        }

        if (Module::query()->where('name', $moduleName)->exists()) {
            abort(200, __('admin.modules.delete_files_not_uninstalled'));
        }

        $this->deleteDirectory($modulePath);

        refreshCaches();

        return redirect()->route('admin.modules.index')
            ->with('success', __('admin.modules.module_files_deleted'));
    }

    /**
     * Откат распаковки: удалить частично распакованное и вернуть резервную копию
     */
    private function restoreBackup(string $targetPath, ?string $backupPath): void
    {
        $this->deleteDirectory($targetPath);

        if ($backupPath && is_dir($backupPath)) {
            rename($backupPath, $targetPath);
        }
    }

    /**
     * Рекурсивно устанавливает права доступа (755 для директорий, 644 для файлов)
     */
    private function chmodRecursive(string $path): void
    {
        chmod($path, 0755);

        foreach (scandir($path) as $item) {
            if ($item === '.' || $item === '..') {
                continue;
            }

            $full = $path . '/' . $item;
            if (is_dir($full)) {
                $this->chmodRecursive($full);
            } else {
                chmod($full, 0644);
            }
        }
    }

    /**
     * Рекурсивно удаляет директорию, включая симлинки
     */
    private function deleteDirectory(string $path): void
    {
        if (is_link($path)) {
            unlink($path);

            return;
        }

        if (! is_dir($path)) {
            return;
        }

        foreach (scandir($path) as $item) {
            if ($item === '.' || $item === '..') {
                continue;
            }

            $full = $path . '/' . $item;
            is_dir($full) && ! is_link($full) ? $this->deleteDirectory($full) : unlink($full);
        }

        rmdir($path);
    }

    /**
     * Удаление/Выключение модуля
     */
    public function uninstall(Request $request): RedirectResponse
    {
        $moduleName = $request->input('module');
        $disable = int($request->input('disable'));
        $modulePath = base_path('modules/' . $moduleName);

        if (! preg_match('|^[A-Z][\w\-]+$|', $moduleName) || ! file_exists($modulePath)) {
            abort(200, __('admin.modules.module_not_found'));
        }

        $module = Module::query()->where('name', $moduleName)->first();
        if (! $module) {
            abort(200, __('admin.modules.module_not_found'));
        }

        $module->deleteSymlink();
        $module->unpublish();

        if ($disable) {
            $module->update([
                'active' => false,
            ]);
            $result = __('admin.modules.module_success_disabled');
        } else {
            if (config('modules.safe_mode')) {
                return redirect('admin/modules/module?module=' . $moduleName)
                    ->with('danger', __('admin.modules.safe_mode_enabled'));
            }

            $module->rollback();
            $module->delete();
            $result = __('admin.modules.module_success_deleted');
        }

        clearCache(['modules', 'settings']);

        // После смены статуса модуля — пересборка соберёт роуты без него
        refreshCaches();

        return redirect('admin/modules/module?module=' . $moduleName)
            ->with('success', $result);
    }
}

visavi / rotor / 35474116988

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous