import { v4 as uuidv4 } from "uuid";
import IMSDK from "openim-uniapp-polyfill";

const state = {
  conversationList: [],
  currentConversation: {},
  unReadCount: 0,
  currentGroup: {},
  currentMemberInGroup: {},
  revokeMap: {}
};

const mutations = {
  SET_CONVERSATION_LIST(state, list) {
    state.conversationList = [...list];
  },
  SET_CURRENT_CONVERSATION(state, conversation) {
    state.currentConversation = {
      ...conversation,
    };
  },
  SET_UNREAD_COUNT(state, count) {
    if (count>0) {
      // uni.setTabBarBadge({
      //   index: 3,
      //   text: count < 99 ? count + "" : "99+",
      // });
	   uni.showTabBarRedDot({
	  	  index: 1,
	   });
    } else {
		uni.hideTabBarRedDot({
			index: 1,
		});
      // uni.removeTabBarBadge({
      //   index: 0,
      // });
    }
    state.unReadCount = count;
  },
  SET_CURRENT_GROUP(state, group) {
    state.currentGroup = {
      ...group,
    };
  },
  SET_CURRENT_MEMBER_IN_GROUP(state, member) {
    state.currentMemberInGroup = {
      ...member,
    };
  },
  SET_REVOKE_MAP(state, message) {
    state.revokeMap = {
      ...state,
      [message.clientMsgID]: {
        text: getMessageText(message),
        quoteMessage: message.quoteElem?.quoteMessage,
      }
    };
  },
};

const actions = {
  async getConversationList({ state, commit }, isFirstPage = true) {
    try {
      const { data } = await IMSDK.asyncApi(
        IMSDK.IMMethods.GetConversationListSplit,
        uuidv4(),
        {
          offset: isFirstPage ? 0 : state.conversationList.length,
          count: 50,
        },
      );
      commit("SET_CONVERSATION_LIST", [
        ...(isFirstPage ? [] : state.conversationList),
        ...data,
      ]);
      return [...data];
    } catch (e) {
      console.log(e);
	  
      commit("SET_CONVERSATION_LIST", []);
      return [];
    }
  },
  delConversationByCID({ state, commit }, conversationID) {
    const tmpList = [...state.conversationList];
    const idx = tmpList.findIndex(
      (conversation) => conversation.conversationID === conversationID,
    );
    if (idx > -1) {
      tmpList.splice(idx, 1);
      commit("SET_CONVERSATION_LIST", tmpList);
    }
  },
  getCurrentGroup({ commit }, groupID) {
    IMSDK.asyncApi(IMSDK.IMMethods.GetSpecifiedGroupsInfo, uuidv4(), [
      groupID,
    ]).then(({ data }) => {
       commit("SET_CURRENT_GROUP", data[0] ?? {});
    });
  },
  getCurrentMemberInGroup({ commit, rootState }, groupID) {
    IMSDK.asyncApi(IMSDK.IMMethods.GetSpecifiedGroupMembersInfo, uuidv4(), {
      groupID,
      userIDList: [rootState.user.selfInfo.userID],
    }).then(({ data }) => {
      commit("SET_CURRENT_MEMBER_IN_GROUP", data[0] ?? {});
    });
  },
  getUnReadCount({ commit }) {
    IMSDK.asyncApi(IMSDK.IMMethods.GetTotalUnreadMsgCount, uuidv4()).then((res) => {
        console.log(res);
        commit("SET_UNREAD_COUNT", res.data);
      },
    );
  },
  updateCurrentMemberInGroup({ commit, state }, memberInfo) {
    if (memberInfo.groupID === state.currentMemberInGroup.groupID && memberInfo.userID === state.currentMemberInGroup.userID) {
        commit("SET_CURRENT_MEMBER_IN_GROUP", memberInfo);
    }
  },
  resetConversationState({ commit }) {
    commit("SET_CURRENT_MEMBER_IN_GROUP", {});
    commit("SET_CURRENT_GROUP", {});
    commit("SET_CURRENT_CONVERSATION", {});
  },
  addRevokedMessage({ commit }, payload) {
    commit("SET_REVOKE_MAP", payload);
  }
  
};

const getMessageText = (message) => {
  if (message.atTextElem) {
    return message.atTextElem.text;
  }
  if (message.quoteElem) {
    return message.quoteElem.text;
  }
  return message.textElem.content;
};

export default {
  namespaced: true,
  state,
  mutations,
  actions,
};