src/Core/Framework/Routing/SalesChannelRequestContextResolver.php line 77

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Routing;
  5. use Shopware\Core\Checkout\Cart\CartException;
  6. use Shopware\Core\Framework\Log\Package;
  7. use Shopware\Core\Framework\Routing\Event\SalesChannelContextResolvedEvent;
  8. use Shopware\Core\Framework\Routing\Exception\MissingRequestParameterException;
  9. use Shopware\Core\Framework\Util\Random;
  10. use Shopware\Core\PlatformRequest;
  11. use Shopware\Core\SalesChannelRequest;
  12. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextServiceInterface;
  13. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextServiceParameters;
  14. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  15. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\Request as SymfonyRequest;
  19. #[Package('core')]
  20. class SalesChannelRequestContextResolver implements RequestContextResolverInterface
  21. {
  22.     use RouteScopeCheckTrait;
  24.     /**
  25.      * @var SalesChannelContext[]
  26.      */
  27.     private array $cache = [];
  29.     /**
  30.      * @internal
  31.      */
  32.     public function __construct(
  33.         private readonly RequestContextResolverInterface $decorated,
  34.         private readonly SalesChannelContextServiceInterface $contextService,
  35.         private readonly EventDispatcherInterface $eventDispatcher,
  36.         private readonly RouteScopeRegistry $routeScopeRegistry
  37.     ) {
  38.     }
  40.     public function resolve(SymfonyRequest $request): void
  41.     {
  42.         if (!$request->attributes->has(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID)) {
  43.             $this->decorated->resolve($request);
  45.             return;
  46.         }
  48.         if (!$this->isRequestScoped($request, SalesChannelContextRouteScopeDependant::class)) {
  49.             return;
  50.         }
  52.         if (
  53.             $this->contextTokenRequired($request) === true
  54.             && !$request->headers->has(PlatformRequest::HEADER_CONTEXT_TOKEN)
  55.         ) {
  56.             throw new MissingRequestParameterException(PlatformRequest::HEADER_CONTEXT_TOKEN);
  57.         }
  59.         if (
  60.             $this->contextTokenRequired($request) === false
  61.             && !$request->headers->has(PlatformRequest::HEADER_CONTEXT_TOKEN)
  62.         ) {
  63.             $request->headers->set(PlatformRequest::HEADER_CONTEXT_TOKEN, Random::getAlphanumericString(32));
  64.         }
  66.         $contextToken = $request->headers->get(PlatformRequest::HEADER_CONTEXT_TOKEN);
  67.         $salesChannelId = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID);
  68.         $language = $request->headers->get(PlatformRequest::HEADER_LANGUAGE_ID);
  69.         $currencyId = $request->attributes->get(SalesChannelRequest::ATTRIBUTE_DOMAIN_CURRENCY_ID);
  70.         $domainId = $request->attributes->get(SalesChannelRequest::ATTRIBUTE_DOMAIN_ID);
  72.         $cacheKey = $salesChannelId . $contextToken . $language . $currencyId . $domainId;
  74.         if (!empty($this->cache[$cacheKey])) {
  75.             $context = $this->cache[$cacheKey];
  76.         } else {
  77.             $context = $this->contextService->get(
  78.                 new SalesChannelContextServiceParameters((string) $salesChannelId, (string) $contextToken, $language, $currencyId, $domainId)
  79.             );
  80.             $request->headers->set(PlatformRequest::HEADER_CONTEXT_TOKEN, $context->getToken());
  81.         }
  83.         $this->validateLogin($request, $context);
  85.         $request->attributes->set(PlatformRequest::ATTRIBUTE_CONTEXT_OBJECT, $context->getContext());
  86.         $request->attributes->set(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT, $context);
  87.         $request->headers->set(PlatformRequest::HEADER_CONTEXT_TOKEN, $context->getToken());
  89.         $this->eventDispatcher->dispatch(
  90.             new SalesChannelContextResolvedEvent($context, (string) $contextToken)
  91.         );
  92.     }
  94.     public function handleSalesChannelContext(Request $request, string $salesChannelId, string $contextToken): void
  95.     {
  96.         $language = $request->headers->get(PlatformRequest::HEADER_LANGUAGE_ID);
  97.         $currencyId = $request->attributes->get(SalesChannelRequest::ATTRIBUTE_DOMAIN_CURRENCY_ID);
  99.         $context = $this->contextService
  100.             ->get(new SalesChannelContextServiceParameters($salesChannelId, $contextToken, $language, $currencyId));
  102.         $request->attributes->set(PlatformRequest::ATTRIBUTE_CONTEXT_OBJECT, $context->getContext());
  103.         $request->attributes->set(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT, $context);
  104.     }
  106.     protected function getScopeRegistry(): RouteScopeRegistry
  107.     {
  108.         return $this->routeScopeRegistry;
  109.     }
  111.     private function contextTokenRequired(Request $request): bool
  112.     {
  113.         return $request->attributes->get(PlatformRequest::ATTRIBUTE_CONTEXT_TOKEN_REQUIRED, false);
  114.     }
  116.     private function validateLogin(Request $request, SalesChannelContext $context): void
  117.     {
  118.         if (!$request->attributes->get(PlatformRequest::ATTRIBUTE_LOGIN_REQUIRED)) {
  119.             return;
  120.         }
  122.         if ($context->getCustomer() === null) {
  123.             throw CartException::customerNotLoggedIn();
  124.         }
  126.         if ($request->attributes->get(PlatformRequest::ATTRIBUTE_LOGIN_REQUIRED_ALLOW_GUEST, false) === false && $context->getCustomer()->getGuest()) {
  127.             throw CartException::customerNotLoggedIn();
  128.         }
  129.     }
  130. }