@@ -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); |
@@ -163,7 +163,7 @@ discard block |
||
163 | 163 | throw new \Exception("API Key or password, Username, Bucket and Region have to be configured."); |
164 | 164 | } |
165 | 165 | |
166 | - $this->id = 'swift::' . $params['user'] . md5($params['bucket']); |
|
166 | + $this->id = 'swift::'.$params['user'].md5($params['bucket']); |
|
167 | 167 | |
168 | 168 | $bucketUrl = Url::factory($params['bucket']); |
169 | 169 | if ($bucketUrl->isAbsolute()) { |
@@ -236,16 +236,16 @@ discard block |
||
236 | 236 | continue; |
237 | 237 | } |
238 | 238 | |
239 | - if ($this->is_dir($path . '/' . $file)) { |
|
240 | - $this->rmdir($path . '/' . $file); |
|
239 | + if ($this->is_dir($path.'/'.$file)) { |
|
240 | + $this->rmdir($path.'/'.$file); |
|
241 | 241 | } else { |
242 | - $this->unlink($path . '/' . $file); |
|
242 | + $this->unlink($path.'/'.$file); |
|
243 | 243 | } |
244 | 244 | } |
245 | 245 | |
246 | 246 | try { |
247 | - $this->getContainer()->dataObject()->setName($path . '/')->delete(); |
|
248 | - $this->objectCache->remove($path . '/'); |
|
247 | + $this->getContainer()->dataObject()->setName($path.'/')->delete(); |
|
248 | + $this->objectCache->remove($path.'/'); |
|
249 | 249 | } catch (Exceptions\DeleteError $e) { |
250 | 250 | \OCP\Util::writeLog('files_external', $e->getMessage(), \OCP\Util::ERROR); |
251 | 251 | return false; |
@@ -326,7 +326,7 @@ discard block |
||
326 | 326 | } |
327 | 327 | |
328 | 328 | $stat = array(); |
329 | - $stat['size'] = (int)$object->getContentLength(); |
|
329 | + $stat['size'] = (int) $object->getContentLength(); |
|
330 | 330 | $stat['mtime'] = $mtime; |
331 | 331 | $stat['atime'] = time(); |
332 | 332 | return $stat; |
@@ -358,7 +358,7 @@ discard block |
||
358 | 358 | try { |
359 | 359 | $this->getContainer()->dataObject()->setName($path)->delete(); |
360 | 360 | $this->objectCache->remove($path); |
361 | - $this->objectCache->remove($path . '/'); |
|
361 | + $this->objectCache->remove($path.'/'); |
|
362 | 362 | } catch (ClientErrorResponseException $e) { |
363 | 363 | if ($e->getResponse()->getStatusCode() !== 404) { |
364 | 364 | \OCP\Util::writeLog('files_external', $e->getMessage(), \OCP\Util::ERROR); |
@@ -383,8 +383,8 @@ discard block |
||
383 | 383 | ->get($c->getUrl($path))); |
384 | 384 | $streamInterface->rewind(); |
385 | 385 | $stream = $streamInterface->getStream(); |
386 | - stream_context_set_option($stream, 'swift','content', $streamInterface); |
|
387 | - if(!strrpos($streamInterface |
|
386 | + stream_context_set_option($stream, 'swift', 'content', $streamInterface); |
|
387 | + if (!strrpos($streamInterface |
|
388 | 388 | ->getMetaData('wrapper_data')[0], '404 Not Found')) { |
389 | 389 | return $stream; |
390 | 390 | } |
@@ -425,7 +425,7 @@ discard block |
||
425 | 425 | } |
426 | 426 | } |
427 | 427 | $handle = fopen($tmpFile, $mode); |
428 | - return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) { |
|
428 | + return CallbackWrapper::wrap($handle, null, null, function() use ($path, $tmpFile) { |
|
429 | 429 | $this->writeBack($tmpFile, $path); |
430 | 430 | }); |
431 | 431 | } |
@@ -472,10 +472,10 @@ discard block |
||
472 | 472 | |
473 | 473 | try { |
474 | 474 | $source = $this->fetchObject($path1); |
475 | - $source->copy($this->bucket . '/' . $path2); |
|
475 | + $source->copy($this->bucket.'/'.$path2); |
|
476 | 476 | // invalidate target object to force repopulation on fetch |
477 | 477 | $this->objectCache->remove($path2); |
478 | - $this->objectCache->remove($path2 . '/'); |
|
478 | + $this->objectCache->remove($path2.'/'); |
|
479 | 479 | } catch (ClientErrorResponseException $e) { |
480 | 480 | \OCP\Util::writeLog('files_external', $e->getMessage(), \OCP\Util::ERROR); |
481 | 481 | return false; |
@@ -487,11 +487,11 @@ discard block |
||
487 | 487 | $this->unlink($path2); |
488 | 488 | |
489 | 489 | try { |
490 | - $source = $this->fetchObject($path1 . '/'); |
|
491 | - $source->copy($this->bucket . '/' . $path2 . '/'); |
|
490 | + $source = $this->fetchObject($path1.'/'); |
|
491 | + $source->copy($this->bucket.'/'.$path2.'/'); |
|
492 | 492 | // invalidate target object to force repopulation on fetch |
493 | 493 | $this->objectCache->remove($path2); |
494 | - $this->objectCache->remove($path2 . '/'); |
|
494 | + $this->objectCache->remove($path2.'/'); |
|
495 | 495 | } catch (ClientErrorResponseException $e) { |
496 | 496 | \OCP\Util::writeLog('files_external', $e->getMessage(), \OCP\Util::ERROR); |
497 | 497 | return false; |
@@ -503,8 +503,8 @@ discard block |
||
503 | 503 | continue; |
504 | 504 | } |
505 | 505 | |
506 | - $source = $path1 . '/' . $file; |
|
507 | - $target = $path2 . '/' . $file; |
|
506 | + $source = $path1.'/'.$file; |
|
507 | + $target = $path2.'/'.$file; |
|
508 | 508 | $this->copy($source, $target); |
509 | 509 | } |
510 | 510 | |
@@ -638,7 +638,7 @@ discard block |
||
638 | 638 | $path = ''; |
639 | 639 | } |
640 | 640 | $cachedContent = $this->getCache()->getFolderContents($path); |
641 | - $cachedNames = array_map(function ($content) { |
|
641 | + $cachedNames = array_map(function($content) { |
|
642 | 642 | return $content['name']; |
643 | 643 | }, $cachedContent); |
644 | 644 | sort($cachedNames); |
@@ -31,7 +31,7 @@ discard block |
||
31 | 31 | * http://%host/%context/remote.php/webdav/%root |
32 | 32 | * |
33 | 33 | */ |
34 | -class OwnCloud extends \OC\Files\Storage\DAV{ |
|
34 | +class OwnCloud extends \OC\Files\Storage\DAV { |
|
35 | 35 | const OC_URL_SUFFIX = 'remote.php/webdav'; |
36 | 36 | |
37 | 37 | public function __construct($params) { |
@@ -48,27 +48,27 @@ discard block |
||
48 | 48 | } |
49 | 49 | $contextPath = ''; |
50 | 50 | $hostSlashPos = strpos($host, '/'); |
51 | - if ($hostSlashPos !== false){ |
|
51 | + if ($hostSlashPos !== false) { |
|
52 | 52 | $contextPath = substr($host, $hostSlashPos); |
53 | 53 | $host = substr($host, 0, $hostSlashPos); |
54 | 54 | } |
55 | 55 | |
56 | - if (substr($contextPath, -1) !== '/'){ |
|
56 | + if (substr($contextPath, -1) !== '/') { |
|
57 | 57 | $contextPath .= '/'; |
58 | 58 | } |
59 | 59 | |
60 | - if (isset($params['root'])){ |
|
60 | + if (isset($params['root'])) { |
|
61 | 61 | $root = $params['root']; |
62 | - if (substr($root, 0, 1) !== '/'){ |
|
63 | - $root = '/' . $root; |
|
62 | + if (substr($root, 0, 1) !== '/') { |
|
63 | + $root = '/'.$root; |
|
64 | 64 | } |
65 | 65 | } |
66 | - else{ |
|
66 | + else { |
|
67 | 67 | $root = '/'; |
68 | 68 | } |
69 | 69 | |
70 | 70 | $params['host'] = $host; |
71 | - $params['root'] = $contextPath . self::OC_URL_SUFFIX . $root; |
|
71 | + $params['root'] = $contextPath.self::OC_URL_SUFFIX.$root; |
|
72 | 72 | |
73 | 73 | parent::__construct($params); |
74 | 74 | } |
@@ -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 | } |