* @author Morris Jobke * @author Robin Appelman * @author Robin McCorkell * @author Roeland Jago Douma * * @license AGPL-3.0 * * This code is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License, version 3, * as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License, version 3, * along with this program. If not, see * */ namespace OC\Files\Mount; use OC\Cache\CappedMemoryCache; use OC\Files\Filesystem; use OCP\Files\Mount\IMountManager; use OCP\Files\Mount\IMountPoint; class Manager implements IMountManager { /** @var MountPoint[] */ private $mounts = []; /** @var CappedMemoryCache */ private $pathCache; /** @var CappedMemoryCache */ private $inPathCache; public function __construct() { $this->pathCache = new CappedMemoryCache(); $this->inPathCache = new CappedMemoryCache(); } /** * @param IMountPoint $mount */ public function addMount(IMountPoint $mount) { $this->mounts[$mount->getMountPoint()] = $mount; $this->pathCache->clear(); $this->inPathCache->clear(); } /** * @param string $mountPoint */ public function removeMount(string $mountPoint) { $mountPoint = Filesystem::normalizePath($mountPoint); if (\strlen($mountPoint) > 1) { $mountPoint .= '/'; } unset($this->mounts[$mountPoint]); $this->pathCache->clear(); $this->inPathCache->clear(); } /** * @param string $mountPoint * @param string $target */ public function moveMount(string $mountPoint, string $target) { $this->mounts[$target] = $this->mounts[$mountPoint]; unset($this->mounts[$mountPoint]); $this->pathCache->clear(); $this->inPathCache->clear(); } /** * Find the mount for $path * * @param string $path * @return MountPoint|null */ public function find(string $path) { \OC_Util::setupFS(); $path = Filesystem::normalizePath($path); if (isset($this->pathCache[$path])) { return $this->pathCache[$path]; } $current = $path; while (true) { $mountPoint = $current . '/'; if (isset($this->mounts[$mountPoint])) { $this->pathCache[$path] = $this->mounts[$mountPoint]; return $this->mounts[$mountPoint]; } if ($current === '') { return null; } $current = dirname($current); if ($current === '.' || $current === '/') { $current = ''; } } } /** * Find all mounts in $path * * @param string $path * @return MountPoint[] */ public function findIn(string $path): array { \OC_Util::setupFS(); $path = $this->formatPath($path); if (isset($this->inPathCache[$path])) { return $this->inPathCache[$path]; } $result = []; $pathLength = \strlen($path); $mountPoints = array_keys($this->mounts); foreach ($mountPoints as $mountPoint) { if (substr($mountPoint, 0, $pathLength) === $path && \strlen($mountPoint) > $pathLength) { $result[] = $this->mounts[$mountPoint]; } } $this->inPathCache[$path] = $result; return $result; } public function clear() { $this->mounts = []; $this->pathCache->clear(); $this->inPathCache->clear(); } /** * Find mounts by storage id * * @param string $id * @return MountPoint[] */ public function findByStorageId(string $id): array { \OC_Util::setupFS(); if (\strlen($id) > 64) { $id = md5($id); } $result = []; foreach ($this->mounts as $mount) { if ($mount->getStorageId() === $id) { $result[] = $mount; } } return $result; } /** * @return MountPoint[] */ public function getAll(): array { return $this->mounts; } /** * Find mounts by numeric storage id * * @param int $id * @return MountPoint[] */ public function findByNumericId(int $id): array { $storageId = \OC\Files\Cache\Storage::getStorageId($id); return $this->findByStorageId($storageId); } /** * @param string $path * @return string */ private function formatPath(string $path): string { $path = Filesystem::normalizePath($path); if (\strlen($path) > 1) { $path .= '/'; } return $path; } }