Http\Client\Plugin\BaseUriPlugin

Complexity

Total Complexity

6

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	3
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	handleRequest()	0	9	2
A	modifyUri()	0	22	3

<?php

namespace Http\Client\Plugin;

use Http\Promise\Promise;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\UriInterface;

class BaseUriPlugin implements Plugin
{
    /**
     * @var UriInterface
     */
    private $baseUri;

    /**
     * @param UriInterface $baseUri
     */
    public function __construct(UriInterface $baseUri)
    {
        $this->baseUri = $baseUri;
    }

    /**
     * Handle the request and return the response coming from the next callable.
     *
     * @param RequestInterface $request
     * @param callable         $next    Next middleware in the chain, the request is passed as the first argument
     * @param callable         $first   First middleware in the chain, used to to restart a request
     *
     * @return Promise
     */
    public function handleRequest(RequestInterface $request, callable $next, callable $first)
    {
        $uriString = $request->getUri()->__toString();
        if (!strpos($uriString, '://')) {
            $request = $request->withUri($this->modifyUri($request->getUri()));
        }

        return $next($request);
    }

    /**
     * @param UriInterface $uri
     *
     * @return UriInterface
     */
    private function modifyUri(UriInterface $uri)
    {
        $uriString = $uri->__toString();
        if (substr($uriString, 0, 1) === '/') {
            // Replace/Add path and query to the baseUri
            $modifiedUri = $this->baseUri->withPath($uri->getPath());
            $modifiedUri = $modifiedUri->withQuery($uri->getQuery());
        } else {
            // Append baseUri this url
            if ('' !== $query = $this->baseUri->getQuery()) {
                // Append the uri on the query
                $modifiedUri = $this->baseUri->withQuery($query.$uriString);
            } else {
                // Append the uri on path and query
                list($path, $query) = explode('?', $uriString, 2);
                $modifiedUri = $this->baseUri->withPath($this->baseUri->getPath().$path);
                $modifiedUri = $modifiedUri->withQuery($query);
            }
        }

        return $modifiedUri;
    }
}