Merge pull request #9 from relayphp/add-reusable

Add ReusableRelay

Author: Paul M. Jones

src/RelayFactory.php

@@ -0,0 +1,19 @@
+<?php
+namespace Relay;
+
+class RelayFactory
+{
+    protected $queue;
+    protected $resolver;
+
+    public function __construct(array $queue, $resolver = null)
+    {
+        $this->queue = $queue;
+        $this->resolver = $resolver;
+    }
+
+    public function newInstance()
+    {
+        return new Relay($this->queue, $this->resolver);
+    }
+}

src/ReusableRelay.php

@@ -0,0 +1,21 @@
+<?php
+namespace Relay;
+
+use Psr\Http\Message\RequestInterface as Request;
+use Psr\Http\Message\ResponseInterface as Response;
+
+class ReusableRelay
+{
+    protected $relayFactory;
+
+    public function __construct(RelayFactory $relayFactory)
+    {
+        $this->relayFactory = $relayFactory;
+    }
+
+    public function __invoke(Request $request, Response $response)
+    {
+        $relay = $this->relayFactory->newInstance();
+        return $relay($request, $response);
+    }
+}

src/ReusableRelayBuilder.php

@@ -0,0 +1,44 @@
+<?php
+namespace Relay;
+
+use ArrayObject;
+use InvalidArgumentException;
+
+class ReusableRelayBuilder
+{
+    protected $resolver;
+
+    public function __construct($resolver = null)
+    {
+        $this->resolver = $resolver;
+    }
+
+    public function newInstance($queue)
+    {
+        return new ReusableRelay($this->newRelayFactory($queue));
+    }
+
+    protected function newRelayFactory($queue)
+    {
+        return new RelayFactory(
+            $this->getArray($queue),
+            $this->resolver
+        );
+    }
+
+    protected function getArray($queue)
+    {
+        if (is_array($queue)) {
+            return $queue;
+        }
+
+        $getArrayCopy = $queue instanceof GetArrayCopyInterface
+            || $queue instanceof ArrayObject;
+
+        if ($getArrayCopy) {
+            return $queue->getArrayCopy();
+        }
+
+        throw new InvalidArgumentException();
+    }
+}

tests/ReusableRelayTest.php

@@ -0,0 +1,36 @@
+<?php
+namespace Relay;
+
+use Zend\Diactoros\ServerRequestFactory;
+use Zend\Diactoros\Response;
+
+class ReusableRelayTest extends \PHPUnit_Framework_TestCase
+{
+    public function test()
+    {
+        FakeMiddleware::$count = 0;
+
+        $queue[] = new FakeMiddleware();
+        $queue[] = new FakeMiddleware();
+        $queue[] = new FakeMiddleware();
+
+        $builder = new ReusableRelayBuilder();
+        $relay = $builder->newInstance($queue);
+
+        // relay once
+        $response = $relay(
+            ServerRequestFactory::fromGlobals(),
+            new Response()
+        );
+        $actual = (string) $response->getBody();
+        $this->assertSame('123456', $actual);
+
+        // relay again
+        $response = $relay(
+            ServerRequestFactory::fromGlobals(),
+            new Response()
+        );
+        $actual = (string) $response->getBody();
+        $this->assertSame('789101112', $actual);
+    }
+}