vendor/shopware/core/Framework/Adapter/Cache/CacheIdLoader.php line 32

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Adapter\Cache;
  5. use Doctrine\DBAL\Connection;
  6. use Psr\Cache\CacheItemPoolInterface;
  7. use Shopware\Core\DevOps\Environment\EnvironmentHelper;
  8. use Shopware\Core\Framework\Uuid\Uuid;
  9. use Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener;
  11. class CacheIdLoader
  12. {
  13.     /**
  14.      * @var Connection
  15.      */
  16.     private $connection;
  18.     /**
  19.      * @var CacheItemPoolInterface|null
  20.      */
  21.     private $restartSignalCachePool;
  23.     /**
  24.      * @internal
  25.      */
  26.     public function __construct(Connection $connection, ?CacheItemPoolInterface $restartSignalCachePool = null)
  27.     {
  28.         $this->connection = $connection;
  29.         $this->restartSignalCachePool = $restartSignalCachePool;
  30.     }
  32.     public function load(): string
  33.     {
  34.         $cacheId = EnvironmentHelper::getVariable('SHOPWARE_CACHE_ID');
  35.         if ($cacheId) {
  36.             return (string) $cacheId;
  37.         }
  39.         try {
  40.             $cacheId = $this->connection->fetchColumn(
  41.                 '# cache-id-loader
  42.                 SELECT `value` FROM app_config WHERE `key` = :key',
  43.                 ['key' => 'cache-id']
  44.             );
  45.         } catch (\Exception $e) {
  46.             $cacheId = null;
  47.         }
  49.         if (\is_string($cacheId)) {
  50.             return $cacheId;
  51.         }
  53.         $cacheId = Uuid::randomHex();
  55.         try {
  56.             $this->write($cacheId);
  58.             return $cacheId;
  59.         } catch (\Exception $e) {
  60.             return 'live';
  61.         }
  62.     }
  64.     public function write(string $cacheId): void
  65.     {
  66.         $this->connection->executeUpdate(
  67.             'REPLACE INTO app_config (`key`, `value`) VALUES (:key, :cacheId)',
  68.             ['cacheId' => $cacheId, 'key' => 'cache-id']
  69.         );
  71.         if ($this->restartSignalCachePool) {
  72.             $cacheItem = $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  73.             $cacheItem->set(microtime(true));
  74.             $this->restartSignalCachePool->save($cacheItem);
  75.         }
  76.     }
  77. }