[ML] Server info service refactor

jgowdyelastic · jgowdyelastic · commit 4e976d0dd16a · 2019-11-12T12:59:21.000Z
diff --git a/x-pack/legacy/plugins/ml/public/datavisualizer/file_based/file_datavisualizer_directive.js b/x-pack/legacy/plugins/ml/public/datavisualizer/file_based/file_datavisualizer_directive.js
@@ -16,7 +16,7 @@ import { getFileDataVisualizerBreadcrumbs } from './breadcrumbs';
 import { checkBasicLicense } from '../../license/check_license';
 import { checkFindFileStructurePrivilege } from '../../privilege/check_privilege';
 import { getMlNodeCount } from '../../ml_nodes_check/check_ml_nodes';
-import { loadNewJobDefaults } from '../../jobs/new_job_new/utils/new_job_defaults';
+import { loadMlServerInfo } from '../../services/ml_server_info';
 import { loadIndexPatterns } from '../../util/index_utils';
 import { FileDataVisualizerPage } from './file_datavisualizer';
 
@@ -36,7 +36,7 @@ uiRoutes
       privileges: checkFindFileStructurePrivilege,
       indexPatterns: loadIndexPatterns,
       mlNodeCount: getMlNodeCount,
-      loadNewJobDefaults,
+      loadMlServerInfo,
     }
   });
 
diff --git a/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/edit_job_flyout/edit_utils.js b/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/edit_job_flyout/edit_utils.js
@@ -7,7 +7,7 @@
 
 import { difference } from 'lodash';
 import chrome from 'ui/chrome';
-import { newJobLimits } from 'plugins/ml/jobs/new_job_new/utils/new_job_defaults';
+import { newJobLimits } from '../../../../services/ml_server_info';
 import { mlJobService } from 'plugins/ml/services/job_service';
 import { processCreatedBy } from '../../../../../common/util/job_utils';
 
diff --git a/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/edit_job_flyout/tabs/datafeed.js b/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/edit_job_flyout/tabs/datafeed.js
@@ -19,7 +19,7 @@ import {
 } from '@elastic/eui';
 
 import { calculateDatafeedFrequencyDefaultSeconds } from 'plugins/ml/../common/util/job_utils';
-import { newJobDefaults } from 'plugins/ml/jobs/new_job_new/utils/new_job_defaults';
+import { newJobDefaults } from '../../../../../services/ml_server_info';
 import { parseInterval } from 'plugins/ml/../common/util/parse_interval';
 import { MLJobEditor } from '../../ml_job_editor';
 import { FormattedMessage } from '@kbn/i18n/react';
diff --git a/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/node_available_warning/node_available_warning.tsx b/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/node_available_warning/node_available_warning.tsx
@@ -14,53 +14,53 @@ import { cloudDeploymentId, isCloud } from '../../../../jobs/new_job_new/utils/n
 export const NodeAvailableWarning: FC = () => {
   if (mlNodesAvailable() === true || permissionToViewMlNodeCount() === false) {
     return null;
-  } else {
-    const id = cloudDeploymentId();
-    return (
-      <Fragment>
-        <EuiCallOut
-          title={
-            <FormattedMessage
-              id="xpack.ml.jobsList.nodeAvailableWarning.noMLNodesAvailableTitle"
-              defaultMessage="No ML nodes available"
-            />
-          }
-          color="warning"
-          iconType="alert"
-        >
-          <p>
-            <FormattedMessage
-              id="xpack.ml.jobsList.nodeAvailableWarning.noMLNodesAvailableDescription"
-              defaultMessage="There are no ML nodes available."
-            />
-            <br />
-            <FormattedMessage
-              id="xpack.ml.jobsList.nodeAvailableWarning.unavailableCreateOrRunJobsDescription"
-              defaultMessage="You will not be able to create or run jobs."
-            />
-            {isCloud && id !== null && (
-              <Fragment>
-                <br />
-                <FormattedMessage
-                  id="xpack.ml.jobsList.nodeAvailableWarning.linkToCloudDescription"
-                  defaultMessage="Please edit your {link}. You may enable a free 1GB machine learning node or expand your existing ML configuration."
-                  values={{
-                    link: (
-                      <EuiLink href={`https://cloud.elastic.co/deployments?q=${id}`}>
-                        <FormattedMessage
-                          id="xpack.ml.jobsList.nodeAvailableWarning.linkToCloud.hereLinkText"
-                          defaultMessage="Elastic Cloud deployment"
-                        />
-                      </EuiLink>
-                    ),
-                  }}
-                />
-              </Fragment>
-            )}
-          </p>
-        </EuiCallOut>
-        <EuiSpacer size="m" />
-      </Fragment>
-    );
   }
+
+  const id = cloudDeploymentId();
+  return (
+    <Fragment>
+      <EuiCallOut
+        title={
+          <FormattedMessage
+            id="xpack.ml.jobsList.nodeAvailableWarning.noMLNodesAvailableTitle"
+            defaultMessage="No ML nodes available"
+          />
+        }
+        color="warning"
+        iconType="alert"
+      >
+        <p>
+          <FormattedMessage
+            id="xpack.ml.jobsList.nodeAvailableWarning.noMLNodesAvailableDescription"
+            defaultMessage="There are no ML nodes available."
+          />
+          <br />
+          <FormattedMessage
+            id="xpack.ml.jobsList.nodeAvailableWarning.unavailableCreateOrRunJobsDescription"
+            defaultMessage="You will not be able to create or run jobs."
+          />
+          {isCloud && id !== null && (
+            <Fragment>
+              <br />
+              <FormattedMessage
+                id="xpack.ml.jobsList.nodeAvailableWarning.linkToCloudDescription"
+                defaultMessage="Please edit your {link}. You may enable a free 1GB machine learning node or expand your existing ML configuration."
+                values={{
+                  link: (
+                    <EuiLink href={`https://cloud.elastic.co/deployments?q=${id}`}>
+                      <FormattedMessage
+                        id="xpack.ml.jobsList.nodeAvailableWarning.linkToCloud.hereLinkText"
+                        defaultMessage="Elastic Cloud deployment"
+                      />
+                    </EuiLink>
+                  ),
+                }}
+              />
+            </Fragment>
+          )}
+        </p>
+      </EuiCallOut>
+      <EuiSpacer size="m" />
+    </Fragment>
+  );
 };
diff --git a/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/validate_job.js b/x-pack/legacy/plugins/ml/public/jobs/jobs_list/components/validate_job.js
@@ -5,7 +5,7 @@
  */
 
 
-import { newJobLimits } from '../../new_job_new/utils/new_job_defaults';
+import { newJobLimits } from '../../../services/ml_server_info';
 import { populateValidationMessages } from '../../new_job_new/common/job_validator/util';
 
 import {
diff --git a/x-pack/legacy/plugins/ml/public/jobs/jobs_list/directive.js b/x-pack/legacy/plugins/ml/public/jobs/jobs_list/directive.js
@@ -16,7 +16,7 @@ import { checkFullLicense } from 'plugins/ml/license/check_license';
 import { checkGetJobsPrivilege } from 'plugins/ml/privilege/check_privilege';
 import { getMlNodeCount } from 'plugins/ml/ml_nodes_check/check_ml_nodes';
 import { getJobManagementBreadcrumbs } from 'plugins/ml/jobs/breadcrumbs';
-import { loadNewJobDefaults } from 'plugins/ml/jobs/new_job_new/utils/new_job_defaults';
+import { loadMlServerInfo } from 'plugins/ml/services/ml_server_info';
 
 import uiRoutes from 'ui/routes';
 
@@ -31,7 +31,7 @@ uiRoutes
       indexPatterns: loadIndexPatterns,
       privileges: checkGetJobsPrivilege,
       mlNodeCount: getMlNodeCount,
-      loadNewJobDefaults,
+      loadMlServerInfo,
     }
   });
 
diff --git a/x-pack/legacy/plugins/ml/public/jobs/new_job_new/common/job_validator/job_validator.ts b/x-pack/legacy/plugins/ml/public/jobs/new_job_new/common/job_validator/job_validator.ts
@@ -6,7 +6,7 @@
 
 import { ReactElement } from 'react';
 import { basicJobValidation, basicDatafeedValidation } from '../../../../../common/util/job_utils';
-import { newJobLimits } from '../../../new_job_new/utils/new_job_defaults';
+import { newJobLimits } from '../../../../services/ml_server_info';
 import { JobCreatorType } from '../job_creator';
 import { populateValidationMessages, checkForExistingJobAndGroupIds } from './util';
 import { ExistingJobsAndGroups } from '../../../../services/job_service';
diff --git a/x-pack/legacy/plugins/ml/public/jobs/new_job_new/common/job_validator/util.ts b/x-pack/legacy/plugins/ml/public/jobs/new_job_new/common/job_validator/util.ts
@@ -8,7 +8,7 @@ import { i18n } from '@kbn/i18n';
 import { BasicValidations } from './job_validator';
 import { Job, Datafeed } from '../job_creator/configs';
 import { ALLOWED_DATA_UNITS, JOB_ID_MAX_LENGTH } from '../../../../../common/constants/validation';
-import { newJobLimits } from '../../../new_job_new/utils/new_job_defaults';
+import { newJobLimits } from '../../../../services/ml_server_info';
 import { ValidationResults, ValidationMessage } from '../../../../../common/util/job_utils';
 import { ExistingJobsAndGroups } from '../../../../services/job_service';
 
diff --git a/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/common/model_memory_limit/model_memory_limit_input.tsx b/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/common/model_memory_limit/model_memory_limit_input.tsx
@@ -6,7 +6,7 @@
 
 import React, { FC, useState, useContext, useEffect } from 'react';
 import { EuiFieldText } from '@elastic/eui';
-import { newJobDefaults } from '../../../../../new_job_new/utils/new_job_defaults';
+import { newJobDefaults } from '../../../../../../services/ml_server_info';
 import { JobCreatorContext } from '../../job_creator_context';
 import { Description } from './description';
 
diff --git a/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/datafeed_step/components/scroll_size/scroll_size_input.tsx b/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/datafeed_step/components/scroll_size/scroll_size_input.tsx
@@ -6,7 +6,7 @@
 
 import React, { FC, useState, useContext, useEffect } from 'react';
 import { EuiFieldNumber } from '@elastic/eui';
-import { newJobDefaults } from '../../../../../utils/new_job_defaults';
+import { newJobDefaults } from '../../../../../../../services/ml_server_info';
 import { JobCreatorContext } from '../../../job_creator_context';
 import { Description } from './description';
 
diff --git a/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/summary_step/components/datafeed_details/datafeed_details.tsx b/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/summary_step/components/datafeed_details/datafeed_details.tsx
@@ -11,7 +11,7 @@ import { JobCreatorContext } from '../../../job_creator_context';
 import { MLJobEditor } from '../../../../../../jobs_list/components/ml_job_editor';
 import { calculateDatafeedFrequencyDefaultSeconds } from '../../../../../../../../common/util/job_utils';
 import { DEFAULT_QUERY_DELAY } from '../../../../../common/job_creator/util/constants';
-import { newJobDefaults } from '../../../../../utils/new_job_defaults';
+import { newJobDefaults } from '../../../../../../../services/ml_server_info';
 import { ListItems, defaultLabel, Italic } from '../common';
 
 const EDITOR_HEIGHT = '200px';
diff --git a/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/summary_step/components/job_details/job_details.tsx b/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/components/summary_step/components/job_details/job_details.tsx
@@ -15,7 +15,7 @@ import {
   isPopulationJobCreator,
   isAdvancedJobCreator,
 } from '../../../../../common/job_creator';
-import { newJobDefaults } from '../../../../../utils/new_job_defaults';
+import { newJobDefaults } from '../../../../../../../services/ml_server_info';
 import { ListItems, falseLabel, trueLabel, defaultLabel, Italic } from '../common';
 import { useKibanaContext } from '../../../../../../../contexts/kibana';
 
diff --git a/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/new_job/route.ts b/x-pack/legacy/plugins/ml/public/jobs/new_job_new/pages/new_job/route.ts
@@ -22,7 +22,7 @@ import { Route } from '../../../../../common/types/kibana';
 
 import { loadNewJobCapabilities } from '../../../../services/new_job_capabilities_service';
 
-import { loadNewJobDefaults } from '../../utils/new_job_defaults';
+import { loadMlServerInfo } from '../../../../services/ml_server_info';
 
 import { mlJobService } from '../../../../services/job_service';
 import { JOB_TYPE } from '../../common/job_creator/util/constants';
@@ -58,7 +58,7 @@ routes.forEach((route: Route) => {
       indexPattern: loadCurrentIndexPattern,
       savedSearch: loadCurrentSavedSearch,
       loadNewJobCapabilities,
-      loadNewJobDefaults,
+      loadMlServerInfo,
       existingJobsAndGroups: mlJobService.getJobAndGroupIds,
       jobType: () => route.id,
     },
diff --git a/x-pack/legacy/plugins/ml/public/services/__mocks__/ml_info_response.json b/x-pack/legacy/plugins/ml/public/services/__mocks__/ml_info_response.json
@@ -0,0 +1,21 @@
+{
+  "defaults": {
+    "anomaly_detectors": {
+      "model_memory_limit": "128mb",
+      "categorization_examples_limit": 4,
+      "model_snapshot_retention_days": 1
+    },
+    "datafeeds": {
+      "scroll_size": 1000
+    }
+  },
+  "upgrade_mode": false,
+  "native_code": {
+    "version": "8.0.0-SNAPSHOT",
+    "build_hash": "4cde1d7c50fc28"
+  },
+  "limits": {
+    "max_model_memory_limit": "128mb"
+  },
+  "cloudId": "cloud_message_test:ZXUtd2VzdC0yLmF3cy5jbG91ZC5lcy5pbyQ4NWQ2NjZmMzM1MGM0NjllOGMzMjQyZDc2YTdmNDU5YyQxNmI1ZDM2ZGE1Mzk0YjlkYjIyZWJlNDk1OWY1OGQzMg=="
+}
diff --git a/x-pack/legacy/plugins/ml/public/services/cloud_service.js b/x-pack/legacy/plugins/ml/public/services/cloud_service.js
diff --git a/x-pack/legacy/plugins/ml/public/services/ml_server_info.test.ts b/x-pack/legacy/plugins/ml/public/services/ml_server_info.test.ts
@@ -0,0 +1,63 @@
+/*
+ * 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 {
+  loadMlServerInfo,
+  cloudDeploymentId,
+  isCloud,
+  newJobDefaults,
+  newJobLimits,
+} from './ml_server_info';
+import mockMlInfoResponse from './__mocks__/ml_info_response.json';
+
+jest.mock('./ml_api_service', () => ({
+  ml: {
+    mlInfo: jest.fn(() => Promise.resolve(mockMlInfoResponse)),
+  },
+}));
+
+describe('ml_server_info initial state', () => {
+  it('server info not loaded ', () => {
+    expect(isCloud()).toBe(false);
+    expect(cloudDeploymentId()).toBe(null);
+  });
+});
+
+describe('ml_server_info', () => {
+  beforeEach(async done => {
+    await loadMlServerInfo();
+    done();
+  });
+
+  describe('cloud information', () => {
+    it('can get could deployment id', async done => {
+      expect(isCloud()).toBe(true);
+      expect(cloudDeploymentId()).toBe('85d666f3350c469e8c3242d76a7f459c');
+      done();
+    });
+  });
+
+  describe('defaults', () => {
+    it('can get defaults', async done => {
+      const defaults = newJobDefaults();
+
+      expect(defaults.anomaly_detectors.model_memory_limit).toBe('128mb');
+      expect(defaults.anomaly_detectors.categorization_examples_limit).toBe(4);
+      expect(defaults.anomaly_detectors.model_snapshot_retention_days).toBe(1);
+      expect(defaults.datafeeds.scroll_size).toBe(1000);
+      done();
+    });
+  });
+
+  describe('limits', () => {
+    it('can get limits', async done => {
+      const limits = newJobLimits();
+
+      expect(limits.max_model_memory_limit).toBe('128mb');
+      done();
+    });
+  });
+});
diff --git a/x-pack/legacy/plugins/ml/public/services/ml_server_info.ts b/x-pack/legacy/plugins/ml/public/services/ml_server_info.ts
