cunkebao_v3/Touchkebao/src/store/module/weChat/message.ts

import { create } from "zustand";
import { persist } from "zustand/middleware";
import { Message, MessageState } from "./message.data";

/**
 * 会话列表状态管理Store
 * 职责：只管理状态，不存储会话列表数据
 * 数据存储在：组件state + IndexedDB
 */
export const useMessageStore = create<MessageState>()(
  persist(
    (set, get) => ({
      // ==================== 新增状态管理 ====================
      loading: false,
      refreshing: false,
      refreshTrigger: 0,
      lastRefreshTime: null,

      setLoading: (loading: boolean) => set({ loading }),
      setRefreshing: (refreshing: boolean) => set({ refreshing }),
      triggerRefresh: () =>
        set({
          refreshTrigger: get().refreshTrigger + 1,
          lastRefreshTime: new Date().toISOString(),
        }),

      // ==================== 保留原有接口（向后兼容） ====================
      messageList: [],
      currentMessage: null,
      updateMessageList: (messageList: Message[]) => set({ messageList }),
      updateCurrentMessage: (message: Message) =>
        set({ currentMessage: message }),
      updateMessageStatus: (messageId: number, status: string) =>
        set({
          messageList: get().messageList.map(message =>
            message.id === messageId ? { ...message, status } : message,
          ),
        }),
    }),
    {
      name: "message-storage",
      partialize: state => ({
        // 只持久化必要的状态，不持久化数据
        lastRefreshTime: state.lastRefreshTime,
        // 保留原有持久化字段（向后兼容）
        messageList: [],
        currentMessage: null,
      }),
    },
  ),
);
/**
 * 更新当前选中的消息
 * @param message 消息
 * @returns void
 */
export const updateCurrentMessage = (message: Message) =>
  useMessageStore.getState().updateCurrentMessage(message);
/**
 * 更新消息列表
 * @param messageList 消息列表
 * @returns void
 */
export const updateMessageList = (messageList: Message[]) =>
  useMessageStore.getState().updateMessageList(messageList);
/**
 * 获取当前选中的消息
 * @returns Message | null
 */
export const getCurrentMessage = () =>
  useMessageStore.getState().currentMessage;

/**
 * 更新消息状态
 * @param messageId 消息ID
 * @param status 状态
 * @returns void
 */
export const updateMessageStatus = (messageId: number, status: string) =>
  useMessageStore.getState().updateMessageStatus(messageId, status);

// ==================== 新增导出函数 ====================

/**
 * 设置加载状态
 * @param loading 加载状态
 */
export const setLoading = (loading: boolean) =>
  useMessageStore.getState().setLoading(loading);

/**
 * 设置同步状态
 * @param refreshing 同步状态
 */
export const setRefreshing = (refreshing: boolean) =>
  useMessageStore.getState().setRefreshing(refreshing);

/**
 * 触发刷新（通知组件重新查询数据库）
 */
export const triggerRefresh = () => useMessageStore.getState().triggerRefresh();