summaryrefslogtreecommitdiffstats
path: root/apps/files_external/lib/Config
diff options
context:
space:
mode:
authorJoas Schilling <nickvergessen@owncloud.com>2016-05-13 11:43:28 +0200
committerJoas Schilling <nickvergessen@owncloud.com>2016-05-24 08:41:21 +0200
commitb9fd7d4cc7834fd0fff01c1c6aa478a62a905bb1 (patch)
tree53f39f34bf02c293db711667634951dae809e3dc /apps/files_external/lib/Config
parent6ea54e73e82fb02bb6bfa3a189a861f90c00d105 (diff)
downloadnextcloud-server-b9fd7d4cc7834fd0fff01c1c6aa478a62a905bb1.tar.gz
nextcloud-server-b9fd7d4cc7834fd0fff01c1c6aa478a62a905bb1.zip
Move Config to PSR-4
Diffstat (limited to 'apps/files_external/lib/Config')
-rw-r--r--apps/files_external/lib/Config/ConfigAdapter.php183
1 files changed, 183 insertions, 0 deletions
diff --git a/apps/files_external/lib/Config/ConfigAdapter.php b/apps/files_external/lib/Config/ConfigAdapter.php
new file mode 100644
index 00000000000..a05ff555f72
--- /dev/null
+++ b/apps/files_external/lib/Config/ConfigAdapter.php
@@ -0,0 +1,183 @@
+<?php
+/**
+ * @author Morris Jobke <hey@morrisjobke.de>
+ * @author Robin Appelman <icewind@owncloud.com>
+ * @author Robin McCorkell <robin@mccorkell.me.uk>
+ *
+ * @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;
+ }
+}