vendor/shopware/core/HttpKernel.php line 68

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core;
  5. use Composer\Autoload\ClassLoader;
  6. use Composer\InstalledVersions;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\Driver\Middleware;
  9. use Doctrine\DBAL\DriverManager;
  10. use Doctrine\DBAL\Exception;
  11. use Shopware\Core\Framework\Adapter\Cache\CacheIdLoader;
  12. use Shopware\Core\Framework\Adapter\Database\MySQLFactory;
  13. use Shopware\Core\Framework\Adapter\Storage\MySQLKeyValueStorage;
  14. use Shopware\Core\Framework\Event\BeforeSendRedirectResponseEvent;
  15. use Shopware\Core\Framework\Event\BeforeSendResponseEvent;
  16. use Shopware\Core\Framework\Log\Package;
  17. use Shopware\Core\Framework\Plugin\KernelPluginLoader\DbalKernelPluginLoader;
  18. use Shopware\Core\Framework\Plugin\KernelPluginLoader\KernelPluginLoader;
  19. use Shopware\Core\Framework\Routing\CanonicalRedirectService;
  20. use Shopware\Core\Framework\Routing\RequestTransformerInterface;
  21. use Shopware\Core\Profiling\Doctrine\ProfilingMiddleware;
  22. use Shopware\Storefront\Framework\Cache\CacheStore;
  23. use Symfony\Component\HttpFoundation\RedirectResponse;
  24. use Symfony\Component\HttpFoundation\Request;
  25. use Symfony\Component\HttpFoundation\Response;
  26. use Symfony\Component\HttpKernel\HttpCache\HttpCache;
  27. use Symfony\Component\HttpKernel\HttpKernelInterface;
  28. use Symfony\Component\HttpKernel\KernelInterface;
  29. use Symfony\Component\HttpKernel\TerminableInterface;
  31. /**
  32.  * @deprecated tag:v6.6.0 - reason:factory-for-deprecation - Will be removed in v6.6.0, use `KernelFactory::create` instead
  33.  *
  34.  * @psalm-import-type Params from DriverManager
  35.  */
  36. #[Package('core')]
  37. class HttpKernel
  38. {
  39.     protected static ?Connection $connection = null;
  41.     /**
  42.      * @var class-string<Kernel>
  43.      */
  44.     protected static string $kernelClass = Kernel::class;
  46.     /**
  47.      * @var class-string<HttpCache>
  48.      */
  49.     protected static string $httpCacheClass = HttpCache::class;
  51.     protected ?string $projectDir = null;
  53.     protected ?KernelPluginLoader $pluginLoader = null;
  55.     protected ?KernelInterface $kernel = null;
  57.     public function __construct(
  58.         protected string $environment,
  59.         protected bool $debug,
  60.         protected ?ClassLoader $classLoader = null
  61.     ) {
  62.     }
  64.     public function handle(Request $request, int $type = HttpKernelInterface::MAIN_REQUEST, bool $catch = true): HttpKernelResult
  65.     {
  66.         try {
  67.             return $this->doHandle($request, $type, $catch);
  68.         } catch (Exception $e) {
  69.             /** @var Params|array{url?: string} $connectionParams */
  70.             $connectionParams = self::getConnection()->getParams();
  72.             $message = str_replace([$connectionParams['url'] ?? null, $connectionParams['password'] ?? null, $connectionParams['user'] ?? null], '******', $e->getMessage());
  74.             // @phpstan-ignore-next-line Ignore domain exception - class will be removed
  75.             throw new \RuntimeException(sprintf('Could not connect to database. Message from SQL Server: %s', $message));
  76.         }
  77.     }
  79.     public function getKernel(): KernelInterface
  80.     {
  81.         return $this->createKernel();
  82.     }
  84.     /**
  85.      * Allows to switch the plugin loading.
  86.      */
  87.     public function setPluginLoader(KernelPluginLoader $pluginLoader): void
  88.     {
  89.         $this->pluginLoader = $pluginLoader;
  90.     }
  92.     /**
  93.      * @param array<Middleware> $middlewares
  94.      */
  95.     public static function getConnection(array $middlewares = []): Connection
  96.     {
  97.         if (self::$connection) {
  98.             return self::$connection;
  99.         }
  101.         self::$connection = MySQLFactory::create($middlewares);
  103.         return self::$connection;
  104.     }
  106.     public function terminate(Request $request, Response $response): void
  107.     {
  108.         if (!$this->kernel instanceof TerminableInterface) {
  109.             return;
  110.         }
  112.         $this->kernel->terminate($request, $response);
  113.     }
  115.     private function doHandle(Request $request, int $type, bool $catch): HttpKernelResult
  116.     {
  117.         // create core kernel which contains bootstrapping for plugins etc.
  118.         $kernel = $this->createKernel();
  119.         $kernel->boot();
  121.         $container = $kernel->getContainer();
  123.         // transform request to resolve seo urls and detect sales channel
  124.         $transformed = $container
  125.             ->get(RequestTransformerInterface::class)
  126.             ->transform($request);
  128.         $redirect = $container
  129.             ->get(CanonicalRedirectService::class)
  130.             ->getRedirect($transformed);
  132.         if ($redirect instanceof RedirectResponse) {
  133.             $event = new BeforeSendRedirectResponseEvent($transformed, $redirect);
  134.             $container->get('event_dispatcher')->dispatch($event);
  136.             return new HttpKernelResult($transformed, $event->getResponse());
  137.         }
  139.         // check for http caching
  140.         $enabled = $container->hasParameter('shopware.http.cache.enabled')
  141.             && $container->getParameter('shopware.http.cache.enabled');
  142.         if ($enabled && $container->has(CacheStore::class)) {
  143.             $kernel = new static::$httpCacheClass($kernel, $container->get(CacheStore::class), null, ['debug' => $this->debug]);
  144.         }
  146.         $response = $kernel->handle($transformed, $type, $catch);
  148.         // fire event to trigger runtime events like seo url headers
  149.         $event = new BeforeSendResponseEvent($transformed, $response);
  150.         $container->get('event_dispatcher')->dispatch($event);
  152.         return new HttpKernelResult($transformed, $event->getResponse());
  153.     }
  155.     private function createKernel(): KernelInterface
  156.     {
  157.         if ($this->kernel !== null) {
  158.             return $this->kernel;
  159.         }
  161.         if (InstalledVersions::isInstalled('shopware/platform')) {
  162.             $shopwareVersion = InstalledVersions::getVersion('shopware/platform')
  163.                 . '@' . InstalledVersions::getReference('shopware/platform');
  164.         } else {
  165.             $shopwareVersion = InstalledVersions::getVersion('shopware/core')
  166.                 . '@' . InstalledVersions::getReference('shopware/core');
  167.         }
  169.         $middlewares = [];
  170.         if (\PHP_SAPI !== 'cli' && $this->environment !== 'prod' && InstalledVersions::isInstalled('symfony/doctrine-bridge')) {
  171.             $middlewares = [new ProfilingMiddleware()];
  172.         }
  174.         $connection = self::getConnection($middlewares);
  176.         $pluginLoader = $this->createPluginLoader($connection);
  178.         $storage = new MySQLKeyValueStorage($connection);
  179.         $cacheId = (new CacheIdLoader($storage))->load();
  181.         return $this->kernel = new static::$kernelClass(
  182.             $this->environment,
  183.             $this->debug,
  184.             $pluginLoader,
  185.             $cacheId,
  186.             $shopwareVersion,
  187.             $connection,
  188.             $this->getProjectDir()
  189.         );
  190.     }
  192.     private function getProjectDir(): string
  193.     {
  194.         if ($this->projectDir === null) {
  195.             if ($dir = $_ENV['PROJECT_ROOT'] ?? $_SERVER['PROJECT_ROOT'] ?? false) {
  196.                 return $this->projectDir = $dir;
  197.             }
  199.             $r = new \ReflectionObject($this);
  201.             /** @var string $dir */
  202.             $dir = $r->getFileName();
  203.             if (!file_exists($dir)) {
  204.                 // @phpstan-ignore-next-line Ignore domain exception - class will be removed
  205.                 throw new \LogicException(sprintf('Cannot auto-detect project dir for kernel of class "%s".', $r->name));
  206.             }
  208.             $dir = $rootDir = \dirname($dir);
  209.             while (!file_exists($dir . '/vendor')) {
  210.                 if ($dir === \dirname($dir)) {
  211.                     return $this->projectDir = $rootDir;
  212.                 }
  213.                 $dir = \dirname($dir);
  214.             }
  215.             $this->projectDir = $dir;
  216.         }
  218.         return $this->projectDir;
  219.     }
  221.     private function createPluginLoader(Connection $connection): KernelPluginLoader
  222.     {
  223.         if ($this->pluginLoader) {
  224.             return $this->pluginLoader;
  225.         }
  227.         if (!$this->classLoader) {
  228.             // @phpstan-ignore-next-line Ignore domain exception - class will be removed
  229.             throw new \RuntimeException('No plugin loader and no class loader provided');
  230.         }
  232.         $this->pluginLoader = new DbalKernelPluginLoader($this->classLoader, null, $connection);
  234.         return $this->pluginLoader;
  235.     }
  236. }