@@ -30,15 +30,15 @@ |
||
| 30 | 30 | * Mount provider for regular posix home folders |
| 31 | 31 | */ |
| 32 | 32 | class LocalHomeMountProvider implements IHomeMountProvider { |
| 33 | - /** |
|
| 34 | - * Get the cache mount for a user |
|
| 35 | - * |
|
| 36 | - * @param IUser $user |
|
| 37 | - * @param IStorageFactory $loader |
|
| 38 | - * @return \OCP\Files\Mount\IMountPoint[] |
|
| 39 | - */ |
|
| 40 | - public function getHomeMountForUser(IUser $user, IStorageFactory $loader) { |
|
| 41 | - $arguments = ['user' => $user]; |
|
| 42 | - return new MountPoint('\OC\Files\Storage\Home', '/' . $user->getUID(), $arguments, $loader); |
|
| 43 | - } |
|
| 33 | + /** |
|
| 34 | + * Get the cache mount for a user |
|
| 35 | + * |
|
| 36 | + * @param IUser $user |
|
| 37 | + * @param IStorageFactory $loader |
|
| 38 | + * @return \OCP\Files\Mount\IMountPoint[] |
|
| 39 | + */ |
|
| 40 | + public function getHomeMountForUser(IUser $user, IStorageFactory $loader) { |
|
| 41 | + $arguments = ['user' => $user]; |
|
| 42 | + return new MountPoint('\OC\Files\Storage\Home', '/' . $user->getUID(), $arguments, $loader); |
|
| 43 | + } |
|
| 44 | 44 | } |
@@ -39,6 +39,6 @@ |
||
| 39 | 39 | */ |
| 40 | 40 | public function getHomeMountForUser(IUser $user, IStorageFactory $loader) { |
| 41 | 41 | $arguments = ['user' => $user]; |
| 42 | - return new MountPoint('\OC\Files\Storage\Home', '/' . $user->getUID(), $arguments, $loader); |
|
| 42 | + return new MountPoint('\OC\Files\Storage\Home', '/'.$user->getUID(), $arguments, $loader); |
|
| 43 | 43 | } |
| 44 | 44 | } |
@@ -27,19 +27,19 @@ |
||
| 27 | 27 | * Defines the mount point to be (re)moved by the user |
| 28 | 28 | */ |
| 29 | 29 | interface MoveableMount { |
| 30 | - /** |
|
| 31 | - * Move the mount point to $target |
|
| 32 | - * |
|
| 33 | - * @param string $target the target mount point |
|
| 34 | - * @return bool |
|
| 35 | - */ |
|
| 36 | - public function moveMount($target); |
|
| 30 | + /** |
|
| 31 | + * Move the mount point to $target |
|
| 32 | + * |
|
| 33 | + * @param string $target the target mount point |
|
| 34 | + * @return bool |
|
| 35 | + */ |
|
| 36 | + public function moveMount($target); |
|
| 37 | 37 | |
| 38 | - /** |
|
| 39 | - * Remove the mount points |
|
| 40 | - * |
|
| 41 | - * @return mixed |
|
| 42 | - * @return bool |
|
| 43 | - */ |
|
| 44 | - public function removeMount(); |
|
| 38 | + /** |
|
| 39 | + * Remove the mount points |
|
| 40 | + * |
|
| 41 | + * @return mixed |
|
| 42 | + * @return bool |
|
| 43 | + */ |
|
| 44 | + public function removeMount(); |
|
| 45 | 45 | } |
@@ -33,71 +33,71 @@ |
||
| 33 | 33 | * usage: resource \OC\Files\Stream\Quota::wrap($stream, $limit) |
| 34 | 34 | */ |
| 35 | 35 | class Quota extends Wrapper { |
| 36 | - /** |
|
| 37 | - * @var int $limit |
|
| 38 | - */ |
|
| 39 | - private $limit; |
|
| 36 | + /** |
|
| 37 | + * @var int $limit |
|
| 38 | + */ |
|
| 39 | + private $limit; |
|
| 40 | 40 | |
| 41 | - /** |
|
| 42 | - * @param resource $stream |
|
| 43 | - * @param int $limit |
|
| 44 | - * @return resource |
|
| 45 | - */ |
|
| 46 | - static public function wrap($stream, $limit) { |
|
| 47 | - $context = stream_context_create(array( |
|
| 48 | - 'quota' => array( |
|
| 49 | - 'source' => $stream, |
|
| 50 | - 'limit' => $limit |
|
| 51 | - ) |
|
| 52 | - )); |
|
| 53 | - return Wrapper::wrapSource($stream, $context, 'quota', self::class); |
|
| 54 | - } |
|
| 41 | + /** |
|
| 42 | + * @param resource $stream |
|
| 43 | + * @param int $limit |
|
| 44 | + * @return resource |
|
| 45 | + */ |
|
| 46 | + static public function wrap($stream, $limit) { |
|
| 47 | + $context = stream_context_create(array( |
|
| 48 | + 'quota' => array( |
|
| 49 | + 'source' => $stream, |
|
| 50 | + 'limit' => $limit |
|
| 51 | + ) |
|
| 52 | + )); |
|
| 53 | + return Wrapper::wrapSource($stream, $context, 'quota', self::class); |
|
| 54 | + } |
|
| 55 | 55 | |
| 56 | - public function stream_open($path, $mode, $options, &$opened_path) { |
|
| 57 | - $context = $this->loadContext('quota'); |
|
| 58 | - $this->source = $context['source']; |
|
| 59 | - $this->limit = $context['limit']; |
|
| 56 | + public function stream_open($path, $mode, $options, &$opened_path) { |
|
| 57 | + $context = $this->loadContext('quota'); |
|
| 58 | + $this->source = $context['source']; |
|
| 59 | + $this->limit = $context['limit']; |
|
| 60 | 60 | |
| 61 | - return true; |
|
| 62 | - } |
|
| 61 | + return true; |
|
| 62 | + } |
|
| 63 | 63 | |
| 64 | - public function dir_opendir($path, $options) { |
|
| 65 | - return false; |
|
| 66 | - } |
|
| 64 | + public function dir_opendir($path, $options) { |
|
| 65 | + return false; |
|
| 66 | + } |
|
| 67 | 67 | |
| 68 | - public function stream_seek($offset, $whence = SEEK_SET) { |
|
| 69 | - if ($whence === SEEK_END){ |
|
| 70 | - // go to the end to find out last position's offset |
|
| 71 | - $oldOffset = $this->stream_tell(); |
|
| 72 | - if (fseek($this->source, 0, $whence) !== 0){ |
|
| 73 | - return false; |
|
| 74 | - } |
|
| 75 | - $whence = SEEK_SET; |
|
| 76 | - $offset = $this->stream_tell() + $offset; |
|
| 77 | - $this->limit += $oldOffset - $offset; |
|
| 78 | - } |
|
| 79 | - else if ($whence === SEEK_SET) { |
|
| 80 | - $this->limit += $this->stream_tell() - $offset; |
|
| 81 | - } else { |
|
| 82 | - $this->limit -= $offset; |
|
| 83 | - } |
|
| 84 | - // this wrapper needs to return "true" for success. |
|
| 85 | - // the fseek call itself returns 0 on succeess |
|
| 86 | - return fseek($this->source, $offset, $whence) === 0; |
|
| 87 | - } |
|
| 68 | + public function stream_seek($offset, $whence = SEEK_SET) { |
|
| 69 | + if ($whence === SEEK_END){ |
|
| 70 | + // go to the end to find out last position's offset |
|
| 71 | + $oldOffset = $this->stream_tell(); |
|
| 72 | + if (fseek($this->source, 0, $whence) !== 0){ |
|
| 73 | + return false; |
|
| 74 | + } |
|
| 75 | + $whence = SEEK_SET; |
|
| 76 | + $offset = $this->stream_tell() + $offset; |
|
| 77 | + $this->limit += $oldOffset - $offset; |
|
| 78 | + } |
|
| 79 | + else if ($whence === SEEK_SET) { |
|
| 80 | + $this->limit += $this->stream_tell() - $offset; |
|
| 81 | + } else { |
|
| 82 | + $this->limit -= $offset; |
|
| 83 | + } |
|
| 84 | + // this wrapper needs to return "true" for success. |
|
| 85 | + // the fseek call itself returns 0 on succeess |
|
| 86 | + return fseek($this->source, $offset, $whence) === 0; |
|
| 87 | + } |
|
| 88 | 88 | |
| 89 | - public function stream_read($count) { |
|
| 90 | - $this->limit -= $count; |
|
| 91 | - return fread($this->source, $count); |
|
| 92 | - } |
|
| 89 | + public function stream_read($count) { |
|
| 90 | + $this->limit -= $count; |
|
| 91 | + return fread($this->source, $count); |
|
| 92 | + } |
|
| 93 | 93 | |
| 94 | - public function stream_write($data) { |
|
| 95 | - $size = strlen($data); |
|
| 96 | - if ($size > $this->limit) { |
|
| 97 | - $data = substr($data, 0, $this->limit); |
|
| 98 | - $size = $this->limit; |
|
| 99 | - } |
|
| 100 | - $this->limit -= $size; |
|
| 101 | - return fwrite($this->source, $data); |
|
| 102 | - } |
|
| 94 | + public function stream_write($data) { |
|
| 95 | + $size = strlen($data); |
|
| 96 | + if ($size > $this->limit) { |
|
| 97 | + $data = substr($data, 0, $this->limit); |
|
| 98 | + $size = $this->limit; |
|
| 99 | + } |
|
| 100 | + $this->limit -= $size; |
|
| 101 | + return fwrite($this->source, $data); |
|
| 102 | + } |
|
| 103 | 103 | } |
@@ -66,10 +66,10 @@ |
||
| 66 | 66 | } |
| 67 | 67 | |
| 68 | 68 | public function stream_seek($offset, $whence = SEEK_SET) { |
| 69 | - if ($whence === SEEK_END){ |
|
| 69 | + if ($whence === SEEK_END) { |
|
| 70 | 70 | // go to the end to find out last position's offset |
| 71 | 71 | $oldOffset = $this->stream_tell(); |
| 72 | - if (fseek($this->source, 0, $whence) !== 0){ |
|
| 72 | + if (fseek($this->source, 0, $whence) !== 0) { |
|
| 73 | 73 | return false; |
| 74 | 74 | } |
| 75 | 75 | $whence = SEEK_SET; |
@@ -75,8 +75,7 @@ |
||
| 75 | 75 | $whence = SEEK_SET; |
| 76 | 76 | $offset = $this->stream_tell() + $offset; |
| 77 | 77 | $this->limit += $oldOffset - $offset; |
| 78 | - } |
|
| 79 | - else if ($whence === SEEK_SET) { |
|
| 78 | + } else if ($whence === SEEK_SET) { |
|
| 80 | 79 | $this->limit += $this->stream_tell() - $offset; |
| 81 | 80 | } else { |
| 82 | 81 | $this->limit -= $offset; |
@@ -29,60 +29,60 @@ |
||
| 29 | 29 | use OCP\IUser; |
| 30 | 30 | |
| 31 | 31 | class LazyStorageMountInfo extends CachedMountInfo { |
| 32 | - /** @var IMountPoint */ |
|
| 33 | - private $mount; |
|
| 32 | + /** @var IMountPoint */ |
|
| 33 | + private $mount; |
|
| 34 | 34 | |
| 35 | - /** |
|
| 36 | - * CachedMountInfo constructor. |
|
| 37 | - * |
|
| 38 | - * @param IUser $user |
|
| 39 | - * @param IMountPoint $mount |
|
| 40 | - */ |
|
| 41 | - public function __construct(IUser $user, IMountPoint $mount) { |
|
| 42 | - $this->user = $user; |
|
| 43 | - $this->mount = $mount; |
|
| 44 | - } |
|
| 35 | + /** |
|
| 36 | + * CachedMountInfo constructor. |
|
| 37 | + * |
|
| 38 | + * @param IUser $user |
|
| 39 | + * @param IMountPoint $mount |
|
| 40 | + */ |
|
| 41 | + public function __construct(IUser $user, IMountPoint $mount) { |
|
| 42 | + $this->user = $user; |
|
| 43 | + $this->mount = $mount; |
|
| 44 | + } |
|
| 45 | 45 | |
| 46 | - /** |
|
| 47 | - * @return int the numeric storage id of the mount |
|
| 48 | - */ |
|
| 49 | - public function getStorageId() { |
|
| 50 | - if (!$this->storageId) { |
|
| 51 | - $this->storageId = $this->mount->getNumericStorageId(); |
|
| 52 | - } |
|
| 53 | - return parent::getStorageId(); |
|
| 54 | - } |
|
| 46 | + /** |
|
| 47 | + * @return int the numeric storage id of the mount |
|
| 48 | + */ |
|
| 49 | + public function getStorageId() { |
|
| 50 | + if (!$this->storageId) { |
|
| 51 | + $this->storageId = $this->mount->getNumericStorageId(); |
|
| 52 | + } |
|
| 53 | + return parent::getStorageId(); |
|
| 54 | + } |
|
| 55 | 55 | |
| 56 | - /** |
|
| 57 | - * @return int the fileid of the root of the mount |
|
| 58 | - */ |
|
| 59 | - public function getRootId() { |
|
| 60 | - if (!$this->rootId) { |
|
| 61 | - $this->rootId = $this->mount->getStorageRootId(); |
|
| 62 | - } |
|
| 63 | - return parent::getRootId(); |
|
| 64 | - } |
|
| 56 | + /** |
|
| 57 | + * @return int the fileid of the root of the mount |
|
| 58 | + */ |
|
| 59 | + public function getRootId() { |
|
| 60 | + if (!$this->rootId) { |
|
| 61 | + $this->rootId = $this->mount->getStorageRootId(); |
|
| 62 | + } |
|
| 63 | + return parent::getRootId(); |
|
| 64 | + } |
|
| 65 | 65 | |
| 66 | - /** |
|
| 67 | - * @return string the mount point of the mount for the user |
|
| 68 | - */ |
|
| 69 | - public function getMountPoint() { |
|
| 70 | - if (!$this->mountPoint) { |
|
| 71 | - $this->mountPoint = $this->mount->getMountPoint(); |
|
| 72 | - } |
|
| 73 | - return parent::getMountPoint(); |
|
| 74 | - } |
|
| 66 | + /** |
|
| 67 | + * @return string the mount point of the mount for the user |
|
| 68 | + */ |
|
| 69 | + public function getMountPoint() { |
|
| 70 | + if (!$this->mountPoint) { |
|
| 71 | + $this->mountPoint = $this->mount->getMountPoint(); |
|
| 72 | + } |
|
| 73 | + return parent::getMountPoint(); |
|
| 74 | + } |
|
| 75 | 75 | |
| 76 | - public function getMountId() { |
|
| 77 | - return $this->mount->getMountId(); |
|
| 78 | - } |
|
| 76 | + public function getMountId() { |
|
| 77 | + return $this->mount->getMountId(); |
|
| 78 | + } |
|
| 79 | 79 | |
| 80 | - /** |
|
| 81 | - * Get the internal path (within the storage) of the root of the mount |
|
| 82 | - * |
|
| 83 | - * @return string |
|
| 84 | - */ |
|
| 85 | - public function getRootInternalPath() { |
|
| 86 | - return $this->mount->getInternalPath($this->mount->getMountPoint()); |
|
| 87 | - } |
|
| 80 | + /** |
|
| 81 | + * Get the internal path (within the storage) of the root of the mount |
|
| 82 | + * |
|
| 83 | + * @return string |
|
| 84 | + */ |
|
| 85 | + public function getRootInternalPath() { |
|
| 86 | + return $this->mount->getInternalPath($this->mount->getMountPoint()); |
|
| 87 | + } |
|
| 88 | 88 | } |
@@ -29,21 +29,21 @@ |
||
| 29 | 29 | * Listen to hooks and update the mount cache as needed |
| 30 | 30 | */ |
| 31 | 31 | class UserMountCacheListener { |
| 32 | - /** |
|
| 33 | - * @var IUserMountCache |
|
| 34 | - */ |
|
| 35 | - private $userMountCache; |
|
| 32 | + /** |
|
| 33 | + * @var IUserMountCache |
|
| 34 | + */ |
|
| 35 | + private $userMountCache; |
|
| 36 | 36 | |
| 37 | - /** |
|
| 38 | - * UserMountCacheListener constructor. |
|
| 39 | - * |
|
| 40 | - * @param IUserMountCache $userMountCache |
|
| 41 | - */ |
|
| 42 | - public function __construct(IUserMountCache $userMountCache) { |
|
| 43 | - $this->userMountCache = $userMountCache; |
|
| 44 | - } |
|
| 37 | + /** |
|
| 38 | + * UserMountCacheListener constructor. |
|
| 39 | + * |
|
| 40 | + * @param IUserMountCache $userMountCache |
|
| 41 | + */ |
|
| 42 | + public function __construct(IUserMountCache $userMountCache) { |
|
| 43 | + $this->userMountCache = $userMountCache; |
|
| 44 | + } |
|
| 45 | 45 | |
| 46 | - public function listen(Manager $manager) { |
|
| 47 | - $manager->listen('\OC\User', 'postDelete', [$this->userMountCache, 'removeUserMounts']); |
|
| 48 | - } |
|
| 46 | + public function listen(Manager $manager) { |
|
| 47 | + $manager->listen('\OC\User', 'postDelete', [$this->userMountCache, 'removeUserMounts']); |
|
| 48 | + } |
|
| 49 | 49 | } |
@@ -28,114 +28,114 @@ |
||
| 28 | 28 | use OCP\IUser; |
| 29 | 29 | |
| 30 | 30 | class CachedMountInfo implements ICachedMountInfo { |
| 31 | - /** |
|
| 32 | - * @var IUser |
|
| 33 | - */ |
|
| 34 | - protected $user; |
|
| 35 | - |
|
| 36 | - /** |
|
| 37 | - * @var int |
|
| 38 | - */ |
|
| 39 | - protected $storageId; |
|
| 40 | - |
|
| 41 | - /** |
|
| 42 | - * @var int |
|
| 43 | - */ |
|
| 44 | - protected $rootId; |
|
| 45 | - |
|
| 46 | - /** |
|
| 47 | - * @var string |
|
| 48 | - */ |
|
| 49 | - protected $mountPoint; |
|
| 50 | - |
|
| 51 | - /** |
|
| 52 | - * @var int|null |
|
| 53 | - */ |
|
| 54 | - protected $mountId; |
|
| 55 | - |
|
| 56 | - /** |
|
| 57 | - * @var string |
|
| 58 | - */ |
|
| 59 | - protected $rootInternalPath; |
|
| 60 | - |
|
| 61 | - /** |
|
| 62 | - * CachedMountInfo constructor. |
|
| 63 | - * |
|
| 64 | - * @param IUser $user |
|
| 65 | - * @param int $storageId |
|
| 66 | - * @param int $rootId |
|
| 67 | - * @param string $mountPoint |
|
| 68 | - * @param int|null $mountId |
|
| 69 | - * @param string $rootInternalPath |
|
| 70 | - */ |
|
| 71 | - public function __construct(IUser $user, $storageId, $rootId, $mountPoint, $mountId = null, $rootInternalPath = '') { |
|
| 72 | - $this->user = $user; |
|
| 73 | - $this->storageId = $storageId; |
|
| 74 | - $this->rootId = $rootId; |
|
| 75 | - $this->mountPoint = $mountPoint; |
|
| 76 | - $this->mountId = $mountId; |
|
| 77 | - $this->rootInternalPath = $rootInternalPath; |
|
| 78 | - } |
|
| 79 | - |
|
| 80 | - /** |
|
| 81 | - * @return IUser |
|
| 82 | - */ |
|
| 83 | - public function getUser() { |
|
| 84 | - return $this->user; |
|
| 85 | - } |
|
| 86 | - |
|
| 87 | - /** |
|
| 88 | - * @return int the numeric storage id of the mount |
|
| 89 | - */ |
|
| 90 | - public function getStorageId() { |
|
| 91 | - return $this->storageId; |
|
| 92 | - } |
|
| 93 | - |
|
| 94 | - /** |
|
| 95 | - * @return int the fileid of the root of the mount |
|
| 96 | - */ |
|
| 97 | - public function getRootId() { |
|
| 98 | - return $this->rootId; |
|
| 99 | - } |
|
| 100 | - |
|
| 101 | - /** |
|
| 102 | - * @return Node the root node of the mount |
|
| 103 | - */ |
|
| 104 | - public function getMountPointNode() { |
|
| 105 | - // TODO injection etc |
|
| 106 | - Filesystem::initMountPoints($this->getUser()->getUID()); |
|
| 107 | - $userNode = \OC::$server->getUserFolder($this->getUser()->getUID()); |
|
| 108 | - $nodes = $userNode->getParent()->getById($this->getRootId()); |
|
| 109 | - if (count($nodes) > 0) { |
|
| 110 | - return $nodes[0]; |
|
| 111 | - } else { |
|
| 112 | - return null; |
|
| 113 | - } |
|
| 114 | - } |
|
| 115 | - |
|
| 116 | - /** |
|
| 117 | - * @return string the mount point of the mount for the user |
|
| 118 | - */ |
|
| 119 | - public function getMountPoint() { |
|
| 120 | - return $this->mountPoint; |
|
| 121 | - } |
|
| 122 | - |
|
| 123 | - /** |
|
| 124 | - * Get the id of the configured mount |
|
| 125 | - * |
|
| 126 | - * @return int|null mount id or null if not applicable |
|
| 127 | - * @since 9.1.0 |
|
| 128 | - */ |
|
| 129 | - public function getMountId() { |
|
| 130 | - return $this->mountId; |
|
| 131 | - } |
|
| 132 | - |
|
| 133 | - /** |
|
| 134 | - * Get the internal path (within the storage) of the root of the mount |
|
| 135 | - * |
|
| 136 | - * @return string |
|
| 137 | - */ |
|
| 138 | - public function getRootInternalPath() { |
|
| 139 | - return $this->rootInternalPath; |
|
| 140 | - } |
|
| 31 | + /** |
|
| 32 | + * @var IUser |
|
| 33 | + */ |
|
| 34 | + protected $user; |
|
| 35 | + |
|
| 36 | + /** |
|
| 37 | + * @var int |
|
| 38 | + */ |
|
| 39 | + protected $storageId; |
|
| 40 | + |
|
| 41 | + /** |
|
| 42 | + * @var int |
|
| 43 | + */ |
|
| 44 | + protected $rootId; |
|
| 45 | + |
|
| 46 | + /** |
|
| 47 | + * @var string |
|
| 48 | + */ |
|
| 49 | + protected $mountPoint; |
|
| 50 | + |
|
| 51 | + /** |
|
| 52 | + * @var int|null |
|
| 53 | + */ |
|
| 54 | + protected $mountId; |
|
| 55 | + |
|
| 56 | + /** |
|
| 57 | + * @var string |
|
| 58 | + */ |
|
| 59 | + protected $rootInternalPath; |
|
| 60 | + |
|
| 61 | + /** |
|
| 62 | + * CachedMountInfo constructor. |
|
| 63 | + * |
|
| 64 | + * @param IUser $user |
|
| 65 | + * @param int $storageId |
|
| 66 | + * @param int $rootId |
|
| 67 | + * @param string $mountPoint |
|
| 68 | + * @param int|null $mountId |
|
| 69 | + * @param string $rootInternalPath |
|
| 70 | + */ |
|
| 71 | + public function __construct(IUser $user, $storageId, $rootId, $mountPoint, $mountId = null, $rootInternalPath = '') { |
|
| 72 | + $this->user = $user; |
|
| 73 | + $this->storageId = $storageId; |
|
| 74 | + $this->rootId = $rootId; |
|
| 75 | + $this->mountPoint = $mountPoint; |
|
| 76 | + $this->mountId = $mountId; |
|
| 77 | + $this->rootInternalPath = $rootInternalPath; |
|
| 78 | + } |
|
| 79 | + |
|
| 80 | + /** |
|
| 81 | + * @return IUser |
|
| 82 | + */ |
|
| 83 | + public function getUser() { |
|
| 84 | + return $this->user; |
|
| 85 | + } |
|
| 86 | + |
|
| 87 | + /** |
|
| 88 | + * @return int the numeric storage id of the mount |
|
| 89 | + */ |
|
| 90 | + public function getStorageId() { |
|
| 91 | + return $this->storageId; |
|
| 92 | + } |
|
| 93 | + |
|
| 94 | + /** |
|
| 95 | + * @return int the fileid of the root of the mount |
|
| 96 | + */ |
|
| 97 | + public function getRootId() { |
|
| 98 | + return $this->rootId; |
|
| 99 | + } |
|
| 100 | + |
|
| 101 | + /** |
|
| 102 | + * @return Node the root node of the mount |
|
| 103 | + */ |
|
| 104 | + public function getMountPointNode() { |
|
| 105 | + // TODO injection etc |
|
| 106 | + Filesystem::initMountPoints($this->getUser()->getUID()); |
|
| 107 | + $userNode = \OC::$server->getUserFolder($this->getUser()->getUID()); |
|
| 108 | + $nodes = $userNode->getParent()->getById($this->getRootId()); |
|
| 109 | + if (count($nodes) > 0) { |
|
| 110 | + return $nodes[0]; |
|
| 111 | + } else { |
|
| 112 | + return null; |
|
| 113 | + } |
|
| 114 | + } |
|
| 115 | + |
|
| 116 | + /** |
|
| 117 | + * @return string the mount point of the mount for the user |
|
| 118 | + */ |
|
| 119 | + public function getMountPoint() { |
|
| 120 | + return $this->mountPoint; |
|
| 121 | + } |
|
| 122 | + |
|
| 123 | + /** |
|
| 124 | + * Get the id of the configured mount |
|
| 125 | + * |
|
| 126 | + * @return int|null mount id or null if not applicable |
|
| 127 | + * @since 9.1.0 |
|
| 128 | + */ |
|
| 129 | + public function getMountId() { |
|
| 130 | + return $this->mountId; |
|
| 131 | + } |
|
| 132 | + |
|
| 133 | + /** |
|
| 134 | + * Get the internal path (within the storage) of the root of the mount |
|
| 135 | + * |
|
| 136 | + * @return string |
|
| 137 | + */ |
|
| 138 | + public function getRootInternalPath() { |
|
| 139 | + return $this->rootInternalPath; |
|
| 140 | + } |
|
| 141 | 141 | } |
@@ -28,42 +28,42 @@ |
||
| 28 | 28 | |
| 29 | 29 | class HomeObjectStoreStorage extends ObjectStoreStorage implements \OCP\Files\IHomeStorage { |
| 30 | 30 | |
| 31 | - /** |
|
| 32 | - * The home user storage requires a user object to create a unique storage id |
|
| 33 | - * @param array $params |
|
| 34 | - */ |
|
| 35 | - public function __construct($params) { |
|
| 36 | - if ( ! isset($params['user']) || ! $params['user'] instanceof User) { |
|
| 37 | - throw new \Exception('missing user object in parameters'); |
|
| 38 | - } |
|
| 39 | - $this->user = $params['user']; |
|
| 40 | - parent::__construct($params); |
|
| 41 | - } |
|
| 31 | + /** |
|
| 32 | + * The home user storage requires a user object to create a unique storage id |
|
| 33 | + * @param array $params |
|
| 34 | + */ |
|
| 35 | + public function __construct($params) { |
|
| 36 | + if ( ! isset($params['user']) || ! $params['user'] instanceof User) { |
|
| 37 | + throw new \Exception('missing user object in parameters'); |
|
| 38 | + } |
|
| 39 | + $this->user = $params['user']; |
|
| 40 | + parent::__construct($params); |
|
| 41 | + } |
|
| 42 | 42 | |
| 43 | - public function getId () { |
|
| 44 | - return 'object::user:' . $this->user->getUID(); |
|
| 45 | - } |
|
| 43 | + public function getId () { |
|
| 44 | + return 'object::user:' . $this->user->getUID(); |
|
| 45 | + } |
|
| 46 | 46 | |
| 47 | - /** |
|
| 48 | - * get the owner of a path |
|
| 49 | - * |
|
| 50 | - * @param string $path The path to get the owner |
|
| 51 | - * @return false|string uid |
|
| 52 | - */ |
|
| 53 | - public function getOwner($path) { |
|
| 54 | - if (is_object($this->user)) { |
|
| 55 | - return $this->user->getUID(); |
|
| 56 | - } |
|
| 57 | - return false; |
|
| 58 | - } |
|
| 47 | + /** |
|
| 48 | + * get the owner of a path |
|
| 49 | + * |
|
| 50 | + * @param string $path The path to get the owner |
|
| 51 | + * @return false|string uid |
|
| 52 | + */ |
|
| 53 | + public function getOwner($path) { |
|
| 54 | + if (is_object($this->user)) { |
|
| 55 | + return $this->user->getUID(); |
|
| 56 | + } |
|
| 57 | + return false; |
|
| 58 | + } |
|
| 59 | 59 | |
| 60 | - /** |
|
| 61 | - * @param string $path, optional |
|
| 62 | - * @return \OC\User\User |
|
| 63 | - */ |
|
| 64 | - public function getUser($path = null) { |
|
| 65 | - return $this->user; |
|
| 66 | - } |
|
| 60 | + /** |
|
| 61 | + * @param string $path, optional |
|
| 62 | + * @return \OC\User\User |
|
| 63 | + */ |
|
| 64 | + public function getUser($path = null) { |
|
| 65 | + return $this->user; |
|
| 66 | + } |
|
| 67 | 67 | |
| 68 | 68 | |
| 69 | 69 | } |
| 70 | 70 | \ No newline at end of file |
@@ -33,15 +33,15 @@ |
||
| 33 | 33 | * @param array $params |
| 34 | 34 | */ |
| 35 | 35 | public function __construct($params) { |
| 36 | - if ( ! isset($params['user']) || ! $params['user'] instanceof User) { |
|
| 36 | + if (!isset($params['user']) || !$params['user'] instanceof User) { |
|
| 37 | 37 | throw new \Exception('missing user object in parameters'); |
| 38 | 38 | } |
| 39 | 39 | $this->user = $params['user']; |
| 40 | 40 | parent::__construct($params); |
| 41 | 41 | } |
| 42 | 42 | |
| 43 | - public function getId () { |
|
| 44 | - return 'object::user:' . $this->user->getUID(); |
|
| 43 | + public function getId() { |
|
| 44 | + return 'object::user:'.$this->user->getUID(); |
|
| 45 | 45 | } |
| 46 | 46 | |
| 47 | 47 | /** |
@@ -29,52 +29,52 @@ |
||
| 29 | 29 | |
| 30 | 30 | class NoopScanner extends Scanner { |
| 31 | 31 | |
| 32 | - public function __construct(Storage $storage) { |
|
| 33 | - //we don't need the storage, so do nothing here |
|
| 34 | - } |
|
| 32 | + public function __construct(Storage $storage) { |
|
| 33 | + //we don't need the storage, so do nothing here |
|
| 34 | + } |
|
| 35 | 35 | |
| 36 | - /** |
|
| 37 | - * scan a single file and store it in the cache |
|
| 38 | - * |
|
| 39 | - * @param string $file |
|
| 40 | - * @param int $reuseExisting |
|
| 41 | - * @param int $parentId |
|
| 42 | - * @param array|null $cacheData existing data in the cache for the file to be scanned |
|
| 43 | - * @return array an array of metadata of the scanned file |
|
| 44 | - */ |
|
| 45 | - public function scanFile($file, $reuseExisting = 0, $parentId = -1, $cacheData = null, $lock = true) { |
|
| 46 | - return array(); |
|
| 47 | - } |
|
| 36 | + /** |
|
| 37 | + * scan a single file and store it in the cache |
|
| 38 | + * |
|
| 39 | + * @param string $file |
|
| 40 | + * @param int $reuseExisting |
|
| 41 | + * @param int $parentId |
|
| 42 | + * @param array|null $cacheData existing data in the cache for the file to be scanned |
|
| 43 | + * @return array an array of metadata of the scanned file |
|
| 44 | + */ |
|
| 45 | + public function scanFile($file, $reuseExisting = 0, $parentId = -1, $cacheData = null, $lock = true) { |
|
| 46 | + return array(); |
|
| 47 | + } |
|
| 48 | 48 | |
| 49 | - /** |
|
| 50 | - * scan a folder and all it's children |
|
| 51 | - * |
|
| 52 | - * @param string $path |
|
| 53 | - * @param bool $recursive |
|
| 54 | - * @param int $reuse |
|
| 55 | - * @return array with the meta data of the scanned file or folder |
|
| 56 | - */ |
|
| 57 | - public function scan($path, $recursive = self::SCAN_RECURSIVE, $reuse = -1, $lock = true) { |
|
| 58 | - return array(); |
|
| 59 | - } |
|
| 49 | + /** |
|
| 50 | + * scan a folder and all it's children |
|
| 51 | + * |
|
| 52 | + * @param string $path |
|
| 53 | + * @param bool $recursive |
|
| 54 | + * @param int $reuse |
|
| 55 | + * @return array with the meta data of the scanned file or folder |
|
| 56 | + */ |
|
| 57 | + public function scan($path, $recursive = self::SCAN_RECURSIVE, $reuse = -1, $lock = true) { |
|
| 58 | + return array(); |
|
| 59 | + } |
|
| 60 | 60 | |
| 61 | - /** |
|
| 62 | - * scan all the files and folders in a folder |
|
| 63 | - * |
|
| 64 | - * @param string $path |
|
| 65 | - * @param bool $recursive |
|
| 66 | - * @param int $reuse |
|
| 67 | - * @param array $folderData existing cache data for the folder to be scanned |
|
| 68 | - * @return int the size of the scanned folder or -1 if the size is unknown at this stage |
|
| 69 | - */ |
|
| 70 | - protected function scanChildren($path, $recursive = self::SCAN_RECURSIVE, $reuse = -1, $folderData = null, $lock = true) { |
|
| 71 | - return 0; |
|
| 72 | - } |
|
| 61 | + /** |
|
| 62 | + * scan all the files and folders in a folder |
|
| 63 | + * |
|
| 64 | + * @param string $path |
|
| 65 | + * @param bool $recursive |
|
| 66 | + * @param int $reuse |
|
| 67 | + * @param array $folderData existing cache data for the folder to be scanned |
|
| 68 | + * @return int the size of the scanned folder or -1 if the size is unknown at this stage |
|
| 69 | + */ |
|
| 70 | + protected function scanChildren($path, $recursive = self::SCAN_RECURSIVE, $reuse = -1, $folderData = null, $lock = true) { |
|
| 71 | + return 0; |
|
| 72 | + } |
|
| 73 | 73 | |
| 74 | - /** |
|
| 75 | - * walk over any folders that are not fully scanned yet and scan them |
|
| 76 | - */ |
|
| 77 | - public function backgroundScan() { |
|
| 78 | - //noop |
|
| 79 | - } |
|
| 74 | + /** |
|
| 75 | + * walk over any folders that are not fully scanned yet and scan them |
|
| 76 | + */ |
|
| 77 | + public function backgroundScan() { |
|
| 78 | + //noop |
|
| 79 | + } |
|
| 80 | 80 | } |
@@ -31,25 +31,25 @@ |
||
| 31 | 31 | * Map a user to a bucket. |
| 32 | 32 | */ |
| 33 | 33 | class Mapper { |
| 34 | - /** @var IUser */ |
|
| 35 | - private $user; |
|
| 34 | + /** @var IUser */ |
|
| 35 | + private $user; |
|
| 36 | 36 | |
| 37 | - /** |
|
| 38 | - * Mapper constructor. |
|
| 39 | - * |
|
| 40 | - * @param IUser $user |
|
| 41 | - */ |
|
| 42 | - public function __construct(IUser $user) { |
|
| 43 | - $this->user = $user; |
|
| 44 | - } |
|
| 37 | + /** |
|
| 38 | + * Mapper constructor. |
|
| 39 | + * |
|
| 40 | + * @param IUser $user |
|
| 41 | + */ |
|
| 42 | + public function __construct(IUser $user) { |
|
| 43 | + $this->user = $user; |
|
| 44 | + } |
|
| 45 | 45 | |
| 46 | - /** |
|
| 47 | - * @param int $numBuckets |
|
| 48 | - * @return string |
|
| 49 | - */ |
|
| 50 | - public function getBucket($numBuckets = 64) { |
|
| 51 | - $hash = md5($this->user->getUID()); |
|
| 52 | - $num = hexdec(substr($hash, 0, 4)); |
|
| 53 | - return (string)($num % $numBuckets); |
|
| 54 | - } |
|
| 46 | + /** |
|
| 47 | + * @param int $numBuckets |
|
| 48 | + * @return string |
|
| 49 | + */ |
|
| 50 | + public function getBucket($numBuckets = 64) { |
|
| 51 | + $hash = md5($this->user->getUID()); |
|
| 52 | + $num = hexdec(substr($hash, 0, 4)); |
|
| 53 | + return (string)($num % $numBuckets); |
|
| 54 | + } |
|
| 55 | 55 | } |
@@ -50,6 +50,6 @@ |
||
| 50 | 50 | public function getBucket($numBuckets = 64) { |
| 51 | 51 | $hash = md5($this->user->getUID()); |
| 52 | 52 | $num = hexdec(substr($hash, 0, 4)); |
| 53 | - return (string)($num % $numBuckets); |
|
| 53 | + return (string) ($num % $numBuckets); |
|
| 54 | 54 | } |
| 55 | 55 | } |