src/EventSubscriber/ContentRefreshSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Blog;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\HttpKernel\Event\RequestEvent;
  8. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  9. use Symfony\Contracts\Cache\CacheInterface;
  11. class ContentRefreshSubscriber implements EventSubscriberInterface
  12. {
  13.     public function __construct(private CacheInterface $cache, private Blog $blog)
  14.     {
  15.     }
  17.     public function onKernelRequest(RequestEvent $event): void
  18.     {
  19.         // Refresh content if a special query parameter is given
  20.         $request = $event->getRequest();
  21.         if ($request->query->has('refresh')) {
  22.             $this->refresh();
  23.         }
  24.     }
  26.     public function onKernelTerminate(TerminateEvent $event): void
  27.     {
  28.         // Periodically reload site content after responses are sent
  29.         $lastRefresh = $this->cache->get('lastContentRefresh', function () {
  30.             return 0;
  31.         });
  33.         if ($lastRefresh < strtotime('-5 minutes')) {
  34.             $this->refresh();
  35.         }
  36.     }
  38.     private function refresh(): void
  39.     {
  40.         // Update the last refresh time now to minimize cache stampede
  41.         $this->cache->get('lastContentRefresh', function () {
  42.             return time();
  43.         }, INF);
  45.         $this->blog->bustCache();
  46.     }
  48.     public static function getSubscribedEvents(): array
  49.     {
  50.         return [
  51.             'kernel.request' => 'onKernelRequest',
  52.             'kernel.terminate' => 'onKernelTerminate',
  53.         ];
  54.     }
  55. }