vendor/doctrine/doctrine-migrations-bundle/src/Collector/MigrationsCollector.php line 33

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Doctrine\Bundle\MigrationsBundle\Collector;
  7. use Doctrine\DBAL\Exception;
  8. use Doctrine\Migrations\DependencyFactory;
  9. use Doctrine\Migrations\Metadata\Storage\TableMetadataStorageConfiguration;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\HttpKernel\DataCollector\DataCollector;
  13. use Symfony\Component\VarDumper\Cloner\Data;
  14. use Throwable;
  16. use function count;
  17. use function get_class;
  19. class MigrationsCollector extends DataCollector
  20. {
  21. /** @var DependencyFactory */
  22. private $dependencyFactory;
  23. /** @var MigrationsFlattener */
  24. private $flattener;
  26. public function __construct(DependencyFactory $dependencyFactory, MigrationsFlattener $migrationsFlattener)
  27. {
  28. $this->dependencyFactory = $dependencyFactory;
  29. $this->flattener = $migrationsFlattener;
  30. }
  32. /** @return void */
  33. public function collect(Request $request, Response $response, ?Throwable $exception = null)
  34. {
  35. if ($this->data !== []) {
  36. return;
  37. }
  39. $metadataStorage = $this->dependencyFactory->getMetadataStorage();
  40. $planCalculator = $this->dependencyFactory->getMigrationPlanCalculator();
  42. try {
  43. $executedMigrations = $metadataStorage->getExecutedMigrations();
  44. } catch (Exception $dbalException) {
  45. $this->dependencyFactory->getLogger()->error(
  46. 'error while trying to collect executed migrations',
  47. ['exception' => $dbalException]
  48. );
  50. return;
  51. }
  53. $availableMigrations = $planCalculator->getMigrations();
  55. $this->data['available_migrations_count'] = count($availableMigrations);
  56. $unavailableMigrations = $executedMigrations->unavailableSubset($availableMigrations);
  57. $this->data['unavailable_migrations_count'] = count($unavailableMigrations);
  59. $newMigrations = $availableMigrations->newSubset($executedMigrations);
  60. $this->data['new_migrations'] = $this->flattener->flattenAvailableMigrations($newMigrations);
  61. $this->data['executed_migrations'] = $this->flattener->flattenExecutedMigrations($executedMigrations, $availableMigrations);
  63. $this->data['storage'] = get_class($metadataStorage);
  64. $configuration = $this->dependencyFactory->getConfiguration();
  65. $storage = $configuration->getMetadataStorageConfiguration();
  66. if ($storage instanceof TableMetadataStorageConfiguration) {
  67. $this->data['table'] = $storage->getTableName();
  68. $this->data['column'] = $storage->getVersionColumnName();
  69. }
  71. $connection = $this->dependencyFactory->getConnection();
  72. $this->data['driver'] = get_class($connection->getDriver());
  73. $this->data['name'] = $connection->getDatabase();
  75. $this->data['namespaces'] = $configuration->getMigrationDirectories();
  76. }
  78. /** @return string */
  79. public function getName()
  80. {
  81. return 'doctrine_migrations';
  82. }
  84. /** @return array<string, mixed>|Data */
  85. public function getData()
  86. {
  87. return $this->data;
  88. }
  90. /** @return void */
  91. public function reset()
  92. {
  93. $this->data = [];
  94. }
  95. }