26723576697

Committed 31 May 2026 08:27PM UTC coverage: 14.172% (-0.4%) from 14.618%

Build # 26723576697

Build Type

push

github

Committed by

visavi

Commit Message

Перенес файлы обновлений бд в отдельную папку

Coverage Stats

785 of 5539 relevant lines covered (14.17%)

1.26 hits per line

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

17.76

/app/Models/Module.php

<?php

declare(strict_types=1);

namespace App\Models;

use Exception;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Artisan;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Str;

/**
 * Class Module
 *
 * @property int    $id
 * @property string $name
 * @property string $version
 * @property bool   $active
 * @property array  $settings
 * @property int    $updated_at
 * @property int    $created_at
 */
class Module extends Model
{
    /**
     * Assets modules path
     */
    protected const ASSETS_PATH = '/assets/modules/';

    /**
     * Indicates if the model should be timestamped.
     */
    public $timestamps = false;

    /**
     * The attributes that aren't mass assignable.
     */
    protected $guarded = [];

    /**
     * Get the attributes that should be cast.
     */
    protected function casts(): array
    {
        return [
            'active'   => 'bool',
            'settings' => 'array',
        ];
    }

    /**
     * Выполняет применение миграции
     */
    public function migrate(): void
    {
        $migrationPath = base_path('modules/' . $this->name . '/database/migrations');

        if (file_exists($migrationPath)) {
            Artisan::call('migrate', [
                '--force'    => true,
                '--realpath' => true,
                '--path'     => $migrationPath,
            ]);
        }
    }

    /**
     * Выполняет откат миграций
     */
    public function rollback(): void
    {
        $migrationPath = base_path('modules/' . $this->name . '/database/migrations');

        if (file_exists($migrationPath)) {
            $migrator = app('migrator');
            $nextBatchNumber = $migrator->getRepository()->getNextBatchNumber();
            $migrationNames = array_keys($migrator->getMigrationFiles($migrationPath));

            DB::table(config('database.migrations.table'))
                ->whereIn('migration', $migrationNames)
                ->update(['batch' => $nextBatchNumber]);

            Artisan::call('migrate:rollback', [
                '--force'    => true,
                '--realpath' => true,
                '--path'     => $migrationPath,
            ]);
        }
    }

    /**
     * Создает симлинки модулей
     */
    public function createSymlink(): void
    {
        $originPath = public_path($this->getLinkName());
        if (file_exists($originPath)) {
            return;
        }

        $assetsPath = base_path('modules/' . $this->name . '/resources/assets');
        if (! file_exists($assetsPath)) {
            return;
        }

        File::link($assetsPath, $originPath);
    }

    /**
     * Удаляет симлинки модулей
     */
    public function deleteSymlink(): void
    {
        $originPath = public_path($this->getLinkName());
        if (! file_exists($originPath)) {
            return;
        }

        File::delete($originPath);
    }

    /**
     * Получает название директории для симлинка
     */
    public function getLinkName(): string
    {
        return self::ASSETS_PATH . Str::plural(strtolower($this->name));
    }

    /**
     * Получает название директории для симлинка из пути
     */
    public static function getLinkNameByPath(string $modulePath): string
    {
        return self::ASSETS_PATH . Str::plural(strtolower(basename($modulePath)));
    }

    /**
     * Количество установленных модулей с доступным обновлением
     */
    public static function updatesCount(): int
    {
        $installed = self::query()->pluck('version', 'name')->all();
        if (! $installed) {
            return 0;
        }

        $registry = ModuleRegistry::getAvailableModules();

        $count = 0;
        foreach ($installed as $name => $version) {
            $configFile = base_path('modules/' . $name . '/module.php');
            if (! file_exists($configFile)) {
                continue;
            }

            $config = include $configFile;
            $localVersion = $config['version'] ?? null;
            $registryVersion = $registry[$name]['version'] ?? null;

            $hasUpdate = ($localVersion && version_compare($localVersion, $version, '>'))
                || ($registryVersion && version_compare($registryVersion, $version, '>'));

            if ($hasUpdate) {
                $count++;
            }
        }

        return $count;
    }

    /**
     * Get enabled modules
     */
    public static function getEnabledModules(): array
    {
        $cached = Cache::get('modules', []);
        if ($cached !== []) {
            return $cached;
        }

        $modules = self::loadEnabledModules();

        if ($modules !== []) {
            Cache::forever('modules', $modules);
        }

        return $modules;
    }

    /**
     * Загружает активные модули с их файловой структурой
     */
    private static function loadEnabledModules(): array
    {
        try {
            $settings = self::query()
                ->where('active', true)
                ->pluck('settings', 'name')
                ->all();
        } catch (Exception) {
            return [];
        }

        $result = [];
        foreach ($settings as $name => $moduleSettings) {
            $result[$name] = [
                'files'  => self::scanModuleFiles($name),
                'config' => self::loadModuleConfig($name, $moduleSettings ?? []),
            ];
        }

        return $result;
    }

    /**
     * Загружает merged config модуля (file + settings)
     */
    private static function loadModuleConfig(string $name, array $settings): ?array
    {
        $configFile = base_path('modules/' . $name . '/config.php');
        if (! file_exists($configFile)) {
            return null;
        }

        $config = include $configFile;
        if (! is_array($config)) {
            return null;
        }

        return $settings ? array_replace_recursive($config, $settings) : $config;
    }

    /**
     * Сканирует наличие файлов модуля
     */
    private static function scanModuleFiles(string $name): array
    {
        $base = base_path('modules/' . $name . '/');

        return [
            'views'      => is_dir($base . 'resources/views'),
            'lang'       => is_dir($base . 'resources/lang'),
            'helpers'    => file_exists($base . 'helpers.php'),
            'hooks'      => file_exists($base . 'hooks.php'),
            'routes'     => file_exists($base . 'routes.php'),
            'middleware' => file_exists($base . 'middleware.php'),
            'module'     => file_exists($base . 'module.php'),
            'commands'   => array_map(
                static fn ($file) => 'Modules\\' . $name . '\\Console\\' . basename($file, '.php'),
                glob($base . 'Console/*.php') ?: []
            ),
        ];
    }
}

1	<?php
2
3	declare(strict_types=1);
4
5	namespace App\Models;
6
7	use Exception;
8	use Illuminate\Database\Eloquent\Model;
9	use Illuminate\Support\Facades\Artisan;
10	use Illuminate\Support\Facades\Cache;
11	use Illuminate\Support\Facades\DB;
12	use Illuminate\Support\Facades\File;
13	use Illuminate\Support\Str;
14
15	/**
16	* Class Module
17	*
18	* @property int $id
19	* @property string $name
20	* @property string $version
21	* @property bool $active
22	* @property array $settings
23	* @property int $updated_at
24	* @property int $created_at
25	*/
26	class Module extends Model
27	{
28	/**
29	* Assets modules path
30	*/
31	protected const ASSETS_PATH = '/assets/modules/';
32
33	/**
34	* Indicates if the model should be timestamped.
35	*/
36	public $timestamps = false;
37
38	/**
39	* The attributes that aren't mass assignable.
40	*/
41	protected $guarded = [];
42
43	/**
44	* Get the attributes that should be cast.
45	*/
46	protected function casts(): array	60✔
47	{
48	return [	60✔
49	'active' => 'bool',	60✔
50	'settings' => 'array',	60✔
51	];	60✔
52	}
53
54	/**
55	* Выполняет применение миграции
56	*/
57	public function migrate(): void	×
58	{
59	$migrationPath = base_path('modules/' . $this->name . '/database/migrations');	×
60
61	if (file_exists($migrationPath)) {	×
62	Artisan::call('migrate', [	×
63	'--force' => true,	×
64	'--realpath' => true,	×
65	'--path' => $migrationPath,	×
66	]);	×
67	}
68	}
69
70	/**
71	* Выполняет откат миграций
72	*/
73	public function rollback(): void	×
74	{
75	$migrationPath = base_path('modules/' . $this->name . '/database/migrations');	×
76
77	if (file_exists($migrationPath)) {	×
78	$migrator = app('migrator');	×
79	$nextBatchNumber = $migrator->getRepository()->getNextBatchNumber();	×
80	$migrationNames = array_keys($migrator->getMigrationFiles($migrationPath));	×
81
82	DB::table(config('database.migrations.table'))	×
83	->whereIn('migration', $migrationNames)	×
84	->update(['batch' => $nextBatchNumber]);	×
85
86	Artisan::call('migrate:rollback', [	×
87	'--force' => true,	×
88	'--realpath' => true,	×
89	'--path' => $migrationPath,	×
90	]);	×
91	}
92	}
93
94	/**
95	* Создает симлинки модулей
96	*/
97	public function createSymlink(): void	×
98	{
99	$originPath = public_path($this->getLinkName());	×
100	if (file_exists($originPath)) {	×
101	return;	×
102	}
103
104	$assetsPath = base_path('modules/' . $this->name . '/resources/assets');	×
105	if (! file_exists($assetsPath)) {	×
106	return;	×
107	}
108
109	File::link($assetsPath, $originPath);	×
110	}
111
112	/**
113	* Удаляет симлинки модулей
114	*/
115	public function deleteSymlink(): void	×
116	{
117	$originPath = public_path($this->getLinkName());	×
118	if (! file_exists($originPath)) {	×
119	return;	×
120	}
121
122	File::delete($originPath);	×
123	}
124
125	/**
126	* Получает название директории для симлинка
127	*/
128	public function getLinkName(): string	×
129	{
130	return self::ASSETS_PATH . Str::plural(strtolower($this->name));	×
131	}
132
133	/**
134	* Получает название директории для симлинка из пути
135	*/
136	public static function getLinkNameByPath(string $modulePath): string	×
137	{
138	return self::ASSETS_PATH . Str::plural(strtolower(basename($modulePath)));	×
139	}
140
141	/**
142	* Количество установленных модулей с доступным обновлением
143	*/
144	public static function updatesCount(): int	×
145	{
146	$installed = self::query()->pluck('version', 'name')->all();	×
147	if (! $installed) {	×
148	return 0;	×
149	}
150
151	$registry = ModuleRegistry::getAvailableModules();	×
152
153	$count = 0;	×
154	foreach ($installed as $name => $version) {	×
155	$configFile = base_path('modules/' . $name . '/module.php');	×
156	if (! file_exists($configFile)) {	×
157	continue;	×
158	}
159
160	$config = include $configFile;	×
161	$localVersion = $config['version'] ?? null;	×
162	$registryVersion = $registry[$name]['version'] ?? null;	×
163
164	$hasUpdate = ($localVersion && version_compare($localVersion, $version, '>'))	×
165	\|\| ($registryVersion && version_compare($registryVersion, $version, '>'));	×
166
167	if ($hasUpdate) {	×
168	$count++;	×
169	}
170	}
171
172	return $count;	×
173	}
174
175	/**
176	* Get enabled modules
177	*/
178	public static function getEnabledModules(): array	60✔
179	{
180	$cached = Cache::get('modules', []);	60✔
181	if ($cached !== []) {	60✔
182	return $cached;	×
183	}
184
185	$modules = self::loadEnabledModules();	60✔
186
187	if ($modules !== []) {	60✔
188	Cache::forever('modules', $modules);	×
189	}
190
191	return $modules;	60✔
192	}
193
194	/**
195	* Загружает активные модули с их файловой структурой
196	*/
197	private static function loadEnabledModules(): array	60✔
198	{
199	try {
200	$settings = self::query()	60✔
201	->where('active', true)	60✔
202	->pluck('settings', 'name')	60✔
203	->all();	60✔
204	} catch (Exception) {	×
205	return [];	×
206	}
207
208	$result = [];	60✔
209	foreach ($settings as $name => $moduleSettings) {	60✔
210	$result[$name] = [	×
211	'files' => self::scanModuleFiles($name),	×
212	'config' => self::loadModuleConfig($name, $moduleSettings ?? []),	×
213	];	×
214	}
215
216	return $result;	60✔
217	}
218
219	/**
220	* Загружает merged config модуля (file + settings)
221	*/
222	private static function loadModuleConfig(string $name, array $settings): ?array	×
223	{
224	$configFile = base_path('modules/' . $name . '/config.php');	×
225	if (! file_exists($configFile)) {	×
226	return null;	×
227	}
228
229	$config = include $configFile;	×
230	if (! is_array($config)) {	×
231	return null;	×
232	}
233
234	return $settings ? array_replace_recursive($config, $settings) : $config;	×
235	}
236
237	/**
238	* Сканирует наличие файлов модуля
239	*/
240	private static function scanModuleFiles(string $name): array	×
241	{
242	$base = base_path('modules/' . $name . '/');	×
243
244	return [	×
245	'views' => is_dir($base . 'resources/views'),	×
246	'lang' => is_dir($base . 'resources/lang'),	×
247	'helpers' => file_exists($base . 'helpers.php'),	×
248	'hooks' => file_exists($base . 'hooks.php'),	×
249	'routes' => file_exists($base . 'routes.php'),	×
250	'middleware' => file_exists($base . 'middleware.php'),	×
251	'module' => file_exists($base . 'module.php'),	×
252	'commands' => array_map(	×
253	static fn ($file) => 'Modules\\' . $name . '\\Console\\' . basename($file, '.php'),	×
254	glob($base . 'Console/*.php') ?: []	×
255	),	×
256	];	×
257	}
258	}

visavi / rotor / 26723576697

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