Jingga/phpOMS
1
0
Fork 0
mirror of https://github.com/Karaka-Management/phpOMS.git synced 2026-02-14 23:48:40 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Remove todos and make use of query builder

Browse Source
This commit is contained in:
Dennis Eichhorn 2018-09-08 18:22:34 +02:00
parent 7a5f75eedc
commit 39635c1115
4 changed files with 47 additions and 81 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
Config/SettingsAbstract.php
View File

@ -82,7 +82,6 @@ abstract class SettingsAbstract implements OptionsInterface
* @return mixed Option value
*
* @since 1.0.0
* @todo: don't db request if exists. check exists()
*/
public function get($columns)
{

2
DataStorage/Session/SessionInterface.php
View File

@ -65,8 +65,6 @@ interface SessionInterface
/**
* Save session.
*
* @todo : implement save type (session, cache, database)
*
* @return void
*
* @since 1.0.0

2
Localization/Localization.php
View File

@ -251,8 +251,6 @@ final class Localization
*
* @return void
*
* @todo : maybe make parameter int
*
* @since 1.0.0
*/
public function setTimezone(string $timezone) : void

119
Module/ModuleManager.php
View File

@ -22,6 +22,7 @@ use phpOMS\Message\Http\Request;
use phpOMS\Message\RequestAbstract;
use phpOMS\System\File\PathException;
use phpOMS\Module\Exception\InvalidModuleException;
use phpOMs\DataStorage\Database\Query\Builder;
/**
* Modules class.
@ -141,44 +142,19 @@ final class ModuleManager
public function getUriLoad(RequestAbstract $request) : array
{
if ($this->uriLoad === null) {
switch ($this->app->dbPool->get('select')->getType()) {
case DatabaseType::MYSQL:
$uriHash = $request->getHash();
$uriPdo = '';
$uriHash = $request->getHash();
$uriPdo = '';
$i = 1;
$c = \count($uriHash);
$query = new Builder($this->app->dbPool->get('select'));
$query->prefix($this->app->dbPool->get('select')->prefix);
$sth = $query->select('module_load.module_load_type', 'module_load.*')
->from('module_load')
->innerJoin('module')->on('module_load.module_load_from', '=', 'module.module_id')->orOn('module_load.module_load_for', '=', 'module.module_id')
->whereIn('module_load.module_load_pid', $uriHash)
->andWhere('module.module_active', '=', 1)
->execute();
for ($k = 0; $k < $c; ++$k) {
$uriPdo .= ':pid' . $i . ',';
++$i;
}
$uriPdo = \rtrim($uriPdo, ',');
/* TODO: make join in order to see if they are active */
$sth = $this->app->dbPool->get('select')->con->prepare(
'SELECT
`' . $this->app->dbPool->get('select')->prefix . 'module_load`.`module_load_type`, `' . $this->app->dbPool->get('select')->prefix . 'module_load`.*
FROM
`' . $this->app->dbPool->get('select')->prefix . 'module_load`
WHERE
`module_load_pid` IN(' . $uriPdo . ')'
);
$i = 1;
foreach ($uriHash as $hash) {
$sth->bindValue(':pid' . $i, $hash, \PDO::PARAM_STR);
++$i;
}
$sth->execute();
$this->uriLoad = $sth->fetchAll(\PDO::FETCH_GROUP);
break;
default:
throw new InvalidDatabaseTypeException($this->app->dbPool->get('select')->getType());
}
$this->uriLoad = $sth->fetchAll(\PDO::FETCH_GROUP);
}
return $this->uriLoad;
@ -196,32 +172,30 @@ final class ModuleManager
public function getActiveModules(bool $useCache = true) : array
{
if (empty($this->active) || !$useCache) {
switch ($this->app->dbPool->get('select')->getType()) {
case DatabaseType::MYSQL:
$sth = $this->app->dbPool->get('select')->con->prepare('SELECT `module_path` FROM `' . $this->app->dbPool->get('select')->prefix . 'module` WHERE `module_active` = 1');
$sth->execute();
$active = $sth->fetchAll(\PDO::FETCH_COLUMN);
$query = new Builder($this->app->dbPool->get('select'));
$query->prefix($this->app->dbPool->get('select')->prefix);
$sth = $query->select('module.module_path')
->from('module')
->where('module.module_active', '=', 1)
->execute();
foreach ($active as $module) {
$path = $this->modulePath . '/' . $module . '/info.json';
$active = $sth->fetchAll(\PDO::FETCH_COLUMN);
if (!\file_exists($path)) {
continue;
// throw new PathException($path);
}
foreach ($active as $module) {
$path = $this->modulePath . '/' . $module . '/info.json';
$content = \file_get_contents($path);
$json = \json_decode($content === false ? '[]' : $content, true);
$this->active[$json['name']['internal']] = $json === false ? [] : $json;
}
break;
default:
throw new InvalidDatabaseTypeException($this->app->dbPool->get('select')->getType());
if (!\file_exists($path)) {
continue;
// throw new PathException($path);
}
$content = \file_get_contents($path);
$json = \json_decode($content === false ? '[]' : $content, true);
$this->active[$json['name']['internal']] = $json === false ? [] : $json;
}
}
return $this->active;
}
@ -294,28 +268,25 @@ final class ModuleManager
public function getInstalledModules(bool $useCache = true) : array
{
if (empty($this->installed) || !$useCache) {
switch ($this->app->dbPool->get('select')->getType()) {
case DatabaseType::MYSQL:
$sth = $this->app->dbPool->get('select')->con->prepare('SELECT `module_path` FROM `' . $this->app->dbPool->get('select')->prefix . 'module`');
$sth->execute();
$installed = $sth->fetchAll(\PDO::FETCH_COLUMN);
$query = new Builder($this->app->dbPool->get('select'));
$query->prefix($this->app->dbPool->get('select')->prefix);
$sth = $query->select('module.module_path')
->from('module')
->execute();
foreach ($installed as $module) {
$path = $this->modulePath . '/' . $module . '/info.json';
$installed = $sth->fetchAll(\PDO::FETCH_COLUMN);
if (!\file_exists($path)) {
continue;
// throw new PathException($path);
}
foreach ($installed as $module) {
$path = $this->modulePath . '/' . $module . '/info.json';
$content = \file_get_contents($path);
$json = \json_decode($content === false ? '[]' : $content, true);
$this->installed[$json['name']['internal']] = $json === false ? [] : $json;
}
if (!\file_exists($path)) {
continue;
// throw new PathException($path);
}
break;
default:
throw new InvalidDatabaseTypeException($this->app->dbPool->get('select')->getType());
$content = \file_get_contents($path);
$json = \json_decode($content === false ? '[]' : $content, true);
$this->installed[$json['name']['internal']] = $json === false ? [] : $json;
}
}