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

  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.     /**
  16.      * @internal
  17.      */
  18.     public function __construct(
  19.         private readonly Connection $connection,
  20.         private readonly ?CacheItemPoolInterface $restartSignalCachePool = null
  21.     ) {
  22.     }
  24.     public function load(): string
  25.     {
  26.         $cacheId = EnvironmentHelper::getVariable('SHOPWARE_CACHE_ID');
  27.         if ($cacheId) {
  28.             return (string) $cacheId;
  29.         }
  31.         try {
  32.             $cacheId = $this->connection->fetchOne(
  33.                 '# cache-id-loader
  34.                 SELECT `value` FROM app_config WHERE `key` = :key',
  35.                 ['key' => 'cache-id']
  36.             );
  37.         } catch (\Exception) {
  38.             $cacheId = null;
  39.         }
  41.         if (\is_string($cacheId)) {
  42.             return $cacheId;
  43.         }
  45.         $cacheId = Uuid::randomHex();
  47.         try {
  48.             $this->write($cacheId);
  50.             return $cacheId;
  51.         } catch (\Exception) {
  52.             return 'live';
  53.         }
  54.     }
  56.     public function write(string $cacheId): void
  57.     {
  58.         $this->connection->executeStatement(
  59.             'REPLACE INTO app_config (`key`, `value`) VALUES (:key, :cacheId)',
  60.             ['cacheId' => $cacheId, 'key' => 'cache-id']
  61.         );
  63.         if ($this->restartSignalCachePool) {
  64.             $cacheItem = $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  65.             $cacheItem->set(microtime(true));
  66.             $this->restartSignalCachePool->save($cacheItem);
  67.         }
  68.     }
  69. }