"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.logJobsSpaces = logJobsSpaces;
var _re = _interopRequireDefault(require("re2"));
var _log = require("../../../lib/log");
/*
 * 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.
 */

const GROUP = 'logs-ui';
const MODULE_PREFIX = 'kibana-logs-ui';
const SOURCES = ['default', 'internal-stack-monitoring'];
const JOB_IDS = ['log-entry-rate', 'log-entry-categories-count'];

// jobs created by the logs plugin will be in the logs-ui group
// they contain the a space name in the job id, and so the id can be parsed
// and the job assigned to the correct space.
async function logJobsSpaces({
  asInternalUser
}) {
  try {
    const body = await asInternalUser.ml.getJobs({
      job_id: GROUP
    });
    if (body.jobs.length === 0) {
      return [];
    }
    const findLogJobSpace = findLogJobSpaceFactory();
    return body.jobs.map(j => ({
      id: j.job_id,
      space: findLogJobSpace(j.job_id)
    })).filter(j => j.space !== null);
  } catch ({
    body
  }) {
    if (body.status !== 404) {
      // 404s are expected if there are no logs-ui jobs
      _log.mlLog.error(`Error Initializing Logs job ${JSON.stringify(body)}`);
    }
  }
  return [];
}
function findLogJobSpaceFactory() {
  const reg = new _re.default(`${MODULE_PREFIX}-(.+)-(${SOURCES.join('|')})-(${JOB_IDS.join('|')})`);
  return jobId => {
    var _result$;
    const result = reg.exec(jobId);
    if (result === null) {
      return null;
    }
    return (_result$ = result[1]) !== null && _result$ !== void 0 ? _result$ : null;
  };
}