"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.ConversationView = ConversationView;
var _react = _interopRequireWildcard(require("react"));
var _eui = require("@elastic/eui");
var _css = require("@emotion/css");
var _i18n = require("@kbn/i18n");
var _uiTheme = require("@kbn/ui-theme");
var _chat_body = require("../../components/chat/chat_body");
var _conversation_list = require("../../components/chat/conversation_list");
var _observability_ai_assistant_chat_service_provider = require("../../context/observability_ai_assistant_chat_service_provider");
var _use_abortable_async = require("../../hooks/use_abortable_async");
var _use_confirm_modal = require("../../hooks/use_confirm_modal");
var _use_conversation = require("../../hooks/use_conversation");
var _use_current_user = require("../../hooks/use_current_user");
var _use_genai_connectors = require("../../hooks/use_genai_connectors");
var _use_kibana = require("../../hooks/use_kibana");
var _use_knowledge_base = require("../../hooks/use_knowledge_base");
var _use_observability_ai_assistant = require("../../hooks/use_observability_ai_assistant");
var _use_observability_ai_assistant_params = require("../../hooks/use_observability_ai_assistant_params");
var _use_observability_ai_assistant_router = require("../../hooks/use_observability_ai_assistant_router");
var _get_connectors_management_href = require("../../utils/get_connectors_management_href");
var _get_models_management_href = require("../../utils/get_models_management_href");
var _i18n2 = require("../../i18n");
function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function (nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); }
function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; }
/*
 * 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 containerClassName = (0, _css.css)`
  max-width: 100%;
`;
const chatBodyContainerClassNameWithError = (0, _css.css)`
  align-self: center;
`;
const conversationListContainerName = (0, _css.css)`
  min-width: 250px;
  width: 250px;
  border-right: solid 1px ${_uiTheme.euiThemeVars.euiColorLightShade};
`;
function ConversationView() {
  var _conversations$value2;
  const currentUser = (0, _use_current_user.useCurrentUser)();
  const service = (0, _use_observability_ai_assistant.useObservabilityAIAssistant)();
  const connectors = (0, _use_genai_connectors.useGenAIConnectors)();
  const knowledgeBase = (0, _use_knowledge_base.useKnowledgeBase)();
  const observabilityAIAssistantRouter = (0, _use_observability_ai_assistant_router.useObservabilityAIAssistantRouter)();
  const {
    path
  } = (0, _use_observability_ai_assistant_params.useObservabilityAIAssistantParams)('/conversations/*');
  const {
    services: {
      http,
      notifications
    }
  } = (0, _use_kibana.useKibana)();
  const {
    element: confirmDeleteElement,
    confirm: confirmDeleteFunction
  } = (0, _use_confirm_modal.useConfirmModal)({
    title: _i18n.i18n.translate('xpack.observabilityAiAssistant.confirmDeleteConversationTitle', {
      defaultMessage: 'Delete this conversation?'
    }),
    children: _i18n.i18n.translate('xpack.observabilityAiAssistant.confirmDeleteConversationContent', {
      defaultMessage: 'This action cannot be undone.'
    }),
    confirmButtonText: _i18n.i18n.translate('xpack.observabilityAiAssistant.confirmDeleteButtonText', {
      defaultMessage: 'Delete conversation'
    })
  });
  const [isUpdatingList, setIsUpdatingList] = (0, _react.useState)(false);
  const chatService = (0, _use_abortable_async.useAbortableAsync)(({
    signal
  }) => {
    return service.start({
      signal
    });
  }, [service]);
  const conversationId = 'conversationId' in path ? path.conversationId : undefined;
  const {
    conversation,
    displayedMessages,
    setDisplayedMessages,
    save,
    saveTitle
  } = (0, _use_conversation.useConversation)({
    conversationId,
    chatService: chatService.value,
    connectorId: connectors.selectedConnector
  });
  const conversations = (0, _use_abortable_async.useAbortableAsync)(({
    signal
  }) => {
    return service.callApi('POST /internal/observability_ai_assistant/conversations', {
      signal
    });
  }, [service]);
  const displayedConversations = (0, _react.useMemo)(() => {
    var _conversations$value$, _conversations$value;
    return [...(!conversationId ? [{
      id: '',
      label: _i18n2.EMPTY_CONVERSATION_TITLE
    }] : []), ...((_conversations$value$ = (_conversations$value = conversations.value) === null || _conversations$value === void 0 ? void 0 : _conversations$value.conversations) !== null && _conversations$value$ !== void 0 ? _conversations$value$ : []).map(conv => ({
      id: conv.conversation.id,
      label: conv.conversation.title,
      href: observabilityAIAssistantRouter.link('/conversations/{conversationId}', {
        path: {
          conversationId: conv.conversation.id
        }
      })
    }))];
  }, [(_conversations$value2 = conversations.value) === null || _conversations$value2 === void 0 ? void 0 : _conversations$value2.conversations, conversationId, observabilityAIAssistantRouter]);
  function navigateToConversation(nextConversationId) {
    observabilityAIAssistantRouter.push(nextConversationId ? '/conversations/{conversationId}' : '/conversations/new', {
      path: {
        conversationId: nextConversationId
      },
      query: {}
    });
  }
  function handleRefreshConversations() {
    conversations.refresh();
  }
  return /*#__PURE__*/_react.default.createElement(_react.default.Fragment, null, confirmDeleteElement, /*#__PURE__*/_react.default.createElement(_eui.EuiFlexGroup, {
    direction: "row",
    className: containerClassName,
    gutterSize: "none"
  }, /*#__PURE__*/_react.default.createElement(_eui.EuiFlexItem, {
    grow: false,
    className: conversationListContainerName
  }, /*#__PURE__*/_react.default.createElement(_conversation_list.ConversationList, {
    selected: conversationId !== null && conversationId !== void 0 ? conversationId : '',
    loading: conversations.loading || isUpdatingList,
    error: conversations.error,
    conversations: displayedConversations,
    onClickNewChat: () => {
      observabilityAIAssistantRouter.push('/conversations/new', {
        path: {},
        query: {}
      });
    },
    onClickDeleteConversation: id => {
      confirmDeleteFunction().then(async confirmed => {
        var _conversations$value3;
        if (!confirmed) {
          return;
        }
        setIsUpdatingList(true);
        await service.callApi('DELETE /internal/observability_ai_assistant/conversation/{conversationId}', {
          params: {
            path: {
              conversationId: id
            }
          },
          signal: null
        });
        const isCurrentConversation = id === conversationId;
        const hasOtherConversations = (_conversations$value3 = conversations.value) === null || _conversations$value3 === void 0 ? void 0 : _conversations$value3.conversations.find(conv => 'id' in conv.conversation && conv.conversation.id !== id);
        if (isCurrentConversation) {
          navigateToConversation(hasOtherConversations ? conversations.value.conversations[0].conversation.id : undefined);
        }
        conversations.refresh();
      }).catch(error => {
        notifications.toasts.addError(error, {
          title: _i18n.i18n.translate('xpack.observabilityAiAssistant.failedToDeleteConversation', {
            defaultMessage: 'Could not delete conversation'
          })
        });
      }).finally(() => {
        setIsUpdatingList(false);
      });
    }
  }), /*#__PURE__*/_react.default.createElement(_eui.EuiSpacer, {
    size: "s"
  })), /*#__PURE__*/_react.default.createElement(_eui.EuiFlexItem, {
    grow: true,
    className: conversation.error ? chatBodyContainerClassNameWithError : undefined
  }, conversation.error ? /*#__PURE__*/_react.default.createElement(_eui.EuiCallOut, {
    color: "danger",
    title: _i18n.i18n.translate('xpack.observabilityAiAssistant.couldNotFindConversationTitle', {
      defaultMessage: 'Conversation not found'
    }),
    iconType: "warning"
  }, _i18n.i18n.translate('xpack.observabilityAiAssistant.couldNotFindConversationContent', {
    defaultMessage: 'Could not find a conversation with id {conversationId}. Make sure the conversation exists and you have access to it.',
    values: {
      conversationId
    }
  })) : null, !chatService.value ? /*#__PURE__*/_react.default.createElement(_eui.EuiFlexGroup, {
    direction: "column",
    alignItems: "center",
    gutterSize: "l"
  }, /*#__PURE__*/_react.default.createElement(_eui.EuiFlexItem, {
    grow: false
  }, /*#__PURE__*/_react.default.createElement(_eui.EuiSpacer, {
    size: "xl"
  }), /*#__PURE__*/_react.default.createElement(_eui.EuiLoadingSpinner, {
    size: "l"
  }))) : null, conversation.value && chatService.value && !conversation.error ? /*#__PURE__*/_react.default.createElement(_observability_ai_assistant_chat_service_provider.ObservabilityAIAssistantChatServiceProvider, {
    value: chatService.value
  }, /*#__PURE__*/_react.default.createElement(_chat_body.ChatBody, {
    loading: conversation.loading,
    currentUser: currentUser,
    connectors: connectors,
    connectorsManagementHref: (0, _get_connectors_management_href.getConnectorsManagementHref)(http),
    modelsManagementHref: (0, _get_models_management_href.getModelsManagementHref)(http),
    conversationId: conversationId,
    knowledgeBase: knowledgeBase,
    messages: displayedMessages,
    title: conversation.value.conversation.title,
    startedFrom: "conversationView",
    onChatUpdate: messages => {
      setDisplayedMessages(messages);
    },
    onChatComplete: messages => {
      save(messages, handleRefreshConversations).then(nextConversation => {
        var _nextConversation$con;
        conversations.refresh();
        if (!conversationId && nextConversation !== null && nextConversation !== void 0 && (_nextConversation$con = nextConversation.conversation) !== null && _nextConversation$con !== void 0 && _nextConversation$con.id) {
          navigateToConversation(nextConversation.conversation.id);
        }
      }).catch(e => {});
    },
    onSaveTitle: title => {
      saveTitle(title, handleRefreshConversations);
    }
  })) : null)));
}