custom/plugins/SwagEnterpriseSearchPlatform/src/Cache/CacheInvalidationSubscriber.php line 49

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace Swag\EnterpriseSearch\Cache;
  6. use Psr\Cache\CacheItemPoolInterface;
  7. use Swag\EnterpriseSearch\Action\ActionSearchTerm\Events\ActionSearchTermIndexerEvent;
  8. use Swag\EnterpriseSearch\Action\Events\ActionIndexerEvent;
  9. use Symfony\Component\Cache\Adapter\TagAwareAdapterInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class CacheInvalidationSubscriber implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var CacheItemPoolInterface[]
  16.      */
  17.     private $adapters;
  19.     /**
  20.      * @var \Shopware\Core\Framework\Adapter\Cache\CacheInvalidator|null
  21.      */
  22.     private $cacheInvalidator;
  24.     /**
  25.      * @param \Shopware\Core\Framework\Adapter\Cache\CacheInvalidator|null $cacheInvalidator
  26.      */
  27.     public function __construct(array $adapters, $cacheInvalidator)
  28.     {
  29.         $this->adapters = $adapters;
  30.         $this->cacheInvalidator = $cacheInvalidator;
  31.     }
  33.     /**
  34.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  35.      */
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             ActionIndexerEvent::class => [
  40.                 ['invalidateSearch', 2000],
  41.             ],
  42.             ActionSearchTermIndexerEvent::class => [
  43.                 ['invalidateSearch', 2000],
  44.             ],
  45.         ];
  46.     }
  48.     // invalidates the search and suggest route each time a term changed
  49.     public function invalidateSearch(): void
  50.     {
  51.         $tags = [
  52.             'product-suggest-route',
  53.             'product-search-route',
  54.         ];
  56.         if ($this->cacheInvalidator === null) {
  57.             $this->invalidateCache($tags);
  59.             return;
  60.         }
  62.         $this->cacheInvalidator->invalidate($tags);
  63.     }
  65.     private function invalidateCache(array $keys): void
  66.     {
  67.         foreach ($this->adapters as $adapter) {
  68.             if ($adapter instanceof TagAwareAdapterInterface) {
  69.                 $adapter->invalidateTags($keys);
  70.             }
  71.         }
  73.         foreach ($this->adapters as $adapter) {
  74.             $adapter->deleteItems($keys);
  75.         }
  76.     }
  77. }