conversation.js
8.29 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
import tim from 'tim'
import TIM from 'tim-js-sdk'
import _ from 'loadsh'
import store from '..'
import {titleNotify} from '../../utils'
import {filterCallingMessage} from '../../utils/common'
const conversationModules = {
state: {
currentConversation: {},
currentMessageList: [],
nextReqMessageID: '',
isCompleted: false, // 当前会话消息列表是否已经拉完了所有消息
conversationList: [],
callingInfo: {
memberList: [],
type: 'C2C', //C2C,GROUP
},
audioCall: false
},
getters: {
toAccount: state => {
if (!state.currentConversation || !state.currentConversation.conversationID) {
return ''
}
switch (state.currentConversation.type) {
case 'C2C':
return state.currentConversation.conversationID.replace('C2C', '')
case 'GROUP':
return state.currentConversation.conversationID.replace('GROUP', '')
default:
return state.currentConversation.conversationID
}
},
currentConversationType: state => {
if (!state.currentConversation || !state.currentConversation.type) {
return ''
}
return state.currentConversation.type
},
totalUnreadCount: state => {
const result = state.conversationList.reduce((count, conversation) => {
// 当前会话不计算总未读
if (!store.getters.hidden && state.currentConversation.conversationID === conversation.conversationID) {
return count
}
return count + conversation.unreadCount
}, 0)
titleNotify(result)
return result
},
// 用于当前会话的图片预览
imgUrlList: state => {
return state.currentMessageList
.filter(message => (message.type === TIM.TYPES.MSG_IMAGE || (message.type === TIM.TYPES.MSG_CUSTOM && _.get(message, 'payload.data', 'custom') === 'image')) && !message.isRevoked) // 筛选出没有撤回并且类型是图片类型的消息
.map(message => message.payload.imageInfoArray[0].url || message.payload.description)
}
},
mutations: {
/**
* 显示trtcCalling 群通话成员列表
* @param {Object} state
* @param {Conversation} setCallingList
*/
setCallingList(state, value) {
state.callingInfo.memberList = value.memberList
state.callingInfo.type = value.type
},
/**
* 显示trtcCalling 语音通话
* @param {Object} state
* @param {Conversation} showAudioCall
*/
showAudioCall(state, value) {
state.audioCall = value
},
/**
* 更新当前会话
* 调用时机: 切换会话时
* @param {Object} state
* @param {Conversation} conversation
*/
updateCurrentConversation(state, conversation) {
state.currentConversation = conversation
state.currentMessageList = []
state.nextReqMessageID = ''
state.isCompleted = false
},
/**
* 更新会话列表
* 调用时机:触发会话列表更新事件时。CONVERSATION_LIST_UPDATED
* @param {Object} state
* @param {Conversation[]} conversationList
*/
updateConversationList(state, conversationList) {
state.conversationList = conversationList
},
/**
* 重置当前会话
* 调用时机:需要重置当前会话时,例如:当前会话是一个群组,正好被踢出群时(被踢群事件触发),重置当前会话
* @param {Object} state
*/
resetCurrentConversation(state) {
state.currentConversation = {}
},
/**
* 将消息插入当前会话列表
* 调用时机:收/发消息事件触发时
* @param {Object} state
* @param {Message[]|Message} data
* @returns
*/
pushCurrentMessageList(state, data) {
// 还没当前会话,则跳过
if (!state.currentConversation.conversationID) {
return
}
if (Array.isArray(data)) {
// 筛选出当前会话的消息
const result = data.filter(item => item.conversationID === state.currentConversation.conversationID)
state.currentMessageList = [...state.currentMessageList, ...result]
filterCallingMessage(state.currentMessageList)
} else if (data.conversationID === state.currentConversation.conversationID) {
state.currentMessageList = [...state.currentMessageList, data]
filterCallingMessage(state.currentMessageList)
}
},
/**
* 从当前消息列表中删除某条消息
* @param {Object} state
* @param {Message} message
*/
removeMessage(state, message) {
const index = state.currentMessageList.findIndex(({ID}) => ID === message.ID)
if (index >= 0) {
state.currentMessageList.splice(index, 1)
}
},
reset(state) {
Object.assign(state, {
currentConversation: {},
currentMessageList: [],
nextReqMessageID: '',
isCompleted: false, // 当前会话消息列表是否已经拉完了所有消息
conversationList: []
})
}
},
actions: {
/**
* 获取消息列表
* 调用时机:打开某一会话时或下拉获取历史消息时
* @param {Object} context
* @param {String} conversationID
*/
getMessageList(context, conversationID) {
if (context.state.isCompleted) {
context.commit('showMessage', {
message: '已经没有更多的历史消息了哦',
type: 'info'
})
return
}
const {nextReqMessageID, currentMessageList} = context.state
tim.getMessageList({conversationID, nextReqMessageID, count: 15}).then(imReponse => {
// 更新messageID,续拉时要用到
context.state.nextReqMessageID = imReponse.data.nextReqMessageID
context.state.isCompleted = imReponse.data.isCompleted
// 更新当前消息列表,从头部插入
context.state.currentMessageList = [...imReponse.data.messageList, ...currentMessageList]
filterCallingMessage(context.state.currentMessageList)
})
},
/**
* 切换会话
* 调用时机:切换会话时
* @param {Object} context
* @param {String} conversationID
*/
checkoutConversation(context, conversationID) {
context.commit('resetCurrentMemberList')
// 1.切换会话前,将切换前的会话进行已读上报
if (context.state.currentConversation.conversationID) {
const prevConversationID = context.state.currentConversation.conversationID
tim.setMessageRead({conversationID: prevConversationID})
}
// 2.待切换的会话也进行已读上报
tim.setMessageRead({conversationID})
// 3. 获取会话信息
return tim.getConversationProfile(conversationID).then(({data}) => {
// 3.1 更新当前会话
context.commit('updateCurrentConversation', data.conversation)
// 3.2 获取消息列表
context.dispatch('getMessageList', conversationID)
// 3.3 拉取第一页群成员列表
if (data.conversation.type === TIM.TYPES.CONV_GROUP) {
context.dispatch('getGroupUnMemberList', data.conversation.groupProfile.groupID)
return context.dispatch('getGroupMemberList', data.conversation.groupProfile.groupID)
}
return Promise.resolve()
})
}
}
}
export default conversationModules