GC0202 / ThinkLibrary

src/service/ksyun/bin/Ks3Client.class.php

Spacing +44 added lines, -44 removed lines

@@ -34,16 +34,16 @@ 
 define("KS3_API_Author", "lijunwei@kingsoft.com");
 define("KS3_API_Version", "1.2");
 
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "config" . DIRECTORY_SEPARATOR . "Consts.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "core" . DIRECTORY_SEPARATOR . "API.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "core" . DIRECTORY_SEPARATOR . "Signers.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "core" . DIRECTORY_SEPARATOR . "Ks3Request.class.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "core" . DIRECTORY_SEPARATOR . "Handlers.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "core" . DIRECTORY_SEPARATOR . "Builders.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "core" . DIRECTORY_SEPARATOR . "Logger.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "core" . DIRECTORY_SEPARATOR . "MessageHolder.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "lib" . DIRECTORY_SEPARATOR . "RequestCore.class.php";
-require_once KS3_API_PATH . DIRECTORY_SEPARATOR . "exceptions" . DIRECTORY_SEPARATOR . "Exceptions.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."config".DIRECTORY_SEPARATOR."Consts.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."core".DIRECTORY_SEPARATOR."API.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."core".DIRECTORY_SEPARATOR."Signers.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."core".DIRECTORY_SEPARATOR."Ks3Request.class.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."core".DIRECTORY_SEPARATOR."Handlers.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."core".DIRECTORY_SEPARATOR."Builders.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."core".DIRECTORY_SEPARATOR."Logger.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."core".DIRECTORY_SEPARATOR."MessageHolder.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."lib".DIRECTORY_SEPARATOR."RequestCore.class.php";
+require_once KS3_API_PATH.DIRECTORY_SEPARATOR."exceptions".DIRECTORY_SEPARATOR."Exceptions.php";
 
 if (function_exists('get_loaded_extensions')) {
     //检测curl扩展
@@ -56,10 +56,10 @@ 
             throw new Ks3ClientException("please install mbstring extension");
 
         }
-    } else {
+    }else {
         throw new Ks3ClientException("please install extensions");
     }
-} else {
+}else {
     throw new Ks3ClientException();
 }
 
@@ -126,12 +126,12 @@ 
         $holder = new MessageHolder();
 
         $holder->msg = "------------------Logging Start-------------------------\r\n";
-        $holder->msg .= "method->" . $method . " args->" . serialize($args) . "\r\n";
+        $holder->msg .= "method->".$method." args->".serialize($args)."\r\n";
         $ex = NULL;
         try {
             $result = $this->invoke($method, $args, $holder);
         } catch (Exception $e) {
-            $holder->msg .= $e . "\r\n";
+            $holder->msg .= $e."\r\n";
             $ex = $e;
         }
         $holder->msg .= "------------------Logging End-------------------------\r\n";
@@ -145,7 +145,7 @@ 
     {
         $api = API::$API[$method];
         if (!$api) {
-            throw new Ks3ClientException($method . " Not Found API");
+            throw new Ks3ClientException($method." Not Found API");
         }
         if (count($args) !== 0) {
             if (count($args) > 1 || !is_array($args[0])) {
@@ -159,20 +159,20 @@ 
         $request = new Ks3Request();
         if (empty($args["Bucket"])) {
             if ($api["needBucket"]) {
-                throw new Ks3ClientException($method . " this api need bucket");
+                throw new Ks3ClientException($method." this api need bucket");
             }
-        } else {
+        }else {
             $request->bucket = $args["Bucket"];
         }
         $position = $api["objectPostion"] ?? "Key";
         if (empty($args[$position])) {
             if ($api["needObject"]) {
-                throw new Ks3ClientException($method . " this api need " . $position);
+                throw new Ks3ClientException($method." this api need ".$position);
             }
-        } else {
+        }else {
             $key = $args[$position];
             $preEncoding = mb_detect_encoding($key, array("ASCII", "UTF-8", "GB2312", "GBK", "BIG5"));
-            $holder->msg .= "key encoding " . $preEncoding . "\r\n";
+            $holder->msg .= "key encoding ".$preEncoding."\r\n";
             if (strtolower($preEncoding) !== "utf-8") {
                 $key = iconv($preEncoding, "UTF-8", $key);
             }
@@ -182,15 +182,15 @@ 
         if ($method === "Method") {
             if (empty($args["Method"])) {
                 $request->method = "GET";
-            } else {
+            }else {
                 $request->method = $args["Method"];
             }
-        } else {
+        }else {
             $request->method = $api["method"];
         }
         if (KS3_API_USE_HTTPS) {
             $request->scheme = "https://";
-        } else {
+        }else {
             $request->scheme = "http://";
         }
         $request->endpoint = $this->endpoint;
@@ -213,7 +213,7 @@ 
                 foreach ($index as $key1 => $value1) {
                     if (!isset($curIndexArg[$value1]) && $value1 !== "*") {
                         $add = FALSE;
-                    } else {
+                    }else {
                         $curkey = $value1;
                         //星号表示所有,按照暂时的业务，默认星号后面就没了
                         if ($curkey === "*") {
@@ -235,7 +235,7 @@ 
                     continue;
                 }
                 if ($required) {
-                    throw new Ks3ClientException($method . " param " . $value . " is required");
+                    throw new Ks3ClientException($method." param ".$value." is required");
                 }
             }
         }
@@ -244,7 +244,7 @@ 
                 $builderName = $api["body"]["builder"];
                 $builder = new $builderName();
                 $request->body = $builder->build($args);
-            } else if (isset($api["body"]["position"])) {
+            }else if (isset($api["body"]["position"])) {
                 $position = $api["body"]["position"];
                 $index = explode("->", $position);
                 $curIndexArg = $args;
@@ -253,7 +253,7 @@ 
                 foreach ($index as $key1 => $value1) {
                     if (!isset($curIndexArg[$value1])) {
                         $add = FALSE;
-                    } else {
+                    }else {
                         $curIndexArg = $curIndexArg[$value1];
                         $curkey = $value1;
                     }
@@ -274,7 +274,7 @@ 
                 $signer = new $value();
                 $log = $signer->sign($request, array("accessKey" => $this->accessKey, "secretKey" => $this->secretKey, "args" => $args));
                 if (!empty($log)) {
-                    $holder->msg .= $log . "\r\n";
+                    $holder->msg .= $log."\r\n";
                 }
             }
         }
@@ -314,31 +314,31 @@ 
                 $httpRequest->set_write_stream($write_stream);
             }
 
-            $holder->msg .= "request url->" . serialize($httpRequest->request_url) . "\r\n";
-            $holder->msg .= "request headers->" . serialize($httpRequest->request_headers) . "\r\n";
-            $holder->msg .= "request body->" . $httpRequest->request_body . "\r\n";
-            $holder->msg .= "request read stream length->" . $read_length . "\r\n";
-            $holder->msg .= "request read stream seek position->" . $seek_position . "\r\n";
+            $holder->msg .= "request url->".serialize($httpRequest->request_url)."\r\n";
+            $holder->msg .= "request headers->".serialize($httpRequest->request_headers)."\r\n";
+            $holder->msg .= "request body->".$httpRequest->request_body."\r\n";
+            $holder->msg .= "request read stream length->".$read_length."\r\n";
+            $holder->msg .= "request read stream seek position->".$seek_position."\r\n";
             $httpRequest->send_request();
             //print_r($httpRequest);
             $body = $httpRequest->get_response_body();
-            $data = new ResponseCore ($httpRequest->get_response_header(), Utils::replaceNS2($body), $httpRequest->get_response_code());
+            $data = new ResponseCore($httpRequest->get_response_header(), Utils::replaceNS2($body), $httpRequest->get_response_code());
 
             if ($data->status == 307) {
                 $respHeaders = $httpRequest->get_response_header();
                 $location = $respHeaders["location"];
                 if (strpos($location, "http") === 0) {
-                    $holder->msg .= "response code->" . $httpRequest->get_response_code() . "\r\n";
-                    $holder->msg .= "response headers->" . serialize($httpRequest->get_response_header()) . "\r\n";
-                    $holder->msg .= "response body->" . $body . "\r\n";
-                    $holder->msg .= "retry request to " . $location . "\r\n";
+                    $holder->msg .= "response code->".$httpRequest->get_response_code()."\r\n";
+                    $holder->msg .= "response headers->".serialize($httpRequest->get_response_header())."\r\n";
+                    $holder->msg .= "response body->".$body."\r\n";
+                    $holder->msg .= "retry request to ".$location."\r\n";
                     //array($args)详见invoke开头
                     return $this->invoke($method, array($args), $holder, $location);
                 }
             }
-            $holder->msg .= "response code->" . $httpRequest->get_response_code() . "\r\n";
-            $holder->msg .= "response headers->" . serialize($httpRequest->get_response_header()) . "\r\n";
-            $holder->msg .= "response body->" . $body . "\r\n";
+            $holder->msg .= "response code->".$httpRequest->get_response_code()."\r\n";
+            $holder->msg .= "response headers->".serialize($httpRequest->get_response_header())."\r\n";
+            $holder->msg .= "response body->".$body."\r\n";
             $handlers = explode("->", $api["handler"]);
             foreach ($handlers as $key => $value) {
                 $handler = new $value();
@@ -348,7 +348,7 @@ 
         }
 
         $url = $request->toUrl($this->endpoint);
-        $holder->msg .= $url . "\r\n";
+        $holder->msg .= $url."\r\n";
         return $url;
     }
 
@@ -357,7 +357,7 @@ 
     {
         $policy = array();
 
-        $expireTime = Utils::iso8601(time() + $expire);
+        $expireTime = Utils::iso8601(time()+$expire);
         $policy["expiration"] = $expireTime;
         $postFormData["bucket"] = $bucket;
         $conditions = array();
@@ -369,7 +369,7 @@ 
         foreach ($unknowValueFormFiled as $key => $value) {
             $condition = array();
             $condition[] = "starts-with";
-            $condition[] = "\$" . $value;
+            $condition[] = "\$".$value;
             $condition[] = "";
             $conditions[] = $condition;
         }