mirror of
https://github.com/xfgryujk/blivechat.git
synced 2026-08-19 09:43:28 +08:00
351 lines
10 KiB
JavaScript
351 lines
10 KiB
JavaScript
import { apiClient as axios, getBaseUrl } from '@/api/base'
|
||
import * as chat from '.'
|
||
import * as chatModels from './models'
|
||
import * as base from './ChatClientOfficialBase'
|
||
import ChatClientOfficialBase from './ChatClientOfficialBase'
|
||
|
||
const GAME_HEARTBEAT_INTERVAL = 20 * 1000
|
||
|
||
export default class ChatClientDirectOpenLive extends ChatClientOfficialBase {
|
||
constructor(roomOwnerAuthCode) {
|
||
super()
|
||
this.CMD_CALLBACK_MAP = CMD_CALLBACK_MAP
|
||
|
||
this.roomOwnerAuthCode = roomOwnerAuthCode
|
||
|
||
this.boundEndGameBeforeUnload = this.endGameBeforeUnload.bind(this)
|
||
|
||
// 调用initRoom后初始化
|
||
this.roomOwnerOpenId = null
|
||
this.hostServerUrlList = []
|
||
this.authBody = null
|
||
this.gameId = null
|
||
|
||
this.gameHeartbeatTimerId = null
|
||
}
|
||
|
||
start() {
|
||
super.start()
|
||
|
||
window.addEventListener('beforeunload', this.boundEndGameBeforeUnload)
|
||
}
|
||
|
||
stop() {
|
||
window.removeEventListener('beforeunload', this.boundEndGameBeforeUnload)
|
||
|
||
this.endGame()
|
||
|
||
super.stop()
|
||
}
|
||
|
||
async initRoom() {
|
||
return this.startGame()
|
||
}
|
||
|
||
async startGame() {
|
||
let res
|
||
try {
|
||
res = (await axios.post('/api/open_live/start_game', {
|
||
code: this.roomOwnerAuthCode,
|
||
app_id: 0
|
||
})).data
|
||
if (res.code !== 0) {
|
||
let msg = `code=${res.code}, message=${res.message}, request_id=${res.request_id}`
|
||
if (res.code === 7007) {
|
||
// 身份码错误
|
||
throw new chatModels.ChatClientFatalError(chatModels.FATAL_ERROR_TYPE_AUTH_CODE_ERROR, msg)
|
||
} else if (res.code === 7010) {
|
||
// 同一个房间连接数超过上限
|
||
throw new chatModels.ChatClientFatalError(chatModels.FATAL_ERROR_TYPE_TOO_MANY_CONNECTIONS, msg)
|
||
}
|
||
throw new Error(msg)
|
||
}
|
||
} catch (e) {
|
||
console.error('startGame failed:', e)
|
||
this.addDebugMsg(`Failed to start Open Live session: ${e}`)
|
||
|
||
if (e instanceof chatModels.ChatClientFatalError) {
|
||
throw e
|
||
}
|
||
return false
|
||
}
|
||
|
||
let data = res.data
|
||
this.gameId = data.game_info.game_id
|
||
let websocketInfo = data.websocket_info
|
||
this.authBody = websocketInfo.auth_body
|
||
this.hostServerUrlList = websocketInfo.wss_link
|
||
let anchorInfo = data.anchor_info
|
||
// this.roomId = anchorInfo.room_id
|
||
this.roomOwnerOpenId = anchorInfo.open_id
|
||
return true
|
||
}
|
||
|
||
async endGame() {
|
||
this.addDebugMsg('Ending Open Live session')
|
||
|
||
this.needInitRoom = true
|
||
if (!this.gameId) {
|
||
return true
|
||
}
|
||
let gameId = this.gameId
|
||
// 直接丢弃将要关闭的gameId
|
||
this.gameId = null
|
||
|
||
try {
|
||
let res = (await axios.post('/api/open_live/end_game', {
|
||
app_id: 0,
|
||
game_id: gameId
|
||
})).data
|
||
// 项目已经关闭了也算成功
|
||
if ([0, 7000, 7003].indexOf(res.code) === -1) {
|
||
throw new Error(`code=${res.code}, message=${res.message}, request_id=${res.request_id}`)
|
||
}
|
||
} catch (e) {
|
||
console.error('endGame failed:', e)
|
||
this.addDebugMsg(`Failed to end Open Live session: ${e}`)
|
||
return false
|
||
}
|
||
return true
|
||
}
|
||
|
||
endGameBeforeUnload() {
|
||
let baseUrl = getBaseUrl()
|
||
if (baseUrl === null) {
|
||
return
|
||
}
|
||
|
||
this.needInitRoom = true
|
||
if (!this.gameId) {
|
||
return
|
||
}
|
||
let gameId = this.gameId
|
||
// 直接丢弃将要关闭的gameId
|
||
this.gameId = null
|
||
|
||
let url = `${baseUrl}/api/open_live/end_game`
|
||
let body = {
|
||
app_id: 0,
|
||
game_id: gameId
|
||
}
|
||
body = new Blob([JSON.stringify(body)], { type: 'application/json' })
|
||
window.navigator.sendBeacon(url, body)
|
||
}
|
||
|
||
onSendGameHeartbeat() {
|
||
// 加上随机延迟，减少同时请求的概率
|
||
let sleepTime = GAME_HEARTBEAT_INTERVAL - (2 * 1000) + (Math.random() * 3 * 1000)
|
||
this.gameHeartbeatTimerId = window.setTimeout(this.onSendGameHeartbeat.bind(this), sleepTime)
|
||
this.sendGameHeartbeat()
|
||
}
|
||
|
||
async sendGameHeartbeat() {
|
||
if (!this.gameId) {
|
||
return false
|
||
}
|
||
|
||
// 保存一下，防止await之后gameId改变
|
||
let gameId = this.gameId
|
||
try {
|
||
let res = (await axios.post(
|
||
'/api/open_live/game_heartbeat',
|
||
{ game_id: gameId },
|
||
// 服务器有心跳合批，超时时间应该长一点
|
||
{ timeout: 15 * 1000 }
|
||
)).data
|
||
if (res.code !== 0) {
|
||
if (res.code === 7003 && this.gameId === gameId) {
|
||
// 项目异常关闭，可能是心跳超时，需要重新开启项目
|
||
this.gameId = null
|
||
this.needInitRoom = true
|
||
this.discardWebsocket()
|
||
}
|
||
throw new Error(`code=${res.code}, message=${res.message}, request_id=${res.request_id}`)
|
||
}
|
||
} catch (e) {
|
||
console.error('sendGameHeartbeat failed:', e)
|
||
this.addDebugMsg(`Failed to send Open Live heartbeat: ${e}`)
|
||
return false
|
||
}
|
||
return true
|
||
}
|
||
|
||
async onBeforeWsConnect() {
|
||
// 重连次数太多则重新initRoom，保险
|
||
let reinitPeriod = Math.max(3, (this.hostServerUrlList || []).length)
|
||
if (this.retryCount > 0 && this.retryCount % reinitPeriod === 0) {
|
||
await this.endGame()
|
||
}
|
||
|
||
return super.onBeforeWsConnect()
|
||
}
|
||
|
||
getWsUrl() {
|
||
return this.hostServerUrlList[this.retryCount % this.hostServerUrlList.length]
|
||
}
|
||
|
||
onWsOpen() {
|
||
super.onWsOpen()
|
||
|
||
if (this.gameId && this.gameHeartbeatTimerId === null) {
|
||
this.gameHeartbeatTimerId = window.setTimeout(this.onSendGameHeartbeat.bind(this), GAME_HEARTBEAT_INTERVAL)
|
||
}
|
||
}
|
||
|
||
sendAuth() {
|
||
this.websocket.send(this.makePacket(this.authBody, base.OP_AUTH))
|
||
}
|
||
|
||
onWsClose() {
|
||
if (this.gameHeartbeatTimerId) {
|
||
window.clearTimeout(this.gameHeartbeatTimerId)
|
||
this.gameHeartbeatTimerId = null
|
||
}
|
||
|
||
super.onWsClose()
|
||
}
|
||
|
||
delayReconnect() {
|
||
if (document.visibilityState !== 'visible') {
|
||
// 不知道什么时候才能重连，先endGame吧
|
||
this.endGame()
|
||
}
|
||
|
||
super.delayReconnect()
|
||
}
|
||
|
||
interactionEndCallback(command) {
|
||
if (command.data.game_id !== this.gameId) {
|
||
return
|
||
}
|
||
// 服务器主动停止推送，可能是心跳超时，需要重新开启项目
|
||
console.error(`Open Live session end by server, gameId=${this.gameId}`)
|
||
this.addDebugMsg('Open Live session end by server')
|
||
|
||
this.gameId = null
|
||
this.needInitRoom = true
|
||
this.discardWebsocket()
|
||
}
|
||
|
||
dmCallback(command) {
|
||
let data = command.data
|
||
|
||
let authorType
|
||
if (data.open_id === this.roomOwnerOpenId) {
|
||
authorType = 3
|
||
} else if (data.is_admin) {
|
||
authorType = 2
|
||
} else if (data.guard_level !== 0) {
|
||
authorType = 1
|
||
} else {
|
||
authorType = 0
|
||
}
|
||
|
||
let showContent = data.msg
|
||
if (data.reply_uname !== '') {
|
||
showContent = `@${data.reply_uname} ${showContent}`
|
||
}
|
||
|
||
let emoticon = null
|
||
if (data.dm_type === 1) {
|
||
emoticon = data.emoji_img_url
|
||
}
|
||
|
||
data = new chatModels.AddTextMsg({
|
||
avatarUrl: chat.processAvatarUrl(data.uface),
|
||
timestamp: data.timestamp,
|
||
authorName: data.uname,
|
||
authorType: authorType,
|
||
content: showContent,
|
||
privilegeType: data.guard_level,
|
||
isGiftDanmaku: chat.isGiftDanmakuByContent(data.msg),
|
||
medalLevel: data.fans_medal_wearing_status ? data.fans_medal_level : 0,
|
||
id: data.msg_id,
|
||
emoticon: emoticon,
|
||
// 给模板用的字段
|
||
uid: data.open_id,
|
||
medalName: data.fans_medal_wearing_status ? data.fans_medal_name : '',
|
||
})
|
||
this.msgHandler.onAddText(data)
|
||
}
|
||
|
||
sendGiftCallback(command) {
|
||
let data = command.data
|
||
let totalCoin = data.r_price * data.gift_num
|
||
data = new chatModels.AddGiftMsg({
|
||
id: data.msg_id,
|
||
avatarUrl: chat.processAvatarUrl(data.uface),
|
||
timestamp: data.timestamp,
|
||
authorName: data.uname,
|
||
totalCoin: data.paid ? totalCoin : 0,
|
||
totalFreeCoin: !data.paid ? totalCoin : 0,
|
||
giftName: data.gift_name,
|
||
num: data.gift_num,
|
||
// 给模板用的字段
|
||
giftId: data.gift_id,
|
||
giftIconUrl: data.gift_icon,
|
||
uid: data.open_id,
|
||
privilegeType: data.guard_level,
|
||
medalLevel: data.fans_medal_wearing_status ? data.fans_medal_level : 0,
|
||
medalName: data.fans_medal_wearing_status ? data.fans_medal_name : '',
|
||
})
|
||
this.msgHandler.onAddGift(data)
|
||
}
|
||
|
||
guardCallback(command) {
|
||
let data = command.data
|
||
data = new chatModels.AddMemberMsg({
|
||
id: data.msg_id,
|
||
avatarUrl: chat.processAvatarUrl(data.user_info.uface),
|
||
timestamp: data.timestamp,
|
||
authorName: data.user_info.uname,
|
||
privilegeType: data.guard_level,
|
||
// 给模板用的字段
|
||
num: data.guard_num,
|
||
unit: data.guard_unit,
|
||
total_coin: data.price * data.guard_num,
|
||
uid: data.user_info.open_id,
|
||
medalLevel: data.fans_medal_wearing_status ? data.fans_medal_level : 0,
|
||
medalName: data.fans_medal_wearing_status ? data.fans_medal_name : '',
|
||
})
|
||
this.msgHandler.onAddMember(data)
|
||
}
|
||
|
||
superChatCallback(command) {
|
||
let data = command.data
|
||
data = new chatModels.AddSuperChatMsg({
|
||
id: data.message_id.toString(),
|
||
avatarUrl: chat.processAvatarUrl(data.uface),
|
||
timestamp: data.start_time,
|
||
authorName: data.uname,
|
||
price: data.rmb,
|
||
content: data.message,
|
||
// 给模板用的字段
|
||
uid: data.open_id,
|
||
privilegeType: data.guard_level,
|
||
medalLevel: data.fans_medal_wearing_status ? data.fans_medal_level : 0,
|
||
medalName: data.fans_medal_wearing_status ? data.fans_medal_name : '',
|
||
})
|
||
this.msgHandler.onAddSuperChat(data)
|
||
}
|
||
|
||
superChatDelCallback(command) {
|
||
let ids = []
|
||
for (let id of command.data.message_ids) {
|
||
ids.push(id.toString())
|
||
}
|
||
let data = new chatModels.DelSuperChatMsg({ ids })
|
||
this.msgHandler.onDelSuperChat(data)
|
||
}
|
||
}
|
||
|
||
const CMD_CALLBACK_MAP = {
|
||
LIVE_OPEN_PLATFORM_INTERACTION_END: ChatClientDirectOpenLive.prototype.interactionEndCallback,
|
||
LIVE_OPEN_PLATFORM_DM: ChatClientDirectOpenLive.prototype.dmCallback,
|
||
LIVE_OPEN_PLATFORM_DM_MIRROR: ChatClientDirectOpenLive.prototype.dmCallback,
|
||
LIVE_OPEN_PLATFORM_SEND_GIFT: ChatClientDirectOpenLive.prototype.sendGiftCallback,
|
||
LIVE_OPEN_PLATFORM_GUARD: ChatClientDirectOpenLive.prototype.guardCallback,
|
||
LIVE_OPEN_PLATFORM_SUPER_CHAT: ChatClientDirectOpenLive.prototype.superChatCallback,
|
||
LIVE_OPEN_PLATFORM_SUPER_CHAT_DEL: ChatClientDirectOpenLive.prototype.superChatDelCallback
|
||
}
|