Passed
Push — master ( 65b0e2...540ec4 )
by Morris
11:53 queued 10s
created
lib/private/Memcache/NullCache.php 1 patch
Indentation   +33 added lines, -33 removed lines patch added patch discarded remove patch
@@ -27,47 +27,47 @@
 block discarded – undo
27 27
 namespace OC\Memcache;
28 28
 
29 29
 class NullCache extends Cache implements \OCP\IMemcache {
30
-	public function get($key) {
31
-		return null;
32
-	}
30
+    public function get($key) {
31
+        return null;
32
+    }
33 33
 
34
-	public function set($key, $value, $ttl = 0) {
35
-		return true;
36
-	}
34
+    public function set($key, $value, $ttl = 0) {
35
+        return true;
36
+    }
37 37
 
38
-	public function hasKey($key) {
39
-		return false;
40
-	}
38
+    public function hasKey($key) {
39
+        return false;
40
+    }
41 41
 
42
-	public function remove($key) {
43
-		return true;
44
-	}
42
+    public function remove($key) {
43
+        return true;
44
+    }
45 45
 
46
-	public function add($key, $value, $ttl = 0) {
47
-		return true;
48
-	}
46
+    public function add($key, $value, $ttl = 0) {
47
+        return true;
48
+    }
49 49
 
50
-	public function inc($key, $step = 1) {
51
-		return true;
52
-	}
50
+    public function inc($key, $step = 1) {
51
+        return true;
52
+    }
53 53
 
54
-	public function dec($key, $step = 1) {
55
-		return true;
56
-	}
54
+    public function dec($key, $step = 1) {
55
+        return true;
56
+    }
57 57
 
58
-	public function cas($key, $old, $new) {
59
-		return true;
60
-	}
58
+    public function cas($key, $old, $new) {
59
+        return true;
60
+    }
61 61
 
62
-	public function cad($key, $old) {
63
-		return true;
64
-	}
62
+    public function cad($key, $old) {
63
+        return true;
64
+    }
65 65
 
66
-	public function clear($prefix = '') {
67
-		return true;
68
-	}
66
+    public function clear($prefix = '') {
67
+        return true;
68
+    }
69 69
 
70
-	static public function isAvailable() {
71
-		return true;
72
-	}
70
+    static public function isAvailable() {
71
+        return true;
72
+    }
73 73
 }
Please login to merge, or discard this patch.
lib/private/OCS/Result.php 2 patches
Indentation   +124 added lines, -124 removed lines patch added patch discarded remove patch
@@ -32,129 +32,129 @@
 block discarded – undo
32 32
 
33 33
 class Result {
34 34
 
35
-	/** @var array  */
36
-	protected $data;
37
-
38
-	/** @var null|string */
39
-	protected $message;
40
-
41
-	/** @var int */
42
-	protected $statusCode;
43
-
44
-	/** @var integer */
45
-	protected $items;
46
-
47
-	/** @var integer */
48
-	protected $perPage;
49
-
50
-	/** @var array */
51
-	private $headers = [];
52
-
53
-	/**
54
-	 * create the OCS_Result object
55
-	 * @param mixed $data the data to return
56
-	 * @param int $code
57
-	 * @param null|string $message
58
-	 * @param array $headers
59
-	 */
60
-	public function __construct($data = null, $code = 100, $message = null, $headers = []) {
61
-		if ($data === null) {
62
-			$this->data = array();
63
-		} elseif (!is_array($data)) {
64
-			$this->data = array($this->data);
65
-		} else {
66
-			$this->data = $data;
67
-		}
68
-		$this->statusCode = $code;
69
-		$this->message = $message;
70
-		$this->headers = $headers;
71
-	}
72
-
73
-	/**
74
-	 * optionally set the total number of items available
75
-	 * @param int $items
76
-	 */
77
-	public function setTotalItems($items) {
78
-		$this->items = $items;
79
-	}
80
-
81
-	/**
82
-	 * optionally set the the number of items per page
83
-	 * @param int $items
84
-	 */
85
-	public function setItemsPerPage($items) {
86
-		$this->perPage = $items;
87
-	}
88
-
89
-	/**
90
-	 * get the status code
91
-	 * @return int
92
-	 */
93
-	public function getStatusCode() {
94
-		return $this->statusCode;
95
-	}
96
-
97
-	/**
98
-	 * get the meta data for the result
99
-	 * @return array
100
-	 */
101
-	public function getMeta() {
102
-		$meta = array();
103
-		$meta['status'] = $this->succeeded() ? 'ok' : 'failure';
104
-		$meta['statuscode'] = $this->statusCode;
105
-		$meta['message'] = $this->message;
106
-		if(isset($this->items)) {
107
-			$meta['totalitems'] = $this->items;
108
-		}
109
-		if(isset($this->perPage)) {
110
-			$meta['itemsperpage'] = $this->perPage;
111
-		}
112
-		return $meta;
113
-
114
-	}
115
-
116
-	/**
117
-	 * get the result data
118
-	 * @return array
119
-	 */
120
-	public function getData() {
121
-		return $this->data;
122
-	}
123
-
124
-	/**
125
-	 * return bool Whether the method succeeded
126
-	 * @return bool
127
-	 */
128
-	public function succeeded() {
129
-		return ($this->statusCode == 100);
130
-	}
131
-
132
-	/**
133
-	 * Adds a new header to the response
134
-	 * @param string $name The name of the HTTP header
135
-	 * @param string $value The value, null will delete it
136
-	 * @return $this
137
-	 */
138
-	public function addHeader($name, $value) {
139
-		$name = trim($name);  // always remove leading and trailing whitespace
140
-		// to be able to reliably check for security
141
-		// headers
142
-
143
-		if(is_null($value)) {
144
-			unset($this->headers[$name]);
145
-		} else {
146
-			$this->headers[$name] = $value;
147
-		}
148
-
149
-		return $this;
150
-	}
151
-
152
-	/**
153
-	 * Returns the set headers
154
-	 * @return array the headers
155
-	 */
156
-	public function getHeaders() {
157
-		return $this->headers;
158
-	}
35
+    /** @var array  */
36
+    protected $data;
37
+
38
+    /** @var null|string */
39
+    protected $message;
40
+
41
+    /** @var int */
42
+    protected $statusCode;
43
+
44
+    /** @var integer */
45
+    protected $items;
46
+
47
+    /** @var integer */
48
+    protected $perPage;
49
+
50
+    /** @var array */
51
+    private $headers = [];
52
+
53
+    /**
54
+     * create the OCS_Result object
55
+     * @param mixed $data the data to return
56
+     * @param int $code
57
+     * @param null|string $message
58
+     * @param array $headers
59
+     */
60
+    public function __construct($data = null, $code = 100, $message = null, $headers = []) {
61
+        if ($data === null) {
62
+            $this->data = array();
63
+        } elseif (!is_array($data)) {
64
+            $this->data = array($this->data);
65
+        } else {
66
+            $this->data = $data;
67
+        }
68
+        $this->statusCode = $code;
69
+        $this->message = $message;
70
+        $this->headers = $headers;
71
+    }
72
+
73
+    /**
74
+     * optionally set the total number of items available
75
+     * @param int $items
76
+     */
77
+    public function setTotalItems($items) {
78
+        $this->items = $items;
79
+    }
80
+
81
+    /**
82
+     * optionally set the the number of items per page
83
+     * @param int $items
84
+     */
85
+    public function setItemsPerPage($items) {
86
+        $this->perPage = $items;
87
+    }
88
+
89
+    /**
90
+     * get the status code
91
+     * @return int
92
+     */
93
+    public function getStatusCode() {
94
+        return $this->statusCode;
95
+    }
96
+
97
+    /**
98
+     * get the meta data for the result
99
+     * @return array
100
+     */
101
+    public function getMeta() {
102
+        $meta = array();
103
+        $meta['status'] = $this->succeeded() ? 'ok' : 'failure';
104
+        $meta['statuscode'] = $this->statusCode;
105
+        $meta['message'] = $this->message;
106
+        if(isset($this->items)) {
107
+            $meta['totalitems'] = $this->items;
108
+        }
109
+        if(isset($this->perPage)) {
110
+            $meta['itemsperpage'] = $this->perPage;
111
+        }
112
+        return $meta;
113
+
114
+    }
115
+
116
+    /**
117
+     * get the result data
118
+     * @return array
119
+     */
120
+    public function getData() {
121
+        return $this->data;
122
+    }
123
+
124
+    /**
125
+     * return bool Whether the method succeeded
126
+     * @return bool
127
+     */
128
+    public function succeeded() {
129
+        return ($this->statusCode == 100);
130
+    }
131
+
132
+    /**
133
+     * Adds a new header to the response
134
+     * @param string $name The name of the HTTP header
135
+     * @param string $value The value, null will delete it
136
+     * @return $this
137
+     */
138
+    public function addHeader($name, $value) {
139
+        $name = trim($name);  // always remove leading and trailing whitespace
140
+        // to be able to reliably check for security
141
+        // headers
142
+
143
+        if(is_null($value)) {
144
+            unset($this->headers[$name]);
145
+        } else {
146
+            $this->headers[$name] = $value;
147
+        }
148
+
149
+        return $this;
150
+    }
151
+
152
+    /**
153
+     * Returns the set headers
154
+     * @return array the headers
155
+     */
156
+    public function getHeaders() {
157
+        return $this->headers;
158
+    }
159 159
 
160 160
 }
Please login to merge, or discard this patch.
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -103,10 +103,10 @@  discard block
 block discarded – undo
103 103
 		$meta['status'] = $this->succeeded() ? 'ok' : 'failure';
104 104
 		$meta['statuscode'] = $this->statusCode;
105 105
 		$meta['message'] = $this->message;
106
-		if(isset($this->items)) {
106
+		if (isset($this->items)) {
107 107
 			$meta['totalitems'] = $this->items;
108 108
 		}
109
-		if(isset($this->perPage)) {
109
+		if (isset($this->perPage)) {
110 110
 			$meta['itemsperpage'] = $this->perPage;
111 111
 		}
112 112
 		return $meta;
@@ -136,11 +136,11 @@  discard block
 block discarded – undo
136 136
 	 * @return $this
137 137
 	 */
138 138
 	public function addHeader($name, $value) {
139
-		$name = trim($name);  // always remove leading and trailing whitespace
139
+		$name = trim($name); // always remove leading and trailing whitespace
140 140
 		// to be able to reliably check for security
141 141
 		// headers
142 142
 
143
-		if(is_null($value)) {
143
+		if (is_null($value)) {
144 144
 			unset($this->headers[$name]);
145 145
 		} else {
146 146
 			$this->headers[$name] = $value;
Please login to merge, or discard this patch.
lib/private/OCS/CoreCapabilities.php 1 patch
Indentation   +21 added lines, -21 removed lines patch added patch discarded remove patch
@@ -33,27 +33,27 @@
 block discarded – undo
33 33
  */
34 34
 class CoreCapabilities implements ICapability {
35 35
 
36
-	/** @var IConfig */
37
-	private $config;
36
+    /** @var IConfig */
37
+    private $config;
38 38
 
39
-	/**
40
-	 * @param IConfig $config
41
-	 */
42
-	public function __construct(IConfig $config) {
43
-		$this->config = $config;
44
-	}
39
+    /**
40
+     * @param IConfig $config
41
+     */
42
+    public function __construct(IConfig $config) {
43
+        $this->config = $config;
44
+    }
45 45
 
46
-	/**
47
-	 * Return this classes capabilities
48
-	 *
49
-	 * @return array
50
-	 */
51
-	public function getCapabilities() {
52
-		return [
53
-			'core' => [
54
-				'pollinterval' => $this->config->getSystemValue('pollinterval', 60),
55
-				'webdav-root' => $this->config->getSystemValue('webdav-root', 'remote.php/webdav'),
56
-			]
57
-		];
58
-	}
46
+    /**
47
+     * Return this classes capabilities
48
+     *
49
+     * @return array
50
+     */
51
+    public function getCapabilities() {
52
+        return [
53
+            'core' => [
54
+                'pollinterval' => $this->config->getSystemValue('pollinterval', 60),
55
+                'webdav-root' => $this->config->getSystemValue('webdav-root', 'remote.php/webdav'),
56
+            ]
57
+        ];
58
+    }
59 59
 }
Please login to merge, or discard this patch.
lib/private/Files/Node/Root.php 2 patches
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -372,12 +372,12 @@
 block discarded – undo
372 372
 			\OC\Files\Filesystem::initMountPoints($userId);
373 373
 
374 374
 			try {
375
-				$folder = $this->get('/' . $userId . '/files');
375
+				$folder = $this->get('/'.$userId.'/files');
376 376
 			} catch (NotFoundException $e) {
377
-				if (!$this->nodeExists('/' . $userId)) {
378
-					$this->newFolder('/' . $userId);
377
+				if (!$this->nodeExists('/'.$userId)) {
378
+					$this->newFolder('/'.$userId);
379 379
 				}
380
-				$folder = $this->newFolder('/' . $userId . '/files');
380
+				$folder = $this->newFolder('/'.$userId.'/files');
381 381
 			}
382 382
 
383 383
 			$this->userFolderCache->set($userId, $folder);
Please login to merge, or discard this patch.
Indentation   +335 added lines, -335 removed lines patch added patch discarded remove patch
@@ -61,339 +61,339 @@
 block discarded – undo
61 61
  * @package OC\Files\Node
62 62
  */
63 63
 class Root extends Folder implements IRootFolder {
64
-	/** @var Manager */
65
-	private $mountManager;
66
-	/** @var PublicEmitter */
67
-	private $emitter;
68
-	/** @var null|\OC\User\User */
69
-	private $user;
70
-	/** @var CappedMemoryCache */
71
-	private $userFolderCache;
72
-	/** @var IUserMountCache */
73
-	private $userMountCache;
74
-	/** @var ILogger */
75
-	private $logger;
76
-	/** @var IUserManager */
77
-	private $userManager;
78
-
79
-	/**
80
-	 * @param \OC\Files\Mount\Manager $manager
81
-	 * @param \OC\Files\View $view
82
-	 * @param \OC\User\User|null $user
83
-	 * @param IUserMountCache $userMountCache
84
-	 * @param ILogger $logger
85
-	 * @param IUserManager $userManager
86
-	 */
87
-	public function __construct($manager,
88
-								$view,
89
-								$user,
90
-								IUserMountCache $userMountCache,
91
-								ILogger $logger,
92
-								IUserManager $userManager) {
93
-		parent::__construct($this, $view, '');
94
-		$this->mountManager = $manager;
95
-		$this->user = $user;
96
-		$this->emitter = new PublicEmitter();
97
-		$this->userFolderCache = new CappedMemoryCache();
98
-		$this->userMountCache = $userMountCache;
99
-		$this->logger = $logger;
100
-		$this->userManager = $userManager;
101
-	}
102
-
103
-	/**
104
-	 * Get the user for which the filesystem is setup
105
-	 *
106
-	 * @return \OC\User\User
107
-	 */
108
-	public function getUser() {
109
-		return $this->user;
110
-	}
111
-
112
-	/**
113
-	 * @param string $scope
114
-	 * @param string $method
115
-	 * @param callable $callback
116
-	 */
117
-	public function listen($scope, $method, callable $callback) {
118
-		$this->emitter->listen($scope, $method, $callback);
119
-	}
120
-
121
-	/**
122
-	 * @param string $scope optional
123
-	 * @param string $method optional
124
-	 * @param callable $callback optional
125
-	 */
126
-	public function removeListener($scope = null, $method = null, callable $callback = null) {
127
-		$this->emitter->removeListener($scope, $method, $callback);
128
-	}
129
-
130
-	/**
131
-	 * @param string $scope
132
-	 * @param string $method
133
-	 * @param Node[] $arguments
134
-	 */
135
-	public function emit($scope, $method, $arguments = array()) {
136
-		$this->emitter->emit($scope, $method, $arguments);
137
-	}
138
-
139
-	/**
140
-	 * @param \OC\Files\Storage\Storage $storage
141
-	 * @param string $mountPoint
142
-	 * @param array $arguments
143
-	 */
144
-	public function mount($storage, $mountPoint, $arguments = array()) {
145
-		$mount = new MountPoint($storage, $mountPoint, $arguments);
146
-		$this->mountManager->addMount($mount);
147
-	}
148
-
149
-	/**
150
-	 * @param string $mountPoint
151
-	 * @return \OC\Files\Mount\MountPoint
152
-	 */
153
-	public function getMount($mountPoint) {
154
-		return $this->mountManager->find($mountPoint);
155
-	}
156
-
157
-	/**
158
-	 * @param string $mountPoint
159
-	 * @return \OC\Files\Mount\MountPoint[]
160
-	 */
161
-	public function getMountsIn($mountPoint) {
162
-		return $this->mountManager->findIn($mountPoint);
163
-	}
164
-
165
-	/**
166
-	 * @param string $storageId
167
-	 * @return \OC\Files\Mount\MountPoint[]
168
-	 */
169
-	public function getMountByStorageId($storageId) {
170
-		return $this->mountManager->findByStorageId($storageId);
171
-	}
172
-
173
-	/**
174
-	 * @param int $numericId
175
-	 * @return MountPoint[]
176
-	 */
177
-	public function getMountByNumericStorageId($numericId) {
178
-		return $this->mountManager->findByNumericId($numericId);
179
-	}
180
-
181
-	/**
182
-	 * @param \OC\Files\Mount\MountPoint $mount
183
-	 */
184
-	public function unMount($mount) {
185
-		$this->mountManager->remove($mount);
186
-	}
187
-
188
-	/**
189
-	 * @param string $path
190
-	 * @throws \OCP\Files\NotFoundException
191
-	 * @throws \OCP\Files\NotPermittedException
192
-	 * @return string
193
-	 */
194
-	public function get($path) {
195
-		$path = $this->normalizePath($path);
196
-		if ($this->isValidPath($path)) {
197
-			$fullPath = $this->getFullPath($path);
198
-			$fileInfo = $this->view->getFileInfo($fullPath);
199
-			if ($fileInfo) {
200
-				return $this->createNode($fullPath, $fileInfo);
201
-			} else {
202
-				throw new NotFoundException($path);
203
-			}
204
-		} else {
205
-			throw new NotPermittedException();
206
-		}
207
-	}
208
-
209
-	//most operations can't be done on the root
210
-
211
-	/**
212
-	 * @param string $targetPath
213
-	 * @throws \OCP\Files\NotPermittedException
214
-	 * @return \OC\Files\Node\Node
215
-	 */
216
-	public function rename($targetPath) {
217
-		throw new NotPermittedException();
218
-	}
219
-
220
-	public function delete() {
221
-		throw new NotPermittedException();
222
-	}
223
-
224
-	/**
225
-	 * @param string $targetPath
226
-	 * @throws \OCP\Files\NotPermittedException
227
-	 * @return \OC\Files\Node\Node
228
-	 */
229
-	public function copy($targetPath) {
230
-		throw new NotPermittedException();
231
-	}
232
-
233
-	/**
234
-	 * @param int $mtime
235
-	 * @throws \OCP\Files\NotPermittedException
236
-	 */
237
-	public function touch($mtime = null) {
238
-		throw new NotPermittedException();
239
-	}
240
-
241
-	/**
242
-	 * @return \OC\Files\Storage\Storage
243
-	 * @throws \OCP\Files\NotFoundException
244
-	 */
245
-	public function getStorage() {
246
-		throw new NotFoundException();
247
-	}
248
-
249
-	/**
250
-	 * @return string
251
-	 */
252
-	public function getPath() {
253
-		return '/';
254
-	}
255
-
256
-	/**
257
-	 * @return string
258
-	 */
259
-	public function getInternalPath() {
260
-		return '';
261
-	}
262
-
263
-	/**
264
-	 * @return int
265
-	 */
266
-	public function getId() {
267
-		return null;
268
-	}
269
-
270
-	/**
271
-	 * @return array
272
-	 */
273
-	public function stat() {
274
-		return null;
275
-	}
276
-
277
-	/**
278
-	 * @return int
279
-	 */
280
-	public function getMTime() {
281
-		return null;
282
-	}
283
-
284
-	/**
285
-	 * @param bool $includeMounts
286
-	 * @return int
287
-	 */
288
-	public function getSize($includeMounts = true) {
289
-		return null;
290
-	}
291
-
292
-	/**
293
-	 * @return string
294
-	 */
295
-	public function getEtag() {
296
-		return null;
297
-	}
298
-
299
-	/**
300
-	 * @return int
301
-	 */
302
-	public function getPermissions() {
303
-		return \OCP\Constants::PERMISSION_CREATE;
304
-	}
305
-
306
-	/**
307
-	 * @return bool
308
-	 */
309
-	public function isReadable() {
310
-		return false;
311
-	}
312
-
313
-	/**
314
-	 * @return bool
315
-	 */
316
-	public function isUpdateable() {
317
-		return false;
318
-	}
319
-
320
-	/**
321
-	 * @return bool
322
-	 */
323
-	public function isDeletable() {
324
-		return false;
325
-	}
326
-
327
-	/**
328
-	 * @return bool
329
-	 */
330
-	public function isShareable() {
331
-		return false;
332
-	}
333
-
334
-	/**
335
-	 * @return Node
336
-	 * @throws \OCP\Files\NotFoundException
337
-	 */
338
-	public function getParent() {
339
-		throw new NotFoundException();
340
-	}
341
-
342
-	/**
343
-	 * @return string
344
-	 */
345
-	public function getName() {
346
-		return '';
347
-	}
348
-
349
-	/**
350
-	 * Returns a view to user's files folder
351
-	 *
352
-	 * @param string $userId user ID
353
-	 * @return \OCP\Files\Folder
354
-	 * @throws \OC\User\NoUserException
355
-	 */
356
-	public function getUserFolder($userId) {
357
-		$userObject = $this->userManager->get($userId);
358
-
359
-		if (is_null($userObject)) {
360
-			$this->logger->error(
361
-				sprintf(
362
-					'Backends provided no user object for %s',
363
-					$userId
364
-				),
365
-				[
366
-					'app' => 'files',
367
-				]
368
-			);
369
-			throw new \OC\User\NoUserException('Backends provided no user object');
370
-		}
371
-
372
-		$userId = $userObject->getUID();
373
-
374
-		if (!$this->userFolderCache->hasKey($userId)) {
375
-			\OC\Files\Filesystem::initMountPoints($userId);
376
-
377
-			try {
378
-				$folder = $this->get('/' . $userId . '/files');
379
-			} catch (NotFoundException $e) {
380
-				if (!$this->nodeExists('/' . $userId)) {
381
-					$this->newFolder('/' . $userId);
382
-				}
383
-				$folder = $this->newFolder('/' . $userId . '/files');
384
-			}
385
-
386
-			$this->userFolderCache->set($userId, $folder);
387
-		}
388
-
389
-		return $this->userFolderCache->get($userId);
390
-	}
391
-
392
-	public function clearCache() {
393
-		$this->userFolderCache = new CappedMemoryCache();
394
-	}
395
-
396
-	public function getUserMountCache() {
397
-		return $this->userMountCache;
398
-	}
64
+    /** @var Manager */
65
+    private $mountManager;
66
+    /** @var PublicEmitter */
67
+    private $emitter;
68
+    /** @var null|\OC\User\User */
69
+    private $user;
70
+    /** @var CappedMemoryCache */
71
+    private $userFolderCache;
72
+    /** @var IUserMountCache */
73
+    private $userMountCache;
74
+    /** @var ILogger */
75
+    private $logger;
76
+    /** @var IUserManager */
77
+    private $userManager;
78
+
79
+    /**
80
+     * @param \OC\Files\Mount\Manager $manager
81
+     * @param \OC\Files\View $view
82
+     * @param \OC\User\User|null $user
83
+     * @param IUserMountCache $userMountCache
84
+     * @param ILogger $logger
85
+     * @param IUserManager $userManager
86
+     */
87
+    public function __construct($manager,
88
+                                $view,
89
+                                $user,
90
+                                IUserMountCache $userMountCache,
91
+                                ILogger $logger,
92
+                                IUserManager $userManager) {
93
+        parent::__construct($this, $view, '');
94
+        $this->mountManager = $manager;
95
+        $this->user = $user;
96
+        $this->emitter = new PublicEmitter();
97
+        $this->userFolderCache = new CappedMemoryCache();
98
+        $this->userMountCache = $userMountCache;
99
+        $this->logger = $logger;
100
+        $this->userManager = $userManager;
101
+    }
102
+
103
+    /**
104
+     * Get the user for which the filesystem is setup
105
+     *
106
+     * @return \OC\User\User
107
+     */
108
+    public function getUser() {
109
+        return $this->user;
110
+    }
111
+
112
+    /**
113
+     * @param string $scope
114
+     * @param string $method
115
+     * @param callable $callback
116
+     */
117
+    public function listen($scope, $method, callable $callback) {
118
+        $this->emitter->listen($scope, $method, $callback);
119
+    }
120
+
121
+    /**
122
+     * @param string $scope optional
123
+     * @param string $method optional
124
+     * @param callable $callback optional
125
+     */
126
+    public function removeListener($scope = null, $method = null, callable $callback = null) {
127
+        $this->emitter->removeListener($scope, $method, $callback);
128
+    }
129
+
130
+    /**
131
+     * @param string $scope
132
+     * @param string $method
133
+     * @param Node[] $arguments
134
+     */
135
+    public function emit($scope, $method, $arguments = array()) {
136
+        $this->emitter->emit($scope, $method, $arguments);
137
+    }
138
+
139
+    /**
140
+     * @param \OC\Files\Storage\Storage $storage
141
+     * @param string $mountPoint
142
+     * @param array $arguments
143
+     */
144
+    public function mount($storage, $mountPoint, $arguments = array()) {
145
+        $mount = new MountPoint($storage, $mountPoint, $arguments);
146
+        $this->mountManager->addMount($mount);
147
+    }
148
+
149
+    /**
150
+     * @param string $mountPoint
151
+     * @return \OC\Files\Mount\MountPoint
152
+     */
153
+    public function getMount($mountPoint) {
154
+        return $this->mountManager->find($mountPoint);
155
+    }
156
+
157
+    /**
158
+     * @param string $mountPoint
159
+     * @return \OC\Files\Mount\MountPoint[]
160
+     */
161
+    public function getMountsIn($mountPoint) {
162
+        return $this->mountManager->findIn($mountPoint);
163
+    }
164
+
165
+    /**
166
+     * @param string $storageId
167
+     * @return \OC\Files\Mount\MountPoint[]
168
+     */
169
+    public function getMountByStorageId($storageId) {
170
+        return $this->mountManager->findByStorageId($storageId);
171
+    }
172
+
173
+    /**
174
+     * @param int $numericId
175
+     * @return MountPoint[]
176
+     */
177
+    public function getMountByNumericStorageId($numericId) {
178
+        return $this->mountManager->findByNumericId($numericId);
179
+    }
180
+
181
+    /**
182
+     * @param \OC\Files\Mount\MountPoint $mount
183
+     */
184
+    public function unMount($mount) {
185
+        $this->mountManager->remove($mount);
186
+    }
187
+
188
+    /**
189
+     * @param string $path
190
+     * @throws \OCP\Files\NotFoundException
191
+     * @throws \OCP\Files\NotPermittedException
192
+     * @return string
193
+     */
194
+    public function get($path) {
195
+        $path = $this->normalizePath($path);
196
+        if ($this->isValidPath($path)) {
197
+            $fullPath = $this->getFullPath($path);
198
+            $fileInfo = $this->view->getFileInfo($fullPath);
199
+            if ($fileInfo) {
200
+                return $this->createNode($fullPath, $fileInfo);
201
+            } else {
202
+                throw new NotFoundException($path);
203
+            }
204
+        } else {
205
+            throw new NotPermittedException();
206
+        }
207
+    }
208
+
209
+    //most operations can't be done on the root
210
+
211
+    /**
212
+     * @param string $targetPath
213
+     * @throws \OCP\Files\NotPermittedException
214
+     * @return \OC\Files\Node\Node
215
+     */
216
+    public function rename($targetPath) {
217
+        throw new NotPermittedException();
218
+    }
219
+
220
+    public function delete() {
221
+        throw new NotPermittedException();
222
+    }
223
+
224
+    /**
225
+     * @param string $targetPath
226
+     * @throws \OCP\Files\NotPermittedException
227
+     * @return \OC\Files\Node\Node
228
+     */
229
+    public function copy($targetPath) {
230
+        throw new NotPermittedException();
231
+    }
232
+
233
+    /**
234
+     * @param int $mtime
235
+     * @throws \OCP\Files\NotPermittedException
236
+     */
237
+    public function touch($mtime = null) {
238
+        throw new NotPermittedException();
239
+    }
240
+
241
+    /**
242
+     * @return \OC\Files\Storage\Storage
243
+     * @throws \OCP\Files\NotFoundException
244
+     */
245
+    public function getStorage() {
246
+        throw new NotFoundException();
247
+    }
248
+
249
+    /**
250
+     * @return string
251
+     */
252
+    public function getPath() {
253
+        return '/';
254
+    }
255
+
256
+    /**
257
+     * @return string
258
+     */
259
+    public function getInternalPath() {
260
+        return '';
261
+    }
262
+
263
+    /**
264
+     * @return int
265
+     */
266
+    public function getId() {
267
+        return null;
268
+    }
269
+
270
+    /**
271
+     * @return array
272
+     */
273
+    public function stat() {
274
+        return null;
275
+    }
276
+
277
+    /**
278
+     * @return int
279
+     */
280
+    public function getMTime() {
281
+        return null;
282
+    }
283
+
284
+    /**
285
+     * @param bool $includeMounts
286
+     * @return int
287
+     */
288
+    public function getSize($includeMounts = true) {
289
+        return null;
290
+    }
291
+
292
+    /**
293
+     * @return string
294
+     */
295
+    public function getEtag() {
296
+        return null;
297
+    }
298
+
299
+    /**
300
+     * @return int
301
+     */
302
+    public function getPermissions() {
303
+        return \OCP\Constants::PERMISSION_CREATE;
304
+    }
305
+
306
+    /**
307
+     * @return bool
308
+     */
309
+    public function isReadable() {
310
+        return false;
311
+    }
312
+
313
+    /**
314
+     * @return bool
315
+     */
316
+    public function isUpdateable() {
317
+        return false;
318
+    }
319
+
320
+    /**
321
+     * @return bool
322
+     */
323
+    public function isDeletable() {
324
+        return false;
325
+    }
326
+
327
+    /**
328
+     * @return bool
329
+     */
330
+    public function isShareable() {
331
+        return false;
332
+    }
333
+
334
+    /**
335
+     * @return Node
336
+     * @throws \OCP\Files\NotFoundException
337
+     */
338
+    public function getParent() {
339
+        throw new NotFoundException();
340
+    }
341
+
342
+    /**
343
+     * @return string
344
+     */
345
+    public function getName() {
346
+        return '';
347
+    }
348
+
349
+    /**
350
+     * Returns a view to user's files folder
351
+     *
352
+     * @param string $userId user ID
353
+     * @return \OCP\Files\Folder
354
+     * @throws \OC\User\NoUserException
355
+     */
356
+    public function getUserFolder($userId) {
357
+        $userObject = $this->userManager->get($userId);
358
+
359
+        if (is_null($userObject)) {
360
+            $this->logger->error(
361
+                sprintf(
362
+                    'Backends provided no user object for %s',
363
+                    $userId
364
+                ),
365
+                [
366
+                    'app' => 'files',
367
+                ]
368
+            );
369
+            throw new \OC\User\NoUserException('Backends provided no user object');
370
+        }
371
+
372
+        $userId = $userObject->getUID();
373
+
374
+        if (!$this->userFolderCache->hasKey($userId)) {
375
+            \OC\Files\Filesystem::initMountPoints($userId);
376
+
377
+            try {
378
+                $folder = $this->get('/' . $userId . '/files');
379
+            } catch (NotFoundException $e) {
380
+                if (!$this->nodeExists('/' . $userId)) {
381
+                    $this->newFolder('/' . $userId);
382
+                }
383
+                $folder = $this->newFolder('/' . $userId . '/files');
384
+            }
385
+
386
+            $this->userFolderCache->set($userId, $folder);
387
+        }
388
+
389
+        return $this->userFolderCache->get($userId);
390
+    }
391
+
392
+    public function clearCache() {
393
+        $this->userFolderCache = new CappedMemoryCache();
394
+    }
395
+
396
+    public function getUserMountCache() {
397
+        return $this->userMountCache;
398
+    }
399 399
 }
Please login to merge, or discard this patch.
lib/private/Files/Node/Node.php 2 patches
Spacing   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -288,7 +288,7 @@  discard block
 block discarded – undo
288 288
 		$path = str_replace('\\', '/', $path);
289 289
 		//add leading slash
290 290
 		if ($path[0] !== '/') {
291
-			$path = '/' . $path;
291
+			$path = '/'.$path;
292 292
 		}
293 293
 		//remove duplicate slashes
294 294
 		while (strpos($path, '//') !== false) {
@@ -308,7 +308,7 @@  discard block
 block discarded – undo
308 308
 	 */
309 309
 	public function isValidPath($path) {
310 310
 		if (!$path || $path[0] !== '/') {
311
-			$path = '/' . $path;
311
+			$path = '/'.$path;
312 312
 		}
313 313
 		if (strstr($path, '/../') || strrchr($path, '/') === '/..') {
314 314
 			return false;
@@ -389,14 +389,14 @@  discard block
 block discarded – undo
389 389
 			$this->root->emit('\OC\Files', 'preCopy', [$this, $nonExisting]);
390 390
 			$this->root->emit('\OC\Files', 'preWrite', [$nonExisting]);
391 391
 			if (!$this->view->copy($this->path, $targetPath)) {
392
-				throw new NotPermittedException('Could not copy ' . $this->path . ' to ' . $targetPath);
392
+				throw new NotPermittedException('Could not copy '.$this->path.' to '.$targetPath);
393 393
 			}
394 394
 			$targetNode = $this->root->get($targetPath);
395 395
 			$this->root->emit('\OC\Files', 'postCopy', [$this, $targetNode]);
396 396
 			$this->root->emit('\OC\Files', 'postWrite', [$targetNode]);
397 397
 			return $targetNode;
398 398
 		} else {
399
-			throw new NotPermittedException('No permission to copy to path ' . $targetPath);
399
+			throw new NotPermittedException('No permission to copy to path '.$targetPath);
400 400
 		}
401 401
 	}
402 402
 
@@ -413,7 +413,7 @@  discard block
 block discarded – undo
413 413
 			$this->root->emit('\OC\Files', 'preRename', [$this, $nonExisting]);
414 414
 			$this->root->emit('\OC\Files', 'preWrite', [$nonExisting]);
415 415
 			if (!$this->view->rename($this->path, $targetPath)) {
416
-				throw new NotPermittedException('Could not move ' . $this->path . ' to ' . $targetPath);
416
+				throw new NotPermittedException('Could not move '.$this->path.' to '.$targetPath);
417 417
 			}
418 418
 			$targetNode = $this->root->get($targetPath);
419 419
 			$this->root->emit('\OC\Files', 'postRename', [$this, $targetNode]);
@@ -421,7 +421,7 @@  discard block
 block discarded – undo
421 421
 			$this->path = $targetPath;
422 422
 			return $targetNode;
423 423
 		} else {
424
-			throw new NotPermittedException('No permission to move to path ' . $targetPath);
424
+			throw new NotPermittedException('No permission to move to path '.$targetPath);
425 425
 		}
426 426
 	}
427 427
 
Please login to merge, or discard this patch.
Indentation   +396 added lines, -396 removed lines patch added patch discarded remove patch
@@ -35,401 +35,401 @@
 block discarded – undo
35 35
 
36 36
 // FIXME: this class really should be abstract
37 37
 class Node implements \OCP\Files\Node {
38
-	/**
39
-	 * @var \OC\Files\View $view
40
-	 */
41
-	protected $view;
42
-
43
-	/**
44
-	 * @var \OC\Files\Node\Root $root
45
-	 */
46
-	protected $root;
47
-
48
-	/**
49
-	 * @var string $path
50
-	 */
51
-	protected $path;
52
-
53
-	/**
54
-	 * @var \OCP\Files\FileInfo
55
-	 */
56
-	protected $fileInfo;
57
-
58
-	/**
59
-	 * @param \OC\Files\View $view
60
-	 * @param \OCP\Files\IRootFolder $root
61
-	 * @param string $path
62
-	 * @param FileInfo $fileInfo
63
-	 */
64
-	public function __construct($root, $view, $path, $fileInfo = null) {
65
-		$this->view = $view;
66
-		$this->root = $root;
67
-		$this->path = $path;
68
-		$this->fileInfo = $fileInfo;
69
-	}
70
-
71
-	/**
72
-	 * Creates a Node of the same type that represents a non-existing path
73
-	 *
74
-	 * @param string $path path
75
-	 * @return string non-existing node class
76
-	 */
77
-	protected function createNonExistingNode($path) {
78
-		throw new \Exception('Must be implemented by subclasses');
79
-	}
80
-
81
-	/**
82
-	 * Returns the matching file info
83
-	 *
84
-	 * @return FileInfo
85
-	 * @throws InvalidPathException
86
-	 * @throws NotFoundException
87
-	 */
88
-	public function getFileInfo() {
89
-		if (!Filesystem::isValidPath($this->path)) {
90
-			throw new InvalidPathException();
91
-		}
92
-		if (!$this->fileInfo) {
93
-			$fileInfo = $this->view->getFileInfo($this->path);
94
-			if ($fileInfo instanceof FileInfo) {
95
-				$this->fileInfo = $fileInfo;
96
-			} else {
97
-				throw new NotFoundException();
98
-			}
99
-		}
100
-		return $this->fileInfo;
101
-	}
102
-
103
-	/**
104
-	 * @param string[] $hooks
105
-	 */
106
-	protected function sendHooks($hooks) {
107
-		foreach ($hooks as $hook) {
108
-			$this->root->emit('\OC\Files', $hook, array($this));
109
-		}
110
-	}
111
-
112
-	/**
113
-	 * @param int $permissions
114
-	 * @return bool
115
-	 */
116
-	protected function checkPermissions($permissions) {
117
-		return ($this->getPermissions() & $permissions) === $permissions;
118
-	}
119
-
120
-	public function delete() {
121
-	}
122
-
123
-	/**
124
-	 * @param int $mtime
125
-	 * @throws \OCP\Files\NotPermittedException
126
-	 */
127
-	public function touch($mtime = null) {
128
-		if ($this->checkPermissions(\OCP\Constants::PERMISSION_UPDATE)) {
129
-			$this->sendHooks(array('preTouch'));
130
-			$this->view->touch($this->path, $mtime);
131
-			$this->sendHooks(array('postTouch'));
132
-			if ($this->fileInfo) {
133
-				if (is_null($mtime)) {
134
-					$mtime = time();
135
-				}
136
-				$this->fileInfo['mtime'] = $mtime;
137
-			}
138
-		} else {
139
-			throw new NotPermittedException();
140
-		}
141
-	}
142
-
143
-	/**
144
-	 * @return \OC\Files\Storage\Storage
145
-	 * @throws \OCP\Files\NotFoundException
146
-	 */
147
-	public function getStorage() {
148
-		list($storage,) = $this->view->resolvePath($this->path);
149
-		return $storage;
150
-	}
151
-
152
-	/**
153
-	 * @return string
154
-	 */
155
-	public function getPath() {
156
-		return $this->path;
157
-	}
158
-
159
-	/**
160
-	 * @return string
161
-	 */
162
-	public function getInternalPath() {
163
-		list(, $internalPath) = $this->view->resolvePath($this->path);
164
-		return $internalPath;
165
-	}
166
-
167
-	/**
168
-	 * @return int
169
-	 * @throws InvalidPathException
170
-	 * @throws NotFoundException
171
-	 */
172
-	public function getId() {
173
-		return $this->getFileInfo()->getId();
174
-	}
175
-
176
-	/**
177
-	 * @return array
178
-	 */
179
-	public function stat() {
180
-		return $this->view->stat($this->path);
181
-	}
182
-
183
-	/**
184
-	 * @return int
185
-	 * @throws InvalidPathException
186
-	 * @throws NotFoundException
187
-	 */
188
-	public function getMTime() {
189
-		return $this->getFileInfo()->getMTime();
190
-	}
191
-
192
-	/**
193
-	 * @param bool $includeMounts
194
-	 * @return int
195
-	 * @throws InvalidPathException
196
-	 * @throws NotFoundException
197
-	 */
198
-	public function getSize($includeMounts = true) {
199
-		return $this->getFileInfo()->getSize($includeMounts);
200
-	}
201
-
202
-	/**
203
-	 * @return string
204
-	 * @throws InvalidPathException
205
-	 * @throws NotFoundException
206
-	 */
207
-	public function getEtag() {
208
-		return $this->getFileInfo()->getEtag();
209
-	}
210
-
211
-	/**
212
-	 * @return int
213
-	 * @throws InvalidPathException
214
-	 * @throws NotFoundException
215
-	 */
216
-	public function getPermissions() {
217
-		return $this->getFileInfo()->getPermissions();
218
-	}
219
-
220
-	/**
221
-	 * @return bool
222
-	 * @throws InvalidPathException
223
-	 * @throws NotFoundException
224
-	 */
225
-	public function isReadable() {
226
-		return $this->getFileInfo()->isReadable();
227
-	}
228
-
229
-	/**
230
-	 * @return bool
231
-	 * @throws InvalidPathException
232
-	 * @throws NotFoundException
233
-	 */
234
-	public function isUpdateable() {
235
-		return $this->getFileInfo()->isUpdateable();
236
-	}
237
-
238
-	/**
239
-	 * @return bool
240
-	 * @throws InvalidPathException
241
-	 * @throws NotFoundException
242
-	 */
243
-	public function isDeletable() {
244
-		return $this->getFileInfo()->isDeletable();
245
-	}
246
-
247
-	/**
248
-	 * @return bool
249
-	 * @throws InvalidPathException
250
-	 * @throws NotFoundException
251
-	 */
252
-	public function isShareable() {
253
-		return $this->getFileInfo()->isShareable();
254
-	}
255
-
256
-	/**
257
-	 * @return bool
258
-	 * @throws InvalidPathException
259
-	 * @throws NotFoundException
260
-	 */
261
-	public function isCreatable() {
262
-		return $this->getFileInfo()->isCreatable();
263
-	}
264
-
265
-	/**
266
-	 * @return Node
267
-	 */
268
-	public function getParent() {
269
-		$newPath = dirname($this->path);
270
-		if ($newPath === '' || $newPath === '.' || $newPath === '/') {
271
-			return $this->root;
272
-		}
273
-		return $this->root->get($newPath);
274
-	}
275
-
276
-	/**
277
-	 * @return string
278
-	 */
279
-	public function getName() {
280
-		return basename($this->path);
281
-	}
282
-
283
-	/**
284
-	 * @param string $path
285
-	 * @return string
286
-	 */
287
-	protected function normalizePath($path) {
288
-		if ($path === '' or $path === '/') {
289
-			return '/';
290
-		}
291
-		//no windows style slashes
292
-		$path = str_replace('\\', '/', $path);
293
-		//add leading slash
294
-		if ($path[0] !== '/') {
295
-			$path = '/' . $path;
296
-		}
297
-		//remove duplicate slashes
298
-		while (strpos($path, '//') !== false) {
299
-			$path = str_replace('//', '/', $path);
300
-		}
301
-		//remove trailing slash
302
-		$path = rtrim($path, '/');
303
-
304
-		return $path;
305
-	}
306
-
307
-	/**
308
-	 * check if the requested path is valid
309
-	 *
310
-	 * @param string $path
311
-	 * @return bool
312
-	 */
313
-	public function isValidPath($path) {
314
-		if (!$path || $path[0] !== '/') {
315
-			$path = '/' . $path;
316
-		}
317
-		if (strstr($path, '/../') || strrchr($path, '/') === '/..') {
318
-			return false;
319
-		}
320
-		return true;
321
-	}
322
-
323
-	public function isMounted() {
324
-		return $this->getFileInfo()->isMounted();
325
-	}
326
-
327
-	public function isShared() {
328
-		return $this->getFileInfo()->isShared();
329
-	}
330
-
331
-	public function getMimeType() {
332
-		return $this->getFileInfo()->getMimetype();
333
-	}
334
-
335
-	public function getMimePart() {
336
-		return $this->getFileInfo()->getMimePart();
337
-	}
338
-
339
-	public function getType() {
340
-		return $this->getFileInfo()->getType();
341
-	}
342
-
343
-	public function isEncrypted() {
344
-		return $this->getFileInfo()->isEncrypted();
345
-	}
346
-
347
-	public function getMountPoint() {
348
-		return $this->getFileInfo()->getMountPoint();
349
-	}
350
-
351
-	public function getOwner() {
352
-		return $this->getFileInfo()->getOwner();
353
-	}
354
-
355
-	public function getChecksum() {
356
-	}
357
-
358
-	public function getExtension(): string {
359
-		return $this->getFileInfo()->getExtension();
360
-	}
361
-
362
-	/**
363
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
364
-	 * @throws \OCP\Lock\LockedException
365
-	 */
366
-	public function lock($type) {
367
-		$this->view->lockFile($this->path, $type);
368
-	}
369
-
370
-	/**
371
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
372
-	 * @throws \OCP\Lock\LockedException
373
-	 */
374
-	public function changeLock($type) {
375
-		$this->view->changeLock($this->path, $type);
376
-	}
377
-
378
-	/**
379
-	 * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
380
-	 * @throws \OCP\Lock\LockedException
381
-	 */
382
-	public function unlock($type) {
383
-		$this->view->unlockFile($this->path, $type);
384
-	}
385
-
386
-	/**
387
-	 * @param string $targetPath
388
-	 * @throws \OCP\Files\NotPermittedException if copy not allowed or failed
389
-	 * @return \OC\Files\Node\Node
390
-	 */
391
-	public function copy($targetPath) {
392
-		$targetPath = $this->normalizePath($targetPath);
393
-		$parent = $this->root->get(dirname($targetPath));
394
-		if ($parent instanceof Folder and $this->isValidPath($targetPath) and $parent->isCreatable()) {
395
-			$nonExisting = $this->createNonExistingNode($targetPath);
396
-			$this->root->emit('\OC\Files', 'preCopy', [$this, $nonExisting]);
397
-			$this->root->emit('\OC\Files', 'preWrite', [$nonExisting]);
398
-			if (!$this->view->copy($this->path, $targetPath)) {
399
-				throw new NotPermittedException('Could not copy ' . $this->path . ' to ' . $targetPath);
400
-			}
401
-			$targetNode = $this->root->get($targetPath);
402
-			$this->root->emit('\OC\Files', 'postCopy', [$this, $targetNode]);
403
-			$this->root->emit('\OC\Files', 'postWrite', [$targetNode]);
404
-			return $targetNode;
405
-		} else {
406
-			throw new NotPermittedException('No permission to copy to path ' . $targetPath);
407
-		}
408
-	}
409
-
410
-	/**
411
-	 * @param string $targetPath
412
-	 * @throws \OCP\Files\NotPermittedException if move not allowed or failed
413
-	 * @return \OC\Files\Node\Node
414
-	 */
415
-	public function move($targetPath) {
416
-		$targetPath = $this->normalizePath($targetPath);
417
-		$parent = $this->root->get(dirname($targetPath));
418
-		if ($parent instanceof Folder and $this->isValidPath($targetPath) and $parent->isCreatable()) {
419
-			$nonExisting = $this->createNonExistingNode($targetPath);
420
-			$this->root->emit('\OC\Files', 'preRename', [$this, $nonExisting]);
421
-			$this->root->emit('\OC\Files', 'preWrite', [$nonExisting]);
422
-			if (!$this->view->rename($this->path, $targetPath)) {
423
-				throw new NotPermittedException('Could not move ' . $this->path . ' to ' . $targetPath);
424
-			}
425
-			$targetNode = $this->root->get($targetPath);
426
-			$this->root->emit('\OC\Files', 'postRename', [$this, $targetNode]);
427
-			$this->root->emit('\OC\Files', 'postWrite', [$targetNode]);
428
-			$this->path = $targetPath;
429
-			return $targetNode;
430
-		} else {
431
-			throw new NotPermittedException('No permission to move to path ' . $targetPath);
432
-		}
433
-	}
38
+    /**
39
+     * @var \OC\Files\View $view
40
+     */
41
+    protected $view;
42
+
43
+    /**
44
+     * @var \OC\Files\Node\Root $root
45
+     */
46
+    protected $root;
47
+
48
+    /**
49
+     * @var string $path
50
+     */
51
+    protected $path;
52
+
53
+    /**
54
+     * @var \OCP\Files\FileInfo
55
+     */
56
+    protected $fileInfo;
57
+
58
+    /**
59
+     * @param \OC\Files\View $view
60
+     * @param \OCP\Files\IRootFolder $root
61
+     * @param string $path
62
+     * @param FileInfo $fileInfo
63
+     */
64
+    public function __construct($root, $view, $path, $fileInfo = null) {
65
+        $this->view = $view;
66
+        $this->root = $root;
67
+        $this->path = $path;
68
+        $this->fileInfo = $fileInfo;
69
+    }
70
+
71
+    /**
72
+     * Creates a Node of the same type that represents a non-existing path
73
+     *
74
+     * @param string $path path
75
+     * @return string non-existing node class
76
+     */
77
+    protected function createNonExistingNode($path) {
78
+        throw new \Exception('Must be implemented by subclasses');
79
+    }
80
+
81
+    /**
82
+     * Returns the matching file info
83
+     *
84
+     * @return FileInfo
85
+     * @throws InvalidPathException
86
+     * @throws NotFoundException
87
+     */
88
+    public function getFileInfo() {
89
+        if (!Filesystem::isValidPath($this->path)) {
90
+            throw new InvalidPathException();
91
+        }
92
+        if (!$this->fileInfo) {
93
+            $fileInfo = $this->view->getFileInfo($this->path);
94
+            if ($fileInfo instanceof FileInfo) {
95
+                $this->fileInfo = $fileInfo;
96
+            } else {
97
+                throw new NotFoundException();
98
+            }
99
+        }
100
+        return $this->fileInfo;
101
+    }
102
+
103
+    /**
104
+     * @param string[] $hooks
105
+     */
106
+    protected function sendHooks($hooks) {
107
+        foreach ($hooks as $hook) {
108
+            $this->root->emit('\OC\Files', $hook, array($this));
109
+        }
110
+    }
111
+
112
+    /**
113
+     * @param int $permissions
114
+     * @return bool
115
+     */
116
+    protected function checkPermissions($permissions) {
117
+        return ($this->getPermissions() & $permissions) === $permissions;
118
+    }
119
+
120
+    public function delete() {
121
+    }
122
+
123
+    /**
124
+     * @param int $mtime
125
+     * @throws \OCP\Files\NotPermittedException
126
+     */
127
+    public function touch($mtime = null) {
128
+        if ($this->checkPermissions(\OCP\Constants::PERMISSION_UPDATE)) {
129
+            $this->sendHooks(array('preTouch'));
130
+            $this->view->touch($this->path, $mtime);
131
+            $this->sendHooks(array('postTouch'));
132
+            if ($this->fileInfo) {
133
+                if (is_null($mtime)) {
134
+                    $mtime = time();
135
+                }
136
+                $this->fileInfo['mtime'] = $mtime;
137
+            }
138
+        } else {
139
+            throw new NotPermittedException();
140
+        }
141
+    }
142
+
143
+    /**
144
+     * @return \OC\Files\Storage\Storage
145
+     * @throws \OCP\Files\NotFoundException
146
+     */
147
+    public function getStorage() {
148
+        list($storage,) = $this->view->resolvePath($this->path);
149
+        return $storage;
150
+    }
151
+
152
+    /**
153
+     * @return string
154
+     */
155
+    public function getPath() {
156
+        return $this->path;
157
+    }
158
+
159
+    /**
160
+     * @return string
161
+     */
162
+    public function getInternalPath() {
163
+        list(, $internalPath) = $this->view->resolvePath($this->path);
164
+        return $internalPath;
165
+    }
166
+
167
+    /**
168
+     * @return int
169
+     * @throws InvalidPathException
170
+     * @throws NotFoundException
171
+     */
172
+    public function getId() {
173
+        return $this->getFileInfo()->getId();
174
+    }
175
+
176
+    /**
177
+     * @return array
178
+     */
179
+    public function stat() {
180
+        return $this->view->stat($this->path);
181
+    }
182
+
183
+    /**
184
+     * @return int
185
+     * @throws InvalidPathException
186
+     * @throws NotFoundException
187
+     */
188
+    public function getMTime() {
189
+        return $this->getFileInfo()->getMTime();
190
+    }
191
+
192
+    /**
193
+     * @param bool $includeMounts
194
+     * @return int
195
+     * @throws InvalidPathException
196
+     * @throws NotFoundException
197
+     */
198
+    public function getSize($includeMounts = true) {
199
+        return $this->getFileInfo()->getSize($includeMounts);
200
+    }
201
+
202
+    /**
203
+     * @return string
204
+     * @throws InvalidPathException
205
+     * @throws NotFoundException
206
+     */
207
+    public function getEtag() {
208
+        return $this->getFileInfo()->getEtag();
209
+    }
210
+
211
+    /**
212
+     * @return int
213
+     * @throws InvalidPathException
214
+     * @throws NotFoundException
215
+     */
216
+    public function getPermissions() {
217
+        return $this->getFileInfo()->getPermissions();
218
+    }
219
+
220
+    /**
221
+     * @return bool
222
+     * @throws InvalidPathException
223
+     * @throws NotFoundException
224
+     */
225
+    public function isReadable() {
226
+        return $this->getFileInfo()->isReadable();
227
+    }
228
+
229
+    /**
230
+     * @return bool
231
+     * @throws InvalidPathException
232
+     * @throws NotFoundException
233
+     */
234
+    public function isUpdateable() {
235
+        return $this->getFileInfo()->isUpdateable();
236
+    }
237
+
238
+    /**
239
+     * @return bool
240
+     * @throws InvalidPathException
241
+     * @throws NotFoundException
242
+     */
243
+    public function isDeletable() {
244
+        return $this->getFileInfo()->isDeletable();
245
+    }
246
+
247
+    /**
248
+     * @return bool
249
+     * @throws InvalidPathException
250
+     * @throws NotFoundException
251
+     */
252
+    public function isShareable() {
253
+        return $this->getFileInfo()->isShareable();
254
+    }
255
+
256
+    /**
257
+     * @return bool
258
+     * @throws InvalidPathException
259
+     * @throws NotFoundException
260
+     */
261
+    public function isCreatable() {
262
+        return $this->getFileInfo()->isCreatable();
263
+    }
264
+
265
+    /**
266
+     * @return Node
267
+     */
268
+    public function getParent() {
269
+        $newPath = dirname($this->path);
270
+        if ($newPath === '' || $newPath === '.' || $newPath === '/') {
271
+            return $this->root;
272
+        }
273
+        return $this->root->get($newPath);
274
+    }
275
+
276
+    /**
277
+     * @return string
278
+     */
279
+    public function getName() {
280
+        return basename($this->path);
281
+    }
282
+
283
+    /**
284
+     * @param string $path
285
+     * @return string
286
+     */
287
+    protected function normalizePath($path) {
288
+        if ($path === '' or $path === '/') {
289
+            return '/';
290
+        }
291
+        //no windows style slashes
292
+        $path = str_replace('\\', '/', $path);
293
+        //add leading slash
294
+        if ($path[0] !== '/') {
295
+            $path = '/' . $path;
296
+        }
297
+        //remove duplicate slashes
298
+        while (strpos($path, '//') !== false) {
299
+            $path = str_replace('//', '/', $path);
300
+        }
301
+        //remove trailing slash
302
+        $path = rtrim($path, '/');
303
+
304
+        return $path;
305
+    }
306
+
307
+    /**
308
+     * check if the requested path is valid
309
+     *
310
+     * @param string $path
311
+     * @return bool
312
+     */
313
+    public function isValidPath($path) {
314
+        if (!$path || $path[0] !== '/') {
315
+            $path = '/' . $path;
316
+        }
317
+        if (strstr($path, '/../') || strrchr($path, '/') === '/..') {
318
+            return false;
319
+        }
320
+        return true;
321
+    }
322
+
323
+    public function isMounted() {
324
+        return $this->getFileInfo()->isMounted();
325
+    }
326
+
327
+    public function isShared() {
328
+        return $this->getFileInfo()->isShared();
329
+    }
330
+
331
+    public function getMimeType() {
332
+        return $this->getFileInfo()->getMimetype();
333
+    }
334
+
335
+    public function getMimePart() {
336
+        return $this->getFileInfo()->getMimePart();
337
+    }
338
+
339
+    public function getType() {
340
+        return $this->getFileInfo()->getType();
341
+    }
342
+
343
+    public function isEncrypted() {
344
+        return $this->getFileInfo()->isEncrypted();
345
+    }
346
+
347
+    public function getMountPoint() {
348
+        return $this->getFileInfo()->getMountPoint();
349
+    }
350
+
351
+    public function getOwner() {
352
+        return $this->getFileInfo()->getOwner();
353
+    }
354
+
355
+    public function getChecksum() {
356
+    }
357
+
358
+    public function getExtension(): string {
359
+        return $this->getFileInfo()->getExtension();
360
+    }
361
+
362
+    /**
363
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
364
+     * @throws \OCP\Lock\LockedException
365
+     */
366
+    public function lock($type) {
367
+        $this->view->lockFile($this->path, $type);
368
+    }
369
+
370
+    /**
371
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
372
+     * @throws \OCP\Lock\LockedException
373
+     */
374
+    public function changeLock($type) {
375
+        $this->view->changeLock($this->path, $type);
376
+    }
377
+
378
+    /**
379
+     * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
380
+     * @throws \OCP\Lock\LockedException
381
+     */
382
+    public function unlock($type) {
383
+        $this->view->unlockFile($this->path, $type);
384
+    }
385
+
386
+    /**
387
+     * @param string $targetPath
388
+     * @throws \OCP\Files\NotPermittedException if copy not allowed or failed
389
+     * @return \OC\Files\Node\Node
390
+     */
391
+    public function copy($targetPath) {
392
+        $targetPath = $this->normalizePath($targetPath);
393
+        $parent = $this->root->get(dirname($targetPath));
394
+        if ($parent instanceof Folder and $this->isValidPath($targetPath) and $parent->isCreatable()) {
395
+            $nonExisting = $this->createNonExistingNode($targetPath);
396
+            $this->root->emit('\OC\Files', 'preCopy', [$this, $nonExisting]);
397
+            $this->root->emit('\OC\Files', 'preWrite', [$nonExisting]);
398
+            if (!$this->view->copy($this->path, $targetPath)) {
399
+                throw new NotPermittedException('Could not copy ' . $this->path . ' to ' . $targetPath);
400
+            }
401
+            $targetNode = $this->root->get($targetPath);
402
+            $this->root->emit('\OC\Files', 'postCopy', [$this, $targetNode]);
403
+            $this->root->emit('\OC\Files', 'postWrite', [$targetNode]);
404
+            return $targetNode;
405
+        } else {
406
+            throw new NotPermittedException('No permission to copy to path ' . $targetPath);
407
+        }
408
+    }
409
+
410
+    /**
411
+     * @param string $targetPath
412
+     * @throws \OCP\Files\NotPermittedException if move not allowed or failed
413
+     * @return \OC\Files\Node\Node
414
+     */
415
+    public function move($targetPath) {
416
+        $targetPath = $this->normalizePath($targetPath);
417
+        $parent = $this->root->get(dirname($targetPath));
418
+        if ($parent instanceof Folder and $this->isValidPath($targetPath) and $parent->isCreatable()) {
419
+            $nonExisting = $this->createNonExistingNode($targetPath);
420
+            $this->root->emit('\OC\Files', 'preRename', [$this, $nonExisting]);
421
+            $this->root->emit('\OC\Files', 'preWrite', [$nonExisting]);
422
+            if (!$this->view->rename($this->path, $targetPath)) {
423
+                throw new NotPermittedException('Could not move ' . $this->path . ' to ' . $targetPath);
424
+            }
425
+            $targetNode = $this->root->get($targetPath);
426
+            $this->root->emit('\OC\Files', 'postRename', [$this, $targetNode]);
427
+            $this->root->emit('\OC\Files', 'postWrite', [$targetNode]);
428
+            $this->path = $targetPath;
429
+            return $targetNode;
430
+        } else {
431
+            throw new NotPermittedException('No permission to move to path ' . $targetPath);
432
+        }
433
+    }
434 434
 
435 435
 }
Please login to merge, or discard this patch.
lib/private/Files/Mount/ObjectHomeMountProvider.php 2 patches
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -64,7 +64,7 @@
 block discarded – undo
64 64
 			return null;
65 65
 		}
66 66
 
67
-		return new MountPoint('\OC\Files\ObjectStore\HomeObjectStoreStorage', '/' . $user->getUID(), $config['arguments'], $loader);
67
+		return new MountPoint('\OC\Files\ObjectStore\HomeObjectStoreStorage', '/'.$user->getUID(), $config['arguments'], $loader);
68 68
 	}
69 69
 
70 70
 	/**
Please login to merge, or discard this patch.
Indentation   +100 added lines, -100 removed lines patch added patch discarded remove patch
@@ -33,107 +33,107 @@
 block discarded – undo
33 33
  * Mount provider for object store home storages
34 34
  */
35 35
 class ObjectHomeMountProvider implements IHomeMountProvider {
36
-	/**
37
-	 * @var IConfig
38
-	 */
39
-	private $config;
40
-
41
-	/**
42
-	 * ObjectStoreHomeMountProvider constructor.
43
-	 *
44
-	 * @param IConfig $config
45
-	 */
46
-	public function __construct(IConfig $config) {
47
-		$this->config = $config;
48
-	}
49
-
50
-	/**
51
-	 * Get the cache mount for a user
52
-	 *
53
-	 * @param IUser $user
54
-	 * @param IStorageFactory $loader
55
-	 * @return \OCP\Files\Mount\IMountPoint
56
-	 */
57
-	public function getHomeMountForUser(IUser $user, IStorageFactory $loader) {
58
-
59
-		$config = $this->getMultiBucketObjectStoreConfig($user);
60
-		if ($config === null) {
61
-			$config = $this->getSingleBucketObjectStoreConfig($user);
62
-		}
63
-
64
-		if ($config === null) {
65
-			return null;
66
-		}
67
-
68
-		return new MountPoint('\OC\Files\ObjectStore\HomeObjectStoreStorage', '/' . $user->getUID(), $config['arguments'], $loader);
69
-	}
70
-
71
-	/**
72
-	 * @param IUser $user
73
-	 * @return array|null
74
-	 */
75
-	private function getSingleBucketObjectStoreConfig(IUser $user) {
76
-		$config = $this->config->getSystemValue('objectstore');
77
-		if (!is_array($config)) {
78
-			return null;
79
-		}
80
-
81
-		// sanity checks
82
-		if (empty($config['class'])) {
83
-			\OCP\Util::writeLog('files', 'No class given for objectstore', ILogger::ERROR);
84
-		}
85
-		if (!isset($config['arguments'])) {
86
-			$config['arguments'] = [];
87
-		}
88
-		// instantiate object store implementation
89
-		$config['arguments']['objectstore'] = new $config['class']($config['arguments']);
90
-
91
-		$config['arguments']['user'] = $user;
92
-
93
-		return $config;
94
-	}
95
-
96
-	/**
97
-	 * @param IUser $user
98
-	 * @return array|null
99
-	 */
100
-	private function getMultiBucketObjectStoreConfig(IUser $user) {
101
-		$config = $this->config->getSystemValue('objectstore_multibucket');
102
-		if (!is_array($config)) {
103
-			return null;
104
-		}
105
-
106
-		// sanity checks
107
-		if (empty($config['class'])) {
108
-			\OCP\Util::writeLog('files', 'No class given for objectstore', ILogger::ERROR);
109
-		}
110
-		if (!isset($config['arguments'])) {
111
-			$config['arguments'] = [];
112
-		}
113
-		$config['arguments']['user'] = $user;
114
-
115
-		$bucket = $this->config->getUserValue($user->getUID(), 'homeobjectstore', 'bucket', null);
116
-
117
-		if ($bucket === null) {
118
-			/*
36
+    /**
37
+     * @var IConfig
38
+     */
39
+    private $config;
40
+
41
+    /**
42
+     * ObjectStoreHomeMountProvider constructor.
43
+     *
44
+     * @param IConfig $config
45
+     */
46
+    public function __construct(IConfig $config) {
47
+        $this->config = $config;
48
+    }
49
+
50
+    /**
51
+     * Get the cache mount for a user
52
+     *
53
+     * @param IUser $user
54
+     * @param IStorageFactory $loader
55
+     * @return \OCP\Files\Mount\IMountPoint
56
+     */
57
+    public function getHomeMountForUser(IUser $user, IStorageFactory $loader) {
58
+
59
+        $config = $this->getMultiBucketObjectStoreConfig($user);
60
+        if ($config === null) {
61
+            $config = $this->getSingleBucketObjectStoreConfig($user);
62
+        }
63
+
64
+        if ($config === null) {
65
+            return null;
66
+        }
67
+
68
+        return new MountPoint('\OC\Files\ObjectStore\HomeObjectStoreStorage', '/' . $user->getUID(), $config['arguments'], $loader);
69
+    }
70
+
71
+    /**
72
+     * @param IUser $user
73
+     * @return array|null
74
+     */
75
+    private function getSingleBucketObjectStoreConfig(IUser $user) {
76
+        $config = $this->config->getSystemValue('objectstore');
77
+        if (!is_array($config)) {
78
+            return null;
79
+        }
80
+
81
+        // sanity checks
82
+        if (empty($config['class'])) {
83
+            \OCP\Util::writeLog('files', 'No class given for objectstore', ILogger::ERROR);
84
+        }
85
+        if (!isset($config['arguments'])) {
86
+            $config['arguments'] = [];
87
+        }
88
+        // instantiate object store implementation
89
+        $config['arguments']['objectstore'] = new $config['class']($config['arguments']);
90
+
91
+        $config['arguments']['user'] = $user;
92
+
93
+        return $config;
94
+    }
95
+
96
+    /**
97
+     * @param IUser $user
98
+     * @return array|null
99
+     */
100
+    private function getMultiBucketObjectStoreConfig(IUser $user) {
101
+        $config = $this->config->getSystemValue('objectstore_multibucket');
102
+        if (!is_array($config)) {
103
+            return null;
104
+        }
105
+
106
+        // sanity checks
107
+        if (empty($config['class'])) {
108
+            \OCP\Util::writeLog('files', 'No class given for objectstore', ILogger::ERROR);
109
+        }
110
+        if (!isset($config['arguments'])) {
111
+            $config['arguments'] = [];
112
+        }
113
+        $config['arguments']['user'] = $user;
114
+
115
+        $bucket = $this->config->getUserValue($user->getUID(), 'homeobjectstore', 'bucket', null);
116
+
117
+        if ($bucket === null) {
118
+            /*
119 119
 			 * Use any provided bucket argument as prefix
120 120
 			 * and add the mapping from username => bucket
121 121
 			 */
122
-			if (!isset($config['arguments']['bucket'])) {
123
-				$config['arguments']['bucket'] = '';
124
-			}
125
-			$mapper = new \OC\Files\ObjectStore\Mapper($user);
126
-			$numBuckets = isset($config['arguments']['num_buckets']) ? $config['arguments']['num_buckets'] : 64;
127
-			$config['arguments']['bucket'] .= $mapper->getBucket($numBuckets);
128
-
129
-			$this->config->setUserValue($user->getUID(), 'homeobjectstore', 'bucket', $config['arguments']['bucket']);
130
-		} else {
131
-			$config['arguments']['bucket'] = $bucket;
132
-		}
133
-
134
-		// instantiate object store implementation
135
-		$config['arguments']['objectstore'] = new $config['class']($config['arguments']);
136
-
137
-		return $config;
138
-	}
122
+            if (!isset($config['arguments']['bucket'])) {
123
+                $config['arguments']['bucket'] = '';
124
+            }
125
+            $mapper = new \OC\Files\ObjectStore\Mapper($user);
126
+            $numBuckets = isset($config['arguments']['num_buckets']) ? $config['arguments']['num_buckets'] : 64;
127
+            $config['arguments']['bucket'] .= $mapper->getBucket($numBuckets);
128
+
129
+            $this->config->setUserValue($user->getUID(), 'homeobjectstore', 'bucket', $config['arguments']['bucket']);
130
+        } else {
131
+            $config['arguments']['bucket'] = $bucket;
132
+        }
133
+
134
+        // instantiate object store implementation
135
+        $config['arguments']['objectstore'] = new $config['class']($config['arguments']);
136
+
137
+        return $config;
138
+    }
139 139
 }
Please login to merge, or discard this patch.
lib/private/Files/Mount/LocalHomeMountProvider.php 2 patches
Indentation   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -30,15 +30,15 @@
 block discarded – undo
30 30
  * Mount provider for regular posix home folders
31 31
  */
32 32
 class LocalHomeMountProvider implements IHomeMountProvider {
33
-	/**
34
-	 * Get the cache mount for a user
35
-	 *
36
-	 * @param IUser $user
37
-	 * @param IStorageFactory $loader
38
-	 * @return \OCP\Files\Mount\IMountPoint[]
39
-	 */
40
-	public function getHomeMountForUser(IUser $user, IStorageFactory $loader) {
41
-		$arguments = ['user' => $user];
42
-		return new MountPoint('\OC\Files\Storage\Home', '/' . $user->getUID(), $arguments, $loader);
43
-	}
33
+    /**
34
+     * Get the cache mount for a user
35
+     *
36
+     * @param IUser $user
37
+     * @param IStorageFactory $loader
38
+     * @return \OCP\Files\Mount\IMountPoint[]
39
+     */
40
+    public function getHomeMountForUser(IUser $user, IStorageFactory $loader) {
41
+        $arguments = ['user' => $user];
42
+        return new MountPoint('\OC\Files\Storage\Home', '/' . $user->getUID(), $arguments, $loader);
43
+    }
44 44
 }
Please login to merge, or discard this patch.
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -39,6 +39,6 @@
 block discarded – undo
39 39
 	 */
40 40
 	public function getHomeMountForUser(IUser $user, IStorageFactory $loader) {
41 41
 		$arguments = ['user' => $user];
42
-		return new MountPoint('\OC\Files\Storage\Home', '/' . $user->getUID(), $arguments, $loader);
42
+		return new MountPoint('\OC\Files\Storage\Home', '/'.$user->getUID(), $arguments, $loader);
43 43
 	}
44 44
 }
Please login to merge, or discard this patch.
lib/private/Files/Mount/MoveableMount.php 1 patch
Indentation   +14 added lines, -14 removed lines patch added patch discarded remove patch
@@ -27,19 +27,19 @@
 block discarded – undo
27 27
  * Defines the mount point to be (re)moved by the user
28 28
  */
29 29
 interface MoveableMount {
30
-	/**
31
-	 * Move the mount point to $target
32
-	 *
33
-	 * @param string $target the target mount point
34
-	 * @return bool
35
-	 */
36
-	public function moveMount($target);
30
+    /**
31
+     * Move the mount point to $target
32
+     *
33
+     * @param string $target the target mount point
34
+     * @return bool
35
+     */
36
+    public function moveMount($target);
37 37
 
38
-	/**
39
-	 * Remove the mount points
40
-	 *
41
-	 * @return mixed
42
-	 * @return bool
43
-	 */
44
-	public function removeMount();
38
+    /**
39
+     * Remove the mount points
40
+     *
41
+     * @return mixed
42
+     * @return bool
43
+     */
44
+    public function removeMount();
45 45
 }
Please login to merge, or discard this patch.
lib/private/Files/Stream/Quota.php 3 patches
Indentation   +60 added lines, -60 removed lines patch added patch discarded remove patch
@@ -33,71 +33,71 @@
 block discarded – undo
33 33
  * usage: resource \OC\Files\Stream\Quota::wrap($stream, $limit)
34 34
  */
35 35
 class Quota extends Wrapper {
36
-	/**
37
-	 * @var int $limit
38
-	 */
39
-	private $limit;
36
+    /**
37
+     * @var int $limit
38
+     */
39
+    private $limit;
40 40
 
41
-	/**
42
-	 * @param resource $stream
43
-	 * @param int $limit
44
-	 * @return resource
45
-	 */
46
-	static public function wrap($stream, $limit) {
47
-		$context = stream_context_create(array(
48
-			'quota' => array(
49
-				'source' => $stream,
50
-				'limit' => $limit
51
-			)
52
-		));
53
-		return Wrapper::wrapSource($stream, $context, 'quota', self::class);
54
-	}
41
+    /**
42
+     * @param resource $stream
43
+     * @param int $limit
44
+     * @return resource
45
+     */
46
+    static public function wrap($stream, $limit) {
47
+        $context = stream_context_create(array(
48
+            'quota' => array(
49
+                'source' => $stream,
50
+                'limit' => $limit
51
+            )
52
+        ));
53
+        return Wrapper::wrapSource($stream, $context, 'quota', self::class);
54
+    }
55 55
 
56
-	public function stream_open($path, $mode, $options, &$opened_path) {
57
-		$context = $this->loadContext('quota');
58
-		$this->source = $context['source'];
59
-		$this->limit = $context['limit'];
56
+    public function stream_open($path, $mode, $options, &$opened_path) {
57
+        $context = $this->loadContext('quota');
58
+        $this->source = $context['source'];
59
+        $this->limit = $context['limit'];
60 60
 
61
-		return true;
62
-	}
61
+        return true;
62
+    }
63 63
 
64
-	public function dir_opendir($path, $options) {
65
-		return false;
66
-	}
64
+    public function dir_opendir($path, $options) {
65
+        return false;
66
+    }
67 67
 
68
-	public function stream_seek($offset, $whence = SEEK_SET) {
69
-		if ($whence === SEEK_END){
70
-			// go to the end to find out last position's offset
71
-			$oldOffset = $this->stream_tell();
72
-			if (fseek($this->source, 0, $whence) !== 0){
73
-				return false;
74
-			}
75
-			$whence = SEEK_SET;
76
-			$offset = $this->stream_tell() + $offset;
77
-			$this->limit += $oldOffset - $offset;
78
-		}
79
-		else if ($whence === SEEK_SET) {
80
-			$this->limit += $this->stream_tell() - $offset;
81
-		} else {
82
-			$this->limit -= $offset;
83
-		}
84
-		// this wrapper needs to return "true" for success.
85
-		// the fseek call itself returns 0 on succeess
86
-		return fseek($this->source, $offset, $whence) === 0;
87
-	}
68
+    public function stream_seek($offset, $whence = SEEK_SET) {
69
+        if ($whence === SEEK_END){
70
+            // go to the end to find out last position's offset
71
+            $oldOffset = $this->stream_tell();
72
+            if (fseek($this->source, 0, $whence) !== 0){
73
+                return false;
74
+            }
75
+            $whence = SEEK_SET;
76
+            $offset = $this->stream_tell() + $offset;
77
+            $this->limit += $oldOffset - $offset;
78
+        }
79
+        else if ($whence === SEEK_SET) {
80
+            $this->limit += $this->stream_tell() - $offset;
81
+        } else {
82
+            $this->limit -= $offset;
83
+        }
84
+        // this wrapper needs to return "true" for success.
85
+        // the fseek call itself returns 0 on succeess
86
+        return fseek($this->source, $offset, $whence) === 0;
87
+    }
88 88
 
89
-	public function stream_read($count) {
90
-		$this->limit -= $count;
91
-		return fread($this->source, $count);
92
-	}
89
+    public function stream_read($count) {
90
+        $this->limit -= $count;
91
+        return fread($this->source, $count);
92
+    }
93 93
 
94
-	public function stream_write($data) {
95
-		$size = strlen($data);
96
-		if ($size > $this->limit) {
97
-			$data = substr($data, 0, $this->limit);
98
-			$size = $this->limit;
99
-		}
100
-		$this->limit -= $size;
101
-		return fwrite($this->source, $data);
102
-	}
94
+    public function stream_write($data) {
95
+        $size = strlen($data);
96
+        if ($size > $this->limit) {
97
+            $data = substr($data, 0, $this->limit);
98
+            $size = $this->limit;
99
+        }
100
+        $this->limit -= $size;
101
+        return fwrite($this->source, $data);
102
+    }
103 103
 }
Please login to merge, or discard this patch.
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -66,10 +66,10 @@
 block discarded – undo
66 66
 	}
67 67
 
68 68
 	public function stream_seek($offset, $whence = SEEK_SET) {
69
-		if ($whence === SEEK_END){
69
+		if ($whence === SEEK_END) {
70 70
 			// go to the end to find out last position's offset
71 71
 			$oldOffset = $this->stream_tell();
72
-			if (fseek($this->source, 0, $whence) !== 0){
72
+			if (fseek($this->source, 0, $whence) !== 0) {
73 73
 				return false;
74 74
 			}
75 75
 			$whence = SEEK_SET;
Please login to merge, or discard this patch.
Braces   +1 added lines, -2 removed lines patch added patch discarded remove patch
@@ -75,8 +75,7 @@
 block discarded – undo
75 75
 			$whence = SEEK_SET;
76 76
 			$offset = $this->stream_tell() + $offset;
77 77
 			$this->limit += $oldOffset - $offset;
78
-		}
79
-		else if ($whence === SEEK_SET) {
78
+		} else if ($whence === SEEK_SET) {
80 79
 			$this->limit += $this->stream_tell() - $offset;
81 80
 		} else {
82 81
 			$this->limit -= $offset;
Please login to merge, or discard this patch.