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

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. /** @final */
  20. class MigrationsCollector extends DataCollector
  21. {
  22.     /** @var DependencyFactory */
  23.     private $dependencyFactory;
  24.     /** @var MigrationsFlattener */
  25.     private $flattener;
  27.     public function __construct(DependencyFactory $dependencyFactory, MigrationsFlattener $migrationsFlattener)
  28.     {
  29.         $this->dependencyFactory = $dependencyFactory;
  30.         $this->flattener         = $migrationsFlattener;
  31.     }
  33.     /** @return void */
  34.     public function collect(Request $request, Response $response, ?Throwable $exception = null)
  35.     {
  36.         if ($this->data !== []) {
  37.             return;
  38.         }
  40.         $metadataStorage = $this->dependencyFactory->getMetadataStorage();
  41.         $planCalculator  = $this->dependencyFactory->getMigrationPlanCalculator();
  43.         try {
  44.             $executedMigrations = $metadataStorage->getExecutedMigrations();
  45.         } catch (Exception $dbalException) {
  46.             $this->dependencyFactory->getLogger()->error(
  47.                 'error while trying to collect executed migrations',
  48.                 ['exception' => $dbalException]
  49.             );
  51.             return;
  52.         }
  54.         $availableMigrations = $planCalculator->getMigrations();
  56.         $this->data['available_migrations_count']   = count($availableMigrations);
  57.         $unavailableMigrations                      = $executedMigrations->unavailableSubset($availableMigrations);
  58.         $this->data['unavailable_migrations_count'] = count($unavailableMigrations);
  60.         $newMigrations                     = $availableMigrations->newSubset($executedMigrations);
  61.         $this->data['new_migrations']      = $this->flattener->flattenAvailableMigrations($newMigrations);
  62.         $this->data['executed_migrations'] = $this->flattener->flattenExecutedMigrations($executedMigrations, $availableMigrations);
  64.         $this->data['storage'] = get_class($metadataStorage);
  65.         $configuration         = $this->dependencyFactory->getConfiguration();
  66.         $storage               = $configuration->getMetadataStorageConfiguration();
  67.         if ($storage instanceof TableMetadataStorageConfiguration) {
  68.             $this->data['table']  = $storage->getTableName();
  69.             $this->data['column'] = $storage->getVersionColumnName();
  70.         }
  72.         $connection           = $this->dependencyFactory->getConnection();
  73.         $this->data['driver'] = get_class($connection->getDriver());
  74.         $this->data['name']   = $connection->getDatabase();
  76.         $this->data['namespaces'] = $configuration->getMigrationDirectories();
  77.     }
  79.     /** @return string */
  80.     public function getName()
  81.     {
  82.         return 'doctrine_migrations';
  83.     }
  85.     /** @return array<string, mixed>|Data */
  86.     public function getData()
  87.     {
  88.         return $this->data;
  89.     }
  91.     /** @return void */
  92.     public function reset()
  93.     {
  94.         $this->data = [];
  95.     }
  96. }