suda\application\loader\ApplicationLoader

Complexity

Total Complexity

42

Size/Duplication

Total Lines	277
Duplicated Lines	0 %

Importance

Changes	6
Bugs	0	Features	0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	loadModule()	0	20	3
A	loadRoute()	0	22	4
A	load()	0	7	1
A	loadModuleFromBag()	0	6	3
A	setModuleStatus()	0	6	1
A	loadDataSource()	0	5	1
A	prepareModuleConfig()	0	13	1
A	registerModule()	0	6	2
A	loadGlobalConfig()	0	8	3
A	activeModule()	0	5	3
A	prepareModule()	0	6	2
A	loadRouteFromModules()	0	5	3
A	setModuleActive()	0	5	3
A	__construct()	0	5	1
A	isDebug()	0	3	2
A	getModuleDirectoryConfig()	0	8	2
A	registerModuleFrom()	0	7	2
A	loadVendorIfExist()	0	5	2
A	setModuleReachable()	0	5	3

<?php

namespace suda\application\loader;

use suda\framework\Cache;
use suda\framework\Config;
use suda\application\Module;
use suda\application\Resource;
use suda\application\ModuleBag;
use suda\application\Application;
use suda\application\database\Database;
use suda\database\exception\SQLException;
use suda\framework\filesystem\FileSystem;
use suda\application\builder\ModuleBuilder;
use suda\framework\loader\Loader;
use suda\framework\runnable\Runnable;

/**
 * 应用程序
 */
class ApplicationLoader
{
    /**
     * 应用程序
     *
     * @var Application
     */
    protected $application;

    /**
     * 模块加载器
     *
     * @var ModuleLoader[]
     */
    protected $moduleLoader;


    /**
     * @var array
     */
    protected $actionableModules;

    /**
     * @var array
     */
    protected $reachableModules;

    public function __construct(Application $application)
    {
        $this->application = $application;
        $this->actionableModules = [];
        $this->reachableModules = [];
    }

    /**
     * 加载APP
     */
    public function load()
    {
        $this->loadVendorIfExist();
        $this->loadGlobalConfig();
        $this->loadModule();
        $this->prepareModule();
        $this->activeModule();
    }

    /**
     * 加载模块
     */
    protected function loadModule()
    {
        $name = 'application-module';
        $this->application->debug()->time($name);
        // 调试模式不缓存
        if (static::isDebug()) {
            $this->registerModule();
            $this->setModuleStatus();
        } else {
            if ($this->application->cache()->has($name)) {
                $module = $this->application->cache()->get($name);
                $this->application->setModule($module);
                $this->application->debug()->info('load modules from cache');
            } else {
                $this->registerModule();
                $this->setModuleStatus();
                $this->application->cache()->set($name, $this->application->getModules());
            }
        }
        $this->application->debug()->timeEnd($name);
    }

    /**
     * 调试模式
     *
     * @return bool
     */
    public static function isDebug()
    {
        return boolval(defined('SUDA_DEBUG') ? constant('SUDA_DEBUG') : false);
    }

    /**
     * 加载路由
     */
    public function loadRoute()
    {
        $name = 'application-route';
        $this->application->debug()->time($name);
        if (static::isDebug()) {
            $this->loadRouteFromModules();
        } elseif ($this->application->cache()->has($name.'-route')) {
            $route = $this->application->cache()->get($name.'-route');
            $runnable = $this->application->cache()->get($name.'-runnable');
            $this->application->getRoute()->setRouteCollection($route);
            $this->application->getRoute()->setRunnable($runnable);
            $this->application->debug()->info('load route from cache');
        } else {
            $this->loadRouteFromModules();
            if ($this->application->getRoute()->isContainClosure()) {
                $this->application->debug()->warning('route contain closure, route prepare cannot be cacheables');
            } else {
                $this->application->cache()->set($name.'-route', $this->application->getRoute()->getRouteCollection());
                $this->application->cache()->set($name.'-runnable', $this->application->getRoute()->getRunnable());
            }
        }
        $this->application->debug()->timeEnd($name);
    }

    protected function loadRouteFromModules()
    {
        foreach ($this->application->getModules() as $name => $module) {
            if ($module->getStatus() === Module::REACHABLE) {
                call_user_func([$this->moduleLoader[$name], 'toReachable']);
            }
        }
    }

    /**
     * 加载全局配置
     */
    public function loadGlobalConfig()
    {
        $resource = $this->application->getResource();
        if ($configPath = $resource->getConfigResourcePath('config/config')) {
            $this->application->getConfig()->load($configPath);
        }
        if ($listenerPath = $resource->getConfigResourcePath('config/listener')) {
            $this->application->loadEvent($listenerPath);
        }
    }

    /**
     * 加载额外vendor
     */
    public function loadVendorIfExist()
    {
        $vendorAutoload = $this->application->getPath() . '/vendor/autoload.php';
        if (FileSystem::exist($vendorAutoload)) {
            Loader::requireOnce($vendorAutoload);
        }
    }

    /**
     * 准备数据源
     *
     * @throws SQLException
     */
    public function loadDataSource()
    {
        Database::loadApplication($this->application);
        $dataSource = Database::getDefaultDataSource();
        $this->application->setDataSource($dataSource);
    }

    /**
     * 准备模块
     */
    protected function prepareModule()
    {
        foreach ($this->application->getModules()->all() as $name => $module) {
            $this->moduleLoader[$name] = new ModuleLoader($this->application, $module);
            $this->moduleLoader[$name]->toLoad(); // 切换到加载状态
            $this->moduleLoader[$name]->loadExtraModuleResourceLibrary(); // 加载二外的模块源
        }
    }

    /**
     * 激活模块
     */
    protected function activeModule()
    {
        foreach ($this->application->getModules()->all() as $name => $module) {
            if ($module->getStatus() !== Module::LOADED) {
                $this->moduleLoader[$name]->toActive();
            }
        }
    }

    /**
     * 注册模块
     */
    protected function registerModule()
    {
        $extractPath = $this->application->getDataPath() . '/extract-module';
        FileSystem::make($extractPath);
        foreach ($this->application->getModulePaths() as $path) {
            $this->registerModuleFrom($path, $extractPath);
        }
    }

    /**
     * 设置模块状态
     */
    protected function setModuleStatus()
    {
        $active = $this->application->getManifest('module.active', $this->actionableModules);
        $reachable = $this->application->getManifest('module.reachable', $this->reachableModules);
        $this->setModuleActive($this->application->getModules(), $active);
        $this->setModuleReachable($this->application->getModules(), $reachable);
    }

    /**
     * 注册模块下的模块
     *
     * @param string $path
     * @param string $extractPath
     */
    protected function registerModuleFrom(string $path, string $extractPath)
    {
        $modules = new ModuleBag;
        foreach (ModuleBuilder::scan($path, $extractPath) as $module) {
            $modules->add($module);
        }
        $this->prepareModuleConfig($path, $modules);
    }

    /**
     * 获取模块的配置
     *
     * @param string $path
     * @param ModuleBag $modules
     */
    protected function prepareModuleConfig(string $path, ModuleBag $modules)
    {
        $config = $this->getModuleDirectoryConfig($path);
        $moduleNames = array_keys($modules->all());
        // 获取模块文件夹模块配置
        $load = $config['load'] ?? $moduleNames;
        $active = $config['active'] ?? $load;
        $reachable = $config['reachable'] ?? $active;
        // 获取允许加载的模块
        $load = $this->application->getManifest('module.load', $load);
        $this->loadModuleFromBag($modules, $load);
        $this->actionableModules = array_merge($this->actionableModules, $active);
        $this->reachableModules = array_merge($this->reachableModules, $reachable);
    }

    /**
     * 获取目录的模板配置
     *
     * @param string $path
     * @return array
     */
    protected function getModuleDirectoryConfig(string $path)
    {
        $resource = new Resource([$path]);
        $configPath = $resource->getConfigResourcePath('config');
        if ($configPath) {
            return Config::loadConfig($configPath, $this->application->getConfig()) ?? [];
        }
        return [];
    }

    protected function loadModuleFromBag(ModuleBag $bag, array $load)
    {
        foreach ($load as $moduleName) {
            if ($module = $bag->get($moduleName)) {
                $module->setStatus(Module::LOADED);
                $this->application->add($module);
            }
        }
    }

    protected function setModuleActive(ModuleBag $bag, array $active)
    {
        foreach ($active as $moduleName) {
            if ($module = $bag->get($moduleName)) {
                $module->setStatus(Module::ACTIVE);
            }
        }
    }

    protected function setModuleReachable(ModuleBag $bag, array $reachable)
    {
        foreach ($reachable as $moduleName) {
            if ($module = $bag->get($moduleName)) {
                $module->setStatus(Module::REACHABLE);
            }
        }
    }
}