src/Juki/Bundle/AppBundle/EventListener/CacheSubscriber.php line 39

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Juki\Bundle\AppBundle\EventListener;
  7. use Hitso\Bundle\CommonBundle\Doctrine\Event\EntityEvent;
  8. use Symfony\Bundle\FrameworkBundle\Console\Application;
  9. use Symfony\Component\Console\Input\ArrayInput;
  10. use Symfony\Component\Console\Output\NullOutput;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpKernel\KernelInterface;
  14. class CacheSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var KernelInterface
  18.      */
  19.     protected $kernel;
  21.     public function __construct(KernelInterface $kernel)
  22.     {
  23.         $this->kernel = $kernel;
  24.     }
  26.     public static function getSubscribedEvents()
  27.     {
  28.         return [
  29.             'article.post_create'   => 'onPostSave',
  30.             'article.post_update'   => 'onPostSave',
  31.             'content.post_create'   => 'onPostSave',
  32.             'content.post_update'   => 'onPostSave',
  33.             'product.post_create'   => 'onPostSave',
  34.             'product.post_update'   => 'onPostSave',
  35.             'repo_file.post_update' => 'onPostSave',
  36.         ];
  37.     }
  39.     public function onPostSave(EntityEvent $event): void
  40.     {
  41.         $cacheDir = $this->kernel->getCacheDir();
  43.         // opcache
  44.         if (function_exists('opcache_reset')) {
  45.             opcache_reset();
  46.         }
  48.         // apcu
  49.         if (function_exists('apcu_clear_cache')) {
  50.             apcu_clear_cache();
  51.         }
  53.         $application = new Application($this->kernel);
  54.         $application->setAutoExit(false);
  56.         $commands = [
  57.             [
  58.                 'command' => 'cache:pool:clear',
  59.                 'pools'   => ['cache.global_clearer'],
  60.             ],
  61.             [
  62.                 'command' => 'doctrine:cache:clear-metadata',
  63.             ],
  64.             [
  65.                 'command' => 'doctrine:cache:clear-query',
  66.             ],
  67.             [
  68.                 'command' => 'doctrine:cache:clear-result',
  69.             ],
  70.         ];
  72.         foreach ($commands as $command) {
  73.             $input = new ArrayInput($command);
  75.             $output = new NullOutput();
  76.             $application->run($input, $output);
  78.             $done[] = $command['command'];
  79.         }
  81.         exec('rm -rf ' . $cacheDir . '-tmp');
  82.         exec('mv ' . $cacheDir . ' ' . $cacheDir . '-tmp');
  83.         exec('rm -rf ' . $cacheDir . '-tmp');
  85.         $this->kernel->getContainer()->get('session')->getFlashBag()->add('success', 'Cache został opróżniony.');
  86.     }
  87. }