Fixed error message for connection exceptions (#68)

* Fixed message for connection exceptions
* Unnecessary class import deleted
* Fixed PHP 8.1 version

Author: Elnadrion

composer.json

@@ -11,7 +11,7 @@
     }
   ],
   "require": {
-    "php": "^7.4|^8.0|8.1.*",
+    "php": "^7.4|^8.0|^8.1",
     "ext-curl": "*",
     "ext-json": "*",
     "guzzlehttp/guzzle": "^7.0",

src/Exception/ExceptionMap.php

@@ -5,6 +5,7 @@
 namespace FlixTech\SchemaRegistryApi\Exception;
 
 use Exception;
+use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Exception\RequestException;
 use Psr\Http\Message\ResponseInterface;
 use RuntimeException;
@@ -38,14 +39,18 @@ private function __construct()
     /**
      * Maps a RequestException to the internal SchemaRegistryException types.
      *
-     * @param RequestException $exception
+     * @param GuzzleException $exception
      *
      * @return SchemaRegistryException
      *
      * @throws RuntimeException
      */
-    public function __invoke(RequestException $exception): SchemaRegistryException
+    public function __invoke(GuzzleException $exception): SchemaRegistryException
     {
+        if (!$exception instanceof RequestException) {
+            throw $exception;
+        }
+
         $response = $this->guardAgainstMissingResponse($exception);
         $decodedBody = $this->guardAgainstMissingErrorCode($response);
         $errorCode = $decodedBody[self::ERROR_CODE_FIELD_NAME];

src/Registry/PromisingRegistry.php

@@ -10,7 +10,7 @@
 use FlixTech\SchemaRegistryApi\Exception\ExceptionMap;
 use FlixTech\SchemaRegistryApi\Schema\AvroReference;
 use GuzzleHttp\ClientInterface;
-use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Promise\PromiseInterface;
 use InvalidArgumentException;
 use Psr\Http\Message\RequestInterface;
@@ -45,7 +45,7 @@ public function __construct(ClientInterface $client)
         $this->client = $client;
         $exceptionMap = ExceptionMap::instance();
 
-        $this->rejectedCallback = static function (RequestException $exception) use ($exceptionMap) {
+        $this->rejectedCallback = static function (GuzzleException $exception) use ($exceptionMap) {
             return $exceptionMap($exception);
         };
     }