@@ -31,390 +31,390 @@ |
||
| 31 | 31 | use OCP\Files\ObjectStore\IObjectStore; |
| 32 | 32 | |
| 33 | 33 | class ObjectStoreStorage extends \OC\Files\Storage\Common { |
| 34 | - /** |
|
| 35 | - * @var \OCP\Files\ObjectStore\IObjectStore $objectStore |
|
| 36 | - */ |
|
| 37 | - protected $objectStore; |
|
| 38 | - /** |
|
| 39 | - * @var string $id |
|
| 40 | - */ |
|
| 41 | - protected $id; |
|
| 42 | - /** |
|
| 43 | - * @var \OC\User\User $user |
|
| 44 | - */ |
|
| 45 | - protected $user; |
|
| 46 | - |
|
| 47 | - private $objectPrefix = 'urn:oid:'; |
|
| 48 | - |
|
| 49 | - private $logger; |
|
| 50 | - |
|
| 51 | - public function __construct($params) { |
|
| 52 | - if (isset($params['objectstore']) && $params['objectstore'] instanceof IObjectStore) { |
|
| 53 | - $this->objectStore = $params['objectstore']; |
|
| 54 | - } else { |
|
| 55 | - throw new \Exception('missing IObjectStore instance'); |
|
| 56 | - } |
|
| 57 | - if (isset($params['storageid'])) { |
|
| 58 | - $this->id = 'object::store:' . $params['storageid']; |
|
| 59 | - } else { |
|
| 60 | - $this->id = 'object::store:' . $this->objectStore->getStorageId(); |
|
| 61 | - } |
|
| 62 | - if (isset($params['objectPrefix'])) { |
|
| 63 | - $this->objectPrefix = $params['objectPrefix']; |
|
| 64 | - } |
|
| 65 | - //initialize cache with root directory in cache |
|
| 66 | - if (!$this->is_dir('/')) { |
|
| 67 | - $this->mkdir('/'); |
|
| 68 | - } |
|
| 69 | - |
|
| 70 | - $this->logger = \OC::$server->getLogger(); |
|
| 71 | - } |
|
| 72 | - |
|
| 73 | - public function mkdir($path) { |
|
| 74 | - $path = $this->normalizePath($path); |
|
| 75 | - |
|
| 76 | - if ($this->file_exists($path)) { |
|
| 77 | - return false; |
|
| 78 | - } |
|
| 79 | - |
|
| 80 | - $mTime = time(); |
|
| 81 | - $data = [ |
|
| 82 | - 'mimetype' => 'httpd/unix-directory', |
|
| 83 | - 'size' => 0, |
|
| 84 | - 'mtime' => $mTime, |
|
| 85 | - 'storage_mtime' => $mTime, |
|
| 86 | - 'permissions' => \OCP\Constants::PERMISSION_ALL, |
|
| 87 | - ]; |
|
| 88 | - if ($path === '') { |
|
| 89 | - //create root on the fly |
|
| 90 | - $data['etag'] = $this->getETag(''); |
|
| 91 | - $this->getCache()->put('', $data); |
|
| 92 | - return true; |
|
| 93 | - } else { |
|
| 94 | - // if parent does not exist, create it |
|
| 95 | - $parent = $this->normalizePath(dirname($path)); |
|
| 96 | - $parentType = $this->filetype($parent); |
|
| 97 | - if ($parentType === false) { |
|
| 98 | - if (!$this->mkdir($parent)) { |
|
| 99 | - // something went wrong |
|
| 100 | - return false; |
|
| 101 | - } |
|
| 102 | - } else if ($parentType === 'file') { |
|
| 103 | - // parent is a file |
|
| 104 | - return false; |
|
| 105 | - } |
|
| 106 | - // finally create the new dir |
|
| 107 | - $mTime = time(); // update mtime |
|
| 108 | - $data['mtime'] = $mTime; |
|
| 109 | - $data['storage_mtime'] = $mTime; |
|
| 110 | - $data['etag'] = $this->getETag($path); |
|
| 111 | - $this->getCache()->put($path, $data); |
|
| 112 | - return true; |
|
| 113 | - } |
|
| 114 | - } |
|
| 115 | - |
|
| 116 | - /** |
|
| 117 | - * @param string $path |
|
| 118 | - * @return string |
|
| 119 | - */ |
|
| 120 | - private function normalizePath($path) { |
|
| 121 | - $path = trim($path, '/'); |
|
| 122 | - //FIXME why do we sometimes get a path like 'files//username'? |
|
| 123 | - $path = str_replace('//', '/', $path); |
|
| 124 | - |
|
| 125 | - // dirname('/folder') returns '.' but internally (in the cache) we store the root as '' |
|
| 126 | - if (!$path || $path === '.') { |
|
| 127 | - $path = ''; |
|
| 128 | - } |
|
| 129 | - |
|
| 130 | - return $path; |
|
| 131 | - } |
|
| 132 | - |
|
| 133 | - /** |
|
| 134 | - * Object Stores use a NoopScanner because metadata is directly stored in |
|
| 135 | - * the file cache and cannot really scan the filesystem. The storage passed in is not used anywhere. |
|
| 136 | - * |
|
| 137 | - * @param string $path |
|
| 138 | - * @param \OC\Files\Storage\Storage (optional) the storage to pass to the scanner |
|
| 139 | - * @return \OC\Files\ObjectStore\NoopScanner |
|
| 140 | - */ |
|
| 141 | - public function getScanner($path = '', $storage = null) { |
|
| 142 | - if (!$storage) { |
|
| 143 | - $storage = $this; |
|
| 144 | - } |
|
| 145 | - if (!isset($this->scanner)) { |
|
| 146 | - $this->scanner = new NoopScanner($storage); |
|
| 147 | - } |
|
| 148 | - return $this->scanner; |
|
| 149 | - } |
|
| 150 | - |
|
| 151 | - public function getId() { |
|
| 152 | - return $this->id; |
|
| 153 | - } |
|
| 154 | - |
|
| 155 | - public function rmdir($path) { |
|
| 156 | - $path = $this->normalizePath($path); |
|
| 157 | - |
|
| 158 | - if (!$this->is_dir($path)) { |
|
| 159 | - return false; |
|
| 160 | - } |
|
| 161 | - |
|
| 162 | - $this->rmObjects($path); |
|
| 163 | - |
|
| 164 | - $this->getCache()->remove($path); |
|
| 165 | - |
|
| 166 | - return true; |
|
| 167 | - } |
|
| 168 | - |
|
| 169 | - private function rmObjects($path) { |
|
| 170 | - $children = $this->getCache()->getFolderContents($path); |
|
| 171 | - foreach ($children as $child) { |
|
| 172 | - if ($child['mimetype'] === 'httpd/unix-directory') { |
|
| 173 | - $this->rmObjects($child['path']); |
|
| 174 | - } else { |
|
| 175 | - $this->unlink($child['path']); |
|
| 176 | - } |
|
| 177 | - } |
|
| 178 | - } |
|
| 179 | - |
|
| 180 | - public function unlink($path) { |
|
| 181 | - $path = $this->normalizePath($path); |
|
| 182 | - $stat = $this->stat($path); |
|
| 183 | - |
|
| 184 | - if ($stat && isset($stat['fileid'])) { |
|
| 185 | - if ($stat['mimetype'] === 'httpd/unix-directory') { |
|
| 186 | - return $this->rmdir($path); |
|
| 187 | - } |
|
| 188 | - try { |
|
| 189 | - $this->objectStore->deleteObject($this->getURN($stat['fileid'])); |
|
| 190 | - } catch (\Exception $ex) { |
|
| 191 | - if ($ex->getCode() !== 404) { |
|
| 192 | - $this->logger->logException($ex, [ |
|
| 193 | - 'app' => 'objectstore', |
|
| 194 | - 'message' => 'Could not delete object ' . $this->getURN($stat['fileid']) . ' for ' . $path, |
|
| 195 | - ]); |
|
| 196 | - return false; |
|
| 197 | - } else { |
|
| 198 | - //removing from cache is ok as it does not exist in the objectstore anyway |
|
| 199 | - } |
|
| 200 | - } |
|
| 201 | - $this->getCache()->remove($path); |
|
| 202 | - return true; |
|
| 203 | - } |
|
| 204 | - return false; |
|
| 205 | - } |
|
| 206 | - |
|
| 207 | - public function stat($path) { |
|
| 208 | - $path = $this->normalizePath($path); |
|
| 209 | - $cacheEntry = $this->getCache()->get($path); |
|
| 210 | - if ($cacheEntry instanceof CacheEntry) { |
|
| 211 | - return $cacheEntry->getData(); |
|
| 212 | - } else { |
|
| 213 | - return false; |
|
| 214 | - } |
|
| 215 | - } |
|
| 216 | - |
|
| 217 | - /** |
|
| 218 | - * Override this method if you need a different unique resource identifier for your object storage implementation. |
|
| 219 | - * The default implementations just appends the fileId to 'urn:oid:'. Make sure the URN is unique over all users. |
|
| 220 | - * You may need a mapping table to store your URN if it cannot be generated from the fileid. |
|
| 221 | - * |
|
| 222 | - * @param int $fileId the fileid |
|
| 223 | - * @return null|string the unified resource name used to identify the object |
|
| 224 | - */ |
|
| 225 | - protected function getURN($fileId) { |
|
| 226 | - if (is_numeric($fileId)) { |
|
| 227 | - return $this->objectPrefix . $fileId; |
|
| 228 | - } |
|
| 229 | - return null; |
|
| 230 | - } |
|
| 231 | - |
|
| 232 | - public function opendir($path) { |
|
| 233 | - $path = $this->normalizePath($path); |
|
| 234 | - |
|
| 235 | - try { |
|
| 236 | - $files = array(); |
|
| 237 | - $folderContents = $this->getCache()->getFolderContents($path); |
|
| 238 | - foreach ($folderContents as $file) { |
|
| 239 | - $files[] = $file['name']; |
|
| 240 | - } |
|
| 241 | - |
|
| 242 | - return IteratorDirectory::wrap($files); |
|
| 243 | - } catch (\Exception $e) { |
|
| 244 | - $this->logger->logException($e); |
|
| 245 | - return false; |
|
| 246 | - } |
|
| 247 | - } |
|
| 248 | - |
|
| 249 | - public function filetype($path) { |
|
| 250 | - $path = $this->normalizePath($path); |
|
| 251 | - $stat = $this->stat($path); |
|
| 252 | - if ($stat) { |
|
| 253 | - if ($stat['mimetype'] === 'httpd/unix-directory') { |
|
| 254 | - return 'dir'; |
|
| 255 | - } |
|
| 256 | - return 'file'; |
|
| 257 | - } else { |
|
| 258 | - return false; |
|
| 259 | - } |
|
| 260 | - } |
|
| 261 | - |
|
| 262 | - public function fopen($path, $mode) { |
|
| 263 | - $path = $this->normalizePath($path); |
|
| 264 | - |
|
| 265 | - switch ($mode) { |
|
| 266 | - case 'r': |
|
| 267 | - case 'rb': |
|
| 268 | - $stat = $this->stat($path); |
|
| 269 | - if (is_array($stat)) { |
|
| 270 | - try { |
|
| 271 | - return $this->objectStore->readObject($this->getURN($stat['fileid'])); |
|
| 272 | - } catch (\Exception $ex) { |
|
| 273 | - $this->logger->logException($ex, [ |
|
| 274 | - 'app' => 'objectstore', |
|
| 275 | - 'message' => 'Count not get object ' . $this->getURN($stat['fileid']) . ' for file ' . $path, |
|
| 276 | - ]); |
|
| 277 | - return false; |
|
| 278 | - } |
|
| 279 | - } else { |
|
| 280 | - return false; |
|
| 281 | - } |
|
| 282 | - case 'w': |
|
| 283 | - case 'wb': |
|
| 284 | - case 'a': |
|
| 285 | - case 'ab': |
|
| 286 | - case 'r+': |
|
| 287 | - case 'w+': |
|
| 288 | - case 'wb+': |
|
| 289 | - case 'a+': |
|
| 290 | - case 'x': |
|
| 291 | - case 'x+': |
|
| 292 | - case 'c': |
|
| 293 | - case 'c+': |
|
| 294 | - if (strrpos($path, '.') !== false) { |
|
| 295 | - $ext = substr($path, strrpos($path, '.')); |
|
| 296 | - } else { |
|
| 297 | - $ext = ''; |
|
| 298 | - } |
|
| 299 | - $tmpFile = \OC::$server->getTempManager()->getTemporaryFile($ext); |
|
| 300 | - if ($this->file_exists($path)) { |
|
| 301 | - $source = $this->fopen($path, 'r'); |
|
| 302 | - file_put_contents($tmpFile, $source); |
|
| 303 | - } |
|
| 304 | - $handle = fopen($tmpFile, $mode); |
|
| 305 | - return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
| 306 | - $this->writeBack($tmpFile, $path); |
|
| 307 | - }); |
|
| 308 | - } |
|
| 309 | - return false; |
|
| 310 | - } |
|
| 311 | - |
|
| 312 | - public function file_exists($path) { |
|
| 313 | - $path = $this->normalizePath($path); |
|
| 314 | - return (bool)$this->stat($path); |
|
| 315 | - } |
|
| 316 | - |
|
| 317 | - public function rename($source, $target) { |
|
| 318 | - $source = $this->normalizePath($source); |
|
| 319 | - $target = $this->normalizePath($target); |
|
| 320 | - $this->remove($target); |
|
| 321 | - $this->getCache()->move($source, $target); |
|
| 322 | - $this->touch(dirname($target)); |
|
| 323 | - return true; |
|
| 324 | - } |
|
| 325 | - |
|
| 326 | - public function getMimeType($path) { |
|
| 327 | - $path = $this->normalizePath($path); |
|
| 328 | - $stat = $this->stat($path); |
|
| 329 | - if (is_array($stat)) { |
|
| 330 | - return $stat['mimetype']; |
|
| 331 | - } else { |
|
| 332 | - return false; |
|
| 333 | - } |
|
| 334 | - } |
|
| 335 | - |
|
| 336 | - public function touch($path, $mtime = null) { |
|
| 337 | - if (is_null($mtime)) { |
|
| 338 | - $mtime = time(); |
|
| 339 | - } |
|
| 340 | - |
|
| 341 | - $path = $this->normalizePath($path); |
|
| 342 | - $dirName = dirname($path); |
|
| 343 | - $parentExists = $this->is_dir($dirName); |
|
| 344 | - if (!$parentExists) { |
|
| 345 | - return false; |
|
| 346 | - } |
|
| 347 | - |
|
| 348 | - $stat = $this->stat($path); |
|
| 349 | - if (is_array($stat)) { |
|
| 350 | - // update existing mtime in db |
|
| 351 | - $stat['mtime'] = $mtime; |
|
| 352 | - $this->getCache()->update($stat['fileid'], $stat); |
|
| 353 | - } else { |
|
| 354 | - $mimeType = \OC::$server->getMimeTypeDetector()->detectPath($path); |
|
| 355 | - // create new file |
|
| 356 | - $stat = array( |
|
| 357 | - 'etag' => $this->getETag($path), |
|
| 358 | - 'mimetype' => $mimeType, |
|
| 359 | - 'size' => 0, |
|
| 360 | - 'mtime' => $mtime, |
|
| 361 | - 'storage_mtime' => $mtime, |
|
| 362 | - 'permissions' => \OCP\Constants::PERMISSION_ALL - \OCP\Constants::PERMISSION_CREATE, |
|
| 363 | - ); |
|
| 364 | - $fileId = $this->getCache()->put($path, $stat); |
|
| 365 | - try { |
|
| 366 | - //read an empty file from memory |
|
| 367 | - $this->objectStore->writeObject($this->getURN($fileId), fopen('php://memory', 'r')); |
|
| 368 | - } catch (\Exception $ex) { |
|
| 369 | - $this->getCache()->remove($path); |
|
| 370 | - $this->logger->logException($ex, [ |
|
| 371 | - 'app' => 'objectstore', |
|
| 372 | - 'message' => 'Could not create object ' . $this->getURN($fileId) . ' for ' . $path, |
|
| 373 | - ]); |
|
| 374 | - return false; |
|
| 375 | - } |
|
| 376 | - } |
|
| 377 | - return true; |
|
| 378 | - } |
|
| 379 | - |
|
| 380 | - public function writeBack($tmpFile, $path) { |
|
| 381 | - $stat = $this->stat($path); |
|
| 382 | - if (empty($stat)) { |
|
| 383 | - // create new file |
|
| 384 | - $stat = array( |
|
| 385 | - 'permissions' => \OCP\Constants::PERMISSION_ALL - \OCP\Constants::PERMISSION_CREATE, |
|
| 386 | - ); |
|
| 387 | - } |
|
| 388 | - // update stat with new data |
|
| 389 | - $mTime = time(); |
|
| 390 | - $stat['size'] = filesize($tmpFile); |
|
| 391 | - $stat['mtime'] = $mTime; |
|
| 392 | - $stat['storage_mtime'] = $mTime; |
|
| 393 | - $stat['mimetype'] = \OC::$server->getMimeTypeDetector()->detect($tmpFile); |
|
| 394 | - $stat['etag'] = $this->getETag($path); |
|
| 395 | - |
|
| 396 | - $fileId = $this->getCache()->put($path, $stat); |
|
| 397 | - try { |
|
| 398 | - //upload to object storage |
|
| 399 | - $this->objectStore->writeObject($this->getURN($fileId), fopen($tmpFile, 'r')); |
|
| 400 | - } catch (\Exception $ex) { |
|
| 401 | - $this->getCache()->remove($path); |
|
| 402 | - $this->logger->logException($ex, [ |
|
| 403 | - 'app' => 'objectstore', |
|
| 404 | - 'message' => 'Could not create object ' . $this->getURN($fileId) . ' for ' . $path, |
|
| 405 | - ]); |
|
| 406 | - throw $ex; // make this bubble up |
|
| 407 | - } |
|
| 408 | - } |
|
| 409 | - |
|
| 410 | - /** |
|
| 411 | - * external changes are not supported, exclusive access to the object storage is assumed |
|
| 412 | - * |
|
| 413 | - * @param string $path |
|
| 414 | - * @param int $time |
|
| 415 | - * @return false |
|
| 416 | - */ |
|
| 417 | - public function hasUpdated($path, $time) { |
|
| 418 | - return false; |
|
| 419 | - } |
|
| 34 | + /** |
|
| 35 | + * @var \OCP\Files\ObjectStore\IObjectStore $objectStore |
|
| 36 | + */ |
|
| 37 | + protected $objectStore; |
|
| 38 | + /** |
|
| 39 | + * @var string $id |
|
| 40 | + */ |
|
| 41 | + protected $id; |
|
| 42 | + /** |
|
| 43 | + * @var \OC\User\User $user |
|
| 44 | + */ |
|
| 45 | + protected $user; |
|
| 46 | + |
|
| 47 | + private $objectPrefix = 'urn:oid:'; |
|
| 48 | + |
|
| 49 | + private $logger; |
|
| 50 | + |
|
| 51 | + public function __construct($params) { |
|
| 52 | + if (isset($params['objectstore']) && $params['objectstore'] instanceof IObjectStore) { |
|
| 53 | + $this->objectStore = $params['objectstore']; |
|
| 54 | + } else { |
|
| 55 | + throw new \Exception('missing IObjectStore instance'); |
|
| 56 | + } |
|
| 57 | + if (isset($params['storageid'])) { |
|
| 58 | + $this->id = 'object::store:' . $params['storageid']; |
|
| 59 | + } else { |
|
| 60 | + $this->id = 'object::store:' . $this->objectStore->getStorageId(); |
|
| 61 | + } |
|
| 62 | + if (isset($params['objectPrefix'])) { |
|
| 63 | + $this->objectPrefix = $params['objectPrefix']; |
|
| 64 | + } |
|
| 65 | + //initialize cache with root directory in cache |
|
| 66 | + if (!$this->is_dir('/')) { |
|
| 67 | + $this->mkdir('/'); |
|
| 68 | + } |
|
| 69 | + |
|
| 70 | + $this->logger = \OC::$server->getLogger(); |
|
| 71 | + } |
|
| 72 | + |
|
| 73 | + public function mkdir($path) { |
|
| 74 | + $path = $this->normalizePath($path); |
|
| 75 | + |
|
| 76 | + if ($this->file_exists($path)) { |
|
| 77 | + return false; |
|
| 78 | + } |
|
| 79 | + |
|
| 80 | + $mTime = time(); |
|
| 81 | + $data = [ |
|
| 82 | + 'mimetype' => 'httpd/unix-directory', |
|
| 83 | + 'size' => 0, |
|
| 84 | + 'mtime' => $mTime, |
|
| 85 | + 'storage_mtime' => $mTime, |
|
| 86 | + 'permissions' => \OCP\Constants::PERMISSION_ALL, |
|
| 87 | + ]; |
|
| 88 | + if ($path === '') { |
|
| 89 | + //create root on the fly |
|
| 90 | + $data['etag'] = $this->getETag(''); |
|
| 91 | + $this->getCache()->put('', $data); |
|
| 92 | + return true; |
|
| 93 | + } else { |
|
| 94 | + // if parent does not exist, create it |
|
| 95 | + $parent = $this->normalizePath(dirname($path)); |
|
| 96 | + $parentType = $this->filetype($parent); |
|
| 97 | + if ($parentType === false) { |
|
| 98 | + if (!$this->mkdir($parent)) { |
|
| 99 | + // something went wrong |
|
| 100 | + return false; |
|
| 101 | + } |
|
| 102 | + } else if ($parentType === 'file') { |
|
| 103 | + // parent is a file |
|
| 104 | + return false; |
|
| 105 | + } |
|
| 106 | + // finally create the new dir |
|
| 107 | + $mTime = time(); // update mtime |
|
| 108 | + $data['mtime'] = $mTime; |
|
| 109 | + $data['storage_mtime'] = $mTime; |
|
| 110 | + $data['etag'] = $this->getETag($path); |
|
| 111 | + $this->getCache()->put($path, $data); |
|
| 112 | + return true; |
|
| 113 | + } |
|
| 114 | + } |
|
| 115 | + |
|
| 116 | + /** |
|
| 117 | + * @param string $path |
|
| 118 | + * @return string |
|
| 119 | + */ |
|
| 120 | + private function normalizePath($path) { |
|
| 121 | + $path = trim($path, '/'); |
|
| 122 | + //FIXME why do we sometimes get a path like 'files//username'? |
|
| 123 | + $path = str_replace('//', '/', $path); |
|
| 124 | + |
|
| 125 | + // dirname('/folder') returns '.' but internally (in the cache) we store the root as '' |
|
| 126 | + if (!$path || $path === '.') { |
|
| 127 | + $path = ''; |
|
| 128 | + } |
|
| 129 | + |
|
| 130 | + return $path; |
|
| 131 | + } |
|
| 132 | + |
|
| 133 | + /** |
|
| 134 | + * Object Stores use a NoopScanner because metadata is directly stored in |
|
| 135 | + * the file cache and cannot really scan the filesystem. The storage passed in is not used anywhere. |
|
| 136 | + * |
|
| 137 | + * @param string $path |
|
| 138 | + * @param \OC\Files\Storage\Storage (optional) the storage to pass to the scanner |
|
| 139 | + * @return \OC\Files\ObjectStore\NoopScanner |
|
| 140 | + */ |
|
| 141 | + public function getScanner($path = '', $storage = null) { |
|
| 142 | + if (!$storage) { |
|
| 143 | + $storage = $this; |
|
| 144 | + } |
|
| 145 | + if (!isset($this->scanner)) { |
|
| 146 | + $this->scanner = new NoopScanner($storage); |
|
| 147 | + } |
|
| 148 | + return $this->scanner; |
|
| 149 | + } |
|
| 150 | + |
|
| 151 | + public function getId() { |
|
| 152 | + return $this->id; |
|
| 153 | + } |
|
| 154 | + |
|
| 155 | + public function rmdir($path) { |
|
| 156 | + $path = $this->normalizePath($path); |
|
| 157 | + |
|
| 158 | + if (!$this->is_dir($path)) { |
|
| 159 | + return false; |
|
| 160 | + } |
|
| 161 | + |
|
| 162 | + $this->rmObjects($path); |
|
| 163 | + |
|
| 164 | + $this->getCache()->remove($path); |
|
| 165 | + |
|
| 166 | + return true; |
|
| 167 | + } |
|
| 168 | + |
|
| 169 | + private function rmObjects($path) { |
|
| 170 | + $children = $this->getCache()->getFolderContents($path); |
|
| 171 | + foreach ($children as $child) { |
|
| 172 | + if ($child['mimetype'] === 'httpd/unix-directory') { |
|
| 173 | + $this->rmObjects($child['path']); |
|
| 174 | + } else { |
|
| 175 | + $this->unlink($child['path']); |
|
| 176 | + } |
|
| 177 | + } |
|
| 178 | + } |
|
| 179 | + |
|
| 180 | + public function unlink($path) { |
|
| 181 | + $path = $this->normalizePath($path); |
|
| 182 | + $stat = $this->stat($path); |
|
| 183 | + |
|
| 184 | + if ($stat && isset($stat['fileid'])) { |
|
| 185 | + if ($stat['mimetype'] === 'httpd/unix-directory') { |
|
| 186 | + return $this->rmdir($path); |
|
| 187 | + } |
|
| 188 | + try { |
|
| 189 | + $this->objectStore->deleteObject($this->getURN($stat['fileid'])); |
|
| 190 | + } catch (\Exception $ex) { |
|
| 191 | + if ($ex->getCode() !== 404) { |
|
| 192 | + $this->logger->logException($ex, [ |
|
| 193 | + 'app' => 'objectstore', |
|
| 194 | + 'message' => 'Could not delete object ' . $this->getURN($stat['fileid']) . ' for ' . $path, |
|
| 195 | + ]); |
|
| 196 | + return false; |
|
| 197 | + } else { |
|
| 198 | + //removing from cache is ok as it does not exist in the objectstore anyway |
|
| 199 | + } |
|
| 200 | + } |
|
| 201 | + $this->getCache()->remove($path); |
|
| 202 | + return true; |
|
| 203 | + } |
|
| 204 | + return false; |
|
| 205 | + } |
|
| 206 | + |
|
| 207 | + public function stat($path) { |
|
| 208 | + $path = $this->normalizePath($path); |
|
| 209 | + $cacheEntry = $this->getCache()->get($path); |
|
| 210 | + if ($cacheEntry instanceof CacheEntry) { |
|
| 211 | + return $cacheEntry->getData(); |
|
| 212 | + } else { |
|
| 213 | + return false; |
|
| 214 | + } |
|
| 215 | + } |
|
| 216 | + |
|
| 217 | + /** |
|
| 218 | + * Override this method if you need a different unique resource identifier for your object storage implementation. |
|
| 219 | + * The default implementations just appends the fileId to 'urn:oid:'. Make sure the URN is unique over all users. |
|
| 220 | + * You may need a mapping table to store your URN if it cannot be generated from the fileid. |
|
| 221 | + * |
|
| 222 | + * @param int $fileId the fileid |
|
| 223 | + * @return null|string the unified resource name used to identify the object |
|
| 224 | + */ |
|
| 225 | + protected function getURN($fileId) { |
|
| 226 | + if (is_numeric($fileId)) { |
|
| 227 | + return $this->objectPrefix . $fileId; |
|
| 228 | + } |
|
| 229 | + return null; |
|
| 230 | + } |
|
| 231 | + |
|
| 232 | + public function opendir($path) { |
|
| 233 | + $path = $this->normalizePath($path); |
|
| 234 | + |
|
| 235 | + try { |
|
| 236 | + $files = array(); |
|
| 237 | + $folderContents = $this->getCache()->getFolderContents($path); |
|
| 238 | + foreach ($folderContents as $file) { |
|
| 239 | + $files[] = $file['name']; |
|
| 240 | + } |
|
| 241 | + |
|
| 242 | + return IteratorDirectory::wrap($files); |
|
| 243 | + } catch (\Exception $e) { |
|
| 244 | + $this->logger->logException($e); |
|
| 245 | + return false; |
|
| 246 | + } |
|
| 247 | + } |
|
| 248 | + |
|
| 249 | + public function filetype($path) { |
|
| 250 | + $path = $this->normalizePath($path); |
|
| 251 | + $stat = $this->stat($path); |
|
| 252 | + if ($stat) { |
|
| 253 | + if ($stat['mimetype'] === 'httpd/unix-directory') { |
|
| 254 | + return 'dir'; |
|
| 255 | + } |
|
| 256 | + return 'file'; |
|
| 257 | + } else { |
|
| 258 | + return false; |
|
| 259 | + } |
|
| 260 | + } |
|
| 261 | + |
|
| 262 | + public function fopen($path, $mode) { |
|
| 263 | + $path = $this->normalizePath($path); |
|
| 264 | + |
|
| 265 | + switch ($mode) { |
|
| 266 | + case 'r': |
|
| 267 | + case 'rb': |
|
| 268 | + $stat = $this->stat($path); |
|
| 269 | + if (is_array($stat)) { |
|
| 270 | + try { |
|
| 271 | + return $this->objectStore->readObject($this->getURN($stat['fileid'])); |
|
| 272 | + } catch (\Exception $ex) { |
|
| 273 | + $this->logger->logException($ex, [ |
|
| 274 | + 'app' => 'objectstore', |
|
| 275 | + 'message' => 'Count not get object ' . $this->getURN($stat['fileid']) . ' for file ' . $path, |
|
| 276 | + ]); |
|
| 277 | + return false; |
|
| 278 | + } |
|
| 279 | + } else { |
|
| 280 | + return false; |
|
| 281 | + } |
|
| 282 | + case 'w': |
|
| 283 | + case 'wb': |
|
| 284 | + case 'a': |
|
| 285 | + case 'ab': |
|
| 286 | + case 'r+': |
|
| 287 | + case 'w+': |
|
| 288 | + case 'wb+': |
|
| 289 | + case 'a+': |
|
| 290 | + case 'x': |
|
| 291 | + case 'x+': |
|
| 292 | + case 'c': |
|
| 293 | + case 'c+': |
|
| 294 | + if (strrpos($path, '.') !== false) { |
|
| 295 | + $ext = substr($path, strrpos($path, '.')); |
|
| 296 | + } else { |
|
| 297 | + $ext = ''; |
|
| 298 | + } |
|
| 299 | + $tmpFile = \OC::$server->getTempManager()->getTemporaryFile($ext); |
|
| 300 | + if ($this->file_exists($path)) { |
|
| 301 | + $source = $this->fopen($path, 'r'); |
|
| 302 | + file_put_contents($tmpFile, $source); |
|
| 303 | + } |
|
| 304 | + $handle = fopen($tmpFile, $mode); |
|
| 305 | + return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
| 306 | + $this->writeBack($tmpFile, $path); |
|
| 307 | + }); |
|
| 308 | + } |
|
| 309 | + return false; |
|
| 310 | + } |
|
| 311 | + |
|
| 312 | + public function file_exists($path) { |
|
| 313 | + $path = $this->normalizePath($path); |
|
| 314 | + return (bool)$this->stat($path); |
|
| 315 | + } |
|
| 316 | + |
|
| 317 | + public function rename($source, $target) { |
|
| 318 | + $source = $this->normalizePath($source); |
|
| 319 | + $target = $this->normalizePath($target); |
|
| 320 | + $this->remove($target); |
|
| 321 | + $this->getCache()->move($source, $target); |
|
| 322 | + $this->touch(dirname($target)); |
|
| 323 | + return true; |
|
| 324 | + } |
|
| 325 | + |
|
| 326 | + public function getMimeType($path) { |
|
| 327 | + $path = $this->normalizePath($path); |
|
| 328 | + $stat = $this->stat($path); |
|
| 329 | + if (is_array($stat)) { |
|
| 330 | + return $stat['mimetype']; |
|
| 331 | + } else { |
|
| 332 | + return false; |
|
| 333 | + } |
|
| 334 | + } |
|
| 335 | + |
|
| 336 | + public function touch($path, $mtime = null) { |
|
| 337 | + if (is_null($mtime)) { |
|
| 338 | + $mtime = time(); |
|
| 339 | + } |
|
| 340 | + |
|
| 341 | + $path = $this->normalizePath($path); |
|
| 342 | + $dirName = dirname($path); |
|
| 343 | + $parentExists = $this->is_dir($dirName); |
|
| 344 | + if (!$parentExists) { |
|
| 345 | + return false; |
|
| 346 | + } |
|
| 347 | + |
|
| 348 | + $stat = $this->stat($path); |
|
| 349 | + if (is_array($stat)) { |
|
| 350 | + // update existing mtime in db |
|
| 351 | + $stat['mtime'] = $mtime; |
|
| 352 | + $this->getCache()->update($stat['fileid'], $stat); |
|
| 353 | + } else { |
|
| 354 | + $mimeType = \OC::$server->getMimeTypeDetector()->detectPath($path); |
|
| 355 | + // create new file |
|
| 356 | + $stat = array( |
|
| 357 | + 'etag' => $this->getETag($path), |
|
| 358 | + 'mimetype' => $mimeType, |
|
| 359 | + 'size' => 0, |
|
| 360 | + 'mtime' => $mtime, |
|
| 361 | + 'storage_mtime' => $mtime, |
|
| 362 | + 'permissions' => \OCP\Constants::PERMISSION_ALL - \OCP\Constants::PERMISSION_CREATE, |
|
| 363 | + ); |
|
| 364 | + $fileId = $this->getCache()->put($path, $stat); |
|
| 365 | + try { |
|
| 366 | + //read an empty file from memory |
|
| 367 | + $this->objectStore->writeObject($this->getURN($fileId), fopen('php://memory', 'r')); |
|
| 368 | + } catch (\Exception $ex) { |
|
| 369 | + $this->getCache()->remove($path); |
|
| 370 | + $this->logger->logException($ex, [ |
|
| 371 | + 'app' => 'objectstore', |
|
| 372 | + 'message' => 'Could not create object ' . $this->getURN($fileId) . ' for ' . $path, |
|
| 373 | + ]); |
|
| 374 | + return false; |
|
| 375 | + } |
|
| 376 | + } |
|
| 377 | + return true; |
|
| 378 | + } |
|
| 379 | + |
|
| 380 | + public function writeBack($tmpFile, $path) { |
|
| 381 | + $stat = $this->stat($path); |
|
| 382 | + if (empty($stat)) { |
|
| 383 | + // create new file |
|
| 384 | + $stat = array( |
|
| 385 | + 'permissions' => \OCP\Constants::PERMISSION_ALL - \OCP\Constants::PERMISSION_CREATE, |
|
| 386 | + ); |
|
| 387 | + } |
|
| 388 | + // update stat with new data |
|
| 389 | + $mTime = time(); |
|
| 390 | + $stat['size'] = filesize($tmpFile); |
|
| 391 | + $stat['mtime'] = $mTime; |
|
| 392 | + $stat['storage_mtime'] = $mTime; |
|
| 393 | + $stat['mimetype'] = \OC::$server->getMimeTypeDetector()->detect($tmpFile); |
|
| 394 | + $stat['etag'] = $this->getETag($path); |
|
| 395 | + |
|
| 396 | + $fileId = $this->getCache()->put($path, $stat); |
|
| 397 | + try { |
|
| 398 | + //upload to object storage |
|
| 399 | + $this->objectStore->writeObject($this->getURN($fileId), fopen($tmpFile, 'r')); |
|
| 400 | + } catch (\Exception $ex) { |
|
| 401 | + $this->getCache()->remove($path); |
|
| 402 | + $this->logger->logException($ex, [ |
|
| 403 | + 'app' => 'objectstore', |
|
| 404 | + 'message' => 'Could not create object ' . $this->getURN($fileId) . ' for ' . $path, |
|
| 405 | + ]); |
|
| 406 | + throw $ex; // make this bubble up |
|
| 407 | + } |
|
| 408 | + } |
|
| 409 | + |
|
| 410 | + /** |
|
| 411 | + * external changes are not supported, exclusive access to the object storage is assumed |
|
| 412 | + * |
|
| 413 | + * @param string $path |
|
| 414 | + * @param int $time |
|
| 415 | + * @return false |
|
| 416 | + */ |
|
| 417 | + public function hasUpdated($path, $time) { |
|
| 418 | + return false; |
|
| 419 | + } |
|
| 420 | 420 | } |
@@ -11,14 +11,14 @@ discard block |
||
| 11 | 11 | <div id="app-navigation"> |
| 12 | 12 | <ul class="with-icon"> |
| 13 | 13 | <?php foreach($_['forms'] as $form) { |
| 14 | - if (isset($form['anchor'])) { |
|
| 15 | - $anchor = '#' . $form['anchor']; |
|
| 16 | - $class = 'nav-icon-' . $form['anchor']; |
|
| 17 | - $sectionName = $form['section-name']; |
|
| 18 | - print_unescaped(sprintf("<li><a href='%s' class='%s'>%s</a></li>", \OCP\Util::sanitizeHTML($anchor), |
|
| 19 | - \OCP\Util::sanitizeHTML($class), \OCP\Util::sanitizeHTML($sectionName))); |
|
| 20 | - } |
|
| 21 | - }?> |
|
| 14 | + if (isset($form['anchor'])) { |
|
| 15 | + $anchor = '#' . $form['anchor']; |
|
| 16 | + $class = 'nav-icon-' . $form['anchor']; |
|
| 17 | + $sectionName = $form['section-name']; |
|
| 18 | + print_unescaped(sprintf("<li><a href='%s' class='%s'>%s</a></li>", \OCP\Util::sanitizeHTML($anchor), |
|
| 19 | + \OCP\Util::sanitizeHTML($class), \OCP\Util::sanitizeHTML($sectionName))); |
|
| 20 | + } |
|
| 21 | + }?> |
|
| 22 | 22 | </ul> |
| 23 | 23 | </div> |
| 24 | 24 | |
@@ -30,10 +30,10 @@ discard block |
||
| 30 | 30 | <p id="quotatext"> |
| 31 | 31 | <?php if ($_['quota'] === \OCP\Files\FileInfo::SPACE_UNLIMITED): ?> |
| 32 | 32 | <?php print_unescaped($l->t('You are using <strong>%s</strong> of <strong>%s</strong>', |
| 33 | - [$_['usage'], $_['total_space']]));?> |
|
| 33 | + [$_['usage'], $_['total_space']]));?> |
|
| 34 | 34 | <?php else: ?> |
| 35 | 35 | <?php print_unescaped($l->t('You are using <strong>%s</strong> of <strong>%s</strong> (<strong>%s %%</strong>)', |
| 36 | - [$_['usage'], $_['total_space'], $_['usage_relative']]));?> |
|
| 36 | + [$_['usage'], $_['total_space'], $_['usage_relative']]));?> |
|
| 37 | 37 | <?php endif ?> |
| 38 | 38 | </p> |
| 39 | 39 | </div> |
@@ -99,17 +99,17 @@ discard block |
||
| 99 | 99 | <div class="verify <?php if ($_['email'] === '' || $_['emailScope'] !== 'public') p('hidden'); ?>"> |
| 100 | 100 | <img id="verify-email" title="<?php p($_['emailMessage']); ?>" data-status="<?php p($_['emailVerification']) ?>" src=" |
| 101 | 101 | <?php |
| 102 | - switch($_['emailVerification']) { |
|
| 103 | - case \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS: |
|
| 104 | - p(image_path('core', 'actions/verifying.svg')); |
|
| 105 | - break; |
|
| 106 | - case \OC\Accounts\AccountManager::VERIFIED: |
|
| 107 | - p(image_path('core', 'actions/verified.svg')); |
|
| 108 | - break; |
|
| 109 | - default: |
|
| 110 | - p(image_path('core', 'actions/verify.svg')); |
|
| 111 | - } |
|
| 112 | - ?>"> |
|
| 102 | + switch($_['emailVerification']) { |
|
| 103 | + case \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS: |
|
| 104 | + p(image_path('core', 'actions/verifying.svg')); |
|
| 105 | + break; |
|
| 106 | + case \OC\Accounts\AccountManager::VERIFIED: |
|
| 107 | + p(image_path('core', 'actions/verified.svg')); |
|
| 108 | + break; |
|
| 109 | + default: |
|
| 110 | + p(image_path('core', 'actions/verify.svg')); |
|
| 111 | + } |
|
| 112 | + ?>"> |
|
| 113 | 113 | </div> |
| 114 | 114 | <input type="email" name="email" id="email" value="<?php if(!$_['displayNameChangeSupported'] && empty($_['email'])) p($l->t('No email address set')); else p($_['email']); ?>" |
| 115 | 115 | <?php if(!$_['displayNameChangeSupported']) { print_unescaped('disabled="1"'); } ?> |
@@ -172,17 +172,17 @@ discard block |
||
| 172 | 172 | <div class="verify <?php if ($_['website'] === '' || $_['websiteScope'] !== 'public') p('hidden'); ?>"> |
| 173 | 173 | <img id="verify-website" title="<?php p($_['websiteMessage']); ?>" data-status="<?php p($_['websiteVerification']) ?>" src=" |
| 174 | 174 | <?php |
| 175 | - switch($_['websiteVerification']) { |
|
| 176 | - case \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS: |
|
| 177 | - p(image_path('core', 'actions/verifying.svg')); |
|
| 178 | - break; |
|
| 179 | - case \OC\Accounts\AccountManager::VERIFIED: |
|
| 180 | - p(image_path('core', 'actions/verified.svg')); |
|
| 181 | - break; |
|
| 182 | - default: |
|
| 183 | - p(image_path('core', 'actions/verify.svg')); |
|
| 184 | - } |
|
| 185 | - ?>" |
|
| 175 | + switch($_['websiteVerification']) { |
|
| 176 | + case \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS: |
|
| 177 | + p(image_path('core', 'actions/verifying.svg')); |
|
| 178 | + break; |
|
| 179 | + case \OC\Accounts\AccountManager::VERIFIED: |
|
| 180 | + p(image_path('core', 'actions/verified.svg')); |
|
| 181 | + break; |
|
| 182 | + default: |
|
| 183 | + p(image_path('core', 'actions/verify.svg')); |
|
| 184 | + } |
|
| 185 | + ?>" |
|
| 186 | 186 | <?php if($_['websiteVerification'] === \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS || $_['websiteVerification'] === \OC\Accounts\AccountManager::NOT_VERIFIED) print_unescaped(' class="verify-action"') ?> |
| 187 | 187 | > |
| 188 | 188 | <div class="verification-dialog popovermenu bubble menu"> |
@@ -217,17 +217,17 @@ discard block |
||
| 217 | 217 | <div class="verify <?php if ($_['twitter'] === '' || $_['twitterScope'] !== 'public') p('hidden'); ?>"> |
| 218 | 218 | <img id="verify-twitter" title="<?php p($_['twitterMessage']); ?>" data-status="<?php p($_['twitterVerification']) ?>" src=" |
| 219 | 219 | <?php |
| 220 | - switch($_['twitterVerification']) { |
|
| 221 | - case \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS: |
|
| 222 | - p(image_path('core', 'actions/verifying.svg')); |
|
| 223 | - break; |
|
| 224 | - case \OC\Accounts\AccountManager::VERIFIED: |
|
| 225 | - p(image_path('core', 'actions/verified.svg')); |
|
| 226 | - break; |
|
| 227 | - default: |
|
| 228 | - p(image_path('core', 'actions/verify.svg')); |
|
| 229 | - } |
|
| 230 | - ?>" |
|
| 220 | + switch($_['twitterVerification']) { |
|
| 221 | + case \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS: |
|
| 222 | + p(image_path('core', 'actions/verifying.svg')); |
|
| 223 | + break; |
|
| 224 | + case \OC\Accounts\AccountManager::VERIFIED: |
|
| 225 | + p(image_path('core', 'actions/verified.svg')); |
|
| 226 | + break; |
|
| 227 | + default: |
|
| 228 | + p(image_path('core', 'actions/verify.svg')); |
|
| 229 | + } |
|
| 230 | + ?>" |
|
| 231 | 231 | <?php if($_['twitterVerification'] === \OC\Accounts\AccountManager::VERIFICATION_IN_PROGRESS || $_['twitterVerification'] === \OC\Accounts\AccountManager::NOT_VERIFIED) print_unescaped(' class="verify-action"') ?> |
| 232 | 232 | > |
| 233 | 233 | <div class="verification-dialog popovermenu bubble menu"> |
@@ -292,9 +292,9 @@ discard block |
||
| 292 | 292 | </div> |
| 293 | 293 | <div class="personal-settings-setting-box personal-settings-password-box"> |
| 294 | 294 | <?php |
| 295 | - if($_['passwordChangeSupported']) { |
|
| 296 | - script('jquery-showpassword'); |
|
| 297 | - ?> |
|
| 295 | + if($_['passwordChangeSupported']) { |
|
| 296 | + script('jquery-showpassword'); |
|
| 297 | + ?> |
|
| 298 | 298 | <form id="passwordform" class="section"> |
| 299 | 299 | <h2 class="inlineblock"><?php p($l->t('Password'));?></h2> |
| 300 | 300 | <div id="password-error-msg" class="msg success inlineblock" style="display: none;">Saved</div> |
@@ -317,8 +317,8 @@ discard block |
||
| 317 | 317 | <br/> |
| 318 | 318 | </form> |
| 319 | 319 | <?php |
| 320 | - } |
|
| 321 | - ?> |
|
| 320 | + } |
|
| 321 | + ?> |
|
| 322 | 322 | </div> |
| 323 | 323 | <span class="msg"></span> |
| 324 | 324 | </div> |
@@ -344,15 +344,15 @@ discard block |
||
| 344 | 344 | |
| 345 | 345 | <p> |
| 346 | 346 | <?php print_unescaped(str_replace( |
| 347 | - [ |
|
| 348 | - '{contributeopen}', |
|
| 349 | - '{linkclose}', |
|
| 350 | - ], |
|
| 351 | - [ |
|
| 352 | - '<a href="https://nextcloud.com/contribute" target="_blank" rel="noreferrer">', |
|
| 353 | - '</a>', |
|
| 354 | - ], |
|
| 355 | - $l->t('If you want to support the project {contributeopen}join development{linkclose} or {contributeopen}spread the word{linkclose}!'))); ?> |
|
| 347 | + [ |
|
| 348 | + '{contributeopen}', |
|
| 349 | + '{linkclose}', |
|
| 350 | + ], |
|
| 351 | + [ |
|
| 352 | + '<a href="https://nextcloud.com/contribute" target="_blank" rel="noreferrer">', |
|
| 353 | + '</a>', |
|
| 354 | + ], |
|
| 355 | + $l->t('If you want to support the project {contributeopen}join development{linkclose} or {contributeopen}spread the word{linkclose}!'))); ?> |
|
| 356 | 356 | </p> |
| 357 | 357 | |
| 358 | 358 | <?php if(OC_APP::isEnabled('firstrunwizard')) {?> |
@@ -401,7 +401,7 @@ discard block |
||
| 401 | 401 | </div> |
| 402 | 402 | |
| 403 | 403 | <?php foreach($_['forms'] as $form) { |
| 404 | - if (isset($form['form'])) {?> |
|
| 404 | + if (isset($form['form'])) {?> |
|
| 405 | 405 | <div id="<?php isset($form['anchor']) ? p($form['anchor']) : p('');?>"><?php print_unescaped($form['form']);?></div> |
| 406 | 406 | <?php } |
| 407 | 407 | };?> |