Adds support for HTTPS transport, SSL, and Authentication

Author: medteck

README.md

@@ -106,6 +106,13 @@ ELASTICSEARCH_HOST=localhost
 ELASTICSEARCH_PORT=9200
 ELASTICSEARCH_INDEX=vue_storefront_catalog
 
+// Set transport value to "https" and ssl to "true" when using an ssl connection
+ELASTICSEARCH_TRANSPORT=http
+ELASTICSEARCH_SSL=false
+// Leave blank if authentication is not required
+ELASTICSEARCH_USERNAME=
+ELASTICSEARCH_PASSWORD=
+
 // Optionally, when using Nelmio CORS Bundle
 CORS_ALLOW_ORIGIN=^https?://(localhost|127\.0\.0\.1)(:[0-9]+)?$
 ```

src/Controller/Catalog/GetCatalogAction.php

@@ -32,17 +32,50 @@ final class GetCatalogAction
     /** @var int */
     private $port;
 
-    public function __construct(ViewHandlerInterface $viewHandler, string $host, int $port)
+    /** @var string */
+    private $transport;
+
+    /** @var bool */
+    private $ssl;
+
+    /** @var int */
+    private $username;
+
+    /** @var string */
+    private $password;
+
+    public function __construct(
+        ViewHandlerInterface $viewHandler,
+        string $host,
+        int $port,
+        string $transport,
+        bool $ssl,
+        string $username,
+        string $password
+    )
     {
         $this->host = $host;
         $this->port = $port;
+        $this->transport = $transport;
+        $this->ssl = $ssl;
+        $this->username = $username;
+        $this->password = $password;
         $this->viewHandler = $viewHandler;
     }
 
     public function __invoke(Request $request): Response
     {
         $client = new Client();
-        $client->addConnection(new Connection(['host' => $this->host, 'port' => $this->port]));
+        $connection = new Connection([
+            'host' => $this->host,
+            'port' => $this->port,
+            'transport' => $this->transport,
+            'ssl' => $this->ssl,
+            'username' => $this->username,
+            'password' => $this->password
+        ]);
+        
+        $client->addConnection($connection);
 
         $index = $request->attributes->get('index');
         $type = $request->attributes->get('type');

src/Resources/config/services/api/catalog.xml

@@ -14,6 +14,10 @@
             <argument type="service" id="fos_rest.view_handler" />
             <argument>%env(ELASTICSEARCH_HOST)%</argument>
             <argument>%env(ELASTICSEARCH_PORT)%</argument>
+            <argument>%env(ELASTICSEARCH_TRANSPORT)%</argument>
+            <argument>%env(ELASTICSEARCH_SSL)%</argument>
+            <argument>%env(ELASTICSEARCH_USERNAME)%</argument>
+            <argument>%env(ELASTICSEARCH_PASSWORD)%</argument>
         </service>
     </services>
 </container>