custom/static-plugins/GlobusSW6/src/Service/Cache/HttpCacheHitMissRater.php line 37

Open in your IDE?
  1. <?php
  3. namespace GlobusSW6\Service\Cache;
  5. use Shopware\Core\Framework\Adapter\Cache\RedisConnectionFactory;
  6. use Shopware\Storefront\Framework\Cache\Event\HttpCacheHitEvent;
  7. use Shopware\Storefront\Framework\Cache\Event\HttpCacheItemWrittenEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. /**
  11.  * @see https://speakerdeck.com/beberlei/best-practices-for-running-shopware-6-in-production?slide=14
  12.  */
  13. class HttpCacheHitMissRater implements EventSubscriberInterface
  14. {
  15.     private RedisConnectionFactory $redisConnectionFactory;
  16.     private string $redisDsn;
  17.     private $redis;
  19.     /**
  20.      * @param RedisConnectionFactory $redisConnectionFactory
  21.      * @param string $redisDsn
  22.      */
  23.     public function __construct(RedisConnectionFactory $redisConnectionFactory, string $redisDsn)
  24.     {
  25.         $this->redisConnectionFactory = $redisConnectionFactory;
  26.         $this->redisDsn = $redisDsn;
  27.     }
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             HttpCacheItemWrittenEvent::class => 'onCacheMiss',
  33.             HttpCacheHitEvent::class => 'onCacheHit',
  34.         ];
  35.     }
  37.     public function onCacheMiss(HttpCacheItemWrittenEvent $event)
  38.     {
  39.         try {
  40.             $this->getRedis()->hIncrBy('http_cache_misses', date('YmdH'), 1);
  41.         } catch (\Throwable $t) {
  42.             // nth
  43.         }
  44.     }
  46.     public function onCacheHit(HttpCacheHitEvent $event)
  47.     {
  48.         try {
  49.             $this->getRedis()->hIncrBy('http_cache_hits', date('YmdH'), 1);
  50.         } catch (\Throwable $t) {
  51.             // nth
  52.         }
  53.     }
  55.     private function getRedis()
  56.     {
  57.         if ($this->redis === null) {
  58.             $this->redis = $this->redisConnectionFactory->create($this->redisDsn);
  59.         }
  61.         return $this->redis;
  62.     }
  63. }