Merge pull request #23 from resendlabs/feat-errors

Author: jayanratna

src/Transporters/HttpTransporter.php

@@ -5,6 +5,7 @@
 use JsonException;
 use Psr\Http\Client\ClientExceptionInterface;
 use Psr\Http\Client\ClientInterface;
+use Psr\Http\Message\ResponseInterface;
 use Resend\Contracts\Transporter;
 use Resend\Exceptions\ErrorException;
 use Resend\Exceptions\TransporterException;
@@ -43,18 +44,40 @@ public function request(Payload $payload): array
             throw new TransporterException($clientException);
         }
 
-        $contents = (string) $response->getBody();
+        $contents = $response->getBody()->getContents();
+
+        $this->throwIfJsonError($response, $contents);
 
         try {
             $response = json_decode($contents, true, 512, JSON_THROW_ON_ERROR);
         } catch (JsonException $jsonException) {
             throw new UnserializableResponse($jsonException);
         }
 
-        if (isset($response['error'])) {
-            throw new ErrorException($response['error']);
+        return $response;
+    }
+
+    /**
+     * Throw an exception if there is a JSON error.
+     */
+    protected function throwIfJsonError(ResponseInterface $response, string $contents): void
+    {
+        if ($response->getStatusCode() < 400) {
+            return;
         }
 
-        return $response;
+        try {
+            $response = json_decode($contents, true, 512, JSON_THROW_ON_ERROR);
+
+            $errors = ['missing_required_fields', 'missing_required_field', 'missing_api_key', 'invalid_api_key', 'invalid_from_address', 'validation_error', 'not_found', 'method_not_allowed', 'invalid_scope', 'restricted_api_key', 'internal_server_error'];
+            if (
+                isset($response['error']) ||
+                in_array($response['name'], $errors)
+            ) {
+                throw new ErrorException($response['error'] ?? $response);
+            }
+        } catch (JsonException $jsonException) {
+            throw new UnserializableResponse($jsonException);
+        }
     }
 }

tests/Transporters/HttpTransporter.php

@@ -95,6 +95,18 @@
     $this->http->request($payload);
 })->throws(UnserializableResponse::class, 'Syntax error');
 
+test('throw json errors', function () {
+    $payload = Payload::create('email', ['to' => '[email protected]']);
+    $response = new Response(422, [], 'err');
+
+    $this->client
+        ->shouldReceive('sendRequest')
+        ->once()
+        ->andReturn($response);
+
+    $this->http->request($payload);
+})->throws(UnserializableResponse::class, 'Syntax error');
+
 test('request can handle server errors', function () {
     $payload = Payload::create('email', ['to' => '[email protected]']);
     $response = new Response(422, [], json_encode([