Error middleware that turns HTTP Exceptions in useful exceptions with errors

Author: WyriHaximus

composer.lock

@@ -0,0 +1,36 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github;
+
+use Exception;
+use Throwable;
+
+final class ApiErrorException extends Exception
+{
+    /**
+     * @var array
+     */
+    private $context = [];
+
+    public static function create(string $message, int $code, Throwable $previous): self
+    {
+        return new self($message, $code, $previous);
+    }
+
+    public static function createWithErrors(string $message, int $code, array $errors, Throwable $previous): self
+    {
+        $exception = new self($message, $code, $previous);
+        $exception->setContext($errors);
+        return $exception;
+    }
+
+    public function getContext(): array
+    {
+        return $this->context;
+    }
+
+    private function setContext(array $context)
+    {
+        $this->context = $context;
+    }
+}

src/ApiErrorException.php

@@ -2,6 +2,7 @@
 
 namespace ApiClients\Client\Github;
 
+use ApiClients\Client\Github\Middleware\ErrorMiddleware;
 use ApiClients\Client\Github\Middleware\RateLimitStateMiddleware;
 use ApiClients\Foundation\Hydrator\Options as HydratorOptions;
 use ApiClients\Foundation\Options as FoundationOptions;
@@ -28,9 +29,10 @@ final class ApiSettings
             TransportOptions::MIDDLEWARE => [
                 JsonDecodeMiddleware::class,
                 JsonEncodeMiddleware::class,
-                HttpExceptionsMiddleware::class,
                 UserAgentMiddleware::class,
                 RateLimitStateMiddleware::class,
+                HttpExceptionsMiddleware::class,
+                ErrorMiddleware::class,
             ],
             TransportOptions::DEFAULT_REQUEST_OPTIONS => [
                 UserAgentMiddleware::class => [

src/ApiSettings.php

@@ -0,0 +1,68 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\Middleware;
+
+use ApiClients\Client\Github\ApiErrorException;
+use ApiClients\Foundation\Middleware\Annotation\SecondLast;
+use ApiClients\Foundation\Middleware\MiddlewareInterface;
+use ApiClients\Foundation\Middleware\PostTrait;
+use ApiClients\Foundation\Middleware\PreTrait;
+use ApiClients\Foundation\Transport\ParsedContentsInterface;
+use ApiClients\Tools\Psr7\HttpStatusExceptions\BadRequestException;
+use ApiClients\Tools\Psr7\HttpStatusExceptions\UnprocessableEntityException;
+use React\Promise\CancellablePromiseInterface;
+use Throwable;
+use function React\Promise\reject;
+
+final class ErrorMiddleware implements MiddlewareInterface
+{
+    use PreTrait;
+    use PostTrait;
+
+    /**
+     * @param Throwable $throwable
+     * @param string $transactionId
+     * @param array $options
+     * @return CancellablePromiseInterface
+     * @SecondLast()
+     */
+    public function error(
+        Throwable $throwable,
+        string $transactionId,
+        array $options = []
+    ): CancellablePromiseInterface
+    {
+        if ($throwable instanceof UnprocessableEntityException ||
+            $throwable instanceof BadRequestException
+        ) {
+            $response = $throwable->getResponse();
+            $body = $response->getBody();
+            if (!($body instanceof ParsedContentsInterface)) {
+                return reject($throwable);
+            }
+            $contents = $body->getParsedContents();
+            $message = $contents['message'] ?? $throwable->getMessage();
+
+            if (isset($contents['errors'])) {
+                return reject(
+                    ApiErrorException::createWithErrors(
+                        $message,
+                        $throwable->getCode(),
+                        $contents['errors'],
+                        $throwable
+                    )
+                );
+            }
+
+            return reject(
+                ApiErrorException::create(
+                    $message,
+                    $throwable->getCode(),
+                    $throwable
+                )
+            );
+        }
+
+        return reject($throwable);
+    }
+}