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');