Filesystem,] * * @throws InvalidArgumentException */ public function __construct(array $filesystems = []) { $this->mountFilesystems($filesystems); } /** * Mount filesystems. * * @param FilesystemInterface[] $filesystems [:prefix => Filesystem,] * * @throws InvalidArgumentException * * @return $this */ public function mountFilesystems(array $filesystems) { foreach ($filesystems as $prefix => $filesystem) { $this->mountFilesystem($prefix, $filesystem); } return $this; } /** * Mount filesystems. * * @param string $prefix * @param FilesystemInterface $filesystem * * @throws InvalidArgumentException * * @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; } /** * Get the filesystem with the corresponding prefix. * * @param string $prefix * * @throws FilesystemNotFoundException * * @return FilesystemInterface */ public function getFilesystem($prefix) { if ( ! isset($this->filesystems[$prefix])) { throw new FilesystemNotFoundException('No filesystem mounted with prefix ' . $prefix); } return $this->filesystems[$prefix]; } /** * Retrieve the prefix from an arguments array. * * @param array $arguments * * @throws InvalidArgumentException * * @return array [:prefix, :arguments] */ 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]; } /** * @param string $directory * @param bool $recursive * * @throws InvalidArgumentException * @throws FilesystemNotFoundException * * @return array */ 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; } /** * Call forwarder. * * @param string $method * @param array $arguments * * @throws InvalidArgumentException * @throws FilesystemNotFoundException * * @return mixed */ public function __call($method, $arguments) { list($prefix, $arguments) = $this->filterPrefix($arguments); return $this->invokePluginOnFilesystem($method, $arguments, $prefix); } /** * @param string $from * @param string $to * @param array $config * * @throws InvalidArgumentException * @throws FilesystemNotFoundException * * @return bool */ 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; } /** * List with plugin adapter. * * @param array $keys * @param string $directory * @param bool $recursive * * @throws InvalidArgumentException * @throws FilesystemNotFoundException * * @return array */ public function listWith(array $keys = [], $directory = '', $recursive = false) { list($prefix, $directory) = $this->getPrefixAndPath($directory); $arguments = [$keys, $directory, $recursive]; return $this->invokePluginOnFilesystem('listWith', $arguments, $prefix); } /** * Move a file. * * @param string $from * @param string $to * @param array $config * * @throws InvalidArgumentException * @throws FilesystemNotFoundException * * @return bool */ public function move($from, $to, array $config = []) { list($prefixFrom, $pathFrom) = $this->getPrefixAndPath($from); list($prefixTo, $pathTo) = $this->getPrefixAndPath($to); if ($prefixFrom === $prefixTo) { $filesystem = $this->getFilesystem($prefixFrom); $renamed = $filesystem->rename($pathFrom, $pathTo); if ($renamed && isset($config['visibility'])) { return $filesystem->setVisibility($pathTo, $config['visibility']); } return $renamed; } $copied = $this->copy($from, $to, $config); if ($copied) { return $this->delete($from); } return false; } /** * Invoke a plugin on a filesystem mounted on a given prefix. * * @param string $method * @param array $arguments * @param string $prefix * * @throws FilesystemNotFoundException * * @return mixed */ 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); } /** * @param string $path * * @throws InvalidArgumentException * * @return string[] [:prefix, :path] */ protected function getPrefixAndPath($path) { if (strpos($path, '://') < 1) { throw new InvalidArgumentException('No prefix detected in path: ' . $path); } return explode('://', $path, 2); } }