Merge pull request #3293 from Nicofuma/ticket/13489

[ticket/13489] Disable the event dispatcher in the migrator
This commit is contained in:
Joas Schilling 2015-01-20 23:27:54 +01:00
commit a5fae1b1f0
12 changed files with 155 additions and 32 deletions

View file

@ -18,6 +18,7 @@ services:
migrator: migrator:
class: phpbb\db\migrator class: phpbb\db\migrator
arguments: arguments:
- @service_container
- @config - @config
- @dbal.conn - @dbal.conn
- @dbal.tools - @dbal.tools

View file

@ -0,0 +1,36 @@
<?php
/**
*
* This file is part of the phpBB Forum Software package.
*
* @copyright (c) phpBB Limited <https://www.phpbb.com>
* @license GNU General Public License, version 2 (GPL-2.0)
*
* For full copyright and license information, please see
* the docs/CREDITS.txt file.
*
*/
namespace phpbb\db\migration;
use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
/**
* Abstract base class for container aware database migrations.
*/
abstract class container_aware_migration extends migration implements ContainerAwareInterface
{
/**
* @var ContainerInterface
*/
protected $container;
/**
* {@inheritdoc}
*/
public function setContainer(ContainerInterface $container = null)
{
$this->container = $container;
}
}

View file

@ -13,7 +13,9 @@
namespace phpbb\db\migration\data\v30x; namespace phpbb\db\migration\data\v30x;
class release_3_0_5_rc1 extends \phpbb\db\migration\migration use phpbb\db\migration\container_aware_migration;
class release_3_0_5_rc1 extends container_aware_migration
{ {
public function effectively_installed() public function effectively_installed()
{ {
@ -55,9 +57,7 @@ class release_3_0_5_rc1 extends \phpbb\db\migration\migration
public function hash_old_passwords() public function hash_old_passwords()
{ {
global $phpbb_container; $passwords_manager = $this->container->get('passwords.manager');
$passwords_manager = $phpbb_container->get('passwords.manager');
$sql = 'SELECT user_id, user_password $sql = 'SELECT user_id, user_password
FROM ' . $this->table_prefix . 'users FROM ' . $this->table_prefix . 'users
WHERE user_pass_convert = 1'; WHERE user_pass_convert = 1';

View file

@ -13,12 +13,14 @@
namespace phpbb\db\migration\data\v310; namespace phpbb\db\migration\data\v310;
use phpbb\db\migration\container_aware_migration;
/** /**
* Migration to convert the Soft Delete MOD for 3.0 * Migration to convert the Soft Delete MOD for 3.0
* *
* https://www.phpbb.com/customise/db/mod/soft_delete/ * https://www.phpbb.com/customise/db/mod/soft_delete/
*/ */
class soft_delete_mod_convert extends \phpbb\db\migration\migration class soft_delete_mod_convert extends container_aware_migration
{ {
static public function depends_on() static public function depends_on()
{ {
@ -115,19 +117,11 @@ class soft_delete_mod_convert extends \phpbb\db\migration\migration
} }
} }
/**
* @return \phpbb\content_visibility
*/
protected function get_content_visibility() protected function get_content_visibility()
{ {
return new \phpbb\content_visibility( return $this->container->get('content.visibility');
new \phpbb\auth\auth(),
$this->config,
$this->db,
new \phpbb\user('\phpbb\datetime'),
$this->phpbb_root_path,
$this->php_ext,
$this->table_prefix . 'forums',
$this->table_prefix . 'posts',
$this->table_prefix . 'topics',
$this->table_prefix . 'users'
);
} }
} }

View file

@ -13,7 +13,7 @@
namespace phpbb\db\migration; namespace phpbb\db\migration;
abstract class profilefield_base_migration extends \phpbb\db\migration\migration abstract class profilefield_base_migration extends container_aware_migration
{ {
protected $profilefield_name; protected $profilefield_name;
@ -237,8 +237,7 @@ abstract class profilefield_base_migration extends \phpbb\db\migration\migration
if ($profile_row === null) if ($profile_row === null)
{ {
global $phpbb_container; $manager = $this->container->get('profilefields.manager');
$manager = $phpbb_container->get('profilefields.manager');
$profile_row = $manager->build_insert_sql_array(array()); $profile_row = $manager->build_insert_sql_array(array());
} }

View file

@ -13,11 +13,19 @@
namespace phpbb\db; namespace phpbb\db;
use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
/** /**
* The migrator is responsible for applying new migrations in the correct order. * The migrator is responsible for applying new migrations in the correct order.
*/ */
class migrator class migrator
{ {
/**
* @var ContainerInterface
*/
protected $container;
/** @var \phpbb\config\config */ /** @var \phpbb\config\config */
protected $config; protected $config;
@ -77,15 +85,16 @@ class migrator
/** /**
* The output handler. A null handler is configured by default. * The output handler. A null handler is configured by default.
* *
* @var migrator_output_handler * @var migrator_output_handler_interface
*/ */
public $output_handler; public $output_handler;
/** /**
* Constructor of the database migrator * Constructor of the database migrator
*/ */
public function __construct(\phpbb\config\config $config, \phpbb\db\driver\driver_interface $db, \phpbb\db\tools $db_tools, $migrations_table, $phpbb_root_path, $php_ext, $table_prefix, $tools, \phpbb\db\migration\helper $helper) public function __construct(ContainerInterface $container, \phpbb\config\config $config, \phpbb\db\driver\driver_interface $db, \phpbb\db\tools $db_tools, $migrations_table, $phpbb_root_path, $php_ext, $table_prefix, $tools, \phpbb\db\migration\helper $helper)
{ {
$this->container = $container;
$this->config = $config; $this->config = $config;
$this->db = $db; $this->db = $db;
$this->db_tools = $db_tools; $this->db_tools = $db_tools;
@ -171,6 +180,18 @@ class migrator
* @return null * @return null
*/ */
public function update() public function update()
{
$this->container->get('dispatcher')->disable();
$this->update_do();
$this->container->get('dispatcher')->enable();
}
/**
* Effectively runs a single update step from the next migration to be applied.
*
* @return null
*/
protected function update_do()
{ {
foreach ($this->migrations as $name) foreach ($this->migrations as $name)
{ {
@ -317,7 +338,7 @@ class migrator
catch (\phpbb\db\migration\exception $e) catch (\phpbb\db\migration\exception $e)
{ {
// Revert the schema changes // Revert the schema changes
$this->revert($name); $this->revert_do($name);
// Rethrow exception // Rethrow exception
throw $e; throw $e;
@ -337,9 +358,21 @@ class migrator
* check if revert() needs to be called again use the migration_state() method. * check if revert() needs to be called again use the migration_state() method.
* *
* @param string $migration String migration name to revert (including any that depend on this migration) * @param string $migration String migration name to revert (including any that depend on this migration)
* @return null
*/ */
public function revert($migration) public function revert($migration)
{
$this->container->get('dispatcher')->disable();
$this->revert_do($migration);
$this->container->get('dispatcher')->enable();
}
/**
* Effectively runs a single revert step from the last migration installed
*
* @param string $migration String migration name to revert (including any that depend on this migration)
* @return null
*/
protected function revert_do($migration)
{ {
if (!isset($this->migration_state[$migration])) if (!isset($this->migration_state[$migration]))
{ {
@ -351,7 +384,7 @@ class migrator
{ {
if (!empty($state['migration_depends_on']) && in_array($migration, $state['migration_depends_on'])) if (!empty($state['migration_depends_on']) && in_array($migration, $state['migration_depends_on']))
{ {
$this->revert($name); $this->revert_do($name);
} }
} }
@ -742,7 +775,14 @@ class migrator
*/ */
protected function get_migration($name) protected function get_migration($name)
{ {
return new $name($this->config, $this->db, $this->db_tools, $this->phpbb_root_path, $this->php_ext, $this->table_prefix); $migration = new $name($this->config, $this->db, $this->db_tools, $this->phpbb_root_path, $this->php_ext, $this->table_prefix);
if ($migration instanceof ContainerAwareInterface)
{
$migration->setContainer($this->container);
}
return $migration;
} }
/** /**

View file

@ -14,6 +14,7 @@
namespace phpbb\event; namespace phpbb\event;
use Symfony\Component\EventDispatcher\ContainerAwareEventDispatcher; use Symfony\Component\EventDispatcher\ContainerAwareEventDispatcher;
use Symfony\Component\EventDispatcher\Event;
/** /**
* Extension of the Symfony2 EventDispatcher * Extension of the Symfony2 EventDispatcher
@ -31,6 +32,11 @@ use Symfony\Component\EventDispatcher\ContainerAwareEventDispatcher;
*/ */
class dispatcher extends ContainerAwareEventDispatcher implements dispatcher_interface class dispatcher extends ContainerAwareEventDispatcher implements dispatcher_interface
{ {
/**
* @var bool
*/
protected $disabled = false;
/** /**
* {@inheritdoc} * {@inheritdoc}
*/ */
@ -40,4 +46,33 @@ class dispatcher extends ContainerAwareEventDispatcher implements dispatcher_int
$this->dispatch($eventName, $event); $this->dispatch($eventName, $event);
return $event->get_data_filtered(array_keys($data)); return $event->get_data_filtered(array_keys($data));
} }
/**
* {@inheritdoc}
*/
public function dispatch($eventName, Event $event = null)
{
if ($this->disabled)
{
return $event;
}
return parent::dispatch($eventName, $event);
}
/**
* {@inheritdoc}
*/
public function disable()
{
$this->disabled = true;
}
/**
* {@inheritdoc}
*/
public function enable()
{
$this->disabled = false;
}
} }

View file

@ -37,4 +37,14 @@ interface dispatcher_interface extends \Symfony\Component\EventDispatcher\EventD
* @return mixed * @return mixed
*/ */
public function trigger_event($eventName, $data = array()); public function trigger_event($eventName, $data = array());
/**
* Disable the event dispatcher.
*/
public function disable();
/**
* Enable the event dispatcher.
*/
public function enable();
} }

View file

@ -46,7 +46,10 @@ class phpbb_dbal_migrator_test extends phpbb_database_test_case
new \phpbb\db\migration\tool\config($this->config), new \phpbb\db\migration\tool\config($this->config),
); );
$container = new phpbb_mock_container_builder();
$this->migrator = new \phpbb\db\migrator( $this->migrator = new \phpbb\db\migrator(
$container,
$this->config, $this->config,
$this->db, $this->db,
$this->db_tools, $this->db_tools,
@ -57,9 +60,8 @@ class phpbb_dbal_migrator_test extends phpbb_database_test_case
$tools, $tools,
new \phpbb\db\migration\helper() new \phpbb\db\migration\helper()
); );
$container->set('migrator', $this->migrator);
$container = new phpbb_mock_container_builder(); $container->set('dispatcher', new phpbb_mock_event_dispatcher());
$container->set('migrator', $migrator);
$user = new \phpbb\user('\phpbb\datetime'); $user = new \phpbb\user('\phpbb\datetime');
$this->extension_manager = new \phpbb\extension\manager( $this->extension_manager = new \phpbb\extension\manager(

View file

@ -156,7 +156,10 @@ class phpbb_extension_manager_test extends phpbb_database_test_case
$table_prefix = 'phpbb_'; $table_prefix = 'phpbb_';
$user = new \phpbb\user('\phpbb\user'); $user = new \phpbb\user('\phpbb\user');
$container = new phpbb_mock_container_builder();
$migrator = new \phpbb\db\migrator( $migrator = new \phpbb\db\migrator(
$container,
$config, $config,
$db, $db,
$db_tools, $db_tools,
@ -167,7 +170,6 @@ class phpbb_extension_manager_test extends phpbb_database_test_case
array(), array(),
new \phpbb\db\migration\helper() new \phpbb\db\migration\helper()
); );
$container = new phpbb_mock_container_builder();
$container->set('migrator', $migrator); $container->set('migrator', $migrator);
return new \phpbb\extension\manager( return new \phpbb\extension\manager(

View file

@ -62,7 +62,10 @@ class phpbb_extension_metadata_manager_test extends phpbb_database_test_case
new \phpbb\template\context() new \phpbb\template\context()
); );
$container = new phpbb_mock_container_builder();
$this->migrator = new \phpbb\db\migrator( $this->migrator = new \phpbb\db\migrator(
$container,
$this->config, $this->config,
$this->db, $this->db,
$this->db_tools, $this->db_tools,
@ -73,7 +76,6 @@ class phpbb_extension_metadata_manager_test extends phpbb_database_test_case
array(), array(),
new \phpbb\db\migration\helper() new \phpbb\db\migration\helper()
); );
$container = new phpbb_mock_container_builder();
$container->set('migrator', $this->migrator); $container->set('migrator', $this->migrator);
$this->extension_manager = new \phpbb\extension\manager( $this->extension_manager = new \phpbb\extension\manager(

View file

@ -227,7 +227,9 @@ class phpbb_functional_test_case extends phpbb_test_case
$db = $this->get_db(); $db = $this->get_db();
$db_tools = new \phpbb\db\tools($db); $db_tools = new \phpbb\db\tools($db);
$container = new phpbb_mock_container_builder();
$migrator = new \phpbb\db\migrator( $migrator = new \phpbb\db\migrator(
$container,
$config, $config,
$db, $db,
$db_tools, $db_tools,
@ -238,8 +240,8 @@ class phpbb_functional_test_case extends phpbb_test_case
array(), array(),
new \phpbb\db\migration\helper() new \phpbb\db\migration\helper()
); );
$container = new phpbb_mock_container_builder();
$container->set('migrator', $migrator); $container->set('migrator', $migrator);
$container->set('dispatcher', new phpbb_mock_event_dispatcher());
$user = new \phpbb\user('\phpbb\datetime'); $user = new \phpbb\user('\phpbb\datetime');
$extension_manager = new \phpbb\extension\manager( $extension_manager = new \phpbb\extension\manager(