vendor/doctrine/phpcr-bundle/src/DoctrinePHPCRBundle.php line 25

  1. <?php
  3. namespace Doctrine\Bundle\PHPCRBundle;
  5. use Doctrine\Bundle\PHPCRBundle\DependencyInjection\Compiler\InitializerPass;
  6. use Doctrine\Bundle\PHPCRBundle\DependencyInjection\Compiler\MigratorPass;
  7. use Doctrine\Bundle\PHPCRBundle\OptionalCommand\Jackalope\InitDoctrineDbalCommand;
  8. use Doctrine\Bundle\PHPCRBundle\OptionalCommand\Jackalope\JackrabbitCommand;
  9. use Doctrine\Bundle\PHPCRBundle\OptionalCommand\ODM\DocumentConvertTranslationCommand;
  10. use Doctrine\Bundle\PHPCRBundle\OptionalCommand\ODM\DocumentMigrateClassCommand;
  11. use Doctrine\Bundle\PHPCRBundle\OptionalCommand\ODM\InfoDoctrineCommand;
  12. use Doctrine\Bundle\PHPCRBundle\OptionalCommand\ODM\VerifyUniqueNodeTypesMappingCommand;
  13. use Doctrine\Common\Util\ClassUtils;
  14. use Doctrine\ODM\PHPCR\Version;
  15. use Jackalope\Session;
  16. use Jackalope\Tools\Console\Command\InitDoctrineDbalCommand as BaseInitDoctrineDbalCommand;
  17. use Jackalope\Tools\Console\Command\JackrabbitCommand as BaseJackrabbitCommand;
  18. use Symfony\Bridge\Doctrine\DependencyInjection\CompilerPass\RegisterEventListenersAndSubscribersPass;
  19. use Symfony\Component\Console\Application;
  20. use Symfony\Component\DependencyInjection\Compiler\PassConfig;
  21. use Symfony\Component\DependencyInjection\ContainerBuilder;
  22. use Symfony\Component\DependencyInjection\IntrospectableContainerInterface;
  23. use Symfony\Component\HttpKernel\Bundle\Bundle;
  25. class DoctrinePHPCRBundle extends Bundle
  26. {
  27.     /**
  28.      * Autoloader for proxies.
  29.      *
  30.      * @var \Closure
  31.      */
  32.     private $autoloader;
  34.     /**
  35.      * {@inheritdoc}
  36.      */
  37.     public function build(ContainerBuilder $container)
  38.     {
  39.         parent::build($container);
  41.         $container->addCompilerPass(new MigratorPass());
  42.         $container->addCompilerPass(new InitializerPass());
  43.         if (class_exists(Version::class)) {
  44.             $container->addCompilerPass(new RegisterEventListenersAndSubscribersPass('doctrine_phpcr.sessions', 'doctrine_phpcr.%s_session.event_manager', 'doctrine_phpcr'), PassConfig::TYPE_BEFORE_OPTIMIZATION);
  45.         }
  46.     }
  48.     /**
  49.      * {@inheritdoc}
  50.      */
  51.     public function registerCommands(Application $application)
  52.     {
  53.         parent::registerCommands($application);
  55.         if (class_exists(Version::class)) {
  56.             $application->add(new DocumentMigrateClassCommand());
  57.             $application->add(new InfoDoctrineCommand());
  58.             $application->add(new VerifyUniqueNodeTypesMappingCommand());
  59.             $application->add(new DocumentConvertTranslationCommand());
  60.         }
  62.         if (class_exists(BaseJackrabbitCommand::class)) {
  63.             $application->add(new JackrabbitCommand());
  64.         }
  65.         if (class_exists(BaseInitDoctrineDbalCommand::class)) {
  66.             $application->add(new InitDoctrineDbalCommand());
  67.         }
  68.     }
  70.     /**
  71.      * {@inheritdoc}
  72.      */
  73.     public function boot()
  74.     {
  75.         // Register an autoloader for proxies to avoid issues when unserializing them when the ODM is used.
  76.         if ($this->container->hasParameter('doctrine_phpcr.odm.proxy_namespace')) {
  77.             $namespace = $this->container->getParameter('doctrine_phpcr.odm.proxy_namespace');
  78.             $dir = $this->container->getParameter('doctrine_phpcr.odm.proxy_dir');
  79.             // See https://github.com/symfony/symfony/pull/3419 for usage of references
  80.             $container = &$this->container;
  82.             $this->autoloader = function ($class) use ($namespace, $dir, &$container) {
  83.                 if (0 === strpos($class, $namespace)) {
  84.                     $fileName = str_replace('\\', '', substr($class, \strlen($namespace) + 1));
  85.                     $file = $dir.\DIRECTORY_SEPARATOR.$fileName.'.php';
  87.                     if (!is_file($file) && $container->getParameter('doctrine_phpcr.odm.auto_generate_proxy_classes')) {
  88.                         $originalClassName = ClassUtils::getRealClass($class);
  89.                         $registry = $container->get('doctrine_phpcr');
  91.                         // Tries to auto-generate the proxy file
  92.                         foreach ($registry->getManagers() as $dm) {
  93.                             if ($dm->getConfiguration()->getAutoGenerateProxyClasses()) {
  94.                                 $classes = $dm->getMetadataFactory()->getAllMetadata();
  96.                                 foreach ($classes as $classMetadata) {
  97.                                     if ($classMetadata->name === $originalClassName) {
  98.                                         $dm->getProxyFactory()->generateProxyClasses([$classMetadata]);
  99.                                     }
  100.                                 }
  101.                             }
  102.                         }
  104.                         clearstatcache($file);
  105.                     }
  107.                     if (is_file($file)) {
  108.                         require $file;
  109.                     }
  110.                 }
  111.             };
  112.             spl_autoload_register($this->autoloader);
  113.         }
  114.     }
  116.     /**
  117.      * {@inheritdoc}
  118.      */
  119.     public function shutdown()
  120.     {
  121.         if (null !== $this->autoloader) {
  122.             spl_autoload_unregister($this->autoloader);
  123.             $this->autoloader = null;
  124.         }
  126.         $this->clearDocumentManagers();
  127.         $this->closeConnections();
  128.     }
  130.     /**
  131.      * Clear all document managers to clear references to entities for GC.
  132.      */
  133.     private function clearDocumentManagers()
  134.     {
  135.         if (!$this->container->hasParameter('doctrine_phpcr.odm.document_managers')) {
  136.             return;
  137.         }
  139.         foreach ($this->container->getParameter('doctrine_phpcr.odm.document_managers') as $id) {
  140.             if ($this->container instanceof IntrospectableContainerInterface && !$this->container->initialized($id)) {
  141.                 continue;
  142.             }
  144.             $this->container->get($id)->clear();
  145.         }
  146.     }
  148.     /**
  149.      * Close all connections to avoid reaching too many connections in the process when booting again later (tests).
  150.      */
  151.     private function closeConnections()
  152.     {
  153.         if (!$this->container->hasParameter('doctrine_phpcr.sessions')) {
  154.             return;
  155.         }
  157.         foreach ($this->container->getParameter('doctrine_phpcr.sessions') as $id) {
  158.             if ($this->container instanceof IntrospectableContainerInterface && !$this->container->initialized($id)) {
  159.                 continue;
  160.             }
  162.             $session = $this->container->get($id);
  163.             if (!$session instanceof Session) {
  164.                 return;
  165.             }
  167.             $session->getTransport()->logout();
  168.         }
  169.     }
  170. }