sinacms / MultiHttp

src/Mime.php

Indentation +46 added lines, -46 removed lines

@@ -9,53 +9,53 @@
  */
 class Mime
 {
-    const JSON = 'application/json';
-    const XML = 'application/xml';
-    const XHTML = 'application/html+xml';
-    const FORM = 'application/x-www-form-urlencoded';
-    const UPLOAD = 'multipart/form-data';
-    const PLAIN = 'text/plain';
-    const JS = 'text/javascript';
-    const HTML = 'text/html';
-    const YAML = 'application/x-yaml';
-    const CSV = 'text/csv';
+	const JSON = 'application/json';
+	const XML = 'application/xml';
+	const XHTML = 'application/html+xml';
+	const FORM = 'application/x-www-form-urlencoded';
+	const UPLOAD = 'multipart/form-data';
+	const PLAIN = 'text/plain';
+	const JS = 'text/javascript';
+	const HTML = 'text/html';
+	const YAML = 'application/x-yaml';
+	const CSV = 'text/csv';
 
-    /**
-     * Map short name for a mime type
-     * to a full proper mime type
-     */
-    public static $mimes = array(
-        'json' => self::JSON,
-        'xml' => self::XML,
-        'form' => self::FORM,
-        'plain' => self::PLAIN,
-        'text' => self::PLAIN,
-        'upload' => self::UPLOAD,
-        'html' => self::HTML,
-        'xhtml' => self::XHTML,
-        'js' => self::JS,
-        'javascript' => self::JS,
-        'yaml' => self::YAML,
-        'csv' => self::CSV,
-    );
+	/**
+	 * Map short name for a mime type
+	 * to a full proper mime type
+	 */
+	public static $mimes = array(
+		'json' => self::JSON,
+		'xml' => self::XML,
+		'form' => self::FORM,
+		'plain' => self::PLAIN,
+		'text' => self::PLAIN,
+		'upload' => self::UPLOAD,
+		'html' => self::HTML,
+		'xhtml' => self::XHTML,
+		'js' => self::JS,
+		'javascript' => self::JS,
+		'yaml' => self::YAML,
+		'csv' => self::CSV,
+	);
 
-    /**
-     * Get the full Mime Type name from a "short name".
-     * Returns the short if no mapping was found.
-     * @param string $short_name common name for mime type (e.g. json)
-     * @return string full mime type (e.g. application/json)
-     */
-    public static function getFullMime($short_name)
-    {
-        return array_key_exists($short_name, self::$mimes) ? self::$mimes[$short_name] : $short_name;
-    }
+	/**
+	 * Get the full Mime Type name from a "short name".
+	 * Returns the short if no mapping was found.
+	 * @param string $short_name common name for mime type (e.g. json)
+	 * @return string full mime type (e.g. application/json)
+	 */
+	public static function getFullMime($short_name)
+	{
+		return array_key_exists($short_name, self::$mimes) ? self::$mimes[$short_name] : $short_name;
+	}
 
-    /**
-     * @param string $short_name
-     * @return bool
-     */
-    public static function supportsMimeType($short_name)
-    {
-        return array_key_exists($short_name, self::$mimes);
-    }
+	/**
+	 * @param string $short_name
+	 * @return bool
+	 */
+	public static function supportsMimeType($short_name)
+	{
+		return array_key_exists($short_name, self::$mimes);
+	}
 }

src/MultiRequest.php

Spacing +5 added lines, -5 removed lines

@@ -46,7 +46,7 @@ 
      * @param array $options
      * @return $this
      */
-    public function setDefaults(array $options = array()){
+    public function setDefaults(array $options = array()) {
         $this->defaultOptions = $options;
         return $this;
     }
@@ -68,7 +68,7 @@ 
                 'method' => $method,
                 'url' => $uri,
                 'data' => $payload,
-            ) + $options;
+            )+$options;
         $this->addOptions(array($options));
         return $this;
     }
@@ -81,7 +81,7 @@ 
     public function addOptions(array $URLOptions)
     {
         foreach ($URLOptions as $options) {
-            $options = $options + $this->defaultOptions;
+            $options = $options+$this->defaultOptions;
             $request = Request::create()->addOptions($options)->applyOptions();
             if (isset($options['callback'])) {
                 $request->onEnd($options['callback']);
@@ -110,7 +110,7 @@ 
      */
     public function sendAll()
     {
-        $sleepTime = 1000;//microsecond, prevent  CPU 100%
+        $sleepTime = 1000; //microsecond, prevent  CPU 100%
         do {
             curl_multi_exec(self::$multiHandler, $active);
             // bug in PHP 5.3.18+ where curl_multi_select can return -1
@@ -119,7 +119,7 @@ 
                 usleep($sleepTime);
             }
             usleep($sleepTime);
-        } while ($active);
+        }while ($active);
         $return = array();
         foreach (self::$requestPool as $request) {
             $return[] = $request->send(true);

Indentation +110 added lines, -110 removed lines

@@ -15,121 +15,121 @@
  */
 class MultiRequest
 {
-    /**
-     * @var [Response]
-     */
-    protected static $requestPool = array();
-    protected static $multiHandler;
-    protected $defaultOptions = array();
-    private static $instance;
-    protected static $loggerHandler;
-    /**
-     * MultiRequest constructor.
-     */
-    protected function __construct()
-    {
-    }
+	/**
+	 * @var [Response]
+	 */
+	protected static $requestPool = array();
+	protected static $multiHandler;
+	protected $defaultOptions = array();
+	private static $instance;
+	protected static $loggerHandler;
+	/**
+	 * MultiRequest constructor.
+	 */
+	protected function __construct()
+	{
+	}
 
-    /**
-     * @return MultiRequest
-     */
-    public static function create()
-    {
-        if (!(self::$instance instanceof self)) {
-            self::$instance = new self;
-        }
-        self::prepare();
-        return self::$instance;
-    }
+	/**
+	 * @return MultiRequest
+	 */
+	public static function create()
+	{
+		if (!(self::$instance instanceof self)) {
+			self::$instance = new self;
+		}
+		self::prepare();
+		return self::$instance;
+	}
 
-    /**
-     * @param array $options
-     * @return $this
-     */
-    public function setDefaults(array $options = array()){
-        $this->defaultOptions = $options;
-        return $this;
-    }
-    protected static function prepare()
-    {
-        self::$multiHandler = curl_multi_init();
-    }
+	/**
+	 * @param array $options
+	 * @return $this
+	 */
+	public function setDefaults(array $options = array()){
+		$this->defaultOptions = $options;
+		return $this;
+	}
+	protected static function prepare()
+	{
+		self::$multiHandler = curl_multi_init();
+	}
 
-    /**
-     * @param $method
-     * @param $uri
-     * @param $payload
-     * @param array $options
-     * @return $this
-     */
-    public function add($method, $uri, $payload, array $options = array())
-    {
-        $options = array(
-                'method' => $method,
-                'url' => $uri,
-                'data' => $payload,
-            ) + $options;
-        $this->addOptions(array($options));
-        return $this;
-    }
+	/**
+	 * @param $method
+	 * @param $uri
+	 * @param $payload
+	 * @param array $options
+	 * @return $this
+	 */
+	public function add($method, $uri, $payload, array $options = array())
+	{
+		$options = array(
+				'method' => $method,
+				'url' => $uri,
+				'data' => $payload,
+			) + $options;
+		$this->addOptions(array($options));
+		return $this;
+	}
 
-    /**
-     * @param array $URLOptions
-     * example: array(array('url'=>'http://localhost:9999/','timeout'=>1, 'method'=>'POST', 'data'=>'aa=bb&c=d'))
-     * @return $this
-     */
-    public function addOptions(array $URLOptions)
-    {
-        foreach ($URLOptions as $options) {
-            $options = $options + $this->defaultOptions;
-            $request = Request::create()->addOptions($options)->applyOptions();
-            if (isset($options['callback'])) {
-                $request->onEnd($options['callback']);
-            }
-            $this->import($request);
-        }
-        return $this;
-    }
+	/**
+	 * @param array $URLOptions
+	 * example: array(array('url'=>'http://localhost:9999/','timeout'=>1, 'method'=>'POST', 'data'=>'aa=bb&c=d'))
+	 * @return $this
+	 */
+	public function addOptions(array $URLOptions)
+	{
+		foreach ($URLOptions as $options) {
+			$options = $options + $this->defaultOptions;
+			$request = Request::create()->addOptions($options)->applyOptions();
+			if (isset($options['callback'])) {
+				$request->onEnd($options['callback']);
+			}
+			$this->import($request);
+		}
+		return $this;
+	}
 
-    /**
-     * @param Request $request
-     * @return $this
-     */
-    public function import(Request $request)
-    {
-        if (!is_resource($request->curlHandle)) {
-            throw new InvalidArgumentException('Request curl handle is not initialized');
-        }
-        curl_multi_add_handle(self::$multiHandler, $request->curlHandle);
-        self::$requestPool[] = $request;
-        return $this;
-    }
+	/**
+	 * @param Request $request
+	 * @return $this
+	 */
+	public function import(Request $request)
+	{
+		if (!is_resource($request->curlHandle)) {
+			throw new InvalidArgumentException('Request curl handle is not initialized');
+		}
+		curl_multi_add_handle(self::$multiHandler, $request->curlHandle);
+		self::$requestPool[] = $request;
+		return $this;
+	}
 
-    /**
-     * @return array(Response)
-     */
-    public function sendAll()
-    {
-        $sleepTime = 1000;//microsecond, prevent  CPU 100%
-        do {
-            curl_multi_exec(self::$multiHandler, $active);
-            // bug in PHP 5.3.18+ where curl_multi_select can return -1
-            // https://bugs.php.net/bug.php?id=63411
-            if (curl_multi_select(self::$multiHandler) == -1) {
-                usleep($sleepTime);
-            }
-            usleep($sleepTime);
-        } while ($active);
-        $return = array();
-        foreach (self::$requestPool as $request) {
-            $return[] = $request->send(true);
-            curl_multi_remove_handle(self::$multiHandler, $request->curlHandle);
-            curl_close($request->curlHandle);
-        }
-        curl_multi_close(self::$multiHandler);
-        self::$requestPool = array();
-        self::$multiHandler = null;
-        return $return;
-    }
+	/**
+	 * @return array(Response)
+	 */
+	public function sendAll()
+	{
+		$sleepTime = 1000;//microsecond, prevent  CPU 100%
+		do {
+			curl_multi_exec(self::$multiHandler, $active);
+			// bug in PHP 5.3.18+ where curl_multi_select can return -1
+			// https://bugs.php.net/bug.php?id=63411
+			if (curl_multi_select(self::$multiHandler) == -1) {
+				usleep($sleepTime);
+			}
+			usleep($sleepTime);
+		} while ($active);
+		$return = array();
+		foreach (self::$requestPool as $request) {
+			$return[] = $request->send(true);
+			curl_multi_remove_handle(self::$multiHandler, $request->curlHandle);
+			curl_close($request->curlHandle);
+		}
+		curl_multi_close(self::$multiHandler);
+		self::$requestPool = array();
+		self::$multiHandler = null;
+		return $return;
+	}
 
 }

src/Helper.php

Indentation +8 added lines, -8 removed lines

@@ -14,12 +14,12 @@
 
 class Helper
 {
-    public static function retry($maxTimes = 2, callable $task, $sleep = 0){
-        $tryTimes = 0;
-        while(++$tryTimes <= $maxTimes){
-            if($task()) break;
-            else usleep(abs($sleep) * 1000000);
-        }
-        return $tryTimes;
-    }
+	public static function retry($maxTimes = 2, callable $task, $sleep = 0){
+		$tryTimes = 0;
+		while(++$tryTimes <= $maxTimes){
+			if($task()) break;
+			else usleep(abs($sleep) * 1000000);
+		}
+		return $tryTimes;
+	}
 }
\ No newline at end of file

Spacing +4 added lines, -4 removed lines

@@ -14,11 +14,11 @@
 
 class Helper
 {
-    public static function retry($maxTimes = 2, callable $task, $sleep = 0){
+    public static function retry($maxTimes = 2, callable $task, $sleep = 0) {
         $tryTimes = 0;
-        while(++$tryTimes <= $maxTimes){
-            if($task()) break;
-            else usleep(abs($sleep) * 1000000);
+        while (++$tryTimes <= $maxTimes) {
+            if ($task()) break;
+            else usleep(abs($sleep)*1000000);
         }
         return $tryTimes;
     }

Braces +5 added lines, -2 removed lines

@@ -17,8 +17,11 @@
     public static function retry($maxTimes = 2, callable $task, $sleep = 0){
         $tryTimes = 0;
         while(++$tryTimes <= $maxTimes){
-            if($task()) break;
-            else usleep(abs($sleep) * 1000000);
+            if($task()) {
+            	break;
+            } else {
+            	usleep(abs($sleep) * 1000000);
+            }
         }
         return $tryTimes;
     }

src/Http.php

Spacing +1 added lines, -1 removed lines

@@ -51,7 +51,7 @@
      * @param $method
      * @return bool
      */
-    public static function hasBody($method){
+    public static function hasBody($method) {
         return in_array($method, array(self::POST, self::PUT, self::PATCH, self::OPTIONS));
     }
 }
\ No newline at end of file

Indentation +76 added lines, -76 removed lines

@@ -17,89 +17,89 @@
  */
 abstract class Http
 {
-    const HEAD = 'HEAD';
-    const GET = 'GET';
-    const POST = 'POST';
-    const PUT = 'PUT';
-    const DELETE = 'DELETE';
-    const PATCH = 'PATCH';
-    const OPTIONS = 'OPTIONS';
-    const TRACE = 'TRACE';
-    public static $methods = array(
-        'HEAD' => self::HEAD,
-        'GET' => self::GET,
-        'POST' => self::POST,
-        'PUT' => self::PUT,
-        'DELETE' => self::DELETE,
-        'PATCH' => self::PATCH,
-        'OPTIONS' => self::OPTIONS,
-        'TRACE' => self::TRACE,
-    );
+	const HEAD = 'HEAD';
+	const GET = 'GET';
+	const POST = 'POST';
+	const PUT = 'PUT';
+	const DELETE = 'DELETE';
+	const PATCH = 'PATCH';
+	const OPTIONS = 'OPTIONS';
+	const TRACE = 'TRACE';
+	public static $methods = array(
+		'HEAD' => self::HEAD,
+		'GET' => self::GET,
+		'POST' => self::POST,
+		'PUT' => self::PUT,
+		'DELETE' => self::DELETE,
+		'PATCH' => self::PATCH,
+		'OPTIONS' => self::OPTIONS,
+		'TRACE' => self::TRACE,
+	);
 
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @return mixed
-     */
-    abstract function post($uri, $payload = null, array $options = array());
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function post($uri, $payload = null, array $options = array());
 
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @return mixed
-     */
-    abstract function patch($uri, $payload = null, array $options = array());
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function patch($uri, $payload = null, array $options = array());
 
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @return mixed
-     */
-    abstract function put($uri, $payload = null, array $options = array());
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function put($uri, $payload = null, array $options = array());
 
-    /**
-     * @param $uri
-     * @param array $options
-     * @return mixed
-     */
-    abstract function get($uri, array $options = array());
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function get($uri, array $options = array());
 
-    /**
-     * @param $uri
-     * @param array $options
-     * @return mixed
-     */
-    abstract function head($uri, array $options = array());
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function head($uri, array $options = array());
 
-    /**
-     * @param $uri
-     * @param array $options
-     * @return mixed
-     */
-    abstract function delete($uri, array $options = array());
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function delete($uri, array $options = array());
 
-    /**
-     * @param $uri
-     * @param array $options
-     * @return mixed
-     */
-    abstract function options($uri, array $options = array());
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function options($uri, array $options = array());
 
-    /**
-     * @param $uri
-     * @param array $options
-     * @return mixed
-     */
-    abstract function trace($uri, array $options = array());
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return mixed
+	 */
+	abstract function trace($uri, array $options = array());
 
-    /**
-     * @param $method
-     * @return bool
-     */
-    public static function hasBody($method){
-        return in_array($method, array(self::POST, self::PUT, self::PATCH, self::OPTIONS));
-    }
+	/**
+	 * @param $method
+	 * @return bool
+	 */
+	public static function hasBody($method){
+		return in_array($method, array(self::POST, self::PUT, self::PATCH, self::OPTIONS));
+	}
 }
\ No newline at end of file

src/Request.php

Doc Comments +2 added lines, -2 removed lines

@@ -225,7 +225,7 @@ 
         return $this;
     }
     /**
-     * @return mixed
+     * @return callable
      */
     public function endCallback()
     {
@@ -253,7 +253,7 @@ 
 
     /**
      * @param $key
-     * @return mixed
+     * @return string
      */
     protected static function fullOption($key)
     {

Unused Use Statements -1 removed lines

@@ -13,7 +13,6 @@
 
 use MultiHttp\Exception\InvalidArgumentException;
 use MultiHttp\Exception\InvalidOperationException;
-use MultiHttp\Handler\Form;
 use MultiHttp\Handler\IHandler;
 
 /**

Indentation +599 added lines, -599 removed lines

@@ -22,610 +22,610 @@
  */
 class Request extends Http
 {
-    /**
-     * you can implement more traits
-     */
-    protected static $curlAlias = array(
-        'url' => 'CURLOPT_URL',
-        'uri' => 'CURLOPT_URL',
-        'debug' => 'CURLOPT_VERBOSE',//for debug verbose
-        'method' => 'CURLOPT_CUSTOMREQUEST',
-        'data' => 'CURLOPT_POSTFIELDS', // array or string , file begin with '@'
-        'ua' => 'CURLOPT_USERAGENT',
-        'timeout' => 'CURLOPT_TIMEOUT', // (secs) 0 means indefinitely
-        'connect_timeout' => 'CURLOPT_CONNECTTIMEOUT',
-        'referer' => 'CURLOPT_REFERER',
-        'binary' => 'CURLOPT_BINARYTRANSFER',
-        'port' => 'CURLOPT_PORT',
-        'header' => 'CURLOPT_HEADER', // TRUE:include header
-        'headers' => 'CURLOPT_HTTPHEADER', // array
-        'download' => 'CURLOPT_FILE', // writing file stream (using fopen()), default is STDOUT
-        'upload' => 'CURLOPT_INFILE', // reading file stream
-        'transfer' => 'CURLOPT_RETURNTRANSFER', // TRUE:return string; FALSE:output directly (curl_exec)
-        'follow_location' => 'CURLOPT_FOLLOWLOCATION',
-        'timeout_ms' => 'CURLOPT_TIMEOUT_MS', // milliseconds,  libcurl version > 7.36.0 ,
-        'expects_mime' => null, //expected mime
-        'send_mime' => null, //send mime
-        'ip' => null,//specify ip to send request
-        'callback' => null,//callback on end
-
-    );
-    protected static $loggerHandler;
-    public
-        $curlHandle,
-        $uri,
-        $sendMime,
-        $expectsMime,
-        $timeout,
-        $maxRedirects,
-        $encoding,
-        $payload,
-        $retryTimes,
-        /**
-         * @var int seconds
-         */
-        $retryDuration,
-        $followRedirects;
-
-    protected
-        $body,
-        $endCallback,
-        $withURIQuery,
-        $hasInitialized = false,
-        /**
-         * @var array
-         */
-        $options = array(
-            'CURLOPT_MAXREDIRS' => 10,
-            'CURLOPT_SSL_VERIFYPEER' => false,//for https
-            'CURLOPT_SSL_VERIFYHOST' => 0,//for https
-            'CURLOPT_IPRESOLVE' => CURL_IPRESOLVE_V4,//ipv4 first
-            'CURLOPT_SAFE_UPLOAD' => false,// compatible with PHP 5.6.0
-            'CURLOPT_USERAGENT' => 'Mozilla/5.0 (compatible;)',
-            'header' => true,
-            'method' => self::GET,
-            'transfer' => true,
-            'headers' => array(),
-            'follow_location' => true,
-            'timeout' => 0,
-            //        'ip' => null, //host, in string, .e.g: 172.16.1.1:888
-            'retry_times' => 1,//redo task when failed
-            'retry_duration' => 0,//in seconds
-            'send_mime' => 'form',//in seconds
-        );
-
-
-    /**
-     * Request constructor.
-     */
-    protected function __construct()
-    {
-    }
-
-    /**
-     * @return Request
-     */
-    public static function create()
-    {
-        return new self;
-    }
-
-    /**
-     * @param callable $handler
-     */
-    public static function setLogHandler(callable $handler)
-    {
-        self::$loggerHandler = $handler;
-    }
-    /**
-     * Specify   timeout
-     * @param float|int $timeout seconds to timeout the HTTP call
-     * @return Request
-     */
-    public function timeout($timeout)
-    {
-        $this->timeout = $timeout;
-        return $this;
-    }
-
-    /**
-     * @return Request
-     */
-    public function noFollow()
-    {
-        return $this->follow(0);
-    }
-
-    /**
-     * If the response is a 301 or 302 redirect, automatically
-     * send off another request to that location
-     * @param int $follow follow or not to follow or maximal number of redirects
-     * @return Request
-     */
-    public function follow($follow)
-    {
-        $this->maxRedirects = abs($follow);
-        $this->followRedirects = $follow > 0;
-        return $this;
-    }
-
-    /**
-     * @param $parsedComponents
-     * @return string
-     */
-    private static function combineUrl($parsedComponents)
-    {
-        $scheme = isset($parsedComponents['scheme']) ? $parsedComponents['scheme'] . '://' : '';
-        $host = isset($parsedComponents['host']) ? $parsedComponents['host'] : '';
-        $port = isset($parsedComponents['port']) ? ':' . $parsedComponents['port'] : '';
-        $user = isset($parsedComponents['user']) ? $parsedComponents['user'] : '';
-        $pass = isset($parsedComponents['pass']) ? ':' . $parsedComponents['pass'] : '';
-        $pass = ($user || $pass) ? "$pass@" : '';
-        $path = isset($parsedComponents['path']) ? $parsedComponents['path'] : '';
-        $query = isset($parsedComponents['query']) ? '?' . $parsedComponents['query'] : '';
-        $fragment = isset($parsedComponents['fragment']) ? '#' . $parsedComponents['fragment'] : '';
-        return "$scheme$user$pass$host$port$path$query$fragment";
-    }
-
-    /**
-     * @param string $mime
-     * @return $this
-     */
-    public function expectsMime($mime = 'json')
-    {
-        $this->expectsMime = $mime;
-        $this->options['expects_mime'] = $mime;
-        return $this;
-    }
-
-    /**
-     * @param string $mime
-     * @return Request
-     */
-    public function sendMime($mime = 'json')
-    {
-        $this->sendMime = $mime;
-        $this->options['send_mime'] = $mime;
+	/**
+	 * you can implement more traits
+	 */
+	protected static $curlAlias = array(
+		'url' => 'CURLOPT_URL',
+		'uri' => 'CURLOPT_URL',
+		'debug' => 'CURLOPT_VERBOSE',//for debug verbose
+		'method' => 'CURLOPT_CUSTOMREQUEST',
+		'data' => 'CURLOPT_POSTFIELDS', // array or string , file begin with '@'
+		'ua' => 'CURLOPT_USERAGENT',
+		'timeout' => 'CURLOPT_TIMEOUT', // (secs) 0 means indefinitely
+		'connect_timeout' => 'CURLOPT_CONNECTTIMEOUT',
+		'referer' => 'CURLOPT_REFERER',
+		'binary' => 'CURLOPT_BINARYTRANSFER',
+		'port' => 'CURLOPT_PORT',
+		'header' => 'CURLOPT_HEADER', // TRUE:include header
+		'headers' => 'CURLOPT_HTTPHEADER', // array
+		'download' => 'CURLOPT_FILE', // writing file stream (using fopen()), default is STDOUT
+		'upload' => 'CURLOPT_INFILE', // reading file stream
+		'transfer' => 'CURLOPT_RETURNTRANSFER', // TRUE:return string; FALSE:output directly (curl_exec)
+		'follow_location' => 'CURLOPT_FOLLOWLOCATION',
+		'timeout_ms' => 'CURLOPT_TIMEOUT_MS', // milliseconds,  libcurl version > 7.36.0 ,
+		'expects_mime' => null, //expected mime
+		'send_mime' => null, //send mime
+		'ip' => null,//specify ip to send request
+		'callback' => null,//callback on end
+
+	);
+	protected static $loggerHandler;
+	public
+		$curlHandle,
+		$uri,
+		$sendMime,
+		$expectsMime,
+		$timeout,
+		$maxRedirects,
+		$encoding,
+		$payload,
+		$retryTimes,
+		/**
+		 * @var int seconds
+		 */
+		$retryDuration,
+		$followRedirects;
+
+	protected
+		$body,
+		$endCallback,
+		$withURIQuery,
+		$hasInitialized = false,
+		/**
+		 * @var array
+		 */
+		$options = array(
+			'CURLOPT_MAXREDIRS' => 10,
+			'CURLOPT_SSL_VERIFYPEER' => false,//for https
+			'CURLOPT_SSL_VERIFYHOST' => 0,//for https
+			'CURLOPT_IPRESOLVE' => CURL_IPRESOLVE_V4,//ipv4 first
+			'CURLOPT_SAFE_UPLOAD' => false,// compatible with PHP 5.6.0
+			'CURLOPT_USERAGENT' => 'Mozilla/5.0 (compatible;)',
+			'header' => true,
+			'method' => self::GET,
+			'transfer' => true,
+			'headers' => array(),
+			'follow_location' => true,
+			'timeout' => 0,
+			//        'ip' => null, //host, in string, .e.g: 172.16.1.1:888
+			'retry_times' => 1,//redo task when failed
+			'retry_duration' => 0,//in seconds
+			'send_mime' => 'form',//in seconds
+		);
+
+
+	/**
+	 * Request constructor.
+	 */
+	protected function __construct()
+	{
+	}
+
+	/**
+	 * @return Request
+	 */
+	public static function create()
+	{
+		return new self;
+	}
+
+	/**
+	 * @param callable $handler
+	 */
+	public static function setLogHandler(callable $handler)
+	{
+		self::$loggerHandler = $handler;
+	}
+	/**
+	 * Specify   timeout
+	 * @param float|int $timeout seconds to timeout the HTTP call
+	 * @return Request
+	 */
+	public function timeout($timeout)
+	{
+		$this->timeout = $timeout;
+		return $this;
+	}
+
+	/**
+	 * @return Request
+	 */
+	public function noFollow()
+	{
+		return $this->follow(0);
+	}
+
+	/**
+	 * If the response is a 301 or 302 redirect, automatically
+	 * send off another request to that location
+	 * @param int $follow follow or not to follow or maximal number of redirects
+	 * @return Request
+	 */
+	public function follow($follow)
+	{
+		$this->maxRedirects = abs($follow);
+		$this->followRedirects = $follow > 0;
+		return $this;
+	}
+
+	/**
+	 * @param $parsedComponents
+	 * @return string
+	 */
+	private static function combineUrl($parsedComponents)
+	{
+		$scheme = isset($parsedComponents['scheme']) ? $parsedComponents['scheme'] . '://' : '';
+		$host = isset($parsedComponents['host']) ? $parsedComponents['host'] : '';
+		$port = isset($parsedComponents['port']) ? ':' . $parsedComponents['port'] : '';
+		$user = isset($parsedComponents['user']) ? $parsedComponents['user'] : '';
+		$pass = isset($parsedComponents['pass']) ? ':' . $parsedComponents['pass'] : '';
+		$pass = ($user || $pass) ? "$pass@" : '';
+		$path = isset($parsedComponents['path']) ? $parsedComponents['path'] : '';
+		$query = isset($parsedComponents['query']) ? '?' . $parsedComponents['query'] : '';
+		$fragment = isset($parsedComponents['fragment']) ? '#' . $parsedComponents['fragment'] : '';
+		return "$scheme$user$pass$host$port$path$query$fragment";
+	}
+
+	/**
+	 * @param string $mime
+	 * @return $this
+	 */
+	public function expectsMime($mime = 'json')
+	{
+		$this->expectsMime = $mime;
+		$this->options['expects_mime'] = $mime;
+		return $this;
+	}
+
+	/**
+	 * @param string $mime
+	 * @return Request
+	 */
+	public function sendMime($mime = 'json')
+	{
+		$this->sendMime = $mime;
+		$this->options['send_mime'] = $mime;
 //        $this->addHeader('Content-type', Mime::getFullMime($mime));
-        return $this;
-    }
-
-    /**
-     * @param $headerName
-     * @param $value , can be rawurlencode
-     * @return $this
-     */
-    public function addHeader($headerName, $value)
-    {
-        $this->options['headers'][] = $headerName . ': ' . $value;
-        return $this;
-    }
-
-    /**
-     * @param $uri
-     * @return $this
-     */
-    public function uri($uri)
-    {
-        $this->uri = $uri;
-        return $this;
-    }
-
-
-
-    /**
-     * @param array $headers
-     * @return $this
-     */
-    public function addHeaders(array $headers)
-    {
-        foreach ($headers as $header => $value) {
-            $this->addHeader($header, $value);
-        }
-        return $this;
-    }
-    /**
-     * @return mixed
-     */
-    public function endCallback()
-    {
-        return $this->endCallback;
-    }
-
-    /**
-     * @return bool
-     */
-    public function hasEndCallback()
-    {
-        return isset($this->endCallback);
-    }
-
-    /**
-     * @param $field alias or field name
-     * @return bool|mixed
-     */
-    public function getIni($field = null)
-    {
-        if(!$field) return $this->options;
-        $full = self::fullOption($field);
-        return isset($this->options[$full]) ? $this->options[$full] : false;
-    }
-
-    /**
-     * @param $key
-     * @return mixed
-     */
-    protected static function fullOption($key)
-    {
-        $full = false;
-        if (isset(self::$curlAlias[$key])) {
-            $full = self::$curlAlias[$key];
-        } elseif ((substr($key, 0, strlen('CURLOPT_')) == 'CURLOPT_') && defined($key)) {
-            $full = $key;
-        }
-        return $full;
-    }
-
-    /**
-     * @param $queryData
-     * @return $this
-     */
-    public function addQuery($queryData)
-    {
-        if (!empty($queryData)) {
-            if (is_array($queryData)) {
-                $this->withURIQuery = http_build_query($queryData);
-            } else if (is_string($queryData)) {
-                $this->withURIQuery = $queryData;
-            } else {
-                throw new InvalidArgumentException('data must be array or string');
-            }
-        }
-        return $this;
-    }
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @return Request
-     */
-    public function post($uri, $payload = null, array $options = array())
-    {
-        return $this->ini(Http::POST, $uri, $payload, $options);
-    }
-
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @return Request
-     */
-    public function upload($uri, $payload = null, array $options = array())
-    {
-        return $this->ini(Http::POST, $uri, $payload, $options)->sendMime('upload');
-    }
-
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @param null $response
-     * @return string
-     */
-    public function quickPost($uri, $payload = null, array $options = array(), &$response = null)
-    {
-        $response = $this->post($uri, $payload, $options)->send();
-        return $response->body;
-    }
-
-
-    /**
-     * @param $method
-     * @param $url
-     * @param $data
-     * @param array $options
-     * @return $this
-     */
-    protected function ini($method, $url, $data, array $options = array())
-    {
-        $options = array('url' => $url, 'method' => $method, 'data' => $data) + $options;
-        $this->addOptions($options);
-
-        return $this;
-    }
-
-    /**
-     * @param array $options
-     * @return $this
-     */
-    public function addOptions(array $options = array())
-    {
-        $this->options = $options + $this->options;
-        $this->uri = $this->options['url'];
-        return $this;
-    }
-
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @return Request
-     */
-    function put($uri, $payload = null, array $options = array())
-    {
-        return $this->ini(Http::PUT, $uri, $payload, $options);
-    }
-
-    /**
-     * @param $uri
-     * @param null $payload
-     * @param array $options
-     * @return Request
-     */
-    function patch($uri, $payload = null, array $options = array())
-    {
-        return $this->ini(Http::PATCH, $uri, $payload, $options);
-    }
-
-    /**
-     * @param $uri
-     * @param array $options
-     * @return Request
-     */
-    public function get($uri, array $options = array())
-    {
-        return $this->ini(Http::GET, $uri, array(), $options);
-    }
-
-
-    /**
-     * @param $uri
-     * @param array $options
-     * @param null $response
-     * @return string
-     */
-    public function quickGet($uri, array $options = array(), &$response = null)
-    {
-        $response = $this->get($uri, $options)->send();
-        return $response->body;
-    }
-
-    /**
-     * @param $uri
-     * @param array $options
-     * @return Request
-     */
-    function options($uri, array $options = array())
-    {
-        return $this->ini(Http::OPTIONS, $uri, array(), $options);
-    }
-
-    /**
-     * @param $uri
-     * @param array $options
-     * @return Request
-     */
-    function head($uri, array $options = array())
-    {
-        return $this->ini(Http::HEAD, $uri, array('CURLOPT_NOBODY' => true), $options);
-    }
-
-    /**
-     * @param $uri
-     * @param array $options
-     * @return Request
-     */
-    function delete($uri, array $options = array())
-    {
-        return $this->ini(Http::DELETE, $uri, array(), $options);
-    }
-
-    /**
-     * @param $uri
-     * @param array $options
-     * @return Request
-     */
-    function trace($uri, array $options = array())
-    {
-        return $this->ini(Http::TRACE, $uri, array(), $options);
-    }
-
-    /**
-     * @param bool $isMultiCurl
-     * @return Response
-     */
-    public function send($isMultiCurl = false)
-    {
-        try {
-            if (!$this->hasInitialized)
-                $this->applyOptions();
-            $response = $this->makeResponse($isMultiCurl);
-            $response->parse();
-        } catch (\Exception $e) {
-            if(!isset($response)) $response = Response::create($this, null, null, null, null);
-            $response->error = $e->getMessage();
-            $response->errorCode = 999;
-        }
-
-        if (self::$loggerHandler) {
-            call_user_func(self::$loggerHandler, $response);
-        }
-        if ($this->endCallback) {
-            call_user_func($this->endCallback, $response);
-        }
-
-        return $response;
-    }
-
-    /**
-     * @return $this
-     */
-    public function applyOptions()
-    {
-        $curl = curl_init();
-        $this->curlHandle = $curl;
-        $this->prepare();
-        $this->hasInitialized = true;
-        return $this;
-    }
-
-    /**
-     * @return $this
-     */
-    protected function prepare()
-    {
-        $this->options['url'] = trim($this->options['url']);
-        if (empty($this->options['url'])) {
-            throw new InvalidArgumentException('url can not empty');
-        }
-
-        if (isset($this->options['retry_times'])) {
-            $this->retryTimes = abs($this->options['retry_times']);
-        }
-
-        if (isset($this->options['retry_duration'])) {
-            $this->retryDuration = abs($this->options['retry_duration']);
-        }
-
-        if(isset($this->options['expects_mime'])){
-            $this->expectsMime = $this->options['expects_mime'];
-        }
-
-        if(isset($this->options['send_mime'])){
-            $this->sendMime = $this->options['send_mime'];
-        }
+		return $this;
+	}
+
+	/**
+	 * @param $headerName
+	 * @param $value , can be rawurlencode
+	 * @return $this
+	 */
+	public function addHeader($headerName, $value)
+	{
+		$this->options['headers'][] = $headerName . ': ' . $value;
+		return $this;
+	}
+
+	/**
+	 * @param $uri
+	 * @return $this
+	 */
+	public function uri($uri)
+	{
+		$this->uri = $uri;
+		return $this;
+	}
+
+
+
+	/**
+	 * @param array $headers
+	 * @return $this
+	 */
+	public function addHeaders(array $headers)
+	{
+		foreach ($headers as $header => $value) {
+			$this->addHeader($header, $value);
+		}
+		return $this;
+	}
+	/**
+	 * @return mixed
+	 */
+	public function endCallback()
+	{
+		return $this->endCallback;
+	}
+
+	/**
+	 * @return bool
+	 */
+	public function hasEndCallback()
+	{
+		return isset($this->endCallback);
+	}
+
+	/**
+	 * @param $field alias or field name
+	 * @return bool|mixed
+	 */
+	public function getIni($field = null)
+	{
+		if(!$field) return $this->options;
+		$full = self::fullOption($field);
+		return isset($this->options[$full]) ? $this->options[$full] : false;
+	}
+
+	/**
+	 * @param $key
+	 * @return mixed
+	 */
+	protected static function fullOption($key)
+	{
+		$full = false;
+		if (isset(self::$curlAlias[$key])) {
+			$full = self::$curlAlias[$key];
+		} elseif ((substr($key, 0, strlen('CURLOPT_')) == 'CURLOPT_') && defined($key)) {
+			$full = $key;
+		}
+		return $full;
+	}
+
+	/**
+	 * @param $queryData
+	 * @return $this
+	 */
+	public function addQuery($queryData)
+	{
+		if (!empty($queryData)) {
+			if (is_array($queryData)) {
+				$this->withURIQuery = http_build_query($queryData);
+			} else if (is_string($queryData)) {
+				$this->withURIQuery = $queryData;
+			} else {
+				throw new InvalidArgumentException('data must be array or string');
+			}
+		}
+		return $this;
+	}
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @return Request
+	 */
+	public function post($uri, $payload = null, array $options = array())
+	{
+		return $this->ini(Http::POST, $uri, $payload, $options);
+	}
+
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @return Request
+	 */
+	public function upload($uri, $payload = null, array $options = array())
+	{
+		return $this->ini(Http::POST, $uri, $payload, $options)->sendMime('upload');
+	}
+
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @param null $response
+	 * @return string
+	 */
+	public function quickPost($uri, $payload = null, array $options = array(), &$response = null)
+	{
+		$response = $this->post($uri, $payload, $options)->send();
+		return $response->body;
+	}
+
+
+	/**
+	 * @param $method
+	 * @param $url
+	 * @param $data
+	 * @param array $options
+	 * @return $this
+	 */
+	protected function ini($method, $url, $data, array $options = array())
+	{
+		$options = array('url' => $url, 'method' => $method, 'data' => $data) + $options;
+		$this->addOptions($options);
+
+		return $this;
+	}
+
+	/**
+	 * @param array $options
+	 * @return $this
+	 */
+	public function addOptions(array $options = array())
+	{
+		$this->options = $options + $this->options;
+		$this->uri = $this->options['url'];
+		return $this;
+	}
+
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @return Request
+	 */
+	function put($uri, $payload = null, array $options = array())
+	{
+		return $this->ini(Http::PUT, $uri, $payload, $options);
+	}
+
+	/**
+	 * @param $uri
+	 * @param null $payload
+	 * @param array $options
+	 * @return Request
+	 */
+	function patch($uri, $payload = null, array $options = array())
+	{
+		return $this->ini(Http::PATCH, $uri, $payload, $options);
+	}
+
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return Request
+	 */
+	public function get($uri, array $options = array())
+	{
+		return $this->ini(Http::GET, $uri, array(), $options);
+	}
+
+
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @param null $response
+	 * @return string
+	 */
+	public function quickGet($uri, array $options = array(), &$response = null)
+	{
+		$response = $this->get($uri, $options)->send();
+		return $response->body;
+	}
+
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return Request
+	 */
+	function options($uri, array $options = array())
+	{
+		return $this->ini(Http::OPTIONS, $uri, array(), $options);
+	}
+
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return Request
+	 */
+	function head($uri, array $options = array())
+	{
+		return $this->ini(Http::HEAD, $uri, array('CURLOPT_NOBODY' => true), $options);
+	}
+
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return Request
+	 */
+	function delete($uri, array $options = array())
+	{
+		return $this->ini(Http::DELETE, $uri, array(), $options);
+	}
+
+	/**
+	 * @param $uri
+	 * @param array $options
+	 * @return Request
+	 */
+	function trace($uri, array $options = array())
+	{
+		return $this->ini(Http::TRACE, $uri, array(), $options);
+	}
+
+	/**
+	 * @param bool $isMultiCurl
+	 * @return Response
+	 */
+	public function send($isMultiCurl = false)
+	{
+		try {
+			if (!$this->hasInitialized)
+				$this->applyOptions();
+			$response = $this->makeResponse($isMultiCurl);
+			$response->parse();
+		} catch (\Exception $e) {
+			if(!isset($response)) $response = Response::create($this, null, null, null, null);
+			$response->error = $e->getMessage();
+			$response->errorCode = 999;
+		}
+
+		if (self::$loggerHandler) {
+			call_user_func(self::$loggerHandler, $response);
+		}
+		if ($this->endCallback) {
+			call_user_func($this->endCallback, $response);
+		}
+
+		return $response;
+	}
+
+	/**
+	 * @return $this
+	 */
+	public function applyOptions()
+	{
+		$curl = curl_init();
+		$this->curlHandle = $curl;
+		$this->prepare();
+		$this->hasInitialized = true;
+		return $this;
+	}
+
+	/**
+	 * @return $this
+	 */
+	protected function prepare()
+	{
+		$this->options['url'] = trim($this->options['url']);
+		if (empty($this->options['url'])) {
+			throw new InvalidArgumentException('url can not empty');
+		}
+
+		if (isset($this->options['retry_times'])) {
+			$this->retryTimes = abs($this->options['retry_times']);
+		}
+
+		if (isset($this->options['retry_duration'])) {
+			$this->retryDuration = abs($this->options['retry_duration']);
+		}
+
+		if(isset($this->options['expects_mime'])){
+			$this->expectsMime = $this->options['expects_mime'];
+		}
+
+		if(isset($this->options['send_mime'])){
+			$this->sendMime = $this->options['send_mime'];
+		}
 
 //        if(!empty($this->options['data']) && !Http::hasBody($this->options['method'])){
 //            $this->withURIQuery =  is_array($this->options['data']) ? http_build_query($this->options['data']) : $this->options['data'];
 //        }
-        if (isset($this->withURIQuery)) {
-            $this->options['url'] .= strpos($this->options['url'], '?') === FALSE ? '?' : '&';
-            $this->options['url'] .= $this->withURIQuery;
-        }
-
-        $this->serializeBody();
-
-        //try fix url
-        if (strpos($this->options['url'], '://') === FALSE) $this->options['url'] = 'http://' . $this->options['url'];
-        $components = parse_url($this->options['url']);
-        if(FALSE === $components) throw new InvalidArgumentException('formatting url occurs error: '. $this->options['url']);
-        if($this->withURIQuery){
-            if(isset($components['query'])) $components['query'] .= '&'. trim($this->withURIQuery);
-            else $components['query'] = trim($this->withURIQuery);
-        }
-        $this->options['url'] = self::combineUrl($components);
-
-        if (isset($this->options['callback'])) {
-            $this->onEnd($this->options['callback']);
-        }
-        //swap ip and host
-        if (!empty($this->options['ip'])) {
-            $matches = array();
-            preg_match('/\/\/([^\/]+)/', $this->options['url'], $matches);
-            $host = $matches[1];
-            if (empty($this->options['headers']) || !is_array($this->options['headers'])) {
-                $this->options['headers'] = array('Host: ' . $host);
-            } else {
-                $this->options['headers'][] = 'Host: ' . $host;
-            }
-            $this->options['url'] = str_replace("//{$host}", '//' . $this->options['ip'], $this->options['url']);
-            unset($host);
-        }
-        //process version
-        if (!empty($this->options['http_version'])) {
-            $version = $this->options['http_version'];
-            if ($version == '1.0') {
-                $this->options['CURLOPT_HTTP_VERSION'] = CURLOPT_HTTP_VERSION_1_0;
-            } elseif ($version == '1.1') {
-                $this->options['CURLOPT_HTTP_VERSION'] = CURLOPT_HTTP_VERSION_1_1;
-            }
-
-            unset($version);
-        }
-
-        //convert secs to milliseconds
-        if (defined('CURLOPT_TIMEOUT_MS')) {
-            if (!isset($this->options['timeout_ms'])) {
-                $this->options['timeout_ms'] = intval($this->options['timeout'] * 1000);
-            } else {
-                $this->options['timeout_ms'] = intval($this->options['timeout_ms']);
-            }
-        }
-
-        $cURLOptions = self::filterAndRaw($this->options);
-        if(isset($this->body))$cURLOptions[CURLOPT_POSTFIELDS] = $this->body;//use serialized body not raw data
-        curl_setopt_array($this->curlHandle, $cURLOptions);
-
-        return $this;
-    }
-
-    public function serializeBody()
-    {
-        //Passing an array to CURLOPT_POSTFIELDS will encode the data as multipart/form-data, while passing a URL-encoded string will encode the data as application/x-www-form-urlencoded.
-        if (isset($this->options['data'])) {
-            $this->options[CURLOPT_POST] = true;
-            $clz = '\\MultiHttp\\Handler\\'.ucfirst($this->sendMime);
-            $inst = new $clz;
-            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
-            $this->body = $inst->encode($this->options['data']);
-        }
-    }
-
-    /**
-     * @param callable $callback
-     * @return $this
-     */
-    public function onEnd(callable $callback)
-    {
-        if (!is_callable($callback)) {
-            throw new InvalidArgumentException('callback not is callable :' . print_r($callback, 1));
-        }
-
-        $this->endCallback = $callback;
-        return $this;
-    }
-
-    /**
-     * @param array $options
-     * @return array
-     */
-    protected static function filterAndRaw(array &$options)
-    {
-        $opts = $fullsOpts = array();
-        foreach ($options as $key => $val) {
-            $fullOption = self::fullOption($key);
-
-            if ($fullOption) {
-                $fullsOpts[$fullOption] = $val;
-                $opts[constant($fullOption)] = $val;
-            }
-            unset($options[$key]);
-        }
-        $options = $fullsOpts;
-        return $opts;
-    }
-
-    /**
-     * @param bool $isMultiCurl
-     * @return Response
-     * @throws \Exception
-     */
-    public function makeResponse($isMultiCurl = false)
-    {
-        $handle = $this->curlHandle;
-        $body = $errno = null;
-        Helper::retry($this->retryTimes, function()use(&$body, &$errno, $isMultiCurl, $handle){
-            $body = $isMultiCurl ? curl_multi_getcontent($handle) : curl_exec($handle);
-            $errno = curl_errno($handle);
-            return 0 == $errno;
-        }, $this->retryDuration);
-
-        $info = curl_getinfo($this->curlHandle);
-        $errorCode = curl_errno($this->curlHandle);
-        $error = curl_error($this->curlHandle);
-        $response = Response::create($this, $body, $info, $errorCode, $error);
-        return $response;
-    }
+		if (isset($this->withURIQuery)) {
+			$this->options['url'] .= strpos($this->options['url'], '?') === FALSE ? '?' : '&';
+			$this->options['url'] .= $this->withURIQuery;
+		}
+
+		$this->serializeBody();
+
+		//try fix url
+		if (strpos($this->options['url'], '://') === FALSE) $this->options['url'] = 'http://' . $this->options['url'];
+		$components = parse_url($this->options['url']);
+		if(FALSE === $components) throw new InvalidArgumentException('formatting url occurs error: '. $this->options['url']);
+		if($this->withURIQuery){
+			if(isset($components['query'])) $components['query'] .= '&'. trim($this->withURIQuery);
+			else $components['query'] = trim($this->withURIQuery);
+		}
+		$this->options['url'] = self::combineUrl($components);
+
+		if (isset($this->options['callback'])) {
+			$this->onEnd($this->options['callback']);
+		}
+		//swap ip and host
+		if (!empty($this->options['ip'])) {
+			$matches = array();
+			preg_match('/\/\/([^\/]+)/', $this->options['url'], $matches);
+			$host = $matches[1];
+			if (empty($this->options['headers']) || !is_array($this->options['headers'])) {
+				$this->options['headers'] = array('Host: ' . $host);
+			} else {
+				$this->options['headers'][] = 'Host: ' . $host;
+			}
+			$this->options['url'] = str_replace("//{$host}", '//' . $this->options['ip'], $this->options['url']);
+			unset($host);
+		}
+		//process version
+		if (!empty($this->options['http_version'])) {
+			$version = $this->options['http_version'];
+			if ($version == '1.0') {
+				$this->options['CURLOPT_HTTP_VERSION'] = CURLOPT_HTTP_VERSION_1_0;
+			} elseif ($version == '1.1') {
+				$this->options['CURLOPT_HTTP_VERSION'] = CURLOPT_HTTP_VERSION_1_1;
+			}
+
+			unset($version);
+		}
+
+		//convert secs to milliseconds
+		if (defined('CURLOPT_TIMEOUT_MS')) {
+			if (!isset($this->options['timeout_ms'])) {
+				$this->options['timeout_ms'] = intval($this->options['timeout'] * 1000);
+			} else {
+				$this->options['timeout_ms'] = intval($this->options['timeout_ms']);
+			}
+		}
+
+		$cURLOptions = self::filterAndRaw($this->options);
+		if(isset($this->body))$cURLOptions[CURLOPT_POSTFIELDS] = $this->body;//use serialized body not raw data
+		curl_setopt_array($this->curlHandle, $cURLOptions);
+
+		return $this;
+	}
+
+	public function serializeBody()
+	{
+		//Passing an array to CURLOPT_POSTFIELDS will encode the data as multipart/form-data, while passing a URL-encoded string will encode the data as application/x-www-form-urlencoded.
+		if (isset($this->options['data'])) {
+			$this->options[CURLOPT_POST] = true;
+			$clz = '\\MultiHttp\\Handler\\'.ucfirst($this->sendMime);
+			$inst = new $clz;
+			if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+			$this->body = $inst->encode($this->options['data']);
+		}
+	}
+
+	/**
+	 * @param callable $callback
+	 * @return $this
+	 */
+	public function onEnd(callable $callback)
+	{
+		if (!is_callable($callback)) {
+			throw new InvalidArgumentException('callback not is callable :' . print_r($callback, 1));
+		}
+
+		$this->endCallback = $callback;
+		return $this;
+	}
+
+	/**
+	 * @param array $options
+	 * @return array
+	 */
+	protected static function filterAndRaw(array &$options)
+	{
+		$opts = $fullsOpts = array();
+		foreach ($options as $key => $val) {
+			$fullOption = self::fullOption($key);
+
+			if ($fullOption) {
+				$fullsOpts[$fullOption] = $val;
+				$opts[constant($fullOption)] = $val;
+			}
+			unset($options[$key]);
+		}
+		$options = $fullsOpts;
+		return $opts;
+	}
+
+	/**
+	 * @param bool $isMultiCurl
+	 * @return Response
+	 * @throws \Exception
+	 */
+	public function makeResponse($isMultiCurl = false)
+	{
+		$handle = $this->curlHandle;
+		$body = $errno = null;
+		Helper::retry($this->retryTimes, function()use(&$body, &$errno, $isMultiCurl, $handle){
+			$body = $isMultiCurl ? curl_multi_getcontent($handle) : curl_exec($handle);
+			$errno = curl_errno($handle);
+			return 0 == $errno;
+		}, $this->retryDuration);
+
+		$info = curl_getinfo($this->curlHandle);
+		$errorCode = curl_errno($this->curlHandle);
+		$error = curl_error($this->curlHandle);
+		$response = Response::create($this, $body, $info, $errorCode, $error);
+		return $response;
+	}
 
 
 }

Spacing +33 added lines, -33 removed lines

@@ -28,7 +28,7 @@ 
     protected static $curlAlias = array(
         'url' => 'CURLOPT_URL',
         'uri' => 'CURLOPT_URL',
-        'debug' => 'CURLOPT_VERBOSE',//for debug verbose
+        'debug' => 'CURLOPT_VERBOSE', //for debug verbose
         'method' => 'CURLOPT_CUSTOMREQUEST',
         'data' => 'CURLOPT_POSTFIELDS', // array or string , file begin with '@'
         'ua' => 'CURLOPT_USERAGENT',
@@ -46,8 +46,8 @@ 
         'timeout_ms' => 'CURLOPT_TIMEOUT_MS', // milliseconds,  libcurl version > 7.36.0 ,
         'expects_mime' => null, //expected mime
         'send_mime' => null, //send mime
-        'ip' => null,//specify ip to send request
-        'callback' => null,//callback on end
+        'ip' => null, //specify ip to send request
+        'callback' => null, //callback on end
 
     );
     protected static $loggerHandler;
@@ -77,10 +77,10 @@ 
          */
         $options = array(
             'CURLOPT_MAXREDIRS' => 10,
-            'CURLOPT_SSL_VERIFYPEER' => false,//for https
-            'CURLOPT_SSL_VERIFYHOST' => 0,//for https
-            'CURLOPT_IPRESOLVE' => CURL_IPRESOLVE_V4,//ipv4 first
-            'CURLOPT_SAFE_UPLOAD' => false,// compatible with PHP 5.6.0
+            'CURLOPT_SSL_VERIFYPEER' => false, //for https
+            'CURLOPT_SSL_VERIFYHOST' => 0, //for https
+            'CURLOPT_IPRESOLVE' => CURL_IPRESOLVE_V4, //ipv4 first
+            'CURLOPT_SAFE_UPLOAD' => false, // compatible with PHP 5.6.0
             'CURLOPT_USERAGENT' => 'Mozilla/5.0 (compatible;)',
             'header' => true,
             'method' => self::GET,
@@ -89,9 +89,9 @@ 
             'follow_location' => true,
             'timeout' => 0,
             //        'ip' => null, //host, in string, .e.g: 172.16.1.1:888
-            'retry_times' => 1,//redo task when failed
-            'retry_duration' => 0,//in seconds
-            'send_mime' => 'form',//in seconds
+            'retry_times' => 1, //redo task when failed
+            'retry_duration' => 0, //in seconds
+            'send_mime' => 'form', //in seconds
         );
 
 
@@ -155,15 +155,15 @@ 
      */
     private static function combineUrl($parsedComponents)
     {
-        $scheme = isset($parsedComponents['scheme']) ? $parsedComponents['scheme'] . '://' : '';
+        $scheme = isset($parsedComponents['scheme']) ? $parsedComponents['scheme'].'://' : '';
         $host = isset($parsedComponents['host']) ? $parsedComponents['host'] : '';
-        $port = isset($parsedComponents['port']) ? ':' . $parsedComponents['port'] : '';
+        $port = isset($parsedComponents['port']) ? ':'.$parsedComponents['port'] : '';
         $user = isset($parsedComponents['user']) ? $parsedComponents['user'] : '';
-        $pass = isset($parsedComponents['pass']) ? ':' . $parsedComponents['pass'] : '';
+        $pass = isset($parsedComponents['pass']) ? ':'.$parsedComponents['pass'] : '';
         $pass = ($user || $pass) ? "$pass@" : '';
         $path = isset($parsedComponents['path']) ? $parsedComponents['path'] : '';
-        $query = isset($parsedComponents['query']) ? '?' . $parsedComponents['query'] : '';
-        $fragment = isset($parsedComponents['fragment']) ? '#' . $parsedComponents['fragment'] : '';
+        $query = isset($parsedComponents['query']) ? '?'.$parsedComponents['query'] : '';
+        $fragment = isset($parsedComponents['fragment']) ? '#'.$parsedComponents['fragment'] : '';
         return "$scheme$user$pass$host$port$path$query$fragment";
     }
 
@@ -197,7 +197,7 @@ 
      */
     public function addHeader($headerName, $value)
     {
-        $this->options['headers'][] = $headerName . ': ' . $value;
+        $this->options['headers'][] = $headerName.': '.$value;
         return $this;
     }
 
@@ -246,7 +246,7 @@ 
      */
     public function getIni($field = null)
     {
-        if(!$field) return $this->options;
+        if (!$field) return $this->options;
         $full = self::fullOption($field);
         return isset($this->options[$full]) ? $this->options[$full] : false;
     }
@@ -328,7 +328,7 @@ 
      */
     protected function ini($method, $url, $data, array $options = array())
     {
-        $options = array('url' => $url, 'method' => $method, 'data' => $data) + $options;
+        $options = array('url' => $url, 'method' => $method, 'data' => $data)+$options;
         $this->addOptions($options);
 
         return $this;
@@ -340,7 +340,7 @@ 
      */
     public function addOptions(array $options = array())
     {
-        $this->options = $options + $this->options;
+        $this->options = $options+$this->options;
         $this->uri = $this->options['url'];
         return $this;
     }
@@ -442,7 +442,7 @@ 
             $response = $this->makeResponse($isMultiCurl);
             $response->parse();
         } catch (\Exception $e) {
-            if(!isset($response)) $response = Response::create($this, null, null, null, null);
+            if (!isset($response)) $response = Response::create($this, null, null, null, null);
             $response->error = $e->getMessage();
             $response->errorCode = 999;
         }
@@ -487,11 +487,11 @@ 
             $this->retryDuration = abs($this->options['retry_duration']);
         }
 
-        if(isset($this->options['expects_mime'])){
+        if (isset($this->options['expects_mime'])) {
             $this->expectsMime = $this->options['expects_mime'];
         }
 
-        if(isset($this->options['send_mime'])){
+        if (isset($this->options['send_mime'])) {
             $this->sendMime = $this->options['send_mime'];
         }
 
@@ -506,11 +506,11 @@ 
         $this->serializeBody();
 
         //try fix url
-        if (strpos($this->options['url'], '://') === FALSE) $this->options['url'] = 'http://' . $this->options['url'];
+        if (strpos($this->options['url'], '://') === FALSE) $this->options['url'] = 'http://'.$this->options['url'];
         $components = parse_url($this->options['url']);
-        if(FALSE === $components) throw new InvalidArgumentException('formatting url occurs error: '. $this->options['url']);
-        if($this->withURIQuery){
-            if(isset($components['query'])) $components['query'] .= '&'. trim($this->withURIQuery);
+        if (FALSE === $components) throw new InvalidArgumentException('formatting url occurs error: '.$this->options['url']);
+        if ($this->withURIQuery) {
+            if (isset($components['query'])) $components['query'] .= '&'.trim($this->withURIQuery);
             else $components['query'] = trim($this->withURIQuery);
         }
         $this->options['url'] = self::combineUrl($components);
@@ -524,11 +524,11 @@ 
             preg_match('/\/\/([^\/]+)/', $this->options['url'], $matches);
             $host = $matches[1];
             if (empty($this->options['headers']) || !is_array($this->options['headers'])) {
-                $this->options['headers'] = array('Host: ' . $host);
+                $this->options['headers'] = array('Host: '.$host);
             } else {
-                $this->options['headers'][] = 'Host: ' . $host;
+                $this->options['headers'][] = 'Host: '.$host;
             }
-            $this->options['url'] = str_replace("//{$host}", '//' . $this->options['ip'], $this->options['url']);
+            $this->options['url'] = str_replace("//{$host}", '//'.$this->options['ip'], $this->options['url']);
             unset($host);
         }
         //process version
@@ -546,14 +546,14 @@ 
         //convert secs to milliseconds
         if (defined('CURLOPT_TIMEOUT_MS')) {
             if (!isset($this->options['timeout_ms'])) {
-                $this->options['timeout_ms'] = intval($this->options['timeout'] * 1000);
+                $this->options['timeout_ms'] = intval($this->options['timeout']*1000);
             } else {
                 $this->options['timeout_ms'] = intval($this->options['timeout_ms']);
             }
         }
 
         $cURLOptions = self::filterAndRaw($this->options);
-        if(isset($this->body))$cURLOptions[CURLOPT_POSTFIELDS] = $this->body;//use serialized body not raw data
+        if (isset($this->body))$cURLOptions[CURLOPT_POSTFIELDS] = $this->body; //use serialized body not raw data
         curl_setopt_array($this->curlHandle, $cURLOptions);
 
         return $this;
@@ -566,7 +566,7 @@ 
             $this->options[CURLOPT_POST] = true;
             $clz = '\\MultiHttp\\Handler\\'.ucfirst($this->sendMime);
             $inst = new $clz;
-            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz.' is not implement of  IHandler');
             $this->body = $inst->encode($this->options['data']);
         }
     }
@@ -578,7 +578,7 @@ 
     public function onEnd(callable $callback)
     {
         if (!is_callable($callback)) {
-            throw new InvalidArgumentException('callback not is callable :' . print_r($callback, 1));
+            throw new InvalidArgumentException('callback not is callable :'.print_r($callback, 1));
         }
 
         $this->endCallback = $callback;

Braces +27 added lines, -10 removed lines

@@ -246,7 +246,9 @@ 
      */
     public function getIni($field = null)
     {
-        if(!$field) return $this->options;
+        if(!$field) {
+        	return $this->options;
+        }
         $full = self::fullOption($field);
         return isset($this->options[$full]) ? $this->options[$full] : false;
     }
@@ -437,12 +439,15 @@ 
     public function send($isMultiCurl = false)
     {
         try {
-            if (!$this->hasInitialized)
-                $this->applyOptions();
+            if (!$this->hasInitialized) {
+                            $this->applyOptions();
+            }
             $response = $this->makeResponse($isMultiCurl);
             $response->parse();
         } catch (\Exception $e) {
-            if(!isset($response)) $response = Response::create($this, null, null, null, null);
+            if(!isset($response)) {
+            	$response = Response::create($this, null, null, null, null);
+            }
             $response->error = $e->getMessage();
             $response->errorCode = 999;
         }
@@ -506,12 +511,19 @@ 
         $this->serializeBody();
 
         //try fix url
-        if (strpos($this->options['url'], '://') === FALSE) $this->options['url'] = 'http://' . $this->options['url'];
+        if (strpos($this->options['url'], '://') === FALSE) {
+        	$this->options['url'] = 'http://' . $this->options['url'];
+        }
         $components = parse_url($this->options['url']);
-        if(FALSE === $components) throw new InvalidArgumentException('formatting url occurs error: '. $this->options['url']);
+        if(FALSE === $components) {
+        	throw new InvalidArgumentException('formatting url occurs error: '. $this->options['url']);
+        }
         if($this->withURIQuery){
-            if(isset($components['query'])) $components['query'] .= '&'. trim($this->withURIQuery);
-            else $components['query'] = trim($this->withURIQuery);
+            if(isset($components['query'])) {
+            	$components['query'] .= '&'. trim($this->withURIQuery);
+            } else {
+            	$components['query'] = trim($this->withURIQuery);
+            }
         }
         $this->options['url'] = self::combineUrl($components);
 
@@ -553,7 +565,10 @@ 
         }
 
         $cURLOptions = self::filterAndRaw($this->options);
-        if(isset($this->body))$cURLOptions[CURLOPT_POSTFIELDS] = $this->body;//use serialized body not raw data
+        if(isset($this->body)) {
+        	$cURLOptions[CURLOPT_POSTFIELDS] = $this->body;
+        }
+        //use serialized body not raw data
         curl_setopt_array($this->curlHandle, $cURLOptions);
 
         return $this;
@@ -566,7 +581,9 @@ 
             $this->options[CURLOPT_POST] = true;
             $clz = '\\MultiHttp\\Handler\\'.ucfirst($this->sendMime);
             $inst = new $clz;
-            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+            if (!($inst instanceof Handler\IHandler)) {
+            	throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+            }
             $this->body = $inst->encode($this->options['data']);
         }
     }

src/Response.php

Indentation +90 added lines, -90 removed lines

@@ -22,104 +22,104 @@
  */
 class Response
 {
-    public
-        $code,
-        $errorCode,
-        $error,
-        $header,
-        $body,
-        /**
-         * @var Request
-         */
-        $request,
-        $contentType,
-        $charset,
-        $duration,
-        $info;
+	public
+		$code,
+		$errorCode,
+		$error,
+		$header,
+		$body,
+		/**
+		 * @var Request
+		 */
+		$request,
+		$contentType,
+		$charset,
+		$duration,
+		$info;
 
-    /**
-     * Response constructor.
-     */
-    protected function __construct()
-    {
-    }
+	/**
+	 * Response constructor.
+	 */
+	protected function __construct()
+	{
+	}
 
-    /**
-     * @param Request $request
-     * @param $body
-     * @param $info
-     * @param $errorCode
-     * @param $error
-     * @return Response
-     */
-    public static function create(Request $request, $body, $info, $errorCode, $error)
-    {
-        $self = new self;
-        $self->request = $request;
-        $self->body = $body;
-        $self->info = $info;
-        $self->errorCode = $errorCode;
-        $self->error = $error;
-        return $self;
-    }
+	/**
+	 * @param Request $request
+	 * @param $body
+	 * @param $info
+	 * @param $errorCode
+	 * @param $error
+	 * @return Response
+	 */
+	public static function create(Request $request, $body, $info, $errorCode, $error)
+	{
+		$self = new self;
+		$self->request = $request;
+		$self->body = $body;
+		$self->info = $info;
+		$self->errorCode = $errorCode;
+		$self->error = $error;
+		return $self;
+	}
 
 
 
-    public function parse()
-    {
-        //has header
-        $headers = rtrim(substr($this->body, 0, $this->info['header_size']));
-        $this->body = substr($this->body, $this->info['header_size']);
-        $headers = explode(PHP_EOL, $headers);
-        array_shift($headers); // HTTP HEADER
-        foreach ($headers as $h) {
-            if (false !== strpos($h, ':'))
-                list($k, $v) = explode(':', $h, 2);
-            else
-                list($k, $v) = array($h, '');
+	public function parse()
+	{
+		//has header
+		$headers = rtrim(substr($this->body, 0, $this->info['header_size']));
+		$this->body = substr($this->body, $this->info['header_size']);
+		$headers = explode(PHP_EOL, $headers);
+		array_shift($headers); // HTTP HEADER
+		foreach ($headers as $h) {
+			if (false !== strpos($h, ':'))
+				list($k, $v) = explode(':', $h, 2);
+			else
+				list($k, $v) = array($h, '');
 
-            $this->header[trim($k)] = trim($v);
-        }
+			$this->header[trim($k)] = trim($v);
+		}
 
-        $this->code = $this->info['http_code'];
-        $this->duration = $this->info['total_time'];
-        $this->contentType = $this->info['content_type'];
-        $content_type = isset($this->info['content_type']) ? $this->info['content_type'] : '';
-        $content_type = explode(';', $content_type);
-        $this->contentType = $content_type[0];
-        if (count($content_type) == 2 && strpos($content_type[1], '=') !== false) {
-            list(, $this->charset) = explode('=', $content_type[1]);
-        }
+		$this->code = $this->info['http_code'];
+		$this->duration = $this->info['total_time'];
+		$this->contentType = $this->info['content_type'];
+		$content_type = isset($this->info['content_type']) ? $this->info['content_type'] : '';
+		$content_type = explode(';', $content_type);
+		$this->contentType = $content_type[0];
+		if (count($content_type) == 2 && strpos($content_type[1], '=') !== false) {
+			list(, $this->charset) = explode('=', $content_type[1]);
+		}
 
-        $this->unserializeBody();
+		$this->unserializeBody();
 
-    }
-    public function unserializeBody()
-    {
-        if (isset($this->request->expectsMime)) {
-            if (Mime::getFullMime($this->request->expectsMime) !== $this->contentType) throw new UnexpectedResponseException('expected mime can not be matched, real mime:'. $this->contentType. ', expected mime:'. Mime::getFullMime($this->request->expectsMime));
-            $clz = "\MultiHttp\\Handler\\".ucfirst($this->request->expectsMime);
-            $inst = new $clz;
-            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
-            $this->body = $inst->decode($this->body);
-        }
-    }
-    /**
-     * Status Code Definitions
-     *
-     * Informational 1xx
-     * Successful    2xx
-     * Redirection   3xx
-     * Client Error  4xx
-     * Server Error  5xx
-     *
-     * http://pretty-rfc.herokuapp.com/RFC2616#status.codes
-     *
-     * @return bool Did we receive a 4xx or 5xx?
-     */
-    public function hasErrors()
-    {
-        return $this->code == 0 || $this->code >= 400;
-    }
+	}
+	public function unserializeBody()
+	{
+		if (isset($this->request->expectsMime)) {
+			if (Mime::getFullMime($this->request->expectsMime) !== $this->contentType) throw new UnexpectedResponseException('expected mime can not be matched, real mime:'. $this->contentType. ', expected mime:'. Mime::getFullMime($this->request->expectsMime));
+			$clz = "\MultiHttp\\Handler\\".ucfirst($this->request->expectsMime);
+			$inst = new $clz;
+			if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+			$this->body = $inst->decode($this->body);
+		}
+	}
+	/**
+	 * Status Code Definitions
+	 *
+	 * Informational 1xx
+	 * Successful    2xx
+	 * Redirection   3xx
+	 * Client Error  4xx
+	 * Server Error  5xx
+	 *
+	 * http://pretty-rfc.herokuapp.com/RFC2616#status.codes
+	 *
+	 * @return bool Did we receive a 4xx or 5xx?
+	 */
+	public function hasErrors()
+	{
+		return $this->code == 0 || $this->code >= 400;
+	}
 
 }
\ No newline at end of file

Spacing +2 added lines, -2 removed lines

@@ -97,10 +97,10 @@
     public function unserializeBody()
     {
         if (isset($this->request->expectsMime)) {
-            if (Mime::getFullMime($this->request->expectsMime) !== $this->contentType) throw new UnexpectedResponseException('expected mime can not be matched, real mime:'. $this->contentType. ', expected mime:'. Mime::getFullMime($this->request->expectsMime));
+            if (Mime::getFullMime($this->request->expectsMime) !== $this->contentType) throw new UnexpectedResponseException('expected mime can not be matched, real mime:'.$this->contentType.', expected mime:'.Mime::getFullMime($this->request->expectsMime));
             $clz = "\MultiHttp\\Handler\\".ucfirst($this->request->expectsMime);
             $inst = new $clz;
-            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz.' is not implement of  IHandler');
             $this->body = $inst->decode($this->body);
         }
     }

Braces +11 added lines, -6 removed lines

@@ -73,10 +73,11 @@ 
         $headers = explode(PHP_EOL, $headers);
         array_shift($headers); // HTTP HEADER
         foreach ($headers as $h) {
-            if (false !== strpos($h, ':'))
-                list($k, $v) = explode(':', $h, 2);
-            else
-                list($k, $v) = array($h, '');
+            if (false !== strpos($h, ':')) {
+                            list($k, $v) = explode(':', $h, 2);
+            } else {
+                            list($k, $v) = array($h, '');
+            }
 
             $this->header[trim($k)] = trim($v);
         }
@@ -97,10 +98,14 @@ 
     public function unserializeBody()
     {
         if (isset($this->request->expectsMime)) {
-            if (Mime::getFullMime($this->request->expectsMime) !== $this->contentType) throw new UnexpectedResponseException('expected mime can not be matched, real mime:'. $this->contentType. ', expected mime:'. Mime::getFullMime($this->request->expectsMime));
+            if (Mime::getFullMime($this->request->expectsMime) !== $this->contentType) {
+            	throw new UnexpectedResponseException('expected mime can not be matched, real mime:'. $this->contentType. ', expected mime:'. Mime::getFullMime($this->request->expectsMime));
+            }
             $clz = "\MultiHttp\\Handler\\".ucfirst($this->request->expectsMime);
             $inst = new $clz;
-            if (!($inst instanceof Handler\IHandler)) throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+            if (!($inst instanceof Handler\IHandler)) {
+            	throw new InvalidOperationException($clz . ' is not implement of  IHandler');
+            }
             $this->body = $inst->decode($this->body);
         }
     }

src/Handler/Json.php

Indentation +47 added lines, -47 removed lines

@@ -18,54 +18,54 @@
  */
 class Json implements IHandler
 {
-    /**
-     * @param $body
-     * @return string
-     */
-    public function encode($body)
-    {
-        return json_encode($body, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
-    }
+	/**
+	 * @param $body
+	 * @return string
+	 */
+	public function encode($body)
+	{
+		return json_encode($body, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
+	}
 
-    /**
-     * @param $body
-     * @return mixed
-     */
-    public function decode($body)
-    {
-        $parsed = json_decode($body, true);
-        if(json_last_error() !== JSON_ERROR_NONE)throw new UnexpectedResponseException('parsing json occurs error: '.  self::jsonLastErrorMsg() . ', raw body: ' .$body  );
-        return $parsed;
-    }
+	/**
+	 * @param $body
+	 * @return mixed
+	 */
+	public function decode($body)
+	{
+		$parsed = json_decode($body, true);
+		if(json_last_error() !== JSON_ERROR_NONE)throw new UnexpectedResponseException('parsing json occurs error: '.  self::jsonLastErrorMsg() . ', raw body: ' .$body  );
+		return $parsed;
+	}
 
-    /**
-     * @return string
-     */
-    private static function jsonLastErrorMsg(){
-        if(function_exists('json_last_error_msg')) return json_last_error_msg();
-        switch (json_last_error()) {
-            case JSON_ERROR_NONE:
-                return ' - No errors';
-                break;
-            case JSON_ERROR_DEPTH:
-                return ' - Maximum stack depth exceeded';
-                break;
-            case JSON_ERROR_STATE_MISMATCH:
-                return ' - Underflow or the modes mismatch';
-                break;
-            case JSON_ERROR_CTRL_CHAR:
-                return ' - Unexpected control character found';
-                break;
-            case JSON_ERROR_SYNTAX:
-                return ' - Syntax error, malformed JSON';
-                break;
-            case JSON_ERROR_UTF8:
-                return ' - Malformed UTF-8 characters, possibly incorrectly encoded';
-                break;
-            default:
-                return ' - Unknown error';
-                break;
-        }
-    }
+	/**
+	 * @return string
+	 */
+	private static function jsonLastErrorMsg(){
+		if(function_exists('json_last_error_msg')) return json_last_error_msg();
+		switch (json_last_error()) {
+			case JSON_ERROR_NONE:
+				return ' - No errors';
+				break;
+			case JSON_ERROR_DEPTH:
+				return ' - Maximum stack depth exceeded';
+				break;
+			case JSON_ERROR_STATE_MISMATCH:
+				return ' - Underflow or the modes mismatch';
+				break;
+			case JSON_ERROR_CTRL_CHAR:
+				return ' - Unexpected control character found';
+				break;
+			case JSON_ERROR_SYNTAX:
+				return ' - Syntax error, malformed JSON';
+				break;
+			case JSON_ERROR_UTF8:
+				return ' - Malformed UTF-8 characters, possibly incorrectly encoded';
+				break;
+			default:
+				return ' - Unknown error';
+				break;
+		}
+	}
 }
 

Spacing +3 added lines, -3 removed lines

@@ -34,15 +34,15 @@
     public function decode($body)
     {
         $parsed = json_decode($body, true);
-        if(json_last_error() !== JSON_ERROR_NONE)throw new UnexpectedResponseException('parsing json occurs error: '.  self::jsonLastErrorMsg() . ', raw body: ' .$body  );
+        if (json_last_error() !== JSON_ERROR_NONE)throw new UnexpectedResponseException('parsing json occurs error: '.self::jsonLastErrorMsg().', raw body: '.$body);
         return $parsed;
     }
 
     /**
      * @return string
      */
-    private static function jsonLastErrorMsg(){
-        if(function_exists('json_last_error_msg')) return json_last_error_msg();
+    private static function jsonLastErrorMsg() {
+        if (function_exists('json_last_error_msg')) return json_last_error_msg();
         switch (json_last_error()) {
             case JSON_ERROR_NONE:
                 return ' - No errors';

Braces +6 added lines, -2 removed lines

@@ -34,7 +34,9 @@ 
     public function decode($body)
     {
         $parsed = json_decode($body, true);
-        if(json_last_error() !== JSON_ERROR_NONE)throw new UnexpectedResponseException('parsing json occurs error: '.  self::jsonLastErrorMsg() . ', raw body: ' .$body  );
+        if(json_last_error() !== JSON_ERROR_NONE) {
+        	throw new UnexpectedResponseException('parsing json occurs error: '.  self::jsonLastErrorMsg() . ', raw body: ' .$body  );
+        }
         return $parsed;
     }
 
@@ -42,7 +44,9 @@ 
      * @return string
      */
     private static function jsonLastErrorMsg(){
-        if(function_exists('json_last_error_msg')) return json_last_error_msg();
+        if(function_exists('json_last_error_msg')) {
+        	return json_last_error_msg();
+        }
         switch (json_last_error()) {
             case JSON_ERROR_NONE:
                 return ' - No errors';

src/Handler/Form.php

Indentation +19 added lines, -19 removed lines

@@ -17,25 +17,25 @@
  */
 class Form implements IHandler
 {
-    /**
-     * @param $body
-     * @return string
-     */
-    public function encode($body)
-    {
-        return is_array($body) ? http_build_query($body) : $body;
-    }
+	/**
+	 * @param $body
+	 * @return string
+	 */
+	public function encode($body)
+	{
+		return is_array($body) ? http_build_query($body) : $body;
+	}
 
-    /**
-     * @param $body
-     * @return mixed
-     */
-    public function decode($body)
-    {
-        if(is_string($body)){
-            parse_str($body, $body);
-        }
-        return $body;
-    }
+	/**
+	 * @param $body
+	 * @return mixed
+	 */
+	public function decode($body)
+	{
+		if(is_string($body)){
+			parse_str($body, $body);
+		}
+		return $body;
+	}
 }
 

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
      */
     public function decode($body)
     {
-        if(is_string($body)){
+        if (is_string($body)) {
             parse_str($body, $body);
         }
         return $body;

src/Handler/Upload.php

Indentation +16 added lines, -16 removed lines

@@ -17,22 +17,22 @@
  */
 class Upload implements IHandler
 {
-    /**
-     * @param $body
-     * @return string
-     */
-    public function encode($body)
-    {
-        return $body;
-    }
+	/**
+	 * @param $body
+	 * @return string
+	 */
+	public function encode($body)
+	{
+		return $body;
+	}
 
-    /**
-     * @param $body
-     * @return mixed
-     */
-    public function decode($body)
-    {
-        return $body;
-    }
+	/**
+	 * @param $body
+	 * @return mixed
+	 */
+	public function decode($body)
+	{
+		return $body;
+	}
 }