Added product not supported scenario

elastic · Aug 30, 2021 · 0f25dc6 · 0f25dc6
1 parent a45adb7
commit 0f25dc6
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 1 deletion.
diff --git a/src/plugins/interactive_setup/server/elasticsearch_service.test.ts b/src/plugins/interactive_setup/server/elasticsearch_service.test.ts
@@ -527,6 +527,16 @@ some weird+ca/with
         );
       });
 
+      it('fails if host is not supported', async () => {
+        mockPingClient.asInternalUser.ping.mockRejectedValue(
+          new errors.ProductNotSupportedError(interactiveSetupMock.createApiResponse({ body: {} }))
+        );
+
+        await expect(setupContract.ping('http://localhost:9200')).rejects.toMatchInlineSnapshot(
+          `[ProductNotSupportedError: The client noticed that the server is not Elasticsearch and we do not support this unknown product.]`
+        );
+      });
+
       it('succeeds if host does not require authentication', async () => {
         mockPingClient.asInternalUser.ping.mockResolvedValue(
           interactiveSetupMock.createApiResponse({ statusCode: 200, body: true })

diff --git a/src/plugins/interactive_setup/server/elasticsearch_service.ts b/src/plugins/interactive_setup/server/elasticsearch_service.ts
@@ -294,7 +294,11 @@ export class ElasticsearchService {
     try {
       await client.asInternalUser.ping();
     } catch (error) {
-      if (error instanceof errors.ConnectionError || error instanceof errors.TimeoutError) {
+      if (
+        error instanceof errors.ConnectionError ||
+        error instanceof errors.TimeoutError ||
+        error instanceof errors.ProductNotSupportedError
+      ) {
         this.logger.error(`Unable to connect to host "${host}": ${getDetailedErrorMessage(error)}`);
         throw error;
       }