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

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 directoryExists(string $location): bool
  40.     {
  41.         return $this->adapter->directoryExists($this->pathNormalizer->normalizePath($location));
  42.     }
  44.     public function has(string $location): bool
  45.     {
  46.         $path = $this->pathNormalizer->normalizePath($location);
  48.         return $this->adapter->fileExists($path) || $this->adapter->directoryExists($path);
  49.     }
  51.     public function write(string $location, string $contents, array $config = []): void
  52.     {
  53.         $this->adapter->write(
  54.             $this->pathNormalizer->normalizePath($location),
  55.             $contents,
  56.             $this->config->extend($config)
  57.         );
  58.     }
  60.     public function writeStream(string $location, $contents, array $config = []): void
  61.     {
  62.         /* @var resource $contents */
  63.         $this->assertIsResource($contents);
  64.         $this->rewindStream($contents);
  65.         $this->adapter->writeStream(
  66.             $this->pathNormalizer->normalizePath($location),
  67.             $contents,
  68.             $this->config->extend($config)
  69.         );
  70.     }
  72.     public function read(string $location): string
  73.     {
  74.         return $this->adapter->read($this->pathNormalizer->normalizePath($location));
  75.     }
  77.     public function readStream(string $location)
  78.     {
  79.         return $this->adapter->readStream($this->pathNormalizer->normalizePath($location));
  80.     }
  82.     public function delete(string $location): void
  83.     {
  84.         $this->adapter->delete($this->pathNormalizer->normalizePath($location));
  85.     }
  87.     public function deleteDirectory(string $location): void
  88.     {
  89.         $this->adapter->deleteDirectory($this->pathNormalizer->normalizePath($location));
  90.     }
  92.     public function createDirectory(string $location, array $config = []): void
  93.     {
  94.         $this->adapter->createDirectory(
  95.             $this->pathNormalizer->normalizePath($location),
  96.             $this->config->extend($config)
  97.         );
  98.     }
  100.     public function listContents(string $location, bool $deep = self::LIST_SHALLOW): DirectoryListing
  101.     {
  102.         $path = $this->pathNormalizer->normalizePath($location);
  104.         return new DirectoryListing($this->adapter->listContents($path, $deep));
  105.     }
  107.     public function move(string $source, string $destination, array $config = []): void
  108.     {
  109.         $this->adapter->move(
  110.             $this->pathNormalizer->normalizePath($source),
  111.             $this->pathNormalizer->normalizePath($destination),
  112.             $this->config->extend($config)
  113.         );
  114.     }
  116.     public function copy(string $source, string $destination, array $config = []): void
  117.     {
  118.         $this->adapter->copy(
  119.             $this->pathNormalizer->normalizePath($source),
  120.             $this->pathNormalizer->normalizePath($destination),
  121.             $this->config->extend($config)
  122.         );
  123.     }
  125.     public function lastModified(string $path): int
  126.     {
  127.         return $this->adapter->lastModified($this->pathNormalizer->normalizePath($path))->lastModified();
  128.     }
  130.     public function fileSize(string $path): int
  131.     {
  132.         return $this->adapter->fileSize($this->pathNormalizer->normalizePath($path))->fileSize();
  133.     }
  135.     public function mimeType(string $path): string
  136.     {
  137.         return $this->adapter->mimeType($this->pathNormalizer->normalizePath($path))->mimeType();
  138.     }
  140.     public function setVisibility(string $path, string $visibility): void
  141.     {
  142.         $this->adapter->setVisibility($this->pathNormalizer->normalizePath($path), $visibility);
  143.     }
  145.     public function visibility(string $path): string
  146.     {
  147.         return $this->adapter->visibility($this->pathNormalizer->normalizePath($path))->visibility();
  148.     }
  150.     /**
  151.      * @param mixed $contents
  152.      */
  153.     private function assertIsResource($contents): void
  154.     {
  155.         if (is_resource($contents) === false) {
  156.             throw new InvalidStreamProvided(
  157.                 "Invalid stream provided, expected stream resource, received " . gettype($contents)
  158.             );
  159.         } elseif ($type = get_resource_type($contents) !== 'stream') {
  160.             throw new InvalidStreamProvided(
  161.                 "Invalid stream provided, expected stream resource, received resource of type " . $type
  162.             );
  163.         }
  164.     }
  166.     /**
  167.      * @param resource $resource
  168.      */
  169.     private function rewindStream($resource): void
  170.     {
  171.         if (ftell($resource) !== 0 && stream_get_meta_data($resource)['seekable']) {
  172.             rewind($resource);
  173.         }
  174.     }
  175. }