mirror of
https://github.com/alchemy-fr/Phraseanet.git
synced 2025-10-17 15:03:25 +00:00
DataboxesController Refactor, CS fixup
This commit is contained in:
Benoît Burnichon
340
lib/Alchemy/Phrasea/Controller/Admin/DataboxesController.php
Normal file
340
lib/Alchemy/Phrasea/Controller/Admin/DataboxesController.php
Normal file
@@ -0,0 +1,340 @@
|
||||
<?php
|
||||
/*
|
||||
* This file is part of Phraseanet
|
||||
*
|
||||
* (c) 2005-2015 Alchemy
|
||||
*
|
||||
* For the full copyright and license information, please view the LICENSE
|
||||
* file that was distributed with this source code.
|
||||
*/
|
||||
|
||||
namespace Alchemy\Phrasea\Controller\Admin;
|
||||
|
||||
use Alchemy\Phrasea\Application;
|
||||
use Alchemy\Phrasea\Authentication\ACLProvider;
|
||||
use Alchemy\Phrasea\Authentication\Authenticator;
|
||||
use Alchemy\Phrasea\Model\Entities\User;
|
||||
use Doctrine\DBAL\Connection;
|
||||
use Doctrine\DBAL\DBALException;
|
||||
use Symfony\Component\HttpFoundation\RedirectResponse;
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
|
||||
class DataboxesController
|
||||
{
|
||||
/** @var Application */
|
||||
private $app;
|
||||
|
||||
public function __construct(Application $app)
|
||||
{
|
||||
$this->app = $app;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get Databases control panel
|
||||
*
|
||||
* @param Request $request
|
||||
* @return Response
|
||||
*/
|
||||
public function getDatabases(Request $request)
|
||||
{
|
||||
$acl = $this->getAclForUser();
|
||||
$sbasIds = array_merge(
|
||||
array_keys($acl->get_granted_sbas(['bas_manage'])),
|
||||
array_keys($acl->get_granted_sbas(['bas_modify_struct']))
|
||||
);
|
||||
|
||||
$sbas = [];
|
||||
foreach ($sbasIds as $sbasId) {
|
||||
$sbas[$sbasId] = [
|
||||
'version' => 'unknown',
|
||||
'image' => '/skins/icons/db-remove.png',
|
||||
'server_info' => '',
|
||||
'name' => $this->app->trans('Unreachable server')
|
||||
];
|
||||
|
||||
try {
|
||||
$databox = $this->findDataboxById($sbasId);
|
||||
|
||||
/** @var \PDO $pdoConnection */
|
||||
$pdoConnection = $databox->get_connection()->getWrappedConnection();
|
||||
$sbas[$sbasId] = [
|
||||
'version' => $databox->get_version(),
|
||||
'image' => '/skins/icons/foldph20close_0.gif',
|
||||
'server_info' => $pdoConnection->getAttribute(\PDO::ATTR_SERVER_VERSION),
|
||||
'name' => \phrasea::sbas_labels($sbasId, $this->app)
|
||||
];
|
||||
} catch (\Exception $e) {
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
switch ($errorMsg = $request->query->get('error')) {
|
||||
case 'scheduler-started' :
|
||||
$errorMsg = $this->app->trans('Veuillez arreter le planificateur avant la mise a jour');
|
||||
break;
|
||||
case 'already-started' :
|
||||
$errorMsg = $this->app->trans('The upgrade is already started');
|
||||
break;
|
||||
case 'unknow' :
|
||||
$errorMsg = $this->app->trans('An error occured');
|
||||
break;
|
||||
case 'bad-email' :
|
||||
$errorMsg = $this->app->trans('Please fix the database before starting');
|
||||
break;
|
||||
case 'special-chars' :
|
||||
$errorMsg = $this->app->trans('Database name can not contains special characters');
|
||||
break;
|
||||
case 'base-failed' :
|
||||
$errorMsg = $this->app->trans('Base could not be created');
|
||||
break;
|
||||
case 'database-failed' :
|
||||
$errorMsg = $this->app->trans('Database does not exists or can not be accessed');
|
||||
break;
|
||||
case 'no-empty' :
|
||||
$errorMsg = $this->app->trans('Database can not be empty');
|
||||
break;
|
||||
case 'mount-failed' :
|
||||
$errorMsg = $this->app->trans('Database could not be mounted');
|
||||
break;
|
||||
case 'innodb-support' :
|
||||
$errorMsg = _('Database server does not support InnoDB storage engine');
|
||||
break;
|
||||
}
|
||||
|
||||
return $this->render('admin/databases.html.twig', [
|
||||
'files' => new \DirectoryIterator($this->app['root.path'] . '/lib/conf.d/data_templates'),
|
||||
'sbas' => $sbas,
|
||||
'error_msg' => $errorMsg,
|
||||
'advices' => $request->query->get('advices', []),
|
||||
'reloadTree' => (Boolean) $request->query->get('reload-tree'),
|
||||
]);
|
||||
}
|
||||
|
||||
/**
|
||||
* Create a new databox
|
||||
*
|
||||
* @param Request $request The current HTTP request
|
||||
* @return RedirectResponse
|
||||
*/
|
||||
public function createDatabase(Request $request)
|
||||
{
|
||||
if ('' === $dbName = $request->request->get('new_dbname', '')) {
|
||||
return $this->app->redirectPath('admin_databases', ['error' => 'no-empty']);
|
||||
}
|
||||
|
||||
if (\p4string::hasAccent($dbName)) {
|
||||
return $this->app->redirectPath('admin_databases', ['error' => 'special-chars']);
|
||||
}
|
||||
|
||||
if ((null === $request->request->get('new_settings')) && (null !== $dataTemplate = $request->request->get('new_data_template'))) {
|
||||
$connexion = $this->app['conf']->get(['main', 'database']);
|
||||
|
||||
$hostname = $connexion['host'];
|
||||
$port = $connexion['port'];
|
||||
$user = $connexion['user'];
|
||||
$password = $connexion['password'];
|
||||
|
||||
$dataTemplate = new \SplFileInfo($this->app['root.path'] . '/lib/conf.d/data_templates/' . $dataTemplate . '.xml');
|
||||
|
||||
try {
|
||||
/** @var Connection $connection */
|
||||
$connection = $this->app['dbal.provider']([
|
||||
'host' => $hostname,
|
||||
'port' => $port,
|
||||
'user' => $user,
|
||||
'password' => $password,
|
||||
'dbname' => $dbName,
|
||||
]);
|
||||
$connection->connect();
|
||||
} catch (DBALException $e) {
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'database-failed']);
|
||||
}
|
||||
|
||||
try {
|
||||
$base = \databox::create($this->app, $connection, $dataTemplate);
|
||||
$base->registerAdmin($this->getAuthenticator()->getUser());
|
||||
$this->getAclForUser()->delete_data_from_cache();
|
||||
|
||||
$connection->close();
|
||||
return $this->app->redirectPath('admin_database', [
|
||||
'databox_id' => $base->get_sbas_id(),
|
||||
'success' => 1,
|
||||
'reload-tree' => 1
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'base-failed']);
|
||||
}
|
||||
}
|
||||
|
||||
if (null !== $request->request->get('new_settings')
|
||||
&& (null !== $hostname = $request->request->get('new_hostname'))
|
||||
&& (null !== $port = $request->request->get('new_port'))
|
||||
&& (null !== $userDb = $request->request->get('new_user'))
|
||||
&& (null !== $passwordDb = $request->request->get('new_password'))
|
||||
&& (null !== $dataTemplate = $request->request->get('new_data_template'))
|
||||
) {
|
||||
try {
|
||||
$data_template = new \SplFileInfo($this->app['root.path'] . '/lib/conf.d/data_templates/' . $dataTemplate . '.xml');
|
||||
/** @var Connection $connection */
|
||||
$connection = $this->app['db.provider']([
|
||||
'host' => $hostname,
|
||||
'port' => $port,
|
||||
'user' => $userDb,
|
||||
'password' => $passwordDb,
|
||||
'dbname' => $dbName,
|
||||
]);
|
||||
$connection->connect();
|
||||
try {
|
||||
$base = \databox::create($this->app, $connection, $data_template);
|
||||
$base->registerAdmin($this->getAuthenticator()->getUser());
|
||||
|
||||
return $this->app->redirectPath('admin_database', [
|
||||
'databox_id' => $base->get_sbas_id(),
|
||||
'success' => 1,
|
||||
'reload-tree' => 1,
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'base-failed']);
|
||||
}
|
||||
} catch (\Exception $e) {
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'database-failed']);
|
||||
}
|
||||
}
|
||||
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'base-failed']);
|
||||
}
|
||||
|
||||
/**
|
||||
* Mount a databox
|
||||
*
|
||||
* @param Request $request The current HTTP request
|
||||
* @return RedirectResponse
|
||||
*/
|
||||
public function databaseMount(Request $request)
|
||||
{
|
||||
if ('' === $dbName = trim($request->request->get('new_dbname', ''))) {
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'no-empty']);
|
||||
}
|
||||
|
||||
if (\p4string::hasAccent($dbName)) {
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'special-chars']);
|
||||
}
|
||||
|
||||
if ((null === $request->request->get('new_settings'))) {
|
||||
try {
|
||||
$connexion = $this->app['conf']->get(['main', 'database']);
|
||||
|
||||
$hostname = $connexion['host'];
|
||||
$port = $connexion['port'];
|
||||
$user = $connexion['user'];
|
||||
$password = $connexion['password'];
|
||||
|
||||
$this->app['phraseanet.appbox']->get_connection()->beginTransaction();
|
||||
$base = \databox::mount($this->app, $hostname, $port, $user, $password, $dbName);
|
||||
$base->registerAdmin($this->app['authentication']->getUser());
|
||||
$this->app['phraseanet.appbox']->get_connection()->commit();
|
||||
|
||||
return $this->app->redirectPath('admin_database', [
|
||||
'databox_id' => $base->get_sbas_id(),
|
||||
'success' => 1,
|
||||
'reload-tree' => 1,
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
$this->app['phraseanet.appbox']->get_connection()->rollBack();
|
||||
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'mount-failed']);
|
||||
}
|
||||
}
|
||||
|
||||
if (null !== $request->request->get('new_settings')
|
||||
&& (null !== $hostname = $request->request->get('new_hostname'))
|
||||
&& (null !== $port = $request->request->get('new_port'))
|
||||
&& (null !== $userDb = $request->request->get('new_user'))
|
||||
&& (null !== $passwordDb = $request->request->get('new_password'))
|
||||
) {
|
||||
$connection = $this->getApplicationBox()->get_connection();
|
||||
try {
|
||||
$connection->beginTransaction();
|
||||
$base = \databox::mount($this->app, $hostname, $port, $userDb, $passwordDb, $dbName);
|
||||
$base->registerAdmin($this->getAuthenticator()->getUser());
|
||||
$connection->commit();
|
||||
|
||||
return $this->app->redirectPath('admin_database', [
|
||||
'databox_id' => $base->get_sbas_id(),
|
||||
'success' => 1,
|
||||
'reload-tree' => 1
|
||||
]);
|
||||
} catch (\Exception $e) {
|
||||
$connection->rollBack();
|
||||
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'mount-failed']);
|
||||
}
|
||||
}
|
||||
return $this->app->redirectPath('admin_databases', ['success' => 0, 'error' => 'mount-failed']);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return \appbox
|
||||
*/
|
||||
private function getApplicationBox()
|
||||
{
|
||||
return $this->app['phraseanet.appbox'];
|
||||
}
|
||||
|
||||
/**
|
||||
* @param int $id
|
||||
* @return \databox
|
||||
*/
|
||||
private function findDataboxById($id)
|
||||
{
|
||||
$appbox = $this->getApplicationBox();
|
||||
|
||||
return $appbox->get_databox($id);
|
||||
}
|
||||
|
||||
/**
|
||||
* @param $name
|
||||
* @param array $context
|
||||
* @return string
|
||||
*/
|
||||
private function render($name, array $context = [])
|
||||
{
|
||||
/** @var \Twig_Environment $twig */
|
||||
$twig = $this->app['twig'];
|
||||
return $twig->render(
|
||||
$name,
|
||||
$context
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return ACLProvider
|
||||
*/
|
||||
private function getAclProvider()
|
||||
{
|
||||
return $this->app['acl'];
|
||||
}
|
||||
|
||||
/**
|
||||
* @return Authenticator
|
||||
*/
|
||||
private function getAuthenticator()
|
||||
{
|
||||
return $this->app['authentication'];
|
||||
}
|
||||
|
||||
/**
|
||||
* @param User|null $user
|
||||
* @return \ACL
|
||||
*/
|
||||
private function getAclForUser(User $user = null)
|
||||
{
|
||||
$aclProvider = $this->getAclProvider();
|
||||
if (null === $user) {
|
||||
$user = $this->getAuthenticator()->getUser();
|
||||
}
|
||||
|
||||
return $aclProvider->get($user);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user