vendor/symfony/cache/Traits/FilesystemTrait.php line 55

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 Symfony\Component\Cache\Exception\CacheException;
  16. /**
  17.  * @author Nicolas Grekas <p@tchwork.com>
  18.  * @author Rob Frawley 2nd <rmf@src.run>
  19.  *
  20.  * @internal
  21.  */
  22. trait FilesystemTrait
  23. {
  24.     use FilesystemCommonTrait;
  26.     private $marshaller;
  28.     /**
  29.      * @return bool
  30.      */
  31.     public function prune()
  32.     {
  33.         $time = time();
  34.         $pruned = true;
  36.         foreach ($this->scanHashDir($this->directory) as $file) {
  37.             if (!$h = @fopen($file, 'r')) {
  38.                 continue;
  39.             }
  41.             if (($expiresAt = (int) fgets($h)) && $time >= $expiresAt) {
  42.                 fclose($h);
  43.                 $pruned = (@unlink($file) || !file_exists($file)) && $pruned;
  44.             } else {
  45.                 fclose($h);
  46.             }
  47.         }
  49.         return $pruned;
  50.     }
  52.     /**
  53.      * {@inheritdoc}
  54.      */
  55.     protected function doFetch(array $ids)
  56.     {
  57.         $values = [];
  58.         $now = time();
  60.         foreach ($ids as $id) {
  61.             $file = $this->getFile($id);
  62.             if (!is_file($file) || !$h = @fopen($file, 'r')) {
  63.                 continue;
  64.             }
  65.             if (($expiresAt = (int) fgets($h)) && $now >= $expiresAt) {
  66.                 fclose($h);
  67.                 @unlink($file);
  68.             } else {
  69.                 $i = rawurldecode(rtrim(fgets($h)));
  70.                 $value = stream_get_contents($h);
  71.                 fclose($h);
  72.                 if ($i === $id) {
  73.                     $values[$id] = $this->marshaller->unmarshall($value);
  74.                 }
  75.             }
  76.         }
  78.         return $values;
  79.     }
  81.     /**
  82.      * {@inheritdoc}
  83.      */
  84.     protected function doHave(string $id)
  85.     {
  86.         $file = $this->getFile($id);
  88.         return is_file($file) && (@filemtime($file) > time() || $this->doFetch([$id]));
  89.     }
  91.     /**
  92.      * {@inheritdoc}
  93.      */
  94.     protected function doSave(array $values, int $lifetime)
  95.     {
  96.         $expiresAt = $lifetime ? (time() + $lifetime) : 0;
  97.         $values = $this->marshaller->marshall($values, $failed);
  99.         foreach ($values as $id => $value) {
  100.             if (!$this->write($this->getFile($id, true), $expiresAt."\n".rawurlencode($id)."\n".$value, $expiresAt)) {
  101.                 $failed[] = $id;
  102.             }
  103.         }
  105.         if ($failed && !is_writable($this->directory)) {
  106.             throw new CacheException(sprintf('Cache directory is not writable (%s).', $this->directory));
  107.         }
  109.         return $failed;
  110.     }
  112.     private function getFileKey(string $file): string
  113.     {
  114.         if (!$h = @fopen($file, 'r')) {
  115.             return '';
  116.         }
  118.         fgets($h); // expiry
  119.         $encodedKey = fgets($h);
  120.         fclose($h);
  122.         return rawurldecode(rtrim($encodedKey));
  123.     }
  124. }