vendor/ibexa/http-cache/src/lib/ProxyClient/Varnish.php line 26

Open in your IDE?
  1. <?php
  3. /**
  4.  * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5.  * @license For full copyright and license information view LICENSE file distributed with this source code.
  6.  */
  7. declare(strict_types=1);
  9. namespace Ibexa\HttpCache\ProxyClient;
  11. use FOS\HttpCache\ProxyClient\Dispatcher;
  12. use FOS\HttpCache\ProxyClient\Invalidation\BanCapable;
  13. use FOS\HttpCache\ProxyClient\Invalidation\PurgeCapable;
  14. use FOS\HttpCache\ProxyClient\Invalidation\RefreshCapable;
  15. use FOS\HttpCache\ProxyClient\Invalidation\TagCapable;
  16. use FOS\HttpCache\ProxyClient\Varnish as FosVarnish;
  17. use Http\Message\RequestFactory;
  18. use Ibexa\Bundle\HttpCache\Controller\InvalidateTokenController;
  19. use Ibexa\Contracts\Core\SiteAccess\ConfigResolverInterface;
  21. final class Varnish extends FosVarnish implements BanCapable, PurgeCapable, RefreshCapable, TagCapable
  22. {
  23.     /** @var \Ibexa\Contracts\Core\SiteAccess\ConfigResolverInterface */
  24.     private $configResolver;
  26.     public function __construct(
  27.         ConfigResolverInterface $configResolver,
  28.         Dispatcher $httpDispatcher,
  29.         array $options = [],
  30.         ?RequestFactory $messageFactory = null
  31.     ) {
  32.         parent::__construct($httpDispatcher, $options, $messageFactory);
  33.         $this->configResolver = $configResolver;
  34.     }
  36.     private function fetchAndMergeAuthHeaders(array $headers): array
  37.     {
  38.         $invalidateToken = $this->getInvalidateToken();
  39.         if (null !== $invalidateToken) {
  40.             $headers[InvalidateTokenController::TOKEN_HEADER_NAME] = $invalidateToken;
  41.         }
  43.         return $headers;
  44.     }
  46.     private function getInvalidateToken(): ?string
  47.     {
  48.         if ($this->configResolver->hasParameter('http_cache.varnish_invalidate_token')) {
  49.             return $this->configResolver->getParameter('http_cache.varnish_invalidate_token');
  50.         }
  52.         return null;
  53.     }
  55.     protected function queueRequest($method, $url, array $headers, $validateHost = true, $body = null)
  56.     {
  57.         parent::queueRequest($method, $url, $this->fetchAndMergeAuthHeaders($headers), $body);
  58.     }
  59. }
  61. class_alias(Varnish::class, 'EzSystems\PlatformHttpCacheBundle\ProxyClient\Varnish');