ApplicationLoader::getDataSourceGroup() - Code Metrics - Inspection of "修复：资源重定义" - dxkite/suda - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( fbcc8b...a5456c )

by 世昌

created 2019-05-13 04:03 UTC

ApplicationLoader::getDataSourceGroup() A

↳ Parent: ApplicationLoader

Complexity

Conditions	4
Paths	4

Size

Total Lines	20
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	4
eloc	15
nc	4
nop	1
dl	0
loc	20
rs	9.7666
c	0
b	0
f	0

<?php
namespace suda\application\loader;

use function strtolower;
use suda\orm\DataSource;
use suda\framework\Config;
use suda\application\Module;
use suda\application\Resource;
use suda\application\ModuleBag;
use suda\application\Application;
use suda\framework\filesystem\FileSystem;
use suda\orm\connection\observer\Observer;
use suda\application\builder\ModuleBuilder;
use suda\application\database\DebugObserver;
use suda\orm\exception\SQLException;

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

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


    public function __construct(Application $application)
    {
        $this->application = $application;
    }

    public function load()
    {
        $this->loadVendorIfExist();
        $this->loadGlobalConfig();
        $this->registerModule();
        $this->prepareModule();
        $this->activeModule();
    }


    public function loadRoute()
    {
        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);
        }
    }

    public function loadVendorIfExist()
    {
        $vendorAutoload = $this->application->getPath().'/vendor/autoload.php';
        if (FileSystem::exist($vendorAutoload)) {
            require_once $vendorAutoload;
        }
    }

    /**
     * @throws SQLException
     */
    public function loadDataSource()
    {
        $dataSource = $this->getDataSourceGroup('default');
        $this->application->setDataSource($dataSource);
    }

    /**
     * @param string $groupName
     * @return DataSource
     * @throws SQLException
     */
    public function getDataSourceGroup(string $groupName):DataSource
    {
        $group = $groupName === 'default' ? '': '-'. $groupName;
        $dataSourceConfigPath = $this->application->getResource()->getConfigResourcePath('config/data-source'.$group);
        $dataSource = new DataSource;
        $observer = new DebugObserver($this->application->debug());
        if ($dataSourceConfigPath !== null) {
            $dataSourceConfig = Config::loadConfig($dataSourceConfigPath);
            foreach ($dataSourceConfig as $name => $config) {
                $this->addDataSource(
                    $dataSource,
                    $observer,
                    $name,
                    $config['type'] ?? 'mysql',
                    $config['mode'] ?? '',
                    $config
                );
            }
        }
        return $dataSource;
    }

    /**
     * @param DataSource $source
     * @param Observer $observer
     * @param string $name
     * @param string $type
     * @param string $mode
     * @param array $config
     * @throws SQLException
     */
    protected function addDataSource(
        DataSource $source,
        Observer $observer,
        string $name,
        string $type,
        string $mode,
        array $config
    ) {
        $mode = strtolower($mode);
        $data = DataSource::new($type, $config, $name);
        $data->setObserver($observer);
        if (strlen($mode) > 0) {
            if (strpos($mode, 'read') !== false || strpos($mode, 'slave') !== false) {
                $source->addRead($data);
            }
            if (strpos($mode, 'write') !== false) {
                $source->addWrite($data);
            }
            if (strpos($mode, 'master') !== false) {
                $source->add($data);
            }
        } else {
            $source->add($data);
        }
    }

    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 = SUDA_DATA .'/extract-module';
        FileSystem::make($extractPath);
        foreach ($this->application->getModulePaths() as $path) {
            $this->registerModuleFrom($path, $extractPath);
        }
    }

    protected function registerModuleFrom(string $path, string $extractPath)
    {
        $modules = new ModuleBag;
        foreach (ModuleBuilder::scan($path, $extractPath) as $module) {
            $modules->add($module);
        }
        $this->assignModuleToApplication($path, $modules);
    }

    protected function assignModuleToApplication(string $path, ModuleBag $modules)
    {
        $resource = new Resource([$path]);
        $configPath = $resource->getConfigResourcePath('config');
        $config = null;
        if ($configPath) {
            $config = Config::loadConfig($configPath, $this->application->getConfig());
        }
        $config = $config ?? [];
        $moduleNames = array_keys($modules->all());
        $load  = $config['load'] ?? $moduleNames;
        $this->loadModules($modules, $load);
        $active = $config['active'] ?? $load;
        $this->setModuleActive($modules, $active);
        $this->setModuleReachable($modules, $config['reachable'] ?? $active);
    }



    protected function loadModules(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);
            }
        }
    }
}


1			<?php
2			namespace suda\application\loader;
3
4			use function strtolower;
5			use suda\orm\DataSource;
6			use suda\framework\Config;
7			use suda\application\Module;
8			use suda\application\Resource;
9			use suda\application\ModuleBag;
10			use suda\application\Application;
11			use suda\framework\filesystem\FileSystem;
12			use suda\orm\connection\observer\Observer;
13			use suda\application\builder\ModuleBuilder;
14			use suda\application\database\DebugObserver;
15			use suda\orm\exception\SQLException;
16
17			/**
18			* 应用程序
19			*/
20			class ApplicationLoader
21			{
22			/**
23			* 应用程序
24			*
25			* @var Application
26			*/
27			protected $application;
28
29			/**
30			* 模块加载器
31			*
32			* @var ModuleLoader[]
33			*/
34			protected $moduleLoader;
35
36
37			public function __construct(Application $application)
38			{
39			$this->application = $application;
40			}
41
42			public function load()
43			{
44			$this->loadVendorIfExist();
45			$this->loadGlobalConfig();
46			$this->registerModule();
47			$this->prepareModule();
48			$this->activeModule();
49			}
50
51
52			public function loadRoute()
53			{
54			foreach ($this->application->getModules() as $name => $module) {
55			if ($module->getStatus() === Module::REACHABLE) {
56			call_user_func([$this->moduleLoader[$name],'toReachable']);
57			}
58			}
59			}
60
61
62			public function loadGlobalConfig()
63			{
64			$resource = $this->application->getResource();
65			if ($configPath = $resource->getConfigResourcePath('config/config')) {
66			$this->application->getConfig()->load($configPath);
67			}
68			if ($listenerPath = $resource->getConfigResourcePath('config/listener')) {
69			$this->application->loadEvent($listenerPath);
70			}
71			}
72
73			public function loadVendorIfExist()
74			{
75			$vendorAutoload = $this->application->getPath().'/vendor/autoload.php';
76			if (FileSystem::exist($vendorAutoload)) {
77			require_once $vendorAutoload;
78			}
79			}
80
81			/**
82			* @throws SQLException
83			*/
84			public function loadDataSource()
85			{
86			$dataSource = $this->getDataSourceGroup('default');
87			$this->application->setDataSource($dataSource);
88			}
89
90			/**
91			* @param string $groupName
92			* @return DataSource
93			* @throws SQLException
94			*/
95			public function getDataSourceGroup(string $groupName):DataSource
96			{
97			$group = $groupName === 'default' ? '': '-'. $groupName;
98			$dataSourceConfigPath = $this->application->getResource()->getConfigResourcePath('config/data-source'.$group);
99			$dataSource = new DataSource;
100			$observer = new DebugObserver($this->application->debug());
101			if ($dataSourceConfigPath !== null) {
102			$dataSourceConfig = Config::loadConfig($dataSourceConfigPath);
103			foreach ($dataSourceConfig as $name => $config) {
104			$this->addDataSource(
105			$dataSource,
106			$observer,
107			$name,
108			$config['type'] ?? 'mysql',
109			$config['mode'] ?? '',
110			$config
111			);
112			}
113			}
114			return $dataSource;
115			}
116
117			/**
118			* @param DataSource $source
119			* @param Observer $observer
120			* @param string $name
121			* @param string $type
122			* @param string $mode
123			* @param array $config
124			* @throws SQLException
125			*/
126			protected function addDataSource(
127			DataSource $source,
128			Observer $observer,
129			string $name,
130			string $type,
131			string $mode,
132			array $config
133			) {
134			$mode = strtolower($mode);
135			$data = DataSource::new($type, $config, $name);
136			$data->setObserver($observer);
137			if (strlen($mode) > 0) {
138			if (strpos($mode, 'read') !== false \|\| strpos($mode, 'slave') !== false) {
139			$source->addRead($data);
140			}
141			if (strpos($mode, 'write') !== false) {
142			$source->addWrite($data);
143			}
144			if (strpos($mode, 'master') !== false) {
145			$source->add($data);
146			}
147			} else {
148			$source->add($data);
149			}
150			}
151
152			protected function prepareModule()
153			{
154			foreach ($this->application->getModules()->all() as $name => $module) {
155			$this->moduleLoader[$name] = new ModuleLoader($this->application, $module);
156			$this->moduleLoader[$name]->toLoad();
157			$this->moduleLoader[$name]->loadExtraModuleResourceLibrary();
158			}
159			}
160
161			protected function activeModule()
162			{
163			foreach ($this->application->getModules()->all() as $name => $module) {
164			if ($module->getStatus() !== Module::LOADED) {
165			$this->moduleLoader[$name]->toActive();
166			}
167			}
168			}
169
170			protected function registerModule()
171			{
172			$extractPath = SUDA_DATA .'/extract-module';
173			FileSystem::make($extractPath);
174			foreach ($this->application->getModulePaths() as $path) {
175			$this->registerModuleFrom($path, $extractPath);
176			}
177			}
178
179			protected function registerModuleFrom(string $path, string $extractPath)
180			{
181			$modules = new ModuleBag;
182			foreach (ModuleBuilder::scan($path, $extractPath) as $module) {
183			$modules->add($module);
184			}
185			$this->assignModuleToApplication($path, $modules);
186			}
187
188			protected function assignModuleToApplication(string $path, ModuleBag $modules)
189			{
190			$resource = new Resource([$path]);
191			$configPath = $resource->getConfigResourcePath('config');
192			$config = null;
193			if ($configPath) {
194			$config = Config::loadConfig($configPath, $this->application->getConfig());
195			}
196			$config = $config ?? [];
197			$moduleNames = array_keys($modules->all());
198			$load = $config['load'] ?? $moduleNames;
199			$this->loadModules($modules, $load);
200			$active = $config['active'] ?? $load;
201			$this->setModuleActive($modules, $active);
202			$this->setModuleReachable($modules, $config['reachable'] ?? $active);
203			}
204
205
206
207			protected function loadModules(ModuleBag $bag, array $load)
208			{
209			foreach ($load as $moduleName) {
210			if ($module = $bag->get($moduleName)) {
211			$module->setStatus(Module::LOADED);
212			$this->application->add($module);
213			}
214			}
215			}
216
217			protected function setModuleActive(ModuleBag $bag, array $active)
218			{
219			foreach ($active as $moduleName) {
220			if ($module = $bag->get($moduleName)) {
221			$module->setStatus(Module::ACTIVE);
222			}
223			}
224			}
225
226			protected function setModuleReachable(ModuleBag $bag, array $reachable)
227			{
228			foreach ($reachable as $moduleName) {
229			if ($module = $bag->get($moduleName)) {
230			$module->setStatus(Module::REACHABLE);
231			}
232			}
233			}
234			}
235

dxkite / suda

Push — master ( fbcc8b...a5456c )

ApplicationLoader::getDataSourceGroup() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like