vendor/gos/web-socket-bundle/DependencyInjection/CompilerPass/PingableDriverCompilerPass.php line 12

Open in your IDE?
  1. <?php
  3. namespace Gos\Bundle\WebSocketBundle\DependencyInjection\CompilerPass;
  5. use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
  6. use Symfony\Component\DependencyInjection\ContainerBuilder;
  7. use Symfony\Component\DependencyInjection\Reference;
  8. use Symfony\Component\HttpFoundation\Session\Storage\Handler\PdoSessionHandler;
  10. @trigger_error(
  11.     sprintf('The %s class is deprecated will be removed in 2.0.', PingableDriverCompilerPass::class),
  12.     E_USER_DEPRECATED
  13. );
  15. /**
  16.  * @deprecated to be removed in 2.0.
  17.  */
  18. class PingableDriverCompilerPass implements CompilerPassInterface
  19. {
  20.     /**
  21.      * @param ContainerBuilder $container
  22.      */
  23.     public function process(ContainerBuilder $container)
  24.     {
  25.         if (false === $container->hasParameter('database_driver')) {
  26.             return;
  27.         }
  29.         if (false === $container->hasAlias('gos_web_socket.session_handler')) {
  30.             return;
  31.         }
  33.         $sessionHandlerDefinition = $container->getDefinition((string) $container->getAlias('gos_web_socket.session_handler'));
  35.         if (PdoSessionHandler::class !== $sessionHandlerDefinition->getClass() && ( !class_exists($sessionHandlerDefinition->getClass()) || !\in_array(PdoSessionHandler::class, \class_parents($sessionHandlerDefinition->getClass()), true))) {
  36.             return;
  37.         }
  39.         if (!$container->hasDefinition('pdo') || !$container->hasAlias('pdo')) {
  40.             $pdoReference = $sessionHandlerDefinition->getArgument(0);
  41.             if (!$pdoReference instanceof Reference || \PDO::class !== $container->getDefinition((string) $pdoReference)->getClass()) {
  42.                 return;
  43.             }
  44.             $periodicPingDefinition = $container->getDefinition('gos_web_socket.pdo.periodic_ping');
  45.             $periodicPingDefinition->setArgument(0, $pdoReference);
  46.         }
  48.         $periodicRegistryDef = $container->getDefinition('gos_web_socket.periodic.registry');
  50.         $pdoDriver = ['pdo_mysql', 'pdo_sqlite', 'pdo_pgsql'];
  52.         if (in_array($container->getParameter('database_driver'), $pdoDriver)) {
  53.             $periodicRegistryDef->addMethodCall(
  54.                 'addPeriodic', [new Reference('gos_web_socket.pdo.periodic_ping')]
  55.             );
  56.         }
  57.     }
  58. }