| | |
| | | import { onMounted, onUnmounted, type Ref } from 'vue'; |
| | | import { reverse } from 'lodash-es'; |
| | | import { type Ref } from 'vue'; |
| | | import type { ChatMessage } from '../model/types'; |
| | | import { RoleEnum } from '../model/types'; |
| | | import { MAIN_URL } from '/@/constants'; |
| | | import { SSEClient } from '/@/utils/sse/SSEClient'; |
| | | import { reverse } from 'lodash-es'; |
| | | import { Local } from '/@/utils/storage'; |
| | | import { accessSessionKey } from '/@/utils/request'; |
| | | |
| | | type UseSyncMsgOptions = { |
| | | updateLoadIndex: (addCount: number) => void; |
| | |
| | | {}, |
| | | { |
| | | onMessage: (data) => { |
| | | console.log("🚀 ~ data:\n", data) |
| | | return; |
| | | const recentIds = reverse([ |
| | | { id: 'a1b2c3d4', time: '2024-03-27 15:42:33' }, |
| | |
| | | // {id: 'k7l8m9n0', time: '2024-10-25 08:19:07'}, |
| | | ]); |
| | | |
| | | |
| | | |
| | | // 获取未同步的消息 |
| | | const unsyncedMessages = findUnsyncedMessages(recentIds, userHistoryIds); |
| | | console.log('未同步的消息:', unsyncedMessages); |
| | |
| | | }, |
| | | } |
| | | ); |
| | | sseClient.connect({}); |
| | | sseClient.connect({ |
| | | websessionid: Local.get(accessSessionKey), |
| | | }); |
| | | |
| | | // onMounted(() => { |
| | | // sseClient.connect({}); |