vendor/shopware/core/HttpKernel.php line 142

  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\Event\BeforeSendRedirectResponseEvent;
  14. use Shopware\Core\Framework\Event\BeforeSendResponseEvent;
  15. use Shopware\Core\Framework\Log\Package;
  16. use Shopware\Core\Framework\Plugin\KernelPluginLoader\DbalKernelPluginLoader;
  17. use Shopware\Core\Framework\Plugin\KernelPluginLoader\KernelPluginLoader;
  18. use Shopware\Core\Framework\Routing\CanonicalRedirectService;
  19. use Shopware\Core\Framework\Routing\RequestTransformerInterface;
  20. use Shopware\Core\Profiling\Doctrine\ProfilingMiddleware;
  21. use Shopware\Storefront\Framework\Cache\CacheStore;
  22. use Symfony\Component\HttpFoundation\RedirectResponse;
  23. use Symfony\Component\HttpFoundation\Request;
  24. use Symfony\Component\HttpFoundation\Response;
  25. use Symfony\Component\HttpKernel\HttpCache\HttpCache;
  26. use Symfony\Component\HttpKernel\HttpKernelInterface;
  27. use Symfony\Component\HttpKernel\KernelInterface;
  28. use Symfony\Component\HttpKernel\TerminableInterface;
  30. /**
  31.  * @psalm-import-type Params from DriverManager
  32.  */
  33. #[Package('core')]
  34. class HttpKernel
  35. {
  36.     protected static ?Connection $connection = null;
  38.     /**
  39.      * @var class-string<Kernel>
  40.      */
  41.     protected static string $kernelClass = Kernel::class;
  43.     /**
  44.      * @var class-string<HttpCache>
  45.      */
  46.     protected static string $httpCacheClass = HttpCache::class;
  48.     protected ?string $projectDir = null;
  50.     protected ?KernelPluginLoader $pluginLoader = null;
  52.     protected ?KernelInterface $kernel = null;
  54.     public function __construct(
  55.         protected string $environment,
  56.         protected bool $debug,
  57.         protected ?ClassLoader $classLoader = null
  58.     ) {
  59.     }
  61.     public function handle(Request $request, int $type = HttpKernelInterface::MAIN_REQUEST, bool $catch = true): HttpKernelResult
  62.     {
  63.         try {
  64.             return $this->doHandle($request, $type, $catch);
  65.         } catch (Exception $e) {
  66.             /** @var Params|array{url?: string} $connectionParams */
  67.             $connectionParams = self::getConnection()->getParams();
  69.             $message = str_replace([$connectionParams['url'] ?? null, $connectionParams['password'] ?? null, $connectionParams['user'] ?? null], '******', $e->getMessage());
  71.             throw new \RuntimeException(sprintf('Could not connect to database. Message from SQL Server: %s', $message));
  72.         }
  73.     }
  75.     public function getKernel(): KernelInterface
  76.     {
  77.         return $this->createKernel();
  78.     }
  80.     /**
  81.      * Allows to switch the plugin loading.
  82.      */
  83.     public function setPluginLoader(KernelPluginLoader $pluginLoader): void
  84.     {
  85.         $this->pluginLoader = $pluginLoader;
  86.     }
  88.     /**
  89.      * @param array<Middleware> $middlewares
  90.      */
  91.     public static function getConnection(array $middlewares = []): Connection
  92.     {
  93.         if (self::$connection) {
  94.             return self::$connection;
  95.         }
  97.         self::$connection = MySQLFactory::create($middlewares);
  99.         return self::$connection;
  100.     }
  102.     public function terminate(Request $request, Response $response): void
  103.     {
  104.         if (!$this->kernel instanceof TerminableInterface) {
  105.             return;
  106.         }
  108.         $this->kernel->terminate($request, $response);
  109.     }
  111.     private function doHandle(Request $request, int $type, bool $catch): HttpKernelResult
  112.     {
  113.         // create core kernel which contains bootstrapping for plugins etc.
  114.         $kernel = $this->createKernel();
  115.         $kernel->boot();
  117.         $container = $kernel->getContainer();
  119.         // transform request to resolve seo urls and detect sales channel
  120.         $transformed = $container
  121.             ->get(RequestTransformerInterface::class)
  122.             ->transform($request);
  124.         $redirect = $container
  125.             ->get(CanonicalRedirectService::class)
  126.             ->getRedirect($transformed);
  128.         if ($redirect instanceof RedirectResponse) {
  129.             $event = new BeforeSendRedirectResponseEvent($transformed, $redirect);
  130.             $container->get('event_dispatcher')->dispatch($event);
  132.             return new HttpKernelResult($transformed, $event->getResponse());
  133.         }
  135.         // check for http caching
  136.         $enabled = $container->hasParameter('shopware.http.cache.enabled')
  137.             && $container->getParameter('shopware.http.cache.enabled');
  138.         if ($enabled && $container->has(CacheStore::class)) {
  139.             $kernel = new static::$httpCacheClass($kernel, $container->get(CacheStore::class), null, ['debug' => $this->debug]);
  140.         }
  142.         $response = $kernel->handle($transformed, $type, $catch);
  144.         // fire event to trigger runtime events like seo url headers
  145.         $event = new BeforeSendResponseEvent($transformed, $response);
  146.         $container->get('event_dispatcher')->dispatch($event);
  148.         return new HttpKernelResult($transformed, $event->getResponse());
  149.     }
  151.     private function createKernel(): KernelInterface
  152.     {
  153.         if ($this->kernel !== null) {
  154.             return $this->kernel;
  155.         }
  157.         if (InstalledVersions::isInstalled('shopware/platform')) {
  158.             $shopwareVersion = InstalledVersions::getVersion('shopware/platform')
  159.                 . '@' . InstalledVersions::getReference('shopware/platform');
  160.         } else {
  161.             $shopwareVersion = InstalledVersions::getVersion('shopware/core')
  162.                 . '@' . InstalledVersions::getReference('shopware/core');
  163.         }
  165.         $middlewares = [];
  166.         if (InstalledVersions::isInstalled('symfony/doctrine-bridge')) {
  167.             $middlewares = [new ProfilingMiddleware()];
  168.         }
  170.         $connection = self::getConnection($middlewares);
  172.         $pluginLoader = $this->createPluginLoader($connection);
  174.         $cacheId = (new CacheIdLoader($connection))->load();
  176.         return $this->kernel = new static::$kernelClass(
  177.             $this->environment,
  178.             $this->debug,
  179.             $pluginLoader,
  180.             $cacheId,
  181.             $shopwareVersion,
  182.             $connection,
  183.             $this->getProjectDir()
  184.         );
  185.     }
  187.     private function getProjectDir(): string
  188.     {
  189.         if ($this->projectDir === null) {
  190.             if ($dir = $_ENV['PROJECT_ROOT'] ?? $_SERVER['PROJECT_ROOT'] ?? false) {
  191.                 return $this->projectDir = $dir;
  192.             }
  194.             $r = new \ReflectionObject($this);
  196.             /** @var string $dir */
  197.             $dir = $r->getFileName();
  198.             if (!file_exists($dir)) {
  199.                 throw new \LogicException(sprintf('Cannot auto-detect project dir for kernel of class "%s".', $r->name));
  200.             }
  202.             $dir = $rootDir = \dirname($dir);
  203.             while (!file_exists($dir . '/vendor')) {
  204.                 if ($dir === \dirname($dir)) {
  205.                     return $this->projectDir = $rootDir;
  206.                 }
  207.                 $dir = \dirname($dir);
  208.             }
  209.             $this->projectDir = $dir;
  210.         }
  212.         return $this->projectDir;
  213.     }
  215.     private function createPluginLoader(Connection $connection): KernelPluginLoader
  216.     {
  217.         if ($this->pluginLoader) {
  218.             return $this->pluginLoader;
  219.         }
  221.         if (!$this->classLoader) {
  222.             throw new \RuntimeException('No plugin loader and no class loader provided');
  223.         }
  225.         $this->pluginLoader = new DbalKernelPluginLoader($this->classLoader, null, $connection);
  227.         return $this->pluginLoader;
  228.     }
  229. }