Http\Client\Socket\ResponseReader

Complexity

Total Complexity

12

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

92.11%

2 Methods

Rating	Name	Duplication	Size	Complexity
C	readResponse()	0	51	10
A	createStream()	0	10	2

<?php

namespace Http\Client\Socket;

use Http\Client\Exception\NetworkException;
use Http\Message\MessageFactory;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * Method for reading response
 *
 * Mainly used by SocketHttpClient
 *
 * @author Joel Wurtz <joel.wurtz@gmail.com>
 */
trait ResponseReader
{
    /**
     * @var MessageFactory
     */
    protected $messageFactory;

    /**
     * Read a response from a socket
     *
     * @param RequestInterface $request
     * @param resource         $socket
     *
     * @throws NetworkException When the response cannot be read
     *
     * @return ResponseInterface
     */
    protected function readResponse(RequestInterface $request, $socket)
    {
        $headers  = [];
        $reason   = null;

        while (($line = fgets($socket)) !== false) {
            if (rtrim($line) === '') {
                break;
            }
            $headers[] = trim($line);
        }

        $metadatas = stream_get_meta_data($socket);

        if (array_key_exists('timed_out', $metadatas) && true === $metadatas['timed_out']) {
            throw new NetworkException("Error while reading response, stream timed out", $request);
        }

        $parts = explode(' ', array_shift($headers), 3);

        if (count($parts) <= 1) {
            throw new NetworkException('Cannot read the response', $request);
        }

        $protocol = substr($parts[0], -3);
        $status   = $parts[1];

        if (isset($parts[2])) {
            $reason = $parts[2];
        }

        // Set the size on the stream if it was returned in the response
        $responseHeaders = [];

        foreach ($headers as $header) {
            $headerParts = explode(':', $header, 2);

            if (!array_key_exists(trim($headerParts[0]), $responseHeaders)) {
                $responseHeaders[trim($headerParts[0])] = [];
            }

            $responseHeaders[trim($headerParts[0])][] = isset($headerParts[1])
                ? trim($headerParts[1])
                : '';
        }

        $response = $this->messageFactory->createResponse($status, $reason, $responseHeaders, null, $protocol);
        $stream   = $this->createStream($socket, $response);

        return $response->withBody($stream);
    }

    /**
     * Create the stream
     *
     * @param $socket
     * @param ResponseInterface $response
     *
     * @return Stream
     */
    protected function createStream($socket, ResponseInterface $response)
    {
        $size = null;

        if ($response->hasHeader('Content-Length')) {
            $size = (int)$response->getHeaderLine('Content-Length');
        }

        return new Stream($socket, $size);
    }
}