Jingga/oms-Exchange
1
0
Fork 0
mirror of https://github.com/Karaka-Management/oms-Exchange.git synced 2026-02-05 12:38:41 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

bug fixes and permission tests

Browse Source
This commit is contained in:
Dennis Eichhorn 2022-01-22 21:56:00 +01:00
parent 435a1455fa
commit bfd8c6dd62
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
Controller/ApiController.php
View File

@ -19,6 +19,7 @@ use Modules\Exchange\Models\InterfaceManager;
use Modules\Exchange\Models\InterfaceManagerMapper;
use Modules\Media\Models\UploadFile;
use phpOMS\Autoloader;
use phpOMS\DataStorage\Database\Connection\ConnectionFactory;
use phpOMS\DataStorage\Database\Connection\NullConnection;
use phpOMS\Localization\L11nManager;
use phpOMS\Message\Http\HttpResponse;
@ -89,12 +90,26 @@ final class ApiController extends Controller
$interface = InterfaceManagerMapper::get()->where('id', $request->getData('id'))->execute();
$dirname = \basename(\dirname($interface->getPath()));
if (!Autoloader::exists($class = '\\Modules\\Exchange\\Interfaces\\' . $dirname . '\\Importer')) {
/** @var class-string<\Modules\Exchange\Models\ImporterAbstract> $class */
$class = '\\Modules\\Exchange\\Interfaces\\' . $dirname . '\\Importer';
if (!Autoloader::exists($class)) {
return [];
}
// @todo: implement real remote connection if available
$importer = new $class($this->app->dbPool->get(), new NullConnection(), new L11nManager($this->app->appName));
$remoteConnection = new NullConnection();
if (!empty($request->getData('dbtype'))) {
$remoteConnection = ConnectionFactory::create([
'db' => $request->getData('dbtype') ?? null,
'host' => $request->getData('dbhost') ?? null,
'port' => $request->getData('dbport') ?? null,
'database' => $request->getData('dbdatabase') ?? null,
'login' => $request->getData('dblogin') ?? null,
'password' => $request->getData('dbpassword') ?? null,
]);
}
/** @var \Modules\Exchange\Models\ImporterAbstract $importer */
$importer = new $class($this->app->dbPool->get(), $remoteConnection, new L11nManager($this->app->appName));
return $importer->importFromRequest($request);
}