Chris@0: <?php
Chris@0: namespace GuzzleHttp\Handler;
Chris@0: 
Chris@0: use GuzzleHttp\Psr7\Response;
Chris@0: use Psr\Http\Message\RequestInterface;
Chris@0: use Psr\Http\Message\ResponseInterface;
Chris@0: use Psr\Http\Message\StreamInterface;
Chris@0: 
Chris@0: /**
Chris@0:  * Represents a cURL easy handle and the data it populates.
Chris@0:  *
Chris@0:  * @internal
Chris@0:  */
Chris@0: final class EasyHandle
Chris@0: {
Chris@0:     /** @var resource cURL resource */
Chris@0:     public $handle;
Chris@0: 
Chris@0:     /** @var StreamInterface Where data is being written */
Chris@0:     public $sink;
Chris@0: 
Chris@0:     /** @var array Received HTTP headers so far */
Chris@0:     public $headers = [];
Chris@0: 
Chris@0:     /** @var ResponseInterface Received response (if any) */
Chris@0:     public $response;
Chris@0: 
Chris@0:     /** @var RequestInterface Request being sent */
Chris@0:     public $request;
Chris@0: 
Chris@0:     /** @var array Request options */
Chris@0:     public $options = [];
Chris@0: 
Chris@0:     /** @var int cURL error number (if any) */
Chris@0:     public $errno = 0;
Chris@0: 
Chris@0:     /** @var \Exception Exception during on_headers (if any) */
Chris@0:     public $onHeadersException;
Chris@0: 
Chris@0:     /**
Chris@0:      * Attach a response to the easy handle based on the received headers.
Chris@0:      *
Chris@0:      * @throws \RuntimeException if no headers have been received.
Chris@0:      */
Chris@0:     public function createResponse()
Chris@0:     {
Chris@0:         if (empty($this->headers)) {
Chris@0:             throw new \RuntimeException('No headers have been received');
Chris@0:         }
Chris@0: 
Chris@0:         // HTTP-version SP status-code SP reason-phrase
Chris@0:         $startLine = explode(' ', array_shift($this->headers), 3);
Chris@0:         $headers = \GuzzleHttp\headers_from_lines($this->headers);
Chris@0:         $normalizedKeys = \GuzzleHttp\normalize_header_keys($headers);
Chris@0: 
Chris@0:         if (!empty($this->options['decode_content'])
Chris@0:             && isset($normalizedKeys['content-encoding'])
Chris@0:         ) {
Chris@0:             $headers['x-encoded-content-encoding']
Chris@0:                 = $headers[$normalizedKeys['content-encoding']];
Chris@0:             unset($headers[$normalizedKeys['content-encoding']]);
Chris@0:             if (isset($normalizedKeys['content-length'])) {
Chris@0:                 $headers['x-encoded-content-length']
Chris@0:                     = $headers[$normalizedKeys['content-length']];
Chris@0: 
Chris@0:                 $bodyLength = (int) $this->sink->getSize();
Chris@0:                 if ($bodyLength) {
Chris@0:                     $headers[$normalizedKeys['content-length']] = $bodyLength;
Chris@0:                 } else {
Chris@0:                     unset($headers[$normalizedKeys['content-length']]);
Chris@0:                 }
Chris@0:             }
Chris@0:         }
Chris@0: 
Chris@0:         // Attach a response to the easy handle with the parsed headers.
Chris@0:         $this->response = new Response(
Chris@0:             $startLine[1],
Chris@0:             $headers,
Chris@0:             $this->sink,
Chris@0:             substr($startLine[0], 5),
Chris@0:             isset($startLine[2]) ? (string) $startLine[2] : null
Chris@0:         );
Chris@0:     }
Chris@0: 
Chris@0:     public function __get($name)
Chris@0:     {
Chris@0:         $msg = $name === 'handle'
Chris@0:             ? 'The EasyHandle has been released'
Chris@0:             : 'Invalid property: ' . $name;
Chris@0:         throw new \BadMethodCallException($msg);
Chris@0:     }
Chris@0: }