GC0202 / ThinkLibrary

src/service/ksyun/bin/lib/RequestCore.class.php

Indentation +999 added lines, -999 removed lines

@@ -13,958 +13,958 @@ 
  */
 class RequestCore
 {
-	/**
-	 * The URL being requested.
-	 */
-	public $request_url;
-
-	/**
-	 * The headers being sent in the request.
-	 */
-	public $request_headers;
-
-	/**
-	 * The body being sent in the request.
-	 */
-	public $request_body;
-
-	/**
-	 * The response returned by the request.
-	 */
-	public $response;
-
-	/**
-	 * The headers returned by the request.
-	 */
-	public $response_headers;
-
-	/**
-	 * The body returned by the request.
-	 */
-	public $response_body;
-
-	/**
-	 * The HTTP status code returned by the request.
-	 */
-	public $response_code;
-
-	/**
-	 * Additional response data.
-	 */
-	public $response_info;
-
-	/**
-	 * The handle for the cURL object.
-	 */
-	public $curl_handle;
-
-	/**
-	 * The method by which the request is being made.
-	 */
-	public $method;
-
-	/**
-	 * Stores the proxy settings to use for the request.
-	 */
-	public $proxy = null;
-
-	/**
-	 * The username to use for the request.
-	 */
-	public $username = null;
-
-	/**
-	 * The password to use for the request.
-	 */
-	public $password = null;
-
-	/**
-	 * Custom CURLOPT settings.
-	 */
-	public $curlopts = null;
-
-	/**
-	 * The state of debug mode.
-	 */
-	public $debug_mode = false;
-
-	/**
-	 * The default class to use for HTTP Requests (defaults to <RequestCore>).
-	 */
-	public $request_class = 'RequestCore';
-
-	/**
-	 * The default class to use for HTTP Responses (defaults to <ResponseCore>).
-	 */
-	public $response_class = 'ResponseCore';
-
-	/**
-	 * Default useragent string to use.
-	 */
-	public $useragent = 'RequestCore/1.4.3';
-
-	/**
-	 * File to read from while streaming up.
-	 */
-	public $read_file = null;
-
-	/**
-	 * The resource to read from while streaming up.
-	 */
-	public $read_stream = null;
-
-	/**
-	 * The size of the stream to read from.
-	 */
-	public $read_stream_size = null;
-
-	/**
-	 * The length already read from the stream.
-	 */
-	public $read_stream_read = 0;
-
-	/**
-	 * File to write to while streaming down.
-	 */
-	public $write_file = null;
-
-	/**
-	 * The resource to write to while streaming down.
-	 */
-	public $write_stream = null;
-
-	/**
-	 * Stores the intended starting seek position.
-	 */
-	public $seek_position = null;
-
-	/**
-	 * The location of the cacert.pem file to use.
-	 */
-	public $cacert_location = false;
-
-	/**
-	 * The state of SSL certificate verification.
-	 */
-	public $ssl_verification = true;
-
-	/**
-	 * The user-defined callback function to call when a stream is read from.
-	 */
-	public $registered_streaming_read_callback = null;
-
-	/**
-	 * The user-defined callback function to call when a stream is written to.
-	 */
-	public $registered_streaming_write_callback = null;
-
-	/*%******************************************************************************************%*/
-	// CONSTANTS
-
-	/**
-	 * GET HTTP Method
-	 */
-	const HTTP_GET = 'GET';
-
-	/**
-	 * POST HTTP Method
-	 */
-	const HTTP_POST = 'POST';
-
-	/**
-	 * PUT HTTP Method
-	 */
-	const HTTP_PUT = 'PUT';
-
-	/**
-	 * DELETE HTTP Method
-	 */
-	const HTTP_DELETE = 'DELETE';
-
-	/**
-	 * HEAD HTTP Method
-	 */
-	const HTTP_HEAD = 'HEAD';
-
-
-	/*%******************************************************************************************%*/
-	// CONSTRUCTOR/DESTRUCTOR
-
-	/**
-	 * Constructs a new instance of this class.
-	 *
-	 * @param string $url (Optional) The URL to request or service endpoint to query.
-	 * @param string $proxy (Optional) The faux-url to use for proxy settings. Takes the following format: `proxy://user:pass@hostname:port`
-	 * @param array $helpers (Optional) An associative array of classnames to use for request, and response functionality. Gets passed in automatically by the calling class.
-	 * @return $this A reference to the current instance.
-	 */
-	public function __construct($url = null, $proxy = null, $helpers = null)
-	{
-		// Set some default values.
-		$this->request_url = $url;
-		$this->method = self::HTTP_GET;
-		$this->request_headers = array();
-		$this->request_body = '';
-
-		// Set a new Request class if one was set.
-		if (isset($helpers['request']) && !empty($helpers['request']))
-		{
-			$this->request_class = $helpers['request'];
-		}
-
-		// Set a new Request class if one was set.
-		if (isset($helpers['response']) && !empty($helpers['response']))
-		{
-			$this->response_class = $helpers['response'];
-		}
-
-		if ($proxy)
-		{
-			$this->set_proxy($proxy);
-		}
-
-		return $this;
-	}
-
-	/**
-	 * Destructs the instance. Closes opened file handles.
-	 *
-	 * @return $this A reference to the current instance.
-	 */
-	public function __destruct()
-	{
-		if (isset($this->read_file) && isset($this->read_stream))
-		{
-			fclose($this->read_stream);
-		}
-
-		if (isset($this->write_file) && isset($this->write_stream))
-		{
-			fclose($this->write_stream);
-		}
-
-		return $this;
-	}
-
-
-	/*%******************************************************************************************%*/
-	// REQUEST METHODS
-
-	/**
-	 * Sets the credentials to use for authentication.
-	 *
-	 * @param string $user (Required) The username to authenticate with.
-	 * @param string $pass (Required) The password to authenticate with.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_credentials($user, $pass)
-	{
-		$this->username = $user;
-		$this->password = $pass;
-		return $this;
-	}
-
-	/**
-	 * Adds a custom HTTP header to the cURL request.
-	 *
-	 * @param string $key (Required) The custom HTTP header to set.
-	 * @param mixed $value (Required) The value to assign to the custom HTTP header.
-	 * @return $this A reference to the current instance.
-	 */
-	public function add_header($key, $value)
-	{
-		$this->request_headers[$key] = $value;
-		return $this;
-	}
-
-	/**
-	 * Removes an HTTP header from the cURL request.
-	 *
-	 * @param string $key (Required) The custom HTTP header to set.
-	 * @return $this A reference to the current instance.
-	 */
-	public function remove_header($key)
-	{
-		if (isset($this->request_headers[$key]))
-		{
-			unset($this->request_headers[$key]);
-		}
-		return $this;
-	}
-
-	/**
-	 * Set the method type for the request.
-	 *
-	 * @param string $method (Required) One of the following constants: <HTTP_GET>, <HTTP_POST>, <HTTP_PUT>, <HTTP_HEAD>, <HTTP_DELETE>.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_method($method)
-	{
-		$this->method = strtoupper($method);
-		return $this;
-	}
-
-	/**
-	 * Sets a custom useragent string for the class.
-	 *
-	 * @param string $ua (Required) The useragent string to use.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_useragent($ua)
-	{
-		$this->useragent = $ua;
-		return $this;
-	}
-
-	/**
-	 * Set the body to send in the request.
-	 *
-	 * @param string $body (Required) The textual content to send along in the body of the request.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_body($body)
-	{
-		$this->request_body = $body;
-		return $this;
-	}
-
-	/**
-	 * Set the URL to make the request to.
-	 *
-	 * @param string $url (Required) The URL to make the request to.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_request_url($url)
-	{
-		$this->request_url = $url;
-		return $this;
-	}
-
-	/**
-	 * Set additional CURLOPT settings. These will merge with the default settings, and override if
-	 * there is a duplicate.
-	 *
-	 * @param array $curlopts (Optional) A set of key-value pairs that set `CURLOPT` options. These will merge with the existing CURLOPTs, and ones passed here will override the defaults. Keys should be the `CURLOPT_*` constants, not strings.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_curlopts($curlopts)
-	{
-		$this->curlopts = $curlopts;
-		return $this;
-	}
-
-	/**
-	 * Sets the length in bytes to read from the stream while streaming up.
-	 *
-	 * @param integer $size (Required) The length in bytes to read from the stream.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_read_stream_size($size)
-	{
-		$this->read_stream_size = $size;
-
-		return $this;
-	}
-
-	/**
-	 * Sets the resource to read from while streaming up. Reads the stream from its current position until
-	 * EOF or `$size` bytes have been read. If `$size` is not given it will be determined by <php:fstat()> and
-	 * <php:ftell()>.
-	 *
-	 * @param resource $resource (Required) The readable resource to read from.
-	 * @param integer $size (Optional) The size of the stream to read.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_read_stream($resource, $size = null)
-	{
-		if (!isset($size) || $size < 0)
-		{
-			$stats = fstat($resource);
-
-			if ($stats && $stats['size'] >= 0)
-			{
-				$position = ftell($resource);
-
-				if ($position !== false && $position >= 0)
-				{
-					$size = $stats['size'] - $position;
-				}
-			}
-		}
-
-		$this->read_stream = $resource;
-
-		return $this->set_read_stream_size($size);
-	}
-
-	/**
-	 * Sets the file to read from while streaming up.
-	 *
-	 * @param string $location (Required) The readable location to read from.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_read_file($location)
-	{
-		$this->read_file = $location;
-		$read_file_handle = fopen($location, 'r');
-
-		return $this->set_read_stream($read_file_handle);
-	}
-
-	/**
-	 * Sets the resource to write to while streaming down.
-	 *
-	 * @param resource $resource (Required) The writeable resource to write to.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_write_stream($resource)
-	{
-		$this->write_stream = $resource;
-
-		return $this;
-	}
-
-	/**
-	 * Sets the file to write to while streaming down.
-	 *
-	 * @param string $location (Required) The writeable location to write to.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_write_file($location)
-	{
-		$this->write_file = $location;
-		$write_file_handle = fopen($location, 'w');
-
-		return $this->set_write_stream($write_file_handle);
-	}
-
-	/**
-	 * Set the proxy to use for making requests.
-	 *
-	 * @param string $proxy (Required) The faux-url to use for proxy settings. Takes the following format: `proxy://user:pass@hostname:port`
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_proxy($proxy)
-	{
-		$proxy = parse_url($proxy);
-		$proxy['user'] = isset($proxy['user']) ? $proxy['user'] : null;
-		$proxy['pass'] = isset($proxy['pass']) ? $proxy['pass'] : null;
-		$proxy['port'] = isset($proxy['port']) ? $proxy['port'] : null;
-		$this->proxy = $proxy;
-		return $this;
-	}
-
-	/**
-	 * Set the intended starting seek position.
-	 *
-	 * @param integer $position (Required) The byte-position of the stream to begin reading from.
-	 * @return $this A reference to the current instance.
-	 */
-	public function set_seek_position($position)
-	{
-		$this->seek_position = isset($position) ? (integer) $position : null;
-
-		return $this;
-	}
-
-	/**
-	 * Register a callback function to execute whenever a data stream is read from using
-	 * <CFRequest::streaming_read_callback()>.
-	 *
-	 * The user-defined callback function should accept three arguments:
-	 *
-	 * <ul>
-	 * 	<li><code>$curl_handle</code> - <code>resource</code> - Required - The cURL handle resource that represents the in-progress transfer.</li>
-	 * 	<li><code>$file_handle</code> - <code>resource</code> - Required - The file handle resource that represents the file on the local file system.</li>
-	 * 	<li><code>$length</code> - <code>integer</code> - Required - The length in kilobytes of the data chunk that was transferred.</li>
-	 * </ul>
-	 *
-	 * @param string|array|function $callback (Required) The callback function is called by <php:call_user_func()>, so you can pass the following values: <ul>
-	 * 	<li>The name of a global function to execute, passed as a string.</li>
-	 * 	<li>A method to execute, passed as <code>array('ClassName', 'MethodName')</code>.</li>
-	 * 	<li>An anonymous function (PHP 5.3+).</li></ul>
-	 * @return $this A reference to the current instance.
-	 */
-	public function register_streaming_read_callback($callback)
-	{
-		$this->registered_streaming_read_callback = $callback;
-
-		return $this;
-	}
-
-	/**
-	 * Register a callback function to execute whenever a data stream is written to using
-	 * <CFRequest::streaming_write_callback()>.
-	 *
-	 * The user-defined callback function should accept two arguments:
-	 *
-	 * <ul>
-	 * 	<li><code>$curl_handle</code> - <code>resource</code> - Required - The cURL handle resource that represents the in-progress transfer.</li>
-	 * 	<li><code>$length</code> - <code>integer</code> - Required - The length in kilobytes of the data chunk that was transferred.</li>
-	 * </ul>
-	 *
-	 * @param string|array|function $callback (Required) The callback function is called by <php:call_user_func()>, so you can pass the following values: <ul>
-	 * 	<li>The name of a global function to execute, passed as a string.</li>
-	 * 	<li>A method to execute, passed as <code>array('ClassName', 'MethodName')</code>.</li>
-	 * 	<li>An anonymous function (PHP 5.3+).</li></ul>
-	 * @return $this A reference to the current instance.
-	 */
-	public function register_streaming_write_callback($callback)
-	{
-		$this->registered_streaming_write_callback = $callback;
-
-		return $this;
-	}
-
-
-	/*%******************************************************************************************%*/
-	// PREPARE, SEND, AND PROCESS REQUEST
-
-	/**
-	 * A callback function that is invoked by cURL for streaming up.
-	 *
-	 * @param resource $curl_handle (Required) The cURL handle for the request.
-	 * @param resource $file_handle (Required) The open file handle resource.
-	 * @param integer $length (Required) The maximum number of bytes to read.
-	 * @return binary Binary data from a stream.
-	 */
-	public function streaming_read_callback($curl_handle, $file_handle, $length)
-	{
-		// Execute callback function
-		if ($this->registered_streaming_read_callback)
-		{
-			return $this->registered_streaming_read_callback->streaming_read_callback($curl_handle, $file_handle, $length,$this->read_stream,$this->seek_position);
-		}
-		// Once we've sent as much as we're supposed to send...
-		if ($this->read_stream_read >= $this->read_stream_size)
-		{
-			// Send EOF
-			return '';
-		}
-
-		// If we're at the beginning of an upload and need to seek...
-		if ($this->read_stream_read == 0 && isset($this->seek_position) && $this->seek_position !== ftell($this->read_stream))
-		{
-			if (fseek($this->read_stream, $this->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.');
-			}
-		}
-
-		$read = fread($this->read_stream, min($this->read_stream_size - $this->read_stream_read, $length)); // Remaining upload data or cURL's requested chunk size
-		$this->read_stream_read += strlen($read);
-
-		$out = $read === false ? '' : $read;
-
-		return $out;
-	}
-
-	/**
-	 * A callback function that is invoked by cURL for streaming down.
-	 *
-	 * @param resource $curl_handle (Required) The cURL handle for the request.
-	 * @param binary $data (Required) The data to write.
-	 * @return integer The number of bytes written.
-	 */
-	public function streaming_write_callback($curl_handle, $data)
-	{
-		if ($this->registered_streaming_write_callback){
-			return $this->registered_streaming_write_callback->streaming_write_callback($curl_handle,$data,$this->write_stream);
-		}
-		$length = strlen($data);
-		$written_total = 0;
-		$written_last = 0;
-
-		while ($written_total < $length)
-		{
-			$written_last = fwrite($this->write_stream, substr($data, $written_total));
-
-			if ($written_last === false)
-			{
-				return $written_total;
-			}
-
-			$written_total += $written_last;
-		}
-
-		return $written_total;
-	}
-
-	/**
-	 * Prepares and adds the details of the cURL request. This can be passed along to a <php:curl_multi_exec()>
-	 * function.
-	 *
-	 * @return resource The handle for the cURL object.
-	 */
-	public function prep_request()
-	{
-		$curl_handle = curl_init();
-
-		// Set default options.
-		curl_setopt($curl_handle, CURLOPT_URL, $this->request_url);
-		curl_setopt($curl_handle, CURLOPT_FILETIME, true);
-		curl_setopt($curl_handle, CURLOPT_FRESH_CONNECT, false);
-		//为了兼容PHP 5.6,PHP 5.6把 CURLOPT_CLOSEPOLICY 这个变量删除了
-		//curl_setopt($curl_handle, CURLOPT_CLOSEPOLICY, CURLCLOSEPOLICY_LEAST_RECENTLY_USED);
-		curl_setopt($curl_handle, CURLOPT_MAXREDIRS, 5);
-		curl_setopt($curl_handle, CURLOPT_HEADER, true);
-		curl_setopt($curl_handle, CURLOPT_RETURNTRANSFER, true);
-		curl_setopt($curl_handle, CURLOPT_TIMEOUT, 5184000);
-		curl_setopt($curl_handle, CURLOPT_CONNECTTIMEOUT, 120);
-		curl_setopt($curl_handle, CURLOPT_NOSIGNAL, true);
-		curl_setopt($curl_handle, CURLOPT_REFERER, $this->request_url);
-		curl_setopt($curl_handle, CURLOPT_USERAGENT, $this->useragent);
-		curl_setopt($curl_handle, CURLOPT_READFUNCTION, array($this, 'streaming_read_callback'));
-
-		// Verification of the SSL cert
-		if ($this->ssl_verification)
-		{
-			curl_setopt($curl_handle, CURLOPT_SSL_VERIFYPEER, true);
-			curl_setopt($curl_handle, CURLOPT_SSL_VERIFYHOST, 2);
-		}
-		else
-		{
-			curl_setopt($curl_handle, CURLOPT_SSL_VERIFYPEER, false);
-			curl_setopt($curl_handle, CURLOPT_SSL_VERIFYHOST, false);
-		}
-
-		// chmod the file as 0755
-		if ($this->cacert_location === true)
-		{
-			curl_setopt($curl_handle, CURLOPT_CAINFO, dirname(__FILE__) . '/cacert.pem');
-		}
-		elseif (is_string($this->cacert_location))
-		{
-			curl_setopt($curl_handle, CURLOPT_CAINFO, $this->cacert_location);
-		}
-
-		// Debug mode
-		if ($this->debug_mode)
-		{
-			curl_setopt($curl_handle, CURLOPT_VERBOSE, true);
-		}
-
-		// Handle open_basedir & safe mode
-		if (!ini_get('safe_mode') && !ini_get('open_basedir'))
-		{
-			curl_setopt($curl_handle, CURLOPT_FOLLOWLOCATION, FALSE);
-		}
-
-		// Enable a proxy connection if requested.
-		if ($this->proxy)
-		{
-			curl_setopt($curl_handle, CURLOPT_HTTPPROXYTUNNEL, true);
-
-			$host = $this->proxy['host'];
-			$host .= ($this->proxy['port']) ? ':' . $this->proxy['port'] : '';
-			curl_setopt($curl_handle, CURLOPT_PROXY, $host);
-
-			if (isset($this->proxy['user']) && isset($this->proxy['pass']))
-			{
-				curl_setopt($curl_handle, CURLOPT_PROXYUSERPWD, $this->proxy['user'] . ':' . $this->proxy['pass']);
-			}
-		}
-
-		// Set credentials for HTTP Basic/Digest Authentication.
-		if ($this->username && $this->password)
-		{
-			curl_setopt($curl_handle, CURLOPT_HTTPAUTH, CURLAUTH_ANY);
-			curl_setopt($curl_handle, CURLOPT_USERPWD, $this->username . ':' . $this->password);
-		}
-
-		// Handle the encoding if we can.
-		if (extension_loaded('zlib'))
-		{
-			curl_setopt($curl_handle, CURLOPT_ENCODING, '');
-		}
-
-		// Process custom headers
-		if (isset($this->request_headers) && count($this->request_headers))
-		{
-			$temp_headers = array();
-
-			foreach ($this->request_headers as $k => $v)
-			{
-				$temp_headers[] = $k . ': ' . $v;
-			}
-
-			curl_setopt($curl_handle, CURLOPT_HTTPHEADER, $temp_headers);
-		}
-
-		switch ($this->method)
-		{
-			case self::HTTP_PUT:
-				//unset($this->read_stream);
-				curl_setopt($curl_handle, CURLOPT_CUSTOMREQUEST, 'PUT');
-				if (isset($this->read_stream))
-				{
-					if (!isset($this->read_stream_size) || $this->read_stream_size < 0)
-					{
-						throw new RequestCore_Exception('The stream size for the streaming upload cannot be determined.');
-					}
-
-					curl_setopt($curl_handle, CURLOPT_INFILESIZE, $this->read_stream_size);
-					curl_setopt($curl_handle, CURLOPT_UPLOAD, true);
-				}
-				else
-				{
-					curl_setopt($curl_handle, CURLOPT_POSTFIELDS, $this->request_body);
-				}
-				break;
-
-			case self::HTTP_POST:
-				curl_setopt($curl_handle, CURLOPT_POST, true);
-				curl_setopt($curl_handle, CURLOPT_POSTFIELDS, $this->request_body);
-				break;
-
-			case self::HTTP_HEAD:
-				curl_setopt($curl_handle, CURLOPT_CUSTOMREQUEST, self::HTTP_HEAD);
-				curl_setopt($curl_handle, CURLOPT_NOBODY, 1);
-				break;
-
-			default: // Assumed GET
-				curl_setopt($curl_handle, CURLOPT_CUSTOMREQUEST, $this->method);
-				if (isset($this->write_stream))
-				{
-					curl_setopt($curl_handle, CURLOPT_WRITEFUNCTION, array($this, 'streaming_write_callback'));
-					curl_setopt($curl_handle, CURLOPT_HEADER, false);
-				}
-				else
-				{
-					curl_setopt($curl_handle, CURLOPT_POSTFIELDS, $this->request_body);
-				}
-				break;
-		}
-
-		// Merge in the CURLOPTs
-		if (isset($this->curlopts) && sizeof($this->curlopts) > 0)
-		{
-			foreach ($this->curlopts as $k => $v)
-			{
-				curl_setopt($curl_handle, $k, $v);
-			}
-		}
-
-		return $curl_handle;
-	}
-
-	/**
-	 * Take the post-processed cURL data and break it down into useful header/body/info chunks. Uses the
-	 * data stored in the `curl_handle` and `response` properties unless replacement data is passed in via
-	 * parameters.
-	 *
-	 * @param resource $curl_handle (Optional) The reference to the already executed cURL request.
-	 * @param string $response (Optional) The actual response content itself that needs to be parsed.
-	 * @return ResponseCore A <ResponseCore> object containing a parsed HTTP response.
-	 */
-	public function process_response($curl_handle = null, $response = null)
-	{
-		// Accept a custom one if it's passed.
-		if ($curl_handle && $response)
-		{
-			$this->curl_handle = $curl_handle;
-			$this->response = $response;
-		}
-
-		// As long as this came back as a valid resource...
-		if (is_resource($this->curl_handle))
-		{
-			// Determine what's what.
-			$header_size = curl_getinfo($this->curl_handle, CURLINFO_HEADER_SIZE);
-			$this->response_headers = substr($this->response, 0, $header_size);
-			$this->response_body = substr($this->response, $header_size);
-			$this->response_code = curl_getinfo($this->curl_handle, CURLINFO_HTTP_CODE);
-			$this->response_info = curl_getinfo($this->curl_handle);
-
-			// Parse out the headers
-			$this->response_headers = explode("\r\n\r\n", trim($this->response_headers));
-			$this->response_headers = array_pop($this->response_headers);
-			$this->response_headers = explode("\r\n", $this->response_headers);
-			array_shift($this->response_headers);
-
-			// Loop through and split up the headers.
-			$header_assoc = array();
-			foreach ($this->response_headers as $header)
-			{
-				$kv = explode(': ', $header);
-				$header_assoc[strtolower($kv[0])] = isset($kv[1])?$kv[1]:'';
-			}
-
-			// Reset the headers to the appropriate property.
-			$this->response_headers = $header_assoc;
-			$this->response_headers['_info'] = $this->response_info;
-			$this->response_headers['_info']['method'] = $this->method;
-
-			if ($curl_handle && $response)
-			{
-				return new $this->response_class($this->response_headers, $this->response_body, $this->response_code, $this->curl_handle);
-			}
-		}
-
-		// Return false
-		return false;
-	}
-
-	/**
-	 * Sends the request, calling necessary utility functions to update built-in properties.
-	 *
-	 * @param boolean $parse (Optional) Whether to parse the response with ResponseCore or not.
-	 * @return string The resulting unparsed data from the request.
-	 */
-	public function send_request($parse = false)
-	{
-		set_time_limit(0);
-
-		$curl_handle = $this->prep_request();
-		$this->response = curl_exec($curl_handle);
-
-		if ($this->response === false)
-		{
-			throw new RequestCore_Exception('cURL resource: ' . (string) $curl_handle . '; cURL error: ' . curl_error($curl_handle) . ' (' . curl_errno($curl_handle) . ')');
-		}
-
-		$parsed_response = $this->process_response($curl_handle, $this->response);
-
-		curl_close($curl_handle);
-
-		if ($parse)
-		{
-			return $parsed_response;
-		}
-
-		return $this->response;
-	}
-
-	/**
-	 * Sends the request using <php:curl_multi_exec()>, enabling parallel requests. Uses the "rolling" method.
-	 *
-	 * @param array $handles (Required) An indexed array of cURL handles to process simultaneously.
-	 * @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
-	 * 	<li><code>callback</code> - <code>string|array</code> - Optional - The string name of a function to pass the response data to. If this is a method, pass an array where the <code>[0]</code> index is the class and the <code>[1]</code> index is the method name.</li>
-	 * 	<li><code>limit</code> - <code>integer</code> - Optional - The number of simultaneous requests to make. This can be useful for scaling around slow server responses. Defaults to trusting cURLs judgement as to how many to use.</li></ul>
-	 * @return array Post-processed cURL responses.
-	 */
-	public function send_multi_request($handles, $opt = null)
-	{
-		set_time_limit(0);
-
-		// Skip everything if there are no handles to process.
-		if (count($handles) === 0) return array();
-
-		if (!$opt) $opt = array();
-
-		// Initialize any missing options
-		$limit = isset($opt['limit']) ? $opt['limit'] : -1;
-
-		// Initialize
-		$handle_list = $handles;
-		$http = new $this->request_class();
-		$multi_handle = curl_multi_init();
-		$handles_post = array();
-		$added = count($handles);
-		$last_handle = null;
-		$count = 0;
-		$i = 0;
-
-		// Loop through the cURL handles and add as many as it set by the limit parameter.
-		while ($i < $added)
-		{
-			if ($limit > 0 && $i >= $limit) break;
-			curl_multi_add_handle($multi_handle, array_shift($handles));
-			$i++;
-		}
-
-		do
-		{
-			$active = false;
-
-			// Start executing and wait for a response.
-			while (($status = curl_multi_exec($multi_handle, $active)) === CURLM_CALL_MULTI_PERFORM)
-			{
-				// Start looking for possible responses immediately when we have to add more handles
-				if (count($handles) > 0) break;
-			}
-
-			// Figure out which requests finished.
-			$to_process = array();
-
-			while ($done = curl_multi_info_read($multi_handle))
-			{
-				// Since curl_errno() isn't reliable for handles that were in multirequests, we check the 'result' of the info read, which contains the curl error number, (listed here http://curl.haxx.se/libcurl/c/libcurl-errors.html )
-				if ($done['result'] > 0)
-				{
-					throw new RequestCore_Exception('cURL resource: ' . (string) $done['handle'] . '; cURL error: ' . curl_error($done['handle']) . ' (' . $done['result'] . ')');
-				}
-
-				// Because curl_multi_info_read() might return more than one message about a request, we check to see if this request is already in our array of completed requests
-				elseif (!isset($to_process[(int) $done['handle']]))
-				{
-					$to_process[(int) $done['handle']] = $done;
-				}
-			}
-
-			// Actually deal with the request
-			foreach ($to_process as $pkey => $done)
-			{
-				$response = $http->process_response($done['handle'], curl_multi_getcontent($done['handle']));
-				$key = array_search($done['handle'], $handle_list, true);
-				$handles_post[$key] = $response;
-
-				if (count($handles) > 0)
-				{
-					curl_multi_add_handle($multi_handle, array_shift($handles));
-				}
-
-				curl_multi_remove_handle($multi_handle, $done['handle']);
-				curl_close($done['handle']);
-			}
-		}
-		while ($active || count($handles_post) < $added);
-
-		curl_multi_close($multi_handle);
-
-		ksort($handles_post, SORT_NUMERIC);
-		return $handles_post;
-	}
-
-
-	/*%******************************************************************************************%*/
-	// RESPONSE METHODS
-
-	/**
-	 * Get the HTTP response headers from the request.
-	 *
-	 * @param string $header (Optional) A specific header value to return. Defaults to all headers.
-	 * @return string|array All or selected header values.
-	 */
-	public function get_response_header($header = null)
-	{
-		if ($header)
-		{
-			return $this->response_headers[strtolower($header)];
-		}
-		return $this->response_headers;
-	}
-
-	/**
-	 * Get the HTTP response body from the request.
-	 *
-	 * @return string The response body.
-	 */
-	public function get_response_body()
-	{
-		return $this->response_body;
-	}
-
-	/**
-	 * Get the HTTP response code from the request.
-	 *
-	 * @return string The HTTP response code.
-	 */
-	public function get_response_code()
-	{
-		return $this->response_code;
-	}
+    /**
+     * The URL being requested.
+     */
+    public $request_url;
+
+    /**
+     * The headers being sent in the request.
+     */
+    public $request_headers;
+
+    /**
+     * The body being sent in the request.
+     */
+    public $request_body;
+
+    /**
+     * The response returned by the request.
+     */
+    public $response;
+
+    /**
+     * The headers returned by the request.
+     */
+    public $response_headers;
+
+    /**
+     * The body returned by the request.
+     */
+    public $response_body;
+
+    /**
+     * The HTTP status code returned by the request.
+     */
+    public $response_code;
+
+    /**
+     * Additional response data.
+     */
+    public $response_info;
+
+    /**
+     * The handle for the cURL object.
+     */
+    public $curl_handle;
+
+    /**
+     * The method by which the request is being made.
+     */
+    public $method;
+
+    /**
+     * Stores the proxy settings to use for the request.
+     */
+    public $proxy = null;
+
+    /**
+     * The username to use for the request.
+     */
+    public $username = null;
+
+    /**
+     * The password to use for the request.
+     */
+    public $password = null;
+
+    /**
+     * Custom CURLOPT settings.
+     */
+    public $curlopts = null;
+
+    /**
+     * The state of debug mode.
+     */
+    public $debug_mode = false;
+
+    /**
+     * The default class to use for HTTP Requests (defaults to <RequestCore>).
+     */
+    public $request_class = 'RequestCore';
+
+    /**
+     * The default class to use for HTTP Responses (defaults to <ResponseCore>).
+     */
+    public $response_class = 'ResponseCore';
+
+    /**
+     * Default useragent string to use.
+     */
+    public $useragent = 'RequestCore/1.4.3';
+
+    /**
+     * File to read from while streaming up.
+     */
+    public $read_file = null;
+
+    /**
+     * The resource to read from while streaming up.
+     */
+    public $read_stream = null;
+
+    /**
+     * The size of the stream to read from.
+     */
+    public $read_stream_size = null;
+
+    /**
+     * The length already read from the stream.
+     */
+    public $read_stream_read = 0;
+
+    /**
+     * File to write to while streaming down.
+     */
+    public $write_file = null;
+
+    /**
+     * The resource to write to while streaming down.
+     */
+    public $write_stream = null;
+
+    /**
+     * Stores the intended starting seek position.
+     */
+    public $seek_position = null;
+
+    /**
+     * The location of the cacert.pem file to use.
+     */
+    public $cacert_location = false;
+
+    /**
+     * The state of SSL certificate verification.
+     */
+    public $ssl_verification = true;
+
+    /**
+     * The user-defined callback function to call when a stream is read from.
+     */
+    public $registered_streaming_read_callback = null;
+
+    /**
+     * The user-defined callback function to call when a stream is written to.
+     */
+    public $registered_streaming_write_callback = null;
+
+    /*%******************************************************************************************%*/
+    // CONSTANTS
+
+    /**
+     * GET HTTP Method
+     */
+    const HTTP_GET = 'GET';
+
+    /**
+     * POST HTTP Method
+     */
+    const HTTP_POST = 'POST';
+
+    /**
+     * PUT HTTP Method
+     */
+    const HTTP_PUT = 'PUT';
+
+    /**
+     * DELETE HTTP Method
+     */
+    const HTTP_DELETE = 'DELETE';
+
+    /**
+     * HEAD HTTP Method
+     */
+    const HTTP_HEAD = 'HEAD';
+
+
+    /*%******************************************************************************************%*/
+    // CONSTRUCTOR/DESTRUCTOR
+
+    /**
+     * Constructs a new instance of this class.
+     *
+     * @param string $url (Optional) The URL to request or service endpoint to query.
+     * @param string $proxy (Optional) The faux-url to use for proxy settings. Takes the following format: `proxy://user:pass@hostname:port`
+     * @param array $helpers (Optional) An associative array of classnames to use for request, and response functionality. Gets passed in automatically by the calling class.
+     * @return $this A reference to the current instance.
+     */
+    public function __construct($url = null, $proxy = null, $helpers = null)
+    {
+        // Set some default values.
+        $this->request_url = $url;
+        $this->method = self::HTTP_GET;
+        $this->request_headers = array();
+        $this->request_body = '';
+
+        // Set a new Request class if one was set.
+        if (isset($helpers['request']) && !empty($helpers['request']))
+        {
+            $this->request_class = $helpers['request'];
+        }
+
+        // Set a new Request class if one was set.
+        if (isset($helpers['response']) && !empty($helpers['response']))
+        {
+            $this->response_class = $helpers['response'];
+        }
+
+        if ($proxy)
+        {
+            $this->set_proxy($proxy);
+        }
+
+        return $this;
+    }
+
+    /**
+     * Destructs the instance. Closes opened file handles.
+     *
+     * @return $this A reference to the current instance.
+     */
+    public function __destruct()
+    {
+        if (isset($this->read_file) && isset($this->read_stream))
+        {
+            fclose($this->read_stream);
+        }
+
+        if (isset($this->write_file) && isset($this->write_stream))
+        {
+            fclose($this->write_stream);
+        }
+
+        return $this;
+    }
+
+
+    /*%******************************************************************************************%*/
+    // REQUEST METHODS
+
+    /**
+     * Sets the credentials to use for authentication.
+     *
+     * @param string $user (Required) The username to authenticate with.
+     * @param string $pass (Required) The password to authenticate with.
+     * @return $this A reference to the current instance.
+     */
+    public function set_credentials($user, $pass)
+    {
+        $this->username = $user;
+        $this->password = $pass;
+        return $this;
+    }
+
+    /**
+     * Adds a custom HTTP header to the cURL request.
+     *
+     * @param string $key (Required) The custom HTTP header to set.
+     * @param mixed $value (Required) The value to assign to the custom HTTP header.
+     * @return $this A reference to the current instance.
+     */
+    public function add_header($key, $value)
+    {
+        $this->request_headers[$key] = $value;
+        return $this;
+    }
+
+    /**
+     * Removes an HTTP header from the cURL request.
+     *
+     * @param string $key (Required) The custom HTTP header to set.
+     * @return $this A reference to the current instance.
+     */
+    public function remove_header($key)
+    {
+        if (isset($this->request_headers[$key]))
+        {
+            unset($this->request_headers[$key]);
+        }
+        return $this;
+    }
+
+    /**
+     * Set the method type for the request.
+     *
+     * @param string $method (Required) One of the following constants: <HTTP_GET>, <HTTP_POST>, <HTTP_PUT>, <HTTP_HEAD>, <HTTP_DELETE>.
+     * @return $this A reference to the current instance.
+     */
+    public function set_method($method)
+    {
+        $this->method = strtoupper($method);
+        return $this;
+    }
+
+    /**
+     * Sets a custom useragent string for the class.
+     *
+     * @param string $ua (Required) The useragent string to use.
+     * @return $this A reference to the current instance.
+     */
+    public function set_useragent($ua)
+    {
+        $this->useragent = $ua;
+        return $this;
+    }
+
+    /**
+     * Set the body to send in the request.
+     *
+     * @param string $body (Required) The textual content to send along in the body of the request.
+     * @return $this A reference to the current instance.
+     */
+    public function set_body($body)
+    {
+        $this->request_body = $body;
+        return $this;
+    }
+
+    /**
+     * Set the URL to make the request to.
+     *
+     * @param string $url (Required) The URL to make the request to.
+     * @return $this A reference to the current instance.
+     */
+    public function set_request_url($url)
+    {
+        $this->request_url = $url;
+        return $this;
+    }
+
+    /**
+     * Set additional CURLOPT settings. These will merge with the default settings, and override if
+     * there is a duplicate.
+     *
+     * @param array $curlopts (Optional) A set of key-value pairs that set `CURLOPT` options. These will merge with the existing CURLOPTs, and ones passed here will override the defaults. Keys should be the `CURLOPT_*` constants, not strings.
+     * @return $this A reference to the current instance.
+     */
+    public function set_curlopts($curlopts)
+    {
+        $this->curlopts = $curlopts;
+        return $this;
+    }
+
+    /**
+     * Sets the length in bytes to read from the stream while streaming up.
+     *
+     * @param integer $size (Required) The length in bytes to read from the stream.
+     * @return $this A reference to the current instance.
+     */
+    public function set_read_stream_size($size)
+    {
+        $this->read_stream_size = $size;
+
+        return $this;
+    }
+
+    /**
+     * Sets the resource to read from while streaming up. Reads the stream from its current position until
+     * EOF or `$size` bytes have been read. If `$size` is not given it will be determined by <php:fstat()> and
+     * <php:ftell()>.
+     *
+     * @param resource $resource (Required) The readable resource to read from.
+     * @param integer $size (Optional) The size of the stream to read.
+     * @return $this A reference to the current instance.
+     */
+    public function set_read_stream($resource, $size = null)
+    {
+        if (!isset($size) || $size < 0)
+        {
+            $stats = fstat($resource);
+
+            if ($stats && $stats['size'] >= 0)
+            {
+                $position = ftell($resource);
+
+                if ($position !== false && $position >= 0)
+                {
+                    $size = $stats['size'] - $position;
+                }
+            }
+        }
+
+        $this->read_stream = $resource;
+
+        return $this->set_read_stream_size($size);
+    }
+
+    /**
+     * Sets the file to read from while streaming up.
+     *
+     * @param string $location (Required) The readable location to read from.
+     * @return $this A reference to the current instance.
+     */
+    public function set_read_file($location)
+    {
+        $this->read_file = $location;
+        $read_file_handle = fopen($location, 'r');
+
+        return $this->set_read_stream($read_file_handle);
+    }
+
+    /**
+     * Sets the resource to write to while streaming down.
+     *
+     * @param resource $resource (Required) The writeable resource to write to.
+     * @return $this A reference to the current instance.
+     */
+    public function set_write_stream($resource)
+    {
+        $this->write_stream = $resource;
+
+        return $this;
+    }
+
+    /**
+     * Sets the file to write to while streaming down.
+     *
+     * @param string $location (Required) The writeable location to write to.
+     * @return $this A reference to the current instance.
+     */
+    public function set_write_file($location)
+    {
+        $this->write_file = $location;
+        $write_file_handle = fopen($location, 'w');
+
+        return $this->set_write_stream($write_file_handle);
+    }
+
+    /**
+     * Set the proxy to use for making requests.
+     *
+     * @param string $proxy (Required) The faux-url to use for proxy settings. Takes the following format: `proxy://user:pass@hostname:port`
+     * @return $this A reference to the current instance.
+     */
+    public function set_proxy($proxy)
+    {
+        $proxy = parse_url($proxy);
+        $proxy['user'] = isset($proxy['user']) ? $proxy['user'] : null;
+        $proxy['pass'] = isset($proxy['pass']) ? $proxy['pass'] : null;
+        $proxy['port'] = isset($proxy['port']) ? $proxy['port'] : null;
+        $this->proxy = $proxy;
+        return $this;
+    }
+
+    /**
+     * Set the intended starting seek position.
+     *
+     * @param integer $position (Required) The byte-position of the stream to begin reading from.
+     * @return $this A reference to the current instance.
+     */
+    public function set_seek_position($position)
+    {
+        $this->seek_position = isset($position) ? (integer) $position : null;
+
+        return $this;
+    }
+
+    /**
+     * Register a callback function to execute whenever a data stream is read from using
+     * <CFRequest::streaming_read_callback()>.
+     *
+     * The user-defined callback function should accept three arguments:
+     *
+     * <ul>
+     * 	<li><code>$curl_handle</code> - <code>resource</code> - Required - The cURL handle resource that represents the in-progress transfer.</li>
+     * 	<li><code>$file_handle</code> - <code>resource</code> - Required - The file handle resource that represents the file on the local file system.</li>
+     * 	<li><code>$length</code> - <code>integer</code> - Required - The length in kilobytes of the data chunk that was transferred.</li>
+     * </ul>
+     *
+     * @param string|array|function $callback (Required) The callback function is called by <php:call_user_func()>, so you can pass the following values: <ul>
+     * 	<li>The name of a global function to execute, passed as a string.</li>
+     * 	<li>A method to execute, passed as <code>array('ClassName', 'MethodName')</code>.</li>
+     * 	<li>An anonymous function (PHP 5.3+).</li></ul>
+     * @return $this A reference to the current instance.
+     */
+    public function register_streaming_read_callback($callback)
+    {
+        $this->registered_streaming_read_callback = $callback;
+
+        return $this;
+    }
+
+    /**
+     * Register a callback function to execute whenever a data stream is written to using
+     * <CFRequest::streaming_write_callback()>.
+     *
+     * The user-defined callback function should accept two arguments:
+     *
+     * <ul>
+     * 	<li><code>$curl_handle</code> - <code>resource</code> - Required - The cURL handle resource that represents the in-progress transfer.</li>
+     * 	<li><code>$length</code> - <code>integer</code> - Required - The length in kilobytes of the data chunk that was transferred.</li>
+     * </ul>
+     *
+     * @param string|array|function $callback (Required) The callback function is called by <php:call_user_func()>, so you can pass the following values: <ul>
+     * 	<li>The name of a global function to execute, passed as a string.</li>
+     * 	<li>A method to execute, passed as <code>array('ClassName', 'MethodName')</code>.</li>
+     * 	<li>An anonymous function (PHP 5.3+).</li></ul>
+     * @return $this A reference to the current instance.
+     */
+    public function register_streaming_write_callback($callback)
+    {
+        $this->registered_streaming_write_callback = $callback;
+
+        return $this;
+    }
+
+
+    /*%******************************************************************************************%*/
+    // PREPARE, SEND, AND PROCESS REQUEST
+
+    /**
+     * A callback function that is invoked by cURL for streaming up.
+     *
+     * @param resource $curl_handle (Required) The cURL handle for the request.
+     * @param resource $file_handle (Required) The open file handle resource.
+     * @param integer $length (Required) The maximum number of bytes to read.
+     * @return binary Binary data from a stream.
+     */
+    public function streaming_read_callback($curl_handle, $file_handle, $length)
+    {
+        // Execute callback function
+        if ($this->registered_streaming_read_callback)
+        {
+            return $this->registered_streaming_read_callback->streaming_read_callback($curl_handle, $file_handle, $length,$this->read_stream,$this->seek_position);
+        }
+        // Once we've sent as much as we're supposed to send...
+        if ($this->read_stream_read >= $this->read_stream_size)
+        {
+            // Send EOF
+            return '';
+        }
+
+        // If we're at the beginning of an upload and need to seek...
+        if ($this->read_stream_read == 0 && isset($this->seek_position) && $this->seek_position !== ftell($this->read_stream))
+        {
+            if (fseek($this->read_stream, $this->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.');
+            }
+        }
+
+        $read = fread($this->read_stream, min($this->read_stream_size - $this->read_stream_read, $length)); // Remaining upload data or cURL's requested chunk size
+        $this->read_stream_read += strlen($read);
+
+        $out = $read === false ? '' : $read;
+
+        return $out;
+    }
+
+    /**
+     * A callback function that is invoked by cURL for streaming down.
+     *
+     * @param resource $curl_handle (Required) The cURL handle for the request.
+     * @param binary $data (Required) The data to write.
+     * @return integer The number of bytes written.
+     */
+    public function streaming_write_callback($curl_handle, $data)
+    {
+        if ($this->registered_streaming_write_callback){
+            return $this->registered_streaming_write_callback->streaming_write_callback($curl_handle,$data,$this->write_stream);
+        }
+        $length = strlen($data);
+        $written_total = 0;
+        $written_last = 0;
+
+        while ($written_total < $length)
+        {
+            $written_last = fwrite($this->write_stream, substr($data, $written_total));
+
+            if ($written_last === false)
+            {
+                return $written_total;
+            }
+
+            $written_total += $written_last;
+        }
+
+        return $written_total;
+    }
+
+    /**
+     * Prepares and adds the details of the cURL request. This can be passed along to a <php:curl_multi_exec()>
+     * function.
+     *
+     * @return resource The handle for the cURL object.
+     */
+    public function prep_request()
+    {
+        $curl_handle = curl_init();
+
+        // Set default options.
+        curl_setopt($curl_handle, CURLOPT_URL, $this->request_url);
+        curl_setopt($curl_handle, CURLOPT_FILETIME, true);
+        curl_setopt($curl_handle, CURLOPT_FRESH_CONNECT, false);
+        //为了兼容PHP 5.6,PHP 5.6把 CURLOPT_CLOSEPOLICY 这个变量删除了
+        //curl_setopt($curl_handle, CURLOPT_CLOSEPOLICY, CURLCLOSEPOLICY_LEAST_RECENTLY_USED);
+        curl_setopt($curl_handle, CURLOPT_MAXREDIRS, 5);
+        curl_setopt($curl_handle, CURLOPT_HEADER, true);
+        curl_setopt($curl_handle, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($curl_handle, CURLOPT_TIMEOUT, 5184000);
+        curl_setopt($curl_handle, CURLOPT_CONNECTTIMEOUT, 120);
+        curl_setopt($curl_handle, CURLOPT_NOSIGNAL, true);
+        curl_setopt($curl_handle, CURLOPT_REFERER, $this->request_url);
+        curl_setopt($curl_handle, CURLOPT_USERAGENT, $this->useragent);
+        curl_setopt($curl_handle, CURLOPT_READFUNCTION, array($this, 'streaming_read_callback'));
+
+        // Verification of the SSL cert
+        if ($this->ssl_verification)
+        {
+            curl_setopt($curl_handle, CURLOPT_SSL_VERIFYPEER, true);
+            curl_setopt($curl_handle, CURLOPT_SSL_VERIFYHOST, 2);
+        }
+        else
+        {
+            curl_setopt($curl_handle, CURLOPT_SSL_VERIFYPEER, false);
+            curl_setopt($curl_handle, CURLOPT_SSL_VERIFYHOST, false);
+        }
+
+        // chmod the file as 0755
+        if ($this->cacert_location === true)
+        {
+            curl_setopt($curl_handle, CURLOPT_CAINFO, dirname(__FILE__) . '/cacert.pem');
+        }
+        elseif (is_string($this->cacert_location))
+        {
+            curl_setopt($curl_handle, CURLOPT_CAINFO, $this->cacert_location);
+        }
+
+        // Debug mode
+        if ($this->debug_mode)
+        {
+            curl_setopt($curl_handle, CURLOPT_VERBOSE, true);
+        }
+
+        // Handle open_basedir & safe mode
+        if (!ini_get('safe_mode') && !ini_get('open_basedir'))
+        {
+            curl_setopt($curl_handle, CURLOPT_FOLLOWLOCATION, FALSE);
+        }
+
+        // Enable a proxy connection if requested.
+        if ($this->proxy)
+        {
+            curl_setopt($curl_handle, CURLOPT_HTTPPROXYTUNNEL, true);
+
+            $host = $this->proxy['host'];
+            $host .= ($this->proxy['port']) ? ':' . $this->proxy['port'] : '';
+            curl_setopt($curl_handle, CURLOPT_PROXY, $host);
+
+            if (isset($this->proxy['user']) && isset($this->proxy['pass']))
+            {
+                curl_setopt($curl_handle, CURLOPT_PROXYUSERPWD, $this->proxy['user'] . ':' . $this->proxy['pass']);
+            }
+        }
+
+        // Set credentials for HTTP Basic/Digest Authentication.
+        if ($this->username && $this->password)
+        {
+            curl_setopt($curl_handle, CURLOPT_HTTPAUTH, CURLAUTH_ANY);
+            curl_setopt($curl_handle, CURLOPT_USERPWD, $this->username . ':' . $this->password);
+        }
+
+        // Handle the encoding if we can.
+        if (extension_loaded('zlib'))
+        {
+            curl_setopt($curl_handle, CURLOPT_ENCODING, '');
+        }
+
+        // Process custom headers
+        if (isset($this->request_headers) && count($this->request_headers))
+        {
+            $temp_headers = array();
+
+            foreach ($this->request_headers as $k => $v)
+            {
+                $temp_headers[] = $k . ': ' . $v;
+            }
+
+            curl_setopt($curl_handle, CURLOPT_HTTPHEADER, $temp_headers);
+        }
+
+        switch ($this->method)
+        {
+            case self::HTTP_PUT:
+                //unset($this->read_stream);
+                curl_setopt($curl_handle, CURLOPT_CUSTOMREQUEST, 'PUT');
+                if (isset($this->read_stream))
+                {
+                    if (!isset($this->read_stream_size) || $this->read_stream_size < 0)
+                    {
+                        throw new RequestCore_Exception('The stream size for the streaming upload cannot be determined.');
+                    }
+
+                    curl_setopt($curl_handle, CURLOPT_INFILESIZE, $this->read_stream_size);
+                    curl_setopt($curl_handle, CURLOPT_UPLOAD, true);
+                }
+                else
+                {
+                    curl_setopt($curl_handle, CURLOPT_POSTFIELDS, $this->request_body);
+                }
+                break;
+
+            case self::HTTP_POST:
+                curl_setopt($curl_handle, CURLOPT_POST, true);
+                curl_setopt($curl_handle, CURLOPT_POSTFIELDS, $this->request_body);
+                break;
+
+            case self::HTTP_HEAD:
+                curl_setopt($curl_handle, CURLOPT_CUSTOMREQUEST, self::HTTP_HEAD);
+                curl_setopt($curl_handle, CURLOPT_NOBODY, 1);
+                break;
+
+            default: // Assumed GET
+                curl_setopt($curl_handle, CURLOPT_CUSTOMREQUEST, $this->method);
+                if (isset($this->write_stream))
+                {
+                    curl_setopt($curl_handle, CURLOPT_WRITEFUNCTION, array($this, 'streaming_write_callback'));
+                    curl_setopt($curl_handle, CURLOPT_HEADER, false);
+                }
+                else
+                {
+                    curl_setopt($curl_handle, CURLOPT_POSTFIELDS, $this->request_body);
+                }
+                break;
+        }
+
+        // Merge in the CURLOPTs
+        if (isset($this->curlopts) && sizeof($this->curlopts) > 0)
+        {
+            foreach ($this->curlopts as $k => $v)
+            {
+                curl_setopt($curl_handle, $k, $v);
+            }
+        }
+
+        return $curl_handle;
+    }
+
+    /**
+     * Take the post-processed cURL data and break it down into useful header/body/info chunks. Uses the
+     * data stored in the `curl_handle` and `response` properties unless replacement data is passed in via
+     * parameters.
+     *
+     * @param resource $curl_handle (Optional) The reference to the already executed cURL request.
+     * @param string $response (Optional) The actual response content itself that needs to be parsed.
+     * @return ResponseCore A <ResponseCore> object containing a parsed HTTP response.
+     */
+    public function process_response($curl_handle = null, $response = null)
+    {
+        // Accept a custom one if it's passed.
+        if ($curl_handle && $response)
+        {
+            $this->curl_handle = $curl_handle;
+            $this->response = $response;
+        }
+
+        // As long as this came back as a valid resource...
+        if (is_resource($this->curl_handle))
+        {
+            // Determine what's what.
+            $header_size = curl_getinfo($this->curl_handle, CURLINFO_HEADER_SIZE);
+            $this->response_headers = substr($this->response, 0, $header_size);
+            $this->response_body = substr($this->response, $header_size);
+            $this->response_code = curl_getinfo($this->curl_handle, CURLINFO_HTTP_CODE);
+            $this->response_info = curl_getinfo($this->curl_handle);
+
+            // Parse out the headers
+            $this->response_headers = explode("\r\n\r\n", trim($this->response_headers));
+            $this->response_headers = array_pop($this->response_headers);
+            $this->response_headers = explode("\r\n", $this->response_headers);
+            array_shift($this->response_headers);
+
+            // Loop through and split up the headers.
+            $header_assoc = array();
+            foreach ($this->response_headers as $header)
+            {
+                $kv = explode(': ', $header);
+                $header_assoc[strtolower($kv[0])] = isset($kv[1])?$kv[1]:'';
+            }
+
+            // Reset the headers to the appropriate property.
+            $this->response_headers = $header_assoc;
+            $this->response_headers['_info'] = $this->response_info;
+            $this->response_headers['_info']['method'] = $this->method;
+
+            if ($curl_handle && $response)
+            {
+                return new $this->response_class($this->response_headers, $this->response_body, $this->response_code, $this->curl_handle);
+            }
+        }
+
+        // Return false
+        return false;
+    }
+
+    /**
+     * Sends the request, calling necessary utility functions to update built-in properties.
+     *
+     * @param boolean $parse (Optional) Whether to parse the response with ResponseCore or not.
+     * @return string The resulting unparsed data from the request.
+     */
+    public function send_request($parse = false)
+    {
+        set_time_limit(0);
+
+        $curl_handle = $this->prep_request();
+        $this->response = curl_exec($curl_handle);
+
+        if ($this->response === false)
+        {
+            throw new RequestCore_Exception('cURL resource: ' . (string) $curl_handle . '; cURL error: ' . curl_error($curl_handle) . ' (' . curl_errno($curl_handle) . ')');
+        }
+
+        $parsed_response = $this->process_response($curl_handle, $this->response);
+
+        curl_close($curl_handle);
+
+        if ($parse)
+        {
+            return $parsed_response;
+        }
+
+        return $this->response;
+    }
+
+    /**
+     * Sends the request using <php:curl_multi_exec()>, enabling parallel requests. Uses the "rolling" method.
+     *
+     * @param array $handles (Required) An indexed array of cURL handles to process simultaneously.
+     * @param array $opt (Optional) An associative array of parameters that can have the following keys: <ul>
+     * 	<li><code>callback</code> - <code>string|array</code> - Optional - The string name of a function to pass the response data to. If this is a method, pass an array where the <code>[0]</code> index is the class and the <code>[1]</code> index is the method name.</li>
+     * 	<li><code>limit</code> - <code>integer</code> - Optional - The number of simultaneous requests to make. This can be useful for scaling around slow server responses. Defaults to trusting cURLs judgement as to how many to use.</li></ul>
+     * @return array Post-processed cURL responses.
+     */
+    public function send_multi_request($handles, $opt = null)
+    {
+        set_time_limit(0);
+
+        // Skip everything if there are no handles to process.
+        if (count($handles) === 0) return array();
+
+        if (!$opt) $opt = array();
+
+        // Initialize any missing options
+        $limit = isset($opt['limit']) ? $opt['limit'] : -1;
+
+        // Initialize
+        $handle_list = $handles;
+        $http = new $this->request_class();
+        $multi_handle = curl_multi_init();
+        $handles_post = array();
+        $added = count($handles);
+        $last_handle = null;
+        $count = 0;
+        $i = 0;
+
+        // Loop through the cURL handles and add as many as it set by the limit parameter.
+        while ($i < $added)
+        {
+            if ($limit > 0 && $i >= $limit) break;
+            curl_multi_add_handle($multi_handle, array_shift($handles));
+            $i++;
+        }
+
+        do
+        {
+            $active = false;
+
+            // Start executing and wait for a response.
+            while (($status = curl_multi_exec($multi_handle, $active)) === CURLM_CALL_MULTI_PERFORM)
+            {
+                // Start looking for possible responses immediately when we have to add more handles
+                if (count($handles) > 0) break;
+            }
+
+            // Figure out which requests finished.
+            $to_process = array();
+
+            while ($done = curl_multi_info_read($multi_handle))
+            {
+                // Since curl_errno() isn't reliable for handles that were in multirequests, we check the 'result' of the info read, which contains the curl error number, (listed here http://curl.haxx.se/libcurl/c/libcurl-errors.html )
+                if ($done['result'] > 0)
+                {
+                    throw new RequestCore_Exception('cURL resource: ' . (string) $done['handle'] . '; cURL error: ' . curl_error($done['handle']) . ' (' . $done['result'] . ')');
+                }
+
+                // Because curl_multi_info_read() might return more than one message about a request, we check to see if this request is already in our array of completed requests
+                elseif (!isset($to_process[(int) $done['handle']]))
+                {
+                    $to_process[(int) $done['handle']] = $done;
+                }
+            }
+
+            // Actually deal with the request
+            foreach ($to_process as $pkey => $done)
+            {
+                $response = $http->process_response($done['handle'], curl_multi_getcontent($done['handle']));
+                $key = array_search($done['handle'], $handle_list, true);
+                $handles_post[$key] = $response;
+
+                if (count($handles) > 0)
+                {
+                    curl_multi_add_handle($multi_handle, array_shift($handles));
+                }
+
+                curl_multi_remove_handle($multi_handle, $done['handle']);
+                curl_close($done['handle']);
+            }
+        }
+        while ($active || count($handles_post) < $added);
+
+        curl_multi_close($multi_handle);
+
+        ksort($handles_post, SORT_NUMERIC);
+        return $handles_post;
+    }
+
+
+    /*%******************************************************************************************%*/
+    // RESPONSE METHODS
+
+    /**
+     * Get the HTTP response headers from the request.
+     *
+     * @param string $header (Optional) A specific header value to return. Defaults to all headers.
+     * @return string|array All or selected header values.
+     */
+    public function get_response_header($header = null)
+    {
+        if ($header)
+        {
+            return $this->response_headers[strtolower($header)];
+        }
+        return $this->response_headers;
+    }
+
+    /**
+     * Get the HTTP response body from the request.
+     *
+     * @return string The response body.
+     */
+    public function get_response_body()
+    {
+        return $this->response_body;
+    }
+
+    /**
+     * Get the HTTP response code from the request.
+     *
+     * @return string The HTTP response code.
+     */
+    public function get_response_code()
+    {
+        return $this->response_code;
+    }
 }
 
 
@@ -973,53 +973,53 @@ 
  */
 class ResponseCore
 {
-	/**
-	 * Stores the HTTP header information.
-	 */
-	public $header;
-
-	/**
-	 * Stores the SimpleXML response.
-	 */
-	public $body;
-
-	/**
-	 * Stores the HTTP response code.
-	 */
-	public $status;
-
-	/**
-	 * Constructs a new instance of this class.
-	 *
-	 * @param array $header (Required) Associative array of HTTP headers (typically returned by <RequestCore::get_response_header()>).
-	 * @param string $body (Required) XML-formatted response from AWS.
-	 * @param integer $status (Optional) HTTP response status code from the request.
-	 * @return object Contains an <php:array> `header` property (HTTP headers as an associative array), a <php:SimpleXMLElement> or <php:string> `body` property, and an <php:integer> `status` code.
-	 */
-	public function __construct($header, $body, $status = null)
-	{
-		$this->header = $header;
-		$this->body = $body;
-		$this->status = $status;
-
-		return $this;
-	}
-
-	/**
-	 * Did we receive the status code we expected?
-	 *
-	 * @param integer|array $codes (Optional) The status code(s) to expect. Pass an <php:integer> for a single acceptable value, or an <php:array> of integers for multiple acceptable values.
-	 * @return boolean Whether we received the expected status code or not.
-	 */
-	public function isOK($codes = array(200, 201, 204, 206))
-	{
-		if (is_array($codes))
-		{
-			return in_array($this->status, $codes);
-		}
-
-		return $this->status === $codes;
-	}
+    /**
+     * Stores the HTTP header information.
+     */
+    public $header;
+
+    /**
+     * Stores the SimpleXML response.
+     */
+    public $body;
+
+    /**
+     * Stores the HTTP response code.
+     */
+    public $status;
+
+    /**
+     * Constructs a new instance of this class.
+     *
+     * @param array $header (Required) Associative array of HTTP headers (typically returned by <RequestCore::get_response_header()>).
+     * @param string $body (Required) XML-formatted response from AWS.
+     * @param integer $status (Optional) HTTP response status code from the request.
+     * @return object Contains an <php:array> `header` property (HTTP headers as an associative array), a <php:SimpleXMLElement> or <php:string> `body` property, and an <php:integer> `status` code.
+     */
+    public function __construct($header, $body, $status = null)
+    {
+        $this->header = $header;
+        $this->body = $body;
+        $this->status = $status;
+
+        return $this;
+    }
+
+    /**
+     * Did we receive the status code we expected?
+     *
+     * @param integer|array $codes (Optional) The status code(s) to expect. Pass an <php:integer> for a single acceptable value, or an <php:array> of integers for multiple acceptable values.
+     * @return boolean Whether we received the expected status code or not.
+     */
+    public function isOK($codes = array(200, 201, 204, 206))
+    {
+        if (is_array($codes))
+        {
+            return in_array($this->status, $codes);
+        }
+
+        return $this->status === $codes;
+    }
 }
 
 /**

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

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);
 

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);	
 }

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);	
 }

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));
 }
 ?>

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

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

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