Migrated BodyParserMiddleware to psr-15 middleware

module/Rest/src/Middleware/BodyParserMiddleware.php

@@ -1,55 +1,45 @@
 <?php
 namespace Shlinkio\Shlink\Rest\Middleware;
 
+use Fig\Http\Message\RequestMethodInterface;
+use Interop\Http\ServerMiddleware\DelegateInterface;
+use Interop\Http\ServerMiddleware\MiddlewareInterface;
 use Psr\Http\Message\ResponseInterface as Response;
 use Psr\Http\Message\ServerRequestInterface as Request;
 use Shlinkio\Shlink\Common\Exception\RuntimeException;
-use Zend\Stratigility\MiddlewareInterface;
 
-class BodyParserMiddleware implements MiddlewareInterface
+class BodyParserMiddleware implements MiddlewareInterface, RequestMethodInterface
 {
     /**
-     * Process an incoming request and/or response.
-     *
-     * Accepts a server-side request and a response instance, and does
-     * something with them.
-     *
-     * If the response is not complete and/or further processing would not
-     * interfere with the work done in the middleware, or if the middleware
-     * wants to delegate to another process, it can use the `$out` callable
-     * if present.
-     *
-     * If the middleware does not return a value, execution of the current
-     * request is considered complete, and the response instance provided will
-     * be considered the response to return.
-     *
-     * Alternately, the middleware may return a response instance.
-     *
-     * Often, middleware will `return $out();`, with the assumption that a
-     * later middleware will return a response.
+     * Process an incoming server request and return a response, optionally delegating
+     * to the next middleware component to create the response.
      *
      * @param Request $request
-     * @param Response $response
-     * @param null|callable $out
-     * @return null|Response
+     * @param DelegateInterface $delegate
+     *
+     * @return Response
      */
-    public function __invoke(Request $request, Response $response, callable $out = null)
+    public function process(Request $request, DelegateInterface $delegate)
     {
         $method = $request->getMethod();
         $currentParams = $request->getParsedBody();
 
         // In requests that do not allow body or if the body has already been parsed, continue to next middleware
-        if (in_array($method, ['GET', 'HEAD', 'OPTIONS']) || ! empty($currentParams)) {
-            return $out($request, $response);
+        if (! empty($currentParams) || in_array($method, [
+            self::METHOD_GET,
+            self::METHOD_HEAD,
+            self::METHOD_OPTIONS
+        ], true)) {
+            return $delegate->process($request);
         }
 
         // If the accepted content is JSON, try to parse the body from JSON
         $contentType = $this->getRequestContentType($request);
-        if (in_array($contentType, ['application/json', 'text/json', 'application/x-json'])) {
-            return $out($this->parseFromJson($request), $response);
+        if (in_array($contentType, ['application/json', 'text/json', 'application/x-json'], true)) {
+            return $delegate->process($this->parseFromJson($request));
         }
 
-        return $out($this->parseFromUrlEncoded($request), $response);
+        return $delegate->process($this->parseFromUrlEncoded($request));
     }
 
     /**

module/Rest/test/Middleware/BodyParserMiddlewareTest.php

@@ -1,8 +1,11 @@
 <?php
 namespace ShlinkioTest\Shlink\Rest\Middleware;
 
+use Interop\Http\ServerMiddleware\DelegateInterface;
 use PHPUnit\Framework\TestCase;
-use Psr\Http\Message\ServerRequestInterface as Request;
+use Prophecy\Argument;
+use Prophecy\Prophecy\MethodProphecy;
+use Psr\Http\Message\ServerRequestInterface;
 use Shlinkio\Shlink\Rest\Middleware\BodyParserMiddleware;
 use Zend\Diactoros\Response;
 use Zend\Diactoros\ServerRequestFactory;
@@ -26,16 +29,13 @@ class BodyParserMiddlewareTest extends TestCase
     public function requestsFromOtherMethodsJustFallbackToNextMiddleware()
     {
         $request = ServerRequestFactory::fromGlobals()->withMethod('GET');
-        $test = $this;
-        $this->middleware->__invoke($request, new Response(), function ($req, $resp) use ($test, $request) {
-            $test->assertSame($request, $req);
-        });
+        $delegate = $this->prophesize(DelegateInterface::class);
+        /** @var MethodProphecy $process */
+        $process = $delegate->process($request)->willReturn(new Response());
 
-        $request = $request->withMethod('POST');
-        $test = $this;
-        $this->middleware->__invoke($request, new Response(), function ($req, $resp) use ($test, $request) {
-            $test->assertSame($request, $req);
-        });
+        $this->middleware->process($request, $delegate->reveal());
+
+        $process->shouldHaveBeenCalledTimes(1);
     }
 
     /**
@@ -43,19 +43,31 @@ class BodyParserMiddlewareTest extends TestCase
      */
     public function jsonRequestsAreJsonDecoded()
     {
+        $test = $this;
         $body = new Stream('php://temp', 'wr');
         $body->write('{"foo": "bar", "bar": ["one", 5]}');
         $request = ServerRequestFactory::fromGlobals()->withMethod('PUT')
                                                       ->withBody($body)
                                                       ->withHeader('content-type', 'application/json');
-        $test = $this;
-        $this->middleware->__invoke($request, new Response(), function (Request $req, $resp) use ($test, $request) {
-            $test->assertNotSame($request, $req);
-            $test->assertEquals([
-                'foo' => 'bar',
-                'bar' => ['one', 5],
-            ], $req->getParsedBody());
-        });
+        $delegate = $this->prophesize(DelegateInterface::class);
+        /** @var MethodProphecy $process */
+        $process = $delegate->process(Argument::type(ServerRequestInterface::class))->will(
+            function (array $args) use ($test) {
+                /** @var ServerRequestInterface $req */
+                $req = array_shift($args);
+
+                $test->assertEquals([
+                    'foo' => 'bar',
+                    'bar' => ['one', 5],
+                ], $req->getParsedBody());
+
+                return new Response();
+            }
+        );
+
+        $this->middleware->process($request, $delegate->reveal());
+
+        $process->shouldHaveBeenCalledTimes(1);
     }
 
     /**
@@ -63,17 +75,29 @@ class BodyParserMiddlewareTest extends TestCase
      */
     public function regularRequestsAreUrlDecoded()
     {
+        $test = $this;
         $body = new Stream('php://temp', 'wr');
         $body->write('foo=bar&bar[]=one&bar[]=5');
         $request = ServerRequestFactory::fromGlobals()->withMethod('PUT')
                                                       ->withBody($body);
-        $test = $this;
-        $this->middleware->__invoke($request, new Response(), function (Request $req, $resp) use ($test, $request) {
-            $test->assertNotSame($request, $req);
-            $test->assertEquals([
-                'foo' => 'bar',
-                'bar' => ['one', 5],
-            ], $req->getParsedBody());
-        });
+        $delegate = $this->prophesize(DelegateInterface::class);
+        /** @var MethodProphecy $process */
+        $process = $delegate->process(Argument::type(ServerRequestInterface::class))->will(
+            function (array $args) use ($test) {
+                /** @var ServerRequestInterface $req */
+                $req = array_shift($args);
+
+                $test->assertEquals([
+                    'foo' => 'bar',
+                    'bar' => ['one', 5],
+                ], $req->getParsedBody());
+
+                return new Response();
+            }
+        );
+
+        $this->middleware->process($request, $delegate->reveal());
+
+        $process->shouldHaveBeenCalledTimes(1);
     }
 }