Fixes index pattern wizard when there are remote clusters but no local indices

src/core_plugins/kibana/index.js

@@ -30,6 +30,7 @@ import { managementApi } from './server/routes/api/management';
 import { scriptsApi } from './server/routes/api/scripts';
 import { registerSuggestionsApi } from './server/routes/api/suggestions';
 import { registerKqlTelemetryApi } from './server/routes/api/kql_telemetry';
+import { registerClustersRoute } from './server/routes/api/remote_info';
 import { registerFieldFormats } from './server/field_formats/register';
 import { registerTutorials } from './server/tutorials/register';
 import * as systemApi from './server/lib/system_api';
@@ -167,6 +168,7 @@ export default function (kibana) {
       registerFieldFormats(server);
       registerTutorials(server);
       makeKQLUsageCollector(server);
+      registerClustersRoute(server);
       server.expose('systemApi', systemApi);
       server.expose('handleEsError', handleEsError);
       server.injectUiAppVars('kibana', () => injectVars(server));

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/__jest__/__snapshots__/create_index_pattern_wizard.test.js.snap

@@ -88,6 +88,35 @@ exports[`CreateIndexPatternWizard renders time field step when step is set to 2
 </div>
 `;
 
+exports[`CreateIndexPatternWizard renders when there are no indices but there are remote clusters 1`] = `
+<div>
+  <Header
+    indexPatternName="name"
+    isIncludingSystemIndices={false}
+    onChangeIncludingSystemIndices={[Function]}
+    showSystemIndices={false}
+  />
+  <StepIndexPattern
+    allIndices={Array []}
+    esService={Object {}}
+    goToNextStep={[Function]}
+    indexPatternCreationType={
+      Object {
+        "checkIndicesForErrors": [Function],
+        "getIndexPatternMappings": [Function],
+        "getIndexPatternName": [Function],
+        "getIndexPatternType": [Function],
+        "getShowSystemIndices": [Function],
+        "renderPrompt": [Function],
+      }
+    }
+    initialQuery=""
+    isIncludingSystemIndices={false}
+    savedObjectsClient={Object {}}
+  />
+</div>
+`;
+
 exports[`CreateIndexPatternWizard shows system indices even if there are no other indices if the include system indices is toggled 1`] = `
 <div>
   <Header

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/__jest__/create_index_pattern_wizard.test.js

@@ -41,6 +41,9 @@ jest.mock('../lib/get_indices', () => ({
     ];
   },
 }));
+jest.mock('ui/chrome', () => ({
+  addBasePath: () => { },
+}));
 
 const loadingDataDocUrl = '';
 const initialQuery = '';
@@ -79,6 +82,26 @@ describe('CreateIndexPatternWizard', () => {
     component.setState({
       isInitiallyLoadingIndices: false,
       allIndices: [],
+      remoteClustersExist: false
+    });
+
+    await component.update();
+    expect(component).toMatchSnapshot();
+  });
+
+  it('renders when there are no indices but there are remote clusters', async () => {
+    const component = shallow(
+      <CreateIndexPatternWizard
+        loadingDataDocUrl={loadingDataDocUrl}
+        initialQuery={initialQuery}
+        services={services}
+      />
+    );
+
+    component.setState({
+      isInitiallyLoadingIndices: false,
+      allIndices: [],
+      remoteClustersExist: true
     });
 
     await component.update();

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/__jest__/render.test.js

@@ -32,6 +32,7 @@ jest.mock('ui/chrome', () => ({
   getUiSettingsClient: () => ({
     get: () => '',
   }),
+  addBasePath: () => { },
 }));
 
 const { renderCreateIndexPatternWizard, destroyCreateIndexPatternWizard } = require('../render');

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/components/step_index_pattern/__jest__/step_index_pattern.test.js

@@ -41,6 +41,7 @@ jest.mock('ui/chrome', () => ({
   getUiSettingsClient: () => ({
     get: () => '',
   }),
+  addBasePath: () => { },
 }));
 
 jest.mock('../../../lib/get_indices', () => ({
@@ -62,7 +63,7 @@ const esService = {};
 const savedObjectsClient = {
   find: () => ({ savedObjects: [] })
 };
-const goToNextStep = () => {};
+const goToNextStep = () => { };
 
 const createComponent = props => {
   return shallowWithIntl(

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/components/step_time_field/__jest__/step_time_field.test.js

@@ -29,6 +29,9 @@ jest.mock('../components/action_buttons', () => ({ ActionButtons: 'ActionButtons
 jest.mock('../../../lib/extract_time_fields', () => ({
   extractTimeFields: fields => fields,
 }));
+jest.mock('ui/chrome', () => ({
+  addBasePath: () => { },
+}));
 
 const mockIndexPatternCreationType = {
   getIndexPatternType: () => 'default',

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/create_index_pattern_wizard.js

@@ -30,6 +30,7 @@ import { MAX_SEARCH_SIZE } from './constants';
 import {
   ensureMinimumTime,
   getIndices,
+  getRemoteClusters
 } from './lib';
 
 export class CreateIndexPatternWizard extends Component {
@@ -52,20 +53,35 @@ export class CreateIndexPatternWizard extends Component {
       step: 1,
       indexPattern: '',
       allIndices: [],
+      remoteClustersExist: false,
       isInitiallyLoadingIndices: true,
       isIncludingSystemIndices: false,
     };
   }
 
   async componentWillMount() {
-    this.fetchIndices();
+    this.fetchData();
   }
 
-  fetchIndices = async () => {
-    this.setState({ allIndices: [], isInitiallyLoadingIndices: true });
+  fetchData = async () => {
     const { services } = this.props;
-    const allIndices = await ensureMinimumTime(getIndices(services.es, this.indexPatternCreationType, `*`, MAX_SEARCH_SIZE)); //
-    this.setState({ allIndices, isInitiallyLoadingIndices: false });
+
+    this.setState({
+      allIndices: [],
+      isInitiallyLoadingIndices: true,
+      remoteClustersExist: false
+    });
+
+    const [allIndices, remoteClusters] = await ensureMinimumTime([
+      getIndices(services.es, this.indexPatternCreationType, `*`, MAX_SEARCH_SIZE),
+      getRemoteClusters(services.$http)
+    ]);
+
+    this.setState({
+      allIndices,
+      isInitiallyLoadingIndices: false,
+      remoteClustersExist: remoteClusters.length !== 0
+    });
   }
 
   createIndexPattern = async (timeFieldName, indexPatternId) => {
@@ -126,15 +142,18 @@ export class CreateIndexPatternWizard extends Component {
       isIncludingSystemIndices,
       step,
       indexPattern,
+      remoteClustersExist
     } = this.state;
 
     if (isInitiallyLoadingIndices) {
       return <LoadingState />;
     }
 
     const hasDataIndices = allIndices.some(({ name }) => !name.startsWith('.'));
-    if (!hasDataIndices && !isIncludingSystemIndices) {
-      return <EmptyState onRefresh={this.fetchIndices} />;
+    if (!hasDataIndices &&
+      !isIncludingSystemIndices &&
+      !remoteClustersExist) {
+      return <EmptyState onRefresh={this.fetchData} />;
     }
 
     if (step === 1) {

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/index.js

@@ -39,6 +39,7 @@ uiRoutes.when('/management/kibana/index', {
         config: $injector.get('config'),
         es: $injector.get('es'),
         indexPatterns: $injector.get('indexPatterns'),
+        $http: $injector.get('$http'),
         savedObjectsClient: Private(SavedObjectsClientProvider),
         indexPatternCreationType,
         changeUrl: url => {

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/lib/get_remote_clusters.js

@@ -0,0 +1,26 @@
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import chrome from 'ui/chrome';
+const apiPrefix = chrome.addBasePath('/api/kibana');
+
+export async function getRemoteClusters($http) {
+  const response = await $http.get(`${apiPrefix}/clusters`);
+  return response.data;
+}

src/core_plugins/kibana/public/management/sections/indices/create_index_pattern_wizard/lib/index.js

@@ -28,3 +28,5 @@ export { getMatchedIndices } from './get_matched_indices';
 export { containsIllegalCharacters } from './contains_illegal_characters';
 
 export { extractTimeFields } from './extract_time_fields';
+
+export { getRemoteClusters } from './get_remote_clusters';

src/core_plugins/kibana/server/routes/api/remote_info/call_with_request_factory.js

@@ -0,0 +1,37 @@
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { once } from 'lodash';
+
+const callWithRequest = once(server => {
+  const cluster = server.plugins.elasticsearch.getCluster('data');
+  return cluster.callWithRequest;
+});
+
+export const callWithRequestFactory = (server, request) => {
+  return (...args) => {
+    return callWithRequest(server)(request, ...args);
+  };
+};

src/core_plugins/kibana/server/routes/api/remote_info/index.js

@@ -0,0 +1,50 @@
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { callWithRequestFactory } from './call_with_request_factory';
+
+async function fetchRemoteClusters(callWithRequest) {
+  const options = {
+    method: 'GET',
+    path: '_remote/info'
+  };
+  const remoteInfo = await callWithRequest('transport.request', options);
+  return Object.keys(remoteInfo);
+}
+
+export function registerClustersRoute(server) {
+  server.route({
+    path: '/api/kibana/clusters',
+    method: 'GET',
+    handler: async request => {
+      const callWithRequest = callWithRequestFactory(server, request);
+      try {
+        return await fetchRemoteClusters(callWithRequest);
+      } catch (error) {
+        return error.body;
+      }
+    }
+  });
+}

x-pack/plugins/index_management/server/routes/api/indices/register_list_route.js

@@ -7,7 +7,7 @@
 import { callWithRequestFactory } from '../../../lib/call_with_request_factory';
 import { isEsErrorFactory } from '../../../lib/is_es_error_factory';
 import { wrapEsError, wrapUnknownError } from '../../../lib/error_wrappers';
-import { licensePreRoutingFactory } from'../../../lib/license_pre_routing_factory';
+import { licensePreRoutingFactory } from '../../../lib/license_pre_routing_factory';
 
 function formatHits(hits) {
   return hits.map(hit => {
@@ -57,7 +57,7 @@ export function registerListRoute(server) {
       }
     },
     config: {
-      pre: [ licensePreRouting ]
+      pre: [licensePreRouting]
     }
   });
 }