CurlAdapter::sendRequest() - Code Metrics - Inspection of "Fix test for v2.6 SDK breaking change on the Reque..." - facebook/facebook-php-ads-sdk - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( a962f3...470970 )

unknown

created 2016-05-06 19:22 UTC

CurlAdapter::sendRequest() C

↳ Parent: CurlAdapter

Complexity

Conditions	12
Paths	128

Size

Total Lines	62
Code Lines	41

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	156

Metric	Value
dl	0
loc	62
ccs	0
cts	44
cp	0
rs	5.6398
cc	12
eloc	41
nc	128
nop	1
crap	156

How to fix Long Method Complexity

<?php
/**
 * Copyright (c) 2014-present, Facebook, Inc. All rights reserved.
 *
 * You are hereby granted a non-exclusive, worldwide, royalty-free license to
 * use, copy, modify, and distribute this software in source code or binary
 * form for use in connection with the web services and APIs provided by
 * Facebook.
 *
 * As with any software that integrates with the Facebook platform, your use
 * of this software is subject to the Facebook Developer Principles and
 * Policies [http://developers.facebook.com/policy/]. This copyright notice
 * shall be included in all copies or substantial portions of the software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
 * DEALINGS IN THE SOFTWARE.
 *
 */

namespace FacebookAds\Http\Adapter;

use FacebookAds\Exception\Exception;
use FacebookAds\Http\Adapter\Curl\AbstractCurl;
use FacebookAds\Http\Adapter\Curl\Curl;
use FacebookAds\Http\Adapter\Curl\CurlInterface;
use FacebookAds\Http\Client;
use FacebookAds\Http\Headers;
use FacebookAds\Http\RequestInterface;
use FacebookAds\Http\ResponseInterface;

class CurlAdapter extends AbstractAdapter {

  /**
   * @var CurlInterface
   */
  protected $curl;

  /**
   * @var \ArrayObject
   */
  protected $opts;

  /**
   * @param Client $client
   * @param CurlInterface $curl
   */
  public function __construct(Client $client, CurlInterface $curl = null) {
    parent::__construct($client);
    $this->curl = $curl ?: AbstractCurl::createOptimalVersion();
    $this->curl->init();
  }

  /**
   * @return Curl
   */
  public function getCurl() {
    return $this->curl;
  }

  /**
   * @return \ArrayObject
   */
  public function getOpts() {
    if ($this->opts === null) {
      $this->opts = new \ArrayObject(array(
        CURLOPT_CONNECTTIMEOUT => 10,
        CURLOPT_TIMEOUT => 60,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HEADER => true,
        CURLOPT_CAINFO => $this->getCaBundlePath(),
      ));
    }

    return $this->opts;
  }

  /**
   * @param \ArrayObject $opts
   */
  public function setOpts(\ArrayObject $opts) {
    $this->opts = $opts;
  }

  /**
   * @return int
   */
  protected function getheaderSize() {
    return $this->getCurl()->getInfo(CURLINFO_HEADER_SIZE);
  }

  /**
   * Extracts the headers and the body into a two-part array
   * @param string $raw_response
   * @return array
   */
  protected function extractResponseHeadersAndBody($raw_response) {
    $header_size = $this->getheaderSize();

    $raw_headers = mb_substr($raw_response, 0, $header_size);
    $raw_body = mb_substr($raw_response, $header_size);

    return array(trim($raw_headers), trim($raw_body));
  }

  /**
   * @param Headers $headers
   * @param string $raw_headers
   */
  protected function parseHeaders(Headers $headers, $raw_headers) {
    $raw_headers = str_replace("\r\n", "\n", $raw_headers);

    // There will be multiple headers if a 301 was followed
    // or a proxy was followed, etc
    $header_collection = explode("\n\n", trim($raw_headers));
    // We just want the last response (at the end)
    $raw_headers = array_pop($header_collection);

    $header_components = explode("\n", $raw_headers);
    foreach ($header_components as $line) {
      if (strpos($line, ': ') === false) {
        $headers['http_code'] = $line;
      } else {
        list ($key, $value) = explode(': ', $line);
        $headers[$key] = $value;
      }
    }
  }

  /**
   * @param RequestInterface $request
   * @return ResponseInterface
   * @throws Exception
   */
  public function sendRequest(RequestInterface $request) {
    $response = $this->getClient()->createResponse();
    $this->getCurl()->reset();
    $curlopts = array(
      CURLOPT_URL => $request->getUrl(),
    );

    $method = $request->getMethod();
    if ($method !== RequestInterface::METHOD_GET
      && $method !== RequestInterface::METHOD_POST) {
      $curlopts[CURLOPT_CUSTOMREQUEST] = $method;
    }

    $curlopts = $this->getOpts()->getArrayCopy() + $curlopts;

    if ($request->getHeaders()->count()) {
      $headers = array();
      foreach ($request->getHeaders() as $header => $value) {
        $headers[] = "{$header}: {$value}";
      }
      $curlopts[CURLOPT_HTTPHEADER] = $headers;
    }

    $postfields = array();
    if ($method === RequestInterface::METHOD_POST
      && $request->getFileParams()->count()
    ) {
      $postfields = array_merge(
        $postfields,
        array_map(
          array($this->getCurl(), 'preparePostFileField'),
          $request->getFileParams()->getArrayCopy()));
    }
    if ($method !== RequestInterface::METHOD_GET
      && $request->getBodyParams()->count()) {
      $postfields
        = array_merge($postfields, $request->getBodyParams()->export());
    }

    if (!empty($postfields)) {
      $curlopts[CURLOPT_POSTFIELDS] = $postfields;
    }

    $this->getCurl()->setoptArray($curlopts);
    $raw_response = $this->getCurl()->exec();

    $status_code = $this->getCurl()->getInfo(CURLINFO_HTTP_CODE);
    $curl_errno = $this->getCurl()->errno();
    $curl_error = $curl_errno ? $this->getCurl()->error() : null;

    $response_parts = $this->extractResponseHeadersAndBody($raw_response);

    $response->setStatusCode($status_code);
    $this->parseHeaders($response->getHeaders(), $response_parts[0]);
    $response->setBody($response_parts[1]);

    if ($curl_errno) {
      throw new Exception($curl_error, $curl_errno);
    }

    return $response;
  }
}


1		<?php
2		/**
3		* Copyright (c) 2014-present, Facebook, Inc. All rights reserved.
4		*
5		* You are hereby granted a non-exclusive, worldwide, royalty-free license to
6		* use, copy, modify, and distribute this software in source code or binary
7		* form for use in connection with the web services and APIs provided by
8		* Facebook.
9		*
10		* As with any software that integrates with the Facebook platform, your use
11		* of this software is subject to the Facebook Developer Principles and
12		* Policies [http://developers.facebook.com/policy/]. This copyright notice
13		* shall be included in all copies or substantial portions of the software.
14		*
15		* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16		* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17		* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
18		* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19		* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20		* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
21		* DEALINGS IN THE SOFTWARE.
22		*
23		*/
24
25		namespace FacebookAds\Http\Adapter;
26
27		use FacebookAds\Exception\Exception;
28		use FacebookAds\Http\Adapter\Curl\AbstractCurl;
29		use FacebookAds\Http\Adapter\Curl\Curl;
30		use FacebookAds\Http\Adapter\Curl\CurlInterface;
31		use FacebookAds\Http\Client;
32		use FacebookAds\Http\Headers;
33		use FacebookAds\Http\RequestInterface;
34		use FacebookAds\Http\ResponseInterface;
35
36		class CurlAdapter extends AbstractAdapter {
37
38		/**
39		* @var CurlInterface
40		*/
41		protected $curl;
42
43		/**
44		* @var \ArrayObject
45		*/
46		protected $opts;
47
48		/**
49		* @param Client $client
50		* @param CurlInterface $curl
51		*/
52	4	public function __construct(Client $client, CurlInterface $curl = null) {
53	4	parent::__construct($client);
54	4	$this->curl = $curl ?: AbstractCurl::createOptimalVersion();
55	4	$this->curl->init();
56	4	}
57
58		/**
59		* @return Curl
60		*/
61	2	public function getCurl() {
62	2	return $this->curl;
63		}
64
65		/**
66		* @return \ArrayObject
67		*/
68	1	public function getOpts() {
69	1	if ($this->opts === null) {
70	1	$this->opts = new \ArrayObject(array(
71	1	CURLOPT_CONNECTTIMEOUT => 10,
72	1	CURLOPT_TIMEOUT => 60,
73	1	CURLOPT_RETURNTRANSFER => true,
74	1	CURLOPT_HEADER => true,
75	1	CURLOPT_CAINFO => $this->getCaBundlePath(),
76	1	));
77	1	}
78
79	1	return $this->opts;
80		}
81
82		/**
83		* @param \ArrayObject $opts
84		*/
85	1	public function setOpts(\ArrayObject $opts) {
86	1	$this->opts = $opts;
87	1	}
88
89		/**
90		* @return int
91		*/
92		protected function getheaderSize() {
93		return $this->getCurl()->getInfo(CURLINFO_HEADER_SIZE);
94		}
95
96		/**
97		* Extracts the headers and the body into a two-part array
98		* @param string $raw_response
99		* @return array
100		*/
101		protected function extractResponseHeadersAndBody($raw_response) {
102		$header_size = $this->getheaderSize();
103
104		$raw_headers = mb_substr($raw_response, 0, $header_size);
105		$raw_body = mb_substr($raw_response, $header_size);
106
107		return array(trim($raw_headers), trim($raw_body));
108		}
109
110		/**
111		* @param Headers $headers
112		* @param string $raw_headers
113		*/
114		protected function parseHeaders(Headers $headers, $raw_headers) {
115		$raw_headers = str_replace("\r\n", "\n", $raw_headers);
116
117		// There will be multiple headers if a 301 was followed
118		// or a proxy was followed, etc
119		$header_collection = explode("\n\n", trim($raw_headers));
120		// We just want the last response (at the end)
121		$raw_headers = array_pop($header_collection);
122
123		$header_components = explode("\n", $raw_headers);
124		foreach ($header_components as $line) {
125		if (strpos($line, ': ') === false) {
126		$headers['http_code'] = $line;
127		} else {
128		list ($key, $value) = explode(': ', $line);
129		$headers[$key] = $value;
130		}
131		}
132		}
133
134		/**
135		* @param RequestInterface $request
136		* @return ResponseInterface
137		* @throws Exception
138		*/
139		public function sendRequest(RequestInterface $request) {
140		$response = $this->getClient()->createResponse();
141		$this->getCurl()->reset();
142		$curlopts = array(
143		CURLOPT_URL => $request->getUrl(),
144		);
145
146		$method = $request->getMethod();
147		if ($method !== RequestInterface::METHOD_GET
148		&& $method !== RequestInterface::METHOD_POST) {
149		$curlopts[CURLOPT_CUSTOMREQUEST] = $method;
150		}
151
152		$curlopts = $this->getOpts()->getArrayCopy() + $curlopts;
153
154		if ($request->getHeaders()->count()) {
155		$headers = array();
156		foreach ($request->getHeaders() as $header => $value) {
157		$headers[] = "{$header}: {$value}";
158		}
159		$curlopts[CURLOPT_HTTPHEADER] = $headers;
160		}
161
162		$postfields = array();
163		if ($method === RequestInterface::METHOD_POST
164		&& $request->getFileParams()->count()
165		) {
166		$postfields = array_merge(
167		$postfields,
168		array_map(
169		array($this->getCurl(), 'preparePostFileField'),
170		$request->getFileParams()->getArrayCopy()));
171		}
172		if ($method !== RequestInterface::METHOD_GET
173		&& $request->getBodyParams()->count()) {
174		$postfields
175		= array_merge($postfields, $request->getBodyParams()->export());
176		}
177
178		if (!empty($postfields)) {
179		$curlopts[CURLOPT_POSTFIELDS] = $postfields;
180		}
181
182		$this->getCurl()->setoptArray($curlopts);
183		$raw_response = $this->getCurl()->exec();
184
185		$status_code = $this->getCurl()->getInfo(CURLINFO_HTTP_CODE);
186		$curl_errno = $this->getCurl()->errno();
187		$curl_error = $curl_errno ? $this->getCurl()->error() : null;
188
189		$response_parts = $this->extractResponseHeadersAndBody($raw_response);
190
191		$response->setStatusCode($status_code);
192		$this->parseHeaders($response->getHeaders(), $response_parts[0]);
193		$response->setBody($response_parts[1]);
194
195		if ($curl_errno) {
196		throw new Exception($curl_error, $curl_errno);
197		}
198
199		return $response;
200		}
201		}
202

facebook / facebook-php-ads-sdk

Push — master ( a962f3...470970 )

CurlAdapter::sendRequest() C

Complexity

Size

Duplication

Code Coverage

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like