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

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\Log\Package;
  9. use Shopware\Core\Framework\Uuid\Uuid;
  10. use Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener;
  12. #[Package('core')]
  13. class CacheIdLoader
  14. {
  15.     private Connection $connection;
  17.     private ?CacheItemPoolInterface $restartSignalCachePool;
  19.     /**
  20.      * @internal
  21.      */
  22.     public function __construct(Connection $connection, ?CacheItemPoolInterface $restartSignalCachePool = null)
  23.     {
  24.         $this->connection = $connection;
  25.         $this->restartSignalCachePool = $restartSignalCachePool;
  26.     }
  28.     public function load(): string
  29.     {
  30.         $cacheId = EnvironmentHelper::getVariable('SHOPWARE_CACHE_ID');
  31.         if ($cacheId) {
  32.             return (string) $cacheId;
  33.         }
  35.         try {
  36.             $cacheId = $this->connection->fetchOne(
  37.                 '# cache-id-loader
  38.                 SELECT `value` FROM app_config WHERE `key` = :key',
  39.                 ['key' => 'cache-id']
  40.             );
  41.         } catch (\Exception $e) {
  42.             $cacheId = null;
  43.         }
  45.         if (\is_string($cacheId)) {
  46.             return $cacheId;
  47.         }
  49.         $cacheId = Uuid::randomHex();
  51.         try {
  52.             $this->write($cacheId);
  54.             return $cacheId;
  55.         } catch (\Exception $e) {
  56.             return 'live';
  57.         }
  58.     }
  60.     public function write(string $cacheId): void
  61.     {
  62.         $this->connection->executeStatement(
  63.             'REPLACE INTO app_config (`key`, `value`) VALUES (:key, :cacheId)',
  64.             ['cacheId' => $cacheId, 'key' => 'cache-id']
  65.         );
  67.         if ($this->restartSignalCachePool) {
  68.             $cacheItem = $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  69.             $cacheItem->set(microtime(true));
  70.             $this->restartSignalCachePool->save($cacheItem);
  71.         }
  72.     }
  73. }