@@ -61,7 +61,7 @@ discard block |
||
61 | 61 | } |
62 | 62 | |
63 | 63 | private function getCredentialsIdentifier($storageId) { |
64 | - return self::CREDENTIALS_IDENTIFIER_PREFIX . $storageId; |
|
64 | + return self::CREDENTIALS_IDENTIFIER_PREFIX.$storageId; |
|
65 | 65 | } |
66 | 66 | |
67 | 67 | public function saveBackendOptions(IUser $user, $id, array $options) { |
@@ -71,7 +71,7 @@ discard block |
||
71 | 71 | ]); |
72 | 72 | } |
73 | 73 | |
74 | - public function manipulateStorageConfig(StorageConfig &$storage, IUser $user = null) { |
|
74 | + public function manipulateStorageConfig(StorageConfig & $storage, IUser $user = null) { |
|
75 | 75 | if (!isset($user)) { |
76 | 76 | throw new InsufficientDataForMeaningfulAnswerException('No credentials saved'); |
77 | 77 | } |
@@ -70,7 +70,7 @@ |
||
70 | 70 | ]); |
71 | 71 | } |
72 | 72 | |
73 | - public function manipulateStorageConfig(StorageConfig &$storage, IUser $user = null) { |
|
73 | + public function manipulateStorageConfig(StorageConfig & $storage, IUser $user = null) { |
|
74 | 74 | if ($storage->getType() === StorageConfig::MOUNT_TYPE_ADMIN) { |
75 | 75 | $uid = ''; |
76 | 76 | } elseif (is_null($user)) { |
@@ -57,7 +57,7 @@ |
||
57 | 57 | ; |
58 | 58 | } |
59 | 59 | |
60 | - public function manipulateStorageConfig(StorageConfig &$storage, IUser $user = null) { |
|
60 | + public function manipulateStorageConfig(StorageConfig & $storage, IUser $user = null) { |
|
61 | 61 | $auth = new RSACrypt(); |
62 | 62 | $auth->setPassword($this->config->getSystemValue('secret', '')); |
63 | 63 | if (!$auth->loadKey($storage->getBackendOption('private_key'))) { |
@@ -123,7 +123,7 @@ discard block |
||
123 | 123 | if (isset($this->driveFiles[$path])) { |
124 | 124 | $parentId = $this->driveFiles[$path]->getId(); |
125 | 125 | } else { |
126 | - $q = "title='" . str_replace("'","\\'", $name) . "' and '" . str_replace("'","\\'", $parentId) . "' in parents and trashed = false"; |
|
126 | + $q = "title='".str_replace("'", "\\'", $name)."' and '".str_replace("'", "\\'", $parentId)."' in parents and trashed = false"; |
|
127 | 127 | $result = $this->service->files->listFiles(array('q' => $q))->getItems(); |
128 | 128 | if (!empty($result)) { |
129 | 129 | // Google Drive allows files with the same name, ownCloud doesn't |
@@ -236,7 +236,7 @@ discard block |
||
236 | 236 | if ($result) { |
237 | 237 | $this->setDriveFile($path, $result); |
238 | 238 | } |
239 | - return (bool)$result; |
|
239 | + return (bool) $result; |
|
240 | 240 | } |
241 | 241 | } |
242 | 242 | return false; |
@@ -248,7 +248,7 @@ discard block |
||
248 | 248 | } |
249 | 249 | if (trim($path, '/') === '') { |
250 | 250 | $dir = $this->opendir($path); |
251 | - if(is_resource($dir)) { |
|
251 | + if (is_resource($dir)) { |
|
252 | 252 | while (($file = readdir($dir)) !== false) { |
253 | 253 | if (!\OC\Files\Filesystem::isIgnoredDir($file)) { |
254 | 254 | if (!$this->unlink($path.'/'.$file)) { |
@@ -276,7 +276,7 @@ discard block |
||
276 | 276 | if ($pageToken !== true) { |
277 | 277 | $params['pageToken'] = $pageToken; |
278 | 278 | } |
279 | - $params['q'] = "'" . str_replace("'","\\'", $folder->getId()) . "' in parents and trashed = false"; |
|
279 | + $params['q'] = "'".str_replace("'", "\\'", $folder->getId())."' in parents and trashed = false"; |
|
280 | 280 | $children = $this->service->files->listFiles($params); |
281 | 281 | foreach ($children->getItems() as $child) { |
282 | 282 | $name = $child->getTitle(); |
@@ -369,7 +369,7 @@ discard block |
||
369 | 369 | } |
370 | 370 | |
371 | 371 | public function file_exists($path) { |
372 | - return (bool)$this->getDriveFile($path); |
|
372 | + return (bool) $this->getDriveFile($path); |
|
373 | 373 | } |
374 | 374 | |
375 | 375 | public function unlink($path) { |
@@ -379,7 +379,7 @@ discard block |
||
379 | 379 | if ($result) { |
380 | 380 | $this->setDriveFile($path, false); |
381 | 381 | } |
382 | - return (bool)$result; |
|
382 | + return (bool) $result; |
|
383 | 383 | } else { |
384 | 384 | return false; |
385 | 385 | } |
@@ -427,7 +427,7 @@ discard block |
||
427 | 427 | } |
428 | 428 | } |
429 | 429 | } |
430 | - return (bool)$result; |
|
430 | + return (bool) $result; |
|
431 | 431 | } else { |
432 | 432 | return false; |
433 | 433 | } |
@@ -462,10 +462,10 @@ discard block |
||
462 | 462 | $response = $client->get($downloadUrl, [ |
463 | 463 | 'headers' => $httpRequest->getRequestHeaders(), |
464 | 464 | 'stream' => true, |
465 | - 'verify' => realpath(__DIR__ . '/../../../3rdparty/google-api-php-client/src/Google/IO/cacerts.pem'), |
|
465 | + 'verify' => realpath(__DIR__.'/../../../3rdparty/google-api-php-client/src/Google/IO/cacerts.pem'), |
|
466 | 466 | ]); |
467 | 467 | } catch (RequestException $e) { |
468 | - if(!is_null($e->getResponse())) { |
|
468 | + if (!is_null($e->getResponse())) { |
|
469 | 469 | if ($e->getResponse()->getStatusCode() === 404) { |
470 | 470 | return false; |
471 | 471 | } else { |
@@ -499,7 +499,7 @@ discard block |
||
499 | 499 | file_put_contents($tmpFile, $source); |
500 | 500 | } |
501 | 501 | $handle = fopen($tmpFile, $mode); |
502 | - return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
502 | + return CallbackWrapper::wrap($handle, null, null, function() use ($path, $tmpFile) { |
|
503 | 503 | $this->writeBack($tmpFile, $path); |
504 | 504 | }); |
505 | 505 | } |
@@ -641,7 +641,7 @@ discard block |
||
641 | 641 | if ($result) { |
642 | 642 | $this->setDriveFile($path, $result); |
643 | 643 | } |
644 | - return (bool)$result; |
|
644 | + return (bool) $result; |
|
645 | 645 | } |
646 | 646 | |
647 | 647 | public function test() { |
@@ -668,7 +668,7 @@ discard block |
||
668 | 668 | 'includeSubscribed' => true, |
669 | 669 | ); |
670 | 670 | if (isset($startChangeId)) { |
671 | - $startChangeId = (int)$startChangeId; |
|
671 | + $startChangeId = (int) $startChangeId; |
|
672 | 672 | $largestChangeId = $startChangeId; |
673 | 673 | $params['startChangeId'] = $startChangeId + 1; |
674 | 674 | } else { |
@@ -62,11 +62,11 @@ discard block |
||
62 | 62 | $input = $host; |
63 | 63 | if (strpos($host, '://') === false) { |
64 | 64 | // add a protocol to fix parse_url behavior with ipv6 |
65 | - $host = 'http://' . $host; |
|
65 | + $host = 'http://'.$host; |
|
66 | 66 | } |
67 | 67 | |
68 | 68 | $parsed = parse_url($host); |
69 | - if(is_array($parsed) && isset($parsed['port'])) { |
|
69 | + if (is_array($parsed) && isset($parsed['port'])) { |
|
70 | 70 | return [$parsed['host'], $parsed['port']]; |
71 | 71 | } else if (is_array($parsed)) { |
72 | 72 | return [$parsed['host'], 22]; |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | // Register sftp:// |
83 | 83 | Stream::register(); |
84 | 84 | |
85 | - $parsedHost = $this->splitHost($params['host']); |
|
85 | + $parsedHost = $this->splitHost($params['host']); |
|
86 | 86 | |
87 | 87 | $this->host = $parsedHost[0]; |
88 | 88 | $this->port = $parsedHost[1]; |
@@ -104,7 +104,7 @@ discard block |
||
104 | 104 | = isset($params['root']) ? $this->cleanPath($params['root']) : '/'; |
105 | 105 | |
106 | 106 | if ($this->root[0] != '/') { |
107 | - $this->root = '/' . $this->root; |
|
107 | + $this->root = '/'.$this->root; |
|
108 | 108 | } |
109 | 109 | |
110 | 110 | if (substr($this->root, -1, 1) != '/') { |
@@ -159,15 +159,15 @@ discard block |
||
159 | 159 | /** |
160 | 160 | * {@inheritdoc} |
161 | 161 | */ |
162 | - public function getId(){ |
|
163 | - $id = 'sftp::' . $this->user . '@' . $this->host; |
|
162 | + public function getId() { |
|
163 | + $id = 'sftp::'.$this->user.'@'.$this->host; |
|
164 | 164 | if ($this->port !== 22) { |
165 | - $id .= ':' . $this->port; |
|
165 | + $id .= ':'.$this->port; |
|
166 | 166 | } |
167 | 167 | // note: this will double the root slash, |
168 | 168 | // we should not change it to keep compatible with |
169 | 169 | // old storage ids |
170 | - $id .= '/' . $this->root; |
|
170 | + $id .= '/'.$this->root; |
|
171 | 171 | return $id; |
172 | 172 | } |
173 | 173 | |
@@ -197,7 +197,7 @@ discard block |
||
197 | 197 | * @return string |
198 | 198 | */ |
199 | 199 | private function absPath($path) { |
200 | - return $this->root . $this->cleanPath($path); |
|
200 | + return $this->root.$this->cleanPath($path); |
|
201 | 201 | } |
202 | 202 | |
203 | 203 | /** |
@@ -207,8 +207,8 @@ discard block |
||
207 | 207 | try { |
208 | 208 | $storage_view = \OCP\Files::getStorage('files_external'); |
209 | 209 | if ($storage_view) { |
210 | - return \OC::$server->getConfig()->getSystemValue('datadirectory', \OC::$SERVERROOT . '/data') . |
|
211 | - $storage_view->getAbsolutePath('') . |
|
210 | + return \OC::$server->getConfig()->getSystemValue('datadirectory', \OC::$SERVERROOT.'/data'). |
|
211 | + $storage_view->getAbsolutePath(''). |
|
212 | 212 | 'ssh_hostKeys'; |
213 | 213 | } |
214 | 214 | } catch (\Exception $e) { |
@@ -226,7 +226,7 @@ discard block |
||
226 | 226 | if ($keyPath && file_exists($keyPath)) { |
227 | 227 | $fp = fopen($keyPath, 'w'); |
228 | 228 | foreach ($keys as $host => $key) { |
229 | - fwrite($fp, $host . '::' . $key . "\n"); |
|
229 | + fwrite($fp, $host.'::'.$key."\n"); |
|
230 | 230 | } |
231 | 231 | fclose($fp); |
232 | 232 | return true; |
@@ -298,15 +298,15 @@ discard block |
||
298 | 298 | return false; |
299 | 299 | } |
300 | 300 | |
301 | - $id = md5('sftp:' . $path); |
|
301 | + $id = md5('sftp:'.$path); |
|
302 | 302 | $dirStream = array(); |
303 | - foreach($list as $file) { |
|
303 | + foreach ($list as $file) { |
|
304 | 304 | if ($file != '.' && $file != '..') { |
305 | 305 | $dirStream[] = $file; |
306 | 306 | } |
307 | 307 | } |
308 | 308 | return IteratorDirectory::wrap($dirStream); |
309 | - } catch(\Exception $e) { |
|
309 | + } catch (\Exception $e) { |
|
310 | 310 | return false; |
311 | 311 | } |
312 | 312 | } |
@@ -358,10 +358,10 @@ discard block |
||
358 | 358 | public function fopen($path, $mode) { |
359 | 359 | try { |
360 | 360 | $absPath = $this->absPath($path); |
361 | - switch($mode) { |
|
361 | + switch ($mode) { |
|
362 | 362 | case 'r': |
363 | 363 | case 'rb': |
364 | - if ( !$this->file_exists($path)) { |
|
364 | + if (!$this->file_exists($path)) { |
|
365 | 365 | return false; |
366 | 366 | } |
367 | 367 | case 'w': |
@@ -388,7 +388,7 @@ discard block |
||
388 | 388 | /** |
389 | 389 | * {@inheritdoc} |
390 | 390 | */ |
391 | - public function touch($path, $mtime=null) { |
|
391 | + public function touch($path, $mtime = null) { |
|
392 | 392 | try { |
393 | 393 | if (!is_null($mtime)) { |
394 | 394 | return false; |
@@ -463,7 +463,7 @@ discard block |
||
463 | 463 | // Do not pass the password here. We want to use the Net_SFTP object |
464 | 464 | // supplied via stream context or fail. We only supply username and |
465 | 465 | // hostname because this might show up in logs (they are not used). |
466 | - $url = 'sftp://' . urlencode($this->user) . '@' . $this->host . ':' . $this->port . $this->root . $path; |
|
466 | + $url = 'sftp://'.urlencode($this->user).'@'.$this->host.':'.$this->port.$this->root.$path; |
|
467 | 467 | return $url; |
468 | 468 | } |
469 | 469 | } |
@@ -36,28 +36,28 @@ discard block |
||
36 | 36 | use Icewind\Streams\CallbackWrapper; |
37 | 37 | use Icewind\Streams\RetryWrapper; |
38 | 38 | |
39 | -class FTP extends StreamWrapper{ |
|
39 | +class FTP extends StreamWrapper { |
|
40 | 40 | private $password; |
41 | 41 | private $user; |
42 | 42 | private $host; |
43 | 43 | private $secure; |
44 | 44 | private $root; |
45 | 45 | |
46 | - private static $tempFiles=array(); |
|
46 | + private static $tempFiles = array(); |
|
47 | 47 | |
48 | 48 | public function __construct($params) { |
49 | 49 | if (isset($params['host']) && isset($params['user']) && isset($params['password'])) { |
50 | - $this->host=$params['host']; |
|
51 | - $this->user=$params['user']; |
|
52 | - $this->password=$params['password']; |
|
50 | + $this->host = $params['host']; |
|
51 | + $this->user = $params['user']; |
|
52 | + $this->password = $params['password']; |
|
53 | 53 | if (isset($params['secure'])) { |
54 | 54 | $this->secure = $params['secure']; |
55 | 55 | } else { |
56 | 56 | $this->secure = false; |
57 | 57 | } |
58 | - $this->root=isset($params['root'])?$params['root']:'/'; |
|
59 | - if ( ! $this->root || $this->root[0]!='/') { |
|
60 | - $this->root='/'.$this->root; |
|
58 | + $this->root = isset($params['root']) ? $params['root'] : '/'; |
|
59 | + if (!$this->root || $this->root[0] != '/') { |
|
60 | + $this->root = '/'.$this->root; |
|
61 | 61 | } |
62 | 62 | if (substr($this->root, -1) !== '/') { |
63 | 63 | $this->root .= '/'; |
@@ -68,8 +68,8 @@ discard block |
||
68 | 68 | |
69 | 69 | } |
70 | 70 | |
71 | - public function getId(){ |
|
72 | - return 'ftp::' . $this->user . '@' . $this->host . '/' . $this->root; |
|
71 | + public function getId() { |
|
72 | + return 'ftp::'.$this->user.'@'.$this->host.'/'.$this->root; |
|
73 | 73 | } |
74 | 74 | |
75 | 75 | /** |
@@ -78,11 +78,11 @@ discard block |
||
78 | 78 | * @return string |
79 | 79 | */ |
80 | 80 | public function constructUrl($path) { |
81 | - $url='ftp'; |
|
81 | + $url = 'ftp'; |
|
82 | 82 | if ($this->secure) { |
83 | - $url.='s'; |
|
83 | + $url .= 's'; |
|
84 | 84 | } |
85 | - $url.='://'.urlencode($this->user).':'.urlencode($this->password).'@'.$this->host.$this->root.$path; |
|
85 | + $url .= '://'.urlencode($this->user).':'.urlencode($this->password).'@'.$this->host.$this->root.$path; |
|
86 | 86 | return $url; |
87 | 87 | } |
88 | 88 | |
@@ -101,8 +101,8 @@ discard block |
||
101 | 101 | return $result; |
102 | 102 | } |
103 | 103 | } |
104 | - public function fopen($path,$mode) { |
|
105 | - switch($mode) { |
|
104 | + public function fopen($path, $mode) { |
|
105 | + switch ($mode) { |
|
106 | 106 | case 'r': |
107 | 107 | case 'rb': |
108 | 108 | case 'w': |
@@ -122,17 +122,17 @@ discard block |
||
122 | 122 | case 'c': |
123 | 123 | case 'c+': |
124 | 124 | //emulate these |
125 | - if (strrpos($path, '.')!==false) { |
|
126 | - $ext=substr($path, strrpos($path, '.')); |
|
125 | + if (strrpos($path, '.') !== false) { |
|
126 | + $ext = substr($path, strrpos($path, '.')); |
|
127 | 127 | } else { |
128 | - $ext=''; |
|
128 | + $ext = ''; |
|
129 | 129 | } |
130 | - $tmpFile=\OCP\Files::tmpFile($ext); |
|
130 | + $tmpFile = \OCP\Files::tmpFile($ext); |
|
131 | 131 | if ($this->file_exists($path)) { |
132 | 132 | $this->getFile($path, $tmpFile); |
133 | 133 | } |
134 | 134 | $handle = fopen($tmpFile, $mode); |
135 | - return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
135 | + return CallbackWrapper::wrap($handle, null, null, function() use ($path, $tmpFile) { |
|
136 | 136 | $this->writeBack($tmpFile, $path); |
137 | 137 | }); |
138 | 138 | } |
@@ -47,10 +47,10 @@ |
||
47 | 47 | return false; |
48 | 48 | } |
49 | 49 | while (($file = readdir($dh)) !== false) { |
50 | - if ($this->is_dir($path . '/' . $file)) { |
|
51 | - $this->rmdir($path . '/' . $file); |
|
50 | + if ($this->is_dir($path.'/'.$file)) { |
|
51 | + $this->rmdir($path.'/'.$file); |
|
52 | 52 | } else { |
53 | - $this->unlink($path . '/' . $file); |
|
53 | + $this->unlink($path.'/'.$file); |
|
54 | 54 | } |
55 | 55 | } |
56 | 56 | $url = $this->constructUrl($path); |
@@ -36,8 +36,8 @@ discard block |
||
36 | 36 | |
37 | 37 | namespace OCA\Files_External\Lib\Storage; |
38 | 38 | |
39 | -set_include_path(get_include_path() . PATH_SEPARATOR . |
|
40 | - \OC_App::getAppPath('files_external') . '/3rdparty/aws-sdk-php'); |
|
39 | +set_include_path(get_include_path().PATH_SEPARATOR. |
|
40 | + \OC_App::getAppPath('files_external').'/3rdparty/aws-sdk-php'); |
|
41 | 41 | require_once 'aws-autoloader.php'; |
42 | 42 | |
43 | 43 | use Aws\S3\S3Client; |
@@ -95,8 +95,8 @@ discard block |
||
95 | 95 | * |
96 | 96 | * @param array $params |
97 | 97 | */ |
98 | - public function updateLegacyId (array $params) { |
|
99 | - $oldId = 'amazon::' . $params['key'] . md5($params['secret']); |
|
98 | + public function updateLegacyId(array $params) { |
|
99 | + $oldId = 'amazon::'.$params['key'].md5($params['secret']); |
|
100 | 100 | |
101 | 101 | // find by old id or bucket |
102 | 102 | $stmt = \OC::$server->getDatabaseConnection()->prepare( |
@@ -148,7 +148,7 @@ discard block |
||
148 | 148 | try { |
149 | 149 | $this->getConnection()->putObject(array( |
150 | 150 | 'Bucket' => $this->bucket, |
151 | - 'Key' => $path . '/', |
|
151 | + 'Key' => $path.'/', |
|
152 | 152 | 'Body' => '', |
153 | 153 | 'ContentType' => 'httpd/unix-directory' |
154 | 154 | )); |
@@ -191,12 +191,12 @@ discard block |
||
191 | 191 | return false; |
192 | 192 | } |
193 | 193 | |
194 | - private function batchDelete ($path = null) { |
|
194 | + private function batchDelete($path = null) { |
|
195 | 195 | $params = array( |
196 | 196 | 'Bucket' => $this->bucket |
197 | 197 | ); |
198 | 198 | if ($path !== null) { |
199 | - $params['Prefix'] = $path . '/'; |
|
199 | + $params['Prefix'] = $path.'/'; |
|
200 | 200 | } |
201 | 201 | try { |
202 | 202 | // Since there are no real directories on S3, we need |
@@ -279,7 +279,7 @@ discard block |
||
279 | 279 | $stat['atime'] = time(); |
280 | 280 | |
281 | 281 | return $stat; |
282 | - } catch(S3Exception $e) { |
|
282 | + } catch (S3Exception $e) { |
|
283 | 283 | \OCP\Util::logException('files_external', $e); |
284 | 284 | return false; |
285 | 285 | } |
@@ -394,14 +394,14 @@ discard block |
||
394 | 394 | $fileType = $this->filetype($path); |
395 | 395 | try { |
396 | 396 | if ($fileType !== false) { |
397 | - if ($fileType === 'dir' && ! $this->isRoot($path)) { |
|
397 | + if ($fileType === 'dir' && !$this->isRoot($path)) { |
|
398 | 398 | $path .= '/'; |
399 | 399 | } |
400 | 400 | $this->getConnection()->copyObject([ |
401 | 401 | 'Bucket' => $this->bucket, |
402 | 402 | 'Key' => $this->cleanKey($path), |
403 | 403 | 'Metadata' => $metadata, |
404 | - 'CopySource' => $this->bucket . '/' . $path, |
|
404 | + 'CopySource' => $this->bucket.'/'.$path, |
|
405 | 405 | 'MetadataDirective' => 'REPLACE', |
406 | 406 | ]); |
407 | 407 | $this->testTimeout(); |
@@ -434,7 +434,7 @@ discard block |
||
434 | 434 | $this->getConnection()->copyObject(array( |
435 | 435 | 'Bucket' => $this->bucket, |
436 | 436 | 'Key' => $this->cleanKey($path2), |
437 | - 'CopySource' => S3Client::encodeKey($this->bucket . '/' . $path1) |
|
437 | + 'CopySource' => S3Client::encodeKey($this->bucket.'/'.$path1) |
|
438 | 438 | )); |
439 | 439 | $this->testTimeout(); |
440 | 440 | } catch (S3Exception $e) { |
@@ -447,8 +447,8 @@ discard block |
||
447 | 447 | try { |
448 | 448 | $this->getConnection()->copyObject(array( |
449 | 449 | 'Bucket' => $this->bucket, |
450 | - 'Key' => $path2 . '/', |
|
451 | - 'CopySource' => S3Client::encodeKey($this->bucket . '/' . $path1 . '/') |
|
450 | + 'Key' => $path2.'/', |
|
451 | + 'CopySource' => S3Client::encodeKey($this->bucket.'/'.$path1.'/') |
|
452 | 452 | )); |
453 | 453 | $this->testTimeout(); |
454 | 454 | } catch (S3Exception $e) { |
@@ -463,8 +463,8 @@ discard block |
||
463 | 463 | continue; |
464 | 464 | } |
465 | 465 | |
466 | - $source = $path1 . '/' . $file; |
|
467 | - $target = $path2 . '/' . $file; |
|
466 | + $source = $path1.'/'.$file; |
|
467 | + $target = $path2.'/'.$file; |
|
468 | 468 | $this->copy($source, $target); |
469 | 469 | } |
470 | 470 | } |
@@ -84,7 +84,7 @@ discard block |
||
84 | 84 | |
85 | 85 | $this->root = isset($params['root']) ? $params['root'] : '/'; |
86 | 86 | if (!$this->root || $this->root[0] != '/') { |
87 | - $this->root = '/' . $this->root; |
|
87 | + $this->root = '/'.$this->root; |
|
88 | 88 | } |
89 | 89 | if (substr($this->root, -1, 1) != '/') { |
90 | 90 | $this->root .= '/'; |
@@ -102,7 +102,7 @@ discard block |
||
102 | 102 | // FIXME: double slash to keep compatible with the old storage ids, |
103 | 103 | // failure to do so will lead to creation of a new storage id and |
104 | 104 | // loss of shares from the storage |
105 | - return 'smb::' . $this->server->getUser() . '@' . $this->server->getHost() . '//' . $this->share->getName() . '/' . $this->root; |
|
105 | + return 'smb::'.$this->server->getUser().'@'.$this->server->getHost().'//'.$this->share->getName().'/'.$this->root; |
|
106 | 106 | } |
107 | 107 | |
108 | 108 | /** |
@@ -110,7 +110,7 @@ discard block |
||
110 | 110 | * @return string |
111 | 111 | */ |
112 | 112 | protected function buildPath($path) { |
113 | - return Filesystem::normalizePath($this->root . '/' . $path, true, false, true); |
|
113 | + return Filesystem::normalizePath($this->root.'/'.$path, true, false, true); |
|
114 | 114 | } |
115 | 115 | |
116 | 116 | protected function relativePath($fullPath) { |
@@ -150,9 +150,9 @@ discard block |
||
150 | 150 | $path = $this->buildPath($path); |
151 | 151 | $files = $this->share->dir($path); |
152 | 152 | foreach ($files as $file) { |
153 | - $this->statCache[$path . '/' . $file->getName()] = $file; |
|
153 | + $this->statCache[$path.'/'.$file->getName()] = $file; |
|
154 | 154 | } |
155 | - return array_filter($files, function (IFileInfo $file) { |
|
155 | + return array_filter($files, function(IFileInfo $file) { |
|
156 | 156 | return !$file->isHidden(); |
157 | 157 | }); |
158 | 158 | } catch (ConnectException $e) { |
@@ -297,7 +297,7 @@ discard block |
||
297 | 297 | case 'w': |
298 | 298 | case 'wb': |
299 | 299 | $source = $this->share->write($fullPath); |
300 | - return CallBackWrapper::wrap($source, null, null, function () use ($fullPath) { |
|
300 | + return CallBackWrapper::wrap($source, null, null, function() use ($fullPath) { |
|
301 | 301 | unset($this->statCache[$fullPath]); |
302 | 302 | }); |
303 | 303 | case 'a': |
@@ -329,7 +329,7 @@ discard block |
||
329 | 329 | } |
330 | 330 | $source = fopen($tmpFile, $mode); |
331 | 331 | $share = $this->share; |
332 | - return CallbackWrapper::wrap($source, null, null, function () use ($tmpFile, $fullPath, $share) { |
|
332 | + return CallbackWrapper::wrap($source, null, null, function() use ($tmpFile, $fullPath, $share) { |
|
333 | 333 | unset($this->statCache[$fullPath]); |
334 | 334 | $share->put($tmpFile, $fullPath); |
335 | 335 | unlink($tmpFile); |
@@ -351,7 +351,7 @@ discard block |
||
351 | 351 | $content = $this->share->dir($this->buildPath($path)); |
352 | 352 | foreach ($content as $file) { |
353 | 353 | if ($file->isDirectory()) { |
354 | - $this->rmdir($path . '/' . $file->getName()); |
|
354 | + $this->rmdir($path.'/'.$file->getName()); |
|
355 | 355 | } else { |
356 | 356 | $this->share->del($file->getPath()); |
357 | 357 | } |
@@ -388,7 +388,7 @@ discard block |
||
388 | 388 | } catch (ForbiddenException $e) { |
389 | 389 | return false; |
390 | 390 | } |
391 | - $names = array_map(function ($info) { |
|
391 | + $names = array_map(function($info) { |
|
392 | 392 | /** @var \Icewind\SMB\IFileInfo $info */ |
393 | 393 | return $info->getName(); |
394 | 394 | }, $files); |
@@ -470,7 +470,7 @@ discard block |
||
470 | 470 | */ |
471 | 471 | public static function checkDependencies() { |
472 | 472 | return ( |
473 | - (bool)\OC_Helper::findBinaryPath('smbclient') |
|
473 | + (bool) \OC_Helper::findBinaryPath('smbclient') |
|
474 | 474 | || Server::NativeAvailable() |
475 | 475 | ) ? true : ['smbclient']; |
476 | 476 | } |
@@ -489,7 +489,7 @@ discard block |
||
489 | 489 | } |
490 | 490 | |
491 | 491 | public function listen($path, callable $callback) { |
492 | - $this->notify($path)->listen(function (IChange $change) use ($callback) { |
|
492 | + $this->notify($path)->listen(function(IChange $change) use ($callback) { |
|
493 | 493 | if ($change instanceof IRenameChange) { |
494 | 494 | return $callback($change->getType(), $change->getPath(), $change->getTargetPath()); |
495 | 495 | } else { |
@@ -499,7 +499,7 @@ discard block |
||
499 | 499 | } |
500 | 500 | |
501 | 501 | public function notify($path) { |
502 | - $path = '/' . ltrim($path, '/'); |
|
502 | + $path = '/'.ltrim($path, '/'); |
|
503 | 503 | $shareNotifyHandler = $this->share->notify($this->buildPath($path)); |
504 | 504 | return new SMBNotifyHandler($shareNotifyHandler, $this->root); |
505 | 505 | } |