Passed
Push — master ( 23bcb7...85f371 )
by Morris
10:27 queued 11s
created
lib/private/Files/Storage/Temporary.php 2 patches
Indentation   +13 added lines, -13 removed lines patch added patch discarded remove patch
@@ -29,20 +29,20 @@
 block discarded – undo
29 29
  * local storage backend in temporary folder for testing purpose
30 30
  */
31 31
 class Temporary extends Local{
32
-	public function __construct($arguments = null) {
33
-		parent::__construct(array('datadir' => \OC::$server->getTempManager()->getTemporaryFolder()));
34
-	}
32
+    public function __construct($arguments = null) {
33
+        parent::__construct(array('datadir' => \OC::$server->getTempManager()->getTemporaryFolder()));
34
+    }
35 35
 
36
-	public function cleanUp() {
37
-		\OC_Helper::rmdirr($this->datadir);
38
-	}
36
+    public function cleanUp() {
37
+        \OC_Helper::rmdirr($this->datadir);
38
+    }
39 39
 
40
-	public function __destruct() {
41
-		parent::__destruct();
42
-		$this->cleanUp();
43
-	}
40
+    public function __destruct() {
41
+        parent::__destruct();
42
+        $this->cleanUp();
43
+    }
44 44
 
45
-	public function getDataDir() {
46
-		return $this->datadir;
47
-	}
45
+    public function getDataDir() {
46
+        return $this->datadir;
47
+    }
48 48
 }
Please login to merge, or discard this patch.
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -28,7 +28,7 @@
 block discarded – undo
28 28
 /**
29 29
  * local storage backend in temporary folder for testing purpose
30 30
  */
31
-class Temporary extends Local{
31
+class Temporary extends Local {
32 32
 	public function __construct($arguments = null) {
33 33
 		parent::__construct(array('datadir' => \OC::$server->getTempManager()->getTemporaryFolder()));
34 34
 	}
Please login to merge, or discard this patch.
lib/private/Files/Storage/Local.php 3 patches
Braces   +3 added lines, -2 removed lines patch added patch discarded remove patch
@@ -317,8 +317,9 @@
 block discarded – undo
317 317
 		$files = array();
318 318
 		$physicalDir = $this->getSourcePath($dir);
319 319
 		foreach (scandir($physicalDir) as $item) {
320
-			if (\OC\Files\Filesystem::isIgnoredDir($item))
321
-				continue;
320
+			if (\OC\Files\Filesystem::isIgnoredDir($item)) {
321
+							continue;
322
+			}
322 323
 			$physicalItem = $physicalDir . '/' . $item;
323 324
 
324 325
 			if (strstr(strtolower($item), strtolower($query)) !== false) {
Please login to merge, or discard this patch.
Indentation   +438 added lines, -438 removed lines patch added patch discarded remove patch
@@ -49,442 +49,442 @@
 block discarded – undo
49 49
  * for local filestore, we only have to map the paths
50 50
  */
51 51
 class Local extends \OC\Files\Storage\Common {
52
-	protected $datadir;
53
-
54
-	protected $dataDirLength;
55
-
56
-	protected $allowSymlinks = false;
57
-
58
-	protected $realDataDir;
59
-
60
-	public function __construct($arguments) {
61
-		if (!isset($arguments['datadir']) || !is_string($arguments['datadir'])) {
62
-			throw new \InvalidArgumentException('No data directory set for local storage');
63
-		}
64
-		$this->datadir = str_replace('//', '/', $arguments['datadir']);
65
-		// some crazy code uses a local storage on root...
66
-		if ($this->datadir === '/') {
67
-			$this->realDataDir = $this->datadir;
68
-		} else {
69
-			$realPath = realpath($this->datadir) ?: $this->datadir;
70
-			$this->realDataDir = rtrim($realPath, '/') . '/';
71
-		}
72
-		if (substr($this->datadir, -1) !== '/') {
73
-			$this->datadir .= '/';
74
-		}
75
-		$this->dataDirLength = strlen($this->realDataDir);
76
-	}
77
-
78
-	public function __destruct() {
79
-	}
80
-
81
-	public function getId() {
82
-		return 'local::' . $this->datadir;
83
-	}
84
-
85
-	public function mkdir($path) {
86
-		return @mkdir($this->getSourcePath($path), 0777, true);
87
-	}
88
-
89
-	public function rmdir($path) {
90
-		if (!$this->isDeletable($path)) {
91
-			return false;
92
-		}
93
-		try {
94
-			$it = new \RecursiveIteratorIterator(
95
-				new \RecursiveDirectoryIterator($this->getSourcePath($path)),
96
-				\RecursiveIteratorIterator::CHILD_FIRST
97
-			);
98
-			/**
99
-			 * RecursiveDirectoryIterator on an NFS path isn't iterable with foreach
100
-			 * This bug is fixed in PHP 5.5.9 or before
101
-			 * See #8376
102
-			 */
103
-			$it->rewind();
104
-			while ($it->valid()) {
105
-				/**
106
-				 * @var \SplFileInfo $file
107
-				 */
108
-				$file = $it->current();
109
-				if (in_array($file->getBasename(), array('.', '..'))) {
110
-					$it->next();
111
-					continue;
112
-				} elseif ($file->isDir()) {
113
-					rmdir($file->getPathname());
114
-				} elseif ($file->isFile() || $file->isLink()) {
115
-					unlink($file->getPathname());
116
-				}
117
-				$it->next();
118
-			}
119
-			return rmdir($this->getSourcePath($path));
120
-		} catch (\UnexpectedValueException $e) {
121
-			return false;
122
-		}
123
-	}
124
-
125
-	public function opendir($path) {
126
-		return opendir($this->getSourcePath($path));
127
-	}
128
-
129
-	public function is_dir($path) {
130
-		if (substr($path, -1) == '/') {
131
-			$path = substr($path, 0, -1);
132
-		}
133
-		return is_dir($this->getSourcePath($path));
134
-	}
135
-
136
-	public function is_file($path) {
137
-		return is_file($this->getSourcePath($path));
138
-	}
139
-
140
-	public function stat($path) {
141
-		clearstatcache();
142
-		$fullPath = $this->getSourcePath($path);
143
-		$statResult = stat($fullPath);
144
-		if (PHP_INT_SIZE === 4 && !$this->is_dir($path)) {
145
-			$filesize = $this->filesize($path);
146
-			$statResult['size'] = $filesize;
147
-			$statResult[7] = $filesize;
148
-		}
149
-		return $statResult;
150
-	}
151
-
152
-	public function filetype($path) {
153
-		$filetype = filetype($this->getSourcePath($path));
154
-		if ($filetype == 'link') {
155
-			$filetype = filetype(realpath($this->getSourcePath($path)));
156
-		}
157
-		return $filetype;
158
-	}
159
-
160
-	public function filesize($path) {
161
-		if ($this->is_dir($path)) {
162
-			return 0;
163
-		}
164
-		$fullPath = $this->getSourcePath($path);
165
-		if (PHP_INT_SIZE === 4) {
166
-			$helper = new \OC\LargeFileHelper;
167
-			return $helper->getFileSize($fullPath);
168
-		}
169
-		return filesize($fullPath);
170
-	}
171
-
172
-	public function isReadable($path) {
173
-		return is_readable($this->getSourcePath($path));
174
-	}
175
-
176
-	public function isUpdatable($path) {
177
-		return is_writable($this->getSourcePath($path));
178
-	}
179
-
180
-	public function file_exists($path) {
181
-		return file_exists($this->getSourcePath($path));
182
-	}
183
-
184
-	public function filemtime($path) {
185
-		$fullPath = $this->getSourcePath($path);
186
-		clearstatcache(true, $fullPath);
187
-		if (!$this->file_exists($path)) {
188
-			return false;
189
-		}
190
-		if (PHP_INT_SIZE === 4) {
191
-			$helper = new \OC\LargeFileHelper();
192
-			return $helper->getFileMtime($fullPath);
193
-		}
194
-		return filemtime($fullPath);
195
-	}
196
-
197
-	public function touch($path, $mtime = null) {
198
-		// sets the modification time of the file to the given value.
199
-		// If mtime is nil the current time is set.
200
-		// note that the access time of the file always changes to the current time.
201
-		if ($this->file_exists($path) and !$this->isUpdatable($path)) {
202
-			return false;
203
-		}
204
-		if (!is_null($mtime)) {
205
-			$result = touch($this->getSourcePath($path), $mtime);
206
-		} else {
207
-			$result = touch($this->getSourcePath($path));
208
-		}
209
-		if ($result) {
210
-			clearstatcache(true, $this->getSourcePath($path));
211
-		}
212
-
213
-		return $result;
214
-	}
215
-
216
-	public function file_get_contents($path) {
217
-		return file_get_contents($this->getSourcePath($path));
218
-	}
219
-
220
-	public function file_put_contents($path, $data) {
221
-		return file_put_contents($this->getSourcePath($path), $data);
222
-	}
223
-
224
-	public function unlink($path) {
225
-		if ($this->is_dir($path)) {
226
-			return $this->rmdir($path);
227
-		} else if ($this->is_file($path)) {
228
-			return unlink($this->getSourcePath($path));
229
-		} else {
230
-			return false;
231
-		}
232
-
233
-	}
234
-
235
-	private function treeContainsBlacklistedFile(string $path): bool {
236
-		$iterator = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($path));
237
-		foreach ($iterator as $file) {
238
-			/** @var \SplFileInfo $file */
239
-			if (Filesystem::isFileBlacklisted($file->getBasename())) {
240
-				return true;
241
-			}
242
-		}
243
-
244
-		return false;
245
-	}
246
-
247
-	public function rename($path1, $path2) {
248
-		$srcParent = dirname($path1);
249
-		$dstParent = dirname($path2);
250
-
251
-		if (!$this->isUpdatable($srcParent)) {
252
-			\OCP\Util::writeLog('core', 'unable to rename, source directory is not writable : ' . $srcParent, ILogger::ERROR);
253
-			return false;
254
-		}
255
-
256
-		if (!$this->isUpdatable($dstParent)) {
257
-			\OCP\Util::writeLog('core', 'unable to rename, destination directory is not writable : ' . $dstParent, ILogger::ERROR);
258
-			return false;
259
-		}
260
-
261
-		if (!$this->file_exists($path1)) {
262
-			\OCP\Util::writeLog('core', 'unable to rename, file does not exists : ' . $path1, ILogger::ERROR);
263
-			return false;
264
-		}
265
-
266
-		if ($this->is_dir($path2)) {
267
-			$this->rmdir($path2);
268
-		} else if ($this->is_file($path2)) {
269
-			$this->unlink($path2);
270
-		}
271
-
272
-		if ($this->is_dir($path1)) {
273
-			// we can't move folders across devices, use copy instead
274
-			$stat1 = stat(dirname($this->getSourcePath($path1)));
275
-			$stat2 = stat(dirname($this->getSourcePath($path2)));
276
-			if ($stat1['dev'] !== $stat2['dev']) {
277
-				$result = $this->copy($path1, $path2);
278
-				if ($result) {
279
-					$result &= $this->rmdir($path1);
280
-				}
281
-				return $result;
282
-			}
283
-
284
-			if ($this->treeContainsBlacklistedFile($this->getSourcePath($path1))) {
285
-				throw new ForbiddenException('Invalid path', false);
286
-			}
287
-		}
288
-
289
-		return rename($this->getSourcePath($path1), $this->getSourcePath($path2));
290
-	}
291
-
292
-	public function copy($path1, $path2) {
293
-		if ($this->is_dir($path1)) {
294
-			return parent::copy($path1, $path2);
295
-		} else {
296
-			return copy($this->getSourcePath($path1), $this->getSourcePath($path2));
297
-		}
298
-	}
299
-
300
-	public function fopen($path, $mode) {
301
-		return fopen($this->getSourcePath($path), $mode);
302
-	}
303
-
304
-	public function hash($type, $path, $raw = false) {
305
-		return hash_file($type, $this->getSourcePath($path), $raw);
306
-	}
307
-
308
-	public function free_space($path) {
309
-		$sourcePath = $this->getSourcePath($path);
310
-		// using !is_dir because $sourcePath might be a part file or
311
-		// non-existing file, so we'd still want to use the parent dir
312
-		// in such cases
313
-		if (!is_dir($sourcePath)) {
314
-			// disk_free_space doesn't work on files
315
-			$sourcePath = dirname($sourcePath);
316
-		}
317
-		$space = @disk_free_space($sourcePath);
318
-		if ($space === false || is_null($space)) {
319
-			return \OCP\Files\FileInfo::SPACE_UNKNOWN;
320
-		}
321
-		return $space;
322
-	}
323
-
324
-	public function search($query) {
325
-		return $this->searchInDir($query);
326
-	}
327
-
328
-	public function getLocalFile($path) {
329
-		return $this->getSourcePath($path);
330
-	}
331
-
332
-	public function getLocalFolder($path) {
333
-		return $this->getSourcePath($path);
334
-	}
335
-
336
-	/**
337
-	 * @param string $query
338
-	 * @param string $dir
339
-	 * @return array
340
-	 */
341
-	protected function searchInDir($query, $dir = '') {
342
-		$files = array();
343
-		$physicalDir = $this->getSourcePath($dir);
344
-		foreach (scandir($physicalDir) as $item) {
345
-			if (\OC\Files\Filesystem::isIgnoredDir($item))
346
-				continue;
347
-			$physicalItem = $physicalDir . '/' . $item;
348
-
349
-			if (strstr(strtolower($item), strtolower($query)) !== false) {
350
-				$files[] = $dir . '/' . $item;
351
-			}
352
-			if (is_dir($physicalItem)) {
353
-				$files = array_merge($files, $this->searchInDir($query, $dir . '/' . $item));
354
-			}
355
-		}
356
-		return $files;
357
-	}
358
-
359
-	/**
360
-	 * check if a file or folder has been updated since $time
361
-	 *
362
-	 * @param string $path
363
-	 * @param int $time
364
-	 * @return bool
365
-	 */
366
-	public function hasUpdated($path, $time) {
367
-		if ($this->file_exists($path)) {
368
-			return $this->filemtime($path) > $time;
369
-		} else {
370
-			return true;
371
-		}
372
-	}
373
-
374
-	/**
375
-	 * Get the source path (on disk) of a given path
376
-	 *
377
-	 * @param string $path
378
-	 * @return string
379
-	 * @throws ForbiddenException
380
-	 */
381
-	public function getSourcePath($path) {
382
-		if (Filesystem::isFileBlacklisted($path)) {
383
-			throw new ForbiddenException('Invalid path', false);
384
-		}
385
-
386
-		$fullPath = $this->datadir . $path;
387
-		$currentPath = $path;
388
-		if ($this->allowSymlinks || $currentPath === '') {
389
-			return $fullPath;
390
-		}
391
-		$pathToResolve = $fullPath;
392
-		$realPath = realpath($pathToResolve);
393
-		while ($realPath === false) { // for non existing files check the parent directory
394
-			$currentPath = dirname($currentPath);
395
-			if ($currentPath === '' || $currentPath === '.') {
396
-				return $fullPath;
397
-			}
398
-			$realPath = realpath($this->datadir . $currentPath);
399
-		}
400
-		if ($realPath) {
401
-			$realPath = $realPath . '/';
402
-		}
403
-		if (substr($realPath, 0, $this->dataDirLength) === $this->realDataDir) {
404
-			return $fullPath;
405
-		}
406
-
407
-		\OCP\Util::writeLog('core', "Following symlinks is not allowed ('$fullPath' -> '$realPath' not inside '{$this->realDataDir}')", ILogger::ERROR);
408
-		throw new ForbiddenException('Following symlinks is not allowed', false);
409
-	}
410
-
411
-	/**
412
-	 * {@inheritdoc}
413
-	 */
414
-	public function isLocal() {
415
-		return true;
416
-	}
417
-
418
-	/**
419
-	 * get the ETag for a file or folder
420
-	 *
421
-	 * @param string $path
422
-	 * @return string
423
-	 */
424
-	public function getETag($path) {
425
-		if ($this->is_file($path)) {
426
-			$stat = $this->stat($path);
427
-			return md5(
428
-				$stat['mtime'] .
429
-				$stat['ino'] .
430
-				$stat['dev'] .
431
-				$stat['size']
432
-			);
433
-		} else {
434
-			return parent::getETag($path);
435
-		}
436
-	}
437
-
438
-	/**
439
-	 * @param IStorage $sourceStorage
440
-	 * @param string $sourceInternalPath
441
-	 * @param string $targetInternalPath
442
-	 * @param bool $preserveMtime
443
-	 * @return bool
444
-	 */
445
-	public function copyFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath, $preserveMtime = false) {
446
-		if ($sourceStorage->instanceOfStorage(Local::class)) {
447
-			if ($sourceStorage->instanceOfStorage(Jail::class)) {
448
-				/**
449
-				 * @var \OC\Files\Storage\Wrapper\Jail $sourceStorage
450
-				 */
451
-				$sourceInternalPath = $sourceStorage->getUnjailedPath($sourceInternalPath);
452
-			}
453
-			/**
454
-			 * @var \OC\Files\Storage\Local $sourceStorage
455
-			 */
456
-			$rootStorage = new Local(['datadir' => '/']);
457
-			return $rootStorage->copy($sourceStorage->getSourcePath($sourceInternalPath), $this->getSourcePath($targetInternalPath));
458
-		} else {
459
-			return parent::copyFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath);
460
-		}
461
-	}
462
-
463
-	/**
464
-	 * @param IStorage $sourceStorage
465
-	 * @param string $sourceInternalPath
466
-	 * @param string $targetInternalPath
467
-	 * @return bool
468
-	 */
469
-	public function moveFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath) {
470
-		if ($sourceStorage->instanceOfStorage(Local::class)) {
471
-			if ($sourceStorage->instanceOfStorage(Jail::class)) {
472
-				/**
473
-				 * @var \OC\Files\Storage\Wrapper\Jail $sourceStorage
474
-				 */
475
-				$sourceInternalPath = $sourceStorage->getUnjailedPath($sourceInternalPath);
476
-			}
477
-			/**
478
-			 * @var \OC\Files\Storage\Local $sourceStorage
479
-			 */
480
-			$rootStorage = new Local(['datadir' => '/']);
481
-			return $rootStorage->rename($sourceStorage->getSourcePath($sourceInternalPath), $this->getSourcePath($targetInternalPath));
482
-		} else {
483
-			return parent::moveFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath);
484
-		}
485
-	}
486
-
487
-	public function writeStream(string $path, $stream, int $size = null): int {
488
-		return (int)file_put_contents($this->getSourcePath($path), $stream);
489
-	}
52
+    protected $datadir;
53
+
54
+    protected $dataDirLength;
55
+
56
+    protected $allowSymlinks = false;
57
+
58
+    protected $realDataDir;
59
+
60
+    public function __construct($arguments) {
61
+        if (!isset($arguments['datadir']) || !is_string($arguments['datadir'])) {
62
+            throw new \InvalidArgumentException('No data directory set for local storage');
63
+        }
64
+        $this->datadir = str_replace('//', '/', $arguments['datadir']);
65
+        // some crazy code uses a local storage on root...
66
+        if ($this->datadir === '/') {
67
+            $this->realDataDir = $this->datadir;
68
+        } else {
69
+            $realPath = realpath($this->datadir) ?: $this->datadir;
70
+            $this->realDataDir = rtrim($realPath, '/') . '/';
71
+        }
72
+        if (substr($this->datadir, -1) !== '/') {
73
+            $this->datadir .= '/';
74
+        }
75
+        $this->dataDirLength = strlen($this->realDataDir);
76
+    }
77
+
78
+    public function __destruct() {
79
+    }
80
+
81
+    public function getId() {
82
+        return 'local::' . $this->datadir;
83
+    }
84
+
85
+    public function mkdir($path) {
86
+        return @mkdir($this->getSourcePath($path), 0777, true);
87
+    }
88
+
89
+    public function rmdir($path) {
90
+        if (!$this->isDeletable($path)) {
91
+            return false;
92
+        }
93
+        try {
94
+            $it = new \RecursiveIteratorIterator(
95
+                new \RecursiveDirectoryIterator($this->getSourcePath($path)),
96
+                \RecursiveIteratorIterator::CHILD_FIRST
97
+            );
98
+            /**
99
+             * RecursiveDirectoryIterator on an NFS path isn't iterable with foreach
100
+             * This bug is fixed in PHP 5.5.9 or before
101
+             * See #8376
102
+             */
103
+            $it->rewind();
104
+            while ($it->valid()) {
105
+                /**
106
+                 * @var \SplFileInfo $file
107
+                 */
108
+                $file = $it->current();
109
+                if (in_array($file->getBasename(), array('.', '..'))) {
110
+                    $it->next();
111
+                    continue;
112
+                } elseif ($file->isDir()) {
113
+                    rmdir($file->getPathname());
114
+                } elseif ($file->isFile() || $file->isLink()) {
115
+                    unlink($file->getPathname());
116
+                }
117
+                $it->next();
118
+            }
119
+            return rmdir($this->getSourcePath($path));
120
+        } catch (\UnexpectedValueException $e) {
121
+            return false;
122
+        }
123
+    }
124
+
125
+    public function opendir($path) {
126
+        return opendir($this->getSourcePath($path));
127
+    }
128
+
129
+    public function is_dir($path) {
130
+        if (substr($path, -1) == '/') {
131
+            $path = substr($path, 0, -1);
132
+        }
133
+        return is_dir($this->getSourcePath($path));
134
+    }
135
+
136
+    public function is_file($path) {
137
+        return is_file($this->getSourcePath($path));
138
+    }
139
+
140
+    public function stat($path) {
141
+        clearstatcache();
142
+        $fullPath = $this->getSourcePath($path);
143
+        $statResult = stat($fullPath);
144
+        if (PHP_INT_SIZE === 4 && !$this->is_dir($path)) {
145
+            $filesize = $this->filesize($path);
146
+            $statResult['size'] = $filesize;
147
+            $statResult[7] = $filesize;
148
+        }
149
+        return $statResult;
150
+    }
151
+
152
+    public function filetype($path) {
153
+        $filetype = filetype($this->getSourcePath($path));
154
+        if ($filetype == 'link') {
155
+            $filetype = filetype(realpath($this->getSourcePath($path)));
156
+        }
157
+        return $filetype;
158
+    }
159
+
160
+    public function filesize($path) {
161
+        if ($this->is_dir($path)) {
162
+            return 0;
163
+        }
164
+        $fullPath = $this->getSourcePath($path);
165
+        if (PHP_INT_SIZE === 4) {
166
+            $helper = new \OC\LargeFileHelper;
167
+            return $helper->getFileSize($fullPath);
168
+        }
169
+        return filesize($fullPath);
170
+    }
171
+
172
+    public function isReadable($path) {
173
+        return is_readable($this->getSourcePath($path));
174
+    }
175
+
176
+    public function isUpdatable($path) {
177
+        return is_writable($this->getSourcePath($path));
178
+    }
179
+
180
+    public function file_exists($path) {
181
+        return file_exists($this->getSourcePath($path));
182
+    }
183
+
184
+    public function filemtime($path) {
185
+        $fullPath = $this->getSourcePath($path);
186
+        clearstatcache(true, $fullPath);
187
+        if (!$this->file_exists($path)) {
188
+            return false;
189
+        }
190
+        if (PHP_INT_SIZE === 4) {
191
+            $helper = new \OC\LargeFileHelper();
192
+            return $helper->getFileMtime($fullPath);
193
+        }
194
+        return filemtime($fullPath);
195
+    }
196
+
197
+    public function touch($path, $mtime = null) {
198
+        // sets the modification time of the file to the given value.
199
+        // If mtime is nil the current time is set.
200
+        // note that the access time of the file always changes to the current time.
201
+        if ($this->file_exists($path) and !$this->isUpdatable($path)) {
202
+            return false;
203
+        }
204
+        if (!is_null($mtime)) {
205
+            $result = touch($this->getSourcePath($path), $mtime);
206
+        } else {
207
+            $result = touch($this->getSourcePath($path));
208
+        }
209
+        if ($result) {
210
+            clearstatcache(true, $this->getSourcePath($path));
211
+        }
212
+
213
+        return $result;
214
+    }
215
+
216
+    public function file_get_contents($path) {
217
+        return file_get_contents($this->getSourcePath($path));
218
+    }
219
+
220
+    public function file_put_contents($path, $data) {
221
+        return file_put_contents($this->getSourcePath($path), $data);
222
+    }
223
+
224
+    public function unlink($path) {
225
+        if ($this->is_dir($path)) {
226
+            return $this->rmdir($path);
227
+        } else if ($this->is_file($path)) {
228
+            return unlink($this->getSourcePath($path));
229
+        } else {
230
+            return false;
231
+        }
232
+
233
+    }
234
+
235
+    private function treeContainsBlacklistedFile(string $path): bool {
236
+        $iterator = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($path));
237
+        foreach ($iterator as $file) {
238
+            /** @var \SplFileInfo $file */
239
+            if (Filesystem::isFileBlacklisted($file->getBasename())) {
240
+                return true;
241
+            }
242
+        }
243
+
244
+        return false;
245
+    }
246
+
247
+    public function rename($path1, $path2) {
248
+        $srcParent = dirname($path1);
249
+        $dstParent = dirname($path2);
250
+
251
+        if (!$this->isUpdatable($srcParent)) {
252
+            \OCP\Util::writeLog('core', 'unable to rename, source directory is not writable : ' . $srcParent, ILogger::ERROR);
253
+            return false;
254
+        }
255
+
256
+        if (!$this->isUpdatable($dstParent)) {
257
+            \OCP\Util::writeLog('core', 'unable to rename, destination directory is not writable : ' . $dstParent, ILogger::ERROR);
258
+            return false;
259
+        }
260
+
261
+        if (!$this->file_exists($path1)) {
262
+            \OCP\Util::writeLog('core', 'unable to rename, file does not exists : ' . $path1, ILogger::ERROR);
263
+            return false;
264
+        }
265
+
266
+        if ($this->is_dir($path2)) {
267
+            $this->rmdir($path2);
268
+        } else if ($this->is_file($path2)) {
269
+            $this->unlink($path2);
270
+        }
271
+
272
+        if ($this->is_dir($path1)) {
273
+            // we can't move folders across devices, use copy instead
274
+            $stat1 = stat(dirname($this->getSourcePath($path1)));
275
+            $stat2 = stat(dirname($this->getSourcePath($path2)));
276
+            if ($stat1['dev'] !== $stat2['dev']) {
277
+                $result = $this->copy($path1, $path2);
278
+                if ($result) {
279
+                    $result &= $this->rmdir($path1);
280
+                }
281
+                return $result;
282
+            }
283
+
284
+            if ($this->treeContainsBlacklistedFile($this->getSourcePath($path1))) {
285
+                throw new ForbiddenException('Invalid path', false);
286
+            }
287
+        }
288
+
289
+        return rename($this->getSourcePath($path1), $this->getSourcePath($path2));
290
+    }
291
+
292
+    public function copy($path1, $path2) {
293
+        if ($this->is_dir($path1)) {
294
+            return parent::copy($path1, $path2);
295
+        } else {
296
+            return copy($this->getSourcePath($path1), $this->getSourcePath($path2));
297
+        }
298
+    }
299
+
300
+    public function fopen($path, $mode) {
301
+        return fopen($this->getSourcePath($path), $mode);
302
+    }
303
+
304
+    public function hash($type, $path, $raw = false) {
305
+        return hash_file($type, $this->getSourcePath($path), $raw);
306
+    }
307
+
308
+    public function free_space($path) {
309
+        $sourcePath = $this->getSourcePath($path);
310
+        // using !is_dir because $sourcePath might be a part file or
311
+        // non-existing file, so we'd still want to use the parent dir
312
+        // in such cases
313
+        if (!is_dir($sourcePath)) {
314
+            // disk_free_space doesn't work on files
315
+            $sourcePath = dirname($sourcePath);
316
+        }
317
+        $space = @disk_free_space($sourcePath);
318
+        if ($space === false || is_null($space)) {
319
+            return \OCP\Files\FileInfo::SPACE_UNKNOWN;
320
+        }
321
+        return $space;
322
+    }
323
+
324
+    public function search($query) {
325
+        return $this->searchInDir($query);
326
+    }
327
+
328
+    public function getLocalFile($path) {
329
+        return $this->getSourcePath($path);
330
+    }
331
+
332
+    public function getLocalFolder($path) {
333
+        return $this->getSourcePath($path);
334
+    }
335
+
336
+    /**
337
+     * @param string $query
338
+     * @param string $dir
339
+     * @return array
340
+     */
341
+    protected function searchInDir($query, $dir = '') {
342
+        $files = array();
343
+        $physicalDir = $this->getSourcePath($dir);
344
+        foreach (scandir($physicalDir) as $item) {
345
+            if (\OC\Files\Filesystem::isIgnoredDir($item))
346
+                continue;
347
+            $physicalItem = $physicalDir . '/' . $item;
348
+
349
+            if (strstr(strtolower($item), strtolower($query)) !== false) {
350
+                $files[] = $dir . '/' . $item;
351
+            }
352
+            if (is_dir($physicalItem)) {
353
+                $files = array_merge($files, $this->searchInDir($query, $dir . '/' . $item));
354
+            }
355
+        }
356
+        return $files;
357
+    }
358
+
359
+    /**
360
+     * check if a file or folder has been updated since $time
361
+     *
362
+     * @param string $path
363
+     * @param int $time
364
+     * @return bool
365
+     */
366
+    public function hasUpdated($path, $time) {
367
+        if ($this->file_exists($path)) {
368
+            return $this->filemtime($path) > $time;
369
+        } else {
370
+            return true;
371
+        }
372
+    }
373
+
374
+    /**
375
+     * Get the source path (on disk) of a given path
376
+     *
377
+     * @param string $path
378
+     * @return string
379
+     * @throws ForbiddenException
380
+     */
381
+    public function getSourcePath($path) {
382
+        if (Filesystem::isFileBlacklisted($path)) {
383
+            throw new ForbiddenException('Invalid path', false);
384
+        }
385
+
386
+        $fullPath = $this->datadir . $path;
387
+        $currentPath = $path;
388
+        if ($this->allowSymlinks || $currentPath === '') {
389
+            return $fullPath;
390
+        }
391
+        $pathToResolve = $fullPath;
392
+        $realPath = realpath($pathToResolve);
393
+        while ($realPath === false) { // for non existing files check the parent directory
394
+            $currentPath = dirname($currentPath);
395
+            if ($currentPath === '' || $currentPath === '.') {
396
+                return $fullPath;
397
+            }
398
+            $realPath = realpath($this->datadir . $currentPath);
399
+        }
400
+        if ($realPath) {
401
+            $realPath = $realPath . '/';
402
+        }
403
+        if (substr($realPath, 0, $this->dataDirLength) === $this->realDataDir) {
404
+            return $fullPath;
405
+        }
406
+
407
+        \OCP\Util::writeLog('core', "Following symlinks is not allowed ('$fullPath' -> '$realPath' not inside '{$this->realDataDir}')", ILogger::ERROR);
408
+        throw new ForbiddenException('Following symlinks is not allowed', false);
409
+    }
410
+
411
+    /**
412
+     * {@inheritdoc}
413
+     */
414
+    public function isLocal() {
415
+        return true;
416
+    }
417
+
418
+    /**
419
+     * get the ETag for a file or folder
420
+     *
421
+     * @param string $path
422
+     * @return string
423
+     */
424
+    public function getETag($path) {
425
+        if ($this->is_file($path)) {
426
+            $stat = $this->stat($path);
427
+            return md5(
428
+                $stat['mtime'] .
429
+                $stat['ino'] .
430
+                $stat['dev'] .
431
+                $stat['size']
432
+            );
433
+        } else {
434
+            return parent::getETag($path);
435
+        }
436
+    }
437
+
438
+    /**
439
+     * @param IStorage $sourceStorage
440
+     * @param string $sourceInternalPath
441
+     * @param string $targetInternalPath
442
+     * @param bool $preserveMtime
443
+     * @return bool
444
+     */
445
+    public function copyFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath, $preserveMtime = false) {
446
+        if ($sourceStorage->instanceOfStorage(Local::class)) {
447
+            if ($sourceStorage->instanceOfStorage(Jail::class)) {
448
+                /**
449
+                 * @var \OC\Files\Storage\Wrapper\Jail $sourceStorage
450
+                 */
451
+                $sourceInternalPath = $sourceStorage->getUnjailedPath($sourceInternalPath);
452
+            }
453
+            /**
454
+             * @var \OC\Files\Storage\Local $sourceStorage
455
+             */
456
+            $rootStorage = new Local(['datadir' => '/']);
457
+            return $rootStorage->copy($sourceStorage->getSourcePath($sourceInternalPath), $this->getSourcePath($targetInternalPath));
458
+        } else {
459
+            return parent::copyFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath);
460
+        }
461
+    }
462
+
463
+    /**
464
+     * @param IStorage $sourceStorage
465
+     * @param string $sourceInternalPath
466
+     * @param string $targetInternalPath
467
+     * @return bool
468
+     */
469
+    public function moveFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath) {
470
+        if ($sourceStorage->instanceOfStorage(Local::class)) {
471
+            if ($sourceStorage->instanceOfStorage(Jail::class)) {
472
+                /**
473
+                 * @var \OC\Files\Storage\Wrapper\Jail $sourceStorage
474
+                 */
475
+                $sourceInternalPath = $sourceStorage->getUnjailedPath($sourceInternalPath);
476
+            }
477
+            /**
478
+             * @var \OC\Files\Storage\Local $sourceStorage
479
+             */
480
+            $rootStorage = new Local(['datadir' => '/']);
481
+            return $rootStorage->rename($sourceStorage->getSourcePath($sourceInternalPath), $this->getSourcePath($targetInternalPath));
482
+        } else {
483
+            return parent::moveFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath);
484
+        }
485
+    }
486
+
487
+    public function writeStream(string $path, $stream, int $size = null): int {
488
+        return (int)file_put_contents($this->getSourcePath($path), $stream);
489
+    }
490 490
 }
Please login to merge, or discard this patch.
Spacing   +15 added lines, -15 removed lines patch added patch discarded remove patch
@@ -67,7 +67,7 @@  discard block
 block discarded – undo
67 67
 			$this->realDataDir = $this->datadir;
68 68
 		} else {
69 69
 			$realPath = realpath($this->datadir) ?: $this->datadir;
70
-			$this->realDataDir = rtrim($realPath, '/') . '/';
70
+			$this->realDataDir = rtrim($realPath, '/').'/';
71 71
 		}
72 72
 		if (substr($this->datadir, -1) !== '/') {
73 73
 			$this->datadir .= '/';
@@ -79,7 +79,7 @@  discard block
 block discarded – undo
79 79
 	}
80 80
 
81 81
 	public function getId() {
82
-		return 'local::' . $this->datadir;
82
+		return 'local::'.$this->datadir;
83 83
 	}
84 84
 
85 85
 	public function mkdir($path) {
@@ -249,17 +249,17 @@  discard block
 block discarded – undo
249 249
 		$dstParent = dirname($path2);
250 250
 
251 251
 		if (!$this->isUpdatable($srcParent)) {
252
-			\OCP\Util::writeLog('core', 'unable to rename, source directory is not writable : ' . $srcParent, ILogger::ERROR);
252
+			\OCP\Util::writeLog('core', 'unable to rename, source directory is not writable : '.$srcParent, ILogger::ERROR);
253 253
 			return false;
254 254
 		}
255 255
 
256 256
 		if (!$this->isUpdatable($dstParent)) {
257
-			\OCP\Util::writeLog('core', 'unable to rename, destination directory is not writable : ' . $dstParent, ILogger::ERROR);
257
+			\OCP\Util::writeLog('core', 'unable to rename, destination directory is not writable : '.$dstParent, ILogger::ERROR);
258 258
 			return false;
259 259
 		}
260 260
 
261 261
 		if (!$this->file_exists($path1)) {
262
-			\OCP\Util::writeLog('core', 'unable to rename, file does not exists : ' . $path1, ILogger::ERROR);
262
+			\OCP\Util::writeLog('core', 'unable to rename, file does not exists : '.$path1, ILogger::ERROR);
263 263
 			return false;
264 264
 		}
265 265
 
@@ -344,13 +344,13 @@  discard block
 block discarded – undo
344 344
 		foreach (scandir($physicalDir) as $item) {
345 345
 			if (\OC\Files\Filesystem::isIgnoredDir($item))
346 346
 				continue;
347
-			$physicalItem = $physicalDir . '/' . $item;
347
+			$physicalItem = $physicalDir.'/'.$item;
348 348
 
349 349
 			if (strstr(strtolower($item), strtolower($query)) !== false) {
350
-				$files[] = $dir . '/' . $item;
350
+				$files[] = $dir.'/'.$item;
351 351
 			}
352 352
 			if (is_dir($physicalItem)) {
353
-				$files = array_merge($files, $this->searchInDir($query, $dir . '/' . $item));
353
+				$files = array_merge($files, $this->searchInDir($query, $dir.'/'.$item));
354 354
 			}
355 355
 		}
356 356
 		return $files;
@@ -383,7 +383,7 @@  discard block
 block discarded – undo
383 383
 			throw new ForbiddenException('Invalid path', false);
384 384
 		}
385 385
 
386
-		$fullPath = $this->datadir . $path;
386
+		$fullPath = $this->datadir.$path;
387 387
 		$currentPath = $path;
388 388
 		if ($this->allowSymlinks || $currentPath === '') {
389 389
 			return $fullPath;
@@ -395,10 +395,10 @@  discard block
 block discarded – undo
395 395
 			if ($currentPath === '' || $currentPath === '.') {
396 396
 				return $fullPath;
397 397
 			}
398
-			$realPath = realpath($this->datadir . $currentPath);
398
+			$realPath = realpath($this->datadir.$currentPath);
399 399
 		}
400 400
 		if ($realPath) {
401
-			$realPath = $realPath . '/';
401
+			$realPath = $realPath.'/';
402 402
 		}
403 403
 		if (substr($realPath, 0, $this->dataDirLength) === $this->realDataDir) {
404 404
 			return $fullPath;
@@ -425,9 +425,9 @@  discard block
 block discarded – undo
425 425
 		if ($this->is_file($path)) {
426 426
 			$stat = $this->stat($path);
427 427
 			return md5(
428
-				$stat['mtime'] .
429
-				$stat['ino'] .
430
-				$stat['dev'] .
428
+				$stat['mtime'].
429
+				$stat['ino'].
430
+				$stat['dev'].
431 431
 				$stat['size']
432 432
 			);
433 433
 		} else {
@@ -485,6 +485,6 @@  discard block
 block discarded – undo
485 485
 	}
486 486
 
487 487
 	public function writeStream(string $path, $stream, int $size = null): int {
488
-		return (int)file_put_contents($this->getSourcePath($path), $stream);
488
+		return (int) file_put_contents($this->getSourcePath($path), $stream);
489 489
 	}
490 490
 }
Please login to merge, or discard this patch.
lib/private/Files/Storage/Storage.php 1 patch
Indentation   +75 added lines, -75 removed lines patch added patch discarded remove patch
@@ -32,90 +32,90 @@
 block discarded – undo
32 32
  */
33 33
 interface Storage extends \OCP\Files\Storage {
34 34
 
35
-	/**
36
-	 * get a cache instance for the storage
37
-	 *
38
-	 * @param string $path
39
-	 * @param \OC\Files\Storage\Storage (optional) the storage to pass to the cache
40
-	 * @return \OC\Files\Cache\Cache
41
-	 */
42
-	public function getCache($path = '', $storage = null);
35
+    /**
36
+     * get a cache instance for the storage
37
+     *
38
+     * @param string $path
39
+     * @param \OC\Files\Storage\Storage (optional) the storage to pass to the cache
40
+     * @return \OC\Files\Cache\Cache
41
+     */
42
+    public function getCache($path = '', $storage = null);
43 43
 
44
-	/**
45
-	 * get a scanner instance for the storage
46
-	 *
47
-	 * @param string $path
48
-	 * @param \OC\Files\Storage\Storage (optional) the storage to pass to the scanner
49
-	 * @return \OC\Files\Cache\Scanner
50
-	 */
51
-	public function getScanner($path = '', $storage = null);
44
+    /**
45
+     * get a scanner instance for the storage
46
+     *
47
+     * @param string $path
48
+     * @param \OC\Files\Storage\Storage (optional) the storage to pass to the scanner
49
+     * @return \OC\Files\Cache\Scanner
50
+     */
51
+    public function getScanner($path = '', $storage = null);
52 52
 
53 53
 
54
-	/**
55
-	 * get the user id of the owner of a file or folder
56
-	 *
57
-	 * @param string $path
58
-	 * @return string
59
-	 */
60
-	public function getOwner($path);
54
+    /**
55
+     * get the user id of the owner of a file or folder
56
+     *
57
+     * @param string $path
58
+     * @return string
59
+     */
60
+    public function getOwner($path);
61 61
 
62
-	/**
63
-	 * get a watcher instance for the cache
64
-	 *
65
-	 * @param string $path
66
-	 * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
67
-	 * @return \OC\Files\Cache\Watcher
68
-	 */
69
-	public function getWatcher($path = '', $storage = null);
62
+    /**
63
+     * get a watcher instance for the cache
64
+     *
65
+     * @param string $path
66
+     * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
67
+     * @return \OC\Files\Cache\Watcher
68
+     */
69
+    public function getWatcher($path = '', $storage = null);
70 70
 
71
-	/**
72
-	 * get a propagator instance for the cache
73
-	 *
74
-	 * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
75
-	 * @return \OC\Files\Cache\Propagator
76
-	 */
77
-	public function getPropagator($storage = null);
71
+    /**
72
+     * get a propagator instance for the cache
73
+     *
74
+     * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
75
+     * @return \OC\Files\Cache\Propagator
76
+     */
77
+    public function getPropagator($storage = null);
78 78
 
79
-	/**
80
-	 * get a updater instance for the cache
81
-	 *
82
-	 * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
83
-	 * @return \OC\Files\Cache\Updater
84
-	 */
85
-	public function getUpdater($storage = null);
79
+    /**
80
+     * get a updater instance for the cache
81
+     *
82
+     * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
83
+     * @return \OC\Files\Cache\Updater
84
+     */
85
+    public function getUpdater($storage = null);
86 86
 
87
-	/**
88
-	 * @return \OC\Files\Cache\Storage
89
-	 */
90
-	public function getStorageCache();
87
+    /**
88
+     * @return \OC\Files\Cache\Storage
89
+     */
90
+    public function getStorageCache();
91 91
 
92
-	/**
93
-	 * @param string $path
94
-	 * @return array
95
-	 */
96
-	public function getMetaData($path);
92
+    /**
93
+     * @param string $path
94
+     * @return array
95
+     */
96
+    public function getMetaData($path);
97 97
 
98
-	/**
99
-	 * @param string $path The path of the file to acquire the lock for
100
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
101
-	 * @param \OCP\Lock\ILockingProvider $provider
102
-	 * @throws \OCP\Lock\LockedException
103
-	 */
104
-	public function acquireLock($path, $type, ILockingProvider $provider);
98
+    /**
99
+     * @param string $path The path of the file to acquire the lock for
100
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
101
+     * @param \OCP\Lock\ILockingProvider $provider
102
+     * @throws \OCP\Lock\LockedException
103
+     */
104
+    public function acquireLock($path, $type, ILockingProvider $provider);
105 105
 
106
-	/**
107
-	 * @param string $path The path of the file to release the lock for
108
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
109
-	 * @param \OCP\Lock\ILockingProvider $provider
110
-	 * @throws \OCP\Lock\LockedException
111
-	 */
112
-	public function releaseLock($path, $type, ILockingProvider $provider);
106
+    /**
107
+     * @param string $path The path of the file to release the lock for
108
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
109
+     * @param \OCP\Lock\ILockingProvider $provider
110
+     * @throws \OCP\Lock\LockedException
111
+     */
112
+    public function releaseLock($path, $type, ILockingProvider $provider);
113 113
 
114
-	/**
115
-	 * @param string $path The path of the file to change the lock for
116
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
117
-	 * @param \OCP\Lock\ILockingProvider $provider
118
-	 * @throws \OCP\Lock\LockedException
119
-	 */
120
-	public function changeLock($path, $type, ILockingProvider $provider);
114
+    /**
115
+     * @param string $path The path of the file to change the lock for
116
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
117
+     * @param \OCP\Lock\ILockingProvider $provider
118
+     * @throws \OCP\Lock\LockedException
119
+     */
120
+    public function changeLock($path, $type, ILockingProvider $provider);
121 121
 }
Please login to merge, or discard this patch.
lib/private/Files/Storage/LocalTempFileTrait.php 1 patch
Indentation   +38 added lines, -38 removed lines patch added patch discarded remove patch
@@ -37,45 +37,45 @@
 block discarded – undo
37 37
  */
38 38
 trait LocalTempFileTrait {
39 39
 
40
-	/** @var string[] */
41
-	protected $cachedFiles = [];
40
+    /** @var string[] */
41
+    protected $cachedFiles = [];
42 42
 
43
-	/**
44
-	 * @param string $path
45
-	 * @return string
46
-	 */
47
-	protected function getCachedFile($path) {
48
-		if (!isset($this->cachedFiles[$path])) {
49
-			$this->cachedFiles[$path] = $this->toTmpFile($path);
50
-		}
51
-		return $this->cachedFiles[$path];
52
-	}
43
+    /**
44
+     * @param string $path
45
+     * @return string
46
+     */
47
+    protected function getCachedFile($path) {
48
+        if (!isset($this->cachedFiles[$path])) {
49
+            $this->cachedFiles[$path] = $this->toTmpFile($path);
50
+        }
51
+        return $this->cachedFiles[$path];
52
+    }
53 53
 
54
-	/**
55
-	 * @param string $path
56
-	 */
57
-	protected function removeCachedFile($path) {
58
-		unset($this->cachedFiles[$path]);
59
-	}
54
+    /**
55
+     * @param string $path
56
+     */
57
+    protected function removeCachedFile($path) {
58
+        unset($this->cachedFiles[$path]);
59
+    }
60 60
 
61
-	/**
62
-	 * @param string $path
63
-	 * @return string
64
-	 */
65
-	protected function toTmpFile($path) { //no longer in the storage api, still useful here
66
-		$source = $this->fopen($path, 'r');
67
-		if (!$source) {
68
-			return false;
69
-		}
70
-		if ($pos = strrpos($path, '.')) {
71
-			$extension = substr($path, $pos);
72
-		} else {
73
-			$extension = '';
74
-		}
75
-		$tmpFile = \OC::$server->getTempManager()->getTemporaryFile($extension);
76
-		$target = fopen($tmpFile, 'w');
77
-		\OC_Helper::streamCopy($source, $target);
78
-		fclose($target);
79
-		return $tmpFile;
80
-	}
61
+    /**
62
+     * @param string $path
63
+     * @return string
64
+     */
65
+    protected function toTmpFile($path) { //no longer in the storage api, still useful here
66
+        $source = $this->fopen($path, 'r');
67
+        if (!$source) {
68
+            return false;
69
+        }
70
+        if ($pos = strrpos($path, '.')) {
71
+            $extension = substr($path, $pos);
72
+        } else {
73
+            $extension = '';
74
+        }
75
+        $tmpFile = \OC::$server->getTempManager()->getTemporaryFile($extension);
76
+        $target = fopen($tmpFile, 'w');
77
+        \OC_Helper::streamCopy($source, $target);
78
+        fclose($target);
79
+        return $tmpFile;
80
+    }
81 81
 }
Please login to merge, or discard this patch.
lib/private/Files/Storage/Common.php 3 patches
Braces   +3 added lines, -1 removed lines patch added patch discarded remove patch
@@ -289,7 +289,9 @@
 block discarded – undo
289 289
 		$dh = $this->opendir($dir);
290 290
 		if (is_resource($dh)) {
291 291
 			while (($item = readdir($dh)) !== false) {
292
-				if (\OC\Files\Filesystem::isIgnoredDir($item)) continue;
292
+				if (\OC\Files\Filesystem::isIgnoredDir($item)) {
293
+				    continue;
294
+				}
293 295
 				if (strstr(strtolower($item), strtolower($query)) !== false) {
294 296
 					$files[] = $dir . '/' . $item;
295 297
 				}
Please login to merge, or discard this patch.
Indentation   +754 added lines, -754 removed lines patch added patch discarded remove patch
@@ -72,762 +72,762 @@
 block discarded – undo
72 72
  */
73 73
 abstract class Common implements Storage, ILockingStorage, IWriteStreamStorage {
74 74
 
75
-	use LocalTempFileTrait;
76
-
77
-	protected $cache;
78
-	protected $scanner;
79
-	protected $watcher;
80
-	protected $propagator;
81
-	protected $storageCache;
82
-	protected $updater;
83
-
84
-	protected $mountOptions = [];
85
-	protected $owner = null;
86
-
87
-	private $shouldLogLocks = null;
88
-	private $logger;
89
-
90
-	public function __construct($parameters) {
91
-	}
92
-
93
-	/**
94
-	 * Remove a file or folder
95
-	 *
96
-	 * @param string $path
97
-	 * @return bool
98
-	 */
99
-	protected function remove($path) {
100
-		if ($this->is_dir($path)) {
101
-			return $this->rmdir($path);
102
-		} else if ($this->is_file($path)) {
103
-			return $this->unlink($path);
104
-		} else {
105
-			return false;
106
-		}
107
-	}
108
-
109
-	public function is_dir($path) {
110
-		return $this->filetype($path) === 'dir';
111
-	}
112
-
113
-	public function is_file($path) {
114
-		return $this->filetype($path) === 'file';
115
-	}
116
-
117
-	public function filesize($path) {
118
-		if ($this->is_dir($path)) {
119
-			return 0; //by definition
120
-		} else {
121
-			$stat = $this->stat($path);
122
-			if (isset($stat['size'])) {
123
-				return $stat['size'];
124
-			} else {
125
-				return 0;
126
-			}
127
-		}
128
-	}
129
-
130
-	public function isReadable($path) {
131
-		// at least check whether it exists
132
-		// subclasses might want to implement this more thoroughly
133
-		return $this->file_exists($path);
134
-	}
135
-
136
-	public function isUpdatable($path) {
137
-		// at least check whether it exists
138
-		// subclasses might want to implement this more thoroughly
139
-		// a non-existing file/folder isn't updatable
140
-		return $this->file_exists($path);
141
-	}
142
-
143
-	public function isCreatable($path) {
144
-		if ($this->is_dir($path) && $this->isUpdatable($path)) {
145
-			return true;
146
-		}
147
-		return false;
148
-	}
149
-
150
-	public function isDeletable($path) {
151
-		if ($path === '' || $path === '/') {
152
-			return false;
153
-		}
154
-		$parent = dirname($path);
155
-		return $this->isUpdatable($parent) && $this->isUpdatable($path);
156
-	}
157
-
158
-	public function isSharable($path) {
159
-		return $this->isReadable($path);
160
-	}
161
-
162
-	public function getPermissions($path) {
163
-		$permissions = 0;
164
-		if ($this->isCreatable($path)) {
165
-			$permissions |= \OCP\Constants::PERMISSION_CREATE;
166
-		}
167
-		if ($this->isReadable($path)) {
168
-			$permissions |= \OCP\Constants::PERMISSION_READ;
169
-		}
170
-		if ($this->isUpdatable($path)) {
171
-			$permissions |= \OCP\Constants::PERMISSION_UPDATE;
172
-		}
173
-		if ($this->isDeletable($path)) {
174
-			$permissions |= \OCP\Constants::PERMISSION_DELETE;
175
-		}
176
-		if ($this->isSharable($path)) {
177
-			$permissions |= \OCP\Constants::PERMISSION_SHARE;
178
-		}
179
-		return $permissions;
180
-	}
181
-
182
-	public function filemtime($path) {
183
-		$stat = $this->stat($path);
184
-		if (isset($stat['mtime']) && $stat['mtime'] > 0) {
185
-			return $stat['mtime'];
186
-		} else {
187
-			return 0;
188
-		}
189
-	}
190
-
191
-	public function file_get_contents($path) {
192
-		$handle = $this->fopen($path, "r");
193
-		if (!$handle) {
194
-			return false;
195
-		}
196
-		$data = stream_get_contents($handle);
197
-		fclose($handle);
198
-		return $data;
199
-	}
200
-
201
-	public function file_put_contents($path, $data) {
202
-		$handle = $this->fopen($path, "w");
203
-		$this->removeCachedFile($path);
204
-		$count = fwrite($handle, $data);
205
-		fclose($handle);
206
-		return $count;
207
-	}
208
-
209
-	public function rename($path1, $path2) {
210
-		$this->remove($path2);
211
-
212
-		$this->removeCachedFile($path1);
213
-		return $this->copy($path1, $path2) and $this->remove($path1);
214
-	}
215
-
216
-	public function copy($path1, $path2) {
217
-		if ($this->is_dir($path1)) {
218
-			$this->remove($path2);
219
-			$dir = $this->opendir($path1);
220
-			$this->mkdir($path2);
221
-			while ($file = readdir($dir)) {
222
-				if (!Filesystem::isIgnoredDir($file)) {
223
-					if (!$this->copy($path1 . '/' . $file, $path2 . '/' . $file)) {
224
-						return false;
225
-					}
226
-				}
227
-			}
228
-			closedir($dir);
229
-			return true;
230
-		} else {
231
-			$source = $this->fopen($path1, 'r');
232
-			$target = $this->fopen($path2, 'w');
233
-			list(, $result) = \OC_Helper::streamCopy($source, $target);
234
-			if (!$result) {
235
-				\OC::$server->getLogger()->warning("Failed to write data while copying $path1 to $path2");
236
-			}
237
-			$this->removeCachedFile($path2);
238
-			return $result;
239
-		}
240
-	}
241
-
242
-	public function getMimeType($path) {
243
-		if ($this->is_dir($path)) {
244
-			return 'httpd/unix-directory';
245
-		} elseif ($this->file_exists($path)) {
246
-			return \OC::$server->getMimeTypeDetector()->detectPath($path);
247
-		} else {
248
-			return false;
249
-		}
250
-	}
251
-
252
-	public function hash($type, $path, $raw = false) {
253
-		$fh = $this->fopen($path, 'rb');
254
-		$ctx = hash_init($type);
255
-		hash_update_stream($ctx, $fh);
256
-		fclose($fh);
257
-		return hash_final($ctx, $raw);
258
-	}
259
-
260
-	public function search($query) {
261
-		return $this->searchInDir($query);
262
-	}
263
-
264
-	public function getLocalFile($path) {
265
-		return $this->getCachedFile($path);
266
-	}
267
-
268
-	/**
269
-	 * @param string $path
270
-	 * @param string $target
271
-	 */
272
-	private function addLocalFolder($path, $target) {
273
-		$dh = $this->opendir($path);
274
-		if (is_resource($dh)) {
275
-			while (($file = readdir($dh)) !== false) {
276
-				if (!\OC\Files\Filesystem::isIgnoredDir($file)) {
277
-					if ($this->is_dir($path . '/' . $file)) {
278
-						mkdir($target . '/' . $file);
279
-						$this->addLocalFolder($path . '/' . $file, $target . '/' . $file);
280
-					} else {
281
-						$tmp = $this->toTmpFile($path . '/' . $file);
282
-						rename($tmp, $target . '/' . $file);
283
-					}
284
-				}
285
-			}
286
-		}
287
-	}
288
-
289
-	/**
290
-	 * @param string $query
291
-	 * @param string $dir
292
-	 * @return array
293
-	 */
294
-	protected function searchInDir($query, $dir = '') {
295
-		$files = array();
296
-		$dh = $this->opendir($dir);
297
-		if (is_resource($dh)) {
298
-			while (($item = readdir($dh)) !== false) {
299
-				if (\OC\Files\Filesystem::isIgnoredDir($item)) continue;
300
-				if (strstr(strtolower($item), strtolower($query)) !== false) {
301
-					$files[] = $dir . '/' . $item;
302
-				}
303
-				if ($this->is_dir($dir . '/' . $item)) {
304
-					$files = array_merge($files, $this->searchInDir($query, $dir . '/' . $item));
305
-				}
306
-			}
307
-		}
308
-		closedir($dh);
309
-		return $files;
310
-	}
311
-
312
-	/**
313
-	 * check if a file or folder has been updated since $time
314
-	 *
315
-	 * The method is only used to check if the cache needs to be updated. Storage backends that don't support checking
316
-	 * the mtime should always return false here. As a result storage implementations that always return false expect
317
-	 * exclusive access to the backend and will not pick up files that have been added in a way that circumvents
318
-	 * ownClouds filesystem.
319
-	 *
320
-	 * @param string $path
321
-	 * @param int $time
322
-	 * @return bool
323
-	 */
324
-	public function hasUpdated($path, $time) {
325
-		return $this->filemtime($path) > $time;
326
-	}
327
-
328
-	public function getCache($path = '', $storage = null) {
329
-		if (!$storage) {
330
-			$storage = $this;
331
-		}
332
-		if (!isset($storage->cache)) {
333
-			$storage->cache = new Cache($storage);
334
-		}
335
-		return $storage->cache;
336
-	}
337
-
338
-	public function getScanner($path = '', $storage = null) {
339
-		if (!$storage) {
340
-			$storage = $this;
341
-		}
342
-		if (!isset($storage->scanner)) {
343
-			$storage->scanner = new Scanner($storage);
344
-		}
345
-		return $storage->scanner;
346
-	}
347
-
348
-	public function getWatcher($path = '', $storage = null) {
349
-		if (!$storage) {
350
-			$storage = $this;
351
-		}
352
-		if (!isset($this->watcher)) {
353
-			$this->watcher = new Watcher($storage);
354
-			$globalPolicy = \OC::$server->getConfig()->getSystemValue('filesystem_check_changes', Watcher::CHECK_NEVER);
355
-			$this->watcher->setPolicy((int)$this->getMountOption('filesystem_check_changes', $globalPolicy));
356
-		}
357
-		return $this->watcher;
358
-	}
359
-
360
-	/**
361
-	 * get a propagator instance for the cache
362
-	 *
363
-	 * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
364
-	 * @return \OC\Files\Cache\Propagator
365
-	 */
366
-	public function getPropagator($storage = null) {
367
-		if (!$storage) {
368
-			$storage = $this;
369
-		}
370
-		if (!isset($storage->propagator)) {
371
-			$config = \OC::$server->getSystemConfig();
372
-			$storage->propagator = new Propagator($storage, \OC::$server->getDatabaseConnection(), ['appdata_' . $config->getValue('instanceid')]);
373
-		}
374
-		return $storage->propagator;
375
-	}
376
-
377
-	public function getUpdater($storage = null) {
378
-		if (!$storage) {
379
-			$storage = $this;
380
-		}
381
-		if (!isset($storage->updater)) {
382
-			$storage->updater = new Updater($storage);
383
-		}
384
-		return $storage->updater;
385
-	}
386
-
387
-	public function getStorageCache($storage = null) {
388
-		if (!$storage) {
389
-			$storage = $this;
390
-		}
391
-		if (!isset($this->storageCache)) {
392
-			$this->storageCache = new \OC\Files\Cache\Storage($storage);
393
-		}
394
-		return $this->storageCache;
395
-	}
396
-
397
-	/**
398
-	 * get the owner of a path
399
-	 *
400
-	 * @param string $path The path to get the owner
401
-	 * @return string|false uid or false
402
-	 */
403
-	public function getOwner($path) {
404
-		if ($this->owner === null) {
405
-			$this->owner = \OC_User::getUser();
406
-		}
407
-
408
-		return $this->owner;
409
-	}
410
-
411
-	/**
412
-	 * get the ETag for a file or folder
413
-	 *
414
-	 * @param string $path
415
-	 * @return string
416
-	 */
417
-	public function getETag($path) {
418
-		return uniqid();
419
-	}
420
-
421
-	/**
422
-	 * clean a path, i.e. remove all redundant '.' and '..'
423
-	 * making sure that it can't point to higher than '/'
424
-	 *
425
-	 * @param string $path The path to clean
426
-	 * @return string cleaned path
427
-	 */
428
-	public function cleanPath($path) {
429
-		if (strlen($path) == 0 or $path[0] != '/') {
430
-			$path = '/' . $path;
431
-		}
432
-
433
-		$output = array();
434
-		foreach (explode('/', $path) as $chunk) {
435
-			if ($chunk == '..') {
436
-				array_pop($output);
437
-			} else if ($chunk == '.') {
438
-			} else {
439
-				$output[] = $chunk;
440
-			}
441
-		}
442
-		return implode('/', $output);
443
-	}
444
-
445
-	/**
446
-	 * Test a storage for availability
447
-	 *
448
-	 * @return bool
449
-	 */
450
-	public function test() {
451
-		try {
452
-			if ($this->stat('')) {
453
-				return true;
454
-			}
455
-			\OC::$server->getLogger()->info("External storage not available: stat() failed");
456
-			return false;
457
-		} catch (\Exception $e) {
458
-			\OC::$server->getLogger()->info("External storage not available: " . $e->getMessage());
459
-			\OC::$server->getLogger()->logException($e, ['level' => ILogger::DEBUG]);
460
-			return false;
461
-		}
462
-	}
463
-
464
-	/**
465
-	 * get the free space in the storage
466
-	 *
467
-	 * @param string $path
468
-	 * @return int|false
469
-	 */
470
-	public function free_space($path) {
471
-		return \OCP\Files\FileInfo::SPACE_UNKNOWN;
472
-	}
473
-
474
-	/**
475
-	 * {@inheritdoc}
476
-	 */
477
-	public function isLocal() {
478
-		// the common implementation returns a temporary file by
479
-		// default, which is not local
480
-		return false;
481
-	}
482
-
483
-	/**
484
-	 * Check if the storage is an instance of $class or is a wrapper for a storage that is an instance of $class
485
-	 *
486
-	 * @param string $class
487
-	 * @return bool
488
-	 */
489
-	public function instanceOfStorage($class) {
490
-		if (ltrim($class, '\\') === 'OC\Files\Storage\Shared') {
491
-			// FIXME Temporary fix to keep existing checks working
492
-			$class = '\OCA\Files_Sharing\SharedStorage';
493
-		}
494
-		return is_a($this, $class);
495
-	}
496
-
497
-	/**
498
-	 * A custom storage implementation can return an url for direct download of a give file.
499
-	 *
500
-	 * For now the returned array can hold the parameter url - in future more attributes might follow.
501
-	 *
502
-	 * @param string $path
503
-	 * @return array|false
504
-	 */
505
-	public function getDirectDownload($path) {
506
-		return [];
507
-	}
508
-
509
-	/**
510
-	 * @inheritdoc
511
-	 * @throws InvalidPathException
512
-	 */
513
-	public function verifyPath($path, $fileName) {
514
-
515
-		// verify empty and dot files
516
-		$trimmed = trim($fileName);
517
-		if ($trimmed === '') {
518
-			throw new EmptyFileNameException();
519
-		}
520
-
521
-		if (\OC\Files\Filesystem::isIgnoredDir($trimmed)) {
522
-			throw new InvalidDirectoryException();
523
-		}
524
-
525
-		if (!\OC::$server->getDatabaseConnection()->supports4ByteText()) {
526
-			// verify database - e.g. mysql only 3-byte chars
527
-			if (preg_match('%(?:
75
+    use LocalTempFileTrait;
76
+
77
+    protected $cache;
78
+    protected $scanner;
79
+    protected $watcher;
80
+    protected $propagator;
81
+    protected $storageCache;
82
+    protected $updater;
83
+
84
+    protected $mountOptions = [];
85
+    protected $owner = null;
86
+
87
+    private $shouldLogLocks = null;
88
+    private $logger;
89
+
90
+    public function __construct($parameters) {
91
+    }
92
+
93
+    /**
94
+     * Remove a file or folder
95
+     *
96
+     * @param string $path
97
+     * @return bool
98
+     */
99
+    protected function remove($path) {
100
+        if ($this->is_dir($path)) {
101
+            return $this->rmdir($path);
102
+        } else if ($this->is_file($path)) {
103
+            return $this->unlink($path);
104
+        } else {
105
+            return false;
106
+        }
107
+    }
108
+
109
+    public function is_dir($path) {
110
+        return $this->filetype($path) === 'dir';
111
+    }
112
+
113
+    public function is_file($path) {
114
+        return $this->filetype($path) === 'file';
115
+    }
116
+
117
+    public function filesize($path) {
118
+        if ($this->is_dir($path)) {
119
+            return 0; //by definition
120
+        } else {
121
+            $stat = $this->stat($path);
122
+            if (isset($stat['size'])) {
123
+                return $stat['size'];
124
+            } else {
125
+                return 0;
126
+            }
127
+        }
128
+    }
129
+
130
+    public function isReadable($path) {
131
+        // at least check whether it exists
132
+        // subclasses might want to implement this more thoroughly
133
+        return $this->file_exists($path);
134
+    }
135
+
136
+    public function isUpdatable($path) {
137
+        // at least check whether it exists
138
+        // subclasses might want to implement this more thoroughly
139
+        // a non-existing file/folder isn't updatable
140
+        return $this->file_exists($path);
141
+    }
142
+
143
+    public function isCreatable($path) {
144
+        if ($this->is_dir($path) && $this->isUpdatable($path)) {
145
+            return true;
146
+        }
147
+        return false;
148
+    }
149
+
150
+    public function isDeletable($path) {
151
+        if ($path === '' || $path === '/') {
152
+            return false;
153
+        }
154
+        $parent = dirname($path);
155
+        return $this->isUpdatable($parent) && $this->isUpdatable($path);
156
+    }
157
+
158
+    public function isSharable($path) {
159
+        return $this->isReadable($path);
160
+    }
161
+
162
+    public function getPermissions($path) {
163
+        $permissions = 0;
164
+        if ($this->isCreatable($path)) {
165
+            $permissions |= \OCP\Constants::PERMISSION_CREATE;
166
+        }
167
+        if ($this->isReadable($path)) {
168
+            $permissions |= \OCP\Constants::PERMISSION_READ;
169
+        }
170
+        if ($this->isUpdatable($path)) {
171
+            $permissions |= \OCP\Constants::PERMISSION_UPDATE;
172
+        }
173
+        if ($this->isDeletable($path)) {
174
+            $permissions |= \OCP\Constants::PERMISSION_DELETE;
175
+        }
176
+        if ($this->isSharable($path)) {
177
+            $permissions |= \OCP\Constants::PERMISSION_SHARE;
178
+        }
179
+        return $permissions;
180
+    }
181
+
182
+    public function filemtime($path) {
183
+        $stat = $this->stat($path);
184
+        if (isset($stat['mtime']) && $stat['mtime'] > 0) {
185
+            return $stat['mtime'];
186
+        } else {
187
+            return 0;
188
+        }
189
+    }
190
+
191
+    public function file_get_contents($path) {
192
+        $handle = $this->fopen($path, "r");
193
+        if (!$handle) {
194
+            return false;
195
+        }
196
+        $data = stream_get_contents($handle);
197
+        fclose($handle);
198
+        return $data;
199
+    }
200
+
201
+    public function file_put_contents($path, $data) {
202
+        $handle = $this->fopen($path, "w");
203
+        $this->removeCachedFile($path);
204
+        $count = fwrite($handle, $data);
205
+        fclose($handle);
206
+        return $count;
207
+    }
208
+
209
+    public function rename($path1, $path2) {
210
+        $this->remove($path2);
211
+
212
+        $this->removeCachedFile($path1);
213
+        return $this->copy($path1, $path2) and $this->remove($path1);
214
+    }
215
+
216
+    public function copy($path1, $path2) {
217
+        if ($this->is_dir($path1)) {
218
+            $this->remove($path2);
219
+            $dir = $this->opendir($path1);
220
+            $this->mkdir($path2);
221
+            while ($file = readdir($dir)) {
222
+                if (!Filesystem::isIgnoredDir($file)) {
223
+                    if (!$this->copy($path1 . '/' . $file, $path2 . '/' . $file)) {
224
+                        return false;
225
+                    }
226
+                }
227
+            }
228
+            closedir($dir);
229
+            return true;
230
+        } else {
231
+            $source = $this->fopen($path1, 'r');
232
+            $target = $this->fopen($path2, 'w');
233
+            list(, $result) = \OC_Helper::streamCopy($source, $target);
234
+            if (!$result) {
235
+                \OC::$server->getLogger()->warning("Failed to write data while copying $path1 to $path2");
236
+            }
237
+            $this->removeCachedFile($path2);
238
+            return $result;
239
+        }
240
+    }
241
+
242
+    public function getMimeType($path) {
243
+        if ($this->is_dir($path)) {
244
+            return 'httpd/unix-directory';
245
+        } elseif ($this->file_exists($path)) {
246
+            return \OC::$server->getMimeTypeDetector()->detectPath($path);
247
+        } else {
248
+            return false;
249
+        }
250
+    }
251
+
252
+    public function hash($type, $path, $raw = false) {
253
+        $fh = $this->fopen($path, 'rb');
254
+        $ctx = hash_init($type);
255
+        hash_update_stream($ctx, $fh);
256
+        fclose($fh);
257
+        return hash_final($ctx, $raw);
258
+    }
259
+
260
+    public function search($query) {
261
+        return $this->searchInDir($query);
262
+    }
263
+
264
+    public function getLocalFile($path) {
265
+        return $this->getCachedFile($path);
266
+    }
267
+
268
+    /**
269
+     * @param string $path
270
+     * @param string $target
271
+     */
272
+    private function addLocalFolder($path, $target) {
273
+        $dh = $this->opendir($path);
274
+        if (is_resource($dh)) {
275
+            while (($file = readdir($dh)) !== false) {
276
+                if (!\OC\Files\Filesystem::isIgnoredDir($file)) {
277
+                    if ($this->is_dir($path . '/' . $file)) {
278
+                        mkdir($target . '/' . $file);
279
+                        $this->addLocalFolder($path . '/' . $file, $target . '/' . $file);
280
+                    } else {
281
+                        $tmp = $this->toTmpFile($path . '/' . $file);
282
+                        rename($tmp, $target . '/' . $file);
283
+                    }
284
+                }
285
+            }
286
+        }
287
+    }
288
+
289
+    /**
290
+     * @param string $query
291
+     * @param string $dir
292
+     * @return array
293
+     */
294
+    protected function searchInDir($query, $dir = '') {
295
+        $files = array();
296
+        $dh = $this->opendir($dir);
297
+        if (is_resource($dh)) {
298
+            while (($item = readdir($dh)) !== false) {
299
+                if (\OC\Files\Filesystem::isIgnoredDir($item)) continue;
300
+                if (strstr(strtolower($item), strtolower($query)) !== false) {
301
+                    $files[] = $dir . '/' . $item;
302
+                }
303
+                if ($this->is_dir($dir . '/' . $item)) {
304
+                    $files = array_merge($files, $this->searchInDir($query, $dir . '/' . $item));
305
+                }
306
+            }
307
+        }
308
+        closedir($dh);
309
+        return $files;
310
+    }
311
+
312
+    /**
313
+     * check if a file or folder has been updated since $time
314
+     *
315
+     * The method is only used to check if the cache needs to be updated. Storage backends that don't support checking
316
+     * the mtime should always return false here. As a result storage implementations that always return false expect
317
+     * exclusive access to the backend and will not pick up files that have been added in a way that circumvents
318
+     * ownClouds filesystem.
319
+     *
320
+     * @param string $path
321
+     * @param int $time
322
+     * @return bool
323
+     */
324
+    public function hasUpdated($path, $time) {
325
+        return $this->filemtime($path) > $time;
326
+    }
327
+
328
+    public function getCache($path = '', $storage = null) {
329
+        if (!$storage) {
330
+            $storage = $this;
331
+        }
332
+        if (!isset($storage->cache)) {
333
+            $storage->cache = new Cache($storage);
334
+        }
335
+        return $storage->cache;
336
+    }
337
+
338
+    public function getScanner($path = '', $storage = null) {
339
+        if (!$storage) {
340
+            $storage = $this;
341
+        }
342
+        if (!isset($storage->scanner)) {
343
+            $storage->scanner = new Scanner($storage);
344
+        }
345
+        return $storage->scanner;
346
+    }
347
+
348
+    public function getWatcher($path = '', $storage = null) {
349
+        if (!$storage) {
350
+            $storage = $this;
351
+        }
352
+        if (!isset($this->watcher)) {
353
+            $this->watcher = new Watcher($storage);
354
+            $globalPolicy = \OC::$server->getConfig()->getSystemValue('filesystem_check_changes', Watcher::CHECK_NEVER);
355
+            $this->watcher->setPolicy((int)$this->getMountOption('filesystem_check_changes', $globalPolicy));
356
+        }
357
+        return $this->watcher;
358
+    }
359
+
360
+    /**
361
+     * get a propagator instance for the cache
362
+     *
363
+     * @param \OC\Files\Storage\Storage (optional) the storage to pass to the watcher
364
+     * @return \OC\Files\Cache\Propagator
365
+     */
366
+    public function getPropagator($storage = null) {
367
+        if (!$storage) {
368
+            $storage = $this;
369
+        }
370
+        if (!isset($storage->propagator)) {
371
+            $config = \OC::$server->getSystemConfig();
372
+            $storage->propagator = new Propagator($storage, \OC::$server->getDatabaseConnection(), ['appdata_' . $config->getValue('instanceid')]);
373
+        }
374
+        return $storage->propagator;
375
+    }
376
+
377
+    public function getUpdater($storage = null) {
378
+        if (!$storage) {
379
+            $storage = $this;
380
+        }
381
+        if (!isset($storage->updater)) {
382
+            $storage->updater = new Updater($storage);
383
+        }
384
+        return $storage->updater;
385
+    }
386
+
387
+    public function getStorageCache($storage = null) {
388
+        if (!$storage) {
389
+            $storage = $this;
390
+        }
391
+        if (!isset($this->storageCache)) {
392
+            $this->storageCache = new \OC\Files\Cache\Storage($storage);
393
+        }
394
+        return $this->storageCache;
395
+    }
396
+
397
+    /**
398
+     * get the owner of a path
399
+     *
400
+     * @param string $path The path to get the owner
401
+     * @return string|false uid or false
402
+     */
403
+    public function getOwner($path) {
404
+        if ($this->owner === null) {
405
+            $this->owner = \OC_User::getUser();
406
+        }
407
+
408
+        return $this->owner;
409
+    }
410
+
411
+    /**
412
+     * get the ETag for a file or folder
413
+     *
414
+     * @param string $path
415
+     * @return string
416
+     */
417
+    public function getETag($path) {
418
+        return uniqid();
419
+    }
420
+
421
+    /**
422
+     * clean a path, i.e. remove all redundant '.' and '..'
423
+     * making sure that it can't point to higher than '/'
424
+     *
425
+     * @param string $path The path to clean
426
+     * @return string cleaned path
427
+     */
428
+    public function cleanPath($path) {
429
+        if (strlen($path) == 0 or $path[0] != '/') {
430
+            $path = '/' . $path;
431
+        }
432
+
433
+        $output = array();
434
+        foreach (explode('/', $path) as $chunk) {
435
+            if ($chunk == '..') {
436
+                array_pop($output);
437
+            } else if ($chunk == '.') {
438
+            } else {
439
+                $output[] = $chunk;
440
+            }
441
+        }
442
+        return implode('/', $output);
443
+    }
444
+
445
+    /**
446
+     * Test a storage for availability
447
+     *
448
+     * @return bool
449
+     */
450
+    public function test() {
451
+        try {
452
+            if ($this->stat('')) {
453
+                return true;
454
+            }
455
+            \OC::$server->getLogger()->info("External storage not available: stat() failed");
456
+            return false;
457
+        } catch (\Exception $e) {
458
+            \OC::$server->getLogger()->info("External storage not available: " . $e->getMessage());
459
+            \OC::$server->getLogger()->logException($e, ['level' => ILogger::DEBUG]);
460
+            return false;
461
+        }
462
+    }
463
+
464
+    /**
465
+     * get the free space in the storage
466
+     *
467
+     * @param string $path
468
+     * @return int|false
469
+     */
470
+    public function free_space($path) {
471
+        return \OCP\Files\FileInfo::SPACE_UNKNOWN;
472
+    }
473
+
474
+    /**
475
+     * {@inheritdoc}
476
+     */
477
+    public function isLocal() {
478
+        // the common implementation returns a temporary file by
479
+        // default, which is not local
480
+        return false;
481
+    }
482
+
483
+    /**
484
+     * Check if the storage is an instance of $class or is a wrapper for a storage that is an instance of $class
485
+     *
486
+     * @param string $class
487
+     * @return bool
488
+     */
489
+    public function instanceOfStorage($class) {
490
+        if (ltrim($class, '\\') === 'OC\Files\Storage\Shared') {
491
+            // FIXME Temporary fix to keep existing checks working
492
+            $class = '\OCA\Files_Sharing\SharedStorage';
493
+        }
494
+        return is_a($this, $class);
495
+    }
496
+
497
+    /**
498
+     * A custom storage implementation can return an url for direct download of a give file.
499
+     *
500
+     * For now the returned array can hold the parameter url - in future more attributes might follow.
501
+     *
502
+     * @param string $path
503
+     * @return array|false
504
+     */
505
+    public function getDirectDownload($path) {
506
+        return [];
507
+    }
508
+
509
+    /**
510
+     * @inheritdoc
511
+     * @throws InvalidPathException
512
+     */
513
+    public function verifyPath($path, $fileName) {
514
+
515
+        // verify empty and dot files
516
+        $trimmed = trim($fileName);
517
+        if ($trimmed === '') {
518
+            throw new EmptyFileNameException();
519
+        }
520
+
521
+        if (\OC\Files\Filesystem::isIgnoredDir($trimmed)) {
522
+            throw new InvalidDirectoryException();
523
+        }
524
+
525
+        if (!\OC::$server->getDatabaseConnection()->supports4ByteText()) {
526
+            // verify database - e.g. mysql only 3-byte chars
527
+            if (preg_match('%(?:
528 528
       \xF0[\x90-\xBF][\x80-\xBF]{2}      # planes 1-3
529 529
     | [\xF1-\xF3][\x80-\xBF]{3}          # planes 4-15
530 530
     | \xF4[\x80-\x8F][\x80-\xBF]{2}      # plane 16
531 531
 )%xs', $fileName)) {
532
-				throw new InvalidCharacterInPathException();
533
-			}
534
-		}
535
-
536
-		if (isset($fileName[255])) {
537
-			throw new FileNameTooLongException();
538
-		}
539
-
540
-		// NOTE: $path will remain unverified for now
541
-		$this->verifyPosixPath($fileName);
542
-	}
543
-
544
-	/**
545
-	 * @param string $fileName
546
-	 * @throws InvalidPathException
547
-	 */
548
-	protected function verifyPosixPath($fileName) {
549
-		$fileName = trim($fileName);
550
-		$this->scanForInvalidCharacters($fileName, "\\/");
551
-		$reservedNames = ['*'];
552
-		if (in_array($fileName, $reservedNames)) {
553
-			throw new ReservedWordException();
554
-		}
555
-	}
556
-
557
-	/**
558
-	 * @param string $fileName
559
-	 * @param string $invalidChars
560
-	 * @throws InvalidPathException
561
-	 */
562
-	private function scanForInvalidCharacters($fileName, $invalidChars) {
563
-		foreach (str_split($invalidChars) as $char) {
564
-			if (strpos($fileName, $char) !== false) {
565
-				throw new InvalidCharacterInPathException();
566
-			}
567
-		}
568
-
569
-		$sanitizedFileName = filter_var($fileName, FILTER_UNSAFE_RAW, FILTER_FLAG_STRIP_LOW);
570
-		if ($sanitizedFileName !== $fileName) {
571
-			throw new InvalidCharacterInPathException();
572
-		}
573
-	}
574
-
575
-	/**
576
-	 * @param array $options
577
-	 */
578
-	public function setMountOptions(array $options) {
579
-		$this->mountOptions = $options;
580
-	}
581
-
582
-	/**
583
-	 * @param string $name
584
-	 * @param mixed $default
585
-	 * @return mixed
586
-	 */
587
-	public function getMountOption($name, $default = null) {
588
-		return isset($this->mountOptions[$name]) ? $this->mountOptions[$name] : $default;
589
-	}
590
-
591
-	/**
592
-	 * @param IStorage $sourceStorage
593
-	 * @param string $sourceInternalPath
594
-	 * @param string $targetInternalPath
595
-	 * @param bool $preserveMtime
596
-	 * @return bool
597
-	 */
598
-	public function copyFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath, $preserveMtime = false) {
599
-		if ($sourceStorage === $this) {
600
-			return $this->copy($sourceInternalPath, $targetInternalPath);
601
-		}
602
-
603
-		if ($sourceStorage->is_dir($sourceInternalPath)) {
604
-			$dh = $sourceStorage->opendir($sourceInternalPath);
605
-			$result = $this->mkdir($targetInternalPath);
606
-			if (is_resource($dh)) {
607
-				while ($result and ($file = readdir($dh)) !== false) {
608
-					if (!Filesystem::isIgnoredDir($file)) {
609
-						$result &= $this->copyFromStorage($sourceStorage, $sourceInternalPath . '/' . $file, $targetInternalPath . '/' . $file);
610
-					}
611
-				}
612
-			}
613
-		} else {
614
-			$source = $sourceStorage->fopen($sourceInternalPath, 'r');
615
-			// TODO: call fopen in a way that we execute again all storage wrappers
616
-			// to avoid that we bypass storage wrappers which perform important actions
617
-			// for this operation. Same is true for all other operations which
618
-			// are not the same as the original one.Once this is fixed we also
619
-			// need to adjust the encryption wrapper.
620
-			$target = $this->fopen($targetInternalPath, 'w');
621
-			list(, $result) = \OC_Helper::streamCopy($source, $target);
622
-			if ($result and $preserveMtime) {
623
-				$this->touch($targetInternalPath, $sourceStorage->filemtime($sourceInternalPath));
624
-			}
625
-			fclose($source);
626
-			fclose($target);
627
-
628
-			if (!$result) {
629
-				// delete partially written target file
630
-				$this->unlink($targetInternalPath);
631
-				// delete cache entry that was created by fopen
632
-				$this->getCache()->remove($targetInternalPath);
633
-			}
634
-		}
635
-		return (bool)$result;
636
-	}
637
-
638
-	/**
639
-	 * @param IStorage $sourceStorage
640
-	 * @param string $sourceInternalPath
641
-	 * @param string $targetInternalPath
642
-	 * @return bool
643
-	 */
644
-	public function moveFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath) {
645
-		if ($sourceStorage === $this) {
646
-			return $this->rename($sourceInternalPath, $targetInternalPath);
647
-		}
648
-
649
-		if (!$sourceStorage->isDeletable($sourceInternalPath)) {
650
-			return false;
651
-		}
652
-
653
-		$result = $this->copyFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath, true);
654
-		if ($result) {
655
-			if ($sourceStorage->is_dir($sourceInternalPath)) {
656
-				$result &= $sourceStorage->rmdir($sourceInternalPath);
657
-			} else {
658
-				$result &= $sourceStorage->unlink($sourceInternalPath);
659
-			}
660
-		}
661
-		return $result;
662
-	}
663
-
664
-	/**
665
-	 * @inheritdoc
666
-	 */
667
-	public function getMetaData($path) {
668
-		$permissions = $this->getPermissions($path);
669
-		if (!$permissions & \OCP\Constants::PERMISSION_READ) {
670
-			//can't read, nothing we can do
671
-			return null;
672
-		}
673
-
674
-		$data = [];
675
-		$data['mimetype'] = $this->getMimeType($path);
676
-		$data['mtime'] = $this->filemtime($path);
677
-		if ($data['mtime'] === false) {
678
-			$data['mtime'] = time();
679
-		}
680
-		if ($data['mimetype'] == 'httpd/unix-directory') {
681
-			$data['size'] = -1; //unknown
682
-		} else {
683
-			$data['size'] = $this->filesize($path);
684
-		}
685
-		$data['etag'] = $this->getETag($path);
686
-		$data['storage_mtime'] = $data['mtime'];
687
-		$data['permissions'] = $permissions;
688
-
689
-		return $data;
690
-	}
691
-
692
-	/**
693
-	 * @param string $path
694
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
695
-	 * @param \OCP\Lock\ILockingProvider $provider
696
-	 * @throws \OCP\Lock\LockedException
697
-	 */
698
-	public function acquireLock($path, $type, ILockingProvider $provider) {
699
-		$logger = $this->getLockLogger();
700
-		if ($logger) {
701
-			$typeString = ($type === ILockingProvider::LOCK_SHARED) ? 'shared' : 'exclusive';
702
-			$logger->info(
703
-				sprintf(
704
-					'acquire %s lock on "%s" on storage "%s"',
705
-					$typeString,
706
-					$path,
707
-					$this->getId()
708
-				),
709
-				[
710
-					'app' => 'locking',
711
-				]
712
-			);
713
-		}
714
-		try {
715
-			$provider->acquireLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
716
-		} catch (LockedException $e) {
717
-			if ($logger) {
718
-				$logger->logException($e);
719
-			}
720
-			throw $e;
721
-		}
722
-	}
723
-
724
-	/**
725
-	 * @param string $path
726
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
727
-	 * @param \OCP\Lock\ILockingProvider $provider
728
-	 * @throws \OCP\Lock\LockedException
729
-	 */
730
-	public function releaseLock($path, $type, ILockingProvider $provider) {
731
-		$logger = $this->getLockLogger();
732
-		if ($logger) {
733
-			$typeString = ($type === ILockingProvider::LOCK_SHARED) ? 'shared' : 'exclusive';
734
-			$logger->info(
735
-				sprintf(
736
-					'release %s lock on "%s" on storage "%s"',
737
-					$typeString,
738
-					$path,
739
-					$this->getId()
740
-				),
741
-				[
742
-					'app' => 'locking',
743
-				]
744
-			);
745
-		}
746
-		try {
747
-			$provider->releaseLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
748
-		} catch (LockedException $e) {
749
-			if ($logger) {
750
-				$logger->logException($e);
751
-			}
752
-			throw $e;
753
-		}
754
-	}
755
-
756
-	/**
757
-	 * @param string $path
758
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
759
-	 * @param \OCP\Lock\ILockingProvider $provider
760
-	 * @throws \OCP\Lock\LockedException
761
-	 */
762
-	public function changeLock($path, $type, ILockingProvider $provider) {
763
-		$logger = $this->getLockLogger();
764
-		if ($logger) {
765
-			$typeString = ($type === ILockingProvider::LOCK_SHARED) ? 'shared' : 'exclusive';
766
-			$logger->info(
767
-				sprintf(
768
-					'change lock on "%s" to %s on storage "%s"',
769
-					$path,
770
-					$typeString,
771
-					$this->getId()
772
-				),
773
-				[
774
-					'app' => 'locking',
775
-				]
776
-			);
777
-		}
778
-		try {
779
-			$provider->changeLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
780
-		} catch (LockedException $e) {
781
-			\OC::$server->getLogger()->logException($e);
782
-			throw $e;
783
-		}
784
-	}
785
-
786
-	private function getLockLogger() {
787
-		if (is_null($this->shouldLogLocks)) {
788
-			$this->shouldLogLocks = \OC::$server->getConfig()->getSystemValue('filelocking.debug', false);
789
-			$this->logger = $this->shouldLogLocks ? \OC::$server->getLogger() : null;
790
-		}
791
-		return $this->logger;
792
-	}
793
-
794
-	/**
795
-	 * @return array [ available, last_checked ]
796
-	 */
797
-	public function getAvailability() {
798
-		return $this->getStorageCache()->getAvailability();
799
-	}
800
-
801
-	/**
802
-	 * @param bool $isAvailable
803
-	 */
804
-	public function setAvailability($isAvailable) {
805
-		$this->getStorageCache()->setAvailability($isAvailable);
806
-	}
807
-
808
-	/**
809
-	 * @return bool
810
-	 */
811
-	public function needsPartFile() {
812
-		return true;
813
-	}
814
-
815
-	/**
816
-	 * fallback implementation
817
-	 *
818
-	 * @param string $path
819
-	 * @param resource $stream
820
-	 * @param int $size
821
-	 * @return int
822
-	 */
823
-	public function writeStream(string $path, $stream, int $size = null): int {
824
-		$target = $this->fopen($path, 'w');
825
-		if (!$target) {
826
-			return 0;
827
-		}
828
-		list($count, $result) = \OC_Helper::streamCopy($stream, $target);
829
-		fclose($stream);
830
-		fclose($target);
831
-		return $count;
832
-	}
532
+                throw new InvalidCharacterInPathException();
533
+            }
534
+        }
535
+
536
+        if (isset($fileName[255])) {
537
+            throw new FileNameTooLongException();
538
+        }
539
+
540
+        // NOTE: $path will remain unverified for now
541
+        $this->verifyPosixPath($fileName);
542
+    }
543
+
544
+    /**
545
+     * @param string $fileName
546
+     * @throws InvalidPathException
547
+     */
548
+    protected function verifyPosixPath($fileName) {
549
+        $fileName = trim($fileName);
550
+        $this->scanForInvalidCharacters($fileName, "\\/");
551
+        $reservedNames = ['*'];
552
+        if (in_array($fileName, $reservedNames)) {
553
+            throw new ReservedWordException();
554
+        }
555
+    }
556
+
557
+    /**
558
+     * @param string $fileName
559
+     * @param string $invalidChars
560
+     * @throws InvalidPathException
561
+     */
562
+    private function scanForInvalidCharacters($fileName, $invalidChars) {
563
+        foreach (str_split($invalidChars) as $char) {
564
+            if (strpos($fileName, $char) !== false) {
565
+                throw new InvalidCharacterInPathException();
566
+            }
567
+        }
568
+
569
+        $sanitizedFileName = filter_var($fileName, FILTER_UNSAFE_RAW, FILTER_FLAG_STRIP_LOW);
570
+        if ($sanitizedFileName !== $fileName) {
571
+            throw new InvalidCharacterInPathException();
572
+        }
573
+    }
574
+
575
+    /**
576
+     * @param array $options
577
+     */
578
+    public function setMountOptions(array $options) {
579
+        $this->mountOptions = $options;
580
+    }
581
+
582
+    /**
583
+     * @param string $name
584
+     * @param mixed $default
585
+     * @return mixed
586
+     */
587
+    public function getMountOption($name, $default = null) {
588
+        return isset($this->mountOptions[$name]) ? $this->mountOptions[$name] : $default;
589
+    }
590
+
591
+    /**
592
+     * @param IStorage $sourceStorage
593
+     * @param string $sourceInternalPath
594
+     * @param string $targetInternalPath
595
+     * @param bool $preserveMtime
596
+     * @return bool
597
+     */
598
+    public function copyFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath, $preserveMtime = false) {
599
+        if ($sourceStorage === $this) {
600
+            return $this->copy($sourceInternalPath, $targetInternalPath);
601
+        }
602
+
603
+        if ($sourceStorage->is_dir($sourceInternalPath)) {
604
+            $dh = $sourceStorage->opendir($sourceInternalPath);
605
+            $result = $this->mkdir($targetInternalPath);
606
+            if (is_resource($dh)) {
607
+                while ($result and ($file = readdir($dh)) !== false) {
608
+                    if (!Filesystem::isIgnoredDir($file)) {
609
+                        $result &= $this->copyFromStorage($sourceStorage, $sourceInternalPath . '/' . $file, $targetInternalPath . '/' . $file);
610
+                    }
611
+                }
612
+            }
613
+        } else {
614
+            $source = $sourceStorage->fopen($sourceInternalPath, 'r');
615
+            // TODO: call fopen in a way that we execute again all storage wrappers
616
+            // to avoid that we bypass storage wrappers which perform important actions
617
+            // for this operation. Same is true for all other operations which
618
+            // are not the same as the original one.Once this is fixed we also
619
+            // need to adjust the encryption wrapper.
620
+            $target = $this->fopen($targetInternalPath, 'w');
621
+            list(, $result) = \OC_Helper::streamCopy($source, $target);
622
+            if ($result and $preserveMtime) {
623
+                $this->touch($targetInternalPath, $sourceStorage->filemtime($sourceInternalPath));
624
+            }
625
+            fclose($source);
626
+            fclose($target);
627
+
628
+            if (!$result) {
629
+                // delete partially written target file
630
+                $this->unlink($targetInternalPath);
631
+                // delete cache entry that was created by fopen
632
+                $this->getCache()->remove($targetInternalPath);
633
+            }
634
+        }
635
+        return (bool)$result;
636
+    }
637
+
638
+    /**
639
+     * @param IStorage $sourceStorage
640
+     * @param string $sourceInternalPath
641
+     * @param string $targetInternalPath
642
+     * @return bool
643
+     */
644
+    public function moveFromStorage(IStorage $sourceStorage, $sourceInternalPath, $targetInternalPath) {
645
+        if ($sourceStorage === $this) {
646
+            return $this->rename($sourceInternalPath, $targetInternalPath);
647
+        }
648
+
649
+        if (!$sourceStorage->isDeletable($sourceInternalPath)) {
650
+            return false;
651
+        }
652
+
653
+        $result = $this->copyFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath, true);
654
+        if ($result) {
655
+            if ($sourceStorage->is_dir($sourceInternalPath)) {
656
+                $result &= $sourceStorage->rmdir($sourceInternalPath);
657
+            } else {
658
+                $result &= $sourceStorage->unlink($sourceInternalPath);
659
+            }
660
+        }
661
+        return $result;
662
+    }
663
+
664
+    /**
665
+     * @inheritdoc
666
+     */
667
+    public function getMetaData($path) {
668
+        $permissions = $this->getPermissions($path);
669
+        if (!$permissions & \OCP\Constants::PERMISSION_READ) {
670
+            //can't read, nothing we can do
671
+            return null;
672
+        }
673
+
674
+        $data = [];
675
+        $data['mimetype'] = $this->getMimeType($path);
676
+        $data['mtime'] = $this->filemtime($path);
677
+        if ($data['mtime'] === false) {
678
+            $data['mtime'] = time();
679
+        }
680
+        if ($data['mimetype'] == 'httpd/unix-directory') {
681
+            $data['size'] = -1; //unknown
682
+        } else {
683
+            $data['size'] = $this->filesize($path);
684
+        }
685
+        $data['etag'] = $this->getETag($path);
686
+        $data['storage_mtime'] = $data['mtime'];
687
+        $data['permissions'] = $permissions;
688
+
689
+        return $data;
690
+    }
691
+
692
+    /**
693
+     * @param string $path
694
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
695
+     * @param \OCP\Lock\ILockingProvider $provider
696
+     * @throws \OCP\Lock\LockedException
697
+     */
698
+    public function acquireLock($path, $type, ILockingProvider $provider) {
699
+        $logger = $this->getLockLogger();
700
+        if ($logger) {
701
+            $typeString = ($type === ILockingProvider::LOCK_SHARED) ? 'shared' : 'exclusive';
702
+            $logger->info(
703
+                sprintf(
704
+                    'acquire %s lock on "%s" on storage "%s"',
705
+                    $typeString,
706
+                    $path,
707
+                    $this->getId()
708
+                ),
709
+                [
710
+                    'app' => 'locking',
711
+                ]
712
+            );
713
+        }
714
+        try {
715
+            $provider->acquireLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
716
+        } catch (LockedException $e) {
717
+            if ($logger) {
718
+                $logger->logException($e);
719
+            }
720
+            throw $e;
721
+        }
722
+    }
723
+
724
+    /**
725
+     * @param string $path
726
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
727
+     * @param \OCP\Lock\ILockingProvider $provider
728
+     * @throws \OCP\Lock\LockedException
729
+     */
730
+    public function releaseLock($path, $type, ILockingProvider $provider) {
731
+        $logger = $this->getLockLogger();
732
+        if ($logger) {
733
+            $typeString = ($type === ILockingProvider::LOCK_SHARED) ? 'shared' : 'exclusive';
734
+            $logger->info(
735
+                sprintf(
736
+                    'release %s lock on "%s" on storage "%s"',
737
+                    $typeString,
738
+                    $path,
739
+                    $this->getId()
740
+                ),
741
+                [
742
+                    'app' => 'locking',
743
+                ]
744
+            );
745
+        }
746
+        try {
747
+            $provider->releaseLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
748
+        } catch (LockedException $e) {
749
+            if ($logger) {
750
+                $logger->logException($e);
751
+            }
752
+            throw $e;
753
+        }
754
+    }
755
+
756
+    /**
757
+     * @param string $path
758
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
759
+     * @param \OCP\Lock\ILockingProvider $provider
760
+     * @throws \OCP\Lock\LockedException
761
+     */
762
+    public function changeLock($path, $type, ILockingProvider $provider) {
763
+        $logger = $this->getLockLogger();
764
+        if ($logger) {
765
+            $typeString = ($type === ILockingProvider::LOCK_SHARED) ? 'shared' : 'exclusive';
766
+            $logger->info(
767
+                sprintf(
768
+                    'change lock on "%s" to %s on storage "%s"',
769
+                    $path,
770
+                    $typeString,
771
+                    $this->getId()
772
+                ),
773
+                [
774
+                    'app' => 'locking',
775
+                ]
776
+            );
777
+        }
778
+        try {
779
+            $provider->changeLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
780
+        } catch (LockedException $e) {
781
+            \OC::$server->getLogger()->logException($e);
782
+            throw $e;
783
+        }
784
+    }
785
+
786
+    private function getLockLogger() {
787
+        if (is_null($this->shouldLogLocks)) {
788
+            $this->shouldLogLocks = \OC::$server->getConfig()->getSystemValue('filelocking.debug', false);
789
+            $this->logger = $this->shouldLogLocks ? \OC::$server->getLogger() : null;
790
+        }
791
+        return $this->logger;
792
+    }
793
+
794
+    /**
795
+     * @return array [ available, last_checked ]
796
+     */
797
+    public function getAvailability() {
798
+        return $this->getStorageCache()->getAvailability();
799
+    }
800
+
801
+    /**
802
+     * @param bool $isAvailable
803
+     */
804
+    public function setAvailability($isAvailable) {
805
+        $this->getStorageCache()->setAvailability($isAvailable);
806
+    }
807
+
808
+    /**
809
+     * @return bool
810
+     */
811
+    public function needsPartFile() {
812
+        return true;
813
+    }
814
+
815
+    /**
816
+     * fallback implementation
817
+     *
818
+     * @param string $path
819
+     * @param resource $stream
820
+     * @param int $size
821
+     * @return int
822
+     */
823
+    public function writeStream(string $path, $stream, int $size = null): int {
824
+        $target = $this->fopen($path, 'w');
825
+        if (!$target) {
826
+            return 0;
827
+        }
828
+        list($count, $result) = \OC_Helper::streamCopy($stream, $target);
829
+        fclose($stream);
830
+        fclose($target);
831
+        return $count;
832
+    }
833 833
 }
Please login to merge, or discard this patch.
Spacing   +18 added lines, -18 removed lines patch added patch discarded remove patch
@@ -220,7 +220,7 @@  discard block
 block discarded – undo
220 220
 			$this->mkdir($path2);
221 221
 			while ($file = readdir($dir)) {
222 222
 				if (!Filesystem::isIgnoredDir($file)) {
223
-					if (!$this->copy($path1 . '/' . $file, $path2 . '/' . $file)) {
223
+					if (!$this->copy($path1.'/'.$file, $path2.'/'.$file)) {
224 224
 						return false;
225 225
 					}
226 226
 				}
@@ -274,12 +274,12 @@  discard block
 block discarded – undo
274 274
 		if (is_resource($dh)) {
275 275
 			while (($file = readdir($dh)) !== false) {
276 276
 				if (!\OC\Files\Filesystem::isIgnoredDir($file)) {
277
-					if ($this->is_dir($path . '/' . $file)) {
278
-						mkdir($target . '/' . $file);
279
-						$this->addLocalFolder($path . '/' . $file, $target . '/' . $file);
277
+					if ($this->is_dir($path.'/'.$file)) {
278
+						mkdir($target.'/'.$file);
279
+						$this->addLocalFolder($path.'/'.$file, $target.'/'.$file);
280 280
 					} else {
281
-						$tmp = $this->toTmpFile($path . '/' . $file);
282
-						rename($tmp, $target . '/' . $file);
281
+						$tmp = $this->toTmpFile($path.'/'.$file);
282
+						rename($tmp, $target.'/'.$file);
283 283
 					}
284 284
 				}
285 285
 			}
@@ -298,10 +298,10 @@  discard block
 block discarded – undo
298 298
 			while (($item = readdir($dh)) !== false) {
299 299
 				if (\OC\Files\Filesystem::isIgnoredDir($item)) continue;
300 300
 				if (strstr(strtolower($item), strtolower($query)) !== false) {
301
-					$files[] = $dir . '/' . $item;
301
+					$files[] = $dir.'/'.$item;
302 302
 				}
303
-				if ($this->is_dir($dir . '/' . $item)) {
304
-					$files = array_merge($files, $this->searchInDir($query, $dir . '/' . $item));
303
+				if ($this->is_dir($dir.'/'.$item)) {
304
+					$files = array_merge($files, $this->searchInDir($query, $dir.'/'.$item));
305 305
 				}
306 306
 			}
307 307
 		}
@@ -352,7 +352,7 @@  discard block
 block discarded – undo
352 352
 		if (!isset($this->watcher)) {
353 353
 			$this->watcher = new Watcher($storage);
354 354
 			$globalPolicy = \OC::$server->getConfig()->getSystemValue('filesystem_check_changes', Watcher::CHECK_NEVER);
355
-			$this->watcher->setPolicy((int)$this->getMountOption('filesystem_check_changes', $globalPolicy));
355
+			$this->watcher->setPolicy((int) $this->getMountOption('filesystem_check_changes', $globalPolicy));
356 356
 		}
357 357
 		return $this->watcher;
358 358
 	}
@@ -369,7 +369,7 @@  discard block
 block discarded – undo
369 369
 		}
370 370
 		if (!isset($storage->propagator)) {
371 371
 			$config = \OC::$server->getSystemConfig();
372
-			$storage->propagator = new Propagator($storage, \OC::$server->getDatabaseConnection(), ['appdata_' . $config->getValue('instanceid')]);
372
+			$storage->propagator = new Propagator($storage, \OC::$server->getDatabaseConnection(), ['appdata_'.$config->getValue('instanceid')]);
373 373
 		}
374 374
 		return $storage->propagator;
375 375
 	}
@@ -427,7 +427,7 @@  discard block
 block discarded – undo
427 427
 	 */
428 428
 	public function cleanPath($path) {
429 429
 		if (strlen($path) == 0 or $path[0] != '/') {
430
-			$path = '/' . $path;
430
+			$path = '/'.$path;
431 431
 		}
432 432
 
433 433
 		$output = array();
@@ -455,7 +455,7 @@  discard block
 block discarded – undo
455 455
 			\OC::$server->getLogger()->info("External storage not available: stat() failed");
456 456
 			return false;
457 457
 		} catch (\Exception $e) {
458
-			\OC::$server->getLogger()->info("External storage not available: " . $e->getMessage());
458
+			\OC::$server->getLogger()->info("External storage not available: ".$e->getMessage());
459 459
 			\OC::$server->getLogger()->logException($e, ['level' => ILogger::DEBUG]);
460 460
 			return false;
461 461
 		}
@@ -606,7 +606,7 @@  discard block
 block discarded – undo
606 606
 			if (is_resource($dh)) {
607 607
 				while ($result and ($file = readdir($dh)) !== false) {
608 608
 					if (!Filesystem::isIgnoredDir($file)) {
609
-						$result &= $this->copyFromStorage($sourceStorage, $sourceInternalPath . '/' . $file, $targetInternalPath . '/' . $file);
609
+						$result &= $this->copyFromStorage($sourceStorage, $sourceInternalPath.'/'.$file, $targetInternalPath.'/'.$file);
610 610
 					}
611 611
 				}
612 612
 			}
@@ -632,7 +632,7 @@  discard block
 block discarded – undo
632 632
 				$this->getCache()->remove($targetInternalPath);
633 633
 			}
634 634
 		}
635
-		return (bool)$result;
635
+		return (bool) $result;
636 636
 	}
637 637
 
638 638
 	/**
@@ -712,7 +712,7 @@  discard block
 block discarded – undo
712 712
 			);
713 713
 		}
714 714
 		try {
715
-			$provider->acquireLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
715
+			$provider->acquireLock('files/'.md5($this->getId().'::'.trim($path, '/')), $type);
716 716
 		} catch (LockedException $e) {
717 717
 			if ($logger) {
718 718
 				$logger->logException($e);
@@ -744,7 +744,7 @@  discard block
 block discarded – undo
744 744
 			);
745 745
 		}
746 746
 		try {
747
-			$provider->releaseLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
747
+			$provider->releaseLock('files/'.md5($this->getId().'::'.trim($path, '/')), $type);
748 748
 		} catch (LockedException $e) {
749 749
 			if ($logger) {
750 750
 				$logger->logException($e);
@@ -776,7 +776,7 @@  discard block
 block discarded – undo
776 776
 			);
777 777
 		}
778 778
 		try {
779
-			$provider->changeLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
779
+			$provider->changeLock('files/'.md5($this->getId().'::'.trim($path, '/')), $type);
780 780
 		} catch (LockedException $e) {
781 781
 			\OC::$server->getLogger()->logException($e);
782 782
 			throw $e;
Please login to merge, or discard this patch.
lib/private/Files/Storage/StorageFactory.php 2 patches
Indentation   +70 added lines, -70 removed lines patch added patch discarded remove patch
@@ -29,80 +29,80 @@
 block discarded – undo
29 29
 use OCP\Files\Storage\IStorageFactory;
30 30
 
31 31
 class StorageFactory implements IStorageFactory {
32
-	/**
33
-	 * @var array[] [$name=>['priority'=>$priority, 'wrapper'=>$callable] $storageWrappers
34
-	 */
35
-	private $storageWrappers = [];
32
+    /**
33
+     * @var array[] [$name=>['priority'=>$priority, 'wrapper'=>$callable] $storageWrappers
34
+     */
35
+    private $storageWrappers = [];
36 36
 
37
-	/**
38
-	 * allow modifier storage behaviour by adding wrappers around storages
39
-	 *
40
-	 * $callback should be a function of type (string $mountPoint, Storage $storage) => Storage
41
-	 *
42
-	 * @param string $wrapperName name of the wrapper
43
-	 * @param callable $callback callback
44
-	 * @param int $priority wrappers with the lower priority are applied last (meaning they get called first)
45
-	 * @param \OCP\Files\Mount\IMountPoint[] $existingMounts existing mount points to apply the wrapper to
46
-	 * @return bool true if the wrapper was added, false if there was already a wrapper with this
47
-	 * name registered
48
-	 */
49
-	public function addStorageWrapper($wrapperName, $callback, $priority = 50, $existingMounts = []) {
50
-		if (isset($this->storageWrappers[$wrapperName])) {
51
-			return false;
52
-		}
37
+    /**
38
+     * allow modifier storage behaviour by adding wrappers around storages
39
+     *
40
+     * $callback should be a function of type (string $mountPoint, Storage $storage) => Storage
41
+     *
42
+     * @param string $wrapperName name of the wrapper
43
+     * @param callable $callback callback
44
+     * @param int $priority wrappers with the lower priority are applied last (meaning they get called first)
45
+     * @param \OCP\Files\Mount\IMountPoint[] $existingMounts existing mount points to apply the wrapper to
46
+     * @return bool true if the wrapper was added, false if there was already a wrapper with this
47
+     * name registered
48
+     */
49
+    public function addStorageWrapper($wrapperName, $callback, $priority = 50, $existingMounts = []) {
50
+        if (isset($this->storageWrappers[$wrapperName])) {
51
+            return false;
52
+        }
53 53
 
54
-		// apply to existing mounts before registering it to prevent applying it double in MountPoint::createStorage
55
-		foreach ($existingMounts as $mount) {
56
-			$mount->wrapStorage($callback);
57
-		}
54
+        // apply to existing mounts before registering it to prevent applying it double in MountPoint::createStorage
55
+        foreach ($existingMounts as $mount) {
56
+            $mount->wrapStorage($callback);
57
+        }
58 58
 
59
-		$this->storageWrappers[$wrapperName] = ['wrapper' => $callback, 'priority' => $priority];
60
-		return true;
61
-	}
59
+        $this->storageWrappers[$wrapperName] = ['wrapper' => $callback, 'priority' => $priority];
60
+        return true;
61
+    }
62 62
 
63
-	/**
64
-	 * Remove a storage wrapper by name.
65
-	 * Note: internal method only to be used for cleanup
66
-	 *
67
-	 * @param string $wrapperName name of the wrapper
68
-	 * @internal
69
-	 */
70
-	public function removeStorageWrapper($wrapperName) {
71
-		unset($this->storageWrappers[$wrapperName]);
72
-	}
63
+    /**
64
+     * Remove a storage wrapper by name.
65
+     * Note: internal method only to be used for cleanup
66
+     *
67
+     * @param string $wrapperName name of the wrapper
68
+     * @internal
69
+     */
70
+    public function removeStorageWrapper($wrapperName) {
71
+        unset($this->storageWrappers[$wrapperName]);
72
+    }
73 73
 
74
-	/**
75
-	 * Create an instance of a storage and apply the registered storage wrappers
76
-	 *
77
-	 * @param \OCP\Files\Mount\IMountPoint $mountPoint
78
-	 * @param string $class
79
-	 * @param array $arguments
80
-	 * @return \OCP\Files\Storage
81
-	 */
82
-	public function getInstance(IMountPoint $mountPoint, $class, $arguments) {
83
-		return $this->wrap($mountPoint, new $class($arguments));
84
-	}
74
+    /**
75
+     * Create an instance of a storage and apply the registered storage wrappers
76
+     *
77
+     * @param \OCP\Files\Mount\IMountPoint $mountPoint
78
+     * @param string $class
79
+     * @param array $arguments
80
+     * @return \OCP\Files\Storage
81
+     */
82
+    public function getInstance(IMountPoint $mountPoint, $class, $arguments) {
83
+        return $this->wrap($mountPoint, new $class($arguments));
84
+    }
85 85
 
86
-	/**
87
-	 * @param \OCP\Files\Mount\IMountPoint $mountPoint
88
-	 * @param \OCP\Files\Storage $storage
89
-	 * @return \OCP\Files\Storage
90
-	 */
91
-	public function wrap(IMountPoint $mountPoint, $storage) {
92
-		$wrappers = array_values($this->storageWrappers);
93
-		usort($wrappers, function ($a, $b) {
94
-			return $b['priority'] - $a['priority'];
95
-		});
96
-		/** @var callable[] $wrappers */
97
-		$wrappers = array_map(function ($wrapper) {
98
-			return $wrapper['wrapper'];
99
-		}, $wrappers);
100
-		foreach ($wrappers as $wrapper) {
101
-			$storage = $wrapper($mountPoint->getMountPoint(), $storage, $mountPoint);
102
-			if (!($storage instanceof \OCP\Files\Storage)) {
103
-				throw new \Exception('Invalid result from storage wrapper');
104
-			}
105
-		}
106
-		return $storage;
107
-	}
86
+    /**
87
+     * @param \OCP\Files\Mount\IMountPoint $mountPoint
88
+     * @param \OCP\Files\Storage $storage
89
+     * @return \OCP\Files\Storage
90
+     */
91
+    public function wrap(IMountPoint $mountPoint, $storage) {
92
+        $wrappers = array_values($this->storageWrappers);
93
+        usort($wrappers, function ($a, $b) {
94
+            return $b['priority'] - $a['priority'];
95
+        });
96
+        /** @var callable[] $wrappers */
97
+        $wrappers = array_map(function ($wrapper) {
98
+            return $wrapper['wrapper'];
99
+        }, $wrappers);
100
+        foreach ($wrappers as $wrapper) {
101
+            $storage = $wrapper($mountPoint->getMountPoint(), $storage, $mountPoint);
102
+            if (!($storage instanceof \OCP\Files\Storage)) {
103
+                throw new \Exception('Invalid result from storage wrapper');
104
+            }
105
+        }
106
+        return $storage;
107
+    }
108 108
 }
Please login to merge, or discard this patch.
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -90,11 +90,11 @@
 block discarded – undo
90 90
 	 */
91 91
 	public function wrap(IMountPoint $mountPoint, $storage) {
92 92
 		$wrappers = array_values($this->storageWrappers);
93
-		usort($wrappers, function ($a, $b) {
93
+		usort($wrappers, function($a, $b) {
94 94
 			return $b['priority'] - $a['priority'];
95 95
 		});
96 96
 		/** @var callable[] $wrappers */
97
-		$wrappers = array_map(function ($wrapper) {
97
+		$wrappers = array_map(function($wrapper) {
98 98
 			return $wrapper['wrapper'];
99 99
 		}, $wrappers);
100 100
 		foreach ($wrappers as $wrapper) {
Please login to merge, or discard this patch.
lib/private/Files/Storage/PolyFill/CopyDirectory.php 2 patches
Indentation   +71 added lines, -71 removed lines patch added patch discarded remove patch
@@ -25,81 +25,81 @@
 block discarded – undo
25 25
 namespace OC\Files\Storage\PolyFill;
26 26
 
27 27
 trait CopyDirectory {
28
-	/**
29
-	 * Check if a path is a directory
30
-	 *
31
-	 * @param string $path
32
-	 * @return bool
33
-	 */
34
-	abstract public function is_dir($path);
28
+    /**
29
+     * Check if a path is a directory
30
+     *
31
+     * @param string $path
32
+     * @return bool
33
+     */
34
+    abstract public function is_dir($path);
35 35
 
36
-	/**
37
-	 * Check if a file or folder exists
38
-	 *
39
-	 * @param string $path
40
-	 * @return bool
41
-	 */
42
-	abstract public function file_exists($path);
36
+    /**
37
+     * Check if a file or folder exists
38
+     *
39
+     * @param string $path
40
+     * @return bool
41
+     */
42
+    abstract public function file_exists($path);
43 43
 
44
-	/**
45
-	 * Delete a file or folder
46
-	 *
47
-	 * @param string $path
48
-	 * @return bool
49
-	 */
50
-	abstract public function unlink($path);
44
+    /**
45
+     * Delete a file or folder
46
+     *
47
+     * @param string $path
48
+     * @return bool
49
+     */
50
+    abstract public function unlink($path);
51 51
 
52
-	/**
53
-	 * Open a directory handle for a folder
54
-	 *
55
-	 * @param string $path
56
-	 * @return resource | bool
57
-	 */
58
-	abstract public function opendir($path);
52
+    /**
53
+     * Open a directory handle for a folder
54
+     *
55
+     * @param string $path
56
+     * @return resource | bool
57
+     */
58
+    abstract public function opendir($path);
59 59
 
60
-	/**
61
-	 * Create a new folder
62
-	 *
63
-	 * @param string $path
64
-	 * @return bool
65
-	 */
66
-	abstract public function mkdir($path);
60
+    /**
61
+     * Create a new folder
62
+     *
63
+     * @param string $path
64
+     * @return bool
65
+     */
66
+    abstract public function mkdir($path);
67 67
 
68
-	public function copy($source, $target) {
69
-		if ($this->is_dir($source)) {
70
-			if ($this->file_exists($target)) {
71
-				$this->unlink($target);
72
-			}
73
-			$this->mkdir($target);
74
-			return $this->copyRecursive($source, $target);
75
-		} else {
76
-			return parent::copy($source, $target);
77
-		}
78
-	}
68
+    public function copy($source, $target) {
69
+        if ($this->is_dir($source)) {
70
+            if ($this->file_exists($target)) {
71
+                $this->unlink($target);
72
+            }
73
+            $this->mkdir($target);
74
+            return $this->copyRecursive($source, $target);
75
+        } else {
76
+            return parent::copy($source, $target);
77
+        }
78
+    }
79 79
 
80
-	/**
81
-	 * For adapters that don't support copying folders natively
82
-	 *
83
-	 * @param $source
84
-	 * @param $target
85
-	 * @return bool
86
-	 */
87
-	protected function copyRecursive($source, $target) {
88
-		$dh = $this->opendir($source);
89
-		$result = true;
90
-		while ($file = readdir($dh)) {
91
-			if (!\OC\Files\Filesystem::isIgnoredDir($file)) {
92
-				if ($this->is_dir($source . '/' . $file)) {
93
-					$this->mkdir($target . '/' . $file);
94
-					$result = $this->copyRecursive($source . '/' . $file, $target . '/' . $file);
95
-				} else {
96
-					$result = parent::copy($source . '/' . $file, $target . '/' . $file);
97
-				}
98
-				if (!$result) {
99
-					break;
100
-				}
101
-			}
102
-		}
103
-		return $result;
104
-	}
80
+    /**
81
+     * For adapters that don't support copying folders natively
82
+     *
83
+     * @param $source
84
+     * @param $target
85
+     * @return bool
86
+     */
87
+    protected function copyRecursive($source, $target) {
88
+        $dh = $this->opendir($source);
89
+        $result = true;
90
+        while ($file = readdir($dh)) {
91
+            if (!\OC\Files\Filesystem::isIgnoredDir($file)) {
92
+                if ($this->is_dir($source . '/' . $file)) {
93
+                    $this->mkdir($target . '/' . $file);
94
+                    $result = $this->copyRecursive($source . '/' . $file, $target . '/' . $file);
95
+                } else {
96
+                    $result = parent::copy($source . '/' . $file, $target . '/' . $file);
97
+                }
98
+                if (!$result) {
99
+                    break;
100
+                }
101
+            }
102
+        }
103
+        return $result;
104
+    }
105 105
 }
Please login to merge, or discard this patch.
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -89,11 +89,11 @@
 block discarded – undo
89 89
 		$result = true;
90 90
 		while ($file = readdir($dh)) {
91 91
 			if (!\OC\Files\Filesystem::isIgnoredDir($file)) {
92
-				if ($this->is_dir($source . '/' . $file)) {
93
-					$this->mkdir($target . '/' . $file);
94
-					$result = $this->copyRecursive($source . '/' . $file, $target . '/' . $file);
92
+				if ($this->is_dir($source.'/'.$file)) {
93
+					$this->mkdir($target.'/'.$file);
94
+					$result = $this->copyRecursive($source.'/'.$file, $target.'/'.$file);
95 95
 				} else {
96
-					$result = parent::copy($source . '/' . $file, $target . '/' . $file);
96
+					$result = parent::copy($source.'/'.$file, $target.'/'.$file);
97 97
 				}
98 98
 				if (!$result) {
99 99
 					break;
Please login to merge, or discard this patch.
lib/private/Files/Storage/CommonTest.php 2 patches
Indentation   +47 added lines, -47 removed lines patch added patch discarded remove patch
@@ -33,53 +33,53 @@
 block discarded – undo
33 33
 namespace OC\Files\Storage;
34 34
 
35 35
 class CommonTest extends \OC\Files\Storage\Common{
36
-	/**
37
-	 * underlying local storage used for missing functions
38
-	 * @var \OC\Files\Storage\Local
39
-	 */
40
-	private $storage;
36
+    /**
37
+     * underlying local storage used for missing functions
38
+     * @var \OC\Files\Storage\Local
39
+     */
40
+    private $storage;
41 41
 
42
-	public function __construct($params) {
43
-		$this->storage=new \OC\Files\Storage\Local($params);
44
-	}
42
+    public function __construct($params) {
43
+        $this->storage=new \OC\Files\Storage\Local($params);
44
+    }
45 45
 
46
-	public function getId(){
47
-		return 'test::'.$this->storage->getId();
48
-	}
49
-	public function mkdir($path) {
50
-		return $this->storage->mkdir($path);
51
-	}
52
-	public function rmdir($path) {
53
-		return $this->storage->rmdir($path);
54
-	}
55
-	public function opendir($path) {
56
-		return $this->storage->opendir($path);
57
-	}
58
-	public function stat($path) {
59
-		return $this->storage->stat($path);
60
-	}
61
-	public function filetype($path) {
62
-		return @$this->storage->filetype($path);
63
-	}
64
-	public function isReadable($path) {
65
-		return $this->storage->isReadable($path);
66
-	}
67
-	public function isUpdatable($path) {
68
-		return $this->storage->isUpdatable($path);
69
-	}
70
-	public function file_exists($path) {
71
-		return $this->storage->file_exists($path);
72
-	}
73
-	public function unlink($path) {
74
-		return $this->storage->unlink($path);
75
-	}
76
-	public function fopen($path, $mode) {
77
-		return $this->storage->fopen($path, $mode);
78
-	}
79
-	public function free_space($path) {
80
-		return $this->storage->free_space($path);
81
-	}
82
-	public function touch($path, $mtime=null) {
83
-		return $this->storage->touch($path, $mtime);
84
-	}
46
+    public function getId(){
47
+        return 'test::'.$this->storage->getId();
48
+    }
49
+    public function mkdir($path) {
50
+        return $this->storage->mkdir($path);
51
+    }
52
+    public function rmdir($path) {
53
+        return $this->storage->rmdir($path);
54
+    }
55
+    public function opendir($path) {
56
+        return $this->storage->opendir($path);
57
+    }
58
+    public function stat($path) {
59
+        return $this->storage->stat($path);
60
+    }
61
+    public function filetype($path) {
62
+        return @$this->storage->filetype($path);
63
+    }
64
+    public function isReadable($path) {
65
+        return $this->storage->isReadable($path);
66
+    }
67
+    public function isUpdatable($path) {
68
+        return $this->storage->isUpdatable($path);
69
+    }
70
+    public function file_exists($path) {
71
+        return $this->storage->file_exists($path);
72
+    }
73
+    public function unlink($path) {
74
+        return $this->storage->unlink($path);
75
+    }
76
+    public function fopen($path, $mode) {
77
+        return $this->storage->fopen($path, $mode);
78
+    }
79
+    public function free_space($path) {
80
+        return $this->storage->free_space($path);
81
+    }
82
+    public function touch($path, $mtime=null) {
83
+        return $this->storage->touch($path, $mtime);
84
+    }
85 85
 }
Please login to merge, or discard this patch.
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -32,7 +32,7 @@  discard block
 block discarded – undo
32 32
 
33 33
 namespace OC\Files\Storage;
34 34
 
35
-class CommonTest extends \OC\Files\Storage\Common{
35
+class CommonTest extends \OC\Files\Storage\Common {
36 36
 	/**
37 37
 	 * underlying local storage used for missing functions
38 38
 	 * @var \OC\Files\Storage\Local
@@ -40,10 +40,10 @@  discard block
 block discarded – undo
40 40
 	private $storage;
41 41
 
42 42
 	public function __construct($params) {
43
-		$this->storage=new \OC\Files\Storage\Local($params);
43
+		$this->storage = new \OC\Files\Storage\Local($params);
44 44
 	}
45 45
 
46
-	public function getId(){
46
+	public function getId() {
47 47
 		return 'test::'.$this->storage->getId();
48 48
 	}
49 49
 	public function mkdir($path) {
@@ -79,7 +79,7 @@  discard block
 block discarded – undo
79 79
 	public function free_space($path) {
80 80
 		return $this->storage->free_space($path);
81 81
 	}
82
-	public function touch($path, $mtime=null) {
82
+	public function touch($path, $mtime = null) {
83 83
 		return $this->storage->touch($path, $mtime);
84 84
 	}
85 85
 }
Please login to merge, or discard this patch.
lib/private/Files/Notify/RenameChange.php 1 patch
Indentation   +21 added lines, -21 removed lines patch added patch discarded remove patch
@@ -26,27 +26,27 @@
 block discarded – undo
26 26
 use OCP\Files\Notify\IRenameChange;
27 27
 
28 28
 class RenameChange extends Change implements IRenameChange {
29
-	/** @var string */
30
-	private $targetPath;
29
+    /** @var string */
30
+    private $targetPath;
31 31
 
32
-	/**
33
-	 * Change constructor.
34
-	 *
35
-	 * @param int $type
36
-	 * @param string $path
37
-	 * @param string $targetPath
38
-	 */
39
-	public function __construct($type, $path, $targetPath) {
40
-		parent::__construct($type, $path);
41
-		$this->targetPath = $targetPath;
42
-	}
32
+    /**
33
+     * Change constructor.
34
+     *
35
+     * @param int $type
36
+     * @param string $path
37
+     * @param string $targetPath
38
+     */
39
+    public function __construct($type, $path, $targetPath) {
40
+        parent::__construct($type, $path);
41
+        $this->targetPath = $targetPath;
42
+    }
43 43
 
44
-	/**
45
-	 * Get the new path of the renamed file relative to the storage root
46
-	 *
47
-	 * @return string
48
-	 */
49
-	public function getTargetPath() {
50
-		return $this->targetPath;
51
-	}
44
+    /**
45
+     * Get the new path of the renamed file relative to the storage root
46
+     *
47
+     * @return string
48
+     */
49
+    public function getTargetPath() {
50
+        return $this->targetPath;
51
+    }
52 52
 }
Please login to merge, or discard this patch.