vendor/symfony/cache-contracts/CacheTrait.php line 64

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <[email protected]>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Contracts\Cache;
  14. use Psr\Cache\CacheItemPoolInterface;
  15. use Psr\Cache\InvalidArgumentException;
  16. use Psr\Log\LoggerInterface;
  18. // Help opcache.preload discover always-needed symbols
  19. class_exists(InvalidArgumentException::class);
  21. /**
  22.  * An implementation of CacheInterface for PSR-6 CacheItemPoolInterface classes.
  23.  *
  24.  * @author Nicolas Grekas <[email protected]>
  25.  */
  26. trait CacheTrait
  27. {
  28.     public function get(string $key, callable $callback, ?float $beta = null, ?array &$metadata = null): mixed
  29.     {
  30.         return $this->doGet($this, $key, $callback, $beta, $metadata);
  31.     }
  33.     public function delete(string $key): bool
  34.     {
  35.         return $this->deleteItem($key);
  36.     }
  38.     private function doGet(CacheItemPoolInterface $pool, string $key, callable $callback, ?float $beta, ?array &$metadata = null, ?LoggerInterface $logger = null): mixed
  39.     {
  40.         if (0 > $beta ??= 1.0) {
  41.             throw new class(\sprintf('Argument "$beta" provided to "%s::get()" must be a positive number, %f given.', static::class, $beta)) extends \InvalidArgumentException implements InvalidArgumentException {};
  42.         }
  44.         $item = $pool->getItem($key);
  45.         $recompute = !$item->isHit() || \INF === $beta;
  46.         $metadata = $item instanceof ItemInterface ? $item->getMetadata() : [];
  48.         if (!$recompute && $metadata) {
  49.             $expiry = $metadata[ItemInterface::METADATA_EXPIRY] ?? false;
  50.             $ctime = $metadata[ItemInterface::METADATA_CTIME] ?? false;
  52.             if ($recompute = $ctime && $expiry && $expiry <= ($now = microtime(true)) - $ctime / 1000 * $beta * log(random_int(1, \PHP_INT_MAX) / \PHP_INT_MAX)) {
  53.                 // force applying defaultLifetime to expiry
  54.                 $item->expiresAt(null);
  55.                 $logger?->info('Item "{key}" elected for early recomputation {delta}s before its expiration', [
  56.                     'key' => $key,
  57.                     'delta' => \sprintf('%.1f', $expiry - $now),
  58.                 ]);
  59.             }
  60.         }
  62.         if ($recompute) {
  63.             $save = true;
  64.             $item->set($callback($item, $save));
  65.             if ($save) {
  66.                 $pool->save($item);
  67.             }
  68.         }
  70.         return $item->get();
  71.     }
  72. }