GC0202 / ThinkLibrary

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

Indentation +100 added lines, -100 removed lines

@@ -19,111 +19,111 @@
 
 
 if(function_exists('get_loaded_extensions')){
-	//检测mcrypt,openssl扩展
-	$extensions = get_loaded_extensions();
-	if($extensions){
-		if(!in_array('mcrypt', $extensions)){
-			throw new Ks3ClientException("please install mcrypt extension");
-		}
-		if(!in_array('openssl', $extensions)){
-			throw new Ks3ClientException("please install openssl extension");
-		}
-	}else{
-		throw new Ks3ClientException("please install extensions");
-	}
+    //检测mcrypt,openssl扩展
+    $extensions = get_loaded_extensions();
+    if($extensions){
+        if(!in_array('mcrypt', $extensions)){
+            throw new Ks3ClientException("please install mcrypt extension");
+        }
+        if(!in_array('openssl', $extensions)){
+            throw new Ks3ClientException("please install openssl extension");
+        }
+    }else{
+        throw new Ks3ClientException("please install extensions");
+    }
 }else{
-	throw new Ks3ClientException();
+    throw new Ks3ClientException();
 } 
 class Ks3EncryptionClient extends Ks3Client{
-	private $encryptionHandler = NULL;
-	//用户提供的主密钥,可以是对称秘钥或非对称秘钥(array,分别是公钥和私钥)
-	private $encryptionMaterials = NULL;
+    private $encryptionHandler = NULL;
+    //用户提供的主密钥,可以是对称秘钥或非对称秘钥(array,分别是公钥和私钥)
+    private $encryptionMaterials = NULL;
 
-	public function __construct($accessKey, $secretKey,$encryptionMaterials, $endpoint = NULL ){
-		parent::__construct($accessKey,$secretKey,$endpoint);
-		if(is_array($encryptionMaterials)){
-			if(count($encryptionMaterials)==2){
-				$pk = openssl_pkey_get_public($encryptionMaterials[0]);
-				$sk = openssl_pkey_get_private($encryptionMaterials[1]);
-				if(!$pk)
-					throw new Ks3ClientException("invalid RSA public key,you can generate key use openssl");
-				if(!$sk)
-					throw new Ks3ClientException("invalid RSA private key,you can generate key use openssl");
-				$encryptionMaterials = array($pk,$sk);
-			}else{
-				throw new Ks3ClientException("encryptionMaterials should be string or an array of size 2");
-			}
-		}
-		$ks3client = new Ks3Client($accessKey,$secretKey,$endpoint);
-		$this->encryptionMaterials = $encryptionMaterials;
-		if(ENCRYPTPTION_MODE == "EO"){
-			$this->encryptionHandler = new EncryptionEO($ks3client,$encryptionMaterials);
-		}elseif (ENCRYPTPTION_MODE == "AE") {
-			throw new Ks3ClientException("Authenticated encryption will be supported in the futher");
-		}
-		else{
-			throw new Ks3ClientException("unsupported encryption mode :".ENCRYPTPTION_MODE);
-		}
-		if(ENCRYPTPTION_STORAGE_MODE != "ObjectMetadata"&&ENCRYPTPTION_STORAGE_MODE!="InstructionFile"){
-			throw new Ks3ClientException("unsupported encryption storage mode :".ENCRYPTPTION_STORAGE_MODE);
-		}
-	}
+    public function __construct($accessKey, $secretKey,$encryptionMaterials, $endpoint = NULL ){
+        parent::__construct($accessKey,$secretKey,$endpoint);
+        if(is_array($encryptionMaterials)){
+            if(count($encryptionMaterials)==2){
+                $pk = openssl_pkey_get_public($encryptionMaterials[0]);
+                $sk = openssl_pkey_get_private($encryptionMaterials[1]);
+                if(!$pk)
+                    throw new Ks3ClientException("invalid RSA public key,you can generate key use openssl");
+                if(!$sk)
+                    throw new Ks3ClientException("invalid RSA private key,you can generate key use openssl");
+                $encryptionMaterials = array($pk,$sk);
+            }else{
+                throw new Ks3ClientException("encryptionMaterials should be string or an array of size 2");
+            }
+        }
+        $ks3client = new Ks3Client($accessKey,$secretKey,$endpoint);
+        $this->encryptionMaterials = $encryptionMaterials;
+        if(ENCRYPTPTION_MODE == "EO"){
+            $this->encryptionHandler = new EncryptionEO($ks3client,$encryptionMaterials);
+        }elseif (ENCRYPTPTION_MODE == "AE") {
+            throw new Ks3ClientException("Authenticated encryption will be supported in the futher");
+        }
+        else{
+            throw new Ks3ClientException("unsupported encryption mode :".ENCRYPTPTION_MODE);
+        }
+        if(ENCRYPTPTION_STORAGE_MODE != "ObjectMetadata"&&ENCRYPTPTION_STORAGE_MODE!="InstructionFile"){
+            throw new Ks3ClientException("unsupported encryption storage mode :".ENCRYPTPTION_STORAGE_MODE);
+        }
+    }
 
-	public function putObjectByContent($args=array()){
-		return $this->encryptionHandler->putObjectByContentSecurely($args);
-	}
-	public function putObjectByFile($args=array()){
-		return $this->encryptionHandler->putObjectByFileSecurely($args);
-	}
-	public function getObject($args=array()){
-		return $this->encryptionHandler->getObjectSecurely($args);
-	}
-	public function initMultipartUpload($args=array()){
-		return $this->encryptionHandler->initMultipartUploadSecurely($args);
-	}
-	public function uploadPart($args=array()){
-		return $this->encryptionHandler->uploadPartSecurely($args);
-	}
-	public function abortMultipartUpload($args=array()){
-		return $this->encryptionHandler->abortMultipartUploadSecurely($args);
-	}
-	public function completeMultipartUpload($args=array()){
-		return $this->encryptionHandler->completeMultipartUploadSecurely($args);
-	}
-	public function deleteObject($args=array()){
-		$result = parent::deleteObject($args);
-		$args["Key"] = $args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX;
-		try {
-			parent::deleteObject($args);
-		} catch (Exception $e) {
-			//do nothing
-		}
-		return $result;
-	}
-	public function copyObject($args=array()){
-		if(parent::objectExists(array(
-			"Bucket"=>$args["Bucket"],
-			"Key"=>$args["Key"]
-			))){
-			throw new Ks3ClientException("copy object faild,destination object exists");
-		}
-		if(parent::objectExists(array(
-			"Bucket"=>$args["CopySource"]["Bucket"],
-			"Key"=>$args["CopySource"]["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX
-			))){
-			parent::copyObject(
-				array(
-					"Bucket"=>$args["Bucket"],
-					"Key"=>$args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX,
-					"CopySource"=>array(
-						"Bucket"=>$args["CopySource"]["Bucket"],
-						"Key"=>$args["CopySource"]["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX
-						)
-					)
-				);
-		}
-		return parent::copyObject($args);
-	}
+    public function putObjectByContent($args=array()){
+        return $this->encryptionHandler->putObjectByContentSecurely($args);
+    }
+    public function putObjectByFile($args=array()){
+        return $this->encryptionHandler->putObjectByFileSecurely($args);
+    }
+    public function getObject($args=array()){
+        return $this->encryptionHandler->getObjectSecurely($args);
+    }
+    public function initMultipartUpload($args=array()){
+        return $this->encryptionHandler->initMultipartUploadSecurely($args);
+    }
+    public function uploadPart($args=array()){
+        return $this->encryptionHandler->uploadPartSecurely($args);
+    }
+    public function abortMultipartUpload($args=array()){
+        return $this->encryptionHandler->abortMultipartUploadSecurely($args);
+    }
+    public function completeMultipartUpload($args=array()){
+        return $this->encryptionHandler->completeMultipartUploadSecurely($args);
+    }
+    public function deleteObject($args=array()){
+        $result = parent::deleteObject($args);
+        $args["Key"] = $args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX;
+        try {
+            parent::deleteObject($args);
+        } catch (Exception $e) {
+            //do nothing
+        }
+        return $result;
+    }
+    public function copyObject($args=array()){
+        if(parent::objectExists(array(
+            "Bucket"=>$args["Bucket"],
+            "Key"=>$args["Key"]
+            ))){
+            throw new Ks3ClientException("copy object faild,destination object exists");
+        }
+        if(parent::objectExists(array(
+            "Bucket"=>$args["CopySource"]["Bucket"],
+            "Key"=>$args["CopySource"]["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX
+            ))){
+            parent::copyObject(
+                array(
+                    "Bucket"=>$args["Bucket"],
+                    "Key"=>$args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX,
+                    "CopySource"=>array(
+                        "Bucket"=>$args["CopySource"]["Bucket"],
+                        "Key"=>$args["CopySource"]["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX
+                        )
+                    )
+                );
+        }
+        return parent::copyObject($args);
+    }
 }
 
 ?>
\ No newline at end of file

Spacing +38 added lines, -38 removed lines

@@ -1,7 +1,7 @@ 
 <?php
 //使用客户端加密的方式上传下载文件
 //检测API路径
-if(!defined('KS3_API_PATH'))
+if (!defined('KS3_API_PATH'))
 define('KS3_API_PATH', dirname(__FILE__));
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."Ks3Client.class.php";
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionUtil.php";
@@ -9,88 +9,88 @@ 
 
 //加密模式
 //暂时仅支持EO,使用AES/CBC/PKCS5Padding算法对数据进行加密
-if(!defined("ENCRYPTPTION_MODE"))
-define("ENCRYPTPTION_MODE","EO");
+if (!defined("ENCRYPTPTION_MODE"))
+define("ENCRYPTPTION_MODE", "EO");
 //加密信息存储模式,暂时支持 ObjectMetadata和InstructionFile
 //ObjectMetadata:存在用户元数据中
 //InstructionFile：存在一个.instruction文件中
-if(!defined("ENCRYPTPTION_STORAGE_MODE"))
-define("ENCRYPTPTION_STORAGE_MODE","ObjectMetadata");
+if (!defined("ENCRYPTPTION_STORAGE_MODE"))
+define("ENCRYPTPTION_STORAGE_MODE", "ObjectMetadata");
 
 
-if(function_exists('get_loaded_extensions')){
+if (function_exists('get_loaded_extensions')) {
 	//检测mcrypt,openssl扩展
 	$extensions = get_loaded_extensions();
-	if($extensions){
-		if(!in_array('mcrypt', $extensions)){
+	if ($extensions) {
+		if (!in_array('mcrypt', $extensions)) {
 			throw new Ks3ClientException("please install mcrypt extension");
 		}
-		if(!in_array('openssl', $extensions)){
+		if (!in_array('openssl', $extensions)) {
 			throw new Ks3ClientException("please install openssl extension");
 		}
-	}else{
+	}else {
 		throw new Ks3ClientException("please install extensions");
 	}
-}else{
+}else {
 	throw new Ks3ClientException();
 } 
-class Ks3EncryptionClient extends Ks3Client{
+class Ks3EncryptionClient extends Ks3Client {
 	private $encryptionHandler = NULL;
 	//用户提供的主密钥,可以是对称秘钥或非对称秘钥(array,分别是公钥和私钥)
 	private $encryptionMaterials = NULL;
 
-	public function __construct($accessKey, $secretKey,$encryptionMaterials, $endpoint = NULL ){
-		parent::__construct($accessKey,$secretKey,$endpoint);
-		if(is_array($encryptionMaterials)){
-			if(count($encryptionMaterials)==2){
+	public function __construct($accessKey, $secretKey, $encryptionMaterials, $endpoint = NULL) {
+		parent::__construct($accessKey, $secretKey, $endpoint);
+		if (is_array($encryptionMaterials)) {
+			if (count($encryptionMaterials) == 2) {
 				$pk = openssl_pkey_get_public($encryptionMaterials[0]);
 				$sk = openssl_pkey_get_private($encryptionMaterials[1]);
-				if(!$pk)
+				if (!$pk)
 					throw new Ks3ClientException("invalid RSA public key,you can generate key use openssl");
-				if(!$sk)
+				if (!$sk)
 					throw new Ks3ClientException("invalid RSA private key,you can generate key use openssl");
-				$encryptionMaterials = array($pk,$sk);
-			}else{
+				$encryptionMaterials = array($pk, $sk);
+			}else {
 				throw new Ks3ClientException("encryptionMaterials should be string or an array of size 2");
 			}
 		}
-		$ks3client = new Ks3Client($accessKey,$secretKey,$endpoint);
+		$ks3client = new Ks3Client($accessKey, $secretKey, $endpoint);
 		$this->encryptionMaterials = $encryptionMaterials;
-		if(ENCRYPTPTION_MODE == "EO"){
-			$this->encryptionHandler = new EncryptionEO($ks3client,$encryptionMaterials);
+		if (ENCRYPTPTION_MODE == "EO") {
+			$this->encryptionHandler = new EncryptionEO($ks3client, $encryptionMaterials);
 		}elseif (ENCRYPTPTION_MODE == "AE") {
 			throw new Ks3ClientException("Authenticated encryption will be supported in the futher");
 		}
-		else{
+		else {
 			throw new Ks3ClientException("unsupported encryption mode :".ENCRYPTPTION_MODE);
 		}
-		if(ENCRYPTPTION_STORAGE_MODE != "ObjectMetadata"&&ENCRYPTPTION_STORAGE_MODE!="InstructionFile"){
+		if (ENCRYPTPTION_STORAGE_MODE != "ObjectMetadata" && ENCRYPTPTION_STORAGE_MODE != "InstructionFile") {
 			throw new Ks3ClientException("unsupported encryption storage mode :".ENCRYPTPTION_STORAGE_MODE);
 		}
 	}
 
-	public function putObjectByContent($args=array()){
+	public function putObjectByContent($args = array()) {
 		return $this->encryptionHandler->putObjectByContentSecurely($args);
 	}
-	public function putObjectByFile($args=array()){
+	public function putObjectByFile($args = array()) {
 		return $this->encryptionHandler->putObjectByFileSecurely($args);
 	}
-	public function getObject($args=array()){
+	public function getObject($args = array()) {
 		return $this->encryptionHandler->getObjectSecurely($args);
 	}
-	public function initMultipartUpload($args=array()){
+	public function initMultipartUpload($args = array()) {
 		return $this->encryptionHandler->initMultipartUploadSecurely($args);
 	}
-	public function uploadPart($args=array()){
+	public function uploadPart($args = array()) {
 		return $this->encryptionHandler->uploadPartSecurely($args);
 	}
-	public function abortMultipartUpload($args=array()){
+	public function abortMultipartUpload($args = array()) {
 		return $this->encryptionHandler->abortMultipartUploadSecurely($args);
 	}
-	public function completeMultipartUpload($args=array()){
+	public function completeMultipartUpload($args = array()) {
 		return $this->encryptionHandler->completeMultipartUploadSecurely($args);
 	}
-	public function deleteObject($args=array()){
+	public function deleteObject($args = array()) {
 		$result = parent::deleteObject($args);
 		$args["Key"] = $args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX;
 		try {
@@ -100,17 +100,17 @@ 
 		}
 		return $result;
 	}
-	public function copyObject($args=array()){
-		if(parent::objectExists(array(
+	public function copyObject($args = array()) {
+		if (parent::objectExists(array(
 			"Bucket"=>$args["Bucket"],
 			"Key"=>$args["Key"]
-			))){
+			))) {
 			throw new Ks3ClientException("copy object faild,destination object exists");
 		}
-		if(parent::objectExists(array(
+		if (parent::objectExists(array(
 			"Bucket"=>$args["CopySource"]["Bucket"],
 			"Key"=>$args["CopySource"]["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX
-			))){
+			))) {
 			parent::copyObject(
 				array(
 					"Bucket"=>$args["Bucket"],

Braces +20 added lines, -16 removed lines

@@ -1,21 +1,24 @@ 
 <?php
 //使用客户端加密的方式上传下载文件
 //检测API路径
-if(!defined('KS3_API_PATH'))
-define('KS3_API_PATH', dirname(__FILE__));
+if(!defined('KS3_API_PATH')) {
+    define('KS3_API_PATH', dirname(__FILE__));
+}
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."Ks3Client.class.php";
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionUtil.php";
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionHandlers.php";
 
 //加密模式
 //暂时仅支持EO,使用AES/CBC/PKCS5Padding算法对数据进行加密
-if(!defined("ENCRYPTPTION_MODE"))
-define("ENCRYPTPTION_MODE","EO");
+if(!defined("ENCRYPTPTION_MODE")) {
+    define("ENCRYPTPTION_MODE","EO");
+}
 //加密信息存储模式,暂时支持 ObjectMetadata和InstructionFile
 //ObjectMetadata:存在用户元数据中
 //InstructionFile：存在一个.instruction文件中
-if(!defined("ENCRYPTPTION_STORAGE_MODE"))
-define("ENCRYPTPTION_STORAGE_MODE","ObjectMetadata");
+if(!defined("ENCRYPTPTION_STORAGE_MODE")) {
+    define("ENCRYPTPTION_STORAGE_MODE","ObjectMetadata");
+}
 
 
 if(function_exists('get_loaded_extensions')){
@@ -28,10 +31,10 @@ 
 		if(!in_array('openssl', $extensions)){
 			throw new Ks3ClientException("please install openssl extension");
 		}
-	}else{
+	} else{
 		throw new Ks3ClientException("please install extensions");
 	}
-}else{
+} else{
 	throw new Ks3ClientException();
 } 
 class Ks3EncryptionClient extends Ks3Client{
@@ -45,12 +48,14 @@ 
 			if(count($encryptionMaterials)==2){
 				$pk = openssl_pkey_get_public($encryptionMaterials[0]);
 				$sk = openssl_pkey_get_private($encryptionMaterials[1]);
-				if(!$pk)
-					throw new Ks3ClientException("invalid RSA public key,you can generate key use openssl");
-				if(!$sk)
-					throw new Ks3ClientException("invalid RSA private key,you can generate key use openssl");
+				if(!$pk) {
+									throw new Ks3ClientException("invalid RSA public key,you can generate key use openssl");
+				}
+				if(!$sk) {
+									throw new Ks3ClientException("invalid RSA private key,you can generate key use openssl");
+				}
 				$encryptionMaterials = array($pk,$sk);
-			}else{
+			} else{
 				throw new Ks3ClientException("encryptionMaterials should be string or an array of size 2");
 			}
 		}
@@ -58,10 +63,9 @@ 
 		$this->encryptionMaterials = $encryptionMaterials;
 		if(ENCRYPTPTION_MODE == "EO"){
 			$this->encryptionHandler = new EncryptionEO($ks3client,$encryptionMaterials);
-		}elseif (ENCRYPTPTION_MODE == "AE") {
+		} elseif (ENCRYPTPTION_MODE == "AE") {
 			throw new Ks3ClientException("Authenticated encryption will be supported in the futher");
-		}
-		else{
+		} else{
 			throw new Ks3ClientException("unsupported encryption mode :".ENCRYPTPTION_MODE);
 		}
 		if(ENCRYPTPTION_STORAGE_MODE != "ObjectMetadata"&&ENCRYPTPTION_STORAGE_MODE!="InstructionFile"){

src/service/ksyun/bin/samples/FormUpload.php

Indentation +6 added lines, -6 removed lines

@@ -16,14 +16,14 @@
 
 //将所有能确定值的表单项都放在该数组中
 $postData = array(
-	"key"=>$key,
-	"success_action_redirect"=>$redirect,
-	"Content-Type"=>"text/html",
-	);
+    "key"=>$key,
+    "success_action_redirect"=>$redirect,
+    "Content-Type"=>"text/html",
+    );
 //将不能确定值的表单项都放在该数组中
 $unknowData = array(
-	"random"
-	);
+    "random"
+    );
 $result = $client->postObject($bucket_name,$postData,$unknowData);
 print_r($result);
 

Spacing +9 added lines, -9 removed lines

@@ -2,9 +2,9 @@ 
 //更加详细的表单上传请参考js sdk
 require_once "../Ks3Client.class.php";
 
-$client = new Ks3Client("","");
+$client = new Ks3Client("", "");
 $bucket_name = "phpsdktestlijunwei";
-if(!$client->bucketExists(array("Bucket"=>$bucket_name))){
+if (!$client->bucketExists(array("Bucket"=>$bucket_name))) {
     $client->createBucket(array("Bucket"=>$bucket_name));
 }
 
@@ -24,7 +24,7 @@ 
 $unknowData = array(
 	"random"
 	);
-$result = $client->postObject($bucket_name,$postData,$unknowData);
+$result = $client->postObject($bucket_name, $postData, $unknowData);
 print_r($result);
 
 ?>
@@ -33,14 +33,14 @@ 
 <meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
 </head>
 <body>
-<form action="<?php echo $host_uri;?>" method="post" enctype="multipart/form-data">
-Key to upload: <input type="input" name="key" value="<?php echo $key;?>" /><br />
-<input type="hidden" name="success_action_redirect" value="<?php echo $redirect;?>" />
+<form action="<?php echo $host_uri; ?>" method="post" enctype="multipart/form-data">
+Key to upload: <input type="input" name="key" value="<?php echo $key; ?>" /><br />
+<input type="hidden" name="success_action_redirect" value="<?php echo $redirect; ?>" />
 <input type="hidden" name="Content-Type" value="text/html" />
 <input type="hidden" name="random" value="vfegf34egf3" />
-<input type="hidden" name="KSSAccessKeyId" value="<?php echo $result["KSSAccessKeyId"];?>" />
-<input type="hidden" name="Policy" value="<?php echo $result["Policy"];?>" />
-<input type="hidden" name="Signature" value="<?php echo $result["Signature"];?>" />
+<input type="hidden" name="KSSAccessKeyId" value="<?php echo $result["KSSAccessKeyId"]; ?>" />
+<input type="hidden" name="Policy" value="<?php echo $result["Policy"]; ?>" />
+<input type="hidden" name="Signature" value="<?php echo $result["Signature"]; ?>" />
 File: <input type="file" name="file" /> <br />
 <!-- The elements after this will be ignored -->
 <input type="submit" name="submit" value="Upload to KSS S3" />

src/service/ksyun/bin/samples/TestEncryptionClientMeta.php

Indentation +59 added lines, -59 removed lines

@@ -16,37 +16,37 @@ 
 multipartUpload($client,$bucket,$keyprefix);
 
 function putObjectByContentAndGetObjectUsingMeta($client,$bucket,$keyprefix){
-	for($i = 45 ;$i < 60;$i++){
+    for($i = 45 ;$i < 60;$i++){
 
-		$content = EncryptionUtil::genereateOnceUsedKey($i);
+        $content = EncryptionUtil::genereateOnceUsedKey($i);
 
-		$args = array(
-			"Bucket"=>$bucket,
-			"Key"=>$keyprefix."EOMeta",
-			"ACL"=>"public-read",
-			"Content"=>$content
-		);
-		$client->putObjectByContent($args);
-		rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
-			"D://testdown/down",base64_encode(md5($args["Content"])));
-	}
+        $args = array(
+            "Bucket"=>$bucket,
+            "Key"=>$keyprefix."EOMeta",
+            "ACL"=>"public-read",
+            "Content"=>$content
+        );
+        $client->putObjectByContent($args);
+        rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
+            "D://testdown/down",base64_encode(md5($args["Content"])));
+    }
 }
 function putObjectByFileAndGetObjectUsingMeta($client,$bucket,$keyprefix){
 
-	$args = array(
-		"Bucket"=>$bucket,
-		"Key"=>$keyprefix."EOMeta",
-		"ACL"=>"public-read",
-		"Content"=>array(
-			"content"=>"D://IMG.jpg"
-			)
-	);
-	$client->putObjectByFile($args);
-	rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
-			"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+    $args = array(
+        "Bucket"=>$bucket,
+        "Key"=>$keyprefix."EOMeta",
+        "ACL"=>"public-read",
+        "Content"=>array(
+            "content"=>"D://IMG.jpg"
+            )
+    );
+    $client->putObjectByFile($args);
+    rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
+            "D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
 }
 function multipartUpload($client,$bucket,$keyprefix){
-	//初始化分开上传，获取uploadid
+    //初始化分开上传，获取uploadid
     $args = array(
         "Bucket"=>$bucket,
         "Key"=>$keyprefix."EOMeta",
@@ -67,8 +67,8 @@ 
         echo "upload".$i."\r\n";
         $args=array(
             "Bucket"=>$bucket,
-        	"Key"=>$keyprefix."EOMeta",
-        	"LastPart"=>($i===$count-1),
+            "Key"=>$keyprefix."EOMeta",
+            "LastPart"=>($i===$count-1),
             "Options"=>array(
                 "partNumber"=>$i+1,
                 "uploadId"=>$uploadid
@@ -95,42 +95,42 @@ 
     $result = $client->completeMultipartUpload($args);
 
     rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
-    	"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+        "D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
 }
 function rangeGetAndCheckMd5($client,$bucket,$key,$file,$expectedMd5){
-	$args = array("Bucket"=>$bucket,"Key"=>$key);
-	$meta = $client->getObjectMeta($args);
-	$contentlength = $meta["ObjectMeta"]["Content-Length"];
+    $args = array("Bucket"=>$bucket,"Key"=>$key);
+    $meta = $client->getObjectMeta($args);
+    $contentlength = $meta["ObjectMeta"]["Content-Length"];
 
-	$filelist = array();
+    $filelist = array();
 
-	for($begin = 0;$begin <$contentlength;){
-		$index = rand((int)($contentlength/20),(int)($contentlength/10));
-		$range = array("start"=>$begin,"end"=>$begin+$index);
-		$destFile = $file.$begin."-".($begin+$index);
-		array_push($filelist,$destFile);
-		$begin += ($index+1);
-		$args = array(
-			"Bucket"=>$bucket,
-			"Key"=>$key,
-			"Range"=>$range,
-			"WriteTo"=>$destFile
-		);
-		$client->getObject($args);
-	}
+    for($begin = 0;$begin <$contentlength;){
+        $index = rand((int)($contentlength/20),(int)($contentlength/10));
+        $range = array("start"=>$begin,"end"=>$begin+$index);
+        $destFile = $file.$begin."-".($begin+$index);
+        array_push($filelist,$destFile);
+        $begin += ($index+1);
+        $args = array(
+            "Bucket"=>$bucket,
+            "Key"=>$key,
+            "Range"=>$range,
+            "WriteTo"=>$destFile
+        );
+        $client->getObject($args);
+    }
 
-	foreach ($filelist as $key => $value) {
-		$handle = fopen($value,"r");
-		$size = filesize($value);
-		if($size > 0){
-			$content = fread($handle,$size);
-			file_put_contents($file,$content,FILE_APPEND);
-		}
-		fclose($handle);
-		@unlink($value);
-	}
-	$md5 = base64_encode(md5_file($file));
-	if($md5 != $expectedMd5)
-		throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
-	@unlink($file);	
+    foreach ($filelist as $key => $value) {
+        $handle = fopen($value,"r");
+        $size = filesize($value);
+        if($size > 0){
+            $content = fread($handle,$size);
+            file_put_contents($file,$content,FILE_APPEND);
+        }
+        fclose($handle);
+        @unlink($value);
+    }
+    $md5 = base64_encode(md5_file($file));
+    if($md5 != $expectedMd5)
+        throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
+    @unlink($file);	
 }

Spacing +38 added lines, -38 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-define("ENCRYPTPTION_STORAGE_MODE","ObjectMetadata");
+define("ENCRYPTPTION_STORAGE_MODE", "ObjectMetadata");
 require_once "../Ks3EncryptionClient.class.php";
 require_once "../Ks3Client.class.php";
 $bucket = "test-encryption";
@@ -7,16 +7,16 @@ 
 
 $filename = "secret.key";
 $handle = fopen($filename, "r");
-$contents = fread($handle, filesize ($filename));
+$contents = fread($handle, filesize($filename));
 fclose($handle);
 
-$client = new Ks3EncryptionClient("lMQTr0hNlMpB0iOk/i+x","D4CsYLs75JcWEjbiI22zR3P7kJ/+5B1qdEje7A7I",$contents);
-putObjectByContentAndGetObjectUsingMeta($client,$bucket,$keyprefix);
-putObjectByFileAndGetObjectUsingMeta($client,$bucket,$keyprefix);
-multipartUpload($client,$bucket,$keyprefix);
+$client = new Ks3EncryptionClient("lMQTr0hNlMpB0iOk/i+x", "D4CsYLs75JcWEjbiI22zR3P7kJ/+5B1qdEje7A7I", $contents);
+putObjectByContentAndGetObjectUsingMeta($client, $bucket, $keyprefix);
+putObjectByFileAndGetObjectUsingMeta($client, $bucket, $keyprefix);
+multipartUpload($client, $bucket, $keyprefix);
 
-function putObjectByContentAndGetObjectUsingMeta($client,$bucket,$keyprefix){
-	for($i = 45 ;$i < 60;$i++){
+function putObjectByContentAndGetObjectUsingMeta($client, $bucket, $keyprefix) {
+	for ($i = 45; $i < 60; $i++) {
 
 		$content = EncryptionUtil::genereateOnceUsedKey($i);
 
@@ -27,11 +27,11 @@ 
 			"Content"=>$content
 		);
 		$client->putObjectByContent($args);
-		rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
-			"D://testdown/down",base64_encode(md5($args["Content"])));
+		rangeGetAndCheckMd5($client, $bucket, $keyprefix."EOMeta",
+			"D://testdown/down", base64_encode(md5($args["Content"])));
 	}
 }
-function putObjectByFileAndGetObjectUsingMeta($client,$bucket,$keyprefix){
+function putObjectByFileAndGetObjectUsingMeta($client, $bucket, $keyprefix) {
 
 	$args = array(
 		"Bucket"=>$bucket,
@@ -42,39 +42,39 @@ 
 			)
 	);
 	$client->putObjectByFile($args);
-	rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
-			"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+	rangeGetAndCheckMd5($client, $bucket, $keyprefix."EOMeta",
+			"D://testdown/down", base64_encode(md5_file("D://IMG.jpg")));
 }
-function multipartUpload($client,$bucket,$keyprefix){
+function multipartUpload($client, $bucket, $keyprefix) {
 	//初始化分开上传，获取uploadid
     $args = array(
         "Bucket"=>$bucket,
         "Key"=>$keyprefix."EOMeta",
     );
     $uploadid = $client->initMultipartUpload($args);
-    $uploadid = $uploadid["UploadId"];//获取到uploadid
+    $uploadid = $uploadid["UploadId"]; //获取到uploadid
         //开始上传
 
-    $file = "D://IMG.jpg";//要上传的文件
+    $file = "D://IMG.jpg"; //要上传的文件
     $partsize = 1024*100;
-    $resource = fopen($file,"r");
+    $resource = fopen($file, "r");
     $stat = fstat($resource);
-    $total = $stat["size"];//获取文件的总大小
+    $total = $stat["size"]; //获取文件的总大小
     fclose($resource);
-    $count = (int)(($total-1)/$partsize)+1;//计算文件需要分几块上传
-    for($i = 0;$i < $count;$i++){
+    $count = (int)(($total-1)/$partsize)+1; //计算文件需要分几块上传
+    for ($i = 0; $i < $count; $i++) {
         //依次上传每一块
         echo "upload".$i."\r\n";
-        $args=array(
+        $args = array(
             "Bucket"=>$bucket,
         	"Key"=>$keyprefix."EOMeta",
-        	"LastPart"=>($i===$count-1),
+        	"LastPart"=>($i === $count-1),
             "Options"=>array(
                 "partNumber"=>$i+1,
                 "uploadId"=>$uploadid
             ),
             "ObjectMeta"=>array(
-                "Content-Length"=>min($partsize,$total-$partsize*$i)//每次上传$partsize大小
+                "Content-Length"=>min($partsize, $total-$partsize*$i)//每次上传$partsize大小
             ),
             "Content"=>array(
                 "content"=>$file,
@@ -84,9 +84,9 @@ 
         $etag = $client->uploadPart($args);
         $etag = $etag["ETag"];
     }
-    $parts = $client->listParts(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOMeta","Options"=>array("uploadId"=>$uploadid)));
+    $parts = $client->listParts(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOMeta", "Options"=>array("uploadId"=>$uploadid)));
     //结束上传
-    $args=array(
+    $args = array(
         "Bucket"=>$bucket,
         "Key"=>$keyprefix."EOMeta",
         "Options"=>array("uploadId"=>$uploadid),
@@ -94,21 +94,21 @@ 
     );
     $result = $client->completeMultipartUpload($args);
 
-    rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOMeta",
-    	"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+    rangeGetAndCheckMd5($client, $bucket, $keyprefix."EOMeta",
+    	"D://testdown/down", base64_encode(md5_file("D://IMG.jpg")));
 }
-function rangeGetAndCheckMd5($client,$bucket,$key,$file,$expectedMd5){
-	$args = array("Bucket"=>$bucket,"Key"=>$key);
+function rangeGetAndCheckMd5($client, $bucket, $key, $file, $expectedMd5) {
+	$args = array("Bucket"=>$bucket, "Key"=>$key);
 	$meta = $client->getObjectMeta($args);
 	$contentlength = $meta["ObjectMeta"]["Content-Length"];
 
 	$filelist = array();
 
-	for($begin = 0;$begin <$contentlength;){
-		$index = rand((int)($contentlength/20),(int)($contentlength/10));
-		$range = array("start"=>$begin,"end"=>$begin+$index);
+	for ($begin = 0; $begin < $contentlength;) {
+		$index = rand((int)($contentlength/20), (int)($contentlength/10));
+		$range = array("start"=>$begin, "end"=>$begin+$index);
 		$destFile = $file.$begin."-".($begin+$index);
-		array_push($filelist,$destFile);
+		array_push($filelist, $destFile);
 		$begin += ($index+1);
 		$args = array(
 			"Bucket"=>$bucket,
@@ -120,17 +120,17 @@ 
 	}
 
 	foreach ($filelist as $key => $value) {
-		$handle = fopen($value,"r");
+		$handle = fopen($value, "r");
 		$size = filesize($value);
-		if($size > 0){
-			$content = fread($handle,$size);
-			file_put_contents($file,$content,FILE_APPEND);
+		if ($size > 0) {
+			$content = fread($handle, $size);
+			file_put_contents($file, $content, FILE_APPEND);
 		}
 		fclose($handle);
 		@unlink($value);
 	}
 	$md5 = base64_encode(md5_file($file));
-	if($md5 != $expectedMd5)
+	if ($md5 != $expectedMd5)
 		throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
 	@unlink($file);	
 }

Braces +3 added lines, -2 removed lines

@@ -130,7 +130,8 @@
 		@unlink($value);
 	}
 	$md5 = base64_encode(md5_file($file));
-	if($md5 != $expectedMd5)
-		throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
+	if($md5 != $expectedMd5) {
+			throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
+	}
 	@unlink($file);	
 }

src/service/ksyun/bin/samples/TestEncryptionClientFile.php

Indentation +87 added lines, -87 removed lines

@@ -17,33 +17,33 @@ 
 copyAnddeleteObject($client,$bucket,$keyprefix);
 
 function putObjectByContentAndGetObjectUsingInstruction($client,$bucket,$keyprefix){
-	$content = EncryptionUtil::genereateOnceUsedKey(rand(100,1000));
-	$args = array(
-		"Bucket"=>$bucket,
-		"Key"=>$keyprefix."EOFile",
-		"ACL"=>"public-read",
-		"Content"=>$content
-	);
-	$client->putObjectByContent($args);
-	rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
-			"D://testdown/down",base64_encode(md5($args["Content"])));
+    $content = EncryptionUtil::genereateOnceUsedKey(rand(100,1000));
+    $args = array(
+        "Bucket"=>$bucket,
+        "Key"=>$keyprefix."EOFile",
+        "ACL"=>"public-read",
+        "Content"=>$content
+    );
+    $client->putObjectByContent($args);
+    rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
+            "D://testdown/down",base64_encode(md5($args["Content"])));
 }
 function putObjectByFileAndGetObjectUsingFile($client,$bucket,$keyprefix){
 
-	$args = array(
-		"Bucket"=>$bucket,
-		"Key"=>$keyprefix."EOFile",
-		"ACL"=>"public-read",
-		"Content"=>array(
-			"content"=>"D://IMG.jpg"
-			)
-	);
-	$client->putObjectByFile($args);
-	rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
-			"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+    $args = array(
+        "Bucket"=>$bucket,
+        "Key"=>$keyprefix."EOFile",
+        "ACL"=>"public-read",
+        "Content"=>array(
+            "content"=>"D://IMG.jpg"
+            )
+    );
+    $client->putObjectByFile($args);
+    rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
+            "D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
 }
 function multipartUpload($client,$bucket,$keyprefix){
-	//初始化分开上传，获取uploadid
+    //初始化分开上传，获取uploadid
     $args = array(
         "Bucket"=>$bucket,
         "Key"=>$keyprefix."EOFile",
@@ -64,8 +64,8 @@ 
         echo "upload".$i."\r\n";
         $args=array(
             "Bucket"=>$bucket,
-        	"Key"=>$keyprefix."EOFile",
-        	"LastPart"=>($i===$count-1),
+            "Key"=>$keyprefix."EOFile",
+            "LastPart"=>($i===$count-1),
             "Options"=>array(
                 "partNumber"=>$i+1,
                 "uploadId"=>$uploadid
@@ -92,79 +92,79 @@ 
     $result = $client->completeMultipartUpload($args);
 
     rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
-    	"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+        "D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
 }
 function copyAnddeleteObject($client,$bucket,$keyprefix){
-	$content = EncryptionUtil::genereateOnceUsedKey(rand(100,1000));
-	$args = array(
-		"Bucket"=>$bucket,
-		"Key"=>$keyprefix."EOFile",
-		"ACL"=>"public-read",
-		"Content"=>$content
-	);
-	$client->putObjectByContent($args);
+    $content = EncryptionUtil::genereateOnceUsedKey(rand(100,1000));
+    $args = array(
+        "Bucket"=>$bucket,
+        "Key"=>$keyprefix."EOFile",
+        "ACL"=>"public-read",
+        "Content"=>$content
+    );
+    $client->putObjectByContent($args);
 
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
-		$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
-		$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"));
+    if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
+        $client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
+    if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
+        $client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"));
 
-	$copyReq = array(
-		"Bucket"=>$bucket,
-		"Key"=>$keyprefix."EOFileCopy",
-		"CopySource"=>array(
-			"Bucket"=>$bucket,
-			"Key"=>$keyprefix."EOFile"
-			)
-		);
-	$client->copyObject($copyReq);
+    $copyReq = array(
+        "Bucket"=>$bucket,
+        "Key"=>$keyprefix."EOFileCopy",
+        "CopySource"=>array(
+            "Bucket"=>$bucket,
+            "Key"=>$keyprefix."EOFile"
+            )
+        );
+    $client->copyObject($copyReq);
 
-	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
-		throw new Exception("not found ".$keyprefix."EOFileCopy");
-	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
-		throw new Exception("not found ".$keyprefix."EOFileCopy.instruction");
+    if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
+        throw new Exception("not found ".$keyprefix."EOFileCopy");
+    if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
+        throw new Exception("not found ".$keyprefix."EOFileCopy.instruction");
 
-	$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
+    $client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
 
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
-		throw new Exception("found ".$keyprefix."EOFileCopy");
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
-		throw new Exception("found ".$keyprefix."EOFileCopy.instruction");
+    if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
+        throw new Exception("found ".$keyprefix."EOFileCopy");
+    if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
+        throw new Exception("found ".$keyprefix."EOFileCopy.instruction");
 }
 function rangeGetAndCheckMd5($client,$bucket,$key,$file,$expectedMd5){
-	$args = array("Bucket"=>$bucket,"Key"=>$key);
-	$meta = $client->getObjectMeta($args);
-	$contentlength = $meta["ObjectMeta"]["Content-Length"];
+    $args = array("Bucket"=>$bucket,"Key"=>$key);
+    $meta = $client->getObjectMeta($args);
+    $contentlength = $meta["ObjectMeta"]["Content-Length"];
 
-	$filelist = array();
+    $filelist = array();
 
-	for($begin = 0;$begin <$contentlength;){
-		$index = rand((int)($contentlength/20),(int)($contentlength/10));
-		$range = array("start"=>$begin,"end"=>$begin+$index);
-		$destFile = $file.$begin."-".($begin+$index);
-		array_push($filelist,$destFile);
-		$begin += ($index+1);
-		$args = array(
-			"Bucket"=>$bucket,
-			"Key"=>$key,
-			"Range"=>$range,
-			"WriteTo"=>$destFile
-		);
-		$client->getObject($args);
-	}
+    for($begin = 0;$begin <$contentlength;){
+        $index = rand((int)($contentlength/20),(int)($contentlength/10));
+        $range = array("start"=>$begin,"end"=>$begin+$index);
+        $destFile = $file.$begin."-".($begin+$index);
+        array_push($filelist,$destFile);
+        $begin += ($index+1);
+        $args = array(
+            "Bucket"=>$bucket,
+            "Key"=>$key,
+            "Range"=>$range,
+            "WriteTo"=>$destFile
+        );
+        $client->getObject($args);
+    }
 
-	foreach ($filelist as $key => $value) {
-		$handle = fopen($value,"r");
-		$size = filesize($value);
-		if($size > 0){
-			$content = fread($handle,$size);
-			file_put_contents($file,$content,FILE_APPEND);
-		}
-		fclose($handle);
-		@unlink($value);
-	}
-	$md5 = base64_encode(md5_file($file));
-	if($md5 != $expectedMd5)
-		throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
-	@unlink($file);	
+    foreach ($filelist as $key => $value) {
+        $handle = fopen($value,"r");
+        $size = filesize($value);
+        if($size > 0){
+            $content = fread($handle,$size);
+            file_put_contents($file,$content,FILE_APPEND);
+        }
+        fclose($handle);
+        @unlink($value);
+    }
+    $md5 = base64_encode(md5_file($file));
+    if($md5 != $expectedMd5)
+        throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
+    @unlink($file);	
 }

Spacing +50 added lines, -50 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-define("ENCRYPTPTION_STORAGE_MODE","InstructionFile");
+define("ENCRYPTPTION_STORAGE_MODE", "InstructionFile");
 require_once "../Ks3EncryptionClient.class.php";
 require_once "../Ks3Client.class.php";
 $bucket = "test-encryption";
@@ -7,17 +7,17 @@ 
 
 $filename = "secret.key";
 $handle = fopen($filename, "r");
-$contents = fread($handle, filesize ($filename));
+$contents = fread($handle, filesize($filename));
 fclose($handle);
 
-$client = new Ks3EncryptionClient("lMQTr0hNlMpB0iOk/i+x","D4CsYLs75JcWEjbiI22zR3P7kJ/+5B1qdEje7A7I",$contents);
-putObjectByContentAndGetObjectUsingInstruction($client,$bucket,$keyprefix);
-putObjectByFileAndGetObjectUsingFile($client,$bucket,$keyprefix);
-multipartUpload($client,$bucket,$keyprefix);
-copyAnddeleteObject($client,$bucket,$keyprefix);
+$client = new Ks3EncryptionClient("lMQTr0hNlMpB0iOk/i+x", "D4CsYLs75JcWEjbiI22zR3P7kJ/+5B1qdEje7A7I", $contents);
+putObjectByContentAndGetObjectUsingInstruction($client, $bucket, $keyprefix);
+putObjectByFileAndGetObjectUsingFile($client, $bucket, $keyprefix);
+multipartUpload($client, $bucket, $keyprefix);
+copyAnddeleteObject($client, $bucket, $keyprefix);
 
-function putObjectByContentAndGetObjectUsingInstruction($client,$bucket,$keyprefix){
-	$content = EncryptionUtil::genereateOnceUsedKey(rand(100,1000));
+function putObjectByContentAndGetObjectUsingInstruction($client, $bucket, $keyprefix) {
+	$content = EncryptionUtil::genereateOnceUsedKey(rand(100, 1000));
 	$args = array(
 		"Bucket"=>$bucket,
 		"Key"=>$keyprefix."EOFile",
@@ -25,10 +25,10 @@ 
 		"Content"=>$content
 	);
 	$client->putObjectByContent($args);
-	rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
-			"D://testdown/down",base64_encode(md5($args["Content"])));
+	rangeGetAndCheckMd5($client, $bucket, $keyprefix."EOFile",
+			"D://testdown/down", base64_encode(md5($args["Content"])));
 }
-function putObjectByFileAndGetObjectUsingFile($client,$bucket,$keyprefix){
+function putObjectByFileAndGetObjectUsingFile($client, $bucket, $keyprefix) {
 
 	$args = array(
 		"Bucket"=>$bucket,
@@ -39,39 +39,39 @@ 
 			)
 	);
 	$client->putObjectByFile($args);
-	rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
-			"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+	rangeGetAndCheckMd5($client, $bucket, $keyprefix."EOFile",
+			"D://testdown/down", base64_encode(md5_file("D://IMG.jpg")));
 }
-function multipartUpload($client,$bucket,$keyprefix){
+function multipartUpload($client, $bucket, $keyprefix) {
 	//初始化分开上传，获取uploadid
     $args = array(
         "Bucket"=>$bucket,
         "Key"=>$keyprefix."EOFile",
     );
     $uploadid = $client->initMultipartUpload($args);
-    $uploadid = $uploadid["UploadId"];//获取到uploadid
+    $uploadid = $uploadid["UploadId"]; //获取到uploadid
         //开始上传
 
-    $file = "D://IMG.jpg";//要上传的文件
+    $file = "D://IMG.jpg"; //要上传的文件
     $partsize = 1024*100;
-    $resource = fopen($file,"r");
+    $resource = fopen($file, "r");
     $stat = fstat($resource);
-    $total = $stat["size"];//获取文件的总大小
+    $total = $stat["size"]; //获取文件的总大小
     fclose($resource);
-    $count = (int)(($total-1)/$partsize)+1;//计算文件需要分几块上传
-    for($i = 0;$i < $count;$i++){
+    $count = (int)(($total-1)/$partsize)+1; //计算文件需要分几块上传
+    for ($i = 0; $i < $count; $i++) {
         //依次上传每一块
         echo "upload".$i."\r\n";
-        $args=array(
+        $args = array(
             "Bucket"=>$bucket,
         	"Key"=>$keyprefix."EOFile",
-        	"LastPart"=>($i===$count-1),
+        	"LastPart"=>($i === $count-1),
             "Options"=>array(
                 "partNumber"=>$i+1,
                 "uploadId"=>$uploadid
             ),
             "ObjectMeta"=>array(
-                "Content-Length"=>min($partsize,$total-$partsize*$i)//每次上传$partsize大小
+                "Content-Length"=>min($partsize, $total-$partsize*$i)//每次上传$partsize大小
             ),
             "Content"=>array(
                 "content"=>$file,
@@ -81,9 +81,9 @@ 
         $etag = $client->uploadPart($args);
         $etag = $etag["ETag"];
     }
-    $parts = $client->listParts(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFile","Options"=>array("uploadId"=>$uploadid)));
+    $parts = $client->listParts(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFile", "Options"=>array("uploadId"=>$uploadid)));
     //结束上传
-    $args=array(
+    $args = array(
         "Bucket"=>$bucket,
         "Key"=>$keyprefix."EOFile",
         "Options"=>array("uploadId"=>$uploadid),
@@ -91,11 +91,11 @@ 
     );
     $result = $client->completeMultipartUpload($args);
 
-    rangeGetAndCheckMd5($client,$bucket,$keyprefix."EOFile",
-    	"D://testdown/down",base64_encode(md5_file("D://IMG.jpg")));
+    rangeGetAndCheckMd5($client, $bucket, $keyprefix."EOFile",
+    	"D://testdown/down", base64_encode(md5_file("D://IMG.jpg")));
 }
-function copyAnddeleteObject($client,$bucket,$keyprefix){
-	$content = EncryptionUtil::genereateOnceUsedKey(rand(100,1000));
+function copyAnddeleteObject($client, $bucket, $keyprefix) {
+	$content = EncryptionUtil::genereateOnceUsedKey(rand(100, 1000));
 	$args = array(
 		"Bucket"=>$bucket,
 		"Key"=>$keyprefix."EOFile",
@@ -104,10 +104,10 @@ 
 	);
 	$client->putObjectByContent($args);
 
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
-		$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
-		$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"));
+	if ($client->objectExists(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy")))
+		$client->deleteObject(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy"));
+	if ($client->objectExists(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy.instruction")))
+		$client->deleteObject(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy.instruction"));
 
 	$copyReq = array(
 		"Bucket"=>$bucket,
@@ -119,30 +119,30 @@ 
 		);
 	$client->copyObject($copyReq);
 
-	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
+	if (!$client->objectExists(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy")))
 		throw new Exception("not found ".$keyprefix."EOFileCopy");
-	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
+	if (!$client->objectExists(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy.instruction")))
 		throw new Exception("not found ".$keyprefix."EOFileCopy.instruction");
 
-	$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
+	$client->deleteObject(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy"));
 
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
+	if ($client->objectExists(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy")))
 		throw new Exception("found ".$keyprefix."EOFileCopy");
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
+	if ($client->objectExists(array("Bucket"=>$bucket, "Key"=>$keyprefix."EOFileCopy.instruction")))
 		throw new Exception("found ".$keyprefix."EOFileCopy.instruction");
 }
-function rangeGetAndCheckMd5($client,$bucket,$key,$file,$expectedMd5){
-	$args = array("Bucket"=>$bucket,"Key"=>$key);
+function rangeGetAndCheckMd5($client, $bucket, $key, $file, $expectedMd5) {
+	$args = array("Bucket"=>$bucket, "Key"=>$key);
 	$meta = $client->getObjectMeta($args);
 	$contentlength = $meta["ObjectMeta"]["Content-Length"];
 
 	$filelist = array();
 
-	for($begin = 0;$begin <$contentlength;){
-		$index = rand((int)($contentlength/20),(int)($contentlength/10));
-		$range = array("start"=>$begin,"end"=>$begin+$index);
+	for ($begin = 0; $begin < $contentlength;) {
+		$index = rand((int)($contentlength/20), (int)($contentlength/10));
+		$range = array("start"=>$begin, "end"=>$begin+$index);
 		$destFile = $file.$begin."-".($begin+$index);
-		array_push($filelist,$destFile);
+		array_push($filelist, $destFile);
 		$begin += ($index+1);
 		$args = array(
 			"Bucket"=>$bucket,
@@ -154,17 +154,17 @@ 
 	}
 
 	foreach ($filelist as $key => $value) {
-		$handle = fopen($value,"r");
+		$handle = fopen($value, "r");
 		$size = filesize($value);
-		if($size > 0){
-			$content = fread($handle,$size);
-			file_put_contents($file,$content,FILE_APPEND);
+		if ($size > 0) {
+			$content = fread($handle, $size);
+			file_put_contents($file, $content, FILE_APPEND);
 		}
 		fclose($handle);
 		@unlink($value);
 	}
 	$md5 = base64_encode(md5_file($file));
-	if($md5 != $expectedMd5)
+	if ($md5 != $expectedMd5)
 		throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
 	@unlink($file);	
 }

Braces +22 added lines, -15 removed lines

@@ -104,10 +104,12 @@ 
 	);
 	$client->putObjectByContent($args);
 
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
-		$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
-		$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"));
+	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"))) {
+			$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
+	}
+	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"))) {
+			$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"));
+	}
 
 	$copyReq = array(
 		"Bucket"=>$bucket,
@@ -119,18 +121,22 @@ 
 		);
 	$client->copyObject($copyReq);
 
-	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
-		throw new Exception("not found ".$keyprefix."EOFileCopy");
-	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
-		throw new Exception("not found ".$keyprefix."EOFileCopy.instruction");
+	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"))) {
+			throw new Exception("not found ".$keyprefix."EOFileCopy");
+	}
+	if(!$client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"))) {
+			throw new Exception("not found ".$keyprefix."EOFileCopy.instruction");
+	}
 
 	$client->deleteObject(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"));
 
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy")))
-		throw new Exception("found ".$keyprefix."EOFileCopy");
-	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction")))
-		throw new Exception("found ".$keyprefix."EOFileCopy.instruction");
-}
+	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy"))) {
+			throw new Exception("found ".$keyprefix."EOFileCopy");
+	}
+	if($client->objectExists(array("Bucket"=>$bucket,"Key"=>$keyprefix."EOFileCopy.instruction"))) {
+			throw new Exception("found ".$keyprefix."EOFileCopy.instruction");
+	}
+	}
 function rangeGetAndCheckMd5($client,$bucket,$key,$file,$expectedMd5){
 	$args = array("Bucket"=>$bucket,"Key"=>$key);
 	$meta = $client->getObjectMeta($args);
@@ -164,7 +170,8 @@ 
 		@unlink($value);
 	}
 	$md5 = base64_encode(md5_file($file));
-	if($md5 != $expectedMd5)
-		throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
+	if($md5 != $expectedMd5) {
+			throw new Exception("file md5 check error expected ".$expectedMd5." ,actual ".$md5, 1);
+	}
 	@unlink($file);	
 }

src/service/ksyun/bin/samples/Samples.php

Indentation +316 added lines, -316 removed lines

@@ -33,381 +33,381 @@
 //print_r(putAdp($client));
 //print_r(postObject($client));
 function listBuckets($client){
-	return $client->listBuckets();
+    return $client->listBuckets();
 }
 function deleteBucket($client){
-	return $client->deleteBucket(array("Bucket"=>"ksc-scm"));
+    return $client->deleteBucket(array("Bucket"=>"ksc-scm"));
 }
 function deleteBucketCORS($client){
-	return $client->deleteBucketCORS(array("Bucket"=>"ksc-scm"));
+    return $client->deleteBucketCORS(array("Bucket"=>"ksc-scm"));
 }
 function listObjects($client){
-	$args = array(
-		"Bucket"=>"lijunwei.test",
-		"Options"=>array(
-			//"prefix"=>"dir/",
-			"max-keys"=>4,
-			//"marker"=>"123.pdf",
-			"delimiter"=>"/"
-			)
-		);
-	return $client->listObjects($args);
+    $args = array(
+        "Bucket"=>"lijunwei.test",
+        "Options"=>array(
+            //"prefix"=>"dir/",
+            "max-keys"=>4,
+            //"marker"=>"123.pdf",
+            "delimiter"=>"/"
+            )
+        );
+    return $client->listObjects($args);
 }
 function getBucketAcl($client){
-	return $client->getBucketAcl(array("Bucket"=>"aaphp"));
+    return $client->getBucketAcl(array("Bucket"=>"aaphp"));
 }
 function getBucketCORS($client){
-	return $client->getBucketCORS(array("Bucket"=>"ksc-scm"));
+    return $client->getBucketCORS(array("Bucket"=>"ksc-scm"));
 }
 function getBucketLocation($client){
-	return $client->getBucketLocation(array("Bucket"=>"ksc-scm"));
+    return $client->getBucketLocation(array("Bucket"=>"ksc-scm"));
 }
 function getBucketLogging($client){
-	return $client->getBucketLogging(array("Bucket"=>"ksc-scm"));
+    return $client->getBucketLogging(array("Bucket"=>"ksc-scm"));
 }
 function bucketExists($client){
-	$args = array("Bucket"=>"ksc-scm");
-	return $client->bucketExists($args);
+    $args = array("Bucket"=>"ksc-scm");
+    return $client->bucketExists($args);
 }
 function createBucket($client){
-	$args = array(
-		"Bucket"=>"ksc-scm",
-		"ACL"=>"private"
-		);
-	return $client->createBucket($args);
+    $args = array(
+        "Bucket"=>"ksc-scm",
+        "ACL"=>"private"
+        );
+    return $client->createBucket($args);
 }
 function setBucketAcl($client){
-	$args = array(
-		"Bucket"=>"ksc-scm",
-		"ACL"=>"private"
-		);
-	return $client->setBucketAcl($args);
+    $args = array(
+        "Bucket"=>"ksc-scm",
+        "ACL"=>"private"
+        );
+    return $client->setBucketAcl($args);
 }
 function setBucketCORS($client){
-	$args = array(
-		"Bucket"=>"ksc-scm",
-		"CORS"=>array(
-			array(
-				"AllowedMethod"=>array("GET","PUT"),
-				"AllowedOrigin"=>array("http://www.kingsoft.com"),
-				"AllowedHeader"=>array("*"),
-				"ExposeHeader"=>array("*"),
-				"MaxAgeSeconds"=>10
-			),
-			array(
-				"AllowedMethod"=>array("GET","PUT"),
-				"AllowedOrigin"=>array("*"),
-				"AllowedHeader"=>array("*"),
-				"ExposeHeader"=>array("*"),
-				"MaxAgeSeconds"=>10
-			)
-		)
-	);
-	return $client->setBucketCORS($args);
+    $args = array(
+        "Bucket"=>"ksc-scm",
+        "CORS"=>array(
+            array(
+                "AllowedMethod"=>array("GET","PUT"),
+                "AllowedOrigin"=>array("http://www.kingsoft.com"),
+                "AllowedHeader"=>array("*"),
+                "ExposeHeader"=>array("*"),
+                "MaxAgeSeconds"=>10
+            ),
+            array(
+                "AllowedMethod"=>array("GET","PUT"),
+                "AllowedOrigin"=>array("*"),
+                "AllowedHeader"=>array("*"),
+                "ExposeHeader"=>array("*"),
+                "MaxAgeSeconds"=>10
+            )
+        )
+    );
+    return $client->setBucketCORS($args);
 }
 function setBucketLogging($client){
-	$args = array(
-		"Bucket"=>"ksc-scm",
-		"BucketLogging"=>array(
-			"Enable"=>TRUE,
-			"TargetBucket"=>"ksc-scm",
-			"TargetPrefix"=>"X-KSS"
-			)
-		);
-	return $client->setBucketLogging($args);
+    $args = array(
+        "Bucket"=>"ksc-scm",
+        "BucketLogging"=>array(
+            "Enable"=>TRUE,
+            "TargetBucket"=>"ksc-scm",
+            "TargetPrefix"=>"X-KSS"
+            )
+        );
+    return $client->setBucketLogging($args);
 }
 function deleteObject($client){
-	$args = array(
-		"Bucket"=>"ksc-scm",
-		"Key"=>"123.pdf"
-		);
-	return $client->deleteObject($args);
+    $args = array(
+        "Bucket"=>"ksc-scm",
+        "Key"=>"123.pdf"
+        );
+    return $client->deleteObject($args);
 }
 function deleteObjects($client){
-	$args = array(
-		"Bucket"=>"ksc-scm",
-		"DeleteKeys"=>array("copy/test.zip","copy/123.doc")
-		);
-	return $client->deleteObjects($args);
+    $args = array(
+        "Bucket"=>"ksc-scm",
+        "DeleteKeys"=>array("copy/test.zip","copy/123.doc")
+        );
+    return $client->deleteObjects($args);
 }
 function getObject($client){
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.exe",
-		"Range"=>array(
-			"start"=>NULL,
-			"end"=>4,
-			),
-		"WriteTo"=>"D://test.zip"
-		);
-	return $client->getObject($args);
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.exe",
+        "Range"=>array(
+            "start"=>NULL,
+            "end"=>4,
+            ),
+        "WriteTo"=>"D://test.zip"
+        );
+    return $client->getObject($args);
 }
 function getObjectAcl($client){
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.exe"
-		);
-	return $client->getObjectAcl($args);
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.exe"
+        );
+    return $client->getObjectAcl($args);
 }
 function objectExists($client){
-	$args = array(
-		"Bucket"=>"ksc-scm",
-		"Key"=>"123.pdf"
-		);
-	return $client->objectExists($args);
+    $args = array(
+        "Bucket"=>"ksc-scm",
+        "Key"=>"123.pdf"
+        );
+    return $client->objectExists($args);
 }
 function getObjectMeta($client){
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"test.zip"
-		);
-	return $client->getObjectMeta($args);
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"test.zip"
+        );
+    return $client->getObjectMeta($args);
 }
 function setObjectAcl($client){
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"test.zip",
-		"ACL"=>"private"
-		);
-	return $client->setObjectAcl($args);
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"test.zip",
+        "ACL"=>"private"
+        );
+    return $client->setObjectAcl($args);
 }
 function copyObject($client){
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"copy/test.zip",
-		"CopySource"=>array(
-			"Bucket"=>"aaphp",
-			"Key"=>"test.zip"
-			)
-		);
-	return $client->copyObject($args);
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"copy/test.zip",
+        "CopySource"=>array(
+            "Bucket"=>"aaphp",
+            "Key"=>"test.zip"
+            )
+        );
+    return $client->copyObject($args);
 }
 function putObjectByFile($client){
-	$file = "D://phpput";
-	if(Utils::chk_chinese($file)){
-		$file = iconv('utf-8','gbk',$file);
-	}
-	$content = $file;
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"stream_upload1.txt",
-		"ACL"=>"public-read",
-		"ObjectMeta"=>array(
-			"Content-Type"=>"image/jpg",//只传0-10字节,
-			),
-		"Content"=>array(
-			"content"=>$file,
-			"seek_position"=>0
-			),
-	);
-	return $client->putObjectByFile($args);
+    $file = "D://phpput";
+    if(Utils::chk_chinese($file)){
+        $file = iconv('utf-8','gbk',$file);
+    }
+    $content = $file;
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"stream_upload1.txt",
+        "ACL"=>"public-read",
+        "ObjectMeta"=>array(
+            "Content-Type"=>"image/jpg",//只传0-10字节,
+            ),
+        "Content"=>array(
+            "content"=>$file,
+            "seek_position"=>0
+            ),
+    );
+    return $client->putObjectByFile($args);
 }
 function multipartUpload($client){
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.zip",
-		"UserMeta"=>array(
-			"x-kss-meta-test"=>"example"
-			),
-		"ObjectMeta"=>array(
-			"Content-Type"=>"text/plain"
-			)
-		);
-	$uploadid = $client->initMultipartUpload($args);
-	print_r($uploadid);
-	$uploadid = $uploadid["UploadId"];
-	echo $uploadid."\r\n";
-	//开始上传
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.zip",
+        "UserMeta"=>array(
+            "x-kss-meta-test"=>"example"
+            ),
+        "ObjectMeta"=>array(
+            "Content-Type"=>"text/plain"
+            )
+        );
+    $uploadid = $client->initMultipartUpload($args);
+    print_r($uploadid);
+    $uploadid = $uploadid["UploadId"];
+    echo $uploadid."\r\n";
+    //开始上传
 
-	$file = "D://新建文件夹.rar";
-	if(Utils::chk_chinese($file)){
-		$file = iconv('utf-8','gbk',$file);
-	}
-	$total = Utils::getFileSize($file);
-	$partsize = 1024*1024*5;
-	$count = (int)(($total-1)/$partsize)+1;
-	echo $count."\r\n";
-	for($i = 0;$i < $count;$i++){
-		echo "upload".$i."\r\n";
-		$args=array(
-			"Bucket"=>"aaphp",
-			"Key"=>"multi.zip",
-			"Options"=>array(
-				"partNumber"=>$i+1,
-				"uploadId"=>$uploadid
-				),
-			"ObjectMeta"=>array(
-				"Content-Length"=>$partsize
-				),
-			"Content"=>array(
-				"content"=>$file,
-				"seek_position"=>$partsize*$i
-				)
-			);
-		$etag = $client->uploadPart($args);
-		print_r($etag);
-		$etag = $etag["ETag"];
-	}
-	$parts = $client->listParts(array("Bucket"=>"aaphp","Key"=>"multi.zip","Options"=>array("uploadId"=>$uploadid)));
-	print_r($parts);
-	//结束上传
-	$args=array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.zip",
-		"Options"=>array("uploadId"=>$uploadid),
-		"Parts"=>$parts["Parts"]
-		);
-	$result = $client->completeMultipartUpload($args);
-	print_r($result);
+    $file = "D://新建文件夹.rar";
+    if(Utils::chk_chinese($file)){
+        $file = iconv('utf-8','gbk',$file);
+    }
+    $total = Utils::getFileSize($file);
+    $partsize = 1024*1024*5;
+    $count = (int)(($total-1)/$partsize)+1;
+    echo $count."\r\n";
+    for($i = 0;$i < $count;$i++){
+        echo "upload".$i."\r\n";
+        $args=array(
+            "Bucket"=>"aaphp",
+            "Key"=>"multi.zip",
+            "Options"=>array(
+                "partNumber"=>$i+1,
+                "uploadId"=>$uploadid
+                ),
+            "ObjectMeta"=>array(
+                "Content-Length"=>$partsize
+                ),
+            "Content"=>array(
+                "content"=>$file,
+                "seek_position"=>$partsize*$i
+                )
+            );
+        $etag = $client->uploadPart($args);
+        print_r($etag);
+        $etag = $etag["ETag"];
+    }
+    $parts = $client->listParts(array("Bucket"=>"aaphp","Key"=>"multi.zip","Options"=>array("uploadId"=>$uploadid)));
+    print_r($parts);
+    //结束上传
+    $args=array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.zip",
+        "Options"=>array("uploadId"=>$uploadid),
+        "Parts"=>$parts["Parts"]
+        );
+    $result = $client->completeMultipartUpload($args);
+    print_r($result);
 }
 function abortMultipartUpload($client){
-	$args=array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.zip",
-		"Options"=>array("uploadId"=>"1234")
-		);
-	return $client->abortMultipartUpload($args);
+    $args=array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.zip",
+        "Options"=>array("uploadId"=>"1234")
+        );
+    return $client->abortMultipartUpload($args);
 }
 function generatePresignedUrl($client){
-	$args=array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.zip",
-		"Options"=>array(
-			"Expires"=>60*60*24*10,
-			"response-content-type"=>"application/xml"
-			)
-		);
-	return $client->generatePresignedUrl($args);
+    $args=array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.zip",
+        "Options"=>array(
+            "Expires"=>60*60*24*10,
+            "response-content-type"=>"application/xml"
+            )
+        );
+    return $client->generatePresignedUrl($args);
 }
 function putObjectWithAdpAndCallBack($client){
-	$content = "D://野生动物.3gp";
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"野生动物.3gp",
-		"ACL"=>"public-read",
-		"Content"=>array(
-			"content"=>$content
-			),
-		"Adp"=>array(
-			"NotifyURL"=>"http://10.4.2.38:19090/",
-			"Adps"=>array(
-				array(
-					"Command"=>"tag=avop&f=mp4&res=1280x720&vbr=1000k&abr=128k",
-					"Key"=>"野生动物-转码.3gp"
-				)
-			)
-		),
-		"CallBack"=>array(
-			"Url"=>"http://10.4.2.38:19090/",
-			"BodyMagicVariables"=>array("bucket"=>"bucket","key"=>"key"),
-			"BodyVariables"=>array("name"=>"lijunwei")
-		)
-	);
-	return $client->putObjectByFile($args);
+    $content = "D://野生动物.3gp";
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"野生动物.3gp",
+        "ACL"=>"public-read",
+        "Content"=>array(
+            "content"=>$content
+            ),
+        "Adp"=>array(
+            "NotifyURL"=>"http://10.4.2.38:19090/",
+            "Adps"=>array(
+                array(
+                    "Command"=>"tag=avop&f=mp4&res=1280x720&vbr=1000k&abr=128k",
+                    "Key"=>"野生动物-转码.3gp"
+                )
+            )
+        ),
+        "CallBack"=>array(
+            "Url"=>"http://10.4.2.38:19090/",
+            "BodyMagicVariables"=>array("bucket"=>"bucket","key"=>"key"),
+            "BodyVariables"=>array("name"=>"lijunwei")
+        )
+    );
+    return $client->putObjectByFile($args);
 }
 function  multipartUploadWithAdpAndCallBack($client){
-	$args = array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.zip",
-		"UserMeta"=>array(
-			"x-kss-meta-test"=>"example"
-			),
-		"ObjectMeta"=>array(
-			"Content-Type"=>"text/plain"
-			)
-		);
-	$uploadid = $client->initMultipartUpload($args);
-	print_r($uploadid);
-	$uploadid = $uploadid["UploadId"];
-	echo $uploadid."\r\n";
-	//开始上传
+    $args = array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.zip",
+        "UserMeta"=>array(
+            "x-kss-meta-test"=>"example"
+            ),
+        "ObjectMeta"=>array(
+            "Content-Type"=>"text/plain"
+            )
+        );
+    $uploadid = $client->initMultipartUpload($args);
+    print_r($uploadid);
+    $uploadid = $uploadid["UploadId"];
+    echo $uploadid."\r\n";
+    //开始上传
 
-	$file = "D://野生动物.3gp";
-	if(Utils::chk_chinese($file)){
-		$file = iconv('utf-8','gbk',$file);
-	}
-	$partsize = 1024*1024*5;
-	$total = Utils::getFileSize($file);
-	$count = (int)(($total-1)/$partsize)+1;
-	echo $count."\r\n";
-	for($i = 0;$i < $count;$i++){
-		echo "upload".$i."\r\n";
-		$args=array(
-			"Bucket"=>"aaphp",
-			"Key"=>"multi.zip",
-			"Options"=>array(
-				"partNumber"=>$i+1,
-				"uploadId"=>$uploadid
-				),
-			"ObjectMeta"=>array(
-				"Content-Length"=>$partsize
-				),
-			"Content"=>array(
-				"content"=>$file,
-				"seek_position"=>$partsize*$i
-				)
-			);
-		$etag = $client->uploadPart($args);
-		print_r($etag);
-		$etag = $etag["ETag"];
-	}
-	$parts = $client->listParts(array("Bucket"=>"aaphp","Key"=>"multi.zip","Options"=>array("uploadId"=>$uploadid)));
-	print_r($parts);
-	//结束上传
-	$args=array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.zip",
-		"Options"=>array("uploadId"=>$uploadid),
-		"Parts"=>$parts["Parts"],
-		"Adp"=>array(
-			"NotifyURL"=>"http://10.4.2.38:19090/",
-			"Adps"=>array(
-				array(
-					"Command"=>"tag=avop&f=mp4&res=1280x720&vbr=1000k&abr=128k",
-					"Key"=>"野生动物-转码.3gp"
-				)
-			)
-		),
-		"CallBack"=>array(
-			"Url"=>"http://10.4.2.38:19090/",
-			"BodyMagicVariables"=>array("bucket"=>"bucket","key"=>"key"),
-			"BodyVariables"=>array("name"=>"lijunwei")
-		)
-	);
-	$result = $client->completeMultipartUpload($args);
-	print_r($result);
-	$taskid = $result["TaskID"];
-	$task = $client->getAdp(array("TaskID"=>$taskid));
-	print_r($task);
+    $file = "D://野生动物.3gp";
+    if(Utils::chk_chinese($file)){
+        $file = iconv('utf-8','gbk',$file);
+    }
+    $partsize = 1024*1024*5;
+    $total = Utils::getFileSize($file);
+    $count = (int)(($total-1)/$partsize)+1;
+    echo $count."\r\n";
+    for($i = 0;$i < $count;$i++){
+        echo "upload".$i."\r\n";
+        $args=array(
+            "Bucket"=>"aaphp",
+            "Key"=>"multi.zip",
+            "Options"=>array(
+                "partNumber"=>$i+1,
+                "uploadId"=>$uploadid
+                ),
+            "ObjectMeta"=>array(
+                "Content-Length"=>$partsize
+                ),
+            "Content"=>array(
+                "content"=>$file,
+                "seek_position"=>$partsize*$i
+                )
+            );
+        $etag = $client->uploadPart($args);
+        print_r($etag);
+        $etag = $etag["ETag"];
+    }
+    $parts = $client->listParts(array("Bucket"=>"aaphp","Key"=>"multi.zip","Options"=>array("uploadId"=>$uploadid)));
+    print_r($parts);
+    //结束上传
+    $args=array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.zip",
+        "Options"=>array("uploadId"=>$uploadid),
+        "Parts"=>$parts["Parts"],
+        "Adp"=>array(
+            "NotifyURL"=>"http://10.4.2.38:19090/",
+            "Adps"=>array(
+                array(
+                    "Command"=>"tag=avop&f=mp4&res=1280x720&vbr=1000k&abr=128k",
+                    "Key"=>"野生动物-转码.3gp"
+                )
+            )
+        ),
+        "CallBack"=>array(
+            "Url"=>"http://10.4.2.38:19090/",
+            "BodyMagicVariables"=>array("bucket"=>"bucket","key"=>"key"),
+            "BodyVariables"=>array("name"=>"lijunwei")
+        )
+    );
+    $result = $client->completeMultipartUpload($args);
+    print_r($result);
+    $taskid = $result["TaskID"];
+    $task = $client->getAdp(array("TaskID"=>$taskid));
+    print_r($task);
 }
 function putAdp($client){
-	$args=array(
-		"Bucket"=>"aaphp",
-		"Key"=>"multi.zip",
-		"Adp"=>array(
-			"NotifyURL"=>"http://10.4.2.38:19090/",
-			"Adps"=>array(
-				array(
-					"Command"=>"tag=avop&f=mp4&res=1280x720&vbr=1000k&abr=128k",
-					"Key"=>"野生动物-转码.3gp"
-				)
-			)
-		)
-	);
-	$result = $client->putAdp($args);
-	print_r($result);
-	$taskid = $result["TaskID"];
-	$task = $client->getAdp(array("TaskID"=>$taskid));
-	print_r($task);
+    $args=array(
+        "Bucket"=>"aaphp",
+        "Key"=>"multi.zip",
+        "Adp"=>array(
+            "NotifyURL"=>"http://10.4.2.38:19090/",
+            "Adps"=>array(
+                array(
+                    "Command"=>"tag=avop&f=mp4&res=1280x720&vbr=1000k&abr=128k",
+                    "Key"=>"野生动物-转码.3gp"
+                )
+            )
+        )
+    );
+    $result = $client->putAdp($args);
+    print_r($result);
+    $taskid = $result["TaskID"];
+    $task = $client->getAdp(array("TaskID"=>$taskid));
+    print_r($task);
 }
 function postObject($client){
 
-	$postData = array(
-		"key"=>"~!@\\#$\%^&*()_+-=qw",
-		"acl"=>"public-read"
-		);
-	$unKnowData=array("122","334");
+    $postData = array(
+        "key"=>"~!@\\#$\%^&*()_+-=qw",
+        "acl"=>"public-read"
+        );
+    $unKnowData=array("122","334");
 
-	print_r($client->postObject("ksc-scm",$postData,$unKnowData));
+    print_r($client->postObject("ksc-scm",$postData,$unKnowData));
 }
 ?>

Spacing +55 added lines, -55 removed lines

@@ -2,7 +2,7 @@ 
 require_once "../Ks3Client.class.php";
 require_once "../core/Utils.class.php";
 
-$client = new Ks3Client("","","kss.ksyun.com");//!!第三个参数endpoint需要对应bucket所在region!! 详见http://ks3.ksyun.com/doc/api/index.html  Region（区域）一节
+$client = new Ks3Client("", "", "kss.ksyun.com"); //!!第三个参数endpoint需要对应bucket所在region!! 详见http://ks3.ksyun.com/doc/api/index.html  Region（区域）一节
 //print_r(listBuckets($client));
 //print_r(deleteBucket($client));
 //print_r(deleteBucketCORS($client));
@@ -32,16 +32,16 @@ 
 //print_r(multipartUploadWithAdpAndCallBack($client));
 //print_r(putAdp($client));
 //print_r(postObject($client));
-function listBuckets($client){
+function listBuckets($client) {
 	return $client->listBuckets();
 }
-function deleteBucket($client){
+function deleteBucket($client) {
 	return $client->deleteBucket(array("Bucket"=>"ksc-scm"));
 }
-function deleteBucketCORS($client){
+function deleteBucketCORS($client) {
 	return $client->deleteBucketCORS(array("Bucket"=>"ksc-scm"));
 }
-function listObjects($client){
+function listObjects($client) {
 	$args = array(
 		"Bucket"=>"lijunwei.test",
 		"Options"=>array(
@@ -53,49 +53,49 @@ 
 		);
 	return $client->listObjects($args);
 }
-function getBucketAcl($client){
+function getBucketAcl($client) {
 	return $client->getBucketAcl(array("Bucket"=>"aaphp"));
 }
-function getBucketCORS($client){
+function getBucketCORS($client) {
 	return $client->getBucketCORS(array("Bucket"=>"ksc-scm"));
 }
-function getBucketLocation($client){
+function getBucketLocation($client) {
 	return $client->getBucketLocation(array("Bucket"=>"ksc-scm"));
 }
-function getBucketLogging($client){
+function getBucketLogging($client) {
 	return $client->getBucketLogging(array("Bucket"=>"ksc-scm"));
 }
-function bucketExists($client){
+function bucketExists($client) {
 	$args = array("Bucket"=>"ksc-scm");
 	return $client->bucketExists($args);
 }
-function createBucket($client){
+function createBucket($client) {
 	$args = array(
 		"Bucket"=>"ksc-scm",
 		"ACL"=>"private"
 		);
 	return $client->createBucket($args);
 }
-function setBucketAcl($client){
+function setBucketAcl($client) {
 	$args = array(
 		"Bucket"=>"ksc-scm",
 		"ACL"=>"private"
 		);
 	return $client->setBucketAcl($args);
 }
-function setBucketCORS($client){
+function setBucketCORS($client) {
 	$args = array(
 		"Bucket"=>"ksc-scm",
 		"CORS"=>array(
 			array(
-				"AllowedMethod"=>array("GET","PUT"),
+				"AllowedMethod"=>array("GET", "PUT"),
 				"AllowedOrigin"=>array("http://www.kingsoft.com"),
 				"AllowedHeader"=>array("*"),
 				"ExposeHeader"=>array("*"),
 				"MaxAgeSeconds"=>10
 			),
 			array(
-				"AllowedMethod"=>array("GET","PUT"),
+				"AllowedMethod"=>array("GET", "PUT"),
 				"AllowedOrigin"=>array("*"),
 				"AllowedHeader"=>array("*"),
 				"ExposeHeader"=>array("*"),
@@ -105,7 +105,7 @@ 
 	);
 	return $client->setBucketCORS($args);
 }
-function setBucketLogging($client){
+function setBucketLogging($client) {
 	$args = array(
 		"Bucket"=>"ksc-scm",
 		"BucketLogging"=>array(
@@ -116,21 +116,21 @@ 
 		);
 	return $client->setBucketLogging($args);
 }
-function deleteObject($client){
+function deleteObject($client) {
 	$args = array(
 		"Bucket"=>"ksc-scm",
 		"Key"=>"123.pdf"
 		);
 	return $client->deleteObject($args);
 }
-function deleteObjects($client){
+function deleteObjects($client) {
 	$args = array(
 		"Bucket"=>"ksc-scm",
-		"DeleteKeys"=>array("copy/test.zip","copy/123.doc")
+		"DeleteKeys"=>array("copy/test.zip", "copy/123.doc")
 		);
 	return $client->deleteObjects($args);
 }
-function getObject($client){
+function getObject($client) {
 	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.exe",
@@ -142,28 +142,28 @@ 
 		);
 	return $client->getObject($args);
 }
-function getObjectAcl($client){
+function getObjectAcl($client) {
 	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.exe"
 		);
 	return $client->getObjectAcl($args);
 }
-function objectExists($client){
+function objectExists($client) {
 	$args = array(
 		"Bucket"=>"ksc-scm",
 		"Key"=>"123.pdf"
 		);
 	return $client->objectExists($args);
 }
-function getObjectMeta($client){
+function getObjectMeta($client) {
 	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"test.zip"
 		);
 	return $client->getObjectMeta($args);
 }
-function setObjectAcl($client){
+function setObjectAcl($client) {
 	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"test.zip",
@@ -171,7 +171,7 @@ 
 		);
 	return $client->setObjectAcl($args);
 }
-function copyObject($client){
+function copyObject($client) {
 	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"copy/test.zip",
@@ -182,10 +182,10 @@ 
 		);
 	return $client->copyObject($args);
 }
-function putObjectByFile($client){
+function putObjectByFile($client) {
 	$file = "D://phpput";
-	if(Utils::chk_chinese($file)){
-		$file = iconv('utf-8','gbk',$file);
+	if (Utils::chk_chinese($file)) {
+		$file = iconv('utf-8', 'gbk', $file);
 	}
 	$content = $file;
 	$args = array(
@@ -193,7 +193,7 @@ 
 		"Key"=>"stream_upload1.txt",
 		"ACL"=>"public-read",
 		"ObjectMeta"=>array(
-			"Content-Type"=>"image/jpg",//只传0-10字节,
+			"Content-Type"=>"image/jpg", //只传0-10字节,
 			),
 		"Content"=>array(
 			"content"=>$file,
@@ -202,7 +202,7 @@ 
 	);
 	return $client->putObjectByFile($args);
 }
-function multipartUpload($client){
+function multipartUpload($client) {
 	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.zip",
@@ -220,16 +220,16 @@ 
 	//开始上传
 
 	$file = "D://新建文件夹.rar";
-	if(Utils::chk_chinese($file)){
-		$file = iconv('utf-8','gbk',$file);
+	if (Utils::chk_chinese($file)) {
+		$file = iconv('utf-8', 'gbk', $file);
 	}
 	$total = Utils::getFileSize($file);
 	$partsize = 1024*1024*5;
 	$count = (int)(($total-1)/$partsize)+1;
 	echo $count."\r\n";
-	for($i = 0;$i < $count;$i++){
+	for ($i = 0; $i < $count; $i++) {
 		echo "upload".$i."\r\n";
-		$args=array(
+		$args = array(
 			"Bucket"=>"aaphp",
 			"Key"=>"multi.zip",
 			"Options"=>array(
@@ -248,10 +248,10 @@ 
 		print_r($etag);
 		$etag = $etag["ETag"];
 	}
-	$parts = $client->listParts(array("Bucket"=>"aaphp","Key"=>"multi.zip","Options"=>array("uploadId"=>$uploadid)));
+	$parts = $client->listParts(array("Bucket"=>"aaphp", "Key"=>"multi.zip", "Options"=>array("uploadId"=>$uploadid)));
 	print_r($parts);
 	//结束上传
-	$args=array(
+	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.zip",
 		"Options"=>array("uploadId"=>$uploadid),
@@ -260,16 +260,16 @@ 
 	$result = $client->completeMultipartUpload($args);
 	print_r($result);
 }
-function abortMultipartUpload($client){
-	$args=array(
+function abortMultipartUpload($client) {
+	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.zip",
 		"Options"=>array("uploadId"=>"1234")
 		);
 	return $client->abortMultipartUpload($args);
 }
-function generatePresignedUrl($client){
-	$args=array(
+function generatePresignedUrl($client) {
+	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.zip",
 		"Options"=>array(
@@ -279,7 +279,7 @@ 
 		);
 	return $client->generatePresignedUrl($args);
 }
-function putObjectWithAdpAndCallBack($client){
+function putObjectWithAdpAndCallBack($client) {
 	$content = "D://野生动物.3gp";
 	$args = array(
 		"Bucket"=>"aaphp",
@@ -299,13 +299,13 @@ 
 		),
 		"CallBack"=>array(
 			"Url"=>"http://10.4.2.38:19090/",
-			"BodyMagicVariables"=>array("bucket"=>"bucket","key"=>"key"),
+			"BodyMagicVariables"=>array("bucket"=>"bucket", "key"=>"key"),
 			"BodyVariables"=>array("name"=>"lijunwei")
 		)
 	);
 	return $client->putObjectByFile($args);
 }
-function  multipartUploadWithAdpAndCallBack($client){
+function  multipartUploadWithAdpAndCallBack($client) {
 	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.zip",
@@ -323,16 +323,16 @@ 
 	//开始上传
 
 	$file = "D://野生动物.3gp";
-	if(Utils::chk_chinese($file)){
-		$file = iconv('utf-8','gbk',$file);
+	if (Utils::chk_chinese($file)) {
+		$file = iconv('utf-8', 'gbk', $file);
 	}
 	$partsize = 1024*1024*5;
 	$total = Utils::getFileSize($file);
 	$count = (int)(($total-1)/$partsize)+1;
 	echo $count."\r\n";
-	for($i = 0;$i < $count;$i++){
+	for ($i = 0; $i < $count; $i++) {
 		echo "upload".$i."\r\n";
-		$args=array(
+		$args = array(
 			"Bucket"=>"aaphp",
 			"Key"=>"multi.zip",
 			"Options"=>array(
@@ -351,10 +351,10 @@ 
 		print_r($etag);
 		$etag = $etag["ETag"];
 	}
-	$parts = $client->listParts(array("Bucket"=>"aaphp","Key"=>"multi.zip","Options"=>array("uploadId"=>$uploadid)));
+	$parts = $client->listParts(array("Bucket"=>"aaphp", "Key"=>"multi.zip", "Options"=>array("uploadId"=>$uploadid)));
 	print_r($parts);
 	//结束上传
-	$args=array(
+	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.zip",
 		"Options"=>array("uploadId"=>$uploadid),
@@ -370,7 +370,7 @@ 
 		),
 		"CallBack"=>array(
 			"Url"=>"http://10.4.2.38:19090/",
-			"BodyMagicVariables"=>array("bucket"=>"bucket","key"=>"key"),
+			"BodyMagicVariables"=>array("bucket"=>"bucket", "key"=>"key"),
 			"BodyVariables"=>array("name"=>"lijunwei")
 		)
 	);
@@ -380,8 +380,8 @@ 
 	$task = $client->getAdp(array("TaskID"=>$taskid));
 	print_r($task);
 }
-function putAdp($client){
-	$args=array(
+function putAdp($client) {
+	$args = array(
 		"Bucket"=>"aaphp",
 		"Key"=>"multi.zip",
 		"Adp"=>array(
@@ -400,14 +400,14 @@ 
 	$task = $client->getAdp(array("TaskID"=>$taskid));
 	print_r($task);
 }
-function postObject($client){
+function postObject($client) {
 
 	$postData = array(
 		"key"=>"~!@\\#$\%^&*()_+-=qw",
 		"acl"=>"public-read"
 		);
-	$unKnowData=array("122","334");
+	$unKnowData = array("122", "334");
 
-	print_r($client->postObject("ksc-scm",$postData,$unKnowData));
+	print_r($client->postObject("ksc-scm", $postData, $unKnowData));
 }
 ?>

src/service/ksyun/bin/encryption/EncryptionUtil.php

Indentation +265 added lines, -265 removed lines

@@ -1,279 +1,279 @@
 <?php
 class EncryptionUtil{
-	public static $INSTRUCTION_SUFFIX = ".instruction";
-	public static function genereateOnceUsedKey($length=32){
-		$randpwd = "";  
-		for ($i = 0; $i < $length; $i++)  
-		{  
-			$randpwd .= chr(mt_rand(33, 126));  
-		}  
-		return $randpwd;   
-	}
-	public static function encode_AES_ECB($data,$secret_key){
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_ECB,'');
+    public static $INSTRUCTION_SUFFIX = ".instruction";
+    public static function genereateOnceUsedKey($length=32){
+        $randpwd = "";  
+        for ($i = 0; $i < $length; $i++)  
+        {  
+            $randpwd .= chr(mt_rand(33, 126));  
+        }  
+        return $randpwd;   
+    }
+    public static function encode_AES_ECB($data,$secret_key){
+        $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_ECB,'');
 
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_ECB);
-		$pad = $blocksize - (strlen($data) % $blocksize);
-		$data = $data . str_repeat(chr($pad), $pad);
+        $blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_ECB);
+        $pad = $blocksize - (strlen($data) % $blocksize);
+        $data = $data . str_repeat(chr($pad), $pad);
 
-		$iv = mcrypt_create_iv (mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
-		mcrypt_generic_init($td,$secret_key,$iv);
-		$encrypted = mcrypt_generic($td,$data);
-		mcrypt_generic_deinit($td);
-		return $encrypted;
-	}
-	public static function decode_AES_ECB($data,$secret_key){
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_ECB,'');
-		$iv = mcrypt_create_iv (mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
-		mcrypt_generic_init($td,$secret_key,$iv);
-		$data = mdecrypt_generic($td,$data);
-		mcrypt_generic_deinit($td);
-		mcrypt_module_close($td);
+        $iv = mcrypt_create_iv (mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
+        mcrypt_generic_init($td,$secret_key,$iv);
+        $encrypted = mcrypt_generic($td,$data);
+        mcrypt_generic_deinit($td);
+        return $encrypted;
+    }
+    public static function decode_AES_ECB($data,$secret_key){
+        $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_ECB,'');
+        $iv = mcrypt_create_iv (mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
+        mcrypt_generic_init($td,$secret_key,$iv);
+        $data = mdecrypt_generic($td,$data);
+        mcrypt_generic_deinit($td);
+        mcrypt_module_close($td);
 
-		$dec_s = strlen($data);
-		$padding = ord($data[$dec_s-1]);
-		$data = substr($data, 0, -$padding);
+        $dec_s = strlen($data);
+        $padding = ord($data[$dec_s-1]);
+        $data = substr($data, 0, -$padding);
 
-		return trim($data);
-	}
-	public static function getKeyEncryptionAlgm($encryptionMaterials){
-		if(is_array($encryptionMaterials)){
-			return "RSA";
-		}else{
-			return "AES";
-		}
-	}
-	public static function getAdjustedRange($range,$blocksize){
-		$a = $range["start"];
-		$b = $range["end"];
-		$a = $a - ($a%$blocksize)-$blocksize;
-		if($a < 0)
-			$a = 0;
+        return trim($data);
+    }
+    public static function getKeyEncryptionAlgm($encryptionMaterials){
+        if(is_array($encryptionMaterials)){
+            return "RSA";
+        }else{
+            return "AES";
+        }
+    }
+    public static function getAdjustedRange($range,$blocksize){
+        $a = $range["start"];
+        $b = $range["end"];
+        $a = $a - ($a%$blocksize)-$blocksize;
+        if($a < 0)
+            $a = 0;
 
-		$b = $b+$blocksize-$b%$blocksize+$blocksize;
+        $b = $b+$blocksize-$b%$blocksize+$blocksize;
 
-		return array("start"=>$a,"end"=>$b);
-	}
-	public static function encodeCek($encryptionMaterials,$cek){
-		$encrypKeyAlg = EncryptionUtil::getKeyEncryptionAlgm($encryptionMaterials);
-		if($encrypKeyAlg === "AES"){
-			$secretKey = $encryptionMaterials;
-			$encryptedSek = EncryptionUtil::encode_AES_ECB($cek,$secretKey);
-			if(empty($encryptedSek))
-				throw new Ks3ClientException("can not encode cek useing AES");
-		}else if($encrypKeyAlg === "RSA"){
-			$encryptedSek = "";
-			openssl_public_encrypt($cek,$encryptedSek, $encryptionMaterials[0]);
-			if(empty($encryptedSek))
-				throw new Ks3ClientException("can not encode cek useing RSA");
-		}
-		return $encryptedSek;
-	}
-	public static function decodeCek($encryptionMaterials,$cekEncrypted){
-		$encrypKeyAlg = EncryptionUtil::getKeyEncryptionAlgm($encryptionMaterials);
-		if($encrypKeyAlg === "AES"){
-			$secretKey = $encryptionMaterials;
-			$cek = EncryptionUtil::decode_AES_ECB($cekEncrypted,$secretKey);
-			if(empty($cek))
-				throw new Ks3ClientException("can not decode cek useing AES,secret key maybe not correct");
-		}else if($encrypKeyAlg === "RSA"){
-			$cek = "";
-			openssl_private_decrypt($cekEncrypted,$cek, $encryptionMaterials[1]);
-			if(empty($cek))
-				throw new Ks3ClientException("can not decode cek useing RSA,public/private key pair maybe not correct");
-		}
-		return $cek;
-	}
-	public static function getPKCS5EncrypedLength($length,$blocksize){
-		$pad = $blocksize - $length%$blocksize;
-		return $length+$pad;
-	}
-	//pkcs5填充
-	public static function PKCS5Padding($data,$blocksize){
-		$pad = $blocksize - strlen($data)%$blocksize;
-		for($i = 0;$i < $pad;$i++){
-			$data.= chr($pad);
-		}
-		return $data;
-	}
-	public static function updateContentMD5Header($req){
-		if(!is_array($req))
-			return $req;
-		if(isset($req["ObjectMeta"])){
-			$meta = $req["ObjectMeta"];
-		}else{
-			return $req;
-		}
-		if(is_array($meta) && isset($meta["Content-MD5"])){
-			$md5 = $meta["Content-MD5"];
-		}else{
-			return $req;
-		}
-		if(empty($md5)){
-			return $req;
-		}else{
-			$req["ObjectMeta"]["Content-MD5"] = NULL;
-			$req["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-md5"] = $md5;
-		}
-		return $req;
-	}
-	public static function metaTextLength($req){
-		if(!is_array($req))
-			return -1;
-		if(isset($req["ObjectMeta"])){
-			$meta = $req["ObjectMeta"];
-		}else{
-			return -1;
-		}
-		if(is_array($meta) && isset($meta["Content-Length"])){
-			$length = $meta["Content-Length"];
-			return $length;
-		}else
-			return -1;
-	}
-	public static function plainTextLength($args){
-		if(isset($args["Content"])){
-			if(is_array($args["Content"])){
-				$content = $args["Content"]["content"];
-				$seek_position = 0;
-				$resourceLength = 0;
-				$length = -1;
-				$isFile = FALSE;
+        return array("start"=>$a,"end"=>$b);
+    }
+    public static function encodeCek($encryptionMaterials,$cek){
+        $encrypKeyAlg = EncryptionUtil::getKeyEncryptionAlgm($encryptionMaterials);
+        if($encrypKeyAlg === "AES"){
+            $secretKey = $encryptionMaterials;
+            $encryptedSek = EncryptionUtil::encode_AES_ECB($cek,$secretKey);
+            if(empty($encryptedSek))
+                throw new Ks3ClientException("can not encode cek useing AES");
+        }else if($encrypKeyAlg === "RSA"){
+            $encryptedSek = "";
+            openssl_public_encrypt($cek,$encryptedSek, $encryptionMaterials[0]);
+            if(empty($encryptedSek))
+                throw new Ks3ClientException("can not encode cek useing RSA");
+        }
+        return $encryptedSek;
+    }
+    public static function decodeCek($encryptionMaterials,$cekEncrypted){
+        $encrypKeyAlg = EncryptionUtil::getKeyEncryptionAlgm($encryptionMaterials);
+        if($encrypKeyAlg === "AES"){
+            $secretKey = $encryptionMaterials;
+            $cek = EncryptionUtil::decode_AES_ECB($cekEncrypted,$secretKey);
+            if(empty($cek))
+                throw new Ks3ClientException("can not decode cek useing AES,secret key maybe not correct");
+        }else if($encrypKeyAlg === "RSA"){
+            $cek = "";
+            openssl_private_decrypt($cekEncrypted,$cek, $encryptionMaterials[1]);
+            if(empty($cek))
+                throw new Ks3ClientException("can not decode cek useing RSA,public/private key pair maybe not correct");
+        }
+        return $cek;
+    }
+    public static function getPKCS5EncrypedLength($length,$blocksize){
+        $pad = $blocksize - $length%$blocksize;
+        return $length+$pad;
+    }
+    //pkcs5填充
+    public static function PKCS5Padding($data,$blocksize){
+        $pad = $blocksize - strlen($data)%$blocksize;
+        for($i = 0;$i < $pad;$i++){
+            $data.= chr($pad);
+        }
+        return $data;
+    }
+    public static function updateContentMD5Header($req){
+        if(!is_array($req))
+            return $req;
+        if(isset($req["ObjectMeta"])){
+            $meta = $req["ObjectMeta"];
+        }else{
+            return $req;
+        }
+        if(is_array($meta) && isset($meta["Content-MD5"])){
+            $md5 = $meta["Content-MD5"];
+        }else{
+            return $req;
+        }
+        if(empty($md5)){
+            return $req;
+        }else{
+            $req["ObjectMeta"]["Content-MD5"] = NULL;
+            $req["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-md5"] = $md5;
+        }
+        return $req;
+    }
+    public static function metaTextLength($req){
+        if(!is_array($req))
+            return -1;
+        if(isset($req["ObjectMeta"])){
+            $meta = $req["ObjectMeta"];
+        }else{
+            return -1;
+        }
+        if(is_array($meta) && isset($meta["Content-Length"])){
+            $length = $meta["Content-Length"];
+            return $length;
+        }else
+            return -1;
+    }
+    public static function plainTextLength($args){
+        if(isset($args["Content"])){
+            if(is_array($args["Content"])){
+                $content = $args["Content"]["content"];
+                $seek_position = 0;
+                $resourceLength = 0;
+                $length = -1;
+                $isFile = FALSE;
 
-				if (!is_resource($content)){
-					$isFile = TRUE;
-					//如果之前用户已经转化为GBK则不转换
-					if(Utils::chk_chinese($content)&&!Utils::check_char($content)){
-						$content = iconv('utf-8','gbk',$content);
-					}
-					if(!file_exists($content))
-						throw new Ks3ClientException("the specified file does not exist ");
-					$length = Utils::getFileSize($content);
-					$content = fopen($content,"r");
-				}else{
-					$stats = fstat($content);
-					if ($stats && $stats["size"] >= 0){
-						$length = $stats["size"];	
-					}
-				}
-				$resourceLength = $length;
-				//优先取用户设置seek_position，没有的话取ftell
-				if(isset($args["Content"]["seek_position"])&&$args["Content"]["seek_position"]>0){
-					$seek_position = $args["Content"]["seek_position"];
-				}else if(!$isFile){
-					$seek_position = ftell($content);
-					if($seek_position<0)
-						$seek_position = 0;
-					fseek($content,0);
-				}
+                if (!is_resource($content)){
+                    $isFile = TRUE;
+                    //如果之前用户已经转化为GBK则不转换
+                    if(Utils::chk_chinese($content)&&!Utils::check_char($content)){
+                        $content = iconv('utf-8','gbk',$content);
+                    }
+                    if(!file_exists($content))
+                        throw new Ks3ClientException("the specified file does not exist ");
+                    $length = Utils::getFileSize($content);
+                    $content = fopen($content,"r");
+                }else{
+                    $stats = fstat($content);
+                    if ($stats && $stats["size"] >= 0){
+                        $length = $stats["size"];	
+                    }
+                }
+                $resourceLength = $length;
+                //优先取用户设置seek_position，没有的话取ftell
+                if(isset($args["Content"]["seek_position"])&&$args["Content"]["seek_position"]>0){
+                    $seek_position = $args["Content"]["seek_position"];
+                }else if(!$isFile){
+                    $seek_position = ftell($content);
+                    if($seek_position<0)
+                        $seek_position = 0;
+                    fseek($content,0);
+                }
 
-				$lengthInMeta = -1;
-				if(isset($args["ObjectMeta"]["Content-Length"])){
-					$lengthInMeta = $args["ObjectMeta"]["Content-Length"];
-				}
-				if($lengthInMeta > 0){
-					$length = $lengthInMeta;
-				}else if($resourceLength > 0){
-					//根据seek_position计算实际长度
-					$length = $resourceLength - $seek_position;
-				}
-				if($length <= 0)
-					throw new Ks3ClientException("calculate content length failed,unexpected contetn length ".$length);
-				return $length;
-			}else{
-				$content = $args["Content"];
-				$lengthInMeta = EncryptionUtil::metaTextLength($args);
-				$length = strlen($content);
-				if($length<$lengthInMeta||$lengthInMeta <= 0)
-					return $length;
-				else
-					return $lengthInMeta;
-			}
-		}
-		return -1;
-	}
-	public static function initMultipartUploadContext($initResult,$iv,$cek,$encryptedCek,$matdesc="{}"){
-		$cacheDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR;
-		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		if(!is_dir($cacheDir))
-			mkdir($cacheDir);
-		if(!is_dir($encryptionDir))
-			mkdir($encryptionDir);
-		if(is_array($matdesc)){
-			$matdesc = json_encode($matdesc);
-		}
-		$initResult["firstIv"] = base64_encode($iv);
-		$initResult["nextIv"] = base64_encode($iv);
-		$initResult["cek"] = base64_encode($cek);
-		$initResult["encryptedCek"] = base64_encode($encryptedCek);
-		$initResult["lastPart"] = FALSE;
-		$initResult["matdesc"] = $matdesc;
-		$json = json_encode($initResult);
-		$file = EncryptionUtil::openfile($encryptionDir.$initResult["UploadId"], "w");
-		fwrite($file, $json);
-		fclose($file);
-	}
-	public static function updateMultipartUploadContext($UploadId,$iv,$lastPart = FALSE){
-		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		$content = EncryptionUtil::getMultipartUploadContext($UploadId);
-		$content["nextIv"] = base64_encode($iv);
-		$content["lastPart"] = $lastPart;
-		$json = json_encode($content);
-		$file = EncryptionUtil::openfile($encryptionDir.$UploadId, "w");
-		fwrite($file, $json);
-		fclose($file);
-	}
-	public static function getMultipartUploadContext($UploadId){
-		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		if(!EncryptionUtil::multipartUploadContextExists($UploadId))
-			throw new Ks3ClientException("can not found multipart upload context in cache dir");
-		$jsonString = file_get_contents($encryptionDir.$UploadId);
-		$arry = json_decode($jsonString,TRUE);
-		return $arry;
-	}
-	public static function deleteMultipartUploadContext($UploadId){
-		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		@unlink($encryptionDir.$UploadId);
-	}
-	public static function multipartUploadContextExists($UploadId){
-		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		return file_exists($encryptionDir.$UploadId);
-	}
-	public static function openfile($path,$mode){
-		$file = fopen($path, $mode);
-		if($file)
-			return $file;
-		else
-			throw new Ks3ClientException("open file ".$path." error");
-	}
-	//matdesc为字符串或array数据类型。
-	public static function createInstructionFile($bucket,$key,$cek,$iv,$matdesc="{}"){
-		if(is_array($matdesc)){
-			$matdesc = json_encode($matdesc);
-		}
-		$key = $key.EncryptionUtil::$INSTRUCTION_SUFFIX;
+                $lengthInMeta = -1;
+                if(isset($args["ObjectMeta"]["Content-Length"])){
+                    $lengthInMeta = $args["ObjectMeta"]["Content-Length"];
+                }
+                if($lengthInMeta > 0){
+                    $length = $lengthInMeta;
+                }else if($resourceLength > 0){
+                    //根据seek_position计算实际长度
+                    $length = $resourceLength - $seek_position;
+                }
+                if($length <= 0)
+                    throw new Ks3ClientException("calculate content length failed,unexpected contetn length ".$length);
+                return $length;
+            }else{
+                $content = $args["Content"];
+                $lengthInMeta = EncryptionUtil::metaTextLength($args);
+                $length = strlen($content);
+                if($length<$lengthInMeta||$lengthInMeta <= 0)
+                    return $length;
+                else
+                    return $lengthInMeta;
+            }
+        }
+        return -1;
+    }
+    public static function initMultipartUploadContext($initResult,$iv,$cek,$encryptedCek,$matdesc="{}"){
+        $cacheDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR;
+        $encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
+        if(!is_dir($cacheDir))
+            mkdir($cacheDir);
+        if(!is_dir($encryptionDir))
+            mkdir($encryptionDir);
+        if(is_array($matdesc)){
+            $matdesc = json_encode($matdesc);
+        }
+        $initResult["firstIv"] = base64_encode($iv);
+        $initResult["nextIv"] = base64_encode($iv);
+        $initResult["cek"] = base64_encode($cek);
+        $initResult["encryptedCek"] = base64_encode($encryptedCek);
+        $initResult["lastPart"] = FALSE;
+        $initResult["matdesc"] = $matdesc;
+        $json = json_encode($initResult);
+        $file = EncryptionUtil::openfile($encryptionDir.$initResult["UploadId"], "w");
+        fwrite($file, $json);
+        fclose($file);
+    }
+    public static function updateMultipartUploadContext($UploadId,$iv,$lastPart = FALSE){
+        $encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
+        $content = EncryptionUtil::getMultipartUploadContext($UploadId);
+        $content["nextIv"] = base64_encode($iv);
+        $content["lastPart"] = $lastPart;
+        $json = json_encode($content);
+        $file = EncryptionUtil::openfile($encryptionDir.$UploadId, "w");
+        fwrite($file, $json);
+        fclose($file);
+    }
+    public static function getMultipartUploadContext($UploadId){
+        $encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
+        if(!EncryptionUtil::multipartUploadContextExists($UploadId))
+            throw new Ks3ClientException("can not found multipart upload context in cache dir");
+        $jsonString = file_get_contents($encryptionDir.$UploadId);
+        $arry = json_decode($jsonString,TRUE);
+        return $arry;
+    }
+    public static function deleteMultipartUploadContext($UploadId){
+        $encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
+        @unlink($encryptionDir.$UploadId);
+    }
+    public static function multipartUploadContextExists($UploadId){
+        $encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
+        return file_exists($encryptionDir.$UploadId);
+    }
+    public static function openfile($path,$mode){
+        $file = fopen($path, $mode);
+        if($file)
+            return $file;
+        else
+            throw new Ks3ClientException("open file ".$path." error");
+    }
+    //matdesc为字符串或array数据类型。
+    public static function createInstructionFile($bucket,$key,$cek,$iv,$matdesc="{}"){
+        if(is_array($matdesc)){
+            $matdesc = json_encode($matdesc);
+        }
+        $key = $key.EncryptionUtil::$INSTRUCTION_SUFFIX;
 
-		$instruction = json_encode(array(
-			"x-kss-key"=>$cek,
-			"x-kss-iv"=>$iv,
-			"x-kss-matdesc"=>$matdesc
-			));
+        $instruction = json_encode(array(
+            "x-kss-key"=>$cek,
+            "x-kss-iv"=>$iv,
+            "x-kss-matdesc"=>$matdesc
+            ));
 
-		$req = array(
-			"Bucket"=>$bucket,
-			"Key"=>$key,
-			"Content"=>$instruction,
-			"UserMeta"=>array(
-				"x-kss-meta-x-kss-crypto-instr-file"=>base64_encode($key)
-				)
-			);
-		return $req;
-	}
-	public static function isInstructionFile($s3Object){
-		$meta = $s3Object["Meta"];
-		if(isset($meta["UserMeta"]["x-kss-meta-x-kss-crypto-instr-file"]))
-			return TRUE;
-		return FALSE;
-	}
+        $req = array(
+            "Bucket"=>$bucket,
+            "Key"=>$key,
+            "Content"=>$instruction,
+            "UserMeta"=>array(
+                "x-kss-meta-x-kss-crypto-instr-file"=>base64_encode($key)
+                )
+            );
+        return $req;
+    }
+    public static function isInstructionFile($s3Object){
+        $meta = $s3Object["Meta"];
+        if(isset($meta["UserMeta"]["x-kss-meta-x-kss-crypto-instr-file"]))
+            return TRUE;
+        return FALSE;
+    }
 }
 ?>
\ No newline at end of file

Spacing +92 added lines, -92 removed lines

@@ -1,7 +1,7 @@ 
 <?php
-class EncryptionUtil{
+class EncryptionUtil {
 	public static $INSTRUCTION_SUFFIX = ".instruction";
-	public static function genereateOnceUsedKey($length=32){
+	public static function genereateOnceUsedKey($length = 32) {
 		$randpwd = "";  
 		for ($i = 0; $i < $length; $i++)  
 		{  
@@ -9,24 +9,24 @@ 
 		}  
 		return $randpwd;   
 	}
-	public static function encode_AES_ECB($data,$secret_key){
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_ECB,'');
+	public static function encode_AES_ECB($data, $secret_key) {
+		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_ECB, '');
 
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_ECB);
-		$pad = $blocksize - (strlen($data) % $blocksize);
-		$data = $data . str_repeat(chr($pad), $pad);
+		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_ECB);
+		$pad = $blocksize-(strlen($data)%$blocksize);
+		$data = $data.str_repeat(chr($pad), $pad);
 
-		$iv = mcrypt_create_iv (mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
-		mcrypt_generic_init($td,$secret_key,$iv);
-		$encrypted = mcrypt_generic($td,$data);
+		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
+		mcrypt_generic_init($td, $secret_key, $iv);
+		$encrypted = mcrypt_generic($td, $data);
 		mcrypt_generic_deinit($td);
 		return $encrypted;
 	}
-	public static function decode_AES_ECB($data,$secret_key){
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_ECB,'');
-		$iv = mcrypt_create_iv (mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
-		mcrypt_generic_init($td,$secret_key,$iv);
-		$data = mdecrypt_generic($td,$data);
+	public static function decode_AES_ECB($data, $secret_key) {
+		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_ECB, '');
+		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
+		mcrypt_generic_init($td, $secret_key, $iv);
+		$data = mdecrypt_generic($td, $data);
 		mcrypt_generic_deinit($td);
 		mcrypt_module_close($td);
 
@@ -36,155 +36,155 @@ 
 
 		return trim($data);
 	}
-	public static function getKeyEncryptionAlgm($encryptionMaterials){
-		if(is_array($encryptionMaterials)){
+	public static function getKeyEncryptionAlgm($encryptionMaterials) {
+		if (is_array($encryptionMaterials)) {
 			return "RSA";
-		}else{
+		}else {
 			return "AES";
 		}
 	}
-	public static function getAdjustedRange($range,$blocksize){
+	public static function getAdjustedRange($range, $blocksize) {
 		$a = $range["start"];
 		$b = $range["end"];
-		$a = $a - ($a%$blocksize)-$blocksize;
-		if($a < 0)
+		$a = $a-($a%$blocksize)-$blocksize;
+		if ($a < 0)
 			$a = 0;
 
 		$b = $b+$blocksize-$b%$blocksize+$blocksize;
 
-		return array("start"=>$a,"end"=>$b);
+		return array("start"=>$a, "end"=>$b);
 	}
-	public static function encodeCek($encryptionMaterials,$cek){
+	public static function encodeCek($encryptionMaterials, $cek) {
 		$encrypKeyAlg = EncryptionUtil::getKeyEncryptionAlgm($encryptionMaterials);
-		if($encrypKeyAlg === "AES"){
+		if ($encrypKeyAlg === "AES") {
 			$secretKey = $encryptionMaterials;
-			$encryptedSek = EncryptionUtil::encode_AES_ECB($cek,$secretKey);
-			if(empty($encryptedSek))
+			$encryptedSek = EncryptionUtil::encode_AES_ECB($cek, $secretKey);
+			if (empty($encryptedSek))
 				throw new Ks3ClientException("can not encode cek useing AES");
-		}else if($encrypKeyAlg === "RSA"){
+		}else if ($encrypKeyAlg === "RSA") {
 			$encryptedSek = "";
-			openssl_public_encrypt($cek,$encryptedSek, $encryptionMaterials[0]);
-			if(empty($encryptedSek))
+			openssl_public_encrypt($cek, $encryptedSek, $encryptionMaterials[0]);
+			if (empty($encryptedSek))
 				throw new Ks3ClientException("can not encode cek useing RSA");
 		}
 		return $encryptedSek;
 	}
-	public static function decodeCek($encryptionMaterials,$cekEncrypted){
+	public static function decodeCek($encryptionMaterials, $cekEncrypted) {
 		$encrypKeyAlg = EncryptionUtil::getKeyEncryptionAlgm($encryptionMaterials);
-		if($encrypKeyAlg === "AES"){
+		if ($encrypKeyAlg === "AES") {
 			$secretKey = $encryptionMaterials;
-			$cek = EncryptionUtil::decode_AES_ECB($cekEncrypted,$secretKey);
-			if(empty($cek))
+			$cek = EncryptionUtil::decode_AES_ECB($cekEncrypted, $secretKey);
+			if (empty($cek))
 				throw new Ks3ClientException("can not decode cek useing AES,secret key maybe not correct");
-		}else if($encrypKeyAlg === "RSA"){
+		}else if ($encrypKeyAlg === "RSA") {
 			$cek = "";
-			openssl_private_decrypt($cekEncrypted,$cek, $encryptionMaterials[1]);
-			if(empty($cek))
+			openssl_private_decrypt($cekEncrypted, $cek, $encryptionMaterials[1]);
+			if (empty($cek))
 				throw new Ks3ClientException("can not decode cek useing RSA,public/private key pair maybe not correct");
 		}
 		return $cek;
 	}
-	public static function getPKCS5EncrypedLength($length,$blocksize){
-		$pad = $blocksize - $length%$blocksize;
+	public static function getPKCS5EncrypedLength($length, $blocksize) {
+		$pad = $blocksize-$length%$blocksize;
 		return $length+$pad;
 	}
 	//pkcs5填充
-	public static function PKCS5Padding($data,$blocksize){
-		$pad = $blocksize - strlen($data)%$blocksize;
-		for($i = 0;$i < $pad;$i++){
-			$data.= chr($pad);
+	public static function PKCS5Padding($data, $blocksize) {
+		$pad = $blocksize-strlen($data)%$blocksize;
+		for ($i = 0; $i < $pad; $i++) {
+			$data .= chr($pad);
 		}
 		return $data;
 	}
-	public static function updateContentMD5Header($req){
-		if(!is_array($req))
+	public static function updateContentMD5Header($req) {
+		if (!is_array($req))
 			return $req;
-		if(isset($req["ObjectMeta"])){
+		if (isset($req["ObjectMeta"])) {
 			$meta = $req["ObjectMeta"];
-		}else{
+		}else {
 			return $req;
 		}
-		if(is_array($meta) && isset($meta["Content-MD5"])){
+		if (is_array($meta) && isset($meta["Content-MD5"])) {
 			$md5 = $meta["Content-MD5"];
-		}else{
+		}else {
 			return $req;
 		}
-		if(empty($md5)){
+		if (empty($md5)) {
 			return $req;
-		}else{
+		}else {
 			$req["ObjectMeta"]["Content-MD5"] = NULL;
 			$req["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-md5"] = $md5;
 		}
 		return $req;
 	}
-	public static function metaTextLength($req){
-		if(!is_array($req))
+	public static function metaTextLength($req) {
+		if (!is_array($req))
 			return -1;
-		if(isset($req["ObjectMeta"])){
+		if (isset($req["ObjectMeta"])) {
 			$meta = $req["ObjectMeta"];
-		}else{
+		}else {
 			return -1;
 		}
-		if(is_array($meta) && isset($meta["Content-Length"])){
+		if (is_array($meta) && isset($meta["Content-Length"])) {
 			$length = $meta["Content-Length"];
 			return $length;
 		}else
 			return -1;
 	}
-	public static function plainTextLength($args){
-		if(isset($args["Content"])){
-			if(is_array($args["Content"])){
+	public static function plainTextLength($args) {
+		if (isset($args["Content"])) {
+			if (is_array($args["Content"])) {
 				$content = $args["Content"]["content"];
 				$seek_position = 0;
 				$resourceLength = 0;
 				$length = -1;
 				$isFile = FALSE;
 
-				if (!is_resource($content)){
+				if (!is_resource($content)) {
 					$isFile = TRUE;
 					//如果之前用户已经转化为GBK则不转换
-					if(Utils::chk_chinese($content)&&!Utils::check_char($content)){
-						$content = iconv('utf-8','gbk',$content);
+					if (Utils::chk_chinese($content) && !Utils::check_char($content)) {
+						$content = iconv('utf-8', 'gbk', $content);
 					}
-					if(!file_exists($content))
+					if (!file_exists($content))
 						throw new Ks3ClientException("the specified file does not exist ");
 					$length = Utils::getFileSize($content);
-					$content = fopen($content,"r");
-				}else{
+					$content = fopen($content, "r");
+				}else {
 					$stats = fstat($content);
-					if ($stats && $stats["size"] >= 0){
+					if ($stats && $stats["size"] >= 0) {
 						$length = $stats["size"];	
 					}
 				}
 				$resourceLength = $length;
 				//优先取用户设置seek_position，没有的话取ftell
-				if(isset($args["Content"]["seek_position"])&&$args["Content"]["seek_position"]>0){
+				if (isset($args["Content"]["seek_position"]) && $args["Content"]["seek_position"] > 0) {
 					$seek_position = $args["Content"]["seek_position"];
-				}else if(!$isFile){
+				}else if (!$isFile) {
 					$seek_position = ftell($content);
-					if($seek_position<0)
+					if ($seek_position < 0)
 						$seek_position = 0;
-					fseek($content,0);
+					fseek($content, 0);
 				}
 
 				$lengthInMeta = -1;
-				if(isset($args["ObjectMeta"]["Content-Length"])){
+				if (isset($args["ObjectMeta"]["Content-Length"])) {
 					$lengthInMeta = $args["ObjectMeta"]["Content-Length"];
 				}
-				if($lengthInMeta > 0){
+				if ($lengthInMeta > 0) {
 					$length = $lengthInMeta;
-				}else if($resourceLength > 0){
+				}else if ($resourceLength > 0) {
 					//根据seek_position计算实际长度
-					$length = $resourceLength - $seek_position;
+					$length = $resourceLength-$seek_position;
 				}
-				if($length <= 0)
+				if ($length <= 0)
 					throw new Ks3ClientException("calculate content length failed,unexpected contetn length ".$length);
 				return $length;
-			}else{
+			}else {
 				$content = $args["Content"];
 				$lengthInMeta = EncryptionUtil::metaTextLength($args);
 				$length = strlen($content);
-				if($length<$lengthInMeta||$lengthInMeta <= 0)
+				if ($length < $lengthInMeta || $lengthInMeta <= 0)
 					return $length;
 				else
 					return $lengthInMeta;
@@ -192,14 +192,14 @@ 
 		}
 		return -1;
 	}
-	public static function initMultipartUploadContext($initResult,$iv,$cek,$encryptedCek,$matdesc="{}"){
+	public static function initMultipartUploadContext($initResult, $iv, $cek, $encryptedCek, $matdesc = "{}") {
 		$cacheDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR;
 		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		if(!is_dir($cacheDir))
+		if (!is_dir($cacheDir))
 			mkdir($cacheDir);
-		if(!is_dir($encryptionDir))
+		if (!is_dir($encryptionDir))
 			mkdir($encryptionDir);
-		if(is_array($matdesc)){
+		if (is_array($matdesc)) {
 			$matdesc = json_encode($matdesc);
 		}
 		$initResult["firstIv"] = base64_encode($iv);
@@ -213,7 +213,7 @@ 
 		fwrite($file, $json);
 		fclose($file);
 	}
-	public static function updateMultipartUploadContext($UploadId,$iv,$lastPart = FALSE){
+	public static function updateMultipartUploadContext($UploadId, $iv, $lastPart = FALSE) {
 		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
 		$content = EncryptionUtil::getMultipartUploadContext($UploadId);
 		$content["nextIv"] = base64_encode($iv);
@@ -223,32 +223,32 @@ 
 		fwrite($file, $json);
 		fclose($file);
 	}
-	public static function getMultipartUploadContext($UploadId){
+	public static function getMultipartUploadContext($UploadId) {
 		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		if(!EncryptionUtil::multipartUploadContextExists($UploadId))
+		if (!EncryptionUtil::multipartUploadContextExists($UploadId))
 			throw new Ks3ClientException("can not found multipart upload context in cache dir");
 		$jsonString = file_get_contents($encryptionDir.$UploadId);
-		$arry = json_decode($jsonString,TRUE);
+		$arry = json_decode($jsonString, TRUE);
 		return $arry;
 	}
-	public static function deleteMultipartUploadContext($UploadId){
+	public static function deleteMultipartUploadContext($UploadId) {
 		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
 		@unlink($encryptionDir.$UploadId);
 	}
-	public static function multipartUploadContextExists($UploadId){
+	public static function multipartUploadContextExists($UploadId) {
 		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
 		return file_exists($encryptionDir.$UploadId);
 	}
-	public static function openfile($path,$mode){
+	public static function openfile($path, $mode) {
 		$file = fopen($path, $mode);
-		if($file)
+		if ($file)
 			return $file;
 		else
 			throw new Ks3ClientException("open file ".$path." error");
 	}
 	//matdesc为字符串或array数据类型。
-	public static function createInstructionFile($bucket,$key,$cek,$iv,$matdesc="{}"){
-		if(is_array($matdesc)){
+	public static function createInstructionFile($bucket, $key, $cek, $iv, $matdesc = "{}") {
+		if (is_array($matdesc)) {
 			$matdesc = json_encode($matdesc);
 		}
 		$key = $key.EncryptionUtil::$INSTRUCTION_SUFFIX;
@@ -269,9 +269,9 @@ 
 			);
 		return $req;
 	}
-	public static function isInstructionFile($s3Object){
+	public static function isInstructionFile($s3Object) {
 		$meta = $s3Object["Meta"];
-		if(isset($meta["UserMeta"]["x-kss-meta-x-kss-crypto-instr-file"]))
+		if (isset($meta["UserMeta"]["x-kss-meta-x-kss-crypto-instr-file"]))
 			return TRUE;
 		return FALSE;
 	}

Braces +66 added lines, -49 removed lines

@@ -39,7 +39,7 @@ 
 	public static function getKeyEncryptionAlgm($encryptionMaterials){
 		if(is_array($encryptionMaterials)){
 			return "RSA";
-		}else{
+		} else{
 			return "AES";
 		}
 	}
@@ -47,8 +47,9 @@ 
 		$a = $range["start"];
 		$b = $range["end"];
 		$a = $a - ($a%$blocksize)-$blocksize;
-		if($a < 0)
-			$a = 0;
+		if($a < 0) {
+					$a = 0;
+		}
 
 		$b = $b+$blocksize-$b%$blocksize+$blocksize;
 
@@ -59,13 +60,15 @@ 
 		if($encrypKeyAlg === "AES"){
 			$secretKey = $encryptionMaterials;
 			$encryptedSek = EncryptionUtil::encode_AES_ECB($cek,$secretKey);
-			if(empty($encryptedSek))
-				throw new Ks3ClientException("can not encode cek useing AES");
-		}else if($encrypKeyAlg === "RSA"){
+			if(empty($encryptedSek)) {
+							throw new Ks3ClientException("can not encode cek useing AES");
+			}
+		} else if($encrypKeyAlg === "RSA"){
 			$encryptedSek = "";
 			openssl_public_encrypt($cek,$encryptedSek, $encryptionMaterials[0]);
-			if(empty($encryptedSek))
-				throw new Ks3ClientException("can not encode cek useing RSA");
+			if(empty($encryptedSek)) {
+							throw new Ks3ClientException("can not encode cek useing RSA");
+			}
 		}
 		return $encryptedSek;
 	}
@@ -74,13 +77,15 @@ 
 		if($encrypKeyAlg === "AES"){
 			$secretKey = $encryptionMaterials;
 			$cek = EncryptionUtil::decode_AES_ECB($cekEncrypted,$secretKey);
-			if(empty($cek))
-				throw new Ks3ClientException("can not decode cek useing AES,secret key maybe not correct");
-		}else if($encrypKeyAlg === "RSA"){
+			if(empty($cek)) {
+							throw new Ks3ClientException("can not decode cek useing AES,secret key maybe not correct");
+			}
+		} else if($encrypKeyAlg === "RSA"){
 			$cek = "";
 			openssl_private_decrypt($cekEncrypted,$cek, $encryptionMaterials[1]);
-			if(empty($cek))
-				throw new Ks3ClientException("can not decode cek useing RSA,public/private key pair maybe not correct");
+			if(empty($cek)) {
+							throw new Ks3ClientException("can not decode cek useing RSA,public/private key pair maybe not correct");
+			}
 		}
 		return $cek;
 	}
@@ -97,39 +102,42 @@ 
 		return $data;
 	}
 	public static function updateContentMD5Header($req){
-		if(!is_array($req))
-			return $req;
+		if(!is_array($req)) {
+					return $req;
+		}
 		if(isset($req["ObjectMeta"])){
 			$meta = $req["ObjectMeta"];
-		}else{
+		} else{
 			return $req;
 		}
 		if(is_array($meta) && isset($meta["Content-MD5"])){
 			$md5 = $meta["Content-MD5"];
-		}else{
+		} else{
 			return $req;
 		}
 		if(empty($md5)){
 			return $req;
-		}else{
+		} else{
 			$req["ObjectMeta"]["Content-MD5"] = NULL;
 			$req["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-md5"] = $md5;
 		}
 		return $req;
 	}
 	public static function metaTextLength($req){
-		if(!is_array($req))
-			return -1;
+		if(!is_array($req)) {
+					return -1;
+		}
 		if(isset($req["ObjectMeta"])){
 			$meta = $req["ObjectMeta"];
-		}else{
+		} else{
 			return -1;
 		}
 		if(is_array($meta) && isset($meta["Content-Length"])){
 			$length = $meta["Content-Length"];
 			return $length;
-		}else
-			return -1;
+		} else {
+					return -1;
+		}
 	}
 	public static function plainTextLength($args){
 		if(isset($args["Content"])){
@@ -146,11 +154,12 @@ 
 					if(Utils::chk_chinese($content)&&!Utils::check_char($content)){
 						$content = iconv('utf-8','gbk',$content);
 					}
-					if(!file_exists($content))
-						throw new Ks3ClientException("the specified file does not exist ");
+					if(!file_exists($content)) {
+											throw new Ks3ClientException("the specified file does not exist ");
+					}
 					$length = Utils::getFileSize($content);
 					$content = fopen($content,"r");
-				}else{
+				} else{
 					$stats = fstat($content);
 					if ($stats && $stats["size"] >= 0){
 						$length = $stats["size"];	
@@ -160,10 +169,11 @@ 
 				//优先取用户设置seek_position，没有的话取ftell
 				if(isset($args["Content"]["seek_position"])&&$args["Content"]["seek_position"]>0){
 					$seek_position = $args["Content"]["seek_position"];
-				}else if(!$isFile){
+				} else if(!$isFile){
 					$seek_position = ftell($content);
-					if($seek_position<0)
-						$seek_position = 0;
+					if($seek_position<0) {
+											$seek_position = 0;
+					}
 					fseek($content,0);
 				}
 
@@ -173,21 +183,23 @@ 
 				}
 				if($lengthInMeta > 0){
 					$length = $lengthInMeta;
-				}else if($resourceLength > 0){
+				} else if($resourceLength > 0){
 					//根据seek_position计算实际长度
 					$length = $resourceLength - $seek_position;
 				}
-				if($length <= 0)
-					throw new Ks3ClientException("calculate content length failed,unexpected contetn length ".$length);
+				if($length <= 0) {
+									throw new Ks3ClientException("calculate content length failed,unexpected contetn length ".$length);
+				}
 				return $length;
-			}else{
+			} else{
 				$content = $args["Content"];
 				$lengthInMeta = EncryptionUtil::metaTextLength($args);
 				$length = strlen($content);
-				if($length<$lengthInMeta||$lengthInMeta <= 0)
-					return $length;
-				else
-					return $lengthInMeta;
+				if($length<$lengthInMeta||$lengthInMeta <= 0) {
+									return $length;
+				} else {
+									return $lengthInMeta;
+				}
 			}
 		}
 		return -1;
@@ -195,10 +207,12 @@ 
 	public static function initMultipartUploadContext($initResult,$iv,$cek,$encryptedCek,$matdesc="{}"){
 		$cacheDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR;
 		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		if(!is_dir($cacheDir))
-			mkdir($cacheDir);
-		if(!is_dir($encryptionDir))
-			mkdir($encryptionDir);
+		if(!is_dir($cacheDir)) {
+					mkdir($cacheDir);
+		}
+		if(!is_dir($encryptionDir)) {
+					mkdir($encryptionDir);
+		}
 		if(is_array($matdesc)){
 			$matdesc = json_encode($matdesc);
 		}
@@ -225,8 +239,9 @@ 
 	}
 	public static function getMultipartUploadContext($UploadId){
 		$encryptionDir = KS3_API_PATH.DIRECTORY_SEPARATOR."cache".DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR;
-		if(!EncryptionUtil::multipartUploadContextExists($UploadId))
-			throw new Ks3ClientException("can not found multipart upload context in cache dir");
+		if(!EncryptionUtil::multipartUploadContextExists($UploadId)) {
+					throw new Ks3ClientException("can not found multipart upload context in cache dir");
+		}
 		$jsonString = file_get_contents($encryptionDir.$UploadId);
 		$arry = json_decode($jsonString,TRUE);
 		return $arry;
@@ -241,10 +256,11 @@ 
 	}
 	public static function openfile($path,$mode){
 		$file = fopen($path, $mode);
-		if($file)
-			return $file;
-		else
-			throw new Ks3ClientException("open file ".$path." error");
+		if($file) {
+					return $file;
+		} else {
+					throw new Ks3ClientException("open file ".$path." error");
+		}
 	}
 	//matdesc为字符串或array数据类型。
 	public static function createInstructionFile($bucket,$key,$cek,$iv,$matdesc="{}"){
@@ -271,8 +287,9 @@ 
 	}
 	public static function isInstructionFile($s3Object){
 		$meta = $s3Object["Meta"];
-		if(isset($meta["UserMeta"]["x-kss-meta-x-kss-crypto-instr-file"]))
-			return TRUE;
+		if(isset($meta["UserMeta"]["x-kss-meta-x-kss-crypto-instr-file"])) {
+					return TRUE;
+		}
 		return FALSE;
 	}
 }

src/service/ksyun/bin/encryption/EncryptionHandlers.php

Indentation +322 added lines, -322 removed lines

@@ -3,356 +3,356 @@
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionCallBack.php";
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."exceptions".DIRECTORY_SEPARATOR."Exceptions.php";
 interface EncryptionHandler{
-	public function putObjectByContentSecurely($args=array());
-	public function putObjectByFileSecurely($args=array());
-	public function getObjectSecurely($args=array());
-	public function initMultipartUploadSecurely($args=array());
-	public function uploadPartSecurely($args=array());
-	public function abortMultipartUploadSecurely($args=array());
-	public function completeMultipartUploadSecurely($args=array());
+    public function putObjectByContentSecurely($args=array());
+    public function putObjectByFileSecurely($args=array());
+    public function getObjectSecurely($args=array());
+    public function initMultipartUploadSecurely($args=array());
+    public function uploadPartSecurely($args=array());
+    public function abortMultipartUploadSecurely($args=array());
+    public function completeMultipartUploadSecurely($args=array());
 }
 class EncryptionEO implements EncryptionHandler{
-	private $encryptionMaterials = NULL;
-	private $ks3client = NULL;
-	public function __construct($ks3client,$encryptionMaterials){
-		$this->encryptionMaterials = $encryptionMaterials;
-		$this->ks3client = $ks3client;
-	}
-	public function putObjectByContentSecurely($args=array()){
-		$sek = EncryptionUtil::genereateOnceUsedKey();
-		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
-		$content = $args["Content"];
-		if(empty($content))
-			throw new Ks3ClientException("please specifie Content in request args");
-		$metaContentLength = EncryptionUtil::metaTextLength($args);
-		$plainTextLength = strlen($content);
-		if($metaContentLength > 0 && $metaContentLength < $plainTextLength){
-			$plainTextLength = $metaContentLength;
-		}
-		if($plainTextLength > 0)
-			$args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
-		else
-			throw new Ks3ClientException("unexpected content length ".$plainTextLength);
+    private $encryptionMaterials = NULL;
+    private $ks3client = NULL;
+    public function __construct($ks3client,$encryptionMaterials){
+        $this->encryptionMaterials = $encryptionMaterials;
+        $this->ks3client = $ks3client;
+    }
+    public function putObjectByContentSecurely($args=array()){
+        $sek = EncryptionUtil::genereateOnceUsedKey();
+        $encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
+        $content = $args["Content"];
+        if(empty($content))
+            throw new Ks3ClientException("please specifie Content in request args");
+        $metaContentLength = EncryptionUtil::metaTextLength($args);
+        $plainTextLength = strlen($content);
+        if($metaContentLength > 0 && $metaContentLength < $plainTextLength){
+            $plainTextLength = $metaContentLength;
+        }
+        if($plainTextLength > 0)
+            $args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
+        else
+            throw new Ks3ClientException("unexpected content length ".$plainTextLength);
 
-		$content =  substr($content, 0,$plainTextLength);
+        $content =  substr($content, 0,$plainTextLength);
 
 
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
-		mcrypt_generic_init($td,$sek,$iv);
-		//对content进行pkcs5填充
-		$content = EncryptionUtil::PKCS5Padding($content,mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC));
-		$encrypted = mcrypt_generic($td,$content);
-		mcrypt_generic_deinit($td);
+        $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
+        $iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
+        mcrypt_generic_init($td,$sek,$iv);
+        //对content进行pkcs5填充
+        $content = EncryptionUtil::PKCS5Padding($content,mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC));
+        $encrypted = mcrypt_generic($td,$content);
+        mcrypt_generic_deinit($td);
 
-		$args["ObjectMeta"]["Content-Length"] = strlen($encrypted);
-		$args["Content"] = $encrypted; 
+        $args["ObjectMeta"]["Content-Length"] = strlen($encrypted);
+        $args["Content"] = $encrypted; 
 
-		$args = EncryptionUtil::updateContentMD5Header($args);
+        $args = EncryptionUtil::updateContentMD5Header($args);
 
-		//TODO
-		$matdesc = "{}";
-		if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
-			$args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
-			$args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
-			$args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
-		}
+        //TODO
+        $matdesc = "{}";
+        if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
+            $args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
+            $args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
+            $args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
+        }
 
-		$result = $this->ks3client->putObjectByContent($args);
+        $result = $this->ks3client->putObjectByContent($args);
 
-		if(ENCRYPTPTION_STORAGE_MODE == "InstructionFile"){
-			$req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
-			base64_encode($encryptedSek),base64_encode($iv),$matdesc);
-			$this->ks3client->putObjectByContent($req);
-		}
+        if(ENCRYPTPTION_STORAGE_MODE == "InstructionFile"){
+            $req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
+            base64_encode($encryptedSek),base64_encode($iv),$matdesc);
+            $this->ks3client->putObjectByContent($req);
+        }
 
-		return $result;
-	}
-	public function putObjectByFileSecurely($args=array()){
-		$sek = EncryptionUtil::genereateOnceUsedKey();
-		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
-		if(!isset($args["Content"])||!is_array($args["Content"])
-			||!isset($args["Content"]["content"])
-			||empty($args["Content"]["content"]))
-			throw new Ks3ClientException("please specifie file content in request args");
-		$content = $args["Content"];
-		$plainTextLength = EncryptionUtil::plainTextLength($args);
-		if($plainTextLength <= 0){
-			throw new Ks3ClientException("get content length failed ,unexpected content length ".$plainTextLength);
-		}
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
+        return $result;
+    }
+    public function putObjectByFileSecurely($args=array()){
+        $sek = EncryptionUtil::genereateOnceUsedKey();
+        $encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
+        if(!isset($args["Content"])||!is_array($args["Content"])
+            ||!isset($args["Content"]["content"])
+            ||empty($args["Content"]["content"]))
+            throw new Ks3ClientException("please specifie file content in request args");
+        $content = $args["Content"];
+        $plainTextLength = EncryptionUtil::plainTextLength($args);
+        if($plainTextLength <= 0){
+            throw new Ks3ClientException("get content length failed ,unexpected content length ".$plainTextLength);
+        }
+        $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
+        $iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
 
-		$args = EncryptionUtil::updateContentMD5Header($args);
-		$encryptedLength = EncryptionUtil::getPKCS5EncrypedLength($plainTextLength,mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC));
+        $args = EncryptionUtil::updateContentMD5Header($args);
+        $encryptedLength = EncryptionUtil::getPKCS5EncrypedLength($plainTextLength,mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC));
 
-		$args["ObjectMeta"]["Content-Length"] = $encryptedLength;
-		$args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
+        $args["ObjectMeta"]["Content-Length"] = $encryptedLength;
+        $args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
 
-		$readCallBack = new AESCBCStreamReadCallBack();
-		$readCallBack->iv = $iv;
-		$readCallBack->cek = $sek;
-		$readCallBack->contentLength = $plainTextLength;
-		$args["readCallBack"] = $readCallBack;
+        $readCallBack = new AESCBCStreamReadCallBack();
+        $readCallBack->iv = $iv;
+        $readCallBack->cek = $sek;
+        $readCallBack->contentLength = $plainTextLength;
+        $args["readCallBack"] = $readCallBack;
 
-		//TODO
-		$matdesc = "{}";
-		if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
-			$args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
-			$args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
-			$args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
-		}
+        //TODO
+        $matdesc = "{}";
+        if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
+            $args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
+            $args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
+            $args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
+        }
 
-		$result = $this->ks3client->putObjectByFile($args);
+        $result = $this->ks3client->putObjectByFile($args);
 
-		if(ENCRYPTPTION_STORAGE_MODE == "InstructionFile"){
-			$req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
-			base64_encode($encryptedSek),base64_encode($iv),$matdesc);
-			$this->ks3client->putObjectByContent($req);
-		}
+        if(ENCRYPTPTION_STORAGE_MODE == "InstructionFile"){
+            $req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
+            base64_encode($encryptedSek),base64_encode($iv),$matdesc);
+            $this->ks3client->putObjectByContent($req);
+        }
 
-		return $result;
-	}
-	public function getObjectSecurely($args=array()){
-		$meta = $this->ks3client->getObjectMeta($args);
-		if(isset($meta["UserMeta"]["x-kss-meta-x-kss-key"])&&isset($meta["UserMeta"]["x-kss-meta-x-kss-iv"])){
-			$encryptedInMeta = TRUE;
-		}else{
-			$encryptedInMeta = FALSE;
-		}
-		$encrypted = TRUE;
-		$encryptionInfo = array();
-		if($encryptedInMeta){
-			$encryptionInfo["iv"] = base64_decode($meta["UserMeta"]["x-kss-meta-x-kss-iv"]);
-			$matdesc =$meta["UserMeta"]["x-kss-meta-x-kss-matdesc"];
-			$encryptionInfo["matdesc"] = $matdesc;
-			$cekEncrypted = base64_decode($meta["UserMeta"]["x-kss-meta-x-kss-key"]);
-			$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
-		}else{
-			if($this->ks3client->objectExists(array(
-				"Bucket"=>$args["Bucket"],
-				"Key"=>$args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX)
-				)
-			){
-				$insKey = $args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX;
-				$getIns = array(
-					"Bucket"=>$args["Bucket"],
-					"Key"=>$insKey,
-				);
-				$s3Object = $this->ks3client->getObject($getIns);
-				if(!EncryptionUtil::isInstructionFile($s3Object))
-					throw new Ks3ClientException($insKey." is not an InstructionFile");
+        return $result;
+    }
+    public function getObjectSecurely($args=array()){
+        $meta = $this->ks3client->getObjectMeta($args);
+        if(isset($meta["UserMeta"]["x-kss-meta-x-kss-key"])&&isset($meta["UserMeta"]["x-kss-meta-x-kss-iv"])){
+            $encryptedInMeta = TRUE;
+        }else{
+            $encryptedInMeta = FALSE;
+        }
+        $encrypted = TRUE;
+        $encryptionInfo = array();
+        if($encryptedInMeta){
+            $encryptionInfo["iv"] = base64_decode($meta["UserMeta"]["x-kss-meta-x-kss-iv"]);
+            $matdesc =$meta["UserMeta"]["x-kss-meta-x-kss-matdesc"];
+            $encryptionInfo["matdesc"] = $matdesc;
+            $cekEncrypted = base64_decode($meta["UserMeta"]["x-kss-meta-x-kss-key"]);
+            $encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
+        }else{
+            if($this->ks3client->objectExists(array(
+                "Bucket"=>$args["Bucket"],
+                "Key"=>$args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX)
+                )
+            ){
+                $insKey = $args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX;
+                $getIns = array(
+                    "Bucket"=>$args["Bucket"],
+                    "Key"=>$insKey,
+                );
+                $s3Object = $this->ks3client->getObject($getIns);
+                if(!EncryptionUtil::isInstructionFile($s3Object))
+                    throw new Ks3ClientException($insKey." is not an InstructionFile");
 
-				$content = $s3Object["Content"];
-				$content = json_decode($content,TRUE);
-				$encryptionInfo["iv"] = base64_decode($content["x-kss-iv"]);
-				$matdesc =$content["x-kss-matdesc"];
-				$encryptionInfo["matdesc"] = $matdesc;
-				$cekEncrypted = base64_decode($content["x-kss-key"]);
-				$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
-			}else{
-				$encrypted =FALSE;
-			}
-		}
-		//是否为下载到文件中
-		$isWriteToFile=FALSE;
-		if($encrypted)
-		{
-			$iv = $encryptionInfo["iv"];
-			$cek = $encryptionInfo["cek"];
+                $content = $s3Object["Content"];
+                $content = json_decode($content,TRUE);
+                $encryptionInfo["iv"] = base64_decode($content["x-kss-iv"]);
+                $matdesc =$content["x-kss-matdesc"];
+                $encryptionInfo["matdesc"] = $matdesc;
+                $cekEncrypted = base64_decode($content["x-kss-key"]);
+                $encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
+            }else{
+                $encrypted =FALSE;
+            }
+        }
+        //是否为下载到文件中
+        $isWriteToFile=FALSE;
+        if($encrypted)
+        {
+            $iv = $encryptionInfo["iv"];
+            $cek = $encryptionInfo["cek"];
 
-			if(empty($iv))
-				throw new Ks3ClientException("can not find iv in UserMeta or InstructionFile");
-			if(empty($cek))
-				throw new Ks3ClientException("can not find cek in UserMeta or InstructionFile");
+            if(empty($iv))
+                throw new Ks3ClientException("can not find iv in UserMeta or InstructionFile");
+            if(empty($cek))
+                throw new Ks3ClientException("can not find cek in UserMeta or InstructionFile");
 
-			if(isset($args["Range"])){
-				$range = $args["Range"];
-				if(!is_array($range)){
-					if(preg_match('/^bytes=[0-9]*-[0-9]*$/', $range)){
-						$ranges = explode("-",substr($range,strlen("bytes=")));
-						$a = $ranges[0];
-						$b = $ranges[1];
-						if($a > $b){
-							throw new Ks3ClientException("Invalid range ".$range);
-						}
-						$range = array("start"=>$a,"end"=>$b);
-					}else{
-						throw new Ks3ClientException("Invalid range ".$range);
-					}
-				}else{
-					if(!isset($range["start"])||!isset($range["end"])){
-						throw new Ks3ClientException("Invalid range ".serialize($range));
-					}
-					if($range["start"] > $range["end"]){
-						throw new Ks3ClientException("Invalid range ".serialize($range));
-					}
-				}
-			}
+            if(isset($args["Range"])){
+                $range = $args["Range"];
+                if(!is_array($range)){
+                    if(preg_match('/^bytes=[0-9]*-[0-9]*$/', $range)){
+                        $ranges = explode("-",substr($range,strlen("bytes=")));
+                        $a = $ranges[0];
+                        $b = $ranges[1];
+                        if($a > $b){
+                            throw new Ks3ClientException("Invalid range ".$range);
+                        }
+                        $range = array("start"=>$a,"end"=>$b);
+                    }else{
+                        throw new Ks3ClientException("Invalid range ".$range);
+                    }
+                }else{
+                    if(!isset($range["start"])||!isset($range["end"])){
+                        throw new Ks3ClientException("Invalid range ".serialize($range));
+                    }
+                    if($range["start"] > $range["end"]){
+                        throw new Ks3ClientException("Invalid range ".serialize($range));
+                    }
+                }
+            }
 
-			$isWriteToFile = isset($args["WriteTo"]);
-			$contentLength = $meta["ObjectMeta"]["Content-Length"];
-			if($isWriteToFile){
-				$writeCallBack = new AESCBCStreamWriteCallBack();
-				$writeCallBack->iv=$iv;
-				$writeCallBack->cek=$cek;
-				$writeCallBack->contentLength = $contentLength;
-				if(isset($range)){
-					$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-					$adjustedRange = EncryptionUtil::getAdjustedRange($range,$blocksize);
-					$writeCallBack->expectedRange = $range;
-					$writeCallBack->adjustedRange = $adjustedRange;
-					$args["Range"]=$adjustedRange;
-				}
-				$args["writeCallBack"] = $writeCallBack;
-				return $this->ks3client->getObject($args);
-			}else{
-				$offset = 0;
-				$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-				if(isset($range)){
-					$adjustedRange = EncryptionUtil::getAdjustedRange($range,$blocksize);
-					$args["Range"]=$adjustedRange;
-				}
-				$s3Object = $this->ks3client->getObject($args);
-				$content = $s3Object["Content"];
+            $isWriteToFile = isset($args["WriteTo"]);
+            $contentLength = $meta["ObjectMeta"]["Content-Length"];
+            if($isWriteToFile){
+                $writeCallBack = new AESCBCStreamWriteCallBack();
+                $writeCallBack->iv=$iv;
+                $writeCallBack->cek=$cek;
+                $writeCallBack->contentLength = $contentLength;
+                if(isset($range)){
+                    $blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
+                    $adjustedRange = EncryptionUtil::getAdjustedRange($range,$blocksize);
+                    $writeCallBack->expectedRange = $range;
+                    $writeCallBack->adjustedRange = $adjustedRange;
+                    $args["Range"]=$adjustedRange;
+                }
+                $args["writeCallBack"] = $writeCallBack;
+                return $this->ks3client->getObject($args);
+            }else{
+                $offset = 0;
+                $blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
+                if(isset($range)){
+                    $adjustedRange = EncryptionUtil::getAdjustedRange($range,$blocksize);
+                    $args["Range"]=$adjustedRange;
+                }
+                $s3Object = $this->ks3client->getObject($args);
+                $content = $s3Object["Content"];
 
-				if(isset($range)){
-					if($adjustedRange["start"] > 0){
-						$iv = substr($content,0,$blocksize);
-						$content = substr($content,$blocksize);
-						$offset = $blocksize+$adjustedRange["start"];
-					}
-				}
-				if(!empty($content)){
-					$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-					mcrypt_generic_init($td,$cek,$iv);
-					$decoded = mdecrypt_generic($td,$content);
-					mcrypt_generic_deinit($td);
-					mcrypt_module_close($td);
-				}else{
-					$decoded = "";
-				}
+                if(isset($range)){
+                    if($adjustedRange["start"] > 0){
+                        $iv = substr($content,0,$blocksize);
+                        $content = substr($content,$blocksize);
+                        $offset = $blocksize+$adjustedRange["start"];
+                    }
+                }
+                if(!empty($content)){
+                    $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
+                    mcrypt_generic_init($td,$cek,$iv);
+                    $decoded = mdecrypt_generic($td,$content);
+                    mcrypt_generic_deinit($td);
+                    mcrypt_module_close($td);
+                }else{
+                    $decoded = "";
+                }
 
-				//判断是否需要删除最后填充的字符,以及获取填充的字符
-				$needRemovePad = FALSE;
-				$pad = NULL;
-				if($offset+strlen($decoded) >=$contentLength){
-					$needRemovePad = TRUE;
-					$pad = ord(substr($decoded,strlen($decoded)-1,1));
-					if($pad<=0||$pad>$blocksize)
-					{
-						//invalid pad
-						$needRemovePad = FALSE;
-					}
-				}
-				$endOffset = 0;
-				if(isset($range)){
-					if($offset+strlen($decoded)>$range["end"]){
-						$preLength = strlen($decoded);
-						$decoded = substr($decoded, 0,$range["end"]-$offset+1);
-						$endOffset = $preLength-strlen($decoded);
-					}
-					if($offset<$range["start"]){
-						$decoded = substr($decoded,$range["start"] - $offset);
-					}
-				}
-				//再次根据截取的长度判断是否需要删除最后填充的字符
-				if($needRemovePad&&$endOffset > $pad){
-					$needRemovePad = FALSE;
-				}
-				if($needRemovePad){
-					$padOffset = $pad-$endOffset;
-					$actualWriteCount = strlen($decoded)-$padOffset;
-					if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
-						$decoded = "";
-					else
-						$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
-				}
-				$s3Object["Content"] = $decoded;
-				return $s3Object;
-			}
-		}else{
-			return $this->ks3client->getObject($args);
-		}
-	}
-	public function initMultipartUploadSecurely($args=array()){
-		$sek = EncryptionUtil::genereateOnceUsedKey();
-		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
+                //判断是否需要删除最后填充的字符,以及获取填充的字符
+                $needRemovePad = FALSE;
+                $pad = NULL;
+                if($offset+strlen($decoded) >=$contentLength){
+                    $needRemovePad = TRUE;
+                    $pad = ord(substr($decoded,strlen($decoded)-1,1));
+                    if($pad<=0||$pad>$blocksize)
+                    {
+                        //invalid pad
+                        $needRemovePad = FALSE;
+                    }
+                }
+                $endOffset = 0;
+                if(isset($range)){
+                    if($offset+strlen($decoded)>$range["end"]){
+                        $preLength = strlen($decoded);
+                        $decoded = substr($decoded, 0,$range["end"]-$offset+1);
+                        $endOffset = $preLength-strlen($decoded);
+                    }
+                    if($offset<$range["start"]){
+                        $decoded = substr($decoded,$range["start"] - $offset);
+                    }
+                }
+                //再次根据截取的长度判断是否需要删除最后填充的字符
+                if($needRemovePad&&$endOffset > $pad){
+                    $needRemovePad = FALSE;
+                }
+                if($needRemovePad){
+                    $padOffset = $pad-$endOffset;
+                    $actualWriteCount = strlen($decoded)-$padOffset;
+                    if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
+                        $decoded = "";
+                    else
+                        $decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+                }
+                $s3Object["Content"] = $decoded;
+                return $s3Object;
+            }
+        }else{
+            return $this->ks3client->getObject($args);
+        }
+    }
+    public function initMultipartUploadSecurely($args=array()){
+        $sek = EncryptionUtil::genereateOnceUsedKey();
+        $encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
+        $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
+        $iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
 		
-		$matdesc = "{}";
-		if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
-			$args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
-			$args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
-			$args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
-		}
+        $matdesc = "{}";
+        if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
+            $args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
+            $args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
+            $args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
+        }
 
-		$initResult = $this->ks3client->initMultipartUpload($args);
+        $initResult = $this->ks3client->initMultipartUpload($args);
 
-		EncryptionUtil::initMultipartUploadContext($initResult,$iv,$sek,$encryptedSek,$matdesc);
+        EncryptionUtil::initMultipartUploadContext($initResult,$iv,$sek,$encryptedSek,$matdesc);
 
-		return $initResult;
-	}
-	public function uploadPartSecurely($args=array()){
-		$uploadId = $args["Options"]["uploadId"];
-		$isLastPart = FALSE;
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-		if(isset($args["LastPart"]))
-			$isLastPart = $args["LastPart"];
-		$exists = EncryptionUtil::multipartUploadContextExists($uploadId);
-		if(!$exists){
-			throw new Ks3ClientException("no such upload in cache/encryption/");
-		}
-		$context = EncryptionUtil::getMultipartUploadContext($uploadId);
-		if($context["lastPart"]){
-			throw new Ks3ClientException("this upload with uploadId ".$uploadId," has been upload last part");
-		}
-		$plainTextLength = EncryptionUtil::plainTextLength($args);
-		if($plainTextLength <= 0){
-			throw new Ks3ClientException("get content length failed ,unexpected content length ".$plainTextLength);
-		}
-		if(!$isLastPart){
-			if($plainTextLength % $blocksize != 0)
-				throw new Ks3ClientException("Invalid part size,part size (".$plainTextLength.") must be multiples of the block size ".$blocksize);
-		}else{
-			$args["ObjectMeta"]["Content-Length"] = $plainTextLength + ($blocksize - $plainTextLength%$blocksize);
-		}
-		$readCallBack = new AESCBCStreamReadCallBack();
-		$readCallBack->iv = base64_decode($context["nextIv"]);
-		$readCallBack->cek = base64_decode($context["cek"]);
-		$readCallBack->contentLength = $plainTextLength;
-		$readCallBack->mutipartUpload = TRUE;
-		$readCallBack->isLastPart = $isLastPart;
-		$args["readCallBack"] = $readCallBack;
+        return $initResult;
+    }
+    public function uploadPartSecurely($args=array()){
+        $uploadId = $args["Options"]["uploadId"];
+        $isLastPart = FALSE;
+        $blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
+        if(isset($args["LastPart"]))
+            $isLastPart = $args["LastPart"];
+        $exists = EncryptionUtil::multipartUploadContextExists($uploadId);
+        if(!$exists){
+            throw new Ks3ClientException("no such upload in cache/encryption/");
+        }
+        $context = EncryptionUtil::getMultipartUploadContext($uploadId);
+        if($context["lastPart"]){
+            throw new Ks3ClientException("this upload with uploadId ".$uploadId," has been upload last part");
+        }
+        $plainTextLength = EncryptionUtil::plainTextLength($args);
+        if($plainTextLength <= 0){
+            throw new Ks3ClientException("get content length failed ,unexpected content length ".$plainTextLength);
+        }
+        if(!$isLastPart){
+            if($plainTextLength % $blocksize != 0)
+                throw new Ks3ClientException("Invalid part size,part size (".$plainTextLength.") must be multiples of the block size ".$blocksize);
+        }else{
+            $args["ObjectMeta"]["Content-Length"] = $plainTextLength + ($blocksize - $plainTextLength%$blocksize);
+        }
+        $readCallBack = new AESCBCStreamReadCallBack();
+        $readCallBack->iv = base64_decode($context["nextIv"]);
+        $readCallBack->cek = base64_decode($context["cek"]);
+        $readCallBack->contentLength = $plainTextLength;
+        $readCallBack->mutipartUpload = TRUE;
+        $readCallBack->isLastPart = $isLastPart;
+        $args["readCallBack"] = $readCallBack;
 
-		$upResult = $this->ks3client->uploadPart($args);
-		EncryptionUtil::updateMultipartUploadContext($uploadId,$readCallBack->iv,$isLastPart);
-		return $upResult;
-	}
-	public function abortMultipartUploadSecurely($args=array()){
-		$uploadId = $args["Options"]["uploadId"];
-		EncryptionUtil::deleteMultipartUploadContext($uploadId);
-		return $this->ks3client->abortMultipartUpload($args);
-	}
-	public function completeMultipartUploadSecurely($args=array()){
-		$uploadId = $args["Options"]["uploadId"];
-		$exists = EncryptionUtil::multipartUploadContextExists($uploadId);
-		if(!$exists){
-			throw new Ks3ClientException("no such upload in cache/encryption/");
-		}
-		$context = EncryptionUtil::getMultipartUploadContext($uploadId);
-		if(!$context["lastPart"]){
-			throw new Ks3ClientException("Unable to complete an encrypted multipart upload without being told which part was the last. when upload part you can add item in args like args[\"LastPart\"]=TRUE");
-		}
-		$result = $this->ks3client->completeMultipartUpload($args);
-		if(ENCRYPTPTION_STORAGE_MODE=="InstructionFile"){
-			$req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
-			$context["encryptedCek"],$context["firstIv"],$context["matdesc"]);
-			$this->ks3client->putObjectByContent($req);
-		}
-		EncryptionUtil::deleteMultipartUploadContext($uploadId);
-		return $result;
-	}
+        $upResult = $this->ks3client->uploadPart($args);
+        EncryptionUtil::updateMultipartUploadContext($uploadId,$readCallBack->iv,$isLastPart);
+        return $upResult;
+    }
+    public function abortMultipartUploadSecurely($args=array()){
+        $uploadId = $args["Options"]["uploadId"];
+        EncryptionUtil::deleteMultipartUploadContext($uploadId);
+        return $this->ks3client->abortMultipartUpload($args);
+    }
+    public function completeMultipartUploadSecurely($args=array()){
+        $uploadId = $args["Options"]["uploadId"];
+        $exists = EncryptionUtil::multipartUploadContextExists($uploadId);
+        if(!$exists){
+            throw new Ks3ClientException("no such upload in cache/encryption/");
+        }
+        $context = EncryptionUtil::getMultipartUploadContext($uploadId);
+        if(!$context["lastPart"]){
+            throw new Ks3ClientException("Unable to complete an encrypted multipart upload without being told which part was the last. when upload part you can add item in args like args[\"LastPart\"]=TRUE");
+        }
+        $result = $this->ks3client->completeMultipartUpload($args);
+        if(ENCRYPTPTION_STORAGE_MODE=="InstructionFile"){
+            $req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
+            $context["encryptedCek"],$context["firstIv"],$context["matdesc"]);
+            $this->ks3client->putObjectByContent($req);
+        }
+        EncryptionUtil::deleteMultipartUploadContext($uploadId);
+        return $result;
+    }
 }
 ?>
\ No newline at end of file

Spacing +124 added lines, -124 removed lines

@@ -2,47 +2,47 @@ 
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionUtil.php";
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionCallBack.php";
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."exceptions".DIRECTORY_SEPARATOR."Exceptions.php";
-interface EncryptionHandler{
-	public function putObjectByContentSecurely($args=array());
-	public function putObjectByFileSecurely($args=array());
-	public function getObjectSecurely($args=array());
-	public function initMultipartUploadSecurely($args=array());
-	public function uploadPartSecurely($args=array());
-	public function abortMultipartUploadSecurely($args=array());
-	public function completeMultipartUploadSecurely($args=array());
+interface EncryptionHandler {
+	public function putObjectByContentSecurely($args = array());
+	public function putObjectByFileSecurely($args = array());
+	public function getObjectSecurely($args = array());
+	public function initMultipartUploadSecurely($args = array());
+	public function uploadPartSecurely($args = array());
+	public function abortMultipartUploadSecurely($args = array());
+	public function completeMultipartUploadSecurely($args = array());
 }
-class EncryptionEO implements EncryptionHandler{
+class EncryptionEO implements EncryptionHandler {
 	private $encryptionMaterials = NULL;
 	private $ks3client = NULL;
-	public function __construct($ks3client,$encryptionMaterials){
+	public function __construct($ks3client, $encryptionMaterials) {
 		$this->encryptionMaterials = $encryptionMaterials;
 		$this->ks3client = $ks3client;
 	}
-	public function putObjectByContentSecurely($args=array()){
+	public function putObjectByContentSecurely($args = array()) {
 		$sek = EncryptionUtil::genereateOnceUsedKey();
-		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
+		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials, $sek);
 		$content = $args["Content"];
-		if(empty($content))
+		if (empty($content))
 			throw new Ks3ClientException("please specifie Content in request args");
 		$metaContentLength = EncryptionUtil::metaTextLength($args);
 		$plainTextLength = strlen($content);
-		if($metaContentLength > 0 && $metaContentLength < $plainTextLength){
+		if ($metaContentLength > 0 && $metaContentLength < $plainTextLength) {
 			$plainTextLength = $metaContentLength;
 		}
-		if($plainTextLength > 0)
+		if ($plainTextLength > 0)
 			$args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
 		else
 			throw new Ks3ClientException("unexpected content length ".$plainTextLength);
 
-		$content =  substr($content, 0,$plainTextLength);
+		$content = substr($content, 0, $plainTextLength);
 
 
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
-		mcrypt_generic_init($td,$sek,$iv);
+		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_CBC, '');
+		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
+		mcrypt_generic_init($td, $sek, $iv);
 		//对content进行pkcs5填充
-		$content = EncryptionUtil::PKCS5Padding($content,mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC));
-		$encrypted = mcrypt_generic($td,$content);
+		$content = EncryptionUtil::PKCS5Padding($content, mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC));
+		$encrypted = mcrypt_generic($td, $content);
 		mcrypt_generic_deinit($td);
 
 		$args["ObjectMeta"]["Content-Length"] = strlen($encrypted);
@@ -52,7 +52,7 @@ 
 
 		//TODO
 		$matdesc = "{}";
-		if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
+		if (ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata") {
 			$args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
 			$args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
 			$args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
@@ -60,31 +60,31 @@ 
 
 		$result = $this->ks3client->putObjectByContent($args);
 
-		if(ENCRYPTPTION_STORAGE_MODE == "InstructionFile"){
-			$req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
-			base64_encode($encryptedSek),base64_encode($iv),$matdesc);
+		if (ENCRYPTPTION_STORAGE_MODE == "InstructionFile") {
+			$req = EncryptionUtil::createInstructionFile($args["Bucket"], $args["Key"],
+			base64_encode($encryptedSek), base64_encode($iv), $matdesc);
 			$this->ks3client->putObjectByContent($req);
 		}
 
 		return $result;
 	}
-	public function putObjectByFileSecurely($args=array()){
+	public function putObjectByFileSecurely($args = array()) {
 		$sek = EncryptionUtil::genereateOnceUsedKey();
-		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
-		if(!isset($args["Content"])||!is_array($args["Content"])
+		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials, $sek);
+		if (!isset($args["Content"]) || !is_array($args["Content"])
 			||!isset($args["Content"]["content"])
 			||empty($args["Content"]["content"]))
 			throw new Ks3ClientException("please specifie file content in request args");
 		$content = $args["Content"];
 		$plainTextLength = EncryptionUtil::plainTextLength($args);
-		if($plainTextLength <= 0){
+		if ($plainTextLength <= 0) {
 			throw new Ks3ClientException("get content length failed ,unexpected content length ".$plainTextLength);
 		}
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
+		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_CBC, '');
+		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
 
 		$args = EncryptionUtil::updateContentMD5Header($args);
-		$encryptedLength = EncryptionUtil::getPKCS5EncrypedLength($plainTextLength,mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC));
+		$encryptedLength = EncryptionUtil::getPKCS5EncrypedLength($plainTextLength, mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC));
 
 		$args["ObjectMeta"]["Content-Length"] = $encryptedLength;
 		$args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
@@ -97,7 +97,7 @@ 
 
 		//TODO
 		$matdesc = "{}";
-		if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
+		if (ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata") {
 			$args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
 			$args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
 			$args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
@@ -105,86 +105,86 @@ 
 
 		$result = $this->ks3client->putObjectByFile($args);
 
-		if(ENCRYPTPTION_STORAGE_MODE == "InstructionFile"){
-			$req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
-			base64_encode($encryptedSek),base64_encode($iv),$matdesc);
+		if (ENCRYPTPTION_STORAGE_MODE == "InstructionFile") {
+			$req = EncryptionUtil::createInstructionFile($args["Bucket"], $args["Key"],
+			base64_encode($encryptedSek), base64_encode($iv), $matdesc);
 			$this->ks3client->putObjectByContent($req);
 		}
 
 		return $result;
 	}
-	public function getObjectSecurely($args=array()){
+	public function getObjectSecurely($args = array()) {
 		$meta = $this->ks3client->getObjectMeta($args);
-		if(isset($meta["UserMeta"]["x-kss-meta-x-kss-key"])&&isset($meta["UserMeta"]["x-kss-meta-x-kss-iv"])){
+		if (isset($meta["UserMeta"]["x-kss-meta-x-kss-key"]) && isset($meta["UserMeta"]["x-kss-meta-x-kss-iv"])) {
 			$encryptedInMeta = TRUE;
-		}else{
+		}else {
 			$encryptedInMeta = FALSE;
 		}
 		$encrypted = TRUE;
 		$encryptionInfo = array();
-		if($encryptedInMeta){
+		if ($encryptedInMeta) {
 			$encryptionInfo["iv"] = base64_decode($meta["UserMeta"]["x-kss-meta-x-kss-iv"]);
-			$matdesc =$meta["UserMeta"]["x-kss-meta-x-kss-matdesc"];
+			$matdesc = $meta["UserMeta"]["x-kss-meta-x-kss-matdesc"];
 			$encryptionInfo["matdesc"] = $matdesc;
 			$cekEncrypted = base64_decode($meta["UserMeta"]["x-kss-meta-x-kss-key"]);
-			$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
-		}else{
-			if($this->ks3client->objectExists(array(
+			$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials, $cekEncrypted);
+		}else {
+			if ($this->ks3client->objectExists(array(
 				"Bucket"=>$args["Bucket"],
 				"Key"=>$args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX)
 				)
-			){
+			) {
 				$insKey = $args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX;
 				$getIns = array(
 					"Bucket"=>$args["Bucket"],
 					"Key"=>$insKey,
 				);
 				$s3Object = $this->ks3client->getObject($getIns);
-				if(!EncryptionUtil::isInstructionFile($s3Object))
+				if (!EncryptionUtil::isInstructionFile($s3Object))
 					throw new Ks3ClientException($insKey." is not an InstructionFile");
 
 				$content = $s3Object["Content"];
-				$content = json_decode($content,TRUE);
+				$content = json_decode($content, TRUE);
 				$encryptionInfo["iv"] = base64_decode($content["x-kss-iv"]);
-				$matdesc =$content["x-kss-matdesc"];
+				$matdesc = $content["x-kss-matdesc"];
 				$encryptionInfo["matdesc"] = $matdesc;
 				$cekEncrypted = base64_decode($content["x-kss-key"]);
-				$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
-			}else{
-				$encrypted =FALSE;
+				$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials, $cekEncrypted);
+			}else {
+				$encrypted = FALSE;
 			}
 		}
 		//是否为下载到文件中
-		$isWriteToFile=FALSE;
-		if($encrypted)
+		$isWriteToFile = FALSE;
+		if ($encrypted)
 		{
 			$iv = $encryptionInfo["iv"];
 			$cek = $encryptionInfo["cek"];
 
-			if(empty($iv))
+			if (empty($iv))
 				throw new Ks3ClientException("can not find iv in UserMeta or InstructionFile");
-			if(empty($cek))
+			if (empty($cek))
 				throw new Ks3ClientException("can not find cek in UserMeta or InstructionFile");
 
-			if(isset($args["Range"])){
+			if (isset($args["Range"])) {
 				$range = $args["Range"];
-				if(!is_array($range)){
-					if(preg_match('/^bytes=[0-9]*-[0-9]*$/', $range)){
-						$ranges = explode("-",substr($range,strlen("bytes=")));
+				if (!is_array($range)) {
+					if (preg_match('/^bytes=[0-9]*-[0-9]*$/', $range)) {
+						$ranges = explode("-", substr($range, strlen("bytes=")));
 						$a = $ranges[0];
 						$b = $ranges[1];
-						if($a > $b){
+						if ($a > $b) {
 							throw new Ks3ClientException("Invalid range ".$range);
 						}
-						$range = array("start"=>$a,"end"=>$b);
-					}else{
+						$range = array("start"=>$a, "end"=>$b);
+					}else {
 						throw new Ks3ClientException("Invalid range ".$range);
 					}
-				}else{
-					if(!isset($range["start"])||!isset($range["end"])){
+				}else {
+					if (!isset($range["start"]) || !isset($range["end"])) {
 						throw new Ks3ClientException("Invalid range ".serialize($range));
 					}
-					if($range["start"] > $range["end"]){
+					if ($range["start"] > $range["end"]) {
 						throw new Ks3ClientException("Invalid range ".serialize($range));
 					}
 				}
@@ -192,97 +192,97 @@ 
 
 			$isWriteToFile = isset($args["WriteTo"]);
 			$contentLength = $meta["ObjectMeta"]["Content-Length"];
-			if($isWriteToFile){
+			if ($isWriteToFile) {
 				$writeCallBack = new AESCBCStreamWriteCallBack();
-				$writeCallBack->iv=$iv;
-				$writeCallBack->cek=$cek;
+				$writeCallBack->iv = $iv;
+				$writeCallBack->cek = $cek;
 				$writeCallBack->contentLength = $contentLength;
-				if(isset($range)){
-					$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-					$adjustedRange = EncryptionUtil::getAdjustedRange($range,$blocksize);
+				if (isset($range)) {
+					$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC);
+					$adjustedRange = EncryptionUtil::getAdjustedRange($range, $blocksize);
 					$writeCallBack->expectedRange = $range;
 					$writeCallBack->adjustedRange = $adjustedRange;
-					$args["Range"]=$adjustedRange;
+					$args["Range"] = $adjustedRange;
 				}
 				$args["writeCallBack"] = $writeCallBack;
 				return $this->ks3client->getObject($args);
-			}else{
+			}else {
 				$offset = 0;
-				$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-				if(isset($range)){
-					$adjustedRange = EncryptionUtil::getAdjustedRange($range,$blocksize);
-					$args["Range"]=$adjustedRange;
+				$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC);
+				if (isset($range)) {
+					$adjustedRange = EncryptionUtil::getAdjustedRange($range, $blocksize);
+					$args["Range"] = $adjustedRange;
 				}
 				$s3Object = $this->ks3client->getObject($args);
 				$content = $s3Object["Content"];
 
-				if(isset($range)){
-					if($adjustedRange["start"] > 0){
-						$iv = substr($content,0,$blocksize);
-						$content = substr($content,$blocksize);
+				if (isset($range)) {
+					if ($adjustedRange["start"] > 0) {
+						$iv = substr($content, 0, $blocksize);
+						$content = substr($content, $blocksize);
 						$offset = $blocksize+$adjustedRange["start"];
 					}
 				}
-				if(!empty($content)){
-					$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-					mcrypt_generic_init($td,$cek,$iv);
-					$decoded = mdecrypt_generic($td,$content);
+				if (!empty($content)) {
+					$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_CBC, '');
+					mcrypt_generic_init($td, $cek, $iv);
+					$decoded = mdecrypt_generic($td, $content);
 					mcrypt_generic_deinit($td);
 					mcrypt_module_close($td);
-				}else{
+				}else {
 					$decoded = "";
 				}
 
 				//判断是否需要删除最后填充的字符,以及获取填充的字符
 				$needRemovePad = FALSE;
 				$pad = NULL;
-				if($offset+strlen($decoded) >=$contentLength){
+				if ($offset+strlen($decoded) >= $contentLength) {
 					$needRemovePad = TRUE;
-					$pad = ord(substr($decoded,strlen($decoded)-1,1));
-					if($pad<=0||$pad>$blocksize)
+					$pad = ord(substr($decoded, strlen($decoded)-1, 1));
+					if ($pad <= 0 || $pad > $blocksize)
 					{
 						//invalid pad
 						$needRemovePad = FALSE;
 					}
 				}
 				$endOffset = 0;
-				if(isset($range)){
-					if($offset+strlen($decoded)>$range["end"]){
+				if (isset($range)) {
+					if ($offset+strlen($decoded) > $range["end"]) {
 						$preLength = strlen($decoded);
-						$decoded = substr($decoded, 0,$range["end"]-$offset+1);
+						$decoded = substr($decoded, 0, $range["end"]-$offset+1);
 						$endOffset = $preLength-strlen($decoded);
 					}
-					if($offset<$range["start"]){
-						$decoded = substr($decoded,$range["start"] - $offset);
+					if ($offset < $range["start"]) {
+						$decoded = substr($decoded, $range["start"]-$offset);
 					}
 				}
 				//再次根据截取的长度判断是否需要删除最后填充的字符
-				if($needRemovePad&&$endOffset > $pad){
+				if ($needRemovePad && $endOffset > $pad) {
 					$needRemovePad = FALSE;
 				}
-				if($needRemovePad){
+				if ($needRemovePad) {
 					$padOffset = $pad-$endOffset;
 					$actualWriteCount = strlen($decoded)-$padOffset;
-					if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
+					if ($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
 						$decoded = "";
 					else
-						$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+						$decoded = substr($decoded, 0, strlen($decoded)-$padOffset);
 				}
 				$s3Object["Content"] = $decoded;
 				return $s3Object;
 			}
-		}else{
+		}else {
 			return $this->ks3client->getObject($args);
 		}
 	}
-	public function initMultipartUploadSecurely($args=array()){
+	public function initMultipartUploadSecurely($args = array()) {
 		$sek = EncryptionUtil::genereateOnceUsedKey();
-		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td),MCRYPT_RAND);
+		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials, $sek);
+		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_CBC, '');
+		$iv = mcrypt_create_iv(mcrypt_enc_get_iv_size($td), MCRYPT_RAND);
 		
 		$matdesc = "{}";
-		if(ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata"){
+		if (ENCRYPTPTION_STORAGE_MODE == "ObjectMetadata") {
 			$args["UserMeta"]["x-kss-meta-x-kss-key"] = base64_encode($encryptedSek);
 			$args["UserMeta"]["x-kss-meta-x-kss-iv"] = base64_encode($iv);
 			$args["UserMeta"]["x-kss-meta-x-kss-matdesc"] = $matdesc;
@@ -290,33 +290,33 @@ 
 
 		$initResult = $this->ks3client->initMultipartUpload($args);
 
-		EncryptionUtil::initMultipartUploadContext($initResult,$iv,$sek,$encryptedSek,$matdesc);
+		EncryptionUtil::initMultipartUploadContext($initResult, $iv, $sek, $encryptedSek, $matdesc);
 
 		return $initResult;
 	}
-	public function uploadPartSecurely($args=array()){
+	public function uploadPartSecurely($args = array()) {
 		$uploadId = $args["Options"]["uploadId"];
 		$isLastPart = FALSE;
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-		if(isset($args["LastPart"]))
+		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC);
+		if (isset($args["LastPart"]))
 			$isLastPart = $args["LastPart"];
 		$exists = EncryptionUtil::multipartUploadContextExists($uploadId);
-		if(!$exists){
+		if (!$exists) {
 			throw new Ks3ClientException("no such upload in cache/encryption/");
 		}
 		$context = EncryptionUtil::getMultipartUploadContext($uploadId);
-		if($context["lastPart"]){
-			throw new Ks3ClientException("this upload with uploadId ".$uploadId," has been upload last part");
+		if ($context["lastPart"]) {
+			throw new Ks3ClientException("this upload with uploadId ".$uploadId, " has been upload last part");
 		}
 		$plainTextLength = EncryptionUtil::plainTextLength($args);
-		if($plainTextLength <= 0){
+		if ($plainTextLength <= 0) {
 			throw new Ks3ClientException("get content length failed ,unexpected content length ".$plainTextLength);
 		}
-		if(!$isLastPart){
-			if($plainTextLength % $blocksize != 0)
+		if (!$isLastPart) {
+			if ($plainTextLength%$blocksize != 0)
 				throw new Ks3ClientException("Invalid part size,part size (".$plainTextLength.") must be multiples of the block size ".$blocksize);
-		}else{
-			$args["ObjectMeta"]["Content-Length"] = $plainTextLength + ($blocksize - $plainTextLength%$blocksize);
+		}else {
+			$args["ObjectMeta"]["Content-Length"] = $plainTextLength+($blocksize-$plainTextLength%$blocksize);
 		}
 		$readCallBack = new AESCBCStreamReadCallBack();
 		$readCallBack->iv = base64_decode($context["nextIv"]);
@@ -327,28 +327,28 @@ 
 		$args["readCallBack"] = $readCallBack;
 
 		$upResult = $this->ks3client->uploadPart($args);
-		EncryptionUtil::updateMultipartUploadContext($uploadId,$readCallBack->iv,$isLastPart);
+		EncryptionUtil::updateMultipartUploadContext($uploadId, $readCallBack->iv, $isLastPart);
 		return $upResult;
 	}
-	public function abortMultipartUploadSecurely($args=array()){
+	public function abortMultipartUploadSecurely($args = array()) {
 		$uploadId = $args["Options"]["uploadId"];
 		EncryptionUtil::deleteMultipartUploadContext($uploadId);
 		return $this->ks3client->abortMultipartUpload($args);
 	}
-	public function completeMultipartUploadSecurely($args=array()){
+	public function completeMultipartUploadSecurely($args = array()) {
 		$uploadId = $args["Options"]["uploadId"];
 		$exists = EncryptionUtil::multipartUploadContextExists($uploadId);
-		if(!$exists){
+		if (!$exists) {
 			throw new Ks3ClientException("no such upload in cache/encryption/");
 		}
 		$context = EncryptionUtil::getMultipartUploadContext($uploadId);
-		if(!$context["lastPart"]){
+		if (!$context["lastPart"]) {
 			throw new Ks3ClientException("Unable to complete an encrypted multipart upload without being told which part was the last. when upload part you can add item in args like args[\"LastPart\"]=TRUE");
 		}
 		$result = $this->ks3client->completeMultipartUpload($args);
-		if(ENCRYPTPTION_STORAGE_MODE=="InstructionFile"){
-			$req = EncryptionUtil::createInstructionFile($args["Bucket"],$args["Key"],
-			$context["encryptedCek"],$context["firstIv"],$context["matdesc"]);
+		if (ENCRYPTPTION_STORAGE_MODE == "InstructionFile") {
+			$req = EncryptionUtil::createInstructionFile($args["Bucket"], $args["Key"],
+			$context["encryptedCek"], $context["firstIv"], $context["matdesc"]);
 			$this->ks3client->putObjectByContent($req);
 		}
 		EncryptionUtil::deleteMultipartUploadContext($uploadId);

Braces +40 added lines, -30 removed lines

@@ -22,17 +22,19 @@ 
 		$sek = EncryptionUtil::genereateOnceUsedKey();
 		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
 		$content = $args["Content"];
-		if(empty($content))
-			throw new Ks3ClientException("please specifie Content in request args");
+		if(empty($content)) {
+					throw new Ks3ClientException("please specifie Content in request args");
+		}
 		$metaContentLength = EncryptionUtil::metaTextLength($args);
 		$plainTextLength = strlen($content);
 		if($metaContentLength > 0 && $metaContentLength < $plainTextLength){
 			$plainTextLength = $metaContentLength;
 		}
-		if($plainTextLength > 0)
-			$args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
-		else
-			throw new Ks3ClientException("unexpected content length ".$plainTextLength);
+		if($plainTextLength > 0) {
+					$args["UserMeta"]["x-kss-meta-x-kss-unencrypted-content-length"] = $plainTextLength;
+		} else {
+					throw new Ks3ClientException("unexpected content length ".$plainTextLength);
+		}
 
 		$content =  substr($content, 0,$plainTextLength);
 
@@ -73,8 +75,9 @@ 
 		$encryptedSek = EncryptionUtil::encodeCek($this->encryptionMaterials,$sek);
 		if(!isset($args["Content"])||!is_array($args["Content"])
 			||!isset($args["Content"]["content"])
-			||empty($args["Content"]["content"]))
-			throw new Ks3ClientException("please specifie file content in request args");
+			||empty($args["Content"]["content"])) {
+					throw new Ks3ClientException("please specifie file content in request args");
+		}
 		$content = $args["Content"];
 		$plainTextLength = EncryptionUtil::plainTextLength($args);
 		if($plainTextLength <= 0){
@@ -117,7 +120,7 @@ 
 		$meta = $this->ks3client->getObjectMeta($args);
 		if(isset($meta["UserMeta"]["x-kss-meta-x-kss-key"])&&isset($meta["UserMeta"]["x-kss-meta-x-kss-iv"])){
 			$encryptedInMeta = TRUE;
-		}else{
+		} else{
 			$encryptedInMeta = FALSE;
 		}
 		$encrypted = TRUE;
@@ -128,7 +131,7 @@ 
 			$encryptionInfo["matdesc"] = $matdesc;
 			$cekEncrypted = base64_decode($meta["UserMeta"]["x-kss-meta-x-kss-key"]);
 			$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
-		}else{
+		} else{
 			if($this->ks3client->objectExists(array(
 				"Bucket"=>$args["Bucket"],
 				"Key"=>$args["Key"].EncryptionUtil::$INSTRUCTION_SUFFIX)
@@ -140,8 +143,9 @@ 
 					"Key"=>$insKey,
 				);
 				$s3Object = $this->ks3client->getObject($getIns);
-				if(!EncryptionUtil::isInstructionFile($s3Object))
-					throw new Ks3ClientException($insKey." is not an InstructionFile");
+				if(!EncryptionUtil::isInstructionFile($s3Object)) {
+									throw new Ks3ClientException($insKey." is not an InstructionFile");
+				}
 
 				$content = $s3Object["Content"];
 				$content = json_decode($content,TRUE);
@@ -150,7 +154,7 @@ 
 				$encryptionInfo["matdesc"] = $matdesc;
 				$cekEncrypted = base64_decode($content["x-kss-key"]);
 				$encryptionInfo["cek"] = $cek = EncryptionUtil::decodeCek($this->encryptionMaterials,$cekEncrypted);
-			}else{
+			} else{
 				$encrypted =FALSE;
 			}
 		}
@@ -161,10 +165,12 @@ 
 			$iv = $encryptionInfo["iv"];
 			$cek = $encryptionInfo["cek"];
 
-			if(empty($iv))
-				throw new Ks3ClientException("can not find iv in UserMeta or InstructionFile");
-			if(empty($cek))
-				throw new Ks3ClientException("can not find cek in UserMeta or InstructionFile");
+			if(empty($iv)) {
+							throw new Ks3ClientException("can not find iv in UserMeta or InstructionFile");
+			}
+			if(empty($cek)) {
+							throw new Ks3ClientException("can not find cek in UserMeta or InstructionFile");
+			}
 
 			if(isset($args["Range"])){
 				$range = $args["Range"];
@@ -177,10 +183,10 @@ 
 							throw new Ks3ClientException("Invalid range ".$range);
 						}
 						$range = array("start"=>$a,"end"=>$b);
-					}else{
+					} else{
 						throw new Ks3ClientException("Invalid range ".$range);
 					}
-				}else{
+				} else{
 					if(!isset($range["start"])||!isset($range["end"])){
 						throw new Ks3ClientException("Invalid range ".serialize($range));
 					}
@@ -206,7 +212,7 @@ 
 				}
 				$args["writeCallBack"] = $writeCallBack;
 				return $this->ks3client->getObject($args);
-			}else{
+			} else{
 				$offset = 0;
 				$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
 				if(isset($range)){
@@ -229,7 +235,7 @@ 
 					$decoded = mdecrypt_generic($td,$content);
 					mcrypt_generic_deinit($td);
 					mcrypt_module_close($td);
-				}else{
+				} else{
 					$decoded = "";
 				}
 
@@ -263,15 +269,17 @@ 
 				if($needRemovePad){
 					$padOffset = $pad-$endOffset;
 					$actualWriteCount = strlen($decoded)-$padOffset;
-					if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
+					if($actualWriteCount <= 0) {
+					    //负数的情况就是用户期望的range里全是填充的
 						$decoded = "";
-					else
-						$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+					} else {
+											$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+					}
 				}
 				$s3Object["Content"] = $decoded;
 				return $s3Object;
 			}
-		}else{
+		} else{
 			return $this->ks3client->getObject($args);
 		}
 	}
@@ -298,8 +306,9 @@ 
 		$uploadId = $args["Options"]["uploadId"];
 		$isLastPart = FALSE;
 		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-		if(isset($args["LastPart"]))
-			$isLastPart = $args["LastPart"];
+		if(isset($args["LastPart"])) {
+					$isLastPart = $args["LastPart"];
+		}
 		$exists = EncryptionUtil::multipartUploadContextExists($uploadId);
 		if(!$exists){
 			throw new Ks3ClientException("no such upload in cache/encryption/");
@@ -313,9 +322,10 @@ 
 			throw new Ks3ClientException("get content length failed ,unexpected content length ".$plainTextLength);
 		}
 		if(!$isLastPart){
-			if($plainTextLength % $blocksize != 0)
-				throw new Ks3ClientException("Invalid part size,part size (".$plainTextLength.") must be multiples of the block size ".$blocksize);
-		}else{
+			if($plainTextLength % $blocksize != 0) {
+							throw new Ks3ClientException("Invalid part size,part size (".$plainTextLength.") must be multiples of the block size ".$blocksize);
+			}
+		} else{
 			$args["ObjectMeta"]["Content-Length"] = $plainTextLength + ($blocksize - $plainTextLength%$blocksize);
 		}
 		$readCallBack = new AESCBCStreamReadCallBack();

src/service/ksyun/bin/encryption/EncryptionCallBack.php

Indentation +207 added lines, -207 removed lines

@@ -2,226 +2,226 @@
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionUtil.php";
 //下载
 class AESCBCStreamWriteCallBack{
-	private $iv;
-	private $cek;
-	private $contentLength;
-	//数组，分别为上限和下限
-	private $expectedRange;
-	//经过调整后的range
-	private $adjustedRange;
-	//当前指针位置
-	private $currentIndex;
-	private $buffer;//上一次调用streaming_write_callback后，未解码的数据
-	private $firstWrite = TRUE;
-	public function __set($property_name, $value){
-		$this->$property_name=$value;
-	}
-	public function __get($property_name){
-		if(isset($this->$property_name))
-		{
-			return($this->$property_name);
-		}else
-		{
-			return(NULL);
-		}
-	}
-	//最后的数据大小肯定是blocksize的倍数，所以最后buffer中不会有未解密的内容。否则可以认为该文件是错误的
-	public function streaming_write_callback($curl_handle,$data,$write_stream){
-		$data = $this->buffer.$data;
+    private $iv;
+    private $cek;
+    private $contentLength;
+    //数组，分别为上限和下限
+    private $expectedRange;
+    //经过调整后的range
+    private $adjustedRange;
+    //当前指针位置
+    private $currentIndex;
+    private $buffer;//上一次调用streaming_write_callback后，未解码的数据
+    private $firstWrite = TRUE;
+    public function __set($property_name, $value){
+        $this->$property_name=$value;
+    }
+    public function __get($property_name){
+        if(isset($this->$property_name))
+        {
+            return($this->$property_name);
+        }else
+        {
+            return(NULL);
+        }
+    }
+    //最后的数据大小肯定是blocksize的倍数，所以最后buffer中不会有未解密的内容。否则可以认为该文件是错误的
+    public function streaming_write_callback($curl_handle,$data,$write_stream){
+        $data = $this->buffer.$data;
 
-		$length = strlen($data);
-		//不能把上次的没读完的长度算在这次里,应该算在上次
-		$written_total = 0-strlen($this->buffer);
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-		if($length<$blocksize)
-			$this->buffer = $data;
-		else{
-			//如果期望的范围之后还有数据，则认为数据已经接收完毕。不做任何处理
-			if($this->expectedRange["end"] < $this->expectedRange["start"]){
-				return $written_total+strlen($data);
-			}
-			$this->buffer = substr($data,$length - $length%$blocksize);
-			$data = substr($data,0,$length - $length%$blocksize);
+        $length = strlen($data);
+        //不能把上次的没读完的长度算在这次里,应该算在上次
+        $written_total = 0-strlen($this->buffer);
+        $blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
+        if($length<$blocksize)
+            $this->buffer = $data;
+        else{
+            //如果期望的范围之后还有数据，则认为数据已经接收完毕。不做任何处理
+            if($this->expectedRange["end"] < $this->expectedRange["start"]){
+                return $written_total+strlen($data);
+            }
+            $this->buffer = substr($data,$length - $length%$blocksize);
+            $data = substr($data,0,$length - $length%$blocksize);
 		
-			$ivoffset = 0;
-			//range get时，如果不是从刚开始，则应该取加密后数据的前16个字节作为之后解密的iv
-			if($this->firstWrite){
-				$this->firstWrite = FALSE;
-				if(!$this->isBegin()){
-					$this->iv = substr($data,0,$blocksize);
-					$data = substr($data,$blocksize);
-					$ivoffset = $blocksize;
-				}
-				//初始化当前位置
-				if(isset($this->adjustedRange))
-					$this->currentIndex = $ivoffset+$this->adjustedRange["start"];
-				else
-					$this->currentIndex = $ivoffset;
-			}
-			$written_total+=$ivoffset;
-			if(strlen($data) == 0){
-				$decoded = "";
-				return $written_total;
-			}else{
-				$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-				mcrypt_generic_init($td,$this->cek,$this->iv);
-				$decoded = mdecrypt_generic($td,$data);
-				mcrypt_generic_deinit($td);
-				mcrypt_module_close($td);
-			}
+            $ivoffset = 0;
+            //range get时，如果不是从刚开始，则应该取加密后数据的前16个字节作为之后解密的iv
+            if($this->firstWrite){
+                $this->firstWrite = FALSE;
+                if(!$this->isBegin()){
+                    $this->iv = substr($data,0,$blocksize);
+                    $data = substr($data,$blocksize);
+                    $ivoffset = $blocksize;
+                }
+                //初始化当前位置
+                if(isset($this->adjustedRange))
+                    $this->currentIndex = $ivoffset+$this->adjustedRange["start"];
+                else
+                    $this->currentIndex = $ivoffset;
+            }
+            $written_total+=$ivoffset;
+            if(strlen($data) == 0){
+                $decoded = "";
+                return $written_total;
+            }else{
+                $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
+                mcrypt_generic_init($td,$this->cek,$this->iv);
+                $decoded = mdecrypt_generic($td,$data);
+                mcrypt_generic_deinit($td);
+                mcrypt_module_close($td);
+            }
 
-			$this->iv = substr($data,strlen($data)-$blocksize);
-			//判断是否需要删除最后填充的字符,以及获取填充的字符
-			$needRemovePad = FALSE;
-			$pad = NULL;
+            $this->iv = substr($data,strlen($data)-$blocksize);
+            //判断是否需要删除最后填充的字符,以及获取填充的字符
+            $needRemovePad = FALSE;
+            $pad = NULL;
 
-			if($this->currentIndex+strlen($decoded) >=$this->contentLength){
-				$needRemovePad = TRUE;
-				$pad = ord(substr($decoded,strlen($decoded)-1,1));
-				if($pad<=0||$pad>$blocksize)
-				{
-					//invalid pad
-					$needRemovePad = FALSE;
-				}
-			}
+            if($this->currentIndex+strlen($decoded) >=$this->contentLength){
+                $needRemovePad = TRUE;
+                $pad = ord(substr($decoded,strlen($decoded)-1,1));
+                if($pad<=0||$pad>$blocksize)
+                {
+                    //invalid pad
+                    $needRemovePad = FALSE;
+                }
+            }
 
-			//将解密后的数据截取到期望的长度
-			$startOffset = 0;
-			$endOffset = 0;
-			if(isset($this->expectedRange)){
-				$trueEnd = $expectedEnd = $this->expectedRange["end"];
+            //将解密后的数据截取到期望的长度
+            $startOffset = 0;
+            $endOffset = 0;
+            if(isset($this->expectedRange)){
+                $trueEnd = $expectedEnd = $this->expectedRange["end"];
 
-				if($this->currentIndex+strlen($decoded)>$expectedEnd){
-					$preLength = strlen($decoded);
-					$decoded = substr($decoded, 0,$expectedEnd-$this->currentIndex+1);
-					$endOffset = $preLength-strlen($decoded);
-				}else{
-					//因为range是开始结束都计算的，range=1-2。currentIndex=1,长度是2，end=currentIndex+2-1
-					$trueEnd = $this->currentIndex+strlen($decoded)-1; 
-				}
-				$expectedStart = $this->expectedRange["start"];
-				if($this->currentIndex<$expectedStart){
-					$decoded = substr($decoded,$expectedStart - $this->currentIndex);
-					$startOffset = $expectedStart - $this->currentIndex;
-				}
-				//调整下次期望的开始
-				$this->expectedRange["start"] = $trueEnd+1;
-			}
+                if($this->currentIndex+strlen($decoded)>$expectedEnd){
+                    $preLength = strlen($decoded);
+                    $decoded = substr($decoded, 0,$expectedEnd-$this->currentIndex+1);
+                    $endOffset = $preLength-strlen($decoded);
+                }else{
+                    //因为range是开始结束都计算的，range=1-2。currentIndex=1,长度是2，end=currentIndex+2-1
+                    $trueEnd = $this->currentIndex+strlen($decoded)-1; 
+                }
+                $expectedStart = $this->expectedRange["start"];
+                if($this->currentIndex<$expectedStart){
+                    $decoded = substr($decoded,$expectedStart - $this->currentIndex);
+                    $startOffset = $expectedStart - $this->currentIndex;
+                }
+                //调整下次期望的开始
+                $this->expectedRange["start"] = $trueEnd+1;
+            }
 
-			$padOffset = 0;
-			//再次根据截取的长度判断是否需要删除最后填充的字符
-			if($needRemovePad&&$endOffset > $pad){
-				$needRemovePad = FALSE;
-			}
-			$actualWriteCount = 0;
-			if($needRemovePad){
-				$padOffset = $pad-$endOffset;
-				$actualWriteCount = strlen($decoded)-$padOffset;
-				if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
-					$decoded = "";
-				else
-					$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
-			}
-			$count = fwrite($write_stream, $decoded);
-			if($count == 0)
-				$count = $actualWriteCount;
-			$count += $padOffset;
-			$count += $startOffset;
-			$count += $endOffset;
-			$this->currentIndex += $count;
-			$written_total+=$count;
-		}
-		//否则curl框架会报错
-		$written_total+=strlen($this->buffer);
-		return $written_total;
-	}
-	//是的话则使用初始化IV
-	private function isBegin(){
-		$beginIndex = 0;
-		if(isset($this->adjustedRange["start"]))
-			$beginIndex = $this->adjustedRange["start"];
-		if($beginIndex == 0)
-			return TRUE;
-		else 
-			return FALSE;
-	}
+            $padOffset = 0;
+            //再次根据截取的长度判断是否需要删除最后填充的字符
+            if($needRemovePad&&$endOffset > $pad){
+                $needRemovePad = FALSE;
+            }
+            $actualWriteCount = 0;
+            if($needRemovePad){
+                $padOffset = $pad-$endOffset;
+                $actualWriteCount = strlen($decoded)-$padOffset;
+                if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
+                    $decoded = "";
+                else
+                    $decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+            }
+            $count = fwrite($write_stream, $decoded);
+            if($count == 0)
+                $count = $actualWriteCount;
+            $count += $padOffset;
+            $count += $startOffset;
+            $count += $endOffset;
+            $this->currentIndex += $count;
+            $written_total+=$count;
+        }
+        //否则curl框架会报错
+        $written_total+=strlen($this->buffer);
+        return $written_total;
+    }
+    //是的话则使用初始化IV
+    private function isBegin(){
+        $beginIndex = 0;
+        if(isset($this->adjustedRange["start"]))
+            $beginIndex = $this->adjustedRange["start"];
+        if($beginIndex == 0)
+            return TRUE;
+        else 
+            return FALSE;
+    }
 }
 //上传
 class AESCBCStreamReadCallBack{
-	private $iv;
-	private $cek;
-	private $contentLength;
-	private $buffer;
-	private $hasread = 0;
-	private $mutipartUpload =FALSE;
-	private $isLastPart = FALSE;
-	public function __set($property_name, $value){
-		$this->$property_name=$value;
-	}
-	public function __get($property_name){
-		if(isset($this->$property_name))
-		{
-			return($this->$property_name);
-		}else
-		{
-			return(NULL);
-		}
-	}
-	public function streaming_read_callback($curl_handle,$file_handle,$length,$read_stream,$seek_position){
-		// Once we've sent as much as we're supposed to send...
-		if ($this->hasread >= $this->contentLength)
-		{
-			// Send EOF
-			return '';
-		}
-		// If we're at the beginning of an upload and need to seek...
-		if ($this->hasread == 0 && $seek_position>0 && $seek_position !== ftell($read_stream))
-		{
-			if (fseek($read_stream, $seek_position) !== 0)
-			{
-				throw new RequestCore_Exception('The stream does not support seeking and is either not at the requested position or the position is unknown.');
-			}
-		}
+    private $iv;
+    private $cek;
+    private $contentLength;
+    private $buffer;
+    private $hasread = 0;
+    private $mutipartUpload =FALSE;
+    private $isLastPart = FALSE;
+    public function __set($property_name, $value){
+        $this->$property_name=$value;
+    }
+    public function __get($property_name){
+        if(isset($this->$property_name))
+        {
+            return($this->$property_name);
+        }else
+        {
+            return(NULL);
+        }
+    }
+    public function streaming_read_callback($curl_handle,$file_handle,$length,$read_stream,$seek_position){
+        // Once we've sent as much as we're supposed to send...
+        if ($this->hasread >= $this->contentLength)
+        {
+            // Send EOF
+            return '';
+        }
+        // If we're at the beginning of an upload and need to seek...
+        if ($this->hasread == 0 && $seek_position>0 && $seek_position !== ftell($read_stream))
+        {
+            if (fseek($read_stream, $seek_position) !== 0)
+            {
+                throw new RequestCore_Exception('The stream does not support seeking and is either not at the requested position or the position is unknown.');
+            }
+        }
 
 
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_ECB);
-		$needRead = min($this->contentLength - $this->hasread,$length);
-		$read = fread($read_stream,$needRead);
-		$this->hasread += strlen($read);
-		$isLast = FALSE;
-		if($this->hasread >= $this->contentLength){
-			$isLast = TRUE;
-		}
-		$data = $this->buffer.$read;
+        $blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_ECB);
+        $needRead = min($this->contentLength - $this->hasread,$length);
+        $read = fread($read_stream,$needRead);
+        $this->hasread += strlen($read);
+        $isLast = FALSE;
+        if($this->hasread >= $this->contentLength){
+            $isLast = TRUE;
+        }
+        $data = $this->buffer.$read;
 
-		$dataLength = strlen($data);
+        $dataLength = strlen($data);
 
-		if(!$isLast){
-			$this->buffer = substr($data,$dataLength-$dataLength%$blocksize);
-			$data = substr($data, 0,$dataLength-$dataLength%$blocksize);
-		}else{
-			//分块上传除最后一块外肯定是blocksize大小的倍数，所以不需要填充。
-			if($this->mutipartUpload){
-				if($this->isLastPart){
-					$this->buffer = NULL;
-					$data = EncryptionUtil::PKCS5Padding($data,$blocksize);
-				}else{
-					//donothing
-				}
-			}else{
-				$this->buffer = NULL;
-				$data = EncryptionUtil::PKCS5Padding($data,$blocksize);
-			}
-		}
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		mcrypt_generic_init($td,$this->cek,$this->iv);
-		$encrypted = mcrypt_generic($td,$data);
-		mcrypt_generic_deinit($td);
-		//去除自动填充的16个字节//php的当恰好为16的倍数时竟然不填充？
-		//$encrypted = substr($encrypted,0,strlen($encrypted)-$blocksize);
-		//取最后一个block作为下一次的iv
-		$this->iv = substr($encrypted, strlen($encrypted)-$blocksize);
-		return $encrypted;
-	}
+        if(!$isLast){
+            $this->buffer = substr($data,$dataLength-$dataLength%$blocksize);
+            $data = substr($data, 0,$dataLength-$dataLength%$blocksize);
+        }else{
+            //分块上传除最后一块外肯定是blocksize大小的倍数，所以不需要填充。
+            if($this->mutipartUpload){
+                if($this->isLastPart){
+                    $this->buffer = NULL;
+                    $data = EncryptionUtil::PKCS5Padding($data,$blocksize);
+                }else{
+                    //donothing
+                }
+            }else{
+                $this->buffer = NULL;
+                $data = EncryptionUtil::PKCS5Padding($data,$blocksize);
+            }
+        }
+        $td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
+        mcrypt_generic_init($td,$this->cek,$this->iv);
+        $encrypted = mcrypt_generic($td,$data);
+        mcrypt_generic_deinit($td);
+        //去除自动填充的16个字节//php的当恰好为16的倍数时竟然不填充？
+        //$encrypted = substr($encrypted,0,strlen($encrypted)-$blocksize);
+        //取最后一个block作为下一次的iv
+        $this->iv = substr($encrypted, strlen($encrypted)-$blocksize);
+        return $encrypted;
+    }
 }
 ?>
\ No newline at end of file

Spacing +70 added lines, -70 removed lines

@@ -1,7 +1,7 @@ 
 <?php
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."encryption".DIRECTORY_SEPARATOR."EncryptionUtil.php";
 //下载
-class AESCBCStreamWriteCallBack{
+class AESCBCStreamWriteCallBack {
 	private $iv;
 	private $cek;
 	private $contentLength;
@@ -11,13 +11,13 @@ 
 	private $adjustedRange;
 	//当前指针位置
 	private $currentIndex;
-	private $buffer;//上一次调用streaming_write_callback后，未解码的数据
+	private $buffer; //上一次调用streaming_write_callback后，未解码的数据
 	private $firstWrite = TRUE;
-	public function __set($property_name, $value){
-		$this->$property_name=$value;
+	public function __set($property_name, $value) {
+		$this->$property_name = $value;
 	}
-	public function __get($property_name){
-		if(isset($this->$property_name))
+	public function __get($property_name) {
+		if (isset($this->$property_name))
 		{
 			return($this->$property_name);
 		}else
@@ -26,59 +26,59 @@ 
 		}
 	}
 	//最后的数据大小肯定是blocksize的倍数，所以最后buffer中不会有未解密的内容。否则可以认为该文件是错误的
-	public function streaming_write_callback($curl_handle,$data,$write_stream){
+	public function streaming_write_callback($curl_handle, $data, $write_stream) {
 		$data = $this->buffer.$data;
 
 		$length = strlen($data);
 		//不能把上次的没读完的长度算在这次里,应该算在上次
 		$written_total = 0-strlen($this->buffer);
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-		if($length<$blocksize)
+		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC);
+		if ($length < $blocksize)
 			$this->buffer = $data;
-		else{
+		else {
 			//如果期望的范围之后还有数据，则认为数据已经接收完毕。不做任何处理
-			if($this->expectedRange["end"] < $this->expectedRange["start"]){
+			if ($this->expectedRange["end"] < $this->expectedRange["start"]) {
 				return $written_total+strlen($data);
 			}
-			$this->buffer = substr($data,$length - $length%$blocksize);
-			$data = substr($data,0,$length - $length%$blocksize);
+			$this->buffer = substr($data, $length-$length%$blocksize);
+			$data = substr($data, 0, $length-$length%$blocksize);
 		
 			$ivoffset = 0;
 			//range get时，如果不是从刚开始，则应该取加密后数据的前16个字节作为之后解密的iv
-			if($this->firstWrite){
+			if ($this->firstWrite) {
 				$this->firstWrite = FALSE;
-				if(!$this->isBegin()){
-					$this->iv = substr($data,0,$blocksize);
-					$data = substr($data,$blocksize);
+				if (!$this->isBegin()) {
+					$this->iv = substr($data, 0, $blocksize);
+					$data = substr($data, $blocksize);
 					$ivoffset = $blocksize;
 				}
 				//初始化当前位置
-				if(isset($this->adjustedRange))
+				if (isset($this->adjustedRange))
 					$this->currentIndex = $ivoffset+$this->adjustedRange["start"];
 				else
 					$this->currentIndex = $ivoffset;
 			}
-			$written_total+=$ivoffset;
-			if(strlen($data) == 0){
+			$written_total += $ivoffset;
+			if (strlen($data) == 0) {
 				$decoded = "";
 				return $written_total;
-			}else{
-				$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-				mcrypt_generic_init($td,$this->cek,$this->iv);
-				$decoded = mdecrypt_generic($td,$data);
+			}else {
+				$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_CBC, '');
+				mcrypt_generic_init($td, $this->cek, $this->iv);
+				$decoded = mdecrypt_generic($td, $data);
 				mcrypt_generic_deinit($td);
 				mcrypt_module_close($td);
 			}
 
-			$this->iv = substr($data,strlen($data)-$blocksize);
+			$this->iv = substr($data, strlen($data)-$blocksize);
 			//判断是否需要删除最后填充的字符,以及获取填充的字符
 			$needRemovePad = FALSE;
 			$pad = NULL;
 
-			if($this->currentIndex+strlen($decoded) >=$this->contentLength){
+			if ($this->currentIndex+strlen($decoded) >= $this->contentLength) {
 				$needRemovePad = TRUE;
-				$pad = ord(substr($decoded,strlen($decoded)-1,1));
-				if($pad<=0||$pad>$blocksize)
+				$pad = ord(substr($decoded, strlen($decoded)-1, 1));
+				if ($pad <= 0 || $pad > $blocksize)
 				{
 					//invalid pad
 					$needRemovePad = FALSE;
@@ -88,21 +88,21 @@ 
 			//将解密后的数据截取到期望的长度
 			$startOffset = 0;
 			$endOffset = 0;
-			if(isset($this->expectedRange)){
+			if (isset($this->expectedRange)) {
 				$trueEnd = $expectedEnd = $this->expectedRange["end"];
 
-				if($this->currentIndex+strlen($decoded)>$expectedEnd){
+				if ($this->currentIndex+strlen($decoded) > $expectedEnd) {
 					$preLength = strlen($decoded);
-					$decoded = substr($decoded, 0,$expectedEnd-$this->currentIndex+1);
+					$decoded = substr($decoded, 0, $expectedEnd-$this->currentIndex+1);
 					$endOffset = $preLength-strlen($decoded);
-				}else{
+				}else {
 					//因为range是开始结束都计算的，range=1-2。currentIndex=1,长度是2，end=currentIndex+2-1
 					$trueEnd = $this->currentIndex+strlen($decoded)-1; 
 				}
 				$expectedStart = $this->expectedRange["start"];
-				if($this->currentIndex<$expectedStart){
-					$decoded = substr($decoded,$expectedStart - $this->currentIndex);
-					$startOffset = $expectedStart - $this->currentIndex;
+				if ($this->currentIndex < $expectedStart) {
+					$decoded = substr($decoded, $expectedStart-$this->currentIndex);
+					$startOffset = $expectedStart-$this->currentIndex;
 				}
 				//调整下次期望的开始
 				$this->expectedRange["start"] = $trueEnd+1;
@@ -110,56 +110,56 @@ 
 
 			$padOffset = 0;
 			//再次根据截取的长度判断是否需要删除最后填充的字符
-			if($needRemovePad&&$endOffset > $pad){
+			if ($needRemovePad && $endOffset > $pad) {
 				$needRemovePad = FALSE;
 			}
 			$actualWriteCount = 0;
-			if($needRemovePad){
+			if ($needRemovePad) {
 				$padOffset = $pad-$endOffset;
 				$actualWriteCount = strlen($decoded)-$padOffset;
-				if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
+				if ($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
 					$decoded = "";
 				else
-					$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+					$decoded = substr($decoded, 0, strlen($decoded)-$padOffset);
 			}
 			$count = fwrite($write_stream, $decoded);
-			if($count == 0)
+			if ($count == 0)
 				$count = $actualWriteCount;
 			$count += $padOffset;
 			$count += $startOffset;
 			$count += $endOffset;
 			$this->currentIndex += $count;
-			$written_total+=$count;
+			$written_total += $count;
 		}
 		//否则curl框架会报错
-		$written_total+=strlen($this->buffer);
+		$written_total += strlen($this->buffer);
 		return $written_total;
 	}
 	//是的话则使用初始化IV
-	private function isBegin(){
+	private function isBegin() {
 		$beginIndex = 0;
-		if(isset($this->adjustedRange["start"]))
+		if (isset($this->adjustedRange["start"]))
 			$beginIndex = $this->adjustedRange["start"];
-		if($beginIndex == 0)
+		if ($beginIndex == 0)
 			return TRUE;
 		else 
 			return FALSE;
 	}
 }
 //上传
-class AESCBCStreamReadCallBack{
+class AESCBCStreamReadCallBack {
 	private $iv;
 	private $cek;
 	private $contentLength;
 	private $buffer;
 	private $hasread = 0;
-	private $mutipartUpload =FALSE;
+	private $mutipartUpload = FALSE;
 	private $isLastPart = FALSE;
-	public function __set($property_name, $value){
-		$this->$property_name=$value;
+	public function __set($property_name, $value) {
+		$this->$property_name = $value;
 	}
-	public function __get($property_name){
-		if(isset($this->$property_name))
+	public function __get($property_name) {
+		if (isset($this->$property_name))
 		{
 			return($this->$property_name);
 		}else
@@ -167,7 +167,7 @@ 
 			return(NULL);
 		}
 	}
-	public function streaming_read_callback($curl_handle,$file_handle,$length,$read_stream,$seek_position){
+	public function streaming_read_callback($curl_handle, $file_handle, $length, $read_stream, $seek_position) {
 		// Once we've sent as much as we're supposed to send...
 		if ($this->hasread >= $this->contentLength)
 		{
@@ -175,7 +175,7 @@ 
 			return '';
 		}
 		// If we're at the beginning of an upload and need to seek...
-		if ($this->hasread == 0 && $seek_position>0 && $seek_position !== ftell($read_stream))
+		if ($this->hasread == 0 && $seek_position > 0 && $seek_position !== ftell($read_stream))
 		{
 			if (fseek($read_stream, $seek_position) !== 0)
 			{
@@ -184,38 +184,38 @@ 
 		}
 
 
-		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_ECB);
-		$needRead = min($this->contentLength - $this->hasread,$length);
-		$read = fread($read_stream,$needRead);
+		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_ECB);
+		$needRead = min($this->contentLength-$this->hasread, $length);
+		$read = fread($read_stream, $needRead);
 		$this->hasread += strlen($read);
 		$isLast = FALSE;
-		if($this->hasread >= $this->contentLength){
+		if ($this->hasread >= $this->contentLength) {
 			$isLast = TRUE;
 		}
 		$data = $this->buffer.$read;
 
 		$dataLength = strlen($data);
 
-		if(!$isLast){
-			$this->buffer = substr($data,$dataLength-$dataLength%$blocksize);
-			$data = substr($data, 0,$dataLength-$dataLength%$blocksize);
-		}else{
+		if (!$isLast) {
+			$this->buffer = substr($data, $dataLength-$dataLength%$blocksize);
+			$data = substr($data, 0, $dataLength-$dataLength%$blocksize);
+		}else {
 			//分块上传除最后一块外肯定是blocksize大小的倍数，所以不需要填充。
-			if($this->mutipartUpload){
-				if($this->isLastPart){
+			if ($this->mutipartUpload) {
+				if ($this->isLastPart) {
 					$this->buffer = NULL;
-					$data = EncryptionUtil::PKCS5Padding($data,$blocksize);
-				}else{
+					$data = EncryptionUtil::PKCS5Padding($data, $blocksize);
+				}else {
 					//donothing
 				}
-			}else{
+			}else {
 				$this->buffer = NULL;
-				$data = EncryptionUtil::PKCS5Padding($data,$blocksize);
+				$data = EncryptionUtil::PKCS5Padding($data, $blocksize);
 			}
 		}
-		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
-		mcrypt_generic_init($td,$this->cek,$this->iv);
-		$encrypted = mcrypt_generic($td,$data);
+		$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128, '', MCRYPT_MODE_CBC, '');
+		mcrypt_generic_init($td, $this->cek, $this->iv);
+		$encrypted = mcrypt_generic($td, $data);
 		mcrypt_generic_deinit($td);
 		//去除自动填充的16个字节//php的当恰好为16的倍数时竟然不填充？
 		//$encrypted = substr($encrypted,0,strlen($encrypted)-$blocksize);

Braces +31 added lines, -25 removed lines

@@ -20,7 +20,7 @@ 
 		if(isset($this->$property_name))
 		{
 			return($this->$property_name);
-		}else
+		} else
 		{
 			return(NULL);
 		}
@@ -33,9 +33,9 @@ 
 		//不能把上次的没读完的长度算在这次里,应该算在上次
 		$written_total = 0-strlen($this->buffer);
 		$blocksize = mcrypt_get_block_size(MCRYPT_RIJNDAEL_128,MCRYPT_MODE_CBC);
-		if($length<$blocksize)
-			$this->buffer = $data;
-		else{
+		if($length<$blocksize) {
+					$this->buffer = $data;
+		} else{
 			//如果期望的范围之后还有数据，则认为数据已经接收完毕。不做任何处理
 			if($this->expectedRange["end"] < $this->expectedRange["start"]){
 				return $written_total+strlen($data);
@@ -53,16 +53,17 @@ 
 					$ivoffset = $blocksize;
 				}
 				//初始化当前位置
-				if(isset($this->adjustedRange))
-					$this->currentIndex = $ivoffset+$this->adjustedRange["start"];
-				else
-					$this->currentIndex = $ivoffset;
+				if(isset($this->adjustedRange)) {
+									$this->currentIndex = $ivoffset+$this->adjustedRange["start"];
+				} else {
+									$this->currentIndex = $ivoffset;
+				}
 			}
 			$written_total+=$ivoffset;
 			if(strlen($data) == 0){
 				$decoded = "";
 				return $written_total;
-			}else{
+			} else{
 				$td = mcrypt_module_open(MCRYPT_RIJNDAEL_128,'',MCRYPT_MODE_CBC,'');
 				mcrypt_generic_init($td,$this->cek,$this->iv);
 				$decoded = mdecrypt_generic($td,$data);
@@ -95,7 +96,7 @@ 
 					$preLength = strlen($decoded);
 					$decoded = substr($decoded, 0,$expectedEnd-$this->currentIndex+1);
 					$endOffset = $preLength-strlen($decoded);
-				}else{
+				} else{
 					//因为range是开始结束都计算的，range=1-2。currentIndex=1,长度是2，end=currentIndex+2-1
 					$trueEnd = $this->currentIndex+strlen($decoded)-1; 
 				}
@@ -117,14 +118,17 @@ 
 			if($needRemovePad){
 				$padOffset = $pad-$endOffset;
 				$actualWriteCount = strlen($decoded)-$padOffset;
-				if($actualWriteCount <= 0)//负数的情况就是用户期望的range里全是填充的
+				if($actualWriteCount <= 0) {
+				    //负数的情况就是用户期望的range里全是填充的
 					$decoded = "";
-				else
-					$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+				} else {
+									$decoded = substr($decoded,0,strlen($decoded)-$padOffset);
+				}
 			}
 			$count = fwrite($write_stream, $decoded);
-			if($count == 0)
-				$count = $actualWriteCount;
+			if($count == 0) {
+							$count = $actualWriteCount;
+			}
 			$count += $padOffset;
 			$count += $startOffset;
 			$count += $endOffset;
@@ -138,12 +142,14 @@ 
 	//是的话则使用初始化IV
 	private function isBegin(){
 		$beginIndex = 0;
-		if(isset($this->adjustedRange["start"]))
-			$beginIndex = $this->adjustedRange["start"];
-		if($beginIndex == 0)
-			return TRUE;
-		else 
-			return FALSE;
+		if(isset($this->adjustedRange["start"])) {
+					$beginIndex = $this->adjustedRange["start"];
+		}
+		if($beginIndex == 0) {
+					return TRUE;
+		} else {
+					return FALSE;
+		}
 	}
 }
 //上传
@@ -162,7 +168,7 @@ 
 		if(isset($this->$property_name))
 		{
 			return($this->$property_name);
-		}else
+		} else
 		{
 			return(NULL);
 		}
@@ -199,16 +205,16 @@ 
 		if(!$isLast){
 			$this->buffer = substr($data,$dataLength-$dataLength%$blocksize);
 			$data = substr($data, 0,$dataLength-$dataLength%$blocksize);
-		}else{
+		} else{
 			//分块上传除最后一块外肯定是blocksize大小的倍数，所以不需要填充。
 			if($this->mutipartUpload){
 				if($this->isLastPart){
 					$this->buffer = NULL;
 					$data = EncryptionUtil::PKCS5Padding($data,$blocksize);
-				}else{
+				} else{
 					//donothing
 				}
-			}else{
+			} else{
 				$this->buffer = NULL;
 				$data = EncryptionUtil::PKCS5Padding($data,$blocksize);
 			}

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

Indentation +278 added lines, -278 removed lines

@@ -39,41 +39,41 @@ 
 require_once KS3_API_PATH.DIRECTORY_SEPARATOR."exceptions".DIRECTORY_SEPARATOR."Exceptions.php";
 
 if(function_exists('get_loaded_extensions')){
-	//检测curl扩展
-	$extensions = get_loaded_extensions();
-	if($extensions){
-		if(!in_array('curl', $extensions)){
-			throw new Ks3ClientException("please install curl extension");
-		}
-		if(!in_array('mbstring', $extensions)){
-			throw new Ks3ClientException("please install mbstring extension");
+    //检测curl扩展
+    $extensions = get_loaded_extensions();
+    if($extensions){
+        if(!in_array('curl', $extensions)){
+            throw new Ks3ClientException("please install curl extension");
+        }
+        if(!in_array('mbstring', $extensions)){
+            throw new Ks3ClientException("please install mbstring extension");
 			
-		}
-	}else{
-		throw new Ks3ClientException("please install extensions");
-	}
+        }
+    }else{
+        throw new Ks3ClientException("please install extensions");
+    }
 }else{
-	throw new Ks3ClientException();
+    throw new Ks3ClientException();
 }
 
 class Ks3Client{
-	private $accessKey;
-	private $secretKey;
-	private $endpoint;
-	private $log;
-	public function __construct($accessKey = NULL, $secretKey = NULL, $endpoint = NULL ){
-		$this->accessKey = $accessKey;
-		$this->secretKey = $secretKey;
+    private $accessKey;
+    private $secretKey;
+    private $endpoint;
+    private $log;
+    public function __construct($accessKey = NULL, $secretKey = NULL, $endpoint = NULL ){
+        $this->accessKey = $accessKey;
+        $this->secretKey = $secretKey;
 
-		if(empty($endpoint)){
-			throw new Ks3ClientException("must set endpoint, please see http://ks3.ksyun.com/doc/api/index.html Region part");
-		}
-		$this->endpoint = $endpoint;
+        if(empty($endpoint)){
+            throw new Ks3ClientException("must set endpoint, please see http://ks3.ksyun.com/doc/api/index.html Region part");
+        }
+        $this->endpoint = $endpoint;
 
-		$this->signers = array();
-		$this->log = new Logger();
-	}
-	/**
+        $this->signers = array();
+        $this->log = new Logger();
+    }
+    /**
 	方法列表:(具体使用请参考readme.md)
 	listBuckets,罗列bucket
 	deleteBucket，删除bucket
@@ -107,264 +107,264 @@ 
 	generatePresignedUrl，生成文件外链
 	putAdp,添加异步数据处理任务
 	getAdp,查询异步数据处理任务
-	*/
-	public function __call($method,$args=array()){
-		$holder = new MessageHolder();
+     */
+    public function __call($method,$args=array()){
+        $holder = new MessageHolder();
 
-		$holder->msg = "------------------Logging Start-------------------------\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";
-			$ex = $e;
-		}
-		$holder->msg .= "------------------Logging End-------------------------\r\n";
-		$this->log->info($holder->msg);
-		if($ex !=NULL)
-			throw $ex;
-		return $result;
-	}
-	private function invoke($method,$args=array(),$holder,$location=NULL){
-		$api = API::$API[$method];
-		if(!$api){
-			throw new Ks3ClientException($method." Not Found API");
-		}
-		if(count($args) !== 0){
-			if(count($args)>1||!is_array($args[0])){
-				throw new Ks3ClientException("this method only needs one array argument");
-			}
-			$args = $args[0];
-		}
-		if(isset($api["redirect"])){
-			$api = API::$API[$api["redirect"]];
-		}
-		$request = new Ks3Request();
-		if(empty($args["Bucket"])){
-			if($api["needBucket"]){
-				throw new Ks3ClientException($method." this api need bucket");
-			}
-		}else{
-			$request->bucket = $args["Bucket"];
-		}
-		$position = "Key";
-		//position主要为queryadp接口用的
-		if(isset($api["objectPostion"])){
-			$position = $api["objectPostion"];
-		}
-		if(empty($args[$position])){
-			if($api["needObject"]){
-				throw new Ks3ClientException($method." this api need ".$position);
-			}
-		}else{
-			$key = $args[$position];
-			$preEncoding = mb_detect_encoding($key, array("ASCII","UTF-8","GB2312","GBK","BIG5"));
-			$holder->msg.="key encoding ".$preEncoding."\r\n";
-			if(strtolower($preEncoding) != "utf-8"){
-				$key = iconv($preEncoding, "UTF-8",$key);
-			}
-			$request->key = $key;
-		}
-		$method = $api["method"];
-		if($method == "Method"){
-			if(empty($args["Method"])){
-				$request->method="GET";
-			}else{
-				$request->method=$args["Method"];
-			}
-		}else{
-			$request->method=$api["method"];
-		}
-		if(KS3_API_USE_HTTPS)
-			$request->scheme="https://";
-		else
-			$request->scheme="http://";
-		$request->endpoint=$this->endpoint;
-		//add subresource
-		if(!empty($api["subResource"])){
-			$request->subResource=$api["subResource"];
-		}
-		//add query params
-		if(isset($api["queryParams"] )){ 
-			foreach ($api["queryParams"] as $key => $value) {
-				$required = FALSE;
-				if(substr($value,0,1)==="!"){
-					$required = TRUE;
-					$value=substr($value,1);
-				}
-				$index = explode("->",$value);
-				$curIndexArg = $args;
-				$add = TRUE;
-				$curkey = "";
-				foreach ($index as $key1 => $value1) {
-					if(!isset($curIndexArg[$value1])&&$value1 !== "*"){
-						$add = FALSE;
-					}else{
-						$curkey = $value1;
-						//星号表示所有,按照暂时的业务，默认星号后面就没了
-						if($curkey == "*"){
-							foreach ($curIndexArg as $queryK => $queryV) {
-								if(!is_array($queryV)){
-									$request->addQueryParams($queryK,$queryV);
-								}
-							}
-							$add = FALSE;
-							$required = FALSE;
-							break;
-						}else{
-							$curIndexArg = $curIndexArg[$value1];
-						}
-					}
-				}
-				if(!empty($curIndexArg)&&$add){
-					$request->addQueryParams($curkey,$curIndexArg);
-					continue;
-				}
-				if($required)
-					throw new Ks3ClientException($method." param ".$value." is required");
-			}
-		}
-		if(isset($api["body"])){
-			if(isset($api["body"]["builder"])){
-				$builderName = $api["body"]["builder"];
-				$builder = new $builderName();
-				$request->body = $builder->build($args);
-			}else if(isset($api["body"]["position"])){
-				$position = $api["body"]["position"];
-				$index = explode("->",$position);
-				$curIndexArg = $args;
-				$add = TRUE;
-				$curkey = "";
-				foreach ($index as $key1 => $value1) {
-					if(!isset($curIndexArg[$value1])){
-						$add = FALSE;
-					}else{
-						$curIndexArg = $curIndexArg[$value1];
-						$curkey = $value1;
-					}
-				}
-				if(!empty($curIndexArg)&&$add){
-					$request->body=$curIndexArg;
-				}
-			}
-		}
+        $holder->msg = "------------------Logging Start-------------------------\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";
+            $ex = $e;
+        }
+        $holder->msg .= "------------------Logging End-------------------------\r\n";
+        $this->log->info($holder->msg);
+        if($ex !=NULL)
+            throw $ex;
+        return $result;
+    }
+    private function invoke($method,$args=array(),$holder,$location=NULL){
+        $api = API::$API[$method];
+        if(!$api){
+            throw new Ks3ClientException($method." Not Found API");
+        }
+        if(count($args) !== 0){
+            if(count($args)>1||!is_array($args[0])){
+                throw new Ks3ClientException("this method only needs one array argument");
+            }
+            $args = $args[0];
+        }
+        if(isset($api["redirect"])){
+            $api = API::$API[$api["redirect"]];
+        }
+        $request = new Ks3Request();
+        if(empty($args["Bucket"])){
+            if($api["needBucket"]){
+                throw new Ks3ClientException($method." this api need bucket");
+            }
+        }else{
+            $request->bucket = $args["Bucket"];
+        }
+        $position = "Key";
+        //position主要为queryadp接口用的
+        if(isset($api["objectPostion"])){
+            $position = $api["objectPostion"];
+        }
+        if(empty($args[$position])){
+            if($api["needObject"]){
+                throw new Ks3ClientException($method." this api need ".$position);
+            }
+        }else{
+            $key = $args[$position];
+            $preEncoding = mb_detect_encoding($key, array("ASCII","UTF-8","GB2312","GBK","BIG5"));
+            $holder->msg.="key encoding ".$preEncoding."\r\n";
+            if(strtolower($preEncoding) != "utf-8"){
+                $key = iconv($preEncoding, "UTF-8",$key);
+            }
+            $request->key = $key;
+        }
+        $method = $api["method"];
+        if($method == "Method"){
+            if(empty($args["Method"])){
+                $request->method="GET";
+            }else{
+                $request->method=$args["Method"];
+            }
+        }else{
+            $request->method=$api["method"];
+        }
+        if(KS3_API_USE_HTTPS)
+            $request->scheme="https://";
+        else
+            $request->scheme="http://";
+        $request->endpoint=$this->endpoint;
+        //add subresource
+        if(!empty($api["subResource"])){
+            $request->subResource=$api["subResource"];
+        }
+        //add query params
+        if(isset($api["queryParams"] )){ 
+            foreach ($api["queryParams"] as $key => $value) {
+                $required = FALSE;
+                if(substr($value,0,1)==="!"){
+                    $required = TRUE;
+                    $value=substr($value,1);
+                }
+                $index = explode("->",$value);
+                $curIndexArg = $args;
+                $add = TRUE;
+                $curkey = "";
+                foreach ($index as $key1 => $value1) {
+                    if(!isset($curIndexArg[$value1])&&$value1 !== "*"){
+                        $add = FALSE;
+                    }else{
+                        $curkey = $value1;
+                        //星号表示所有,按照暂时的业务，默认星号后面就没了
+                        if($curkey == "*"){
+                            foreach ($curIndexArg as $queryK => $queryV) {
+                                if(!is_array($queryV)){
+                                    $request->addQueryParams($queryK,$queryV);
+                                }
+                            }
+                            $add = FALSE;
+                            $required = FALSE;
+                            break;
+                        }else{
+                            $curIndexArg = $curIndexArg[$value1];
+                        }
+                    }
+                }
+                if(!empty($curIndexArg)&&$add){
+                    $request->addQueryParams($curkey,$curIndexArg);
+                    continue;
+                }
+                if($required)
+                    throw new Ks3ClientException($method." param ".$value." is required");
+            }
+        }
+        if(isset($api["body"])){
+            if(isset($api["body"]["builder"])){
+                $builderName = $api["body"]["builder"];
+                $builder = new $builderName();
+                $request->body = $builder->build($args);
+            }else if(isset($api["body"]["position"])){
+                $position = $api["body"]["position"];
+                $index = explode("->",$position);
+                $curIndexArg = $args;
+                $add = TRUE;
+                $curkey = "";
+                foreach ($index as $key1 => $value1) {
+                    if(!isset($curIndexArg[$value1])){
+                        $add = FALSE;
+                    }else{
+                        $curIndexArg = $curIndexArg[$value1];
+                        $curkey = $value1;
+                    }
+                }
+                if(!empty($curIndexArg)&&$add){
+                    $request->body=$curIndexArg;
+                }
+            }
+        }
 		
-		//add ext headers
-		//TODO
-		//sign request
-		$signer = NULL;
-		if(isset($api["signer"])){
-			$signers = explode("->",$api["signer"]);
-			foreach ($signers as $key => $value) {
-				$signer = new $value();
-				$log = $signer->sign($request,array("accessKey"=>$this->accessKey,"secretKey"=>$this->secretKey,"args"=>$args));
-				if(!empty($log)){
-					$holder->msg.=$log."\r\n";
-				}
-			}
-		}
+        //add ext headers
+        //TODO
+        //sign request
+        $signer = NULL;
+        if(isset($api["signer"])){
+            $signers = explode("->",$api["signer"]);
+            foreach ($signers as $key => $value) {
+                $signer = new $value();
+                $log = $signer->sign($request,array("accessKey"=>$this->accessKey,"secretKey"=>$this->secretKey,"args"=>$args));
+                if(!empty($log)){
+                    $holder->msg.=$log."\r\n";
+                }
+            }
+        }
 
-		if($signer===NULL||!($signer instanceof QueryAuthSigner)){
-			$url = $request->toUrl($this->endpoint);
-			if($location!=NULL)
-				$url = $location;
-			$httpRequest = new RequestCore($url);
-			if(KS3_API_DEBUG_MODE===TRUE)
-				$httpRequest->debug_mode=TRUE;
-			$httpRequest->set_method($request->method);
-			foreach ($request->headers as $key => $value) {
-				$httpRequest->add_header($key,$value);
-			}
-			$httpRequest->request_body=$request->body;
+        if($signer===NULL||!($signer instanceof QueryAuthSigner)){
+            $url = $request->toUrl($this->endpoint);
+            if($location!=NULL)
+                $url = $location;
+            $httpRequest = new RequestCore($url);
+            if(KS3_API_DEBUG_MODE===TRUE)
+                $httpRequest->debug_mode=TRUE;
+            $httpRequest->set_method($request->method);
+            foreach ($request->headers as $key => $value) {
+                $httpRequest->add_header($key,$value);
+            }
+            $httpRequest->request_body=$request->body;
 
-			if(isset($args["writeCallBack"])){
-				$httpRequest->register_streaming_write_callback($args["writeCallBack"]);
-			}
-			if(isset($args["readCallBack"])){
-				$httpRequest->register_streaming_read_callback($args["readCallBack"]);
-			}
+            if(isset($args["writeCallBack"])){
+                $httpRequest->register_streaming_write_callback($args["writeCallBack"]);
+            }
+            if(isset($args["readCallBack"])){
+                $httpRequest->register_streaming_read_callback($args["readCallBack"]);
+            }
 
-			$read_stream = $request->read_stream;
-			$read_length = $request->getHeader(Headers::$ContentLength);
-			$seek_position = $request->seek_position;
-			if(isset($read_stream))
-			{
-				$httpRequest->set_read_stream($read_stream,$read_length);
-				$httpRequest->set_seek_position($seek_position);
-				$httpRequest->remove_header(Headers::$ContentLength);
-			}
-			$write_stream = $request->write_stream;
-			if(isset($write_stream)){
-				$httpRequest->set_write_stream($write_stream);
-			}
+            $read_stream = $request->read_stream;
+            $read_length = $request->getHeader(Headers::$ContentLength);
+            $seek_position = $request->seek_position;
+            if(isset($read_stream))
+            {
+                $httpRequest->set_read_stream($read_stream,$read_length);
+                $httpRequest->set_seek_position($seek_position);
+                $httpRequest->remove_header(Headers::$ContentLength);
+            }
+            $write_stream = $request->write_stream;
+            if(isset($write_stream)){
+                $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";
-			$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 () );
+            $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 () );
 
-			if($data->status == 307){
-				$respHeaders = $httpRequest->get_response_header();
-				$location = $respHeaders["location"];
-				if(substr($location,0,4) == "http"){
-					$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";
-			$handlers = explode("->",$api["handler"]);
-			foreach ($handlers as $key => $value) {
-				$handler = new $value();
-				$data = $handler->handle($data);
-			}
-			return $data;
-		}else{
-			$url = $request->toUrl($this->endpoint);
-			$holder->msg.=$url."\r\n";
-			return $url;
-		}
-	}
-	//用于生产表单上传时的签名信息
-	public function postObject($bucket ,$postFormData=array(),$unknowValueFormFiled=array(),$filename=NULL,$expire=18000){
-		$policy = array();
+            if($data->status == 307){
+                $respHeaders = $httpRequest->get_response_header();
+                $location = $respHeaders["location"];
+                if(substr($location,0,4) == "http"){
+                    $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";
+            $handlers = explode("->",$api["handler"]);
+            foreach ($handlers as $key => $value) {
+                $handler = new $value();
+                $data = $handler->handle($data);
+            }
+            return $data;
+        }else{
+            $url = $request->toUrl($this->endpoint);
+            $holder->msg.=$url."\r\n";
+            return $url;
+        }
+    }
+    //用于生产表单上传时的签名信息
+    public function postObject($bucket ,$postFormData=array(),$unknowValueFormFiled=array(),$filename=NULL,$expire=18000){
+        $policy = array();
 
-		$expireTime = Utils::iso8601(time()+$expire);
-		$policy["expiration"] = $expireTime;
-		$postFormData["bucket"]=$bucket;
-		$conditions = array();
-		foreach ($postFormData as $key => $value) {
-			$condition = array();
-			$condition[$key] = str_replace("\${filename}",$filename, $value);
-			array_push($conditions,$condition);
-		}
-		foreach ($unknowValueFormFiled as $key => $value) {
-			$condition = array();
-			array_push($condition,"starts-with");
-			array_push($condition,"\$".$value);
-			array_push($condition,"");
-			array_push($conditions,$condition);
-		}
-		$policy["conditions"] = $conditions;
-		$json = json_encode($policy);
-		$signature = base64_encode(hash_hmac('sha1', base64_encode($json), $this->secretKey, true));
-		$result = array();
-		$result["Policy"] = base64_encode($json);
-		$result["Signature"] = $signature;
-		$result["KSSAccessKeyId"] = $this->accessKey;
-		return $result;
-	}
+        $expireTime = Utils::iso8601(time()+$expire);
+        $policy["expiration"] = $expireTime;
+        $postFormData["bucket"]=$bucket;
+        $conditions = array();
+        foreach ($postFormData as $key => $value) {
+            $condition = array();
+            $condition[$key] = str_replace("\${filename}",$filename, $value);
+            array_push($conditions,$condition);
+        }
+        foreach ($unknowValueFormFiled as $key => $value) {
+            $condition = array();
+            array_push($condition,"starts-with");
+            array_push($condition,"\$".$value);
+            array_push($condition,"");
+            array_push($conditions,$condition);
+        }
+        $policy["conditions"] = $conditions;
+        $json = json_encode($policy);
+        $signature = base64_encode(hash_hmac('sha1', base64_encode($json), $this->secretKey, true));
+        $result = array();
+        $result["Policy"] = base64_encode($json);
+        $result["Signature"] = $signature;
+        $result["KSSAccessKeyId"] = $this->accessKey;
+        return $result;
+    }
 }
 
 ?>

Spacing +123 added lines, -123 removed lines

@@ -4,28 +4,28 @@ 
 date_default_timezone_set('Asia/Shanghai');
 
 //检测API路径
-if(!defined("KS3_API_PATH"))
+if (!defined("KS3_API_PATH"))
 define("KS3_API_PATH", dirname(__FILE__));
 //是否使用VHOST
-if(!defined("KS3_API_VHOST"))
-define("KS3_API_VHOST",TRUE);
+if (!defined("KS3_API_VHOST"))
+define("KS3_API_VHOST", TRUE);
 //是否开启日志(写入日志文件)
-if(!defined("KS3_API_LOG"))
-define("KS3_API_LOG",TRUE);
+if (!defined("KS3_API_LOG"))
+define("KS3_API_LOG", TRUE);
 //是否显示日志(直接输出日志)
-if(!defined("KS3_API_DISPLAY_LOG"))
+if (!defined("KS3_API_DISPLAY_LOG"))
 define("KS3_API_DISPLAY_LOG", TRUE);
 //定义日志目录(默认是该项目log下)
-if(!defined("KS3_API_LOG_PATH"))
-define("KS3_API_LOG_PATH","");
+if (!defined("KS3_API_LOG_PATH"))
+define("KS3_API_LOG_PATH", "");
 //是否使用HTTPS
-if(!defined("KS3_API_USE_HTTPS"))
-define("KS3_API_USE_HTTPS",FALSE);
+if (!defined("KS3_API_USE_HTTPS"))
+define("KS3_API_USE_HTTPS", FALSE);
 //是否开启curl debug模式
-if(!defined("KS3_API_DEBUG_MODE"))
-define("KS3_API_DEBUG_MODE",FALSE);
-define("KS3_API_Author","lijunwei@kingsoft.com");
-define("KS3_API_Version","1.2");
+if (!defined("KS3_API_DEBUG_MODE"))
+define("KS3_API_DEBUG_MODE", FALSE);
+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";
@@ -38,34 +38,34 @@ 
 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')){
+if (function_exists('get_loaded_extensions')) {
 	//检测curl扩展
 	$extensions = get_loaded_extensions();
-	if($extensions){
-		if(!in_array('curl', $extensions)){
+	if ($extensions) {
+		if (!in_array('curl', $extensions)) {
 			throw new Ks3ClientException("please install curl extension");
 		}
-		if(!in_array('mbstring', $extensions)){
+		if (!in_array('mbstring', $extensions)) {
 			throw new Ks3ClientException("please install mbstring extension");
 			
 		}
-	}else{
+	}else {
 		throw new Ks3ClientException("please install extensions");
 	}
-}else{
+}else {
 	throw new Ks3ClientException();
 }
 
-class Ks3Client{
+class Ks3Client {
 	private $accessKey;
 	private $secretKey;
 	private $endpoint;
 	private $log;
-	public function __construct($accessKey = NULL, $secretKey = NULL, $endpoint = NULL ){
+	public function __construct($accessKey = NULL, $secretKey = NULL, $endpoint = NULL) {
 		$this->accessKey = $accessKey;
 		$this->secretKey = $secretKey;
 
-		if(empty($endpoint)){
+		if (empty($endpoint)) {
 			throw new Ks3ClientException("must set endpoint, please see http://ks3.ksyun.com/doc/api/index.html Region part");
 		}
 		$this->endpoint = $endpoint;
@@ -108,144 +108,144 @@ 
 	putAdp,添加异步数据处理任务
 	getAdp,查询异步数据处理任务
 	*/
-	public function __call($method,$args=array()){
+	public function __call($method, $args = array()) {
 		$holder = new MessageHolder();
 
 		$holder->msg = "------------------Logging Start-------------------------\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";
+		try {
+			$result = $this->invoke($method, $args, $holder);
+		} catch (Exception $e) {
+			$holder->msg .= $e."\r\n";
 			$ex = $e;
 		}
 		$holder->msg .= "------------------Logging End-------------------------\r\n";
 		$this->log->info($holder->msg);
-		if($ex !=NULL)
+		if ($ex != NULL)
 			throw $ex;
 		return $result;
 	}
-	private function invoke($method,$args=array(),$holder,$location=NULL){
+	private function invoke($method, $args = array(), $holder, $location = NULL) {
 		$api = API::$API[$method];
-		if(!$api){
+		if (!$api) {
 			throw new Ks3ClientException($method." Not Found API");
 		}
-		if(count($args) !== 0){
-			if(count($args)>1||!is_array($args[0])){
+		if (count($args) !== 0) {
+			if (count($args) > 1 || !is_array($args[0])) {
 				throw new Ks3ClientException("this method only needs one array argument");
 			}
 			$args = $args[0];
 		}
-		if(isset($api["redirect"])){
+		if (isset($api["redirect"])) {
 			$api = API::$API[$api["redirect"]];
 		}
 		$request = new Ks3Request();
-		if(empty($args["Bucket"])){
-			if($api["needBucket"]){
+		if (empty($args["Bucket"])) {
+			if ($api["needBucket"]) {
 				throw new Ks3ClientException($method." this api need bucket");
 			}
-		}else{
+		}else {
 			$request->bucket = $args["Bucket"];
 		}
 		$position = "Key";
 		//position主要为queryadp接口用的
-		if(isset($api["objectPostion"])){
+		if (isset($api["objectPostion"])) {
 			$position = $api["objectPostion"];
 		}
-		if(empty($args[$position])){
-			if($api["needObject"]){
+		if (empty($args[$position])) {
+			if ($api["needObject"]) {
 				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";
-			if(strtolower($preEncoding) != "utf-8"){
-				$key = iconv($preEncoding, "UTF-8",$key);
+			$preEncoding = mb_detect_encoding($key, array("ASCII", "UTF-8", "GB2312", "GBK", "BIG5"));
+			$holder->msg .= "key encoding ".$preEncoding."\r\n";
+			if (strtolower($preEncoding) != "utf-8") {
+				$key = iconv($preEncoding, "UTF-8", $key);
 			}
 			$request->key = $key;
 		}
 		$method = $api["method"];
-		if($method == "Method"){
-			if(empty($args["Method"])){
-				$request->method="GET";
-			}else{
-				$request->method=$args["Method"];
+		if ($method == "Method") {
+			if (empty($args["Method"])) {
+				$request->method = "GET";
+			}else {
+				$request->method = $args["Method"];
 			}
-		}else{
-			$request->method=$api["method"];
+		}else {
+			$request->method = $api["method"];
 		}
-		if(KS3_API_USE_HTTPS)
-			$request->scheme="https://";
+		if (KS3_API_USE_HTTPS)
+			$request->scheme = "https://";
 		else
-			$request->scheme="http://";
-		$request->endpoint=$this->endpoint;
+			$request->scheme = "http://";
+		$request->endpoint = $this->endpoint;
 		//add subresource
-		if(!empty($api["subResource"])){
-			$request->subResource=$api["subResource"];
+		if (!empty($api["subResource"])) {
+			$request->subResource = $api["subResource"];
 		}
 		//add query params
-		if(isset($api["queryParams"] )){ 
+		if (isset($api["queryParams"])) { 
 			foreach ($api["queryParams"] as $key => $value) {
 				$required = FALSE;
-				if(substr($value,0,1)==="!"){
+				if (substr($value, 0, 1) === "!") {
 					$required = TRUE;
-					$value=substr($value,1);
+					$value = substr($value, 1);
 				}
-				$index = explode("->",$value);
+				$index = explode("->", $value);
 				$curIndexArg = $args;
 				$add = TRUE;
 				$curkey = "";
 				foreach ($index as $key1 => $value1) {
-					if(!isset($curIndexArg[$value1])&&$value1 !== "*"){
+					if (!isset($curIndexArg[$value1]) && $value1 !== "*") {
 						$add = FALSE;
-					}else{
+					}else {
 						$curkey = $value1;
 						//星号表示所有,按照暂时的业务，默认星号后面就没了
-						if($curkey == "*"){
+						if ($curkey == "*") {
 							foreach ($curIndexArg as $queryK => $queryV) {
-								if(!is_array($queryV)){
-									$request->addQueryParams($queryK,$queryV);
+								if (!is_array($queryV)) {
+									$request->addQueryParams($queryK, $queryV);
 								}
 							}
 							$add = FALSE;
 							$required = FALSE;
 							break;
-						}else{
+						}else {
 							$curIndexArg = $curIndexArg[$value1];
 						}
 					}
 				}
-				if(!empty($curIndexArg)&&$add){
-					$request->addQueryParams($curkey,$curIndexArg);
+				if (!empty($curIndexArg) && $add) {
+					$request->addQueryParams($curkey, $curIndexArg);
 					continue;
 				}
-				if($required)
+				if ($required)
 					throw new Ks3ClientException($method." param ".$value." is required");
 			}
 		}
-		if(isset($api["body"])){
-			if(isset($api["body"]["builder"])){
+		if (isset($api["body"])) {
+			if (isset($api["body"]["builder"])) {
 				$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);
+				$index = explode("->", $position);
 				$curIndexArg = $args;
 				$add = TRUE;
 				$curkey = "";
 				foreach ($index as $key1 => $value1) {
-					if(!isset($curIndexArg[$value1])){
+					if (!isset($curIndexArg[$value1])) {
 						$add = FALSE;
-					}else{
+					}else {
 						$curIndexArg = $curIndexArg[$value1];
 						$curkey = $value1;
 					}
 				}
-				if(!empty($curIndexArg)&&$add){
-					$request->body=$curIndexArg;
+				if (!empty($curIndexArg) && $add) {
+					$request->body = $curIndexArg;
 				}
 			}
 		}
@@ -254,107 +254,107 @@ 
 		//TODO
 		//sign request
 		$signer = NULL;
-		if(isset($api["signer"])){
-			$signers = explode("->",$api["signer"]);
+		if (isset($api["signer"])) {
+			$signers = explode("->", $api["signer"]);
 			foreach ($signers as $key => $value) {
 				$signer = new $value();
-				$log = $signer->sign($request,array("accessKey"=>$this->accessKey,"secretKey"=>$this->secretKey,"args"=>$args));
-				if(!empty($log)){
-					$holder->msg.=$log."\r\n";
+				$log = $signer->sign($request, array("accessKey"=>$this->accessKey, "secretKey"=>$this->secretKey, "args"=>$args));
+				if (!empty($log)) {
+					$holder->msg .= $log."\r\n";
 				}
 			}
 		}
 
-		if($signer===NULL||!($signer instanceof QueryAuthSigner)){
+		if ($signer === NULL || !($signer instanceof QueryAuthSigner)) {
 			$url = $request->toUrl($this->endpoint);
-			if($location!=NULL)
+			if ($location != NULL)
 				$url = $location;
 			$httpRequest = new RequestCore($url);
-			if(KS3_API_DEBUG_MODE===TRUE)
-				$httpRequest->debug_mode=TRUE;
+			if (KS3_API_DEBUG_MODE === TRUE)
+				$httpRequest->debug_mode = TRUE;
 			$httpRequest->set_method($request->method);
 			foreach ($request->headers as $key => $value) {
-				$httpRequest->add_header($key,$value);
+				$httpRequest->add_header($key, $value);
 			}
-			$httpRequest->request_body=$request->body;
+			$httpRequest->request_body = $request->body;
 
-			if(isset($args["writeCallBack"])){
+			if (isset($args["writeCallBack"])) {
 				$httpRequest->register_streaming_write_callback($args["writeCallBack"]);
 			}
-			if(isset($args["readCallBack"])){
+			if (isset($args["readCallBack"])) {
 				$httpRequest->register_streaming_read_callback($args["readCallBack"]);
 			}
 
 			$read_stream = $request->read_stream;
 			$read_length = $request->getHeader(Headers::$ContentLength);
 			$seek_position = $request->seek_position;
-			if(isset($read_stream))
+			if (isset($read_stream))
 			{
-				$httpRequest->set_read_stream($read_stream,$read_length);
+				$httpRequest->set_read_stream($read_stream, $read_length);
 				$httpRequest->set_seek_position($seek_position);
 				$httpRequest->remove_header(Headers::$ContentLength);
 			}
 			$write_stream = $request->write_stream;
-			if(isset($write_stream)){
+			if (isset($write_stream)) {
 				$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 () );
+			$body = $httpRequest->get_response_body();	
+			$data = new ResponseCore($httpRequest->get_response_header(), Utils::replaceNS2($body), $httpRequest->get_response_code());
 
-			if($data->status == 307){
+			if ($data->status == 307) {
 				$respHeaders = $httpRequest->get_response_header();
 				$location = $respHeaders["location"];
-				if(substr($location,0,4) == "http"){
-					$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";
+				if (substr($location, 0, 4) == "http") {
+					$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);
+					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";
-			$handlers = explode("->",$api["handler"]);
+			$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();
 				$data = $handler->handle($data);
 			}
 			return $data;
-		}else{
+		}else {
 			$url = $request->toUrl($this->endpoint);
-			$holder->msg.=$url."\r\n";
+			$holder->msg .= $url."\r\n";
 			return $url;
 		}
 	}
 	//用于生产表单上传时的签名信息
-	public function postObject($bucket ,$postFormData=array(),$unknowValueFormFiled=array(),$filename=NULL,$expire=18000){
+	public function postObject($bucket, $postFormData = array(), $unknowValueFormFiled = array(), $filename = NULL, $expire = 18000) {
 		$policy = array();
 
 		$expireTime = Utils::iso8601(time()+$expire);
 		$policy["expiration"] = $expireTime;
-		$postFormData["bucket"]=$bucket;
+		$postFormData["bucket"] = $bucket;
 		$conditions = array();
 		foreach ($postFormData as $key => $value) {
 			$condition = array();
-			$condition[$key] = str_replace("\${filename}",$filename, $value);
-			array_push($conditions,$condition);
+			$condition[$key] = str_replace("\${filename}", $filename, $value);
+			array_push($conditions, $condition);
 		}
 		foreach ($unknowValueFormFiled as $key => $value) {
 			$condition = array();
-			array_push($condition,"starts-with");
-			array_push($condition,"\$".$value);
-			array_push($condition,"");
-			array_push($conditions,$condition);
+			array_push($condition, "starts-with");
+			array_push($condition, "\$".$value);
+			array_push($condition, "");
+			array_push($conditions, $condition);
 		}
 		$policy["conditions"] = $conditions;
 		$json = json_encode($policy);

Braces +50 added lines, -38 removed lines

@@ -4,26 +4,33 @@ 
 date_default_timezone_set('Asia/Shanghai');
 
 //检测API路径
-if(!defined("KS3_API_PATH"))
-define("KS3_API_PATH", dirname(__FILE__));
+if(!defined("KS3_API_PATH")) {
+    define("KS3_API_PATH", dirname(__FILE__));
+}
 //是否使用VHOST
-if(!defined("KS3_API_VHOST"))
-define("KS3_API_VHOST",TRUE);
+if(!defined("KS3_API_VHOST")) {
+    define("KS3_API_VHOST",TRUE);
+}
 //是否开启日志(写入日志文件)
-if(!defined("KS3_API_LOG"))
-define("KS3_API_LOG",TRUE);
+if(!defined("KS3_API_LOG")) {
+    define("KS3_API_LOG",TRUE);
+}
 //是否显示日志(直接输出日志)
-if(!defined("KS3_API_DISPLAY_LOG"))
-define("KS3_API_DISPLAY_LOG", TRUE);
+if(!defined("KS3_API_DISPLAY_LOG")) {
+    define("KS3_API_DISPLAY_LOG", TRUE);
+}
 //定义日志目录(默认是该项目log下)
-if(!defined("KS3_API_LOG_PATH"))
-define("KS3_API_LOG_PATH","");
+if(!defined("KS3_API_LOG_PATH")) {
+    define("KS3_API_LOG_PATH","");
+}
 //是否使用HTTPS
-if(!defined("KS3_API_USE_HTTPS"))
-define("KS3_API_USE_HTTPS",FALSE);
+if(!defined("KS3_API_USE_HTTPS")) {
+    define("KS3_API_USE_HTTPS",FALSE);
+}
 //是否开启curl debug模式
-if(!defined("KS3_API_DEBUG_MODE"))
-define("KS3_API_DEBUG_MODE",FALSE);
+if(!defined("KS3_API_DEBUG_MODE")) {
+    define("KS3_API_DEBUG_MODE",FALSE);
+}
 define("KS3_API_Author","lijunwei@kingsoft.com");
 define("KS3_API_Version","1.2");
 
@@ -49,10 +56,10 @@ 
 			throw new Ks3ClientException("please install mbstring extension");
 			
 		}
-	}else{
+	} else{
 		throw new Ks3ClientException("please install extensions");
 	}
-}else{
+} else{
 	throw new Ks3ClientException();
 }
 
@@ -116,14 +123,15 @@ 
 		$ex = NULL;
 		try{
 			$result = $this->invoke($method,$args,$holder);
-		}catch(Exception $e){
+		} catch(Exception $e){
 			$holder->msg.=$e."\r\n";
 			$ex = $e;
 		}
 		$holder->msg .= "------------------Logging End-------------------------\r\n";
 		$this->log->info($holder->msg);
-		if($ex !=NULL)
-			throw $ex;
+		if($ex !=NULL) {
+					throw $ex;
+		}
 		return $result;
 	}
 	private function invoke($method,$args=array(),$holder,$location=NULL){
@@ -145,7 +153,7 @@ 
 			if($api["needBucket"]){
 				throw new Ks3ClientException($method." this api need bucket");
 			}
-		}else{
+		} else{
 			$request->bucket = $args["Bucket"];
 		}
 		$position = "Key";
@@ -157,7 +165,7 @@ 
 			if($api["needObject"]){
 				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";
@@ -170,16 +178,17 @@ 
 		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
-			$request->scheme="http://";
+		if(KS3_API_USE_HTTPS) {
+					$request->scheme="https://";
+		} else {
+					$request->scheme="http://";
+		}
 		$request->endpoint=$this->endpoint;
 		//add subresource
 		if(!empty($api["subResource"])){
@@ -200,7 +209,7 @@ 
 				foreach ($index as $key1 => $value1) {
 					if(!isset($curIndexArg[$value1])&&$value1 !== "*"){
 						$add = FALSE;
-					}else{
+					} else{
 						$curkey = $value1;
 						//星号表示所有,按照暂时的业务，默认星号后面就没了
 						if($curkey == "*"){
@@ -212,7 +221,7 @@ 
 							$add = FALSE;
 							$required = FALSE;
 							break;
-						}else{
+						} else{
 							$curIndexArg = $curIndexArg[$value1];
 						}
 					}
@@ -221,8 +230,9 @@ 
 					$request->addQueryParams($curkey,$curIndexArg);
 					continue;
 				}
-				if($required)
-					throw new Ks3ClientException($method." param ".$value." is required");
+				if($required) {
+									throw new Ks3ClientException($method." param ".$value." is required");
+				}
 			}
 		}
 		if(isset($api["body"])){
@@ -230,7 +240,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;
@@ -239,7 +249,7 @@ 
 				foreach ($index as $key1 => $value1) {
 					if(!isset($curIndexArg[$value1])){
 						$add = FALSE;
-					}else{
+					} else{
 						$curIndexArg = $curIndexArg[$value1];
 						$curkey = $value1;
 					}
@@ -267,11 +277,13 @@ 
 
 		if($signer===NULL||!($signer instanceof QueryAuthSigner)){
 			$url = $request->toUrl($this->endpoint);
-			if($location!=NULL)
-				$url = $location;
+			if($location!=NULL) {
+							$url = $location;
+			}
 			$httpRequest = new RequestCore($url);
-			if(KS3_API_DEBUG_MODE===TRUE)
-				$httpRequest->debug_mode=TRUE;
+			if(KS3_API_DEBUG_MODE===TRUE) {
+							$httpRequest->debug_mode=TRUE;
+			}
 			$httpRequest->set_method($request->method);
 			foreach ($request->headers as $key => $value) {
 				$httpRequest->add_header($key,$value);
@@ -330,7 +342,7 @@ 
 				$data = $handler->handle($data);
 			}
 			return $data;
-		}else{
+		} else{
 			$url = $request->toUrl($this->endpoint);
 			$holder->msg.=$url."\r\n";
 			return $url;