123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185 |
- <?php
- /**
- * @author Joas Schilling <nickvergessen@owncloud.com>
- * @author Morris Jobke <hey@morrisjobke.de>
- * @author Robin Appelman <icewind@owncloud.com>
- * @author Robin McCorkell <robin@mccorkell.me.uk>
- * @author Vincent Petry <pvince81@owncloud.com>
- *
- * @copyright Copyright (c) 2016, ownCloud, Inc.
- * @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 <http://www.gnu.org/licenses/>
- *
- */
-
- namespace OCA\Files_External\Config;
-
- use OC\Files\Storage\Wrapper\Availability;
- use OCA\Files_External\Migration\StorageMigrator;
- use OCP\Files\Storage;
- use OC\Files\Mount\MountPoint;
- use OCP\Files\Storage\IStorageFactory;
- use OCA\Files_External\Lib\PersonalMount;
- use OCP\Files\Config\IMountProvider;
- use OCP\IUser;
- use OCA\Files_External\Service\UserStoragesService;
- use OCA\Files_External\Service\UserGlobalStoragesService;
- use OCA\Files_External\Lib\StorageConfig;
- use OC\Files\Storage\FailedStorage;
- use OCP\Files\StorageNotAvailableException;
-
- /**
- * Make the old files_external config work with the new public mount config api
- */
- class ConfigAdapter implements IMountProvider {
-
- /** @var UserStoragesService */
- private $userStoragesService;
-
- /** @var UserGlobalStoragesService */
- private $userGlobalStoragesService;
- /** @var StorageMigrator */
- private $migrator;
-
- /**
- * @param UserStoragesService $userStoragesService
- * @param UserGlobalStoragesService $userGlobalStoragesService
- * @param StorageMigrator $migrator
- */
- public function __construct(
- UserStoragesService $userStoragesService,
- UserGlobalStoragesService $userGlobalStoragesService,
- StorageMigrator $migrator
- ) {
- $this->userStoragesService = $userStoragesService;
- $this->userGlobalStoragesService = $userGlobalStoragesService;
- $this->migrator = $migrator;
- }
-
- /**
- * Process storage ready for mounting
- *
- * @param StorageConfig $storage
- * @param IUser $user
- */
- private function prepareStorageConfig(StorageConfig &$storage, IUser $user) {
- foreach ($storage->getBackendOptions() as $option => $value) {
- $storage->setBackendOption($option, \OC_Mount_Config::setUserVars(
- $user->getUID(), $value
- ));
- }
-
- $objectStore = $storage->getBackendOption('objectstore');
- if ($objectStore) {
- $objectClass = $objectStore['class'];
- if (!is_subclass_of($objectClass, '\OCP\Files\ObjectStore\IObjectStore')) {
- throw new \InvalidArgumentException('Invalid object store');
- }
- $storage->setBackendOption('objectstore', new $objectClass($objectStore));
- }
-
- $storage->getAuthMechanism()->manipulateStorageConfig($storage, $user);
- $storage->getBackend()->manipulateStorageConfig($storage, $user);
- }
-
- /**
- * Construct the storage implementation
- *
- * @param StorageConfig $storageConfig
- * @return Storage
- */
- private function constructStorage(StorageConfig $storageConfig) {
- $class = $storageConfig->getBackend()->getStorageClass();
- $storage = new $class($storageConfig->getBackendOptions());
-
- // auth mechanism should fire first
- $storage = $storageConfig->getBackend()->wrapStorage($storage);
- $storage = $storageConfig->getAuthMechanism()->wrapStorage($storage);
-
- return $storage;
- }
-
- /**
- * Get all mountpoints applicable for the user
- *
- * @param \OCP\IUser $user
- * @param \OCP\Files\Storage\IStorageFactory $loader
- * @return \OCP\Files\Mount\IMountPoint[]
- */
- public function getMountsForUser(IUser $user, IStorageFactory $loader) {
- $this->migrator->migrateUser($user);
-
- $mounts = [];
-
- $this->userStoragesService->setUser($user);
- $this->userGlobalStoragesService->setUser($user);
-
- foreach ($this->userGlobalStoragesService->getUniqueStorages() as $storage) {
- try {
- $this->prepareStorageConfig($storage, $user);
- $impl = $this->constructStorage($storage);
- } catch (\Exception $e) {
- // propagate exception into filesystem
- $impl = new FailedStorage(['exception' => $e]);
- }
-
- try {
- $availability = $impl->getAvailability();
- if (!$availability['available'] && !Availability::shouldRecheck($availability)) {
- $impl = new FailedStorage([
- 'exception' => new StorageNotAvailableException('Storage with mount id ' . $storage->getId() . ' is not available')
- ]);
- }
- } catch (\Exception $e) {
- // propagate exception into filesystem
- $impl = new FailedStorage(['exception' => $e]);
- }
-
- $mount = new MountPoint(
- $impl,
- '/' . $user->getUID() . '/files' . $storage->getMountPoint(),
- null,
- $loader,
- $storage->getMountOptions()
- );
- $mounts[$storage->getMountPoint()] = $mount;
- }
-
- foreach ($this->userStoragesService->getStorages() as $storage) {
- try {
- $this->prepareStorageConfig($storage, $user);
- $impl = $this->constructStorage($storage);
- } catch (\Exception $e) {
- // propagate exception into filesystem
- $impl = new FailedStorage(['exception' => $e]);
- }
-
- $mount = new PersonalMount(
- $this->userStoragesService,
- $storage->getId(),
- $impl,
- '/' . $user->getUID() . '/files' . $storage->getMountPoint(),
- null,
- $loader,
- $storage->getMountOptions()
- );
- $mounts[$storage->getMountPoint()] = $mount;
- }
-
- $this->userStoragesService->resetUser();
- $this->userGlobalStoragesService->resetUser();
-
- return $mounts;
- }
- }
|