Skip to main content
Drupal API
User account menu
  • Log in

Breadcrumb

  1. Drupal Core 11.1.x
  2. Filesystem.php

class Filesystem

Same name in this branch
  1. 11.1.x vendor/phpunit/php-code-coverage/src/Util/Filesystem.php \SebastianBergmann\CodeCoverage\Util\Filesystem
  2. 11.1.x vendor/phpunit/phpunit/src/Util/Filesystem.php \PHPUnit\Util\Filesystem
  3. 11.1.x vendor/php-tuf/composer-stager/src/Internal/Filesystem/Service/Filesystem.php \PhpTuf\ComposerStager\Internal\Filesystem\Service\Filesystem
  4. 11.1.x vendor/symfony/filesystem/Filesystem.php \Symfony\Component\Filesystem\Filesystem
  5. 11.1.x core/lib/Drupal/Core/File/FileSystem.php \Drupal\Core\File\FileSystem
  6. 11.1.x core/lib/Drupal/Component/FileSystem/FileSystem.php \Drupal\Component\FileSystem\FileSystem

@author Jordi Boggiano <j.boggiano@seld.be> @author Johannes M. Schmitt <schmittjoh@gmail.com>

Hierarchy

  • class \Composer\Util\Filesystem

Expanded class hierarchy of Filesystem

49 files declare their use of Filesystem
Application.php in vendor/composer/composer/src/Composer/Console/Application.php
ArchivableFilesFinder.php in vendor/composer/composer/src/Composer/Package/Archiver/ArchivableFilesFinder.php
ArchiveCommand.php in vendor/composer/composer/src/Composer/Command/ArchiveCommand.php
ArchiveManager.php in vendor/composer/composer/src/Composer/Package/Archiver/ArchiveManager.php
AutoloadGenerator.php in vendor/composer/composer/src/Composer/Autoload/AutoloadGenerator.php

... See full list

2 string references to 'Filesystem'
RepositoryFactory::configFromString in vendor/composer/composer/src/Composer/Repository/RepositoryFactory.php
RepositoryFactory::createRepos in vendor/composer/composer/src/Composer/Repository/RepositoryFactory.php

File

vendor/composer/composer/src/Composer/Util/Filesystem.php, line 27

Namespace

Composer\Util
View source
class Filesystem {
    
    /** @var ?ProcessExecutor */
    private $processExecutor;
    public function __construct(?ProcessExecutor $executor = null) {
        $this->processExecutor = $executor;
    }
    
    /**
     * @return bool
     */
    public function remove(string $file) {
        if (is_dir($file)) {
            return $this->removeDirectory($file);
        }
        if (file_exists($file)) {
            return $this->unlink($file);
        }
        return false;
    }
    
    /**
     * Checks if a directory is empty
     *
     * @return bool
     */
    public function isDirEmpty(string $dir) {
        $finder = Finder::create()->ignoreVCS(false)
            ->ignoreDotFiles(false)
            ->depth(0)
            ->in($dir);
        return \count($finder) === 0;
    }
    
    /**
     * @return void
     */
    public function emptyDirectory(string $dir, bool $ensureDirectoryExists = true) {
        if (is_link($dir) && file_exists($dir)) {
            $this->unlink($dir);
        }
        if ($ensureDirectoryExists) {
            $this->ensureDirectoryExists($dir);
        }
        if (is_dir($dir)) {
            $finder = Finder::create()->ignoreVCS(false)
                ->ignoreDotFiles(false)
                ->depth(0)
                ->in($dir);
            foreach ($finder as $path) {
                $this->remove((string) $path);
            }
        }
    }
    
    /**
     * Recursively remove a directory
     *
     * Uses the process component if proc_open is enabled on the PHP
     * installation.
     *
     * @throws \RuntimeException
     * @return bool
     */
    public function removeDirectory(string $directory) {
        $edgeCaseResult = $this->removeEdgeCases($directory);
        if ($edgeCaseResult !== null) {
            return $edgeCaseResult;
        }
        if (Platform::isWindows()) {
            $cmd = [
                'rmdir',
                '/S',
                '/Q',
                Platform::realpath($directory),
            ];
        }
        else {
            $cmd = [
                'rm',
                '-rf',
                $directory,
            ];
        }
        $result = $this->getProcess()
            ->execute($cmd, $output) === 0;
        // clear stat cache because external processes aren't tracked by the php stat cache
        clearstatcache();
        if ($result && !is_dir($directory)) {
            return true;
        }
        return $this->removeDirectoryPhp($directory);
    }
    
    /**
     * Recursively remove a directory asynchronously
     *
     * Uses the process component if proc_open is enabled on the PHP
     * installation.
     *
     * @throws \RuntimeException
     * @return PromiseInterface
     * @phpstan-return PromiseInterface<bool>
     */
    public function removeDirectoryAsync(string $directory) {
        $edgeCaseResult = $this->removeEdgeCases($directory);
        if ($edgeCaseResult !== null) {
            return \React\Promise\resolve($edgeCaseResult);
        }
        if (Platform::isWindows()) {
            $cmd = [
                'rmdir',
                '/S',
                '/Q',
                Platform::realpath($directory),
            ];
        }
        else {
            $cmd = [
                'rm',
                '-rf',
                $directory,
            ];
        }
        $promise = $this->getProcess()
            ->executeAsync($cmd);
        return $promise->then(function ($process) use ($directory) {
            // clear stat cache because external processes aren't tracked by the php stat cache
            clearstatcache();
            if ($process->isSuccessful()) {
                if (!is_dir($directory)) {
                    return \React\Promise\resolve(true);
                }
            }
            return \React\Promise\resolve($this->removeDirectoryPhp($directory));
        });
    }
    
    /**
     * @return bool|null Returns null, when no edge case was hit. Otherwise a bool whether removal was successful
     */
    private function removeEdgeCases(string $directory, bool $fallbackToPhp = true) : ?bool {
        if ($this->isSymlinkedDirectory($directory)) {
            return $this->unlinkSymlinkedDirectory($directory);
        }
        if ($this->isJunction($directory)) {
            return $this->removeJunction($directory);
        }
        if (is_link($directory)) {
            return unlink($directory);
        }
        if (!is_dir($directory) || !file_exists($directory)) {
            return true;
        }
        if (Preg::isMatch('{^(?:[a-z]:)?[/\\\\]+$}i', $directory)) {
            throw new \RuntimeException('Aborting an attempted deletion of ' . $directory . ', this was probably not intended, if it is a real use case please report it.');
        }
        if (!\function_exists('proc_open') && $fallbackToPhp) {
            return $this->removeDirectoryPhp($directory);
        }
        return null;
    }
    
    /**
     * Recursively delete directory using PHP iterators.
     *
     * Uses a CHILD_FIRST RecursiveIteratorIterator to sort files
     * before directories, creating a single non-recursive loop
     * to delete files/directories in the correct order.
     *
     * @return bool
     */
    public function removeDirectoryPhp(string $directory) {
        $edgeCaseResult = $this->removeEdgeCases($directory, false);
        if ($edgeCaseResult !== null) {
            return $edgeCaseResult;
        }
        try {
            $it = new RecursiveDirectoryIterator($directory, RecursiveDirectoryIterator::SKIP_DOTS);
        } catch (\UnexpectedValueException $e) {
            // re-try once after clearing the stat cache if it failed as it
            // sometimes fails without apparent reason, see https://github.com/composer/composer/issues/4009
            clearstatcache();
            usleep(100000);
            if (!is_dir($directory)) {
                return true;
            }
            $it = new RecursiveDirectoryIterator($directory, RecursiveDirectoryIterator::SKIP_DOTS);
        }
        $ri = new RecursiveIteratorIterator($it, RecursiveIteratorIterator::CHILD_FIRST);
        foreach ($ri as $file) {
            if ($file->isDir()) {
                $this->rmdir($file->getPathname());
            }
            else {
                $this->unlink($file->getPathname());
            }
        }
        // release locks on the directory, see https://github.com/composer/composer/issues/9945
        unset($ri, $it, $file);
        return $this->rmdir($directory);
    }
    
    /**
     * @return void
     */
    public function ensureDirectoryExists(string $directory) {
        if (!is_dir($directory)) {
            if (file_exists($directory)) {
                throw new \RuntimeException($directory . ' exists and is not a directory.');
            }
            if (is_link($directory) && !@$this->unlinkImplementation($directory)) {
                throw new \RuntimeException('Could not delete symbolic link ' . $directory . ': ' . (error_get_last()['message'] ?? ''));
            }
            if (!@mkdir($directory, 0777, true)) {
                $e = new \RuntimeException($directory . ' does not exist and could not be created: ' . (error_get_last()['message'] ?? ''));
                // in pathological cases with paths like path/to/broken-symlink/../foo is_dir will fail to detect path/to/foo
                // but normalizing the ../ away first makes it work so we attempt this just in case, and if it still fails we
                // report the initial error we had with the original path, and ignore the normalized path exception
                // see https://github.com/composer/composer/issues/11864
                $normalized = $this->normalizePath($directory);
                if ($normalized !== $directory) {
                    try {
                        $this->ensureDirectoryExists($normalized);
                        return;
                    } catch (\Throwable $ignoredEx) {
                    }
                }
                throw $e;
            }
        }
    }
    
    /**
     * Attempts to unlink a file and in case of failure retries after 350ms on windows
     *
     * @throws \RuntimeException
     * @return bool
     */
    public function unlink(string $path) {
        $unlinked = @$this->unlinkImplementation($path);
        if (!$unlinked) {
            // retry after a bit on windows since it tends to be touchy with mass removals
            if (Platform::isWindows()) {
                usleep(350000);
                $unlinked = @$this->unlinkImplementation($path);
            }
            if (!$unlinked) {
                $error = error_get_last();
                $message = 'Could not delete ' . $path . ': ' . ($error['message'] ?? '');
                if (Platform::isWindows()) {
                    $message .= "\nThis can be due to an antivirus or the Windows Search Indexer locking the file while they are analyzed";
                }
                throw new \RuntimeException($message);
            }
        }
        return true;
    }
    
    /**
     * Attempts to rmdir a file and in case of failure retries after 350ms on windows
     *
     * @throws \RuntimeException
     * @return bool
     */
    public function rmdir(string $path) {
        $deleted = @rmdir($path);
        if (!$deleted) {
            // retry after a bit on windows since it tends to be touchy with mass removals
            if (Platform::isWindows()) {
                usleep(350000);
                $deleted = @rmdir($path);
            }
            if (!$deleted) {
                $error = error_get_last();
                $message = 'Could not delete ' . $path . ': ' . ($error['message'] ?? '');
                if (Platform::isWindows()) {
                    $message .= "\nThis can be due to an antivirus or the Windows Search Indexer locking the file while they are analyzed";
                }
                throw new \RuntimeException($message);
            }
        }
        return true;
    }
    
    /**
     * Copy then delete is a non-atomic version of {@link rename}.
     *
     * Some systems can't rename and also don't have proc_open,
     * which requires this solution.
     *
     * @return void
     */
    public function copyThenRemove(string $source, string $target) {
        $this->copy($source, $target);
        if (!is_dir($source)) {
            $this->unlink($source);
            return;
        }
        $this->removeDirectoryPhp($source);
    }
    
    /**
     * Copies a file or directory from $source to $target.
     *
     * @return bool
     */
    public function copy(string $source, string $target) {
        // refs https://github.com/composer/composer/issues/11864
        $target = $this->normalizePath($target);
        if (!is_dir($source)) {
            try {
                return copy($source, $target);
            } catch (ErrorException $e) {
                // if copy fails we attempt to copy it manually as this can help bypass issues with VirtualBox shared folders
                // see https://github.com/composer/composer/issues/12057
                if (str_contains($e->getMessage(), 'Bad address')) {
                    $sourceHandle = fopen($source, 'r');
                    $targetHandle = fopen($target, 'w');
                    if (false === $sourceHandle || false === $targetHandle) {
                        throw $e;
                    }
                    while (!feof($sourceHandle)) {
                        if (false === fwrite($targetHandle, (string) fread($sourceHandle, 1024 * 1024))) {
                            throw $e;
                        }
                    }
                    fclose($sourceHandle);
                    fclose($targetHandle);
                    return true;
                }
                throw $e;
            }
        }
        $it = new RecursiveDirectoryIterator($source, RecursiveDirectoryIterator::SKIP_DOTS);
        $ri = new RecursiveIteratorIterator($it, RecursiveIteratorIterator::SELF_FIRST);
        $this->ensureDirectoryExists($target);
        $result = true;
        foreach ($ri as $file) {
            $targetPath = $target . DIRECTORY_SEPARATOR . $ri->getSubPathname();
            if ($file->isDir()) {
                $this->ensureDirectoryExists($targetPath);
            }
            else {
                $result = $result && copy($file->getPathname(), $targetPath);
            }
        }
        return $result;
    }
    
    /**
     * @return void
     */
    public function rename(string $source, string $target) {
        if (true === @rename($source, $target)) {
            return;
        }
        if (!\function_exists('proc_open')) {
            $this->copyThenRemove($source, $target);
            return;
        }
        if (Platform::isWindows()) {
            // Try to copy & delete - this is a workaround for random "Access denied" errors.
            $result = $this->getProcess()
                ->execute([
                'xcopy',
                $source,
                $target,
                '/E',
                '/I',
                '/Q',
                '/Y',
            ], $output);
            // clear stat cache because external processes aren't tracked by the php stat cache
            clearstatcache();
            if (0 === $result) {
                $this->remove($source);
                return;
            }
        }
        else {
            // We do not use PHP's "rename" function here since it does not support
            // the case where $source, and $target are located on different partitions.
            $result = $this->getProcess()
                ->execute([
                'mv',
                $source,
                $target,
            ], $output);
            // clear stat cache because external processes aren't tracked by the php stat cache
            clearstatcache();
            if (0 === $result) {
                return;
            }
        }
        $this->copyThenRemove($source, $target);
    }
    
    /**
     * Returns the shortest path from $from to $to
     *
     * @param  bool                      $directories if true, the source/target are considered to be directories
     * @param  bool                      $preferRelative if true, relative paths will be preferred even if longer
     * @throws \InvalidArgumentException
     * @return string
     */
    public function findShortestPath(string $from, string $to, bool $directories = false, bool $preferRelative = false) {
        if (!$this->isAbsolutePath($from) || !$this->isAbsolutePath($to)) {
            throw new \InvalidArgumentException(sprintf('$from (%s) and $to (%s) must be absolute paths.', $from, $to));
        }
        $from = $this->normalizePath($from);
        $to = $this->normalizePath($to);
        if ($directories) {
            $from = rtrim($from, '/') . '/dummy_file';
        }
        if (\dirname($from) === \dirname($to)) {
            return './' . basename($to);
        }
        $commonPath = $to;
        while (strpos($from . '/', $commonPath . '/') !== 0 && '/' !== $commonPath && !Preg::isMatch('{^[A-Z]:/?$}i', $commonPath)) {
            $commonPath = strtr(\dirname($commonPath), '\\', '/');
        }
        // no commonality at all
        if (0 !== strpos($from, $commonPath)) {
            return $to;
        }
        $commonPath = rtrim($commonPath, '/') . '/';
        $sourcePathDepth = substr_count((string) substr($from, \strlen($commonPath)), '/');
        $commonPathCode = str_repeat('../', $sourcePathDepth);
        // allow top level /foo & /bar dirs to be addressed relatively as this is common in Docker setups
        if (!$preferRelative && '/' === $commonPath && $sourcePathDepth > 1) {
            return $to;
        }
        $result = $commonPathCode . substr($to, \strlen($commonPath));
        if (\strlen($result) === 0) {
            return './';
        }
        return $result;
    }
    
    /**
     * Returns PHP code that, when executed in $from, will return the path to $to
     *
     * @param  bool                      $directories if true, the source/target are considered to be directories
     * @param  bool                      $preferRelative if true, relative paths will be preferred even if longer
     * @throws \InvalidArgumentException
     * @return string
     */
    public function findShortestPathCode(string $from, string $to, bool $directories = false, bool $staticCode = false, bool $preferRelative = false) {
        if (!$this->isAbsolutePath($from) || !$this->isAbsolutePath($to)) {
            throw new \InvalidArgumentException(sprintf('$from (%s) and $to (%s) must be absolute paths.', $from, $to));
        }
        $from = $this->normalizePath($from);
        $to = $this->normalizePath($to);
        if ($from === $to) {
            return $directories ? '__DIR__' : '__FILE__';
        }
        $commonPath = $to;
        while (strpos($from . '/', $commonPath . '/') !== 0 && '/' !== $commonPath && !Preg::isMatch('{^[A-Z]:/?$}i', $commonPath) && '.' !== $commonPath) {
            $commonPath = strtr(\dirname($commonPath), '\\', '/');
        }
        // no commonality at all
        if (0 !== strpos($from, $commonPath) || '.' === $commonPath) {
            return var_export($to, true);
        }
        $commonPath = rtrim($commonPath, '/') . '/';
        if (str_starts_with($to, $from . '/')) {
            return '__DIR__ . ' . var_export((string) substr($to, \strlen($from)), true);
        }
        $sourcePathDepth = substr_count((string) substr($from, \strlen($commonPath)), '/') + (int) $directories;
        // allow top level /foo & /bar dirs to be addressed relatively as this is common in Docker setups
        if (!$preferRelative && '/' === $commonPath && $sourcePathDepth > 1) {
            return var_export($to, true);
        }
        if ($staticCode) {
            $commonPathCode = "__DIR__ . '" . str_repeat('/..', $sourcePathDepth) . "'";
        }
        else {
            $commonPathCode = str_repeat('dirname(', $sourcePathDepth) . '__DIR__' . str_repeat(')', $sourcePathDepth);
        }
        $relTarget = (string) substr($to, \strlen($commonPath));
        return $commonPathCode . (\strlen($relTarget) > 0 ? '.' . var_export('/' . $relTarget, true) : '');
    }
    
    /**
     * Checks if the given path is absolute
     *
     * @return bool
     */
    public function isAbsolutePath(string $path) {
        return strpos($path, '/') === 0 || substr($path, 1, 1) === ':' || strpos($path, '\\\\') === 0;
    }
    
    /**
     * Returns size of a file or directory specified by path. If a directory is
     * given, its size will be computed recursively.
     *
     * @param  string            $path Path to the file or directory
     * @throws \RuntimeException
     * @return int
     */
    public function size(string $path) {
        if (!file_exists($path)) {
            throw new \RuntimeException("{$path} does not exist.");
        }
        if (is_dir($path)) {
            return $this->directorySize($path);
        }
        return (int) filesize($path);
    }
    
    /**
     * Normalize a path. This replaces backslashes with slashes, removes ending
     * slash and collapses redundant separators and up-level references.
     *
     * @param  string $path Path to the file or directory
     * @return string
     */
    public function normalizePath(string $path) {
        $parts = [];
        $path = strtr($path, '\\', '/');
        $prefix = '';
        $absolute = '';
        // extract windows UNC paths e.g. \\foo\bar
        if (strpos($path, '//') === 0 && \strlen($path) > 2) {
            $absolute = '//';
            $path = substr($path, 2);
        }
        // extract a prefix being a protocol://, protocol:, protocol://drive: or simply drive:
        if (Preg::isMatchStrictGroups('{^( [0-9a-z]{2,}+: (?: // (?: [a-z]: )? )? | [a-z]: )}ix', $path, $match)) {
            $prefix = $match[1];
            $path = substr($path, \strlen($prefix));
        }
        if (strpos($path, '/') === 0) {
            $absolute = '/';
            $path = substr($path, 1);
        }
        $up = false;
        foreach (explode('/', $path) as $chunk) {
            if ('..' === $chunk && (\strlen($absolute) > 0 || $up)) {
                array_pop($parts);
                $up = !(\count($parts) === 0 || '..' === end($parts));
            }
            elseif ('.' !== $chunk && '' !== $chunk) {
                $parts[] = $chunk;
                $up = '..' !== $chunk;
            }
        }
        // ensure c: is normalized to C:
        $prefix = Preg::replaceCallback('{(^|://)[a-z]:$}i', static function (array $m) {
            return strtoupper($m[0]);
        }, $prefix);
        return $prefix . $absolute . implode('/', $parts);
    }
    
    /**
     * Remove trailing slashes if present to avoid issues with symlinks
     *
     * And other possible unforeseen disasters, see https://github.com/composer/composer/pull/9422
     *
     * @return string
     */
    public static function trimTrailingSlash(string $path) {
        if (!Preg::isMatch('{^[/\\\\]+$}', $path)) {
            $path = rtrim($path, '/\\');
        }
        return $path;
    }
    
    /**
     * Return if the given path is local
     *
     * @return bool
     */
    public static function isLocalPath(string $path) {
        // on windows, \\foo indicates network paths so we exclude those from local paths, however it is unsafe
        // on linux as file:////foo (which would be a network path \\foo on windows) will resolve to /foo which could be a local path
        if (Platform::isWindows()) {
            return Preg::isMatch('{^(file://(?!//)|/(?!/)|/?[a-z]:[\\\\/]|\\.\\.[\\\\/]|[a-z0-9_.-]+[\\\\/])}i', $path);
        }
        return Preg::isMatch('{^(file://|/|/?[a-z]:[\\\\/]|\\.\\.[\\\\/]|[a-z0-9_.-]+[\\\\/])}i', $path);
    }
    
    /**
     * @return string
     */
    public static function getPlatformPath(string $path) {
        if (Platform::isWindows()) {
            $path = Preg::replace('{^(?:file:///([a-z]):?/)}i', 'file://$1:/', $path);
        }
        return Preg::replace('{^file://}i', '', $path);
    }
    
    /**
     * Cross-platform safe version of is_readable()
     *
     * This will also check for readability by reading the file as is_readable can not be trusted on network-mounts
     * and \\wsl$ paths. See https://github.com/composer/composer/issues/8231 and https://bugs.php.net/bug.php?id=68926
     *
     * @return bool
     */
    public static function isReadable(string $path) {
        if (is_readable($path)) {
            return true;
        }
        if (is_file($path)) {
            return false !== Silencer::call('file_get_contents', $path, false, null, 0, 1);
        }
        if (is_dir($path)) {
            return false !== Silencer::call('opendir', $path);
        }
        // assume false otherwise
        return false;
    }
    
    /**
     * @return int
     */
    protected function directorySize(string $directory) {
        $it = new RecursiveDirectoryIterator($directory, RecursiveDirectoryIterator::SKIP_DOTS);
        $ri = new RecursiveIteratorIterator($it, RecursiveIteratorIterator::CHILD_FIRST);
        $size = 0;
        foreach ($ri as $file) {
            if ($file->isFile()) {
                $size += $file->getSize();
            }
        }
        return $size;
    }
    
    /**
     * @return ProcessExecutor
     */
    protected function getProcess() {
        if (null === $this->processExecutor) {
            $this->processExecutor = new ProcessExecutor();
        }
        return $this->processExecutor;
    }
    
    /**
     * delete symbolic link implementation (commonly known as "unlink()")
     *
     * symbolic links on windows which link to directories need rmdir instead of unlink
     */
    private function unlinkImplementation(string $path) : bool {
        if (Platform::isWindows() && is_dir($path) && is_link($path)) {
            return rmdir($path);
        }
        return unlink($path);
    }
    
    /**
     * Creates a relative symlink from $link to $target
     *
     * @param  string $target The path of the binary file to be symlinked
     * @param  string $link   The path where the symlink should be created
     * @return bool
     */
    public function relativeSymlink(string $target, string $link) {
        if (!function_exists('symlink')) {
            return false;
        }
        $cwd = Platform::getCwd();
        $relativePath = $this->findShortestPath($link, $target);
        chdir(\dirname($link));
        $result = @symlink($relativePath, $link);
        chdir($cwd);
        return $result;
    }
    
    /**
     * return true if that directory is a symlink.
     *
     * @return bool
     */
    public function isSymlinkedDirectory(string $directory) {
        if (!is_dir($directory)) {
            return false;
        }
        $resolved = $this->resolveSymlinkedDirectorySymlink($directory);
        return is_link($resolved);
    }
    private function unlinkSymlinkedDirectory(string $directory) : bool {
        $resolved = $this->resolveSymlinkedDirectorySymlink($directory);
        return $this->unlink($resolved);
    }
    
    /**
     * resolve pathname to symbolic link of a directory
     *
     * @param string $pathname directory path to resolve
     *
     * @return string resolved path to symbolic link or original pathname (unresolved)
     */
    private function resolveSymlinkedDirectorySymlink(string $pathname) : string {
        if (!is_dir($pathname)) {
            return $pathname;
        }
        $resolved = rtrim($pathname, '/');
        if (0 === \strlen($resolved)) {
            return $pathname;
        }
        return $resolved;
    }
    
    /**
     * Creates an NTFS junction.
     *
     * @return void
     */
    public function junction(string $target, string $junction) {
        if (!Platform::isWindows()) {
            throw new \LogicException(sprintf('Function %s is not available on non-Windows platform', __CLASS__));
        }
        if (!is_dir($target)) {
            throw new IOException(sprintf('Cannot junction to "%s" as it is not a directory.', $target), 0, null, $target);
        }
        // Removing any previously junction to ensure clean execution.
        if (!is_dir($junction) || $this->isJunction($junction)) {
            @rmdir($junction);
        }
        $cmd = [
            'mklink',
            '/J',
            str_replace('/', DIRECTORY_SEPARATOR, $junction),
            Platform::realpath($target),
        ];
        if ($this->getProcess()
            ->execute($cmd, $output) !== 0) {
            throw new IOException(sprintf('Failed to create junction to "%s" at "%s".', $target, $junction), 0, null, $target);
        }
        clearstatcache(true, $junction);
    }
    
    /**
     * Returns whether the target directory is a Windows NTFS Junction.
     *
     * We test if the path is a directory and not an ordinary link, then check
     * that the mode value returned from lstat (which gives the status of the
     * link itself) is not a directory, by replicating the POSIX S_ISDIR test.
     *
     * This logic works because PHP does not set the mode value for a junction,
     * since there is no universal file type flag for it. Unfortunately an
     * uninitialized variable in PHP prior to 7.2.16 and 7.3.3 may cause a
     * random value to be returned. See https://bugs.php.net/bug.php?id=77552
     *
     * If this random value passes the S_ISDIR test, then a junction will not be
     * detected and a recursive delete operation could lead to loss of data in
     * the target directory. Note that Windows rmdir can handle this situation
     * and will only delete the junction (from Windows 7 onwards).
     *
     * @param  string $junction Path to check.
     * @return bool
     */
    public function isJunction(string $junction) {
        if (!Platform::isWindows()) {
            return false;
        }
        // Important to clear all caches first
        clearstatcache(true, $junction);
        if (!is_dir($junction) || is_link($junction)) {
            return false;
        }
        $stat = lstat($junction);
        // S_ISDIR test (S_IFDIR is 0x4000, S_IFMT is 0xF000 bitmask)
        return is_array($stat) ? 0x4000 !== ($stat['mode'] & 0xf000) : false;
    }
    
    /**
     * Removes a Windows NTFS junction.
     *
     * @return bool
     */
    public function removeJunction(string $junction) {
        if (!Platform::isWindows()) {
            return false;
        }
        $junction = rtrim(str_replace('/', DIRECTORY_SEPARATOR, $junction), DIRECTORY_SEPARATOR);
        if (!$this->isJunction($junction)) {
            throw new IOException(sprintf('%s is not a junction and thus cannot be removed as one', $junction));
        }
        return $this->rmdir($junction);
    }
    
    /**
     * @return int|false
     */
    public function filePutContentsIfModified(string $path, string $content) {
        $currentContent = Silencer::call('file_get_contents', $path);
        if (false === $currentContent || $currentContent !== $content) {
            return file_put_contents($path, $content);
        }
        return 0;
    }
    
    /**
     * Copy file using stream_copy_to_stream to work around https://bugs.php.net/bug.php?id=6463
     */
    public function safeCopy(string $source, string $target) : void {
        if (!file_exists($target) || !file_exists($source) || !$this->filesAreEqual($source, $target)) {
            $sourceHandle = fopen($source, 'r');
            assert($sourceHandle !== false, 'Could not open "' . $source . '" for reading.');
            $targetHandle = fopen($target, 'w+');
            assert($targetHandle !== false, 'Could not open "' . $target . '" for writing.');
            stream_copy_to_stream($sourceHandle, $targetHandle);
            fclose($sourceHandle);
            fclose($targetHandle);
            touch($target, (int) filemtime($source), (int) fileatime($source));
        }
    }
    
    /**
     * compare 2 files
     * https://stackoverflow.com/questions/3060125/can-i-use-file-get-contents-to-compare-two-files
     */
    private function filesAreEqual(string $a, string $b) : bool {
        // Check if filesize is different
        if (filesize($a) !== filesize($b)) {
            return false;
        }
        // Check if content is different
        $aHandle = fopen($a, 'rb');
        assert($aHandle !== false, 'Could not open "' . $a . '" for reading.');
        $bHandle = fopen($b, 'rb');
        assert($bHandle !== false, 'Could not open "' . $b . '" for reading.');
        $result = true;
        while (!feof($aHandle)) {
            if (fread($aHandle, 8192) !== fread($bHandle, 8192)) {
                $result = false;
                break;
            }
        }
        fclose($aHandle);
        fclose($bHandle);
        return $result;
    }

}

Members

Title Sort descending Modifiers Object type Summary
Filesystem::$processExecutor private property @var ?ProcessExecutor
Filesystem::copy public function Copies a file or directory from $source to $target.
Filesystem::copyThenRemove public function Copy then delete is a non-atomic version of {@link rename}.
Filesystem::directorySize protected function
Filesystem::emptyDirectory public function
Filesystem::ensureDirectoryExists public function
Filesystem::filePutContentsIfModified public function
Filesystem::filesAreEqual private function compare 2 files
https://stackoverflow.com/questions/3060125/can-i-use-file-get-contents-to-compare-two-files
Filesystem::findShortestPath public function Returns the shortest path from $from to $to
Filesystem::findShortestPathCode public function Returns PHP code that, when executed in $from, will return the path to $to
Filesystem::getPlatformPath public static function
Filesystem::getProcess protected function
Filesystem::isAbsolutePath public function Checks if the given path is absolute
Filesystem::isDirEmpty public function Checks if a directory is empty
Filesystem::isJunction public function Returns whether the target directory is a Windows NTFS Junction.
Filesystem::isLocalPath public static function Return if the given path is local
Filesystem::isReadable public static function Cross-platform safe version of is_readable()
Filesystem::isSymlinkedDirectory public function return true if that directory is a symlink.
Filesystem::junction public function Creates an NTFS junction.
Filesystem::normalizePath public function Normalize a path. This replaces backslashes with slashes, removes ending
slash and collapses redundant separators and up-level references.
Filesystem::relativeSymlink public function Creates a relative symlink from $link to $target
Filesystem::remove public function
Filesystem::removeDirectory public function Recursively remove a directory
Filesystem::removeDirectoryAsync public function Recursively remove a directory asynchronously
Filesystem::removeDirectoryPhp public function Recursively delete directory using PHP iterators.
Filesystem::removeEdgeCases private function
Filesystem::removeJunction public function Removes a Windows NTFS junction.
Filesystem::rename public function
Filesystem::resolveSymlinkedDirectorySymlink private function resolve pathname to symbolic link of a directory
Filesystem::rmdir public function Attempts to rmdir a file and in case of failure retries after 350ms on windows
Filesystem::safeCopy public function Copy file using stream_copy_to_stream to work around https://bugs.php.net/bug.php?id=6463
Filesystem::size public function Returns size of a file or directory specified by path. If a directory is
given, its size will be computed recursively.
Filesystem::trimTrailingSlash public static function Remove trailing slashes if present to avoid issues with symlinks
Filesystem::unlink public function Attempts to unlink a file and in case of failure retries after 350ms on windows
Filesystem::unlinkImplementation private function delete symbolic link implementation (commonly known as &quot;unlink()&quot;)
Filesystem::unlinkSymlinkedDirectory private function
Filesystem::__construct public function

API Navigation

  • Drupal Core 11.1.x
  • Topics
  • Classes
  • Functions
  • Constants
  • Globals
  • Files
  • Namespaces
  • Deprecated
  • Services
RSS feed
Powered by Drupal