chillerlan\HTTP\CurlHandle::init()

Complexity

Conditions	23
Paths	8064

Size

Total Lines

130

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	public function init(){

		$v = $this->request->getProtocolVersion();

		switch($v){
			case '1.0': $v = CURL_HTTP_VERSION_1_0; break;
			case '1.1': $v = CURL_HTTP_VERSION_1_1; break;
			case '2.0': $v = CURL_HTTP_VERSION_2_0; break;
			default:    $v = CURL_HTTP_VERSION_NONE;
		}

		$options = [
			CURLOPT_HEADER         => false,
			CURLOPT_RETURNTRANSFER => false,
			CURLOPT_FOLLOWLOCATION => false,
			CURLOPT_URL            => (string)$this->request->getUri()->withFragment(''),
			CURLOPT_HTTP_VERSION   => $v,
			CURLOPT_USERAGENT      => $this->options->user_agent,
			CURLOPT_PROTOCOLS      => CURLPROTO_HTTP | CURLPROTO_HTTPS,
			CURLOPT_SSL_VERIFYPEER => true,
			CURLOPT_SSL_VERIFYHOST => 2,
			CURLOPT_CAINFO         => is_file($this->options->ca_info) ? $this->options->ca_info : null,
			CURLOPT_TIMEOUT        => (int)$this->options->timeout,
			CURLOPT_CONNECTTIMEOUT => 30,
			CURLOPT_WRITEFUNCTION  => [$this, 'writefunction'],
			CURLOPT_HEADERFUNCTION => [$this, 'headerfunction'],
		];

		$userinfo = $this->request->getUri()->getUserInfo();

		if(!empty($userinfo)){
			$options[CURLOPT_USERPWD] = $userinfo;
		}

		/*
		 * Some HTTP methods cannot have payload:
		 *
		 * - GET   — cURL will automatically change method to PUT or POST
		 *           if we set CURLOPT_UPLOAD or CURLOPT_POSTFIELDS.
		 * - HEAD  — cURL treats HEAD as GET request with a same restrictions.
		 * - TRACE — According to RFC7231: a client MUST NOT send a message body in a TRACE request.
		 */
		$method   = $this->request->getMethod();
		$body     = $this->request->getBody();
		$bodySize = $body->getSize();

		if(in_array($method, ['DELETE', 'PATCH', 'POST', 'PUT'], true) && $bodySize !== 0){

			if($body->isSeekable()){
				$body->rewind();
			}

			// Message has non empty body.
			if($bodySize === null || $bodySize > 1024 * 1024){
				// Avoid full loading large or unknown size body into memory
				$options[CURLOPT_UPLOAD] = true;

				if($bodySize !== null){
					$options[CURLOPT_INFILESIZE] = $bodySize;
				}

				$options[CURLOPT_READFUNCTION] = [$this, 'readfunction'];
			}
			// Small body can be loaded into memory
			else{
				$options[CURLOPT_POSTFIELDS] = (string)$body;
			}

		}

		// This will set HTTP method to "HEAD".
		if($method === 'HEAD'){
			$options[CURLOPT_NOBODY] = true;
		}
		// GET is a default method. Other methods should be specified explicitly.
		elseif($method !== 'GET'){
			$options[CURLOPT_CUSTOMREQUEST] = $method;
		}

		$curlHeaders = [];

		foreach($this->request->getHeaders() as $name => $values){
			$header = strtolower($name);

			// curl-client does not support "Expect-Continue", so dropping "expect" headers
			if($header === 'expect'){
				continue;
			}

			if($header === 'content-length'){

				// Small body content length can be calculated here.
				if(array_key_exists(CURLOPT_POSTFIELDS, $options)){
					$values = [strlen($options[CURLOPT_POSTFIELDS])];
				}
				// Else if there is no body, forcing "Content-length" to 0
				elseif(!array_key_exists(CURLOPT_READFUNCTION, $options)){
					$values = ['0'];
				}

			}

			foreach($values as $value){
				$value = (string)$value;

				// cURL requires a special format for empty headers.
				// See https://github.com/guzzle/guzzle/issues/1882 for more details.
				$curlHeaders[] = $value === ''
					? $name.';'
					: $name.': '.$value;
			}

		}

		$options[CURLOPT_HTTPHEADER] = $curlHeaders;

		// If the Expect header is not present, prevent curl from adding it
		if (!$this->request->hasHeader('Expect')) {
			$options[CURLOPT_HTTPHEADER][] = 'Expect:';
		}

		// cURL sometimes adds a content-type by default. Prevent this.
		if (!$this->request->hasHeader('Content-Type')) {
			$options[CURLOPT_HTTPHEADER][] = 'Content-Type:';
		}

		curl_setopt_array($this->ch, $this->options->curl_options + $options);

		return $this->ch;
	}