hasData service - hit search api in case of an error with resolve api (…

…elastic#132618)
klacabane · May 20, 2022 · 1d8bc7e · 1d8bc7e
1 parent 7c37eda
commit 1d8bc7e
Show file tree

Hide file tree

Showing 3 changed files with 57 additions and 9 deletions.
diff --git a/src/plugins/data_views/public/index.ts b/src/plugins/data_views/public/index.ts
@@ -57,6 +57,7 @@ export type {
   HasDataViewsResponse,
   IndicesResponse,
   IndicesResponseModified,
+  IndicesViaSearchResponse,
 } from './types';
 
 // Export plugin after all other imports

diff --git a/src/plugins/data_views/public/services/has_data.ts b/src/plugins/data_views/public/services/has_data.ts
@@ -8,7 +8,12 @@
 
 import { CoreStart, HttpStart } from '@kbn/core/public';
 import { DEFAULT_ASSETS_TO_IGNORE } from '../../common';
-import { HasDataViewsResponse, IndicesResponse, IndicesResponseModified } from '..';
+import {
+  HasDataViewsResponse,
+  IndicesResponse,
+  IndicesResponseModified,
+  IndicesViaSearchResponse,
+} from '..';
 
 export class HasData {
   private removeAliases = (source: IndicesResponseModified): boolean => !source.item.indices;
@@ -77,6 +82,41 @@ export class HasData {
     return source;
   };
 
+  private getIndicesViaSearch = async ({
+    http,
+    pattern,
+    showAllIndices,
+  }: {
+    http: HttpStart;
+    pattern: string;
+    showAllIndices: boolean;
+  }): Promise<boolean> =>
+    http
+      .post<IndicesViaSearchResponse>(`/internal/search/ese`, {
+        body: JSON.stringify({
+          params: {
+            ignore_unavailable: true,
+            expand_wildcards: showAllIndices ? 'all' : 'open',
+            index: pattern,
+            body: {
+              size: 0, // no hits
+              aggs: {
+                indices: {
+                  terms: {
+                    field: '_index',
+                    size: 200,
+                  },
+                },
+              },
+            },
+          },
+        }),
+      })
+      .then((resp) => {
+        return !!(resp && resp.total >= 0);
+      })
+      .catch(() => false);
+
   private getIndices = async ({
     http,
     pattern,
@@ -96,26 +136,29 @@ export class HasData {
         } else {
           return this.responseToItemArray(response);
         }
-      })
-      .catch(() => []);
+      });
 
   private checkLocalESData = (http: HttpStart): Promise<boolean> =>
     this.getIndices({
       http,
       pattern: '*',
       showAllIndices: false,
-    }).then((dataSources: IndicesResponseModified[]) => {
-      return dataSources.some(this.isUserDataIndex);
-    });
+    })
+      .then((dataSources: IndicesResponseModified[]) => {
+        return dataSources.some(this.isUserDataIndex);
+      })
+      .catch(() => this.getIndicesViaSearch({ http, pattern: '*', showAllIndices: false }));
 
   private checkRemoteESData = (http: HttpStart): Promise<boolean> =>
     this.getIndices({
       http,
       pattern: '*:*',
       showAllIndices: false,
-    }).then((dataSources: IndicesResponseModified[]) => {
-      return !!dataSources.filter(this.removeAliases).length;
-    });
+    })
+      .then((dataSources: IndicesResponseModified[]) => {
+        return !!dataSources.filter(this.removeAliases).length;
+      })
+      .catch(() => this.getIndicesViaSearch({ http, pattern: '*:*', showAllIndices: false }));
 
   // Data Views
 

diff --git a/src/plugins/data_views/public/types.ts b/src/plugins/data_views/public/types.ts
@@ -56,6 +56,10 @@ export interface IndicesResponse {
   data_streams?: IndicesResponseItemDataStream[];
 }
 
+export interface IndicesViaSearchResponse {
+  total: number;
+}
+
 export interface HasDataViewsResponse {
   hasDataView: boolean;
   hasUserDataView: boolean;