summergeorge / Aliyun-oss-storage

src/AliOssAdapter.php

Spacing +33 added lines, -33 removed lines

@@ -148,10 +148,10 @@ 
         $object = $this->applyPathPrefix($path);
         $options = $this->getOptions($this->options, $config);
 
-        if (! isset($options[OssClient::OSS_LENGTH])) {
+        if (!isset($options[OssClient::OSS_LENGTH])) {
             $options[OssClient::OSS_LENGTH] = Util::contentSize($contents);
         }
-        if (! isset($options[OssClient::OSS_CONTENT_TYPE])) {
+        if (!isset($options[OssClient::OSS_CONTENT_TYPE])) {
             $options[OssClient::OSS_CONTENT_TYPE] = Util::guessMimeType($path, $contents);
         }
         try {
@@ -180,13 +180,13 @@ 
         return $this->write($path, $contents, $config);
     }
 
-    public function writeFile($path, $filePath, Config $config){
+    public function writeFile($path, $filePath, Config $config) {
         $object = $this->applyPathPrefix($path);
         $options = $this->getOptions($this->options, $config);
 
         $options[OssClient::OSS_CHECK_MD5] = true;
 
-        if (! isset($options[OssClient::OSS_CONTENT_TYPE])) {
+        if (!isset($options[OssClient::OSS_CONTENT_TYPE])) {
             $options[OssClient::OSS_CONTENT_TYPE] = Util::guessMimeType($path, '');
         }
         try {
@@ -209,7 +209,7 @@ 
      */
     public function update($path, $contents, Config $config)
     {
-        if (! $config->has('visibility') && ! $config->has('ACL')) {
+        if (!$config->has('visibility') && !$config->has('ACL')) {
             $config->set(static::$metaMap['ACL'], $this->getObjectACL($path));
         }
         // $this->delete($path);
@@ -236,7 +236,7 @@ 
      */
     public function rename($path, $newpath)
     {
-        if (! $this->copy($path, $newpath)){
+        if (!$this->copy($path, $newpath)) {
             return false;
         }
 
@@ -250,7 +250,7 @@ 
     {
         $object = $this->applyPathPrefix($path);
         $newObject = $this->applyPathPrefix($newpath);
-        try{
+        try {
             $this->client->copyObject($this->bucket, $object, $this->bucket, $newObject);
         } catch (OssException $e) {
             $this->logErr(__FUNCTION__, $e);
@@ -268,14 +268,14 @@ 
         $bucket = $this->bucket;
         $object = $this->applyPathPrefix($path);
 
-        try{
+        try {
             $this->client->deleteObject($bucket, $object);
-        }catch (OssException $e) {
+        } catch (OssException $e) {
             $this->logErr(__FUNCTION__, $e);
             return false;
         }
 
-        return ! $this->has($path);
+        return !$this->has($path);
     }
 
     /**
@@ -286,9 +286,9 @@ 
         $dirname = rtrim($this->applyPathPrefix($dirname), '/').'/';
         $dirObjects = $this->listDirObjects($dirname, true);
 
-        if(count($dirObjects['objects']) > 0 ){
+        if (count($dirObjects['objects']) > 0) {
 
-            foreach($dirObjects['objects'] as $object)
+            foreach ($dirObjects['objects'] as $object)
             {
                 $objects[] = $object['Key'];
             }
@@ -319,7 +319,7 @@ 
      * @return mixed
      * @throws OssException
      */
-    public function listDirObjects($dirname = '', $recursive =  false)
+    public function listDirObjects($dirname = '', $recursive = false)
     {
         $delimiter = '/';
         $nextMarker = '';
@@ -328,7 +328,7 @@ 
         //存储结果
         $result = [];
 
-        while(true){
+        while (true) {
             $options = [
                 'delimiter' => $delimiter,
                 'prefix'    => $dirname,
@@ -361,7 +361,7 @@ 
 
                     $result['objects'][] = $object;
                 }
-            }else{
+            } else {
                 $result["objects"] = [];
             }
 
@@ -369,14 +369,14 @@ 
                 foreach ($prefixList as $prefixInfo) {
                     $result['prefix'][] = $prefixInfo->getPrefix();
                 }
-            }else{
+            } else {
                 $result['prefix'] = [];
             }
 
             //递归查询子目录所有文件
-            if($recursive){
-                foreach( $result['prefix'] as $pfix){
-                    $next  =  $this->listDirObjects($pfix , $recursive);
+            if ($recursive) {
+                foreach ($result['prefix'] as $pfix) {
+                    $next = $this->listDirObjects($pfix, $recursive);
                     $result["objects"] = array_merge($result['objects'], $next["objects"]);
                 }
             }
@@ -414,7 +414,7 @@ 
     public function setVisibility($path, $visibility)
     {
         $object = $this->applyPathPrefix($path);
-        $acl = ( $visibility === AdapterInterface::VISIBILITY_PUBLIC ) ? OssClient::OSS_ACL_TYPE_PUBLIC_READ : OssClient::OSS_ACL_TYPE_PRIVATE;
+        $acl = ($visibility === AdapterInterface::VISIBILITY_PUBLIC) ? OssClient::OSS_ACL_TYPE_PUBLIC_READ : OssClient::OSS_ACL_TYPE_PRIVATE;
 
         $this->client->putObjectAcl($this->bucket, $object, $acl);
 
@@ -437,7 +437,7 @@ 
     public function read($path)
     {
         $result = $this->readObject($path);
-        $result['contents'] = (string) $result['raw_contents'];
+        $result['contents'] = (string)$result['raw_contents'];
         unset($result['raw_contents']);
         return $result;
     }
@@ -482,7 +482,7 @@ 
         $contents = $dirObjects["objects"];
 
         $result = array_map([$this, 'normalizeResponse'], $contents);
-        $result = array_filter($result, function ($value) {
+        $result = array_filter($result, function($value) {
             return $value['path'] !== false;
         });
 
@@ -521,7 +521,7 @@ 
      */
     public function getMimetype($path)
     {
-        if( $object = $this->getMetadata($path))
+        if ($object = $this->getMetadata($path))
             $object['mimetype'] = $object['content-type'];
         return $object;
     }
@@ -531,8 +531,8 @@ 
      */
     public function getTimestamp($path)
     {
-        if( $object = $this->getMetadata($path))
-            $object['timestamp'] = strtotime( $object['last-modified'] );
+        if ($object = $this->getMetadata($path))
+            $object['timestamp'] = strtotime($object['last-modified']);
         return $object;
     }
 
@@ -549,9 +549,9 @@ 
             return false;
         }
 
-        if ($acl == OssClient::OSS_ACL_TYPE_PUBLIC_READ ){
+        if ($acl == OssClient::OSS_ACL_TYPE_PUBLIC_READ) {
             $res['visibility'] = AdapterInterface::VISIBILITY_PUBLIC;
-        }else{
+        } else {
             $res['visibility'] = AdapterInterface::VISIBILITY_PRIVATE;
         }
 
@@ -564,10 +564,10 @@ 
      *
      * @return string
      */
-    public function getUrl( $path )
+    public function getUrl($path)
     {
         if (!$this->has($path)) throw new FileNotFoundException($path.' not found');
-        return ( $this->ssl ? 'https://' : 'http://' ) . ( $this->isCname ? ( $this->cdnDomain == '' ? $this->endPoint : $this->cdnDomain ) : $this->bucket . '.' . $this->endPoint ) . '/' . ltrim($path, '/');
+        return ($this->ssl ? 'https://' : 'http://').($this->isCname ? ($this->cdnDomain == '' ? $this->endPoint : $this->cdnDomain) : $this->bucket.'.'.$this->endPoint).'/'.ltrim($path, '/');
     }
 
     /**
@@ -643,7 +643,7 @@ 
         $options = [];
 
         foreach (static::$metaOptions as $option) {
-            if (! $config->has($option)) {
+            if (!$config->has($option)) {
                 continue;
             }
             $options[static::$metaMap[$option]] = $config->get($option);
@@ -670,9 +670,9 @@ 
      * @param $fun string function name : __FUNCTION__
      * @param $e
      */
-    protected function logErr($fun, $e){
-        if( $this->debug ){
-            Log::error($fun . ": FAILED");
+    protected function logErr($fun, $e) {
+        if ($this->debug) {
+            Log::error($fun.": FAILED");
             Log::error($e->getMessage());
         }
     }

Braces +13 added lines, -9 removed lines

@@ -270,7 +270,7 @@ 
 
         try{
             $this->client->deleteObject($bucket, $object);
-        }catch (OssException $e) {
+        } catch (OssException $e) {
             $this->logErr(__FUNCTION__, $e);
             return false;
         }
@@ -361,7 +361,7 @@ 
 
                     $result['objects'][] = $object;
                 }
-            }else{
+            } else{
                 $result["objects"] = [];
             }
 
@@ -369,7 +369,7 @@ 
                 foreach ($prefixList as $prefixInfo) {
                     $result['prefix'][] = $prefixInfo->getPrefix();
                 }
-            }else{
+            } else{
                 $result['prefix'] = [];
             }
 
@@ -521,8 +521,9 @@ 
      */
     public function getMimetype($path)
     {
-        if( $object = $this->getMetadata($path))
-            $object['mimetype'] = $object['content-type'];
+        if( $object = $this->getMetadata($path)) {
+                    $object['mimetype'] = $object['content-type'];
+        }
         return $object;
     }
 
@@ -531,8 +532,9 @@ 
      */
     public function getTimestamp($path)
     {
-        if( $object = $this->getMetadata($path))
-            $object['timestamp'] = strtotime( $object['last-modified'] );
+        if( $object = $this->getMetadata($path)) {
+                    $object['timestamp'] = strtotime( $object['last-modified'] );
+        }
         return $object;
     }
 
@@ -551,7 +553,7 @@ 
 
         if ($acl == OssClient::OSS_ACL_TYPE_PUBLIC_READ ){
             $res['visibility'] = AdapterInterface::VISIBILITY_PUBLIC;
-        }else{
+        } else{
             $res['visibility'] = AdapterInterface::VISIBILITY_PRIVATE;
         }
 
@@ -566,7 +568,9 @@ 
      */
     public function getUrl( $path )
     {
-        if (!$this->has($path)) throw new FileNotFoundException($path.' not found');
+        if (!$this->has($path)) {
+            throw new FileNotFoundException($path.' not found');
+        }
         return ( $this->ssl ? 'https://' : 'http://' ) . ( $this->isCname ? ( $this->cdnDomain == '' ? $this->endPoint : $this->cdnDomain ) : $this->bucket . '.' . $this->endPoint ) . '/' . ltrim($path, '/');
     }
 

src/Plugins/GetProcessUrl.php

Spacing +3 added lines, -3 removed lines

@@ -33,15 +33,15 @@
      * @return string 返回 url 链接地址
      * @throws \Exception
      */
-    public function handle($path, $action = 'resize', $option = ['m' => 'fixed','h' => '100','w' => '100']){
-        if(empty($action) || empty($option)){
+    public function handle($path, $action = 'resize', $option = ['m' => 'fixed', 'h' => '100', 'w' => '100']) {
+        if (empty($action) || empty($option)) {
             throw new \Exception('操作名称和操作参数不能为空！');
         }
 
         $url = $this->filesystem->getAdapter()->getUrl($path);
 
         $param = '';
-        foreach ($option as $key => $value){
+        foreach ($option as $key => $value) {
             $param .= ','.$key.'_'.$value;
         }
 

src/Plugins/PutRemoteFile.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
         return 'putRemoteFile';
     }
 
-    public function handle($path, $remoteUrl, array $options = []){
+    public function handle($path, $remoteUrl, array $options = []) {
         $config = new Config($options);
         if (method_exists($this->filesystem, 'getConfig')) {
             $config->setFallback($this->filesystem->getConfig());

src/Plugins/PutFile.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
         return 'putFile';
     }
 
-    public function handle($path, $filePath, array $options = []){
+    public function handle($path, $filePath, array $options = []) {
         $config = new Config($options);
         if (method_exists($this->filesystem, 'getConfig')) {
             $config->setFallback($this->filesystem->getConfig());

src/Plugins/SignUrl.php

Spacing +2 added lines, -2 removed lines

@@ -24,8 +24,8 @@
         return 'signUrl';
     }
 
-    public function handle($path, $timeout = 600){
+    public function handle($path, $timeout = 600) {
         if (!$this->filesystem->getAdapter()->has($path)) throw new FileNotFoundException($path.' not found');
-        return $this->filesystem->getAdapter()->getClient()->signUrl($this->filesystem->getAdapter()->getBucket(),$path,$timeout);
+        return $this->filesystem->getAdapter()->getClient()->signUrl($this->filesystem->getAdapter()->getBucket(), $path, $timeout);
     }
 }

Braces +3 added lines, -1 removed lines

@@ -25,7 +25,9 @@
     }
 
     public function handle($path, $timeout = 600){
-        if (!$this->filesystem->getAdapter()->has($path)) throw new FileNotFoundException($path.' not found');
+        if (!$this->filesystem->getAdapter()->has($path)) {
+            throw new FileNotFoundException($path.' not found');
+        }
         return $this->filesystem->getAdapter()->getClient()->signUrl($this->filesystem->getAdapter()->getBucket(),$path,$timeout);
     }
 }

src/AliOssServiceProvider.php

Spacing +3 added lines, -3 removed lines

@@ -43,15 +43,15 @@
             $debug     = empty($config['debug']) ? false : $config['debug'];
 
             $endPoint  = $config['endpoint']; // 默认作为外部节点
-            $epInternal= $isCname?$cdnDomain:(empty($config['endpoint_internal']) ? $endPoint : $config['endpoint_internal']); // 内部节点
+            $epInternal = $isCname ? $cdnDomain : (empty($config['endpoint_internal']) ? $endPoint : $config['endpoint_internal']); // 内部节点
 
-            if($debug) Log::debug('OSS config:', $config);
+            if ($debug) Log::debug('OSS config:', $config);
 
             $client  = new OssClient($accessId, $accessKey, $epInternal, $isCname);
             $adapter = new AliOssAdapter($client, $bucket, $endPoint, $ssl, $isCname, $debug, $cdnDomain);
 
             //Log::debug($client);
-            $filesystem =  new Filesystem($adapter);
+            $filesystem = new Filesystem($adapter);
 
             $filesystem->addPlugin(new PutFile());
             $filesystem->addPlugin(new PutRemoteFile());

Braces +3 added lines, -1 removed lines

@@ -45,7 +45,9 @@
             $endPoint  = $config['endpoint']; // 默认作为外部节点
             $epInternal= $isCname?$cdnDomain:(empty($config['endpoint_internal']) ? $endPoint : $config['endpoint_internal']); // 内部节点
 
-            if($debug) Log::debug('OSS config:', $config);
+            if($debug) {
+                Log::debug('OSS config:', $config);
+            }
 
             $client  = new OssClient($accessId, $accessKey, $epInternal, $isCname);
             $adapter = new AliOssAdapter($client, $bucket, $endPoint, $ssl, $isCname, $debug, $cdnDomain);