improved exceptions

Author: rennokki

src/Exceptions/KubeConfigClusterNotFound.php

@@ -2,9 +2,7 @@
 
 namespace RenokiCo\PhpK8s\Exceptions;
 
-use Exception;
-
-class KubeConfigClusterNotFound extends Exception
+class KubeConfigClusterNotFound extends PhpK8sException
 {
     //
 }

src/Exceptions/KubeConfigContextNotFound.php

@@ -2,9 +2,7 @@
 
 namespace RenokiCo\PhpK8s\Exceptions;
 
-use Exception;
-
-class KubeConfigContextNotFound extends Exception
+class KubeConfigContextNotFound extends PhpK8sException
 {
     //
 }

src/Exceptions/KubeConfigUserNotFound.php

@@ -2,9 +2,7 @@
 
 namespace RenokiCo\PhpK8s\Exceptions;
 
-use Exception;
-
-class KubeConfigUserNotFound extends Exception
+class KubeConfigUserNotFound extends PhpK8sException
 {
     //
 }

src/Exceptions/KubernetesAPIException.php

@@ -2,9 +2,7 @@
 
 namespace RenokiCo\PhpK8s\Exceptions;
 
-use Exception;
-
-class KubernetesAPIException extends Exception
+class KubernetesAPIException extends PhpK8sException
 {
     //
 }

src/Exceptions/KubernetesWatchException.php

@@ -2,9 +2,7 @@
 
 namespace RenokiCo\PhpK8s\Exceptions;
 
-use Exception;
-
-class KubernetesWatchException extends Exception
+class KubernetesWatchException extends PhpK8sException
 {
     //
 }

src/Exceptions/PhpK8sException.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace RenokiCo\PhpK8s\Exceptions;
+
+use Exception;
+
+class PhpK8sException extends Exception
+{
+    /**
+     * The payload coming from the Guzzle client.
+     *
+     * @var array
+     */
+    protected $payload = [];
+
+    /**
+     * Initialize the exception.
+     *
+     * @param  string|null  $message
+     * @param  int  $code
+     * @param  array|null  $payload
+     */
+    public function __construct($message = null, $code = 0, array $payload = null)
+    {
+        parent::__construct($message, $code);
+
+        $this->payload = $payload;
+    }
+
+    /**
+     * Get the payload instance.
+     *
+     * @return null|array
+     */
+    public function getPayload()
+    {
+        return $this->payload;
+    }
+}

src/Traits/Cluster/ChecksClusterVersion.php

@@ -34,7 +34,13 @@ protected function loadClusterVersion(): void
         try {
             $response = $this->getClient()->request('GET', $callableUrl);
         } catch (ClientException $e) {
-            throw new KubernetesAPIException($e->getMessage());
+            $payload = json_decode((string) $e->getResponse()->getBody(), true);
+
+            throw new KubernetesAPIException(
+                $e->getMessage(),
+                $payload['code'] ?? 0,
+                $payload
+            );
         }
 
         $json = @json_decode($response->getBody(), true);

src/Traits/Cluster/RunsClusterOperations.php

@@ -106,7 +106,13 @@ protected function makeRequest(string $method, string $path, string $payload = '
                 RequestOptions::BODY => $payload,
             ]);
         } catch (ClientException $e) {
-            throw new KubernetesAPIException($e->getMessage());
+            $payload = json_decode((string) $e->getResponse()->getBody(), true);
+
+            throw new KubernetesAPIException(
+                $e->getMessage(),
+                $payload['code'] ?? 0,
+                $payload
+            );
         }
 
         $json = @json_decode($response->getBody(), true);