src/Core/Framework/Adapter/Cache/CacheIdLoader.php line 30

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