MountManager.php

Go to the documentation of this file.

<?php
 
namespace League\Flysystem;
 
use InvalidArgumentException;
use League\Flysystem\FilesystemNotFoundException;
use League\Flysystem\Plugin\PluggableTrait;
use League\Flysystem\Plugin\PluginNotFoundException;
 
class MountManager
{
    use PluggableTrait;
 
    protected $filesystems = [];
 
    public function __construct(array $filesystems = [])
    {
        $this->mountFilesystems($filesystems);
    }
 
    public function mountFilesystems(array $filesystems)
    {
        foreach ($filesystems as $prefix => $filesystem) {
            $this->mountFilesystem($prefix, $filesystem);
        }
 
        return $this;
    }
 
    public function mountFilesystem($prefix, FilesystemInterface $filesystem)
    {
        if ( ! is_string($prefix)) {
            throw new InvalidArgumentException(__METHOD__ . ' expects argument #1 to be a string.');
        }
 
        $this->filesystems[$prefix] = $filesystem;
 
        return $this;
    }
 
    public function getFilesystem($prefix)
    {
        if ( ! isset($this->filesystems[$prefix])) {
            throw new FilesystemNotFoundException('No filesystem mounted with prefix ' . $prefix);
        }
 
        return $this->filesystems[$prefix];
    }
 
    public function filterPrefix(array $arguments)
    {
        if (empty($arguments)) {
            throw new InvalidArgumentException('At least one argument needed');
        }
 
        $path = array_shift($arguments);
 
        if ( ! is_string($path)) {
            throw new InvalidArgumentException('First argument should be a string');
        }
 
        list($prefix, $path) = $this->getPrefixAndPath($path);
        array_unshift($arguments, $path);
 
        return [$prefix, $arguments];
    }
 
    public function listContents($directory = '', $recursive = false)
    {
        list($prefix, $directory) = $this->getPrefixAndPath($directory);
        $filesystem = $this->getFilesystem($prefix);
        $result = $filesystem->listContents($directory, $recursive);
 
        foreach ($result as &$file) {
            $file['filesystem'] = $prefix;
        }
 
        return $result;
    }
 
    public function __call($method, $arguments)
    {
        list($prefix, $arguments) = $this->filterPrefix($arguments);
 
        return $this->invokePluginOnFilesystem($method, $arguments, $prefix);
    }
 
    public function copy($from, $to, array $config = [])
    {
        list($prefixFrom, $from) = $this->getPrefixAndPath($from);
 
        $buffer = $this->getFilesystem($prefixFrom)->readStream($from);
 
        if ($buffer === false) {
            return false;
        }
 
        list($prefixTo, $to) = $this->getPrefixAndPath($to);
 
        $result = $this->getFilesystem($prefixTo)->writeStream($to, $buffer, $config);
 
        if (is_resource($buffer)) {
            fclose($buffer);
        }
 
        return $result;
    }
 
    public function listWith(array $keys = [], $directory = '', $recursive = false)
    {
        list($prefix, $directory) = $this->getPrefixAndPath($directory);
        $arguments = [$keys, $directory, $recursive];
 
        return $this->invokePluginOnFilesystem('listWith', $arguments, $prefix);
    }
 
    public function move($from, $to, array $config = [])
    {
        $copied = $this->copy($from, $to, $config);
 
        if ($copied) {
            return $this->delete($from);
        }
 
        return false;
    }
 
    public function invokePluginOnFilesystem($method, $arguments, $prefix)
    {
        $filesystem = $this->getFilesystem($prefix);
 
        try {
            return $this->invokePlugin($method, $arguments, $filesystem);
        } catch (PluginNotFoundException $e) {
            // Let it pass, it's ok, don't panic.
        }
 
        $callback = [$filesystem, $method];
 
        return call_user_func_array($callback, $arguments);
    }
 
    protected function getPrefixAndPath($path)
    {
        if (strpos($path, '://') < 1) {
            throw new InvalidArgumentException('No prefix detected in path: ' . $path);
        }
 
        return explode('://', $path, 2);
    }
}