Merge branch 'master' of https://git.itguild.info/stasbilay02/MicroFrameWork

2024-12-18 12:29:14 +03:00 · 2024-12-18 12:29:14 +03:00 · ea83698070
commit ea83698070
parent c4b3f46111 aa913293ef
9 changed files with 283 additions and 33 deletions
--- a/kernel/console/controllers/KernelController.php
+++ b/kernel/console/controllers/KernelController.php
@ -27,7 +27,7 @@ class KernelController extends ConsoleController

        if (file_exists(ROOT_DIR . $this->argv['path'])) {
            $tmpKernelDirFull = RESOURCES_DIR . '/tmp/ad/kernel/kernel';
-            $this->files->copy_folder(KERNEL_DIR, $tmpKernelDirFull);
+            $this->files->copy_folder(ROOT_DIR . $this->argv['path'], $tmpKernelDirFull);
            $this->out->r("Ядро скопировано во временную папку", 'green');
        } else {
            $this->out->r("Ядро не найдено", 'red');
@ -65,11 +65,19 @@ class KernelController extends ConsoleController
            $this->out->r("/composer.json не найден", 'red');
        }

-        if (!is_dir(RESOURCES_DIR . '/tmp/app')) {
-            mkdir(RESOURCES_DIR . '/tmp/app');
+        if (!is_dir(RESOURCES_DIR . '/tmp/kernel')) {
+            mkdir(RESOURCES_DIR . '/tmp/kernel');
        }

+        if (file_exists(KERNEL_DIR . '/manifest.json')) {
+            $manifest = json_decode(file_get_contents(KERNEL_DIR . '/manifest.json'), true);
+            $version = $manifest['version'] ?? '';
+            $this->files->pack(RESOURCES_DIR . '/tmp/ad/kernel/', RESOURCES_DIR . '/tmp/kernel/kernel_v' . $version . '.igk');
+        }
+        else {
            $this->files->pack(RESOURCES_DIR . '/tmp/ad/kernel/', RESOURCES_DIR . '/tmp/kernel/kernel.igk');
+        }
+
        $this->files->recursiveRemoveDir(RESOURCES_DIR . '/tmp/ad/kernel/');
    }

--- a/kernel/manifest.json
+++ b/kernel/manifest.json
@ -0,0 +1,8 @@
+{
+  "name": "Kernel",
+  "version": "0.1",
+  "author": "ITGuild",
+  "slug": "kernel",
+  "type": "kernel",
+  "description": "Kernel"
+}
--- a/kernel/modules/module_shop_client/controllers/ModuleShopClientController.php
+++ b/kernel/modules/module_shop_client/controllers/ModuleShopClientController.php
@ -12,8 +12,9 @@ use kernel\helpers\Files;
 use kernel\helpers\RESTClient;
 use kernel\helpers\SMTP;
 use kernel\Mailing;
-use kernel\modules\module_shop_client\services\ModuleShopClientService;
 use kernel\Request;
+use kernel\services\AdminThemeService;
+use kernel\services\KernelService;
 use kernel\services\ModuleService;
 use kernel\services\ModuleShopService;
 use kernel\services\TokenService;
@ -24,6 +25,7 @@ class ModuleShopClientController extends AdminController

    protected Client $client;
    protected ModuleService $moduleService;
+    protected KernelService $kernelService;

    protected function init(): void
    {
@ -32,6 +34,7 @@ class ModuleShopClientController extends AdminController

        $this->client = new Client();
        $this->moduleService = new ModuleService();
+        $this->kernelService = new KernelService();
    }

    /**
@ -55,6 +58,8 @@ class ModuleShopClientController extends AdminController
                    'page_number' => $page_number,
                    'module_count' => $module_count,
                    'per_page' => $per_page,
+                    'kernelService' => new KernelService(),
+                    'adminThemeService' => new AdminThemeService(),
                ]);
            } else {
                $this->cgView->render("module_shop_error_connection.php");
@ -112,6 +117,36 @@ class ModuleShopClientController extends AdminController
        $this->redirect('/admin/module_shop_client', 302);
    }

+    public function actionRenderKernelUpdateForm(): void
+    {
+        $this->cgView->render("kernel_update.php");
+    }
+
+    #[NoReturn] public function actionKernelUpdate(): void
+    {
+        $request = new Request();
+        $modules_info = RESTClient::request($_ENV['MODULE_SHOP_URL'] . '/api/module_shop/gb_slug');
+
+        $modules_info = json_decode($modules_info->getBody()->getContents(), true);
+        foreach ($modules_info as $module) {
+            if ($module['slug'] === 'kernel') {
+                $path = $module['path_to_archive'];
+            }
+        }
+        if (isset($path)) {
+            Files::uploadByUrl($_ENV['MODULE_SHOP_URL'] . $path, RESOURCES_DIR . "/tmp/kernel");
+            if ($this->kernelService->updateKernel('/resources/tmp/kernel/' . basename($path))) {
+                Flash::setMessage("success", "Ядро успешно обновлено.");
+            } else {
+                Flash::setMessage("error", "Ошибка обновления ядра.");
+            }
+        } else {
+            Flash::setMessage("error", "Ошибка обновления ядра.");
+        }
+
+        $this->redirect('/admin/module_shop_client', 302);
+    }
+
    #[NoReturn] public function actionDelete(): void
    {
        $request = new Request();
@ -131,13 +166,6 @@ class ModuleShopClientController extends AdminController
        $request = new Request();
        $address = $request->post("email");

-//        $mailing = new Mailing();
-//        $mailing->send_html("login_by_code.php", ['code' => mt_rand(100000, 999999)], [
-//            'address' => $address,
-//            'subject' => "Код авторизации",
-//            "from_name" => $_ENV['APP_NAME']
-//        ]);
-
        $moduleShopService = new ModuleShopService();
        $result = $moduleShopService->email_auth($address);

@ -153,13 +181,6 @@ class ModuleShopClientController extends AdminController
        $request = new Request();
        $code = $request->post("code");

-//        $mailing = new Mailing();
-//        $mailing->send_html("login_by_code.php", ['code' => mt_rand(100000, 999999)], [
-//            'address' => $address,
-//            'subject' => "Код авторизации",
-//            "from_name" => $_ENV['APP_NAME']
-//        ]);
-
        $moduleShopService = new ModuleShopService();
        $result = $moduleShopService->code_check($code);

--- a/kernel/modules/module_shop_client/routs/module_shop_client.php
+++ b/kernel/modules/module_shop_client/routs/module_shop_client.php
@ -17,6 +17,14 @@ App::$collector->group(["prefix" => "admin"], function (RouteCollector $router){
            App::$collector->get('/update', [\kernel\modules\module_shop_client\controllers\ModuleShopClientController::class, 'actionUpdate']);
            App::$collector->post('/auth', [\kernel\modules\module_shop_client\controllers\ModuleShopClientController::class, 'actionAuth']);
            App::$collector->post('/code_check', [\kernel\modules\module_shop_client\controllers\ModuleShopClientController::class, 'actionCodeCheck']);
+            App::$collector->group(["prefix" => "kernel"], function (RouteCollector $router) {
+                App::$collector->get('/update_form', [\kernel\modules\module_shop_client\controllers\ModuleShopClientController::class, 'actionRenderKernelUpdateForm']);
+                App::$collector->post('/update', [\kernel\modules\module_shop_client\controllers\ModuleShopClientController::class, 'actionKernelUpdate']);
+            });
+            App::$collector->group(["prefix" => "admin_theme"], function (RouteCollector $router) {
+                App::$collector->get('/install', [\kernel\modules\module_shop_client\controllers\ModuleShopClientController::class, 'actionAdminThemeInstall']);
+                App::$collector->post('/update', [\kernel\modules\module_shop_client\controllers\ModuleShopClientController::class, 'actionAdminThemeUpdate']);
+            });
        });
    });
 });
--- a/kernel/modules/module_shop_client/views/index.php
+++ b/kernel/modules/module_shop_client/views/index.php
@ -5,6 +5,8 @@
 * @var int $page_number
 * @var int $per_page
 * @var \kernel\services\ModuleService $moduleService
+ * @var \kernel\services\KernelService $kernelService
+ * @var \kernel\services\AdminThemeService $adminThemeService
 */

 use Itguild\Tables\ListJsonTable;
@ -37,21 +39,23 @@ $table->addAction(function ($row, $url) use ($moduleService) {
 });

 $table->addAction(function ($row, $url) use ($moduleService){
-    if ($moduleService->isInstall($row['slug'])){
+    if ($row['slug'] !== 'kernel') {
+        if ($moduleService->isInstall($row['slug'])) {
            $url = "$url/delete/?slug=" . $row['slug'];

            return \kernel\widgets\IconBtn\IconBtnDeleteWidget::create(['url' => $url])->run();
-    }
-    else {
+        } else {
            $url = "$url/install/?id=" . $row['id'];

            return \kernel\widgets\IconBtn\IconBtnInstallWidget::create(['url' => $url])->run();
        }
+    }
+    return null;
 });

-$table->addAction(function ($row, $url) use ($moduleService){
+$table->addAction(function ($row, $url) use ($moduleService) {
    $slug = $row['slug'];
-    if ($moduleService->isInstall($slug)){
+    if ($moduleService->isInstall($slug)) {
        if (!$moduleService->isLastVersion($slug)) {
            $url = "$url/update/?slug=" . $slug;

@ -62,6 +66,35 @@ $table->addAction(function ($row, $url) use ($moduleService){
    return false;
 });

+$table->addAction(function ($row, $url) use ($kernelService) {
+    $slug = $row['slug'];
+    if ($slug === 'kernel') {
+        if (!$kernelService->isLastVersion()) {
+            $url = "$url/kernel/update_form/";
+
+            return \kernel\widgets\IconBtn\IconBtnUpdateWidget::create(['url' => $url])->run();
+        }
+    }
+
+    return false;
+});
+
+$table->addAction(function ($row, $url) use ($adminThemeService) {
+    $type = $row['type'];
+    $slug = $row['slug'];
+    if ($type === 'admin_theme') {
+        if ($adminThemeService->isInstall($slug)) {
+            if (!$adminThemeService->isLastVersion($slug)) {
+                $url = "$url/admin_theme/update/";
+
+                return \kernel\widgets\IconBtn\IconBtnUpdateWidget::create(['url' => $url])->run();
+            }
+        }
+    }
+
+    return false;
+});
+
 \kernel\widgets\ModuleTabsWidget::create()->run();

 $table->create();
--- a/kernel/modules/module_shop_client/views/kernel_update.php
+++ b/kernel/modules/module_shop_client/views/kernel_update.php
@ -0,0 +1,39 @@
+<?php
+
+use itguild\forms\ActiveForm;
+
+\kernel\widgets\ModuleTabsWidget::create()->run();
+
+echo \kernel\helpers\Html::h(2, "Выберите нужные файлы для обновления");
+
+$form = new ActiveForm();
+$form->beginForm("/admin/module_shop_client/kernel/update/", enctype: 'multipart/form-data');
+
+$form->field(\itguild\forms\inputs\Select::class, "files[]", [
+    'class' => "form-control",
+    'multiple' => "multiple",
+])
+    ->setLabel("Дополнительные файлы")
+    ->setOptions([
+        '.env.example' => '.env.example',
+        'bootstrap.php' => 'bootstrap',
+        'composer.json' => 'composer.json',
+    ])
+    ->render();
+?>
+
+    <div class="row">
+        <div class="col-sm-2">
+            <?php
+            $form->field(\itguild\forms\inputs\Button::class, name: "btn-submit", params: [
+                'class' => "btn btn-primary ",
+                'value' => 'Отправить',
+                'typeInput' => 'submit'
+            ])
+                ->render();
+            ?>
+        </div>
+
+    </div>
+<?php
+$form->endForm();
--- a/kernel/services/AdminThemeService.php
+++ b/kernel/services/AdminThemeService.php
@ -2,20 +2,24 @@

 namespace kernel\services;

+use DirectoryIterator;
 use kernel\helpers\Debug;
 use kernel\helpers\Manifest;
+use kernel\helpers\RESTClient;
 use kernel\models\Option;

 class AdminThemeService
 {
    protected Option $option;
    protected string $active_theme;
+    protected ModuleService $moduleService;


    public function __construct()
    {
        $this->option = new Option();
        $this->findActiveAdminTheme();
+        $this->moduleService = new ModuleService();
    }

    public function findActiveAdminTheme(): void
@ -56,4 +60,43 @@ class AdminThemeService
        return $info;
    }

+    public function isInstall(string $slug): bool
+    {
+        $adminThemePaths = Option::where("key", "admin_theme_paths")->first();
+        $dirs = [];
+        if ($adminThemePaths) {
+            $path = json_decode($adminThemePaths->value);
+            foreach ($path->paths as $p) {
+                $dirs[] = getConst($p);
+            }
+        }
+        foreach ($dirs as $dir) {
+            foreach (new DirectoryIterator($dir) as $fileInfo) {
+                if ($fileInfo->isDot()) continue;
+                if ($this->getAdminThemeInfo($fileInfo->getPathname())['slug'] === $slug) {
+                    return true;
+                }
+            }
+        }
+
+        return false;
+    }
+
+    public function isLastVersion(string $slug): bool
+    {
+        if ($this->moduleService->isServerAvailable()) {
+            $modules_info = RESTClient::request($_ENV['MODULE_SHOP_URL'] . '/api/module_shop/gb_slug');
+
+            $modules_info = json_decode($modules_info->getBody()->getContents(), true);
+
+            $themeInfo = $this->getAdminThemeInfo($slug);
+            foreach ($modules_info as $mod) {
+                if ($mod['slug'] === $themeInfo['slug'] && $mod['version'] === $themeInfo['version']) {
+                    return true;
+                }
+            }
+        }
+
+        return false;
+    }
 }
--- a/kernel/services/KernelService.php
+++ b/kernel/services/KernelService.php
@ -0,0 +1,88 @@
+<?php
+
+namespace kernel\services;
+
+use kernel\helpers\Debug;
+use kernel\helpers\Files;
+use kernel\helpers\Manifest;
+use kernel\helpers\RESTClient;
+use kernel\Request;
+use ZipArchive;
+
+class KernelService
+{
+    protected null|bool $serverAvailable = null;
+    protected ModuleService $moduleService;
+    protected Files $files;
+
+    public function __construct()
+    {
+        $this->moduleService = new ModuleService();
+        $this->files = new Files();
+    }
+
+    public function getKernelInfo(): false|array|string
+    {
+        $info = [];
+        $info['path'] = KERNEL_DIR;
+        if (file_exists(KERNEL_DIR . "/manifest.json")) {
+            $manifest = json_decode(file_get_contents(KERNEL_DIR . "/manifest.json"), true);
+            $manifest = getConst($manifest);
+            $info = array_merge($info, $manifest);
+        }
+
+        return $info;
+    }
+
+    public function isLastVersion(): bool
+    {
+        if ($this->moduleService->isServerAvailable()) {
+            $modules_info = RESTClient::request($_ENV['MODULE_SHOP_URL'] . '/api/module_shop/gb_slug');
+
+            $modules_info = json_decode($modules_info->getBody()->getContents(), true);
+
+            $kernel_info = $this->getKernelInfo();
+            foreach ($modules_info as $mod) {
+                if ($mod['slug'] === $kernel_info['slug'] && $mod['version'] === $kernel_info['version']) {
+                    return true;
+                }
+            }
+        }
+
+        return false;
+    }
+
+    public function updateKernel(string $path): bool
+    {
+        $request = new Request();
+        $files = $request->post('files');
+        
+        $zip = new ZipArchive;
+        if (file_exists(ROOT_DIR . $path)) {
+            $tmpKernelDir = md5(time());
+            $res = $zip->open(ROOT_DIR . $path);
+            if ($res === TRUE) {
+                $tmpKernelDirFull = RESOURCES_DIR . '/tmp/kernel/' . $tmpKernelDir . "/";
+                $zip->extractTo($tmpKernelDirFull);
+                $zip->close();
+                $this->files->recursiveRemoveKernelDir();
+                $this->files->copy_folder($tmpKernelDirFull . 'kernel' , ROOT_DIR . "/kernel");
+
+                foreach ($files as $file) {
+                    if ($file === 'bootstrap') {
+                        $this->files->recursiveRemoveDir(ROOT_DIR . '/bootstrap');
+                        $this->files->copy_folder($tmpKernelDirFull . 'bootstrap' , ROOT_DIR . '/bootstrap');
+                    }
+                    copy($tmpKernelDirFull . $file , ROOT_DIR . '/' . $file);
+                }
+
+                $this->files->recursiveRemoveDir($tmpKernelDirFull);
+                unlink(ROOT_DIR . $path);
+
+                return true;
+            }
+        }
+
+        return false;
+    }
+}
--- a/kernel/services/ModuleService.php
+++ b/kernel/services/ModuleService.php
@ -10,7 +10,6 @@ use kernel\helpers\Files;
 use kernel\helpers\Manifest;
 use kernel\helpers\RESTClient;
 use kernel\models\Option;
-use MongoDB\Driver\Session;
 use ZipArchive;

 class ModuleService
@ -448,6 +447,7 @@ class ModuleService
            $modules_info = RESTClient::request($_ENV['MODULE_SHOP_URL'] . '/api/module_shop/gb_slug');

            $modules_info = json_decode($modules_info->getBody()->getContents(), true);
+
            $mod_info = $this->getModuleInfoBySlug($slug);
            foreach ($modules_info as $mod) {
                if ($mod['slug'] === $mod_info['slug'] && $mod['version'] === $mod_info['version']) {
@ -481,6 +481,7 @@ class ModuleService
            }

            $modules_info = json_decode($modules_info->getBody()->getContents(), true);
+            if (isset($modules_info)) {
                $mod_info = $this->getModuleInfoBySlug($slug);
                foreach ($modules_info as $mod) {
                    if ($mod['slug'] === $mod_info['slug']) {
@ -488,6 +489,7 @@ class ModuleService
                    }
                }
            }
+        }

        return false;
    }