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

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.     public function __construct(Connection $connection, ?CacheItemPoolInterface $restartSignalCachePool = null)
  24.     {
  25.         $this->connection = $connection;
  26.         $this->restartSignalCachePool = $restartSignalCachePool;
  27.     }
  29.     public function load(): string
  30.     {
  31.         $cacheId = EnvironmentHelper::getVariable('SHOPWARE_CACHE_ID');
  32.         if ($cacheId) {
  33.             return (string) $cacheId;
  34.         }
  36.         try {
  37.             $cacheId = $this->connection->fetchColumn(
  38.                 '# cache-id-loader
  39.                 SELECT `value` FROM app_config WHERE `key` = :key',
  40.                 ['key' => 'cache-id']
  41.             );
  42.         } catch (\Exception $e) {
  43.             $cacheId = null;
  44.         }
  46.         if (\is_string($cacheId)) {
  47.             return $cacheId;
  48.         }
  50.         $cacheId = Uuid::randomHex();
  52.         try {
  53.             $this->write($cacheId);
  55.             return $cacheId;
  56.         } catch (\Exception $e) {
  57.             return 'live';
  58.         }
  59.     }
  61.     public function write(string $cacheId): void
  62.     {
  63.         $this->connection->executeUpdate(
  64.             'REPLACE INTO app_config (`key`, `value`) VALUES (:key, :cacheId)',
  65.             ['cacheId' => $cacheId, 'key' => 'cache-id']
  66.         );
  68.         if ($this->restartSignalCachePool) {
  69.             $cacheItem = $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  70.             $cacheItem->set(microtime(true));
  71.             $this->restartSignalCachePool->save($cacheItem);
  72.         }
  73.     }
  74. }