123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532 |
- <?php
- namespace OCA\Files_Sharing;
- use OC\Files\Cache\FailedCache;
- use OC\Files\Cache\NullWatcher;
- use OC\Files\Cache\Watcher;
- use OC\Files\Filesystem;
- use OC\Files\Storage\FailedStorage;
- use OC\Files\Storage\Wrapper\PermissionsMask;
- use OC\User\NoUserException;
- use OCA\Files_External\Config\ExternalMountPoint;
- use OCP\Constants;
- use OCP\Files\Cache\ICacheEntry;
- use OCP\Files\NotFoundException;
- use OCP\Files\Storage\IDisableEncryptionStorage;
- use OCP\Files\Storage\IStorage;
- use OCP\Lock\ILockingProvider;
- class SharedStorage extends \OC\Files\Storage\Wrapper\Jail implements ISharedStorage, IDisableEncryptionStorage {
-
- private $superShare;
-
- private $groupedShares;
-
- private $ownerView;
- private $initialized = false;
-
- private $sourceRootInfo;
-
- private $user;
-
- private $logger;
-
- private $nonMaskedStorage;
- private $options;
-
- private $sharingDisabledForUser;
- public function __construct($arguments) {
- $this->ownerView = $arguments['ownerView'];
- $this->logger = \OC::$server->getLogger();
- $this->superShare = $arguments['superShare'];
- $this->groupedShares = $arguments['groupedShares'];
- $this->user = $arguments['user'];
- if (isset($arguments['sharingDisabledForUser'])) {
- $this->sharingDisabledForUser = $arguments['sharingDisabledForUser'];
- } else {
- $this->sharingDisabledForUser = false;
- }
- parent::__construct([
- 'storage' => null,
- 'root' => null,
- ]);
- }
-
- private function getSourceRootInfo() {
- if (is_null($this->sourceRootInfo)) {
- if (is_null($this->superShare->getNodeCacheEntry())) {
- $this->init();
- $this->sourceRootInfo = $this->nonMaskedStorage->getCache()->get($this->rootPath);
- } else {
- $this->sourceRootInfo = $this->superShare->getNodeCacheEntry();
- }
- }
- return $this->sourceRootInfo;
- }
- private function init() {
- if ($this->initialized) {
- return;
- }
- $this->initialized = true;
- try {
- Filesystem::initMountPoints($this->superShare->getShareOwner());
- $storageId = $this->superShare->getNodeCacheEntry() ? $this->superShare->getNodeCacheEntry()->getStorageId() : null;
- $sourcePath = $this->ownerView->getPath($this->superShare->getNodeId(), $storageId);
- [$this->nonMaskedStorage, $this->rootPath] = $this->ownerView->resolvePath($sourcePath);
- $this->storage = new PermissionsMask([
- 'storage' => $this->nonMaskedStorage,
- 'mask' => $this->superShare->getPermissions(),
- ]);
- } catch (NotFoundException $e) {
-
- $this->storage = new FailedStorage(['exception' => $e]);
- $this->cache = new FailedCache();
- $this->rootPath = '';
- } catch (NoUserException $e) {
-
- $this->storage = new FailedStorage(['exception' => $e]);
- $this->cache = new FailedCache();
- $this->rootPath = '';
- } catch (\Exception $e) {
- $this->storage = new FailedStorage(['exception' => $e]);
- $this->cache = new FailedCache();
- $this->rootPath = '';
- $this->logger->logException($e);
- }
- if (!$this->nonMaskedStorage) {
- $this->nonMaskedStorage = $this->storage;
- }
- }
-
- public function instanceOfStorage($class) {
- if ($class === '\OC\Files\Storage\Common') {
- return true;
- }
- if (in_array($class, ['\OC\Files\Storage\Home', '\OC\Files\ObjectStore\HomeObjectStoreStorage', '\OCP\Files\IHomeStorage'])) {
- return false;
- }
- return parent::instanceOfStorage($class);
- }
-
- public function getShareId() {
- return $this->superShare->getId();
- }
- private function isValid() {
- return $this->getSourceRootInfo() && ($this->getSourceRootInfo()->getPermissions() & Constants::PERMISSION_SHARE) === Constants::PERMISSION_SHARE;
- }
-
- public function getId() {
- return 'shared::' . $this->getMountPoint();
- }
-
- public function getPermissions($target = '') {
- if (!$this->isValid()) {
- return 0;
- }
- $permissions = parent::getPermissions($target) & $this->superShare->getPermissions();
-
- if ($target === '' || pathinfo($target, PATHINFO_EXTENSION) === 'part') {
- $permissions |= \OCP\Constants::PERMISSION_DELETE;
- }
- if ($this->sharingDisabledForUser) {
- $permissions &= ~\OCP\Constants::PERMISSION_SHARE;
- }
- return $permissions;
- }
- public function isCreatable($path) {
- return ($this->getPermissions($path) & \OCP\Constants::PERMISSION_CREATE);
- }
- public function isReadable($path) {
- if (!$this->isValid()) {
- return false;
- }
- if (!$this->file_exists($path)) {
- return false;
- }
-
-
- [$storage, $internalPath] = $this->resolvePath($path);
- return $storage->isReadable($internalPath);
- }
- public function isUpdatable($path) {
- return ($this->getPermissions($path) & \OCP\Constants::PERMISSION_UPDATE);
- }
- public function isDeletable($path) {
- return ($this->getPermissions($path) & \OCP\Constants::PERMISSION_DELETE);
- }
- public function isSharable($path) {
- if (\OCP\Util::isSharingDisabledForUser() || !\OC\Share\Share::isResharingAllowed()) {
- return false;
- }
- return ($this->getPermissions($path) & \OCP\Constants::PERMISSION_SHARE);
- }
- public function fopen($path, $mode) {
- $source = $this->getUnjailedPath($path);
- switch ($mode) {
- case 'r+':
- case 'rb+':
- case 'w+':
- case 'wb+':
- case 'x+':
- case 'xb+':
- case 'a+':
- case 'ab+':
- case 'w':
- case 'wb':
- case 'x':
- case 'xb':
- case 'a':
- case 'ab':
- $creatable = $this->isCreatable(dirname($path));
- $updatable = $this->isUpdatable($path);
-
- if (!$creatable && !$updatable) {
- if (pathinfo($path, PATHINFO_EXTENSION) === 'part') {
- $updatable = $this->isUpdatable(dirname($path));
- }
- if (!$updatable) {
- return false;
- }
- }
- $exists = $this->file_exists($path);
-
- if ($exists && !$updatable) {
- return false;
- }
-
- if (pathinfo($path, PATHINFO_EXTENSION) !== 'part') {
- if (!$exists && !$creatable) {
- return false;
- }
- }
- }
- $info = [
- 'target' => $this->getMountPoint() . '/' . $path,
- 'source' => $source,
- 'mode' => $mode,
- ];
- \OCP\Util::emitHook('\OC\Files\Storage\Shared', 'fopen', $info);
- return $this->nonMaskedStorage->fopen($this->getUnjailedPath($path), $mode);
- }
-
- public function rename($path1, $path2) {
- $this->init();
- $isPartFile = pathinfo($path1, PATHINFO_EXTENSION) === 'part';
- $targetExists = $this->file_exists($path2);
- $sameFolder = dirname($path1) === dirname($path2);
- if ($targetExists || ($sameFolder && !$isPartFile)) {
- if (!$this->isUpdatable('')) {
- return false;
- }
- } else {
- if (!$this->isCreatable('')) {
- return false;
- }
- }
- return $this->nonMaskedStorage->rename($this->getUnjailedPath($path1), $this->getUnjailedPath($path2));
- }
-
- public function getMountPoint() {
- return $this->superShare->getTarget();
- }
-
- public function setMountPoint($path) {
- $this->superShare->setTarget($path);
- foreach ($this->groupedShares as $share) {
- $share->setTarget($path);
- }
- }
-
- public function getSharedFrom() {
- return $this->superShare->getShareOwner();
- }
-
- public function getShare() {
- return $this->superShare;
- }
-
- public function getItemType() {
- return $this->superShare->getNodeType();
- }
-
- public function getCache($path = '', $storage = null) {
- if ($this->cache) {
- return $this->cache;
- }
- if (!$storage) {
- $storage = $this;
- }
- $sourceRoot = $this->getSourceRootInfo();
- if ($this->storage instanceof FailedStorage) {
- return new FailedCache();
- }
- $this->cache = new \OCA\Files_Sharing\Cache($storage, $sourceRoot, $this->superShare);
- return $this->cache;
- }
- public function getScanner($path = '', $storage = null) {
- if (!$storage) {
- $storage = $this;
- }
- return new \OCA\Files_Sharing\Scanner($storage);
- }
- public function getOwner($path) {
- return $this->superShare->getShareOwner();
- }
- public function getWatcher($path = '', $storage = null): Watcher {
- $mountManager = \OC::$server->getMountManager();
-
- $node = $this->getShare()->getNodeCacheEntry();
- if ($node) {
- $mount = $mountManager->findByNumericId($node->getStorageId());
-
- if (count($mount) > 0 && $mount[0] instanceof ExternalMountPoint) {
-
- return parent::getWatcher($path, $storage);
- }
- }
-
- return new NullWatcher();
- }
-
- public function unshareStorage() {
- foreach ($this->groupedShares as $share) {
- \OC::$server->getShareManager()->deleteFromSelf($share, $this->user);
- }
- return true;
- }
-
- public function acquireLock($path, $type, ILockingProvider $provider) {
-
- [$targetStorage, $targetInternalPath] = $this->resolvePath($path);
- $targetStorage->acquireLock($targetInternalPath, $type, $provider);
-
- if ($path === '') {
- $sourcePath = $this->ownerView->getPath($this->superShare->getNodeId());
- $this->ownerView->lockFile(dirname($sourcePath), ILockingProvider::LOCK_SHARED, true);
- }
- }
-
- public function releaseLock($path, $type, ILockingProvider $provider) {
-
- [$targetStorage, $targetInternalPath] = $this->resolvePath($path);
- $targetStorage->releaseLock($targetInternalPath, $type, $provider);
-
- if ($path === '') {
- $sourcePath = $this->ownerView->getPath($this->superShare->getNodeId());
- $this->ownerView->unlockFile(dirname($sourcePath), ILockingProvider::LOCK_SHARED, true);
- }
- }
-
- public function changeLock($path, $type, ILockingProvider $provider) {
-
- [$targetStorage, $targetInternalPath] = $this->resolvePath($path);
- $targetStorage->changeLock($targetInternalPath, $type, $provider);
- }
-
- public function getAvailability() {
-
- return [
- 'available' => true,
- 'last_checked' => 0,
- ];
- }
-
- public function setAvailability($available) {
-
- }
- public function getSourceStorage() {
- $this->init();
- return $this->nonMaskedStorage;
- }
- public function getWrapperStorage() {
- $this->init();
- return $this->storage;
- }
- public function file_get_contents($path) {
- $info = [
- 'target' => $this->getMountPoint() . '/' . $path,
- 'source' => $this->getUnjailedPath($path),
- ];
- \OCP\Util::emitHook('\OC\Files\Storage\Shared', 'file_get_contents', $info);
- return parent::file_get_contents($path);
- }
- public function file_put_contents($path, $data) {
- $info = [
- 'target' => $this->getMountPoint() . '/' . $path,
- 'source' => $this->getUnjailedPath($path),
- ];
- \OCP\Util::emitHook('\OC\Files\Storage\Shared', 'file_put_contents', $info);
- return parent::file_put_contents($path, $data);
- }
- public function setMountOptions(array $options) {
- $this->mountOptions = $options;
- }
- public function getUnjailedPath($path) {
- $this->init();
- return parent::getUnjailedPath($path);
- }
- }
|