Merge pull request #121 from marmichalski/rejected-ex-srv

feat: pass service name to RejectedException

Author: ackintosh

src/Ganesha/Exception/RejectedException.php

@@ -4,4 +4,22 @@
 
 class RejectedException extends \RuntimeException
 {
+    public function __construct(
+        string $message = "",
+        int $code = 0,
+        ?\Throwable $previous = null,
+        private ?string $serviceName = null,
+    ) {
+        parent::__construct($message, $code, $previous);
+    }
+
+    public static function withServiceName(string $serviceName): self
+    {
+        return new self(sprintf('"%s" is not available', $serviceName), serviceName: $serviceName);
+    }
+
+    public function serviceName(): ?string
+    {
+        return $this->serviceName;
+    }
 }

src/Ganesha/GaneshaHttpClient.php

@@ -59,7 +59,7 @@ public function request(string $method, string $url, array $options = []): Respo
         $serviceName = $this->serviceNameExtractor->extract($method, $url, $options);
 
         if (!$this->ganesha->isAvailable($serviceName)) {
-            throw new RejectedException(sprintf('"%s" is not available', $serviceName));
+            throw RejectedException::withServiceName($serviceName);
         }
 
         $response = $this->client->request($method, $url, $this->avoidGaneshaOptionsPropagation($options));

src/Ganesha/GuzzleMiddleware.php

@@ -69,9 +69,7 @@ public function __invoke(callable $handler): \Closure
             if (!$this->ganesha->isAvailable($serviceName)) {
                 return call_user_func(
                     $this->rejectionForFunction,
-                    new RejectedException(
-                        sprintf('"%s" is not available', $serviceName)
-                    )
+                    RejectedException::withServiceName($serviceName),
                 );
             }
 

tests/Ackintosh/Ganesha/GaneshaHttpClientTest.php

@@ -239,7 +239,7 @@ public function reject(): void
         $ganesha->failure($service);
         $ganesha->failure($service);
 
-        $this->expectException(RejectedException::class);
+        $this->expectExceptionObject(RejectedException::withServiceName($service));
         $client->request('GET', 'http://'.$service.'/awesome_resource');
     }
 

tests/Ackintosh/Ganesha/GuzzleMiddlewareTest.php

@@ -155,8 +155,6 @@ public function recordsFailureOnRequestTimedOut()
      */
     public function reject()
     {
-        $this->expectException(RejectedException::class);
-
         // Build Ganesha which has count strategy with memcached adapter
         $m = new \Memcached();
         $m->addServer(
@@ -180,6 +178,8 @@ public function reject()
         $ganesha->failure($service);
         $ganesha->failure($service);
 
+        $this->expectExceptionObject(RejectedException::withServiceName($service));
+
         $client->get('http://' . $service . '/awesome_resource');
     }