"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.mlFieldFormatService = void 0;
var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
var _job_utils = require("../../../common/util/job_utils");
var _index_utils = require("../util/index_utils");
var _job_service = require("./job_service");
/*
 * 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.
 */

// Service for accessing FieldFormat objects configured for a Kibana data view
// for use in formatting the actual and typical values from anomalies.
class FieldFormatService {
  constructor() {
    (0, _defineProperty2.default)(this, "indexPatternIdsByJob", {});
    (0, _defineProperty2.default)(this, "formatsByJob", {});
  }
  // 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
  // configured in the datafeed of each job.
  // Builds a map of Kibana FieldFormats (plugins/data/common/field_formats)
  // against detector index by job ID.
  async populateFormats(jobIds) {
    // Populate a map of data view IDs against job ID, by finding the ID of the data
    // view with a title attribute which matches the indices configured in the datafeed.
    // If a Kibana data view has not been created
    // for this index, then no custom field formatting will occur.
    (await Promise.all(jobIds.map(async jobId => {
      const jobObj = _job_service.mlJobService.getJob(jobId);
      return {
        jobId,
        dataViewId: await (0, _index_utils.getDataViewIdFromName)(jobObj.datafeed_config.indices.join(','))
      };
    }))).forEach(({
      jobId,
      dataViewId
    }) => {
      if (dataViewId !== null) {
        this.indexPatternIdsByJob[jobId] = dataViewId;
      }
    });
    const promises = jobIds.map(jobId => Promise.all([this.getFormatsForJob(jobId)]));
    try {
      const fmtsByJobByDetector = await Promise.all(promises);
      fmtsByJobByDetector.forEach((formatsByDetector, i) => {
        this.formatsByJob[jobIds[i]] = formatsByDetector[0];
      });
      return this.formatsByJob;
    } catch (error) {
      console.log('Error populating field formats:', error); // eslint-disable-line no-console
      return {
        formats: {},
        error
      };
    }
  }

  // Return the FieldFormat to use for formatting values from
  // the detector from the job with the specified ID.
  getFieldFormat(jobId, detectorIndex) {
    if (this.formatsByJob.hasOwnProperty(jobId)) {
      return this.formatsByJob[jobId][detectorIndex];
    }
  }
  getFormatsForJob(jobId) {
    return new Promise((resolve, reject) => {
      const jobObj = _job_service.mlJobService.getJob(jobId);
      const detectors = jobObj.analysis_config.detectors || [];
      const formatsByDetector = [];
      const dataViewId = this.indexPatternIdsByJob[jobId];
      if (dataViewId !== undefined) {
        // Load the full data view configuration to obtain the formats of each field.
        (0, _index_utils.getDataViewById)(dataViewId).then(dataView => {
          // Store the FieldFormat for each job by detector_index.
          const fieldList = dataView.fields;
          detectors.forEach(dtr => {
            const esAgg = (0, _job_utils.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);
      }
    });
  }
}
const mlFieldFormatService = new FieldFormatService();
exports.mlFieldFormatService = mlFieldFormatService;