Added authenticate

CHANGELOG.md

@@ -1,4 +1,7 @@
 # Changelog yii2 etcd component
 
+## 1.0.1
+- Added authenticate
+
 ## 1.0.0
 - Initial version

README.md

@@ -31,6 +31,7 @@ to the require section of your composer.json file.
 - `version`
 - `range`
 - `put`
+- `authenticate`
 
 
 ## How to use
@@ -43,6 +44,8 @@ $config = [
         'etcd' => [
             'class' => \S1lver\Etcd\Etcd::class,
             'host' => 'etcd:2379',
+            'user' => 'username',
+            'password' => 'password',
         ],
     ],
 ];

src/Etcd.php

@@ -8,6 +8,7 @@
 use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\RequestOptions;
 use JsonException;
+use S1lver\Etcd\Rest\AuthenticateResponse;
 use S1lver\Etcd\Rest\RangeResponse;
 use yii\base\Component;
 
@@ -21,6 +22,8 @@ class Etcd extends Component
     private const ETCD_VERSION = '/v3';
 
     public string $host = '';
+    public string $user = '';
+    public string $password = '';
 
     private Client $client;
 
@@ -56,6 +59,7 @@ public function getKey(string $key): RangeResponse
             $this->host.self::ETCD_VERSION.EtcdEndpoint::RANGE,
             [
                 RequestOptions::BODY => json_encode(['key' => $key], JSON_THROW_ON_ERROR),
+                RequestOptions::HEADERS => ['Authorization' => $this->authenticate()->token]
             ]
         );
 
@@ -76,4 +80,23 @@ public function put(string $key, string $value): bool
 
         return 200 === $response->getStatusCode();
     }
+
+    /**
+     * @return AuthenticateResponse
+     * @throws GuzzleException|JsonException
+     */
+    public function authenticate(): AuthenticateResponse
+    {
+        $response = $this->client->post(
+            $this->host.self::ETCD_VERSION.EtcdEndpoint::AUTHENTICATE,
+            [
+                RequestOptions::BODY => json_encode(
+                    ['name' => $this->user, 'password' => $this->password],
+                    JSON_THROW_ON_ERROR
+                ),
+            ]
+        );
+
+        return new AuthenticateResponse(json_decode($response->getBody()->getContents(), true, 512, JSON_THROW_ON_ERROR));
+    }
 }

src/EtcdEndpoint.php

@@ -15,4 +15,6 @@ final class EtcdEndpoint
     public const PUT = '/kv/put';
     public const RANGE = '/kv/range';
 
+    // Authentication
+    public const AUTHENTICATE =  '/auth/authenticate';
 }

src/Rest/AuthenticateResponse.php

@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace S1lver\Etcd\Rest;
+
+use yii\base\BaseObject;
+
+class AuthenticateResponse extends BaseObject
+{
+    public array $header = [];
+    public string $token = '';
+}