|
@@ -0,0 +1,346 @@
|
|
|
+import Event from '../utils/event.js'
|
|
|
+import User from '../model/user.js'
|
|
|
+import Stream from '../model/stream.js'
|
|
|
+import { EVENT } from '../common/constants.js'
|
|
|
+
|
|
|
+const TAG_NAME = 'UserController'
|
|
|
+/**
|
|
|
+ * 通讯成员管理
|
|
|
+ */
|
|
|
+class UserController {
|
|
|
+ constructor(componentContext) {
|
|
|
+ // userMap 用于存储完整的数据结构
|
|
|
+ this.userMap = new Map()
|
|
|
+ // userList 用于存储简化的用户数据 Object,包括 {userID hasMainAudio hasMainVideo hasAuxAudio hasAuxVideo}
|
|
|
+ this.userList = []
|
|
|
+ // streamList 存储steam 对象列表,用于 trtc-room 渲染 player
|
|
|
+ this.streamList = []
|
|
|
+ this._emitter = new Event()
|
|
|
+ this.componentContext = componentContext
|
|
|
+ this.isNewVersion = componentContext.isNewVersion
|
|
|
+ }
|
|
|
+ userEventHandler(event) {
|
|
|
+ const code = event.detail.code
|
|
|
+ let data
|
|
|
+ if (event.detail.message && typeof event.detail.message === 'string') {
|
|
|
+ try {
|
|
|
+ data = JSON.parse(event.detail.message)
|
|
|
+ } catch (exception) {
|
|
|
+ console.warn(TAG_NAME, 'userEventHandler 数据格式错误', exception)
|
|
|
+ return false
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ console.warn(TAG_NAME, 'userEventHandler 数据格式错误')
|
|
|
+ return false
|
|
|
+ }
|
|
|
+ switch (code) {
|
|
|
+ case 1020:
|
|
|
+ // console.log(TAG_NAME, '远端用户全量列表更新:', code)
|
|
|
+ if (!this.isNewVersion) {
|
|
|
+ // TODO 旧版SDK处理逻辑,返回全量的用户列表,需要对userList 进行前后对比,筛选出新增用户,暂不实现
|
|
|
+ }
|
|
|
+ break
|
|
|
+ case 1031:
|
|
|
+ // console.log(TAG_NAME, '远端用户进房通知:', code)
|
|
|
+ // 1031 有新用户
|
|
|
+ // {
|
|
|
+ // "userlist":[
|
|
|
+ // {
|
|
|
+ // "userid":"webrtc11"
|
|
|
+ // }
|
|
|
+ // ]
|
|
|
+ // }
|
|
|
+ this.addUser(data)
|
|
|
+ break
|
|
|
+ case 1032:
|
|
|
+ // console.log(TAG_NAME, '远端用户退房通知:', code)
|
|
|
+ // 1032 有用户退出
|
|
|
+ this.removeUser(data)
|
|
|
+ break
|
|
|
+ case 1033:
|
|
|
+ // console.log(TAG_NAME, '远端用户视频状态位变化通知:', code)
|
|
|
+ // 1033 用户视频状态变化,新增stream或者更新stream 状态
|
|
|
+ // {
|
|
|
+ // "userlist":[
|
|
|
+ // {
|
|
|
+ // "userid":"webrtc11",
|
|
|
+ // "playurl":" room://rtc.tencent.com?userid=xxx&streamtype=main",
|
|
|
+ // "streamtype":"main",
|
|
|
+ // "hasvideo":true
|
|
|
+ // }
|
|
|
+ // ]
|
|
|
+ // }
|
|
|
+ this.updateUserVideo(data)
|
|
|
+ break
|
|
|
+ case 1034:
|
|
|
+ // console.log(TAG_NAME, '远端用户音频状态位变化通知:', code)
|
|
|
+ // 1034 用户音频状态变化
|
|
|
+ // {
|
|
|
+ // "userlist":[
|
|
|
+ // {
|
|
|
+ // "userid":"webrtc11",
|
|
|
+ // "playurl":" room://rtc.tencent.com?userid=xxx&streamtype=main",
|
|
|
+ // "hasaudio":false
|
|
|
+ // }
|
|
|
+ // ]
|
|
|
+ // }
|
|
|
+ this.updateUserAudio(data)
|
|
|
+ break
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ * 处理用户进房事件
|
|
|
+ * @param {Object} data pusher 下发的数据
|
|
|
+ */
|
|
|
+ addUser(data) {
|
|
|
+ // console.log(TAG_NAME, 'addUser', data)
|
|
|
+ const incomingUserList = data.userlist
|
|
|
+ const userMap = this.userMap
|
|
|
+ if (Array.isArray(incomingUserList) && incomingUserList.length > 0) {
|
|
|
+ incomingUserList.forEach((item) => {
|
|
|
+ const userID = item.userid
|
|
|
+ // 已经在 map 中的用户
|
|
|
+ let user = this.getUser(userID)
|
|
|
+ if (!user) {
|
|
|
+ // 新增用户
|
|
|
+ user = new User({ userID: userID })
|
|
|
+ this.userList.push({
|
|
|
+ userID: userID,
|
|
|
+ })
|
|
|
+ }
|
|
|
+ userMap.set(userID, user)
|
|
|
+ this._emitter.emit(EVENT.REMOTE_USER_JOIN, { userID: userID, userList: this.userList })
|
|
|
+ // console.log(TAG_NAME, 'addUser', item, userMap.get(userID), this.userMap)
|
|
|
+ })
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ * 处理用户退房事件
|
|
|
+ * @param {Object} data pusher 下发的数据 {userlist}
|
|
|
+ */
|
|
|
+ removeUser(data) {
|
|
|
+ // console.log(TAG_NAME, 'removeUser', data)
|
|
|
+ const incomingUserList = data.userlist
|
|
|
+ if (Array.isArray(incomingUserList) && incomingUserList.length > 0) {
|
|
|
+ incomingUserList.forEach((item) => {
|
|
|
+ const userID = item.userid
|
|
|
+ let user = this.getUser(userID)
|
|
|
+ // 偶现SDK触发退房事件前没有触发进房事件
|
|
|
+ if (!user || !user.streams) {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 从userList 里删除指定的用户和 stream
|
|
|
+ this._removeUserAndStream(userID)
|
|
|
+ // 重置
|
|
|
+ user.streams['main'] && user.streams['main'].reset()
|
|
|
+ user.streams['aux'] && user.streams['aux'].reset()
|
|
|
+ // 用户退出,释放引用,外部调用该 user 所有stream 的 playerContext.stop() 方法停止播放
|
|
|
+ // TODO 触发时机提前了,方便外部用户做出处理,时机仍需进一步验证
|
|
|
+ this._emitter.emit(EVENT.REMOTE_USER_LEAVE, { userID: userID, userList: this.userList, streamList: this.streamList })
|
|
|
+ user = undefined
|
|
|
+ this.userMap.delete(userID)
|
|
|
+ // console.log(TAG_NAME, 'removeUser', this.userMap)
|
|
|
+ })
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ * 处理用户视频通知事件
|
|
|
+ * @param {Object} data pusher 下发的数据 {userlist}
|
|
|
+ */
|
|
|
+ updateUserVideo(data) {
|
|
|
+ console.log(TAG_NAME, 'updateUserVideo', data)
|
|
|
+ const incomingUserList = data.userlist
|
|
|
+ if (Array.isArray(incomingUserList) && incomingUserList.length > 0) {
|
|
|
+ incomingUserList.forEach((item) => {
|
|
|
+ const userID = item.userid
|
|
|
+ const streamType = item.streamtype
|
|
|
+ const streamID = userID + '_' + streamType
|
|
|
+ const hasVideo = item.hasvideo
|
|
|
+ const src = item.playurl
|
|
|
+ const user = this.getUser(userID)
|
|
|
+ // 更新指定用户的属性
|
|
|
+ if (user) {
|
|
|
+ // 查找对应的 stream
|
|
|
+ let stream = user.streams[streamType]
|
|
|
+ console.log(TAG_NAME, 'updateUserVideo start', user, streamType, stream)
|
|
|
+ // 常规逻辑
|
|
|
+ // 新来的stream,新增到 user.steams 和 streamList,streamList 包含所有用户(有音频或视频)的 stream
|
|
|
+ if (!stream) {
|
|
|
+ // 不在 user streams 里,需要新建
|
|
|
+ user.streams[streamType] = stream = new Stream({ userID, streamID, hasVideo, src, streamType })
|
|
|
+ this._addStream(stream)
|
|
|
+ } else {
|
|
|
+ // 更新 stream 属性
|
|
|
+ stream.setProperty({ hasVideo })
|
|
|
+ if (!hasVideo && !stream.hasAudio) {
|
|
|
+ this._removeStream(stream)
|
|
|
+ }
|
|
|
+ // or
|
|
|
+ // if (hasVideo) {
|
|
|
+ // stream.setProperty({ hasVideo })
|
|
|
+ // } else if (!stream.hasAudio) {
|
|
|
+ // // hasVideo == false && hasAudio == false
|
|
|
+ // this._removeStream(stream)
|
|
|
+ // }
|
|
|
+ }
|
|
|
+ // 特殊逻辑
|
|
|
+ if (streamType === 'aux') {
|
|
|
+ if (hasVideo) {
|
|
|
+ // 辅流需要修改填充模式
|
|
|
+ stream.objectFit = 'contain'
|
|
|
+ this._addStream(stream)
|
|
|
+ } else {
|
|
|
+ // 如果是辅流要移除该 stream,否则需要移除 player
|
|
|
+ this._removeStream(stream)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 更新所属user 的 hasXxx 值
|
|
|
+ this.userList.find((item)=>{
|
|
|
+ if (item.userID === userID) {
|
|
|
+ item[`has${streamType.replace(/^\S/, (s) => s.toUpperCase())}Video`] = hasVideo
|
|
|
+ return true
|
|
|
+ }
|
|
|
+ })
|
|
|
+ console.log(TAG_NAME, 'updateUserVideo end', user, streamType, stream)
|
|
|
+ const eventName = hasVideo ? EVENT.REMOTE_VIDEO_ADD : EVENT.REMOTE_VIDEO_REMOVE
|
|
|
+ this._emitter.emit(eventName, { stream: stream, streamList: this.streamList, userList: this.userList })
|
|
|
+ // console.log(TAG_NAME, 'updateUserVideo', user, stream, this.userMap)
|
|
|
+ }
|
|
|
+ })
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ * 处理用户音频通知事件
|
|
|
+ * @param {Object} data pusher 下发的数据 {userlist}
|
|
|
+ */
|
|
|
+ updateUserAudio(data) {
|
|
|
+ // console.log(TAG_NAME, 'updateUserAudio', data)
|
|
|
+ const incomingUserList = data.userlist
|
|
|
+ if (Array.isArray(incomingUserList) && incomingUserList.length > 0) {
|
|
|
+ incomingUserList.forEach((item) => {
|
|
|
+ const userID = item.userid
|
|
|
+ // 音频只跟着 stream main ,这里只修改 main
|
|
|
+ const streamType = 'main'
|
|
|
+ const streamID = userID + '_' + streamType
|
|
|
+ const hasAudio = item.hasaudio
|
|
|
+ const src = item.playurl
|
|
|
+ const user = this.getUser(userID)
|
|
|
+ if (user) {
|
|
|
+ let stream = user.streams[streamType]
|
|
|
+ // if (!stream) {
|
|
|
+ // user.streams[streamType] = stream = new Stream({ streamType: streamType })
|
|
|
+ // this._addStream(stream)
|
|
|
+ // }
|
|
|
+
|
|
|
+ // 常规逻辑
|
|
|
+ // 新来的stream,新增到 user.steams 和 streamList,streamList 包含所有用户的 stream
|
|
|
+ if (!stream) {
|
|
|
+ // 不在 user streams 里,需要新建
|
|
|
+ user.streams[streamType] = stream = new Stream({ userID, streamID, hasAudio, src, streamType })
|
|
|
+ this._addStream(stream)
|
|
|
+ } else {
|
|
|
+ // 更新 stream 属性
|
|
|
+ stream.setProperty({ hasAudio })
|
|
|
+ if (!hasAudio && !stream.hasVideo) {
|
|
|
+ this._removeStream(stream)
|
|
|
+ }
|
|
|
+ // or
|
|
|
+ // if (hasAudio) {
|
|
|
+ // stream.setProperty({ hasAudio })
|
|
|
+ // } else if (!stream.hasVideo) {
|
|
|
+ // // hasVideo == false && hasAudio == false
|
|
|
+ // this._removeStream(stream)
|
|
|
+ // }
|
|
|
+ }
|
|
|
+
|
|
|
+ // stream.userID = userID
|
|
|
+ // stream.streamID = userID + '_' + streamType
|
|
|
+ // stream.hasAudio = hasAudio
|
|
|
+ // stream.src = src
|
|
|
+ // 更新所属 user 的 hasXxx 值
|
|
|
+ this.userList.find((item)=>{
|
|
|
+ if (item.userID === userID) {
|
|
|
+ item[`has${streamType.replace(/^\S/, (s) => s.toUpperCase())}Audio`] = hasAudio
|
|
|
+ return true
|
|
|
+ }
|
|
|
+ })
|
|
|
+ const eventName = hasAudio ? EVENT.REMOTE_AUDIO_ADD : EVENT.REMOTE_AUDIO_REMOVE
|
|
|
+ this._emitter.emit(eventName, { stream: stream, streamList: this.streamList, userList: this.userList })
|
|
|
+ // console.log(TAG_NAME, 'updateUserAudio', user, stream, this.userMap)
|
|
|
+ }
|
|
|
+ })
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ *
|
|
|
+ * @param {String} userID 用户ID
|
|
|
+ * @returns {Object}
|
|
|
+ */
|
|
|
+ getUser(userID) {
|
|
|
+ return this.userMap.get(userID)
|
|
|
+ }
|
|
|
+ getStream({ userID, streamType }) {
|
|
|
+ const user = this.userMap.get(userID)
|
|
|
+ if (user) {
|
|
|
+ return user.streams[streamType]
|
|
|
+ }
|
|
|
+ return undefined
|
|
|
+ }
|
|
|
+ getUserList() {
|
|
|
+ return this.userList
|
|
|
+ }
|
|
|
+ getStreamList() {
|
|
|
+ return this.streamList
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ * 重置所有user 和 steam
|
|
|
+ * @returns {Object}
|
|
|
+ */
|
|
|
+ reset() {
|
|
|
+ this.streamList.forEach((item)=>{
|
|
|
+ item.reset()
|
|
|
+ })
|
|
|
+ this.streamList = []
|
|
|
+ this.userList = []
|
|
|
+ this.userMap.clear()
|
|
|
+ return {
|
|
|
+ userList: this.userList,
|
|
|
+ streamList: this.streamList,
|
|
|
+ }
|
|
|
+ }
|
|
|
+ on(eventCode, handler, context) {
|
|
|
+ this._emitter.on(eventCode, handler, context)
|
|
|
+ }
|
|
|
+ off(eventCode, handler) {
|
|
|
+ this._emitter.off(eventCode, handler)
|
|
|
+ }
|
|
|
+ /**
|
|
|
+ * 删除用户和所有的 stream
|
|
|
+ * @param {String} userID 用户ID
|
|
|
+ */
|
|
|
+ _removeUserAndStream(userID) {
|
|
|
+ this.streamList = this.streamList.filter((item)=>{
|
|
|
+ return item.userID !== userID && item.userID !== ''
|
|
|
+ })
|
|
|
+ this.userList = this.userList.filter((item)=>{
|
|
|
+ return item.userID !== userID
|
|
|
+ })
|
|
|
+ }
|
|
|
+ _addStream(stream) {
|
|
|
+ if (!this.streamList.includes(stream)) {
|
|
|
+ this.streamList.push(stream)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ _removeStream(stream) {
|
|
|
+ this.streamList = this.streamList.filter((item)=>{
|
|
|
+ if (item.userID === stream.userID && item.streamType === stream.streamType) {
|
|
|
+ return false
|
|
|
+ }
|
|
|
+ return true
|
|
|
+ })
|
|
|
+ const user = this.getUser(stream.userID)
|
|
|
+ user.streams[stream.streamType] = undefined
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+export default UserController
|