Buzz\Client\FileGetContents

Complexity

Total Complexity

10

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Test Coverage

Coverage

92.11%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	filterHeaders()	0	12	3
A	sendRequest()	0	20	3
A	getStreamContextArray()	0	33	4

<?php

declare(strict_types=1);

namespace Buzz\Client;

use Buzz\Configuration\ParameterBag;
use Buzz\Exception\NetworkException;
use Buzz\Message\HeaderConverter;
use Buzz\Message\ResponseBuilder;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

class FileGetContents extends AbstractClient implements BuzzClientInterface
{
    public function sendRequest(RequestInterface $request, array $options = []): ResponseInterface
    {
        $options = $this->validateOptions($options);
        $context = stream_context_create($this->getStreamContextArray($request, $options));

        $level = error_reporting(0);
        $content = file_get_contents($request->getUri()->__toString(), false, $context);
        error_reporting($level);
        if (false === $content) {
            if ($error = error_get_last()) {
                throw new NetworkException($request, $error['message']);
            }
            throw new NetworkException($request, 'Failed to get contents from '.$request->getUri()->__toString());
        }

        $requestBuilder = new ResponseBuilder($this->responseFactory);
        $requestBuilder->parseHttpHeaders($this->filterHeaders((array) $http_response_header));
        $requestBuilder->writeBody($content);

        return $requestBuilder->getResponse();
    }

    /**
     * Converts a request into an array for stream_context_create().
     *
     * @param RequestInterface $request A request object
     *
     * @return array An array for stream_context_create()
     */
    protected function getStreamContextArray(RequestInterface $request, ParameterBag $options): array
    {
        $headers = $request->getHeaders();
        unset($headers['Host']);
        $context = [
            'http' => [
                // values from the request
                'method' => $request->getMethod(),
                'header' => implode("\r\n", HeaderConverter::toBuzzHeaders($headers)),
                'content' => $request->getBody()->__toString(),
                'protocol_version' => $request->getProtocolVersion(),

                // values from the current client
                'ignore_errors' => true,
                'follow_location' => $options->get('allow_redirects') && $options->get('max_redirects') > 0,
                'max_redirects' => $options->get('max_redirects') + 1,
            ],
            'ssl' => [
                'verify_peer' => $options->get('verify'),
                'verify_host' => $options->get('verify'),
            ],
        ];

        if (0 < $options->get('timeout')) {
            $context['http']['timeout'] = $options->get('timeout');
        }

        if (null !== $options->get('proxy')) {
            $context['http']['proxy'] = $options->get('proxy');
            $context['http']['request_fulluri'] = true;
        }

        return $context;
    }

    private function filterHeaders(array $headers): array
    {
        $filtered = [];
        foreach ($headers as $header) {
            if (0 === stripos($header, 'http/')) {
                $filtered = [];
            }

            $filtered[] = $header;
        }

        return $filtered;
    }
}