vendor/league/flysystem/src/Filesystem.php line 115

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace League\Flysystem;
  7. class Filesystem implements FilesystemOperator
  8. {
  9.     /**
  10.      * @var FilesystemAdapter
  11.      */
  12.     private $adapter;
  14.     /**
  15.      * @var Config
  16.      */
  17.     private $config;
  19.     /**
  20.      * @var PathNormalizer
  21.      */
  22.     private $pathNormalizer;
  24.     public function __construct(
  25.         FilesystemAdapter $adapter,
  26.         array $config = [],
  27.         PathNormalizer $pathNormalizer = null
  28.     ) {
  29.         $this->adapter = $adapter;
  30.         $this->config = new Config($config);
  31.         $this->pathNormalizer = $pathNormalizer ?: new WhitespacePathNormalizer();
  32.     }
  34.     public function fileExists(string $location): bool
  35.     {
  36.         return $this->adapter->fileExists($this->pathNormalizer->normalizePath($location));
  37.     }
  39.     public function write(string $location, string $contents, array $config = []): void
  40.     {
  41.         $this->adapter->write(
  42.             $this->pathNormalizer->normalizePath($location),
  43.             $contents,
  44.             $this->config->extend($config)
  45.         );
  46.     }
  48.     public function writeStream(string $location, $contents, array $config = []): void
  49.     {
  50.         /* @var resource $contents */
  51.         $this->assertIsResource($contents);
  52.         $this->rewindStream($contents);
  53.         $this->adapter->writeStream(
  54.             $this->pathNormalizer->normalizePath($location),
  55.             $contents,
  56.             $this->config->extend($config)
  57.         );
  58.     }
  60.     public function read(string $location): string
  61.     {
  62.         return $this->adapter->read($this->pathNormalizer->normalizePath($location));
  63.     }
  65.     public function readStream(string $location)
  66.     {
  67.         return $this->adapter->readStream($this->pathNormalizer->normalizePath($location));
  68.     }
  70.     public function delete(string $location): void
  71.     {
  72.         $this->adapter->delete($this->pathNormalizer->normalizePath($location));
  73.     }
  75.     public function deleteDirectory(string $location): void
  76.     {
  77.         $this->adapter->deleteDirectory($this->pathNormalizer->normalizePath($location));
  78.     }
  80.     public function createDirectory(string $location, array $config = []): void
  81.     {
  82.         $this->adapter->createDirectory(
  83.             $this->pathNormalizer->normalizePath($location),
  84.             $this->config->extend($config)
  85.         );
  86.     }
  88.     public function listContents(string $location, bool $deep = self::LIST_SHALLOW): DirectoryListing
  89.     {
  90.         $path = $this->pathNormalizer->normalizePath($location);
  92.         return new DirectoryListing($this->adapter->listContents($path, $deep));
  93.     }
  95.     public function move(string $source, string $destination, array $config = []): void
  96.     {
  97.         $this->adapter->move(
  98.             $this->pathNormalizer->normalizePath($source),
  99.             $this->pathNormalizer->normalizePath($destination),
  100.             $this->config->extend($config)
  101.         );
  102.     }
  104.     public function copy(string $source, string $destination, array $config = []): void
  105.     {
  106.         $this->adapter->copy(
  107.             $this->pathNormalizer->normalizePath($source),
  108.             $this->pathNormalizer->normalizePath($destination),
  109.             $this->config->extend($config)
  110.         );
  111.     }
  113.     public function lastModified(string $path): int
  114.     {
  115.         return $this->adapter->lastModified($this->pathNormalizer->normalizePath($path))->lastModified();
  116.     }
  118.     public function fileSize(string $path): int
  119.     {
  120.         return $this->adapter->fileSize($this->pathNormalizer->normalizePath($path))->fileSize();
  121.     }
  123.     public function mimeType(string $path): string
  124.     {
  125.         return $this->adapter->mimeType($this->pathNormalizer->normalizePath($path))->mimeType();
  126.     }
  128.     public function setVisibility(string $path, string $visibility): void
  129.     {
  130.         $this->adapter->setVisibility($this->pathNormalizer->normalizePath($path), $visibility);
  131.     }
  133.     public function visibility(string $path): string
  134.     {
  135.         return $this->adapter->visibility($this->pathNormalizer->normalizePath($path))->visibility();
  136.     }
  138.     /**
  139.      * @param mixed $contents
  140.      */
  141.     private function assertIsResource($contents): void
  142.     {
  143.         if (is_resource($contents) === false) {
  144.             throw new InvalidStreamProvided(
  145.                 "Invalid stream provided, expected stream resource, received " . gettype($contents)
  146.             );
  147.         } elseif ($type = get_resource_type($contents) !== 'stream') {
  148.             throw new InvalidStreamProvided(
  149.                 "Invalid stream provided, expected stream resource, received resource of type " . $type
  150.             );
  151.         }
  152.     }
  154.     /**
  155.      * @param resource $resource
  156.      */
  157.     private function rewindStream($resource): void
  158.     {
  159.         if (ftell($resource) !== 0 && stream_get_meta_data($resource)['seekable']) {
  160.             rewind($resource);
  161.         }
  162.     }
  163. }