vendor/doctrine/doctrine-migrations-bundle/Collector/MigrationsCollector.php line 36

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