860 lines
33 KiB
TypeScript
860 lines
33 KiB
TypeScript
/*
|
||
* @FileDescription: 消息处理模块
|
||
* @Author: Stapxs
|
||
* @Date:
|
||
* 2022/11/1
|
||
* 2022/12/7
|
||
* @Version:
|
||
* 1.0 - 初始版本
|
||
* 2.0 - 重构为 ts 版本，修改 Vue3 相关变更
|
||
* @Description: 此模块用于拆分和保存/处理 bot 返回的各类信息，整个运行时数据也保存在这儿。
|
||
*/
|
||
import qed from '@/assets/qed.txt'
|
||
|
||
import { Md5 } from 'ts-md5'
|
||
import app from '@/main'
|
||
import Option from './option'
|
||
import Util from './util'
|
||
|
||
import { reactive, nextTick, markRaw, defineAsyncComponent } from 'vue'
|
||
import { PopInfo, PopType, Logger, LogType } from './base'
|
||
import { Connector, login } from './connect'
|
||
import { GroupMemberInfoElem, UserFriendElem, UserGroupElem, MsgItemElem, RunTimeDataElem, BotMsgType } from './elements/information'
|
||
import { NotificationElem } from './elements/system'
|
||
import xss from 'xss'
|
||
|
||
const popInfo = new PopInfo()
|
||
|
||
export function parse(str: string) {
|
||
const msg = JSON.parse(str)
|
||
if (msg.echo !== undefined) {
|
||
const echoList = msg.echo.split('_')
|
||
const head = echoList[0]
|
||
// 处理追加方法
|
||
// PS：这儿对插件附加方法进行寻找执行，同名将会覆盖已有方法
|
||
if(appendMsg[head]) {
|
||
appendMsg[head](msg)
|
||
} else {
|
||
switch (head) {
|
||
case 'getVersionInfo' : saveBotInfo(msg.data); break
|
||
case 'getLoginInfo' : saveLoginInfo(msg.data); break
|
||
case 'getMoreLoginInfo' : runtimeData.loginInfo.info = msg.data.data.result.buddy.info_list[0]; break
|
||
case 'getGroupList' : saveUser(msg.data); break
|
||
case 'getFriendList' : saveUser(msg.data); break
|
||
case 'getUserInfoInGroup' : runtimeData.chatInfo.info.me_info = msg; break
|
||
case 'getGroupMemberList' : saveGroupMember(msg.data); break
|
||
case 'getChatHistoryFist' : saveMsgFist(msg); break
|
||
case 'getChatHistory' : saveMsg(msg); break
|
||
case 'getForwardMsg' : saveForwardMsg(msg.data); break
|
||
case 'sendMsgBack' : showSendedMsg(msg, echoList); break
|
||
case 'getRoamingStamp' : runtimeData.stickerCache = msg.data.reverse(); break
|
||
case 'getMoreGroupInfo' : runtimeData.chatInfo.info.group_info = msg.data.data; break
|
||
case 'getMoreUserInfo' : runtimeData.chatInfo.info.user_info = msg.data.data.result.buddy.info_list[0]; break
|
||
case 'getGroupNotices' : runtimeData.chatInfo.info.group_notices = msg.data.data; break
|
||
case 'getGroupFiles' : saveFileList(msg.data.data); break
|
||
case 'getMoreGroupFiles' : saveMoreFileList(msg.data.data); break
|
||
case 'getJin' : saveJin(msg.data.data); break
|
||
case 'getSystemMsg' : runtimeData.systemNoticesList = msg.data; break
|
||
case 'getSendMsg' : saveSendedMsg(echoList, msg); break
|
||
case 'getGroupMemberInfo' : saveMemberInfo(msg); break
|
||
case 'downloadFile' : downloadFileChat(msg); break
|
||
case 'downloadGroupFile' : downloadGroupFile(msg); break
|
||
case 'getVideoUrl' : getVideoUrl(msg); break
|
||
case 'getGroupDirFiles' : saveDirFile(msg); break
|
||
case 'readMemberMessage' : readMemberMessage(msg.data[0]); break
|
||
case 'setFriendAdd' :
|
||
case 'setGroupAdd' : updateSysInfo(head); break
|
||
}
|
||
}
|
||
} else {
|
||
switch (msg.post_type) {
|
||
// 心跳包
|
||
case 'meta_event' : livePackage(msg); break
|
||
// go-cqhttp：自动发送的消息回调和其他消息有区分
|
||
case 'message_sent' :
|
||
case 'message' : newMsg(msg); break
|
||
case 'notice' : {
|
||
if(runtimeData.botInfo.app_name == 'go-cqhttp') {
|
||
// go-cqhttp：通知消息子类别是 notice_type
|
||
switch (msg.notice_type) {
|
||
case 'group_recall' : msg.notice_type = 'group'
|
||
// eslint-disable-next-line
|
||
case 'friend_recall' : msg.notice_type = 'friend'
|
||
// eslint-disable-next-line
|
||
case 'recall' : revokeMsg(msg); break
|
||
}
|
||
break
|
||
} else {
|
||
switch (msg.sub_type) {
|
||
case 'recall' : revokeMsg(msg); break
|
||
}
|
||
break
|
||
}
|
||
}
|
||
case 'request' : addSystemNotice(msg); break
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
// ==============================================================
|
||
|
||
/**
|
||
* 保存 Bot 信息
|
||
* @param data Bot 信息
|
||
*/
|
||
function saveBotInfo(data: { [key: string]: any }) {
|
||
runtimeData.botInfo = data
|
||
// GA：提交分析信息，主要在意的是 bot 类型
|
||
if (Option.get('open_ga_bot') !== false) {
|
||
if (data.app_name !== undefined) {
|
||
app.config.globalProperties.
|
||
$gtag.event('login', { method: data.app_name })
|
||
} else {
|
||
app.config.globalProperties.
|
||
$gtag.event('login')
|
||
}
|
||
}
|
||
// 加载切换兼容功能
|
||
switch (data.app_name) {
|
||
// go-cqhttp：消息格式 CQCode <-> JSON
|
||
case 'go-cqhttp': {
|
||
runtimeData.tags.msgType = BotMsgType.CQCode
|
||
break
|
||
}
|
||
// oicq1：消息格式 JSON_OICQ_1 <-> JSON
|
||
case 'oicq': {
|
||
runtimeData.tags.msgType = BotMsgType.JSON_OICQ_1
|
||
break
|
||
}
|
||
}
|
||
// 加载设置项内的兼容功能，覆盖此处的设置（如果有的话）
|
||
Option.runAS('msg_type', Number(Option.get('msg_type')))
|
||
}
|
||
|
||
/**
|
||
* 保存账号信息
|
||
* @param data 账号信息
|
||
*/
|
||
function saveLoginInfo(data: { [key: string]: any }) {
|
||
// 如果是 user_id 的话 ……
|
||
if (data.uin === undefined && data.user_id !== undefined) {
|
||
data.uin = data.user_id
|
||
}
|
||
// 完成登陆初始化
|
||
runtimeData.loginInfo = data
|
||
login.status = true
|
||
clearInterval(runtimeData.tags.loginWaveTimer)
|
||
// 跳转标签卡
|
||
const barMsg = document.getElementById('bar-msg')
|
||
if(barMsg != null) {
|
||
barMsg.click()
|
||
}
|
||
// 获取更详细的信息
|
||
const url = 'https://find.qq.com/proxy/domain/cgi.find.qq.com/qqfind/find_v11?backver=2'
|
||
const info = `bnum=15&pagesize=15&id=0&sid=0&page=0&pageindex=0&ext=&guagua=1&gnum=12&guaguan=2&type=2&ver=4903&longitude=116.405285&latitude=39.904989&lbs_addr_country=%E4%B8%AD%E5%9B%BD&lbs_addr_province=%E5%8C%97%E4%BA%AC&lbs_addr_city=%E5%8C%97%E4%BA%AC%E5%B8%82&keyword=${data.uin}&nf=0&of=0&ldw=${data.bkn}`
|
||
Connector.send(
|
||
'http_proxy',
|
||
{ 'url': url, 'method': 'post', 'data': info },
|
||
'getMoreLoginInfo'
|
||
)
|
||
// GA：将 QQ 号 MD5 编码后用于用户识别码
|
||
if (Option.get('open_ga_user') === true) {
|
||
const userId = Md5.hashStr(data.uin)
|
||
app.config.globalProperties.$gtag.config({
|
||
user_id: userId
|
||
})
|
||
}
|
||
// 好友列表
|
||
Connector.send('get_friend_list', {}, 'getFriendList')
|
||
// 群列表
|
||
Connector.send('get_group_list', {}, 'getGroupList')
|
||
// 系统通知
|
||
Connector.send('get_system_msg', {}, 'getSystemMsg')
|
||
}
|
||
|
||
function saveUser(list: (UserFriendElem & UserGroupElem)[]) {
|
||
runtimeData.userList = runtimeData.userList.concat(list)
|
||
// 刷新置顶列表
|
||
const info = runtimeData.sysConfig.top_info as { [key: string]: number[] } | null
|
||
if (info != null) {
|
||
const topList = info[runtimeData.loginInfo.uin]
|
||
if (topList !== undefined) {
|
||
list.forEach((item) => {
|
||
const id = Number(item.user_id ? item.user_id : item.group_id)
|
||
if (topList.indexOf(id) >= 0) {
|
||
item.always_top = true
|
||
runtimeData.onMsgList.push(item)
|
||
}
|
||
})
|
||
}
|
||
}
|
||
}
|
||
|
||
function saveGroupMember(data: GroupMemberInfoElem[]) {
|
||
// 筛选列表
|
||
const adminList = data.filter((item: GroupMemberInfoElem) => {
|
||
return item.role === 'admin'
|
||
})
|
||
const createrList = data.filter((item: GroupMemberInfoElem) => {
|
||
return item.role === 'owner'
|
||
})
|
||
const memberList = data.filter((item: GroupMemberInfoElem) => {
|
||
return item.role !== 'admin' && item.role !== 'owner'
|
||
})
|
||
// 拼接列表
|
||
const back = createrList.concat(adminList.concat(memberList))
|
||
runtimeData.chatInfo.info.group_members = back
|
||
}
|
||
|
||
function saveMsgFist(msg: any) {
|
||
runtimeData.messageList = []
|
||
if (msg.error !== null && (msg.error !== undefined || msg.status === 'failed')) {
|
||
popInfo.add(PopType.ERR, app.config.globalProperties.$t('pop_chat_load_msg_err', { code: msg.error | msg.retcode }))
|
||
} else {
|
||
// go-cqhttp：返回的列表是倒的
|
||
if(runtimeData.botInfo.app_name == 'go-cqhttp') {
|
||
msg.data.reverse()
|
||
}
|
||
// 对消息进行转换
|
||
if (runtimeData.tags.msgType === BotMsgType.CQCode) {
|
||
for (let i = 0; i < msg.data.length; i++) {
|
||
msg.data[i] = Util.parseCQ(msg.data[i])
|
||
}
|
||
} else if(runtimeData.tags.msgType == BotMsgType.JSON_OICQ_1) {
|
||
for (let i = 0; i < msg.data.length; i++) {
|
||
msg.data[i] = Util.parseOICQ1JSON(msg.data[i])
|
||
}
|
||
}
|
||
// 检查必要字段
|
||
msg.data.forEach((item: any) => {
|
||
if(!item.post_type) {
|
||
item.post_type = 'message'
|
||
}
|
||
})
|
||
runtimeData.messageList = msg.data
|
||
}
|
||
}
|
||
|
||
function saveMsg(msg: any) {
|
||
if (msg.error != null && msg.error !== undefined) {
|
||
popInfo.add(PopType.ERR, app.config.globalProperties.$t('pop_chat_load_msg_err', { code: msg.error | msg.retcode }))
|
||
} else {
|
||
const items = msg.data
|
||
// go-cqhttp：返回的列表是倒的
|
||
if(runtimeData.botInfo.app_name == 'go-cqhttp') {
|
||
items.reverse()
|
||
}
|
||
items.pop() // 去除最后一条重复的消息，获取历史消息会返回当前消息 **以及** 之前的 N-1 条
|
||
if (items.length < 1) {
|
||
runtimeData.tags.canLoadHistory = false
|
||
return
|
||
}
|
||
// 对消息进行转换
|
||
if (runtimeData.tags.msgType === BotMsgType.CQCode) {
|
||
for (let i = 0; i < items.length; i++) {
|
||
items[i] = Util.parseCQ(items[i])
|
||
}
|
||
} else if(runtimeData.tags.msgType == BotMsgType.JSON_OICQ_1) {
|
||
for (let i = 0; i < msg.data.length; i++) {
|
||
items[i] = Util.parseOICQ1JSON(items[i])
|
||
}
|
||
}
|
||
// 检查必要字段
|
||
msg.data.forEach((item: any) => {
|
||
if(!item.post_type) {
|
||
item.post_type = 'message'
|
||
}
|
||
})
|
||
runtimeData.messageList = items.concat(runtimeData.messageList)
|
||
}
|
||
}
|
||
|
||
|
||
function saveForwardMsg(data: any) {
|
||
// gocqhttp 在 message 里，消息为 content，并且直接进行一个 CQCode 的转
|
||
if(runtimeData.botInfo['go-cqhttp'] === true) {
|
||
data = data.messages
|
||
}
|
||
|
||
// 格式化不规范消息格式
|
||
for (let i = 0; i < data.length; i++) {
|
||
if(!data[i].sender) {
|
||
data[i].sender = {
|
||
user_id: data[i].user_id,
|
||
nickname: data[i].nickname,
|
||
card: ''
|
||
}
|
||
}
|
||
if(!data[i].message) {
|
||
data[i].message = data[i].content
|
||
data[i] = Util.parseCQ(data[i])
|
||
}
|
||
}
|
||
// 处理
|
||
runtimeData.mergeMessageList = data
|
||
}
|
||
|
||
function showSendedMsg(msg: any, echoList: string[]) {
|
||
if (msg.error !== null && msg.error !== undefined) {
|
||
popInfo.add(PopType.ERR, app.config.globalProperties.$t('pop_chat_send_msg_err', { code: msg.error }))
|
||
} else {
|
||
if(msg.message_id == undefined) {
|
||
msg.message_id = msg.data.message_id
|
||
}
|
||
if (msg.message_id !== undefined && Option.get('send_reget') !== true) {
|
||
// 请求消息内容
|
||
Connector.send(
|
||
'get_msg',
|
||
{ 'message_id': msg.message_id },
|
||
'getSendMsg_' + msg.message_id + '_0'
|
||
)
|
||
}
|
||
if(echoList[1] == 'forward') {
|
||
// PS：这儿写是写了转发成功，事实上不确定消息有没有真的发送出去（
|
||
popInfo.add(PopType.INFO, app.config.globalProperties.$t('chat_chat_forward_success'))
|
||
}
|
||
}
|
||
}
|
||
|
||
function saveSendedMsg(echoList: string[], msg: any) {
|
||
// TODO: 这里暂时没有考虑消息获取失败的情况（因为没有例子）
|
||
const msgIdInfo = Util.parseMsgId(echoList[1]);
|
||
if (Number(echoList[2]) <= 5) {
|
||
// // 防止重试过程中切换聊天
|
||
if(msgIdInfo.gid == runtimeData.chatInfo.show.id || msgIdInfo.uid == runtimeData.chatInfo.show.id) {
|
||
// oicq1：返回的消息格式兼容
|
||
if(msg.message_id == undefined) {
|
||
msg = msg.data
|
||
}
|
||
// 对消息进行转换
|
||
if (runtimeData.tags.msgType === BotMsgType.CQCode) {
|
||
msg = Util.parseCQ(msg)
|
||
} else if(runtimeData.tags.msgType == BotMsgType.JSON_OICQ_1) {
|
||
msg = Util.parseOICQ1JSON(msg)
|
||
}
|
||
if (echoList[1] !== msg.message_id) {
|
||
console.log(msg)
|
||
// 返回的不是这条消息，重新请求
|
||
popInfo.add(PopType.ERR,
|
||
app.config.globalProperties.$t('pop_chat_get_msg_err') + ' ( ' + echoList[2] + ' )')
|
||
setTimeout(() => {
|
||
Connector.send(
|
||
'get_msg',
|
||
{ 'message_id': echoList[1] },
|
||
'getSendMsg_' + echoList[1] + '_' + (Number(echoList[2]) + 1)
|
||
)
|
||
}, 5000)
|
||
} else {
|
||
runtimeData.messageList.push(msg)
|
||
}
|
||
}
|
||
} else {
|
||
popInfo.add(PopType.ERR, app.config.globalProperties.$t('pop_chat_get_msg_err_fin'))
|
||
}
|
||
}
|
||
|
||
function saveMemberInfo(msg: any) {
|
||
const pointInfo = msg.echo.split('_')
|
||
msg.x = pointInfo[1]
|
||
msg.y = pointInfo[2]
|
||
runtimeData.chatInfo.info.now_member_info = msg
|
||
}
|
||
|
||
function revokeMsg(msg: any) {
|
||
const chatId = msg.notice_type === 'group' ? msg.group_id : msg.user_id
|
||
const msgId = msg.message_id
|
||
// 当前窗口
|
||
if (Number(chatId) === Number(runtimeData.chatInfo.show.id)) {
|
||
// 寻找消息
|
||
let msgGet = null as { [key: string]: any } | null
|
||
let msgIndex = -1
|
||
runtimeData.messageList.forEach((item, index) => {
|
||
if (item.message_id === msgId) {
|
||
msgGet = item
|
||
msgIndex = index
|
||
}
|
||
})
|
||
if (msgGet !== null && msgIndex !== -1) {
|
||
runtimeData.messageList[msgIndex].revoke = true
|
||
if(runtimeData.messageList[msgIndex].sender.user_id != runtimeData.loginInfo.uin) {
|
||
runtimeData.messageList.splice(msgIndex, 1)
|
||
}
|
||
if (msgGet.sender.user_id !== runtimeData.loginInfo.uin) {
|
||
// 显示撤回提示
|
||
const list = runtimeData.messageList
|
||
if (msgIndex !== -1) {
|
||
list.splice((msgIndex + 1), 0, msg)
|
||
} else {
|
||
list.push(msg)
|
||
}
|
||
}
|
||
} else {
|
||
new Logger().error(app.config.globalProperties.$t('log_revoke_miss'))
|
||
}
|
||
}
|
||
// // 尝试撤回通知
|
||
// if(window.notices != undefined && window.notices[msg.message_id] != undefined) {
|
||
// window.notices[msg.message_id].close()
|
||
// }
|
||
}
|
||
|
||
function downloadFileChat(msg: any) {
|
||
const info = msg.echo.split('_')
|
||
const msgId = info[1]
|
||
const url = msg.data.url
|
||
// 在消息列表内寻找这条消息（从后往前找）
|
||
let index = -1
|
||
let indexMsg = -1
|
||
for(let i=runtimeData.messageList.length - 1; i>0; i--) {
|
||
if(runtimeData.messageList[i].message_id == msgId) {
|
||
index = i
|
||
for(let j=0; j<runtimeData.messageList[i].message.length; j++) {
|
||
if(runtimeData.messageList[i].message[j].type == 'file') {
|
||
indexMsg = j
|
||
break
|
||
}
|
||
}
|
||
break
|
||
}
|
||
}
|
||
// 下载文件
|
||
if(index != -1 && indexMsg != -1) {
|
||
const onProcess = function (event: ProgressEvent): undefined {
|
||
if (!event.lengthComputable) return
|
||
runtimeData.messageList[index].message[indexMsg].
|
||
downloadingPercentage = Math.floor(event.loaded / event.total * 100)
|
||
}
|
||
Util.downloadFile(url, msg.echo.substring(msg.echo.lastIndexOf('_') + 1, msg.echo.length), onProcess)
|
||
}
|
||
}
|
||
|
||
function downloadGroupFile(msg: any) {
|
||
// 基本信息
|
||
const info = msg.echo.split('_')
|
||
const id = info[1]
|
||
// 文件信息
|
||
let fileName = 'new-file'
|
||
let fileIndex = -1
|
||
let subFileIndex = -1
|
||
runtimeData.chatInfo.info.group_files.file_list.forEach((item: any, index: number) => {
|
||
if (item.id === id) {
|
||
fileName = Util.htmlDecodeByRegExp(item.name)
|
||
fileIndex = index
|
||
}
|
||
})
|
||
// 特殊情况：这是个子文件
|
||
if (info[2] !== undefined) {
|
||
runtimeData.chatInfo.info.group_files.file_list[fileIndex].sub_list.forEach((item: any, index:number) => {
|
||
if (item.id === info[2]) {
|
||
fileName = Util.htmlDecodeByRegExp(item.name)
|
||
subFileIndex = index
|
||
}
|
||
})
|
||
}
|
||
// 下载事件
|
||
const onProcess = function (event: ProgressEvent): undefined {
|
||
if (!event.lengthComputable) return
|
||
const downloadingPercentage = Math.floor(event.loaded / event.total * 100)
|
||
if (fileIndex !== -1) {
|
||
if (subFileIndex === -1) {
|
||
if (runtimeData.chatInfo.info.group_files.file_list[fileIndex].downloadingPercentage === undefined) {
|
||
runtimeData.chatInfo.info.group_files.file_list[fileIndex].downloadingPercentage = 0
|
||
}
|
||
runtimeData.chatInfo.info.group_files.file_list[fileIndex].downloadingPercentage = downloadingPercentage
|
||
} else {
|
||
if (runtimeData.chatInfo.info.group_files.file_list[fileIndex].sub_list[subFileIndex].downloadingPercentage === undefined) {
|
||
runtimeData.chatInfo.info.group_files.file_list[fileIndex].sub_list[subFileIndex].downloadingPercentage= 0
|
||
}
|
||
runtimeData.chatInfo.info.group_files.file_list[fileIndex].sub_list[subFileIndex].downloadingPercentage = downloadingPercentage
|
||
}
|
||
}
|
||
}
|
||
|
||
// 下载文件
|
||
Util.downloadFile(msg.data.url, fileName, onProcess)
|
||
}
|
||
|
||
function getVideoUrl(msg: any) {
|
||
const info = msg.echo.split('_')
|
||
const msgId = info[1]
|
||
const url = msg.data.url
|
||
// 在消息列表内寻找这条消息
|
||
for(let i=0; i<runtimeData.messageList.length; i++) {
|
||
if(runtimeData.messageList[i].message_id == msgId) {
|
||
for(let j=0; j<runtimeData.messageList[i].message.length; j++) {
|
||
if(runtimeData.messageList[i].message[j].type == 'video') {
|
||
runtimeData.messageList[i].message[j].url = url
|
||
return
|
||
}
|
||
}
|
||
return
|
||
}
|
||
}
|
||
}
|
||
|
||
function saveDirFile(msg: any) {
|
||
// TODO: 这边不分页直接拿全，还没写
|
||
const id = msg.echo.split('_')[1]
|
||
let fileIndex = -1
|
||
runtimeData.chatInfo.info.group_files.file_list.forEach((item: any, index: number) => {
|
||
if (item.id === id) {
|
||
fileIndex = index
|
||
}
|
||
})
|
||
runtimeData.chatInfo.info.group_files.file_list[fileIndex].sub_list = msg.data.data.file_list
|
||
}
|
||
|
||
function saveFileList(data: any) {
|
||
const div = document.createElement('div')
|
||
div.innerHTML = data.em
|
||
if (data.ec !== 0) {
|
||
popInfo.add(
|
||
PopType.ERR,
|
||
app.config.globalProperties.$t('pop_chat_chat_info_load_file_err', { code: xss(div.innerHTML) })
|
||
)
|
||
} else {
|
||
runtimeData.chatInfo.info.group_files = data
|
||
}
|
||
}
|
||
|
||
function saveMoreFileList(data: any) {
|
||
if (runtimeData.chatInfo.info !== undefined && runtimeData.chatInfo.info.group_files !== undefined) {
|
||
// 追加文件列表
|
||
runtimeData.chatInfo.info.group_files.file_list = runtimeData.chatInfo.info.group_files.file_list.concat(data.file_list)
|
||
// 设置最大值位置
|
||
runtimeData.chatInfo.info.group_files.next_index = data.next_index
|
||
}
|
||
}
|
||
|
||
function newMsg(data: any) {
|
||
// TODO: 没有对频道的支持计划
|
||
if(data.message_type == 'guild') {
|
||
return
|
||
}
|
||
// 对消息进行转换
|
||
if (runtimeData.tags.msgType === BotMsgType.CQCode) {
|
||
data = Util.parseCQ(data)
|
||
} else if (runtimeData.tags.msgType == BotMsgType.JSON_OICQ_1) {
|
||
data = Util.parseOICQ1JSON(data)
|
||
}
|
||
let id = data.from_id ? data.from_id : data.group_id
|
||
const sender = data.sender.user_id
|
||
// oicq1：消息格式兼容
|
||
if(runtimeData.botInfo.app_name == 'oicq') {
|
||
id = data.group_id ? data.group_id : data.user_id
|
||
}
|
||
// go-cqhttp：消息格式兼容
|
||
if(runtimeData.botInfo.app_name == 'go-cqhttp') {
|
||
if(data.post_type == 'message_sent') {
|
||
id = data.group_id ? data.group_id : data.target_id
|
||
data.post_type = 'message'
|
||
} else {
|
||
id = data.group_id ? data.group_id : data.user_id
|
||
}
|
||
}
|
||
// 消息回调检查
|
||
// PS：如果在新消息中获取到了自己的消息，则自动打开“停止消息回调”设置防止发送的消息重复
|
||
if (Option.get('send_reget') !== true && sender === runtimeData.loginInfo.uin) {
|
||
Option.save('send_reget', true)
|
||
}
|
||
// 显示消息
|
||
if (id === runtimeData.chatInfo.show.id) {
|
||
runtimeData.messageList.push(data)
|
||
// 抽个签
|
||
const num = Util.randomNum(0, 10000)
|
||
if (num >= 4500 && num <= 5500) {
|
||
new Logger().add(LogType.INFO, num.toString())
|
||
}
|
||
if (num === 5000) {
|
||
const popInfo = {
|
||
html: qed,
|
||
button: [
|
||
{
|
||
text: '确定(O)',
|
||
fun: () => { runtimeData.popBoxList.shift() }
|
||
}
|
||
]
|
||
}
|
||
runtimeData.popBoxList.push(popInfo)
|
||
}
|
||
}
|
||
// 刷新消息列表
|
||
// PS：在消息列表内的永远会刷新，不需要被提及
|
||
const get = runtimeData.onMsgList.filter((item, index) => {
|
||
if(Number(id) === item.user_id || Number(id) === item.group_id) {
|
||
runtimeData.onMsgList[index].message_id = data.message_id
|
||
if(data.message_type === 'group') {
|
||
const name = (data.sender.card && data.sender.card !== '') ? data.sender.card : data.sender.nickname
|
||
runtimeData.onMsgList[index].raw_msg = name + ': ' + data.raw_message
|
||
} else {
|
||
runtimeData.onMsgList[index].raw_msg = data.raw_message
|
||
}
|
||
runtimeData.onMsgList[index].time = Number(data.time) * 1000
|
||
return true
|
||
}
|
||
return false
|
||
})
|
||
// 对于其他不在消息里标记 atme、atall 的处理
|
||
if(data.atme == undefined || data.atall == undefined) {
|
||
data.message.forEach((item: any) => {
|
||
if(item.type == 'at' && item.qq == runtimeData.loginInfo.uin) {
|
||
data.atme = true
|
||
}
|
||
})
|
||
}
|
||
// (发送者不是群组 || 群组 AT || 群组 AT 全体 || 打开了通知全部消息) 这些情况需要进行新消息处理
|
||
if (data.message_type !== 'group' || data.atme || data.atall || Option.get('notice_all') === true) {
|
||
// (发送者没有被打开 || 窗口被最小化) 这些情况需要进行消息通知
|
||
if (id !== runtimeData.chatInfo.show.id || document.hidden) {
|
||
// 检查通知权限，老旧浏览器不支持这个功能
|
||
if (Notification.permission === 'default') {
|
||
Notification.requestPermission(() => {
|
||
sendNotice(data)
|
||
})
|
||
} else if (Notification.permission !== 'denied') {
|
||
sendNotice(data)
|
||
}
|
||
// electron：在 windows 下对任务栏图标进行闪烁
|
||
if(runtimeData.tags.isElectron) {
|
||
const electron = (process.env.IS_ELECTRON as any) === true ? window.require('electron') : null
|
||
const reader = electron ? electron.ipcRenderer : null
|
||
if (reader) {
|
||
reader.send('win:flashWindow')
|
||
}
|
||
}
|
||
}
|
||
// 如果发送者不在消息列表里，将它添加到消息列表里
|
||
if (get.length !== 1) {
|
||
const getList = runtimeData.userList.filter((item) => { return item.user_id === id || item.group_id === id })
|
||
if (getList.length === 1) {
|
||
runtimeData.onMsgList.push(getList[0])
|
||
}
|
||
}
|
||
runtimeData.onMsgList.forEach((item) => {
|
||
// 刷新新消息标签
|
||
if (id !== runtimeData.chatInfo.show.id && (id == item.group_id || id == item.user_id)) {
|
||
item.new_msg = true
|
||
}
|
||
})
|
||
// 重新排序列表
|
||
const newList = [] as (UserFriendElem & UserGroupElem)[]
|
||
let topNum = 1
|
||
runtimeData.onMsgList.forEach((item) => {
|
||
// 排序操作
|
||
if (item.always_top === true) {
|
||
newList.unshift(item)
|
||
topNum++
|
||
} else if (item.new_msg === true) {
|
||
newList.splice(topNum - 1, 0, item)
|
||
} else {
|
||
newList.push(item)
|
||
}
|
||
})
|
||
runtimeData.onMsgList = newList
|
||
}
|
||
}
|
||
|
||
function sendNotice(msg: any) {
|
||
if (Option.get('close_notice') !== true) {
|
||
let raw = Util.getMsgRawTxt(msg.message)
|
||
raw = raw === '' ? msg.raw_message : raw
|
||
// 构建通知
|
||
let notificationTile = ''
|
||
const notificationBody = {} as NotificationElem
|
||
notificationBody.requireInteraction = true
|
||
if (msg.message_type === 'group') {
|
||
notificationTile = msg.group_name
|
||
notificationBody.body = msg.sender.nickname + ':' + raw
|
||
notificationBody.tag = `${msg.group_id}/${msg.message_id}`
|
||
notificationBody.icon = `https://p.qlogo.cn/gh/${msg.group_id}/${msg.group_id}/0`
|
||
} else {
|
||
notificationTile = msg.sender.nickname
|
||
notificationBody.body = raw
|
||
notificationBody.tag = `${msg.user_id}/${msg.message_id}`
|
||
notificationBody.icon = `https://q1.qlogo.cn/g?b=qq&s=0&nk=${msg.user_id}`
|
||
}
|
||
// 如果消息有图片，追加第一张图片
|
||
msg.message.forEach((item: MsgItemElem) => {
|
||
if (item.type === 'image' && notificationBody.image === undefined) {
|
||
notificationBody.image = item.url
|
||
}
|
||
})
|
||
// 检查这个用户是否有通知，有的话删除旧的
|
||
// PS：这个处理逻辑主要用于防止大量消息刷大量的通知
|
||
const index = notificationList.findIndex((item) => {
|
||
const tag = item.tag
|
||
const userId = Number(tag.split('/')[0])
|
||
return userId === msg.user_id || userId === msg.group_id
|
||
})
|
||
if (index !== -1) {
|
||
notificationList.splice(index, 1)
|
||
notificationList[index].close()
|
||
}
|
||
// 发起通知
|
||
const notification = new Notification(notificationTile, notificationBody)
|
||
notification.onclick = (event: Event) => {
|
||
const info = event.target as NotificationOptions
|
||
if(info.tag !== undefined) {
|
||
const userId = info.tag.split('/')[0]
|
||
const msgId = Number(info.tag.substring(userId.length + 1, info.tag.length))
|
||
// 在通知列表中删除这条消息
|
||
const index = notificationList.findIndex((item) => { return item.tag === info.tag })
|
||
if (index !== -1) {
|
||
notificationList.splice(index, 1)
|
||
}
|
||
// 跳转到这条消息的发送者页面
|
||
window.focus()
|
||
// electron：需要让 electron 拉起页面
|
||
if(runtimeData.tags.isElectron) {
|
||
const electron = (process.env.IS_ELECTRON as any) === true ? window.require('electron') : null
|
||
const reader = electron ? electron.ipcRenderer : null
|
||
if (reader) {
|
||
reader.send('win:fouesWindow')
|
||
}
|
||
}
|
||
const body = document.getElementById('user-' + userId)
|
||
if (body === null) {
|
||
// 从缓存列表里寻找这个 ID
|
||
for (let i = 0; i < runtimeData.userList.length; i++) {
|
||
const item = runtimeData.userList[i]
|
||
const id = item.user_id !== undefined ? item.user_id : item.group_id
|
||
if (String(id) === userId) {
|
||
// 把它插入到显示列表的第一个
|
||
runtimeData.showList?.unshift(item)
|
||
nextTick(() => {
|
||
const bodyNext = document.getElementById('user-' + userId)
|
||
if(bodyNext !== null) {
|
||
// 添加一个消息跳转标记
|
||
bodyNext.dataset.jump = msgId.toString()
|
||
// 然后点一下它触发聊天框切换
|
||
bodyNext.click()
|
||
}
|
||
})
|
||
break
|
||
}
|
||
}
|
||
} else {
|
||
body.click()
|
||
}
|
||
|
||
}
|
||
}
|
||
notification.onclose = (event: Event) => {
|
||
const info = event.target as NotificationOptions
|
||
if(info.tag !== undefined) {
|
||
// 在通知列表中删除这条消息
|
||
const index = notificationList.findIndex((item) => { return item.tag === info.tag })
|
||
if (index !== -1) {
|
||
notificationList.splice(index, 1)
|
||
}
|
||
}
|
||
}
|
||
notificationList.push(notification)
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 保存精华消息
|
||
* @param data 返回数据
|
||
*/
|
||
function saveJin (data: any) {
|
||
if(runtimeData.chatInfo.info.jin_info.data.msg_list.length == 0) {
|
||
// 首次获取
|
||
runtimeData.chatInfo.info.jin_info = data
|
||
} else {
|
||
// 追加保存
|
||
if(data.retcode == 0) {
|
||
runtimeData.chatInfo.info.jin_info.data.msg_list =
|
||
runtimeData.chatInfo.info.jin_info.data.msg_list.concat(data.data.msg_list)
|
||
runtimeData.chatInfo.info.jin_info.data.is_end = data.data.is_end
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 将这条消息以上的所有消息标记为已读
|
||
* @param data 消息
|
||
*/
|
||
function readMemberMessage(data: any) {
|
||
Connector.send('set_message_read', {
|
||
message_id: data.message_id
|
||
}, 'setMessageRead')
|
||
// go-cqhttp：他们名字不一样
|
||
Connector.send('mark_msg_as_read', {
|
||
message_id: data.message_id
|
||
}, 'setMessageRead')
|
||
}
|
||
|
||
/**
|
||
* 心跳包处理
|
||
* @param msg
|
||
*/
|
||
function livePackage(msg: any) {
|
||
// TODO: 还没写这个功能
|
||
msg
|
||
}
|
||
|
||
/**
|
||
* 刷新系统通知和其他内容，给系统通知响应用的
|
||
*/
|
||
function updateSysInfo(type: string) {
|
||
Connector.send('get_system_msg', {}, 'getSystemMsg')
|
||
switch(type) {
|
||
case 'setFriendAdd':
|
||
Connector.send('get_friend_list', {}, 'getFriendList'); break
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 添加获取到的系统通知消息
|
||
* @param msg 系统通知
|
||
*/
|
||
function addSystemNotice(msg: any) {
|
||
if(runtimeData.systemNoticesList) {
|
||
runtimeData.systemNoticesList.push(msg)
|
||
} else {
|
||
runtimeData.systemNoticesList = [msg]
|
||
}
|
||
}
|
||
|
||
// ==============================================================
|
||
|
||
const baseRuntime = {
|
||
tags: {
|
||
firstLoad: false,
|
||
canLoadHistory: true,
|
||
openSideBar: false,
|
||
viewer: { index: 0 },
|
||
msgType: BotMsgType.JSON,
|
||
isElectron: false
|
||
},
|
||
chatInfo: {
|
||
show: { type: '', id: 0, name: '', avatar: '' },
|
||
info: {
|
||
group_info: {},
|
||
user_info: {},
|
||
me_info: {},
|
||
group_members: [],
|
||
group_files: {},
|
||
group_sub_files: {},
|
||
jin_info: { data: { msg_list: [] } }
|
||
}
|
||
},
|
||
pageView: {
|
||
chatView: markRaw(defineAsyncComponent(() => import('@/pages/Chat.vue'))),
|
||
msgView: markRaw(defineAsyncComponent(() => import('@/pages/Chat.vue')))
|
||
},
|
||
userList: [],
|
||
systemNoticesList: [],
|
||
onMsgList: [],
|
||
loginInfo: {},
|
||
botInfo: {},
|
||
sysConfig: {},
|
||
messageList: [],
|
||
popBoxList: []
|
||
}
|
||
|
||
export const runtimeData: RunTimeDataElem = reactive(baseRuntime)
|
||
export const appendMsg: { [ key: string ]: (msg: any) => void } = reactive({})
|
||
export const notificationList: Notification[] = reactive([]) |