@@ -35,14 +35,14 @@ discard block |
||
| 35 | 35 | 'timeout_ms' => 'CURLOPT_TIMEOUT_MS', // milliseconds, libcurl version > 7.36.0 , |
| 36 | 36 | ); |
| 37 | 37 | public $curlHandle; |
| 38 | - protected $options = array( |
|
| 39 | - 'CURLOPT_MAXREDIRS' => 10, |
|
| 40 | - 'header' => true, |
|
| 41 | - 'method' => self::GET, |
|
| 42 | - 'transfer' => true, |
|
| 43 | - 'follow_location' => true, |
|
| 44 | - 'timeout' => 0); |
|
| 45 | - protected $endCallback; |
|
| 38 | + protected $options = array( |
|
| 39 | + 'CURLOPT_MAXREDIRS' => 10, |
|
| 40 | + 'header' => true, |
|
| 41 | + 'method' => self::GET, |
|
| 42 | + 'transfer' => true, |
|
| 43 | + 'follow_location' => true, |
|
| 44 | + 'timeout' => 0); |
|
| 45 | + protected $endCallback; |
|
| 46 | 46 | protected $withURIQuery; |
| 47 | 47 | protected static $logger; |
| 48 | 48 | protected $uri; |
@@ -113,8 +113,8 @@ discard block |
||
| 113 | 113 | |
| 114 | 114 | public function addOptions(array $options = array()) { |
| 115 | 115 | $this->options = $options+$this->options; |
| 116 | - $this->uri = $this->options['url']; |
|
| 117 | - return $this; |
|
| 116 | + $this->uri = $this->options['url']; |
|
| 117 | + return $this; |
|
| 118 | 118 | } |
| 119 | 119 | |
| 120 | 120 | /* no body */ |
@@ -151,7 +151,7 @@ discard block |
||
| 151 | 151 | * @return Response |
| 152 | 152 | */ |
| 153 | 153 | public function send() { |
| 154 | - $this->applyOptions(); |
|
| 154 | + $this->applyOptions(); |
|
| 155 | 155 | $response = $this->makeResponse(); |
| 156 | 156 | if ($this->endCallback) { |
| 157 | 157 | $func = $this->endCallback; |
@@ -168,21 +168,21 @@ discard block |
||
| 168 | 168 | } |
| 169 | 169 | |
| 170 | 170 | protected function prepare() { |
| 171 | - if (empty($this->options['url'])) { |
|
| 172 | - throw new InvalidArgumentException('url can not empty'); |
|
| 173 | - } |
|
| 174 | - |
|
| 175 | - if (isset($this->options['data'])) { |
|
| 176 | - $this->options['data'] = is_array($this->options['data'])?http_build_query($this->options['data']):$this->options['data'];//for better compatibility |
|
| 177 | - } |
|
| 178 | - if (isset($this->withURIQuery)) { |
|
| 179 | - $this->options['url'] .= strpos($this->options['url'], '?') === FALSE?'?':'&'; |
|
| 180 | - $this->options['url'] .= $this->withURIQuery; |
|
| 181 | - } |
|
| 182 | - if (isset($this->options['callback'])) { |
|
| 183 | - $this->onEnd($this->options['callback']); |
|
| 184 | - unset($this->options['callback']); |
|
| 185 | - } |
|
| 171 | + if (empty($this->options['url'])) { |
|
| 172 | + throw new InvalidArgumentException('url can not empty'); |
|
| 173 | + } |
|
| 174 | + |
|
| 175 | + if (isset($this->options['data'])) { |
|
| 176 | + $this->options['data'] = is_array($this->options['data'])?http_build_query($this->options['data']):$this->options['data'];//for better compatibility |
|
| 177 | + } |
|
| 178 | + if (isset($this->withURIQuery)) { |
|
| 179 | + $this->options['url'] .= strpos($this->options['url'], '?') === FALSE?'?':'&'; |
|
| 180 | + $this->options['url'] .= $this->withURIQuery; |
|
| 181 | + } |
|
| 182 | + if (isset($this->options['callback'])) { |
|
| 183 | + $this->onEnd($this->options['callback']); |
|
| 184 | + unset($this->options['callback']); |
|
| 185 | + } |
|
| 186 | 186 | //swap ip and host |
| 187 | 187 | if (!empty($this->options['ip'])) { |
| 188 | 188 | $matches = array(); |
@@ -219,7 +219,7 @@ discard block |
||
| 219 | 219 | |
| 220 | 220 | $cURLOptions = self::filterAndRaw($this->options); |
| 221 | 221 | |
| 222 | - curl_setopt_array($this->curlHandle, $cURLOptions); |
|
| 222 | + curl_setopt_array($this->curlHandle, $cURLOptions); |
|
| 223 | 223 | |
| 224 | 224 | return $this; |
| 225 | 225 | } |
@@ -228,11 +228,11 @@ discard block |
||
| 228 | 228 | $opts = array(); |
| 229 | 229 | foreach ($options as $key => $val) { |
| 230 | 230 | $alias = self::optionAlias($key); |
| 231 | - $options[$alias] = $val; |
|
| 232 | - if ($alias) {$opts[constant($alias)] = $val; |
|
| 233 | - } |
|
| 234 | - unset($options[$key]); |
|
| 235 | - } |
|
| 231 | + $options[$alias] = $val; |
|
| 232 | + if ($alias) {$opts[constant($alias)] = $val; |
|
| 233 | + } |
|
| 234 | + unset($options[$key]); |
|
| 235 | + } |
|
| 236 | 236 | return $opts; |
| 237 | 237 | } |
| 238 | 238 | |
@@ -254,26 +254,26 @@ discard block |
||
| 254 | 254 | $info = curl_getinfo($this->curlHandle); |
| 255 | 255 | $errno = curl_errno($this->curlHandle); |
| 256 | 256 | $error = curl_error($this->curlHandle); |
| 257 | - $response = Response::create($this, $body, $info, $errno, $error); |
|
| 258 | - self::log($response); |
|
| 257 | + $response = Response::create($this, $body, $info, $errno, $error); |
|
| 258 | + self::log($response); |
|
| 259 | 259 | return $response; |
| 260 | 260 | } |
| 261 | 261 | |
| 262 | - private static function log(Response $response) |
|
| 263 | - { |
|
| 264 | - if (is_null(self::$logger)) { |
|
| 265 | - return; |
|
| 266 | - } |
|
| 267 | - if($response->hasErrors()){ |
|
| 268 | - self::$logger->error($response->request->getURI() . "\t" . $response->error, array( |
|
| 269 | - 'response' => print_r($response,1), |
|
| 270 | - )); |
|
| 271 | - } |
|
| 272 | - |
|
| 273 | - } |
|
| 274 | - |
|
| 275 | - public static function setLogger($logger) |
|
| 276 | - { |
|
| 277 | - self::$logger = $logger; |
|
| 278 | - } |
|
| 262 | + private static function log(Response $response) |
|
| 263 | + { |
|
| 264 | + if (is_null(self::$logger)) { |
|
| 265 | + return; |
|
| 266 | + } |
|
| 267 | + if($response->hasErrors()){ |
|
| 268 | + self::$logger->error($response->request->getURI() . "\t" . $response->error, array( |
|
| 269 | + 'response' => print_r($response,1), |
|
| 270 | + )); |
|
| 271 | + } |
|
| 272 | + |
|
| 273 | + } |
|
| 274 | + |
|
| 275 | + public static function setLogger($logger) |
|
| 276 | + { |
|
| 277 | + self::$logger = $logger; |
|
| 278 | + } |
|
| 279 | 279 | } |
@@ -17,7 +17,7 @@ discard block |
||
| 17 | 17 | protected static $curlAlias = array( |
| 18 | 18 | 'url' => 'CURLOPT_URL', |
| 19 | 19 | 'uri' => 'CURLOPT_URL', |
| 20 | - 'debug' => 'CURLOPT_VERBOSE',//for debug verbose |
|
| 20 | + 'debug' => 'CURLOPT_VERBOSE', //for debug verbose |
|
| 21 | 21 | 'method' => 'CURLOPT_CUSTOMREQUEST', |
| 22 | 22 | 'data' => 'CURLOPT_POSTFIELDS', // array or string , file begin with '@' |
| 23 | 23 | 'ua' => 'CURLOPT_USERAGENT', |
@@ -83,7 +83,7 @@ discard block |
||
| 83 | 83 | $alias = self::optionAlias($field); |
| 84 | 84 | // if (null === ($rawField = constant($alias))) {throw new InvalidArgumentException('field is invalid'); |
| 85 | 85 | // } |
| 86 | - return isset($this->options[$alias])?$this->options[$alias]:false; |
|
| 86 | + return isset($this->options[$alias]) ? $this->options[$alias] : false; |
|
| 87 | 87 | } |
| 88 | 88 | |
| 89 | 89 | |
@@ -173,10 +173,10 @@ discard block |
||
| 173 | 173 | } |
| 174 | 174 | |
| 175 | 175 | if (isset($this->options['data'])) { |
| 176 | - $this->options['data'] = is_array($this->options['data'])?http_build_query($this->options['data']):$this->options['data'];//for better compatibility |
|
| 176 | + $this->options['data'] = is_array($this->options['data']) ? http_build_query($this->options['data']) : $this->options['data']; //for better compatibility |
|
| 177 | 177 | } |
| 178 | 178 | if (isset($this->withURIQuery)) { |
| 179 | - $this->options['url'] .= strpos($this->options['url'], '?') === FALSE?'?':'&'; |
|
| 179 | + $this->options['url'] .= strpos($this->options['url'], '?') === FALSE ? '?' : '&'; |
|
| 180 | 180 | $this->options['url'] .= $this->withURIQuery; |
| 181 | 181 | } |
| 182 | 182 | if (isset($this->options['callback'])) { |
@@ -219,7 +219,7 @@ discard block |
||
| 219 | 219 | |
| 220 | 220 | $cURLOptions = self::filterAndRaw($this->options); |
| 221 | 221 | |
| 222 | - curl_setopt_array($this->curlHandle, $cURLOptions); |
|
| 222 | + curl_setopt_array($this->curlHandle, $cURLOptions); |
|
| 223 | 223 | |
| 224 | 224 | return $this; |
| 225 | 225 | } |
@@ -250,7 +250,7 @@ discard block |
||
| 250 | 250 | return $alias; |
| 251 | 251 | } |
| 252 | 252 | public function makeResponse($isMultiCurl = false) { |
| 253 | - $body = $isMultiCurl?curl_multi_getcontent($this->curlHandle):curl_exec($this->curlHandle); |
|
| 253 | + $body = $isMultiCurl ? curl_multi_getcontent($this->curlHandle) : curl_exec($this->curlHandle); |
|
| 254 | 254 | $info = curl_getinfo($this->curlHandle); |
| 255 | 255 | $errno = curl_errno($this->curlHandle); |
| 256 | 256 | $error = curl_error($this->curlHandle); |
@@ -264,9 +264,9 @@ discard block |
||
| 264 | 264 | if (is_null(self::$logger)) { |
| 265 | 265 | return; |
| 266 | 266 | } |
| 267 | - if($response->hasErrors()){ |
|
| 268 | - self::$logger->error($response->request->getURI() . "\t" . $response->error, array( |
|
| 269 | - 'response' => print_r($response,1), |
|
| 267 | + if ($response->hasErrors()) { |
|
| 268 | + self::$logger->error($response->request->getURI()."\t".$response->error, array( |
|
| 269 | + 'response' => print_r($response, 1), |
|
| 270 | 270 | )); |
| 271 | 271 | } |
| 272 | 272 | |