@@ -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 | } |