SWAMPy

✎ CARVE FLESH

EDITING: Filesystem.php

<?php

declare(strict_types=1);

namespace League\Flysystem;

use DateTimeInterface;
use Generator;
use League\Flysystem\UrlGeneration\PrefixPublicUrlGenerator;
use League\Flysystem\UrlGeneration\PublicUrlGenerator;
use League\Flysystem\UrlGeneration\ShardedPrefixPublicUrlGenerator;
use League\Flysystem\UrlGeneration\TemporaryUrlGenerator;
use Throwable;

use function array_key_exists;
use function is_array;

class Filesystem implements FilesystemOperator
{
    use CalculateChecksumFromStream;

private Config $config;
    private PathNormalizer $pathNormalizer;

public function __construct(
        private FilesystemAdapter $adapter,
        array $config = [],
        ?PathNormalizer $pathNormalizer = null,
        private ?PublicUrlGenerator $publicUrlGenerator = null,
        private ?TemporaryUrlGenerator $temporaryUrlGenerator = null,
    ) {
        $this->config = new Config($config);
        $this->pathNormalizer = $pathNormalizer ?? new WhitespacePathNormalizer($this->config->get('allow_relative_path_traversal', true));
    }

public function fileExists(string $location): bool
    {
        return $this->adapter->fileExists($this->pathNormalizer->normalizePath($location));
    }

public function directoryExists(string $location): bool
    {
        return $this->adapter->directoryExists($this->pathNormalizer->normalizePath($location));
    }

public function has(string $location): bool
    {
        $path = $this->pathNormalizer->normalizePath($location);

return $this->adapter->fileExists($path) || $this->adapter->directoryExists($path);
    }

public function write(string $location, string $contents, array $config = []): void
    {
        $this->adapter->write(
            $this->pathNormalizer->normalizePath($location),
            $contents,
            $this->config->extend($config)
        );
    }

public function writeStream(string $location, $contents, array $config = []): void
    {
        /* @var resource $contents */
        $this->assertIsResource($contents);
        $this->rewindStream($contents);
        $this->adapter->writeStream(
            $this->pathNormalizer->normalizePath($location),
            $contents,
            $this->config->extend($config)
        );
    }

public function read(string $location): string
    {
        return $this->adapter->read($this->pathNormalizer->normalizePath($location));
    }

public function readStream(string $location)
    {
        return $this->adapter->readStream($this->pathNormalizer->normalizePath($location));
    }

public function delete(string $location): void
    {
        $this->adapter->delete($this->pathNormalizer->normalizePath($location));
    }

public function deleteDirectory(string $location): void
    {
        $this->adapter->deleteDirectory($this->pathNormalizer->normalizePath($location));
    }

public function createDirectory(string $location, array $config = []): void
    {
        $this->adapter->createDirectory(
            $this->pathNormalizer->normalizePath($location),
            $this->config->extend($config)
        );
    }

public function listContents(string $location, bool $deep = self::LIST_SHALLOW): DirectoryListing
    {
        $path = $this->pathNormalizer->normalizePath($location);
        $listing = $this->adapter->listContents($path, $deep);

return new DirectoryListing($this->pipeListing($location, $deep, $listing));
    }

private function pipeListing(string $location, bool $deep, iterable $listing): Generator
    {
        try {
            foreach ($listing as $item) {
                yield $item;
            }
        } catch (Throwable $exception) {
            throw UnableToListContents::atLocation($location, $deep, $exception);
        }
    }

public function move(string $source, string $destination, array $config = []): void
    {
        $config = $this->resolveConfigForMoveAndCopy($config);
        $from = $this->pathNormalizer->normalizePath($source);
        $to = $this->pathNormalizer->normalizePath($destination);

if ($from === $to) {
            $resolutionStrategy = $config->get(Config::OPTION_MOVE_IDENTICAL_PATH, ResolveIdenticalPathConflict::TRY);

if ($resolutionStrategy === ResolveIdenticalPathConflict::FAIL) {
                throw UnableToMoveFile::sourceAndDestinationAreTheSame($source, $destination);
            } elseif ($resolutionStrategy === ResolveIdenticalPathConflict::IGNORE) {
                return;
            }
        }

$this->adapter->move($from, $to, $config);
    }

public function copy(string $source, string $destination, array $config = []): void
    {
        $config = $this->resolveConfigForMoveAndCopy($config);
        $from = $this->pathNormalizer->normalizePath($source);
        $to = $this->pathNormalizer->normalizePath($destination);

if ($from === $to) {
            $resolutionStrategy = $config->get(Config::OPTION_COPY_IDENTICAL_PATH, ResolveIdenticalPathConflict::TRY);

if ($resolutionStrategy === ResolveIdenticalPathConflict::FAIL) {
                throw UnableToCopyFile::sourceAndDestinationAreTheSame($source, $destination);
            } elseif ($resolutionStrategy === ResolveIdenticalPathConflict::IGNORE) {
                return;
            }
        }

$this->adapter->copy($from, $to, $config);
    }

public function lastModified(string $path): int
    {
        return $this->adapter->lastModified($this->pathNormalizer->normalizePath($path))->lastModified();
    }

public function fileSize(string $path): int
    {
        return $this->adapter->fileSize($this->pathNormalizer->normalizePath($path))->fileSize();
    }

public function mimeType(string $path): string
    {
        $normalizedPath = $this->pathNormalizer->normalizePath($path);
        $attributes = $this->adapter->mimeType($normalizedPath);

if ($attributes->mimeType() === null) {
            throw UnableToRetrieveMetadata::mimeType($path);
        }

return $attributes->mimeType();
    }

public function setVisibility(string $path, string $visibility): void
    {
        $this->adapter->setVisibility($this->pathNormalizer->normalizePath($path), $visibility);
    }

public function visibility(string $path): string
    {
        return $this->adapter->visibility($this->pathNormalizer->normalizePath($path))->visibility();
    }

public function publicUrl(string $path, array $config = []): string
    {
        $this->publicUrlGenerator ??= $this->resolvePublicUrlGenerator()
            ?? throw UnableToGeneratePublicUrl::noGeneratorConfigured($path);
        $config = $this->config->extend($config);

return $this->publicUrlGenerator->publicUrl(
            $this->pathNormalizer->normalizePath($path),
            $config,
        );
    }

public function temporaryUrl(string $path, DateTimeInterface $expiresAt, array $config = []): string
    {
        $generator = $this->temporaryUrlGenerator ?? $this->adapter;

if ($generator instanceof TemporaryUrlGenerator) {
            return $generator->temporaryUrl(
                $this->pathNormalizer->normalizePath($path),
                $expiresAt,
                $this->config->extend($config)
            );
        }

throw UnableToGenerateTemporaryUrl::noGeneratorConfigured($path);
    }

public function checksum(string $path, array $config = []): string
    {
        $config = $this->config->extend($config);

if ( ! $this->adapter instanceof ChecksumProvider) {
            return $this->calculateChecksumFromStream($path, $config);
        }

try {
            return $this->adapter->checksum(
                $this->pathNormalizer->normalizePath($path),
                $config,
            );
        } catch (ChecksumAlgoIsNotSupported) {
            return $this->calculateChecksumFromStream(
                $this->pathNormalizer->normalizePath($path),
                $config,
            );
        }
    }

private function resolvePublicUrlGenerator(): ?PublicUrlGenerator
    {
        if ($publicUrl = $this->config->get('public_url')) {
            return match (true) {
                is_array($publicUrl) => new ShardedPrefixPublicUrlGenerator($publicUrl),
                default => new PrefixPublicUrlGenerator($publicUrl),
            };
        }

if ($this->adapter instanceof PublicUrlGenerator) {
            return $this->adapter;
        }

return null;
    }

/**
     * @param mixed $contents
     */
    private function assertIsResource($contents): void
    {
        if (is_resource($contents) === false) {
            throw new InvalidStreamProvided(
                "Invalid stream provided, expected stream resource, received " . gettype($contents)
            );
        } elseif (($type = get_resource_type($contents)) !== 'stream') {
            throw new InvalidStreamProvided(
                "Invalid stream provided, expected stream resource, received resource of type " . $type
            );
        }
    }

/**
     * @param resource $resource
     */
    private function rewindStream($resource): void
    {
        if (ftell($resource) !== 0 && stream_get_meta_data($resource)['seekable']) {
            rewind($resource);
        }
    }

private function resolveConfigForMoveAndCopy(array $config): Config
    {
        $retainVisibility = $this->config->get(Config::OPTION_RETAIN_VISIBILITY, $config[Config::OPTION_RETAIN_VISIBILITY] ?? true);
        $fullConfig = $this->config->extend($config);

/*
         * By default, we retain visibility. When we do not retain visibility, the visibility setting
         * from the default configuration is ignored. Only when it is set explicitly, we propagate the
         * setting.
         */
        if ($retainVisibility && ! array_key_exists(Config::OPTION_VISIBILITY, $config)) {
            $fullConfig = $fullConfig->withoutSettings(Config::OPTION_VISIBILITY)->extend($config);
        }

return $fullConfig;
    }
}

CANCEL

Name	Type	Size	Modified	Actions
↩ ..	DIR	—	—
📁 UnixVisibility/	DIR	—	2026-07-06 14:42
📁 UrlGeneration/	DIR	—	2026-07-06 14:42
📄 CalculateChecksumFromStream.php	PHP	793 B	2026-07-06 14:42	EDIT
📄 ChecksumAlgoIsNotSupported.php	PHP	169 B	2026-07-06 14:42	EDIT
📄 ChecksumProvider.php	PHP	291 B	2026-07-06 14:42	EDIT
📄 Config.php	PHP	1.4 KB	2026-07-06 14:42	EDIT
📄 CorruptedPathDetected.php	PHP	316 B	2026-07-06 14:42	EDIT
📄 DecoratedAdapter.php	PHP	2.4 KB	2026-07-06 14:42	EDIT
📄 DirectoryAttributes.php	PHP	2 KB	2026-07-06 14:42	EDIT
📄 DirectoryListing.php	PHP	2 KB	2026-07-06 14:42	EDIT
📄 FileAttributes.php	PHP	2.5 KB	2026-07-06 14:42	EDIT
📄 Filesystem.php	PHP	9.9 KB	2026-07-06 14:42	EDIT
📄 FilesystemAdapter.php	PHP	2.7 KB	2026-07-06 14:42	EDIT
📄 FilesystemException.php	PHP	130 B	2026-07-06 14:42	EDIT
📄 FilesystemOperationFailed.php	PHP	954 B	2026-07-06 14:42	EDIT
📄 FilesystemOperator.php	PHP	138 B	2026-07-06 14:42	EDIT
📄 FilesystemReader.php	PHP	2.1 KB	2026-07-06 14:42	EDIT
📄 FilesystemWriter.php	PHP	1.4 KB	2026-07-06 14:42	EDIT
📄 InvalidStreamProvided.php	PHP	225 B	2026-07-06 14:42	EDIT
📄 InvalidVisibilityProvided.php	PHP	553 B	2026-07-06 14:42	EDIT
📄 MountManager.php	PHP	15 KB	2026-07-06 14:42	EDIT
📄 PathNormalizer.php	PHP	148 B	2026-07-06 14:42	EDIT
📄 PathPrefixer.php	PHP	1.1 KB	2026-07-06 14:42	EDIT
📄 PathTraversalDetected.php	PHP	482 B	2026-07-06 14:42	EDIT
📄 PortableVisibilityGuard.php	PHP	511 B	2026-07-06 14:42	EDIT
📄 ProxyArrayAccessToProperties.php	PHP	1.2 KB	2026-07-06 14:42	EDIT
📄 ResolveIdenticalPathConflict.php	PHP	198 B	2026-07-06 14:42	EDIT
📄 StorageAttributes.php	PHP	1 KB	2026-07-06 14:42	EDIT
📄 SymbolicLinkEncountered.php	PHP	531 B	2026-07-06 14:42	EDIT
📄 UnableToCheckDirectoryExistence.php	PHP	257 B	2026-07-06 14:42	EDIT
📄 UnableToCheckExistence.php	PHP	678 B	2026-07-06 14:42	EDIT
📄 UnableToCheckFileExistence.php	PHP	247 B	2026-07-06 14:42	EDIT
📄 UnableToCopyFile.php	PHP	1.5 KB	2026-07-06 14:42	EDIT
📄 UnableToCreateDirectory.php	PHP	1.3 KB	2026-07-06 14:42	EDIT
📄 UnableToDeleteDirectory.php	PHP	974 B	2026-07-06 14:42	EDIT
📄 UnableToDeleteFile.php	PHP	923 B	2026-07-06 14:42	EDIT
📄 UnableToGeneratePublicUrl.php	PHP	754 B	2026-07-06 14:42	EDIT
📄 UnableToGenerateTemporaryUrl.php	PHP	760 B	2026-07-06 14:42	EDIT
📄 UnableToListContents.php	PHP	650 B	2026-07-06 14:42	EDIT
📄 UnableToMountFilesystem.php	PHP	915 B	2026-07-06 14:42	EDIT
📄 UnableToMoveFile.php	PHP	1.6 KB	2026-07-06 14:42	EDIT
📄 UnableToProvideChecksum.php	PHP	387 B	2026-07-06 14:42	EDIT
📄 UnableToReadFile.php	PHP	925 B	2026-07-06 14:42	EDIT
📄 UnableToResolveFilesystemMount.php	PHP	723 B	2026-07-06 14:42	EDIT
📄 UnableToRetrieveMetadata.php	PHP	2 KB	2026-07-06 14:42	EDIT
📄 UnableToSetVisibility.php	PHP	982 B	2026-07-06 14:42	EDIT
📄 UnableToWriteFile.php	PHP	920 B	2026-07-06 14:42	EDIT
📄 UnreadableFileEncountered.php	PHP	556 B	2026-07-06 14:42	EDIT
📄 Visibility.php	PHP	163 B	2026-07-06 14:42	EDIT
📄 WhitespacePathNormalizer.php	PHP	1.2 KB	2026-07-06 14:42	EDIT