[Monitoring] "Internal Monitoring" deprecation warning

x-pack/plugins/monitoring/public/lib/internal_monitoring_toasts.tsx

@@ -0,0 +1,123 @@
+/*
+ * 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 React from 'react';
+import { i18n } from '@kbn/i18n';
+import { FormattedMessage } from '@kbn/i18n/react';
+import { EuiSpacer, EuiLink } from '@elastic/eui';
+import { Legacy } from '../legacy_shims';
+import { toMountPoint } from '../../../../../src/plugins/kibana_react/public';
+import { isInSetupMode, toggleSetupMode } from './setup_mode';
+
+export interface MonitoringIndicesTypes {
+  legacyIndices: boolean;
+  metricbeatIndices: boolean;
+}
+
+const enterSetupModeLabel = () =>
+  i18n.translate('xpack.monitoring.internalMonitoringToast.enterSetupMode', {
+    defaultMessage: 'Enter setup mode',
+  });
+
+const learnMoreLabel = () =>
+  i18n.translate('xpack.monitoring.internalMonitoringToast.learnMoreAction', {
+    defaultMessage: 'Learn more',
+  });
+
+const showIfLegacyOnlyIndices = () => {
+  const { ELASTIC_WEBSITE_URL } = Legacy.shims.docLinks;
+  const toast = Legacy.shims.toastNotifications.addWarning({
+    title: toMountPoint(
+      <FormattedMessage
+        id="xpack.monitoring.internalMonitoringToast.title"
+        defaultMessage="Internal Monitoring Detected"
+      />
+    ),
+    text: toMountPoint(
+      <div>
+        <p>
+          {i18n.translate('xpack.monitoring.internalMonitoringToast.description', {
+            defaultMessage: `It appears you are using "Internal Collection" for Stack Monitoring. 
+            This method of monitoring will no longer be supported in the next major release (8.0.0). 
+            Please follow the steps in setup mode to start monitoring with Metricbeat.`,
+          })}
+        </p>
+        <EuiLink
+          onClick={() => {
+            Legacy.shims.toastNotifications.remove(toast);
+            toggleSetupMode(true);
+          }}
+        >
+          {enterSetupModeLabel()}
+        </EuiLink>
+
+        <EuiSpacer />
+        <EuiLink
+          href={`${ELASTIC_WEBSITE_URL}blog/external-collection-for-elastic-stack-monitoring-is-now-available-via-metricbeat`}
+          external
+          target="_blank"
+        >
+          {learnMoreLabel()}
+        </EuiLink>
+      </div>
+    ),
+  });
+};
+
+const showIfLegacyAndMetricbeatIndices = () => {
+  const { ELASTIC_WEBSITE_URL } = Legacy.shims.docLinks;
+  const toast = Legacy.shims.toastNotifications.addWarning({
+    title: toMountPoint(
+      <FormattedMessage
+        id="xpack.monitoring.internalAndMetricbeatMonitoringToast.title"
+        defaultMessage="Partial Internal Monitoring Detected"
+      />
+    ),
+    text: toMountPoint(
+      <div>
+        <p>
+          {i18n.translate('xpack.monitoring.internalAndMetricbeatMonitoringToast.description', {
+            defaultMessage: `It appears you are using both Metricbeat and "Internal Collection" for Stack Monitoring. 
+            only Metricbeat type monitoring will be supported in the next major release (8.0.0). 
+            Please follow the steps in setup mode to migrate the rest of the monitoring to Metricbeat.`,
+          })}
+        </p>
+        <EuiLink
+          onClick={() => {
+            Legacy.shims.toastNotifications.remove(toast);
+            toggleSetupMode(true);
+          }}
+        >
+          {enterSetupModeLabel()}
+        </EuiLink>
+
+        <EuiSpacer />
+        <EuiLink
+          href={`${ELASTIC_WEBSITE_URL}blog/external-collection-for-elastic-stack-monitoring-is-now-available-via-metricbeat`}
+          external
+          target="_blank"
+        >
+          {learnMoreLabel()}
+        </EuiLink>
+      </div>
+    ),
+  });
+};
+
+export const showInternalMonitoringToast = ({
+  legacyIndices,
+  metricbeatIndices,
+}: MonitoringIndicesTypes) => {
+  if (isInSetupMode()) {
+    return;
+  }
+
+  if (legacyIndices && !metricbeatIndices) {
+    showIfLegacyOnlyIndices();
+  } else if (legacyIndices && metricbeatIndices) {
+    showIfLegacyAndMetricbeatIndices();
+  }
+};

x-pack/plugins/monitoring/public/services/clusters.js

@@ -7,6 +7,7 @@
 import { ajaxErrorHandlersProvider } from '../lib/ajax_error_handler';
 import { Legacy } from '../legacy_shims';
 import { STANDALONE_CLUSTER_CLUSTER_UUID } from '../../common/constants';
+import { showInternalMonitoringToast } from '../lib/internal_monitoring_toasts';
 
 function formatClusters(clusters) {
   return clusters.map(formatCluster);
@@ -62,10 +63,30 @@ export function monitoringClustersProvider($injector) {
       });
     }
 
+    function ensureMetricbeatEnabled() {
+      if (Legacy.shims.isCloud) {
+        return Promise.resolve();
+      }
+
+      return $http
+        .get('../api/monitoring/v1/elasticsearch_settings/check/internal_monitoring')
+        .then(({ data }) => {
+          showInternalMonitoringToast({
+            legacyIndices: data.legacy_indices,
+            metricbeatIndices: data.mb_indices,
+          });
+        })
+        .catch((err) => {
+          const Private = $injector.get('Private');
+          const ajaxErrorHandlers = Private(ajaxErrorHandlersProvider);
+          return ajaxErrorHandlers(err);
+        });
+    }
+
     if (!once) {
       return getClusters().then((clusters) => {
         if (clusters.length) {
-          return ensureAlertsEnabled()
+          return Promise.all([ensureAlertsEnabled(), ensureMetricbeatEnabled()])
             .then(() => {
               once = true;
               return clusters;

x-pack/plugins/monitoring/server/routes/api/v1/elasticsearch_settings/check/internal_monitoring.ts

@@ -0,0 +1,53 @@
+/*
+ * 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 { CatIndicesParams } from 'elasticsearch';
+// @ts-ignore
+import { handleError } from '../../../../../lib/errors';
+import { RouteDependencies } from '../../../../../types';
+
+export function internalMonitoringCheckRoute(_server: unknown, npRoute: RouteDependencies) {
+  npRoute.router.get(
+    {
+      path: '/api/monitoring/v1/elasticsearch_settings/check/internal_monitoring',
+      options: { tags: ['access:monitoring'] },
+      validate: false,
+    },
+    async (context, _request, response) => {
+      try {
+        const catQuery: Pick<CatIndicesParams, 'format' | 'h'> & {
+          expand_wildcards: string;
+          index?: string;
+        } = {
+          format: 'json',
+          h: 'index',
+          expand_wildcards: 'hidden,all',
+          index: '.monitoring-*',
+        };
+
+        const { client: esClient } = context.core.elasticsearch.legacy;
+        const monitoringIndices = await esClient.callAsInternalUser('transport.request', {
+          method: 'GET',
+          path: '/_cat/indices',
+          query: catQuery,
+        });
+
+        const mbIndices = monitoringIndices.filter(({ index }: { index: string }) =>
+          index.includes('-mb-')
+        );
+
+        return response.ok({
+          body: {
+            legacy_indices: Boolean(monitoringIndices.length - mbIndices.length),
+            mb_indices: Boolean(mbIndices.length),
+          },
+        });
+      } catch (err) {
+        throw handleError(err);
+      }
+    }
+  );
+}

x-pack/plugins/monitoring/server/routes/api/v1/elasticsearch_settings/index.js

@@ -4,6 +4,7 @@
  * you may not use this file except in compliance with the Elastic License.
  */
 
+export { internalMonitoringCheckRoute } from './check/internal_monitoring';
 export { clusterSettingsCheckRoute } from './check/cluster';
 export { nodesSettingsCheckRoute } from './check/nodes';
 export { setCollectionEnabledRoute } from './set/collection_enabled';

x-pack/plugins/monitoring/server/routes/api/v1/ui.js

@@ -20,6 +20,7 @@ export {
   ccrShardRoute,
 } from './elasticsearch';
 export {
+  internalMonitoringCheckRoute,
   clusterSettingsCheckRoute,
   nodesSettingsCheckRoute,
   setCollectionEnabledRoute,