From 1953acf25d935d8d7b2bbea5e89ae1993099e0ab Mon Sep 17 00:00:00 2001
From: PJ Dietz <pjdietz@gmail.com>
Date: Fri, 15 May 2015 07:46:41 -0400
Subject: [PATCH] Add integration tests to double check routing and dispatching
 functionality

---
 phpunit.xml.dist                       |   3 +
 test/tests/integration/RoutingTest.php | 202 +++++++++++++++++++++++++
 2 files changed, 205 insertions(+)
 create mode 100644 test/tests/integration/RoutingTest.php

diff --git a/phpunit.xml.dist b/phpunit.xml.dist
index 7a8e7e0..7dee3d7 100644
--- a/phpunit.xml.dist
+++ b/phpunit.xml.dist
@@ -15,6 +15,9 @@
         <testsuite name="unit">
             <directory>./test/tests/unit</directory>
         </testsuite>
+        <testsuite name="integration">
+            <directory>./test/tests/integration</directory>
+        </testsuite>
     </testsuites>
     <filter>
         <whitelist>
diff --git a/test/tests/integration/RoutingTest.php b/test/tests/integration/RoutingTest.php
new file mode 100644
index 0000000..5717bb2
--- /dev/null
+++ b/test/tests/integration/RoutingTest.php
@@ -0,0 +1,202 @@
+<?php
+
+namespace WellRESTed\Test\Integration;
+
+use Prophecy\Argument;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use WellRESTed\Message\Response;
+use WellRESTed\Message\ServerRequest;
+use WellRESTed\Message\Stream;
+use WellRESTed\MiddlewareInterface;
+use WellRESTed\Server;
+use WellRESTed\Transmission\TransmitterInterface;
+
+/**
+ * @coversNothing
+ */
+class ServerTest extends \PHPUnit_Framework_TestCase
+{
+    public function testDispatchesMiddleware()
+    {
+        $server = new Server();
+        $server->add(function ($rqst, $resp, $next) {
+            $resp = $resp->withStatus(200)
+                ->withBody(new Stream("Hello, world!"));
+            return $next($rqst, $resp);
+        });
+
+        $request = new ServerRequest();
+        $response = new Response();
+        $transmitter = new CallableTransmitter(function ($request, $response) {
+            $this->assertEquals("Hello, world!", (string) $response->getBody());
+        });
+        $server->respond($request, $response, $transmitter);
+    }
+
+    public function testDispatchesMiddlewareChain()
+    {
+        $server = new Server();
+        $server->add(function ($rqst, $resp, $next) {
+           return $next($rqst, $resp);
+        });
+        $server->add(function ($rqst, $resp, $next) {
+            $resp = $resp->withStatus(200)
+                ->withBody(new Stream("Hello, world!"));
+            return $next($rqst, $resp);
+        });
+
+        $request = new ServerRequest();
+        $response = new Response();
+        $transmitter = new CallableTransmitter(function ($request, $response) {
+            $this->assertEquals("Hello, world!", (string) $response->getBody());
+        });
+        $server->respond($request, $response, $transmitter);
+    }
+
+    /**
+     * @dataProvider routeProvider
+     */
+    public function testDispatchesAssortedMiddlewareTypesByPath($requestTarget, $expectedBody)
+    {
+        $stringMiddlewareWrapper = function ($string) {
+            return new StringMiddleware($string);
+        };
+
+        $server = new Server();
+        $server->add(function ($rqst, $resp, $next) {
+            return $next($rqst, $resp);
+        });
+        $server->add($server->createRouter()
+            ->register("GET", "/fry", [
+                    new StringMiddleware("Philip "),
+                    new StringMiddleware("J. "),
+                    new StringMiddleware("Fry")
+                ])
+            ->register("GET", "/leela", new StringMiddleware("Turanga Leela"))
+            ->register("GET", "/bender", __NAMESPACE__ . '\BenderMiddleware')
+            ->register("GET", "/professor", $stringMiddlewareWrapper("Professor Hubert J. Farnsworth"))
+            ->register("GET", "/amy", function ($request, $response, $next) {
+                $message = "Amy Wong";
+                $body = $response->getBody();
+                if ($body->isWritable()) {
+                    $body->write($message);
+                } else {
+                    $response = $response->withBody(new Stream($message));
+                }
+                return $next($request, $response);
+            })
+            ->register("GET", "/hermes", [
+                    new StringMiddleware("Hermes "),
+                    new StringMiddleware("Conrad", false),
+                    new StringMiddleware(", CPA")
+                ])
+            ->register("GET", "/zoidberg", [
+                function ($request, $response, $next) {
+                    // Prepend "Doctor " to the dispatched response on the return trip.
+                    $response = $next($request, $response);
+                    $message = "Doctor " . (string) $response->getBody();
+                    return $response->withBody(new Stream($message));
+                },
+                new StringMiddleware("John "),
+                new StringMiddleware("Zoidberg")
+            ])
+        );
+        $server->add(function ($rqst, $resp, $next) {
+            $resp = $resp->withStatus(200);
+            return $next($rqst, $resp);
+        });
+
+        $request = (new ServerRequest())->withRequestTarget($requestTarget);
+        $response = new Response();
+
+        $transmitter = new CallableTransmitter(function ($request, $response) use ($expectedBody) {
+            $this->assertEquals($expectedBody, (string) $response->getBody());
+        });
+        $server->respond($request, $response, $transmitter);
+    }
+
+    public function routeProvider()
+    {
+        return [
+            ["/fry", "Philip J. Fry"],
+            ["/leela", "Turanga Leela"],
+            ["/bender", "Bender Bending Rodriguez"],
+            ["/professor", "Professor Hubert J. Farnsworth"],
+            ["/amy", "Amy Wong"],
+            ["/hermes", "Hermes Conrad"],
+            ["/zoidberg", "Doctor John Zoidberg"]
+        ];
+    }
+
+}
+
+class CallableTransmitter implements TransmitterInterface
+{
+    private $callable;
+
+    public function __construct($callable)
+    {
+        $this->callable = $callable;
+    }
+
+    public function transmit(ServerRequestInterface $request, ResponseInterface $response)
+    {
+        $callable = $this->callable;
+        $callable($request, $response);
+    }
+}
+
+class StringMiddleware implements MiddlewareInterface
+{
+    private $string;
+    private $propagate;
+
+    public function __construct($string, $propagate = true)
+    {
+        $this->string = $string;
+        $this->propagate = $propagate;
+    }
+
+    /**
+     * @param ServerRequestInterface $request
+     * @param ResponseInterface $response
+     * @param callable $next
+     * @return ResponseInterface
+     */
+    public function dispatch(ServerRequestInterface $request, ResponseInterface $response, $next)
+    {
+        $body = $response->getBody();
+        if ($body->isWritable()) {
+            $body->write($this->string);
+        } else {
+            $response = $response->withBody(new Stream($this->string));
+        }
+        if ($this->propagate) {
+            return $next($request, $response);
+        } else {
+            return $response;
+        }
+    }
+}
+
+class BenderMiddleware implements MiddlewareInterface
+{
+    /**
+     * @param ServerRequestInterface $request
+     * @param ResponseInterface $response
+     * @param callable $next
+     * @return ResponseInterface
+     */
+    public function dispatch(ServerRequestInterface $request, ResponseInterface $response, $next)
+    {
+        $message = "Bender Bending Rodriguez";
+        $body = $response->getBody();
+        if ($body->isWritable()) {
+            $body->write($message);
+        } else {
+            $response = $response->withBody(new Stream($message));
+        }
+        return $next($request, $response);
+    }
+}