/*
 * Copyright OpenSearch Contributors
 * SPDX-License-Identifier: Apache-2.0
 */
import { CoreStart } from "opensearch-dashboards/public";
import { CommonService } from "../../../../services";
import { TemplateItemRemote } from "../../../../../models/interfaces";
import { DataStream } from "../../../../../server/models/interfaces";

export const createDataStream = async (props: { value: string; isEdit: boolean; commonService: CommonService }) => {
  return await props.commonService.apiCaller({
    endpoint: "transport.request",
    data: {
      method: "PUT",
      path: `_data_stream/${props.value}`,
    },
  });
};

export const getDataStream = async (props: { dataStream: string; commonService: CommonService; coreService: CoreStart }) => {
  const response = await props.commonService.apiCaller<{
    data_streams: DataStream[];
  }>({
    endpoint: "transport.request",
    data: {
      method: "GET",
      path: `_data_stream/${props.dataStream}`,
    },
  });
  let error: string = "";
  if (response.ok) {
    const findItem = response.response?.data_streams?.find((item) => item.name === props.dataStream);
    if (findItem) {
      const dataStreamDetail = findItem;

      return JSON.parse(JSON.stringify(dataStreamDetail));
    }
    error = `The data stream ${props.dataStream} does not exist.`;
  } else {
    error = response.error || "";
  }

  props.coreService.notifications.toasts.addDanger(error);
  throw new Error(error);
};

export const getAllDataStreamTemplate = (props: {
  commonService: CommonService;
}): Promise<
  {
    name: string;
    index_template: TemplateItemRemote;
  }[]
> => {
  return props.commonService
    .apiCaller<{
      index_templates?: {
        name: string;
        index_template: TemplateItemRemote;
      }[];
    }>({
      data: {
        method: "GET",
        path: "/_index_template/*",
      },
      endpoint: "transport.request",
    })
    .then((result) => {
      if (result && result.ok) {
        return (result.response.index_templates || []).filter((item) => item.index_template.data_stream);
      }

      return [];
    });
};