@@ -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 | } |
@@ -25,38 +25,38 @@ |
||
25 | 25 | namespace OC\Files\Type; |
26 | 26 | |
27 | 27 | class TemplateManager { |
28 | - protected $templates = array(); |
|
28 | + protected $templates = array(); |
|
29 | 29 | |
30 | - public function registerTemplate($mimetype, $path) { |
|
31 | - $this->templates[$mimetype] = $path; |
|
32 | - } |
|
30 | + public function registerTemplate($mimetype, $path) { |
|
31 | + $this->templates[$mimetype] = $path; |
|
32 | + } |
|
33 | 33 | |
34 | - /** |
|
35 | - * get the path of the template for a mimetype |
|
36 | - * |
|
37 | - * @param string $mimetype |
|
38 | - * @return string|null |
|
39 | - */ |
|
40 | - public function getTemplatePath($mimetype) { |
|
41 | - if (isset($this->templates[$mimetype])) { |
|
42 | - return $this->templates[$mimetype]; |
|
43 | - } else { |
|
44 | - return null; |
|
45 | - } |
|
46 | - } |
|
34 | + /** |
|
35 | + * get the path of the template for a mimetype |
|
36 | + * |
|
37 | + * @param string $mimetype |
|
38 | + * @return string|null |
|
39 | + */ |
|
40 | + public function getTemplatePath($mimetype) { |
|
41 | + if (isset($this->templates[$mimetype])) { |
|
42 | + return $this->templates[$mimetype]; |
|
43 | + } else { |
|
44 | + return null; |
|
45 | + } |
|
46 | + } |
|
47 | 47 | |
48 | - /** |
|
49 | - * get the template content for a mimetype |
|
50 | - * |
|
51 | - * @param string $mimetype |
|
52 | - * @return string |
|
53 | - */ |
|
54 | - public function getTemplate($mimetype) { |
|
55 | - $path = $this->getTemplatePath($mimetype); |
|
56 | - if ($path) { |
|
57 | - return file_get_contents($path); |
|
58 | - } else { |
|
59 | - return ''; |
|
60 | - } |
|
61 | - } |
|
48 | + /** |
|
49 | + * get the template content for a mimetype |
|
50 | + * |
|
51 | + * @param string $mimetype |
|
52 | + * @return string |
|
53 | + */ |
|
54 | + public function getTemplate($mimetype) { |
|
55 | + $path = $this->getTemplatePath($mimetype); |
|
56 | + if ($path) { |
|
57 | + return file_get_contents($path); |
|
58 | + } else { |
|
59 | + return ''; |
|
60 | + } |
|
61 | + } |
|
62 | 62 | } |
@@ -26,7 +26,7 @@ |
||
26 | 26 | use OCP\Files\NotPermittedException; |
27 | 27 | use OCP\Files\SimpleFS\ISimpleFile; |
28 | 28 | |
29 | -class SimpleFile implements ISimpleFile { |
|
29 | +class SimpleFile implements ISimpleFile { |
|
30 | 30 | |
31 | 31 | /** @var File $file */ |
32 | 32 | private $file; |
@@ -29,153 +29,153 @@ |
||
29 | 29 | |
30 | 30 | class SimpleFile implements ISimpleFile { |
31 | 31 | |
32 | - /** @var File $file */ |
|
33 | - private $file; |
|
34 | - |
|
35 | - /** |
|
36 | - * File constructor. |
|
37 | - * |
|
38 | - * @param File $file |
|
39 | - */ |
|
40 | - public function __construct(File $file) { |
|
41 | - $this->file = $file; |
|
42 | - } |
|
43 | - |
|
44 | - /** |
|
45 | - * Get the name |
|
46 | - * |
|
47 | - * @return string |
|
48 | - */ |
|
49 | - public function getName() { |
|
50 | - return $this->file->getName(); |
|
51 | - } |
|
52 | - |
|
53 | - /** |
|
54 | - * Get the size in bytes |
|
55 | - * |
|
56 | - * @return int |
|
57 | - */ |
|
58 | - public function getSize() { |
|
59 | - return $this->file->getSize(); |
|
60 | - } |
|
61 | - |
|
62 | - /** |
|
63 | - * Get the ETag |
|
64 | - * |
|
65 | - * @return string |
|
66 | - */ |
|
67 | - public function getETag() { |
|
68 | - return $this->file->getEtag(); |
|
69 | - } |
|
70 | - |
|
71 | - /** |
|
72 | - * Get the last modification time |
|
73 | - * |
|
74 | - * @return int |
|
75 | - */ |
|
76 | - public function getMTime() { |
|
77 | - return $this->file->getMTime(); |
|
78 | - } |
|
79 | - |
|
80 | - /** |
|
81 | - * Get the content |
|
82 | - * |
|
83 | - * @throws NotPermittedException |
|
84 | - * @throws NotFoundException |
|
85 | - * @return string |
|
86 | - */ |
|
87 | - public function getContent() { |
|
88 | - $result = $this->file->getContent(); |
|
89 | - |
|
90 | - if ($result === false) { |
|
91 | - $this->checkFile(); |
|
92 | - } |
|
93 | - |
|
94 | - return $result; |
|
95 | - } |
|
96 | - |
|
97 | - /** |
|
98 | - * Overwrite the file |
|
99 | - * |
|
100 | - * @param string|resource $data |
|
101 | - * @throws NotPermittedException |
|
102 | - * @throws NotFoundException |
|
103 | - */ |
|
104 | - public function putContent($data) { |
|
105 | - try { |
|
106 | - return $this->file->putContent($data); |
|
107 | - } catch (NotFoundException $e) { |
|
108 | - $this->checkFile(); |
|
109 | - } |
|
110 | - } |
|
111 | - |
|
112 | - /** |
|
113 | - * Sometimes there are some issues with the AppData. Most of them are from |
|
114 | - * user error. But we should handle them gracefull anyway. |
|
115 | - * |
|
116 | - * If for some reason the current file can't be found. We remove it. |
|
117 | - * Then traverse up and check all folders if they exists. This so that the |
|
118 | - * next request will have a valid appdata structure again. |
|
119 | - * |
|
120 | - * @throws NotFoundException |
|
121 | - */ |
|
122 | - private function checkFile() { |
|
123 | - $cur = $this->file; |
|
124 | - |
|
125 | - while ($cur->stat() === false) { |
|
126 | - $parent = $cur->getParent(); |
|
127 | - try { |
|
128 | - $cur->delete(); |
|
129 | - } catch (NotFoundException $e) { |
|
130 | - // Just continue then |
|
131 | - } |
|
132 | - $cur = $parent; |
|
133 | - } |
|
134 | - |
|
135 | - if ($cur !== $this->file) { |
|
136 | - throw new NotFoundException('File does not exist'); |
|
137 | - } |
|
138 | - } |
|
139 | - |
|
140 | - |
|
141 | - /** |
|
142 | - * Delete the file |
|
143 | - * |
|
144 | - * @throws NotPermittedException |
|
145 | - */ |
|
146 | - public function delete() { |
|
147 | - $this->file->delete(); |
|
148 | - } |
|
149 | - |
|
150 | - /** |
|
151 | - * Get the MimeType |
|
152 | - * |
|
153 | - * @return string |
|
154 | - */ |
|
155 | - public function getMimeType() { |
|
156 | - return $this->file->getMimeType(); |
|
157 | - } |
|
158 | - |
|
159 | - /** |
|
160 | - * Open the file as stream for reading, resulting resource can be operated as stream like the result from php's own fopen |
|
161 | - * |
|
162 | - * @return resource |
|
163 | - * @throws \OCP\Files\NotPermittedException |
|
164 | - * @since 14.0.0 |
|
165 | - */ |
|
166 | - public function read() { |
|
167 | - return $this->file->fopen('r'); |
|
168 | - } |
|
169 | - |
|
170 | - /** |
|
171 | - * Open the file as stream for writing, resulting resource can be operated as stream like the result from php's own fopen |
|
172 | - * |
|
173 | - * @return resource |
|
174 | - * @throws \OCP\Files\NotPermittedException |
|
175 | - * @since 14.0.0 |
|
176 | - */ |
|
177 | - public function write() { |
|
178 | - return $this->file->fopen('w'); |
|
179 | - } |
|
32 | + /** @var File $file */ |
|
33 | + private $file; |
|
34 | + |
|
35 | + /** |
|
36 | + * File constructor. |
|
37 | + * |
|
38 | + * @param File $file |
|
39 | + */ |
|
40 | + public function __construct(File $file) { |
|
41 | + $this->file = $file; |
|
42 | + } |
|
43 | + |
|
44 | + /** |
|
45 | + * Get the name |
|
46 | + * |
|
47 | + * @return string |
|
48 | + */ |
|
49 | + public function getName() { |
|
50 | + return $this->file->getName(); |
|
51 | + } |
|
52 | + |
|
53 | + /** |
|
54 | + * Get the size in bytes |
|
55 | + * |
|
56 | + * @return int |
|
57 | + */ |
|
58 | + public function getSize() { |
|
59 | + return $this->file->getSize(); |
|
60 | + } |
|
61 | + |
|
62 | + /** |
|
63 | + * Get the ETag |
|
64 | + * |
|
65 | + * @return string |
|
66 | + */ |
|
67 | + public function getETag() { |
|
68 | + return $this->file->getEtag(); |
|
69 | + } |
|
70 | + |
|
71 | + /** |
|
72 | + * Get the last modification time |
|
73 | + * |
|
74 | + * @return int |
|
75 | + */ |
|
76 | + public function getMTime() { |
|
77 | + return $this->file->getMTime(); |
|
78 | + } |
|
79 | + |
|
80 | + /** |
|
81 | + * Get the content |
|
82 | + * |
|
83 | + * @throws NotPermittedException |
|
84 | + * @throws NotFoundException |
|
85 | + * @return string |
|
86 | + */ |
|
87 | + public function getContent() { |
|
88 | + $result = $this->file->getContent(); |
|
89 | + |
|
90 | + if ($result === false) { |
|
91 | + $this->checkFile(); |
|
92 | + } |
|
93 | + |
|
94 | + return $result; |
|
95 | + } |
|
96 | + |
|
97 | + /** |
|
98 | + * Overwrite the file |
|
99 | + * |
|
100 | + * @param string|resource $data |
|
101 | + * @throws NotPermittedException |
|
102 | + * @throws NotFoundException |
|
103 | + */ |
|
104 | + public function putContent($data) { |
|
105 | + try { |
|
106 | + return $this->file->putContent($data); |
|
107 | + } catch (NotFoundException $e) { |
|
108 | + $this->checkFile(); |
|
109 | + } |
|
110 | + } |
|
111 | + |
|
112 | + /** |
|
113 | + * Sometimes there are some issues with the AppData. Most of them are from |
|
114 | + * user error. But we should handle them gracefull anyway. |
|
115 | + * |
|
116 | + * If for some reason the current file can't be found. We remove it. |
|
117 | + * Then traverse up and check all folders if they exists. This so that the |
|
118 | + * next request will have a valid appdata structure again. |
|
119 | + * |
|
120 | + * @throws NotFoundException |
|
121 | + */ |
|
122 | + private function checkFile() { |
|
123 | + $cur = $this->file; |
|
124 | + |
|
125 | + while ($cur->stat() === false) { |
|
126 | + $parent = $cur->getParent(); |
|
127 | + try { |
|
128 | + $cur->delete(); |
|
129 | + } catch (NotFoundException $e) { |
|
130 | + // Just continue then |
|
131 | + } |
|
132 | + $cur = $parent; |
|
133 | + } |
|
134 | + |
|
135 | + if ($cur !== $this->file) { |
|
136 | + throw new NotFoundException('File does not exist'); |
|
137 | + } |
|
138 | + } |
|
139 | + |
|
140 | + |
|
141 | + /** |
|
142 | + * Delete the file |
|
143 | + * |
|
144 | + * @throws NotPermittedException |
|
145 | + */ |
|
146 | + public function delete() { |
|
147 | + $this->file->delete(); |
|
148 | + } |
|
149 | + |
|
150 | + /** |
|
151 | + * Get the MimeType |
|
152 | + * |
|
153 | + * @return string |
|
154 | + */ |
|
155 | + public function getMimeType() { |
|
156 | + return $this->file->getMimeType(); |
|
157 | + } |
|
158 | + |
|
159 | + /** |
|
160 | + * Open the file as stream for reading, resulting resource can be operated as stream like the result from php's own fopen |
|
161 | + * |
|
162 | + * @return resource |
|
163 | + * @throws \OCP\Files\NotPermittedException |
|
164 | + * @since 14.0.0 |
|
165 | + */ |
|
166 | + public function read() { |
|
167 | + return $this->file->fopen('r'); |
|
168 | + } |
|
169 | + |
|
170 | + /** |
|
171 | + * Open the file as stream for writing, resulting resource can be operated as stream like the result from php's own fopen |
|
172 | + * |
|
173 | + * @return resource |
|
174 | + * @throws \OCP\Files\NotPermittedException |
|
175 | + * @since 14.0.0 |
|
176 | + */ |
|
177 | + public function write() { |
|
178 | + return $this->file->fopen('w'); |
|
179 | + } |
|
180 | 180 | |
181 | 181 | } |