Implemented HttpExceptionsMiddleware

Author: WyriHaximus

composer.json

@@ -11,6 +11,7 @@
   "require": {
     "php": "^7.0",
     "api-clients/middleware": "^2.0",
+    "api-clients/psr7-http-status-exceptions": "dev-master",
     "clue/buzz-react": "^1.1"
   },
   "require-dev": {

composer.lock

@@ -0,0 +1,44 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Middleware\HttpExceptions;
+
+use ApiClients\Foundation\Middleware\MiddlewareInterface;
+use ApiClients\Foundation\Middleware\PostTrait;
+use ApiClients\Foundation\Middleware\PreTrait;
+use ApiClients\Foundation\Middleware\Priority;
+use ApiClients\Tools\Psr7\HttpStatusExceptions\ExceptionFactory;
+use Clue\React\Buzz\Message\ResponseException;
+use React\Promise\CancellablePromiseInterface;
+use Throwable;
+use function React\Promise\reject;
+
+final class HttpExceptionsMiddleware implements MiddlewareInterface
+{
+    use PreTrait;
+    use PostTrait;
+
+    /**
+     * @return int
+     */
+    public function priority(): int
+    {
+        return Priority::SECOND_LAST;
+    }
+
+    /**
+     * When $throwable is a ResponseException this method will turn it into a
+     * HTTP status code specific exception.
+     *
+     * @param Throwable $throwable
+     * @param array $options
+     * @return CancellablePromiseInterface
+     */
+    public function error(Throwable $throwable, array $options = []): CancellablePromiseInterface
+    {
+        if (!($throwable instanceof ResponseException)) {
+            return reject($throwable);
+        }
+
+        return reject(ExceptionFactory::create($throwable->getResponse(), $throwable));
+    }
+}

src/HttpExceptionsMiddleware.php

@@ -0,0 +1,67 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Tests\Middleware\HttpExceptions;
+
+use ApiClients\Foundation\Middleware\Priority;
+use ApiClients\Middleware\HttpExceptions\HttpExceptionsMiddleware;
+use ApiClients\Tools\Psr7\HttpStatusExceptions\ExceptionFactory;
+use ApiClients\Tools\TestUtilities\TestCase;
+use Clue\React\Buzz\Message\ResponseException;
+use Exception;
+use React\EventLoop\Factory;
+use RingCentral\Psr7\Response;
+use Throwable;
+use function Clue\React\Block\await;
+use function React\Promise\reject;
+
+final class HttpExceptionsMiddlewareTest extends TestCase
+{
+    /**
+     * Ensure we run second last so the last can be logging or so that stores information.
+     */
+    public function testPriority()
+    {
+        self::assertSame(
+            Priority::SECOND_LAST,
+            (new HttpExceptionsMiddleware())->priority()
+        );
+    }
+
+    public function provideThrowables()
+    {
+        yield [
+            new Exception('foo.bar'),
+            new Exception('foo.bar'),
+        ];
+
+        foreach (ExceptionFactory::STATUS_CODE_EXCEPTION_MAP as $code => $exception) {
+            $response = new Response($code);
+            $responseException = new ResponseException(
+                new Response($code)
+            );
+            yield [
+                $responseException,
+                $exception::create($response, $responseException)
+            ];
+        }
+    }
+
+    /**
+     * @dataProvider provideThrowables
+     */
+    public function testException(Throwable $input, Throwable $output)
+    {
+        $result = null;
+
+        try {
+            await(
+                (new HttpExceptionsMiddleware())->error($input, []),
+                Factory::create()
+            );
+        } catch (Throwable $result) {
+        }
+
+        self::assertNotNull($result);
+        self::assertEquals($output, $result);
+    }
+}