Add isDaprHealthy function to client (#100)

* Add healthz endpoint support

* Add doc string

* Add tests

src/lib/Client/DaprClient.php

@@ -420,6 +420,13 @@ abstract public function getBulkSecretAsync(string $storeName, array $metadata =
      */
     abstract public function getBulkSecret(string $storeName, array $metadata = []): array;
 
+    /**
+     * Check if the daprd instance is up and running.
+     *
+     * @return bool True if it is running, else false.
+     */
+    abstract public function isDaprHealthy(): bool;
+
     /**
      * @param string $token
      * @return null|array{dapr-api-token: string}

src/lib/Client/DaprHttpClient.php

@@ -43,4 +43,17 @@ public function __construct(
             ]
         );
     }
+
+    public function isDaprHealthy(): bool
+    {
+        try {
+            $result = $this->httpClient->get('/v1.0/healthz');
+            if (200 === $result->getStatusCode()) {
+                return true;
+            }
+            return false;
+        } catch (\Throwable $exception) {
+            return false;
+        }
+    }
 }

tests/HealthTest.php

@@ -0,0 +1,48 @@
+<?php
+
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\Psr7\Request;
+use GuzzleHttp\Psr7\Response;
+
+/**
+ * Class HealthTest
+ */
+class HealthTest extends DaprTests
+{
+    public function testIsHealthy()
+    {
+        $container = $this->get_http_client_stack(
+            [
+                new Response(200)
+            ]
+        );
+        $client = $this->get_new_client_with_http($container->client);
+        $this->assertTrue($client->isDaprHealthy());
+        $request = $container->history[0]['request'];
+        $this->assertRequestUri('/v1.0/healthz', $request);
+    }
+
+    public function testIsNotHealthy() {
+        $container = $this->get_http_client_stack(
+            [
+                new Response(500)
+            ]
+        );
+        $client = $this->get_new_client_with_http($container->client);
+        $this->assertFalse($client->isDaprHealthy());
+        $request = $container->history[0]['request'];
+        $this->assertRequestUri('/v1.0/healthz', $request);
+    }
+
+    public function testTimeout() {
+        $container = $this->get_http_client_stack(
+            [
+                new RequestException('timed out', new Request('GET', 'test'))
+            ]
+        );
+        $client = $this->get_new_client_with_http($container->client);
+        $this->assertFalse($client->isDaprHealthy());
+        $request = $container->history[0]['request'];
+        $this->assertRequestUri('/v1.0/healthz', $request);
+    }
+}