Merge pull request #9 from olekjs/dev-release-v1.7.1

Add port and api key configuration

Author: olekjs

config/services.php

@@ -3,5 +3,7 @@
 return [
     'elasticsearch' => [
         'url' => env('ELASTICSEARCH_URL', 'http://localhost:9200'),
+        'port' => env('ELASTICSEARCH_PORT'),
+        'api_key' => env('ELASTICSEARCH_API_KEY'),
     ],
 ];

src/Client.php

@@ -2,8 +2,6 @@
 
 namespace Olekjs\Elasticsearch;
 
-use Illuminate\Contracts\Support\Jsonable;
-use Illuminate\Support\Facades\Http;
 use Olekjs\Elasticsearch\Contracts\AbstractClient;
 use Olekjs\Elasticsearch\Contracts\BulkOperationInterface;
 use Olekjs\Elasticsearch\Contracts\ClientInterface;

src/Contracts/AbstractClient.php

@@ -4,6 +4,8 @@
 
 use Illuminate\Http\Client\PendingRequest;
 use Illuminate\Support\Facades\Http;
+use Illuminate\Support\Str;
+use Illuminate\Support\Stringable;
 use Olekjs\Elasticsearch\Exceptions\ConflictResponseException;
 use Olekjs\Elasticsearch\Exceptions\DeleteResponseException;
 use Olekjs\Elasticsearch\Exceptions\IndexNotFoundResponseException;
@@ -17,9 +19,21 @@ abstract class AbstractClient
 {
     protected function getBaseClient(): PendingRequest
     {
-        return Http::acceptJson()
+        $apiKey = config('services.elasticsearch.api_key');
+        $port = config('services.elasticsearch.port');
+
+        $url = Str::of(config('services.elasticsearch.url'))
+            ->when(!is_null($port), fn(Stringable $str) => $str->append(':' . $port));
+
+        $http = Http::acceptJson()
             ->asJson()
-            ->baseUrl(config('services.elasticsearch.url'));
+            ->baseUrl($url);
+
+        if (!is_null($apiKey)) {
+            $http->withToken($apiKey, 'ApiKey');
+        }
+
+        return $http;
     }
 
     /**