[ML] Anomaly Detection: Adds single metric viewer embeddable for dashboards

x-pack/packages/ml/anomaly_utils/anomaly_utils.ts

@@ -59,6 +59,10 @@ export interface MlEntityField {
    * Optional entity field operation
    */
   operation?: MlEntityFieldOperation;
+  /**
+   * Optional cardinality of field
+   */
+  cardinality?: number;
 }
 
 // List of function descriptions for which actual values from record level results should be displayed.

x-pack/plugins/ml/public/application/services/field_format_service.ts

@@ -8,16 +8,20 @@
 import { mlFunctionToESAggregation } from '../../../common/util/job_utils';
 import { getDataViewById, getDataViewIdFromName } from '../util/index_utils';
 import { mlJobService } from './job_service';
+import type { MlIndexUtils } from '../util/index_service';
+import type { MlApiServices } from './ml_api_service';
 
 type FormatsByJobId = Record<string, any>;
 type IndexPatternIdsByJob = Record<string, any>;
 
 // Service for accessing FieldFormat objects configured for a Kibana data view
 // for use in formatting the actual and typical values from anomalies.
-class FieldFormatService {
+export class FieldFormatService {
   indexPatternIdsByJob: IndexPatternIdsByJob = {};
   formatsByJob: FormatsByJobId = {};
 
+  constructor(private mlApiServices?: MlApiServices, private mlIndexUtils?: MlIndexUtils) {}
+
   // Populate the service with the FieldFormats for the list of jobs with the
   // specified IDs. List of Kibana data views is passed, with a title
   // attribute set in each pattern which will be compared to the indices
@@ -32,10 +36,17 @@ class FieldFormatService {
     (
       await Promise.all(
         jobIds.map(async (jobId) => {
-          const jobObj = mlJobService.getJob(jobId);
+          const getDataViewId = this.mlIndexUtils?.getDataViewIdFromName ?? getDataViewIdFromName;
+          let jobObj;
+          if (this.mlApiServices) {
+            const { jobs } = await this.mlApiServices.getJobs({ jobId });
+            jobObj = jobs[0];
+          } else {
+            jobObj = mlJobService.getJob(jobId);
+          }
           return {
             jobId,
-            dataViewId: await getDataViewIdFromName(jobObj.datafeed_config.indices.join(',')),
+            dataViewId: await getDataViewId(jobObj.datafeed_config!.indices.join(',')),
           };
         })
       )
@@ -68,41 +79,40 @@ class FieldFormatService {
     }
   }
 
-  getFormatsForJob(jobId: string): Promise<any[]> {
-    return new Promise((resolve, reject) => {
-      const jobObj = mlJobService.getJob(jobId);
-      const detectors = jobObj.analysis_config.detectors || [];
-      const formatsByDetector: any[] = [];
+  async getFormatsForJob(jobId: string): Promise<any[]> {
+    let jobObj;
+    const getDataView = this.mlIndexUtils?.getDataViewById ?? getDataViewById;
+    if (this.mlApiServices) {
+      const { jobs } = await this.mlApiServices.getJobs({ jobId });
+      jobObj = jobs[0];
+    } else {
+      jobObj = mlJobService.getJob(jobId);
+    }
+    const detectors = jobObj.analysis_config.detectors || [];
+    const formatsByDetector: any[] = [];
 
-      const dataViewId = this.indexPatternIdsByJob[jobId];
-      if (dataViewId !== undefined) {
-        // Load the full data view configuration to obtain the formats of each field.
-        getDataViewById(dataViewId)
-          .then((dataView) => {
-            // Store the FieldFormat for each job by detector_index.
-            const fieldList = dataView.fields;
-            detectors.forEach((dtr) => {
-              const esAgg = mlFunctionToESAggregation(dtr.function);
-              // distinct_count detectors should fall back to the default
-              // formatter as the values are just counts.
-              if (dtr.field_name !== undefined && esAgg !== 'cardinality') {
-                const field = fieldList.getByName(dtr.field_name);
-                if (field !== undefined) {
-                  formatsByDetector[dtr.detector_index!] = dataView.getFormatterForField(field);
-                }
-              }
-            });
+    const dataViewId = this.indexPatternIdsByJob[jobId];
+    if (dataViewId !== undefined) {
+      // Load the full data view configuration to obtain the formats of each field.
+      const dataView = await getDataView(dataViewId);
+      // Store the FieldFormat for each job by detector_index.
+      const fieldList = dataView.fields;
+      detectors.forEach((dtr) => {
+        const esAgg = mlFunctionToESAggregation(dtr.function);
+        // distinct_count detectors should fall back to the default
+        // formatter as the values are just counts.
+        if (dtr.field_name !== undefined && esAgg !== 'cardinality') {
+          const field = fieldList.getByName(dtr.field_name);
+          if (field !== undefined) {
+            formatsByDetector[dtr.detector_index!] = dataView.getFormatterForField(field);
+          }
+        }
+      });
+    }
 
-            resolve(formatsByDetector);
-          })
-          .catch((err) => {
-            reject(err);
-          });
-      } else {
-        resolve(formatsByDetector);
-      }
-    });
+    return formatsByDetector;
   }
 }
 
 export const mlFieldFormatService = new FieldFormatService();
+export type MlFieldFormatService = typeof mlFieldFormatService;

x-pack/plugins/ml/public/application/services/field_format_service_factory.ts

@@ -0,0 +1,17 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0; you may not use this file except in compliance with the Elastic License
+ * 2.0.
+ */
+
+import { type MlFieldFormatService, FieldFormatService } from './field_format_service';
+import type { MlIndexUtils } from '../util/index_service';
+import type { MlApiServices } from './ml_api_service';
+
+export function fieldFormatServiceFactory(
+  mlApiServices: MlApiServices,
+  mlIndexUtils: MlIndexUtils
+): MlFieldFormatService {
+  return new FieldFormatService(mlApiServices, mlIndexUtils);
+}

x-pack/plugins/ml/public/application/services/forecast_service.d.ts

@@ -32,3 +32,5 @@ export const mlForecastService: {
 
   getForecastDateRange: (job: Job, forecastId: string) => Promise<ForecastDateRange>;
 };
+
+export type MlForecastService = typeof mlForecastService;