vendor/symfony/symfony/src/Symfony/Component/Cache/Traits/AbstractAdapterTrait.php line 39

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  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\Component\Cache\Traits;
  14. use Psr\Cache\CacheItemInterface;
  15. use Symfony\Component\Cache\CacheItem;
  17. /**
  18.  * @author Nicolas Grekas <p@tchwork.com>
  19.  *
  20.  * @internal
  21.  */
  22. trait AbstractAdapterTrait
  23. {
  24.     use AbstractTrait;
  26.     /**
  27.      * @var \Closure needs to be set by class, signature is function(string <key>, mixed <value>, bool <isHit>)
  28.      */
  29.     private $createCacheItem;
  31.     /**
  32.      * @var \Closure needs to be set by class, signature is function(array <deferred>, string <namespace>, array <&expiredIds>)
  33.      */
  34.     private $mergeByLifetime;
  36.     /**
  37.      * {@inheritdoc}
  38.      */
  39.     public function getItem($key)
  40.     {
  41.         if ($this->deferred) {
  42.             $this->commit();
  43.         }
  44.         $id = $this->getId($key);
  46.         $f = $this->createCacheItem;
  47.         $isHit = false;
  48.         $value = null;
  50.         try {
  51.             foreach ($this->doFetch([$id]) as $value) {
  52.                 $isHit = true;
  53.             }
  55.             return $f($key, $value, $isHit);
  56.         } catch (\Exception $e) {
  57.             CacheItem::log($this->logger, 'Failed to fetch key "{key}": '.$e->getMessage(), ['key' => $key, 'exception' => $e]);
  58.         }
  60.         return $f($key, null, false);
  61.     }
  63.     /**
  64.      * {@inheritdoc}
  65.      */
  66.     public function getItems(array $keys = [])
  67.     {
  68.         if ($this->deferred) {
  69.             $this->commit();
  70.         }
  71.         $ids = [];
  73.         foreach ($keys as $key) {
  74.             $ids[] = $this->getId($key);
  75.         }
  76.         try {
  77.             $items = $this->doFetch($ids);
  78.         } catch (\Exception $e) {
  79.             CacheItem::log($this->logger, 'Failed to fetch items: '.$e->getMessage(), ['keys' => $keys, 'exception' => $e]);
  80.             $items = [];
  81.         }
  82.         $ids = array_combine($ids, $keys);
  84.         return $this->generateItems($items, $ids);
  85.     }
  87.     /**
  88.      * {@inheritdoc}
  89.      *
  90.      * @return bool
  91.      */
  92.     public function save(CacheItemInterface $item)
  93.     {
  94.         if (!$item instanceof CacheItem) {
  95.             return false;
  96.         }
  97.         $this->deferred[$item->getKey()] = $item;
  99.         return $this->commit();
  100.     }
  102.     /**
  103.      * {@inheritdoc}
  104.      *
  105.      * @return bool
  106.      */
  107.     public function saveDeferred(CacheItemInterface $item)
  108.     {
  109.         if (!$item instanceof CacheItem) {
  110.             return false;
  111.         }
  112.         $this->deferred[$item->getKey()] = $item;
  114.         return true;
  115.     }
  117.     public function __sleep()
  118.     {
  119.         throw new \BadMethodCallException('Cannot serialize '.__CLASS__);
  120.     }
  122.     public function __wakeup()
  123.     {
  124.         throw new \BadMethodCallException('Cannot unserialize '.__CLASS__);
  125.     }
  127.     public function __destruct()
  128.     {
  129.         if ($this->deferred) {
  130.             $this->commit();
  131.         }
  132.     }
  134.     private function generateItems(iterable $items, array &$keys): iterable
  135.     {
  136.         $f = $this->createCacheItem;
  138.         try {
  139.             foreach ($items as $id => $value) {
  140.                 if (!isset($keys[$id])) {
  141.                     throw new InvalidArgumentException(sprintf('Could not match value id "%s" to keys "%s".', $id, implode('", "', $keys)));
  142.                 }
  143.                 $key = $keys[$id];
  144.                 unset($keys[$id]);
  145.                 yield $key => $f($key, $value, true);
  146.             }
  147.         } catch (\Exception $e) {
  148.             CacheItem::log($this->logger, 'Failed to fetch items: '.$e->getMessage(), ['keys' => array_values($keys), 'exception' => $e]);
  149.         }
  151.         foreach ($keys as $key) {
  152.             yield $key => $f($key, null, false);
  153.         }
  154.     }
  155. }