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

const state = {
	friendList: [],
	blackList: [],
	groupList: [],
	recvFriendApplications: [],
	sentFriendApplications: [],
	recvGroupApplications: [],
	sentGroupApplications: [],
	unHandleFriendApplicationNum: 0,
	unHandleGroupApplicationNum: 0,
};

const mutations = {
	SET_FRIEND_LIST(state, list) {
		state.friendList = [...list];
	},
	SET_BLACK_LIST(state, list) {
		state.blackList = [...list];
	},
	SET_GROUP_LIST(state, list) {
		state.groupList = [...list];
	},
	SET_RECV_FRIEND_APPLICATIONS(state, list) {
		state.recvFriendApplications = [...list];
	},
	SET_SENT_FRIEND_APPLICATIONS(state, list) {
		state.sentFriendApplications = [...list];
	},
	SET_RECV_GROUP_APPLICATIONS(state, list) {
		state.recvGroupApplications = [...list];
	},
	SET_SENT_GROUP_APPLICATIONS(state, list) {
		state.sentGroupApplications = [...list];
	},
	SET_UNHANDLE_FRIEND_APPLICATION_NUM(state, num) {
		state.unHandleFriendApplicationNum = num;
	},
	SET_UNHANDLE_GROUP_APPLICATION_NUM(state, num) {
		state.unHandleGroupApplicationNum = num;
	},
};

const actions = {
	async getFriendList({
		commit
	}) {
		let offset = 0;
		let friendInfoList = [];
		let initialFetch = true;
		let retryCount = 0;
		while (true) {
			try {
				const count = initialFetch ? 1000 : 1000;
				const {
					data
				} = await IMSDK.asyncApi("getFriendListPage", uuidv4(), {
					offset,
					count,
				});
				friendInfoList = [
					...friendInfoList,
					...data,
				];
				offset += count;
				retryCount = 0;
				if (data.length < count) break;
				initialFetch = false;
			} catch (error) {
				console.error("getFriendListPage error", error);
				retryCount++;
				if (retryCount >= 10) break;
				// 指数退避：200ms, 400ms, 800ms ...
				const delay = 200 * Math.pow(2, retryCount - 1);
				await new Promise(resolve => setTimeout(resolve, delay));
			}
		}
		commit("SET_FRIEND_LIST", friendInfoList);
	},
	async getGrouplist({
		commit
	}) {
		let offset = 0;
		let groupList = [];
		let retryCount = 0;
		while (true) {
			try {
				const {
					data
				} = await IMSDK.asyncApi(
					"getJoinedGroupListPage",
					uuidv4(), {
						offset,
						count: 1000,
					}
				);
				groupList = [...groupList, ...data];
				offset += 1000;
				retryCount = 0;
				if (data.length < 1000) break;
			} catch (error) {
				console.error("getGrouplist error", error);
				retryCount++;
				if (retryCount >= 10) break;
				// 指数退避：200ms, 400ms, 800ms ...
				const delay = 200 * Math.pow(2, retryCount - 1);
				await new Promise(resolve => setTimeout(resolve, delay));
			}
		}
		commit("SET_GROUP_LIST", groupList);
	},
	getBlacklist({
		commit
	}) {
		IMSDK.asyncApi(IMSDK.IMMethods.GetBlackList, uuidv4()).then(({
			data
		}) => {
			commit("SET_BLACK_LIST", data);
		});
	},
	getRecvFriendApplications({ commit }) {
			let offset = 0;
			let recvFriendApplications = [];
			async function fetchRecvFriendApplications() {
			  try {
				const { data } = await IMSDK.asyncApi(
				  IMSDK.IMMethods.GetFriendApplicationListAsRecipient, 
				  uuidv4(), 
				  {
					  offset,
					  count: 200,
				  }
				);
				recvFriendApplications = [...recvFriendApplications, ...data];
				offset += 200;
				
				if (data.length < 200) {
				  commit("SET_RECV_FRIEND_APPLICATIONS", recvFriendApplications);
				} else {
				  fetchRecvFriendApplications();
				}
				} catch (error) {
				console.error("getRecvFriendApplications error");
				commit("SET_RECV_FRIEND_APPLICATIONS", recvFriendApplications);
				}
			}
	        fetchRecvFriendApplications();
			
	// 		// #ifdef H5 || MP-WEIXIN
	// 		fetchRecvFriendApplications()
	// 		// #endif
	
	// 		// #ifdef APP-PLUS
	// 		IMSDK.asyncApi(
	// 		  IMSDK.IMMethods.GetFriendApplicationListAsRecipient,
	// 		  uuidv4(),
	// 		).then(({ data }) => {
	// 		  commit("SET_RECV_FRIEND_APPLICATIONS", data);
	// 		});
	// 		// #endif
	},
	getSentFriendApplications({ commit }) {
			let offset = 0;
			let sentFriendApplications = [];
			async function fetchSentFriendApplications() {
			  try {
				const { data } = await IMSDK.asyncApi(
				  IMSDK.IMMethods.GetFriendApplicationListAsApplicant, 
				  uuidv4(), 
				  {
					  offset,
					  count: 200,
				  }
				);
				sentFriendApplications = [...sentFriendApplications, ...data];
				offset += 200;
				if (data.length < 200) {
				   commit("SET_SENT_FRIEND_APPLICATIONS", sentFriendApplications);
				} else {
				   fetchSentFriendApplications();
				}
				} catch (error) {
					console.error("getSentFriendApplications error");
					commit("SET_SENT_FRIEND_APPLICATIONS", sentFriendApplications);
				}
			}
	        fetchSentFriendApplications();
	// 		// #ifdef H5 || MP-WEIXIN
	// 		fetchSentFriendApplications()
	// 		// #endif
	
	// 		// #ifdef APP-PLUS
	// 		IMSDK.asyncApi(
	// 		    IMSDK.IMMethods.GetFriendApplicationListAsApplicant,
	// 		    uuidv4(),
	// 		).then(({ data }) => {
	// 		    commit("SET_SENT_FRIEND_APPLICATIONS", data);
	// 		});
	// 		// #endif
	},
	getRecvGroupApplications({ commit }) {
			let offset = 0;
			let recvGroupApplications = [];
	
			async function fetchRecvGroupApplications() {
			  try {
				const { data } = await IMSDK.asyncApi(
				  IMSDK.IMMethods.GetGroupApplicationListAsRecipient, 
				  uuidv4(), 
				  {
				  offset,
				  count: 200,
				  }
				);
				
				recvGroupApplications = [...recvGroupApplications, ...data];
				offset += 200;
				
				if (data.length < 200) {
				  commit("SET_RECV_GROUP_APPLICATIONS", recvGroupApplications);
				} else {
				  fetchRecvGroupApplications();
				}
				} catch (error) {
				console.error("getRecvGroupApplications error");
				commit("SET_RECV_GROUP_APPLICATIONS", recvGroupApplications);
				}
			}
	        
			fetchRecvGroupApplications();
			
	// 		// #ifdef H5 || MP-WEIXIN
	// 		fetchRecvGroupApplications()
	// 		// #endif
	
	// 		// #ifdef APP-PLUS
	// 		IMSDK.asyncApi(
	// 		  IMSDK.IMMethods.GetGroupApplicationListAsRecipient,
	// 		  uuidv4(),
	// 		).then(({ data }) => {
	// 		  commit("SET_RECV_GROUP_APPLICATIONS", data);
	// 		});
	// 		// #endif
	},
	getSentGroupApplications({ commit }) {
			let offset = 0;
			let sentGroupApplications = [];
			async function fetchSentGroupApplications() {
			  try {
				const { data } = await IMSDK.asyncApi(
					  IMSDK.IMMethods.GetGroupApplicationListAsApplicant, 
					  uuidv4(), 
					  {
						  offset,
						  count: 200,
					  }
				);
				
				sentGroupApplications = [...sentGroupApplications, ...data];
				offset += 200;
				
				if (data.length < 200) {
					commit("SET_SENT_GROUP_APPLICATIONS", sentGroupApplications);
				} else {
					fetchSentGroupApplications();
				}
				} catch (error) {
					console.error("getSentGroupApplications error");
					commit("SET_SENT_GROUP_APPLICATIONS", sentGroupApplications);
				}
			};
			fetchSentGroupApplications();
			
	// 		// #ifdef H5 || MP-WEIXIN
	// 		fetchSentGroupApplications()
	// 		// #endif
	
	// 		 // #ifdef APP-PLUS
	// 		IMSDK.asyncApi(
	// 			  IMSDK.IMMethods.GetGroupApplicationListAsApplicant,
	// 			  uuidv4(),
	// 			).then(({ data }) => {
	// 			  commit("SET_SENT_GROUP_APPLICATIONS", data);
	// 		});
	// 		// #endif
	},
	pushNewFriend({
		commit,
		state
	}, friendInfo) {
		const tmpList = [...state.friendList];
		const idx = tmpList.findIndex((item) => item.userID === friendInfo.userID);
		if (idx === -1) {
			commit("SET_FRIEND_LIST", [...tmpList, friendInfo]);
		}
	},
	updateFriendInfo({
		commit,
		state
	}, {
		friendInfo,
		isRemove = false
	}) {
		const tmpList = [...state.friendList];
		const idx = tmpList.findIndex((item) => item.userID === friendInfo.userID);

		if (idx !== -1) {
			if (isRemove) {
				tmpList.splice(idx, 1);
			} else {
				tmpList[idx] = {
					...friendInfo,
				};
			}
			commit("SET_FRIEND_LIST", tmpList);
		}
	},
	pushNewBlack({
		commit,
		state
	}, blackInfo) {
		const tmpList = [...state.blackList];
		const idx = tmpList.findIndex((item) => item.userID === blackInfo.userID);
		if (idx === -1) {
			commit("SET_BLACK_LIST", [...tmpList, blackInfo]);
		}
	},
	updateBlackInfo({
		commit,
		state
	}, {
		blackInfo,
		isRemove = false
	}) {
		const tmpList = [...state.blackList];
		const idx = tmpList.findIndex((item) => item.userID === blackInfo.userID);

		if (idx !== -1) {
			if (isRemove) {
				tmpList.splice(idx, 1);
			} else {
				tmpList[idx] = {
					...blackInfo,
				};
			}
			commit("SET_BLACK_LIST", tmpList);
		}
	},
	pushNewGroup({
		commit,
		state
	}, groupInfo) {
		const tmpList = [...state.groupList];
		const idx = tmpList.findIndex((item) => item.groupID === groupInfo.groupID);
		if (idx === -1) {
			commit("SET_GROUP_LIST", [...tmpList, groupInfo]);
		}
	},
	updateGroupInfo({
		commit,
		state,
		rootState
	}, {
		groupInfo,
		isRemove = false
	}, ) {
		const tmpList = [...state.groupList];
		const idx = tmpList.findIndex((item) => item.groupID === groupInfo.groupID);

		if (rootState.conversation.currentGroup.groupID === groupInfo.groupID) {
			commit("conversation/SET_CURRENT_GROUP", groupInfo, {
				root: true
			});
		}

		if (idx !== -1) {
			if (isRemove) {
				tmpList.splice(idx, 1);
			} else {
				tmpList[idx] = {
					...groupInfo,
				};
			}
			commit("SET_GROUP_LIST", tmpList);
		}
	},
	pushNewRecvFriendApplition({
		commit,
		state
	}, application) {
		const tmpList = [...state.recvFriendApplications];
		const idx = tmpList.findIndex(
			(item) => item.fromUserID === application.fromUserID,
		);
		if (idx !== -1) {
			tmpList.splice(idx, 1);
		}
		commit("SET_RECV_FRIEND_APPLICATIONS", [...tmpList, application]);
	},
	updateRecvFriendApplition({
		commit,
		state,
		rootState
	}, {
		application,
		isRemove = false
	}, ) {
		const tmpList = [...state.recvFriendApplications];
		const idx = tmpList.findIndex(
			(item) => item.fromUserID === application.fromUserID,
		);

		if (idx !== -1) {
			if (isRemove) {
				tmpList.splice(idx, 1);
			} else {
				tmpList[idx] = {
					...application,
				};
			}
			commit("SET_RECV_FRIEND_APPLICATIONS", tmpList);
		}
	},
	pushNewSentFriendApplition({
		commit,
		state
	}, application) {
		const tmpList = [...state.sentFriendApplications];
		const idx = tmpList.findIndex(
			(item) => item.toUserID === application.toUserID,
		);
		if (idx !== -1) {
			tmpList.splice(idx, 1);
		}
		commit("SET_SENT_FRIEND_APPLICATIONS", [...tmpList, application]);
	},
	updateSentFriendApplition({
		commit,
		state,
		rootState
	}, {
		application,
		isRemove = false
	}, ) {
		const tmpList = [...state.sentFriendApplications];
		const idx = tmpList.findIndex(
			(item) => item.toUserID === application.toUserID,
		);

		if (idx !== -1) {
			if (isRemove) {
				tmpList.splice(idx, 1);
			} else {
				tmpList[idx] = {
					...application,
				};
			}
			commit("SET_SENT_FRIEND_APPLICATIONS", tmpList);
		}
	},
	pushNewRecvGroupApplition({
		commit,
		state
	}, application) {
		const tmpList = [...state.recvGroupApplications];
		const idx = tmpList.findIndex((item) => item.userID === application.userID);
		if (idx !== -1) {
			tmpList.splice(idx, 1);
		}
		commit("SET_RECV_GROUP_APPLICATIONS", [...tmpList, application]);
	},
	updateRecvGroupApplition({
		commit,
		state,
		rootState
	}, {
		application,
		isRemove = false
	}, ) {
		const tmpList = [...state.recvGroupApplications];
		const idx = tmpList.findIndex((item) => item.userID === application.userID);

		if (idx !== -1) {
			if (isRemove) {
				tmpList.splice(idx, 1);
			} else {
				tmpList[idx] = {
					...application,
				};
			}
			commit("SET_RECV_GROUP_APPLICATIONS", tmpList);
		}
	},
	pushNewSentGroupApplition({
		commit,
		state
	}, application) {
		const tmpList = [...state.sentGroupApplications];
		const idx = tmpList.findIndex(
			(item) => item.groupID === application.groupID,
		);
		if (idx !== -1) {
			tmpList.splice(idx, 1);
		}
		commit("SET_SENT_GROUP_APPLICATIONS", [...tmpList, application]);
	},
	updateSentGroupApplition({
		commit,
		state,
		rootState
	}, {
		application,
		isRemove = false
	}, ) {
		const tmpList = [...state.sentGroupApplications];
		const idx = tmpList.findIndex(
			(item) => item.groupID === application.groupID,
		);

		if (idx !== -1) {
			if (isRemove) {
				tmpList.splice(idx, 1);
			} else {
				tmpList[idx] = {
					...application,
				};
			}
			commit("SET_SENT_GROUP_APPLICATIONS", tmpList);
		}
	},
};

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