chillerlan / php-curl

src/MultiRequest.php

Spacing +27 added lines, -27 removed lines

@@ -19,7 +19,7 @@ 
  *
  * @link http://www.onlineaspect.com/2009/01/26/how-to-use-curl_multi-without-blocking/
  */
-class MultiRequest{
+class MultiRequest {
 
 	/**
 	 * the curl_multi master handle
@@ -64,15 +64,15 @@ 
 	 *
 	 * @param \chillerlan\TinyCurl\MultiRequestOptions $options
 	 */
-	public function __construct(MultiRequestOptions $options = null){
+	public function __construct(MultiRequestOptions $options = null) {
 
-		if(!$options){
+		if (!$options) {
 			$options = new MultiRequestOptions;
 		}
 
 		$this->options = $options;
 
-		if($this->options->handler){
+		if ($this->options->handler) {
 			$this->setHandler();
 		}
 
@@ -92,8 +92,8 @@ 
 	 *
 	 * @codeCoverageIgnore
 	 */
-	public function __destruct(){
-		if($this->curl_multi){
+	public function __destruct() {
+		if ($this->curl_multi) {
 			curl_multi_close($this->curl_multi);
 		}
 	}
@@ -104,17 +104,17 @@ 
 	 * @return $this
 	 * @throws \chillerlan\TinyCurl\RequestException
 	 */
-	public function setHandler(MultiResponseHandlerInterface $handler = null){
+	public function setHandler(MultiResponseHandlerInterface $handler = null) {
 
-		if(!$handler){
+		if (!$handler) {
 
-			if(!class_exists($this->options->handler)){
+			if (!class_exists($this->options->handler)) {
 				throw new RequestException('!$this->options->handler');
 			}
 
 			$handler = new $this->options->handler($this);
 
-			if(!is_a($handler, MultiResponseHandlerInterface::class)){
+			if (!is_a($handler, MultiResponseHandlerInterface::class)) {
 				throw new RequestException('!is_a($handler)');
 			}
 
@@ -131,9 +131,9 @@ 
 	 * @return $this
 	 * @throws \chillerlan\TinyCurl\RequestException
 	 */
-	public function fetch(array $urls){
+	public function fetch(array $urls) {
 
-		if(empty($urls)){
+		if (empty($urls)) {
 			throw new RequestException('empty($urls)');
 		}
 
@@ -142,12 +142,12 @@ 
 
 		$url_count = count($this->stack);
 
-		if($this->options->window_size > $url_count){
+		if ($this->options->window_size > $url_count) {
 			$this->options->window_size = $url_count;
 		}
 
 		// shoot out the first batch of requests
-		array_map(function(){
+		array_map(function() {
 			$this->createHandle();
 		}, range(1, $this->options->window_size));
 
@@ -163,7 +163,7 @@ 
 	 * @see \chillerlan\TinyCurl\Response\MultiResponseHandlerInterface
 	 * @return $this
 	 */
-	public function addResponse($response){
+	public function addResponse($response) {
 		$this->responses[] = $response;
 
 		return $this;
@@ -172,24 +172,24 @@ 
 	/**
 	 * @return array
 	 */
-	public function getResponseData(){
+	public function getResponseData() {
 		return $this->responses;
 	}
 
 	/**
 	 * creates a new handle for $request[$index]
 	 */
-	protected function createHandle(){
+	protected function createHandle() {
 
-		if(!empty($this->stack)){
+		if (!empty($this->stack)) {
 			$url = array_shift($this->stack);
 
-			if($url instanceof URL){
+			if ($url instanceof URL) {
 				$curl = curl_init($url);
 				curl_setopt_array($curl, $this->curl_options);
 				curl_multi_add_handle($this->curl_multi, $curl);
 			}
-			else{
+			else {
 				// retry on next if we don't get what we expect
 				$this->createHandle();
 			}
@@ -201,19 +201,19 @@ 
 	/**
 	 * processes the requests
 	 */
-	protected function processStack(){
+	protected function processStack() {
 
-		do{
+		do {
 
-			if(curl_multi_exec($this->curl_multi, $active) !== CURLM_OK){
+			if (curl_multi_exec($this->curl_multi, $active) !== CURLM_OK) {
 				break; // @codeCoverageIgnore
 			}
 
 			// welcome to callback hell.
-			while($state = curl_multi_info_read($this->curl_multi)){
+			while ($state = curl_multi_info_read($this->curl_multi)) {
 				$url = $this->multiResponseHandler->handleResponse(new MultiResponse($state['handle']));
 
-				if($url instanceof URL){
+				if ($url instanceof URL) {
 					$this->stack[] = $url;
 				}
 
@@ -221,12 +221,12 @@ 
 				curl_multi_remove_handle($this->curl_multi, $state['handle']);
 			}
 
-			if($active){
+			if ($active) {
 				curl_multi_select($this->curl_multi, $this->options->timeout);
 			}
 
 		}
-		while($active);
+		while ($active);
 
 	}
 

Braces +1 added lines, -2 removed lines

@@ -188,8 +188,7 @@
 				$curl = curl_init($url);
 				curl_setopt_array($curl, $this->curl_options);
 				curl_multi_add_handle($this->curl_multi, $curl);
-			}
-			else{
+			} else{
 				// retry on next if we don't get what we expect
 				$this->createHandle();
 			}

src/MultiRequestOptions.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 /**
  * Class MultiRequestOptions
  */
-class MultiRequestOptions extends RequestOptions{
+class MultiRequestOptions extends RequestOptions {
 
 	public $handler = null;
 

src/Request.php

Spacing +10 added lines, -10 removed lines

@@ -18,7 +18,7 @@ 
 /**
  *
  */
-class Request{
+class Request {
 
 	/**
 	 * The cURL connection
@@ -37,9 +37,9 @@ 
 	 *
 	 * @param \chillerlan\TinyCurl\RequestOptions $options
 	 */
-	public function __construct(RequestOptions $options = null){
+	public function __construct(RequestOptions $options = null) {
 
-		if(!$options){
+		if (!$options) {
 			$options = new RequestOptions;
 		}
 
@@ -51,7 +51,7 @@ 
 	 *
 	 * @return ResponseInterface
 	 */
-	protected function getResponse($url){
+	protected function getResponse($url) {
 		$ca_info = is_file($this->options->ca_info) ? $this->options->ca_info : null;
 
 		curl_setopt_array($this->curl, $this->options->curl_options + [
@@ -71,10 +71,10 @@ 
 	 * @return \chillerlan\TinyCurl\Response\ResponseInterface
 	 * @throws \chillerlan\TinyCurl\RequestException
 	 */
-	public function fetch(URL $url){
+	public function fetch(URL $url) {
 		$this->curl = curl_init();
 
-		if(!$url->host || !in_array($url->scheme, ['http', 'https', 'ftp'], true)){
+		if (!$url->host || !in_array($url->scheme, ['http', 'https', 'ftp'], true)) {
 			throw new RequestException('$url');
 		}
 
@@ -86,10 +86,10 @@ 
 	 *
 	 * @return array
 	 */
-	public function extractShortUrl($url){
+	public function extractShortUrl($url) {
 		$urls = [$url];
 
-		while($url = $this->extract($url)){
+		while ($url = $this->extract($url)) {
 			$urls[] = $url;
 		}
 
@@ -102,7 +102,7 @@ 
 	 * @return string|bool
 	 * @link http://www.internoetics.com/2012/11/12/resolve-short-urls-to-their-destination-url-php-api/
 	 */
-	protected function extract($url){
+	protected function extract($url) {
 		$this->curl = curl_init();
 
 		curl_setopt_array($this->curl, [
@@ -114,7 +114,7 @@ 
 		$info    = $response->info;
 		$headers = $response->headers;
 
-		switch(true){
+		switch (true) {
 			// check curl_info()
 			case in_array($info->http_code, range(300, 308), true) && isset($info->redirect_url) && !empty($info->redirect_url):
 				return $info->redirect_url;

src/RequestException.php

Spacing +1 added lines, -1 removed lines

@@ -16,6 +16,6 @@
 /**
  * Class RequestException
  */
-class RequestException extends Exception{
+class RequestException extends Exception {
 
 }

src/RequestOptions.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 /**
  * Class RequestOptions
  */
-class RequestOptions{
+class RequestOptions {
 
 	/**
 	 * options for each curl instance

src/Response/MultiResponse.php

Spacing +4 added lines, -4 removed lines

@@ -15,19 +15,19 @@
 /**
  *
  */
-class MultiResponse extends Response implements ResponseInterface{
+class MultiResponse extends Response implements ResponseInterface {
 
 	/**
 	 * Fills self::$response_body and calls self::getInfo()
 	 */
-	protected function exec(){
+	protected function exec() {
 		$response = explode("\r\n\r\n", curl_multi_getcontent($this->curl), 2);
 		$headers = isset($response[0]) ? explode("\r\n", $response[0]) : null;
 		$this->response_body = isset($response[1]) ? $response[1] : null;
 		$this->getInfo();
 
-		if(is_array($headers)){
-			foreach($headers as $line){
+		if (is_array($headers)) {
+			foreach ($headers as $line) {
 				$this->headerLine(null, $line);
 			}
 		}

src/Response/MultiResponseHandlerInterface.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
 /**
  *
  */
-interface MultiResponseHandlerInterface{
+interface MultiResponseHandlerInterface {
 
 	/**
 	 * The response handler.

src/Response/Response.php

Spacing +18 added lines, -18 removed lines

@@ -17,7 +17,7 @@ 
 /**
  *
  */
-class Response implements ResponseInterface{
+class Response implements ResponseInterface {
 
 	/**
 	 * @var resource
@@ -51,14 +51,14 @@ 
 	 *
 	 * @throws \chillerlan\TinyCurl\Response\ResponseException
 	 */
-	public function __construct($curl){
+	public function __construct($curl) {
 
-		if(!$curl){
+		if (!$curl) {
 			throw new ResponseException('!$curl');
 		}
 
 		$this->curl             = $curl;
- 		$this->curl_info        = new stdClass;
+ 		$this->curl_info = new stdClass;
 		$this->response_error   = new stdClass;
 		$this->response_headers = new stdClass;
 
@@ -68,8 +68,8 @@ 
 	/**
 	 * Farewell.
 	 */
-	public function __destruct(){
-		if($this->curl){
+	public function __destruct() {
+		if ($this->curl) {
 			curl_close($this->curl);
 		}
 	}
@@ -80,9 +80,9 @@ 
 	 * @return mixed
 	 * @throws \chillerlan\TinyCurl\Response\ResponseException
 	 */
-	public function __get($property){
+	public function __get($property) {
 
-		switch($property){
+		switch ($property) {
 			case 'body'   : return $this->getBody();
 			case 'info'   : return $this->curl_info;
 			case 'json'   : return json_decode($this->response_body);
@@ -96,7 +96,7 @@ 
 	/**
 	 * Fills self::$response_body and calls self::getInfo()
 	 */
-	protected function exec(){
+	protected function exec() {
 		curl_setopt($this->curl, CURLOPT_HEADERFUNCTION, [$this, 'headerLine']);
 		$this->response_body = curl_exec($this->curl);
 		$this->getInfo();
@@ -110,9 +110,9 @@ 
 	 *
 	 * @link http://php.net/manual/function.curl-setopt.php CURLOPT_HEADERFUNCTION
 	 */
-	protected function headerLine(/** @noinspection PhpUnusedParameterInspection */$curl, $header_line){
+	protected function headerLine(/** @noinspection PhpUnusedParameterInspection */$curl, $header_line) {
 
-		if(substr($header_line, 0, 4) === 'HTTP'){
+		if (substr($header_line, 0, 4) === 'HTTP') {
 			$status = explode(' ', $header_line, 3);
 
 			$this->response_headers->httpversion = explode('/', $status[0], 2)[1];
@@ -121,7 +121,7 @@ 
 		}
 
 		$h = explode(':', $header_line, 2);
-		if(count($h) === 2){
+		if (count($h) === 2) {
 			$this->response_headers->{trim(strtolower($h[0]))} = trim($h[1]);
 		}
 
@@ -131,17 +131,17 @@ 
 	/**
 	 * @return \stdClass
 	 */
-	protected function getBody(){
+	protected function getBody() {
 		$body = new stdClass;
 
 		$body->content = $this->response_body;
 		$body->length  = strlen($this->response_body);
 
-		if(isset($this->curl_info->content_type) && !empty($this->curl_info->content_type)){
+		if (isset($this->curl_info->content_type) && !empty($this->curl_info->content_type)) {
 			$body->content_type = $this->curl_info->content_type;
 		}
 		// @codeCoverageIgnoreStart
-		elseif(isset($this->response_headers->content_type) && !empty($this->response_headers->content_type)){
+		elseif (isset($this->response_headers->content_type) && !empty($this->response_headers->content_type)) {
 			$body->content_type = $this->response_headers->content_type;
 		}
 		// @codeCoverageIgnoreEnd
@@ -152,10 +152,10 @@ 
 	/**
 	 *
 	 */
-	protected function getInfo(){
+	protected function getInfo() {
 		$curl_info = curl_getinfo($this->curl);
-		if(is_array($curl_info)){
-			foreach($curl_info as $key => $value){
+		if (is_array($curl_info)) {
+			foreach ($curl_info as $key => $value) {
 				$this->curl_info->{$key} = $value;
 			}
 		}

src/Response/ResponseException.php

Spacing +1 added lines, -1 removed lines

@@ -16,6 +16,6 @@
 /**
  * Class ResponseException
  */
-class ResponseException extends Exception{
+class ResponseException extends Exception {
 
 }