// 接受參數(shù)
export interface SSEChatParams {
    url: string,// sse 連接
    onmessage: (event: MessageEvent) => void,// 處理消息的函數(shù)
    onopen: () => void,// 建立連接觸發(fā)的事件
    finallyHandler: () => void,// 相當(dāng)于 try_finally 中的 finally 部分，不管出現(xiàn)異?；蛘哧P(guān)閉必然會(huì)執(zhí)行的代碼塊
}


class SSEService {
    private eventSource: EventSource | null = null;

    private finallyHandler: (() => void) | undefined;

    // 建立連接
    connect(sseChatParams: SSEChatParams) {

        this.finallyHandler = sseChatParams.finallyHandler;

        this.eventSource = new EventSource(sseChatParams.url);

        if (sseChatParams.onopen != null) {
            this.eventSource.onopen = sseChatParams.onopen;
        }else{
            this.eventSource.onopen = () => {
                console.log('SSE 連接已開啟');
            };
        }

        if (sseChatParams.onmessage != null) {
            this.eventSource.onmessage = sseChatParams.onmessage;
        } else {
            this.eventSource.onmessage = (event) => {
                console.log('收到消息：', event.data);
            };
        }

        this.eventSource.onerror = (error) => {
            if (this.eventSource?.readyState === EventSource.CLOSED) {
                console.log("SSE 連接已關(guān)閉");
            } else {
                console.error("SSE 錯(cuò)誤：", error);
            }
            sseChatParams.finallyHandler();
        };
    }

    // 關(guān)閉連接
    disconnect() {
        if (this.eventSource) {
            this.eventSource.close();
            console.log("關(guān)閉 sse 連接")
            if (this.finallyHandler != null) {
                this.finallyHandler();
            }
        }
    }
}

export const sseService = new SSEService();

const onopen = () => {
  console.log("建立無敵 sse 連接成功")
}
// 建立連接
let sseChatParams: SSEChatParams = {
  onopen,
  url: import.meta.env.VITE_GLOB_API_URL + 'sse/createConnect?clientId=' + userStore.getSseClientId(),
  onmessage: (event: MessageEvent) => {
    // 收到消息
    console.log('收到消息xsssx：', event.data);
    let chunk = event.data;
    if (chunk === '[DONE]') {
      sseService.disconnect()
      state.imageList = []
      chatGuide(chatStore.activeChatId).then(resp => {
        chatGuideList.value = resp.data.guideList
        scrollViewBottom()
      })
      return
    }
    chunk = JSON.parse(chunk)
    if (chunk.type === 'error') {
      errorText = chunk.content
      console.log("errorText", errorText);
      updateChatData(errorText)
      return;
    }
    chunk = chunk.content;
    if (!chunk) {
      return;
    }
    lastText = lastText + chunk
    // 更新聊天數(shù)據(jù)源中的對(duì)話
    updateChatData(lastText)
  },
  finallyHandler: () => {
    console.log("finallyHandler操作")
    sessionStatus.value = 0
    inputDisabled.value = false
    dataSources.value[dataSources.value.length - 1].loading = false
    loading.value = false
    if (!isMobile.value) {
      // 聚焦輸入框
      inputRef.value?.focus()
    }
  }
};
sseService.connect(sseChatParams)

// 當(dāng)組件從 DOM 中卸載前執(zhí)行的操作
onUnmounted(() => {
    sseService.disconnect()
})