Added BaseUriPlugin

Author: Nyholm

spec/BaseUriPluginSpec.php

@@ -0,0 +1,101 @@
+<?php
+
+namespace spec\Http\Client\Plugin;
+
+use Http\Message\StreamFactory;
+use Http\Message\UriFactory;
+use Http\Promise\FulfilledPromise;
+use PhpSpec\ObjectBehavior;
+use Prophecy\Argument;
+use Psr\Cache\CacheItemInterface;
+use Psr\Cache\CacheItemPoolInterface;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\StreamInterface;
+use Psr\Http\Message\UriInterface;
+
+class BaseUriPluginSpec extends ObjectBehavior
+{
+    function let(UriFactory $uriFactory)
+    {
+        $this->beConstructedWith($uriFactory, 'http://httplug.io/');
+    }
+
+    function it_is_initializable()
+    {
+        $this->shouldHaveType('Http\Client\Plugin\BaseUriPlugin');
+    }
+
+    function it_is_a_plugin()
+    {
+        $this->shouldImplement('Http\Client\Plugin\Plugin');
+    }
+
+    function it_appends_base_uri(
+        UriFactory $uriFactory,
+        RequestInterface $request,
+        ResponseInterface $response,
+        UriInterface $uri,
+        RequestInterface $modifiedRequest,
+        UriInterface $modifiedUri
+    ) {
+        $uriFactory->createUri('http://httplug.io/bar')->willReturn($modifiedUri);
+        $this->beConstructedWith($uriFactory, 'http://httplug.io/');
+
+        $request->getUri()->shouldBeCalled()->willReturn($uri);
+        $uri->__toString()->shouldBeCalled()->willReturn('bar');
+        $request->withUri($modifiedUri)->shouldBeCalled()->willReturn($modifiedRequest);
+        $modifiedRequest->getUri()->willReturn($modifiedUri);
+
+        $next = function (RequestInterface $receivedRequest) use($modifiedUri, $response) {
+            if (Argument::is($modifiedUri->getWrappedObject())->scoreArgument($receivedRequest->getUri())) {
+                return new FulfilledPromise($response->getWrappedObject());
+            }
+        };
+
+        $finalPromise = $this->handleRequest($request, $next, function () {});
+        $finalPromise->shouldReturnAnInstanceOf('Http\Promise\FulfilledPromise');
+    }
+
+    function it_replaces_path_on_base_uri(
+        UriFactory $uriFactory,
+        RequestInterface $request,
+        ResponseInterface $response,
+        UriInterface $uri,
+        RequestInterface $modifiedRequest,
+        UriInterface $modifiedUri
+    ) {
+        $baseUri = 'http://httplug.io/';
+        $uriFactory->createUri($baseUri)->willReturn($modifiedUri);
+        $this->beConstructedWith($uriFactory, $baseUri);
+
+        $request->getUri()->shouldBeCalled()->willReturn($uri);
+        $uri->__toString()->shouldBeCalled()->willReturn('/foo');
+        $uri->getPath()->shouldBeCalled()->willReturn('/foo');
+        $uri->getQuery()->shouldBeCalled()->willReturn('');
+
+        $modifiedUri->withPath('/foo')->shouldBeCalled()->willReturn($modifiedUri);
+        $modifiedUri->withQuery('')->shouldBeCalled()->willReturn($modifiedUri);
+
+        $request->withUri($modifiedUri)->shouldBeCalled()->willReturn($modifiedRequest);
+        $modifiedRequest->getUri()->willReturn($modifiedUri);
+
+        $next = function (RequestInterface $receivedRequest) use($modifiedUri, $response) {
+            if (Argument::is($modifiedUri->getWrappedObject())->scoreArgument($receivedRequest->getUri())) {
+                return new FulfilledPromise($response->getWrappedObject());
+            }
+        };
+
+        $finalPromise = $this->handleRequest($request, $next, function () {});
+        $finalPromise->shouldReturnAnInstanceOf('Http\Promise\FulfilledPromise');
+    }
+
+    function it_ignores_absolute_url(RequestInterface $request, UriInterface $uri)
+    {
+        $request->getUri()->shouldBeCalled()->willReturn($uri);
+        $uri->__toString()->shouldBeCalled()->willReturn('http://foo.io/bar');
+
+        $this->handleRequest($request, function () {}, function () {});
+    }
+
+}

src/BaseUriPlugin.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace Http\Client\Plugin;
+
+use Http\Message\UriFactory;
+use Http\Promise\Promise;
+use Psr\Http\Message\RequestInterface;
+
+class BaseUriPlugin implements Plugin
+{
+    /**
+     * @var string
+     */
+    private $baseUri;
+
+    /**
+     * @var UriFactory
+     */
+    private $factory;
+
+    /**
+     * @param UriFactory $factory
+     * @param string     $baseUri
+     */
+    public function __construct(UriFactory $factory, $baseUri)
+    {
+        $this->factory = $factory;
+        $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)
+    {
+        $uri = $request->getUri();
+        $uriString = $uri->__toString();
+        if (!strpos($uriString, '://')) {
+            if (substr($uriString, 0, 1) !== '/') {
+                // Append baseUri this url
+                $request = $request->withUri($this->factory->createUri($this->baseUri.$uriString));
+            } else {
+                // Replace add/replace path and query to the baseUri
+                $modifiedUri = $this->factory->createUri($this->baseUri);
+                $modifiedUri = $modifiedUri->withPath($uri->getPath());
+                $modifiedUri = $modifiedUri->withQuery($uri->getQuery());
+                $request = $request->withUri($modifiedUri);
+            }
+        }
+
+        return $next($request);
+    }
+}