mirror of
https://github.com/NapNeko/NapCatQQ.git
synced 2025-12-31 06:29:02 +08:00
568 lines
19 KiB
TypeScript
568 lines
19 KiB
TypeScript
import {
|
||
AtType,
|
||
ChatType,
|
||
ElementType,
|
||
Group, PicSubType,
|
||
RawMessage,
|
||
SendArkElement,
|
||
SendMessageElement,
|
||
Peer
|
||
} from '@/core/qqnt/entities';
|
||
|
||
import {
|
||
OB11MessageCustomMusic,
|
||
OB11MessageData,
|
||
OB11MessageDataType,
|
||
OB11MessageMixType,
|
||
OB11MessageNode,
|
||
OB11PostSendMsg
|
||
} from '../../types';
|
||
import { SendMsgElementConstructor } from '@/core/qqnt/entities/constructor';
|
||
import BaseAction from '../BaseAction';
|
||
import { ActionName, BaseCheckResult } from '../types';
|
||
import * as fs from 'node:fs';
|
||
import { decodeCQCode } from '../../cqcode';
|
||
import { dbUtil } from '@/common/utils/db';
|
||
import { log } from '@/common/utils/log';
|
||
import { sleep } from '@/common/utils/helper';
|
||
import { uri2local } from '@/common/utils/file';
|
||
import { getFriend, getGroup, getGroupMember, getUidByUin, selfInfo } from '@/common/data';
|
||
import { NTQQMsgApi } from '@/core/qqnt/apis';
|
||
import { NTQQFileApi } from '@/core/qqnt/apis';
|
||
|
||
const ALLOW_SEND_TEMP_MSG = false;
|
||
|
||
function checkSendMessage(sendMsgList: OB11MessageData[]) {
|
||
function checkUri(uri: string): boolean {
|
||
const pattern = /^(file:\/\/|http:\/\/|https:\/\/|base64:\/\/)/;
|
||
return pattern.test(uri);
|
||
}
|
||
|
||
for (const msg of sendMsgList) {
|
||
if (msg['type'] && msg['data']) {
|
||
const type = msg['type'];
|
||
const data = msg['data'];
|
||
if (type === 'text' && !data['text']) {
|
||
return 400;
|
||
} else if (['image', 'voice', 'record'].includes(type)) {
|
||
if (!data['file']) {
|
||
return 400;
|
||
} else {
|
||
if (checkUri(data['file'])) {
|
||
return 200;
|
||
} else {
|
||
return 400;
|
||
}
|
||
}
|
||
|
||
} else if (type === 'at' && !data['qq']) {
|
||
return 400;
|
||
} else if (type === 'reply' && !data['id']) {
|
||
return 400;
|
||
}
|
||
} else {
|
||
return 400;
|
||
}
|
||
}
|
||
return 200;
|
||
}
|
||
|
||
export interface ReturnDataType {
|
||
message_id: number;
|
||
}
|
||
|
||
export function convertMessage2List(message: OB11MessageMixType, autoEscape = false) {
|
||
if (typeof message === 'string') {
|
||
if (autoEscape === true) {
|
||
message = [{
|
||
type: OB11MessageDataType.text,
|
||
data: {
|
||
text: message
|
||
}
|
||
}];
|
||
} else {
|
||
message = decodeCQCode(message.toString());
|
||
}
|
||
} else if (!Array.isArray(message)) {
|
||
message = [message];
|
||
}
|
||
return message;
|
||
}
|
||
|
||
export async function createSendElements(messageData: OB11MessageData[], group: Group | undefined, ignoreTypes: OB11MessageDataType[] = []) {
|
||
const sendElements: SendMessageElement[] = [];
|
||
const deleteAfterSentFiles: string[] = [];
|
||
for (const sendMsg of messageData) {
|
||
if (ignoreTypes.includes(sendMsg.type)) {
|
||
continue;
|
||
}
|
||
switch (sendMsg.type) {
|
||
case OB11MessageDataType.text: {
|
||
const text = sendMsg.data?.text;
|
||
if (text) {
|
||
sendElements.push(SendMsgElementConstructor.text(sendMsg.data!.text));
|
||
}
|
||
}
|
||
break;
|
||
case OB11MessageDataType.at: {
|
||
if (!group) {
|
||
continue;
|
||
}
|
||
let atQQ = sendMsg.data?.qq;
|
||
if (atQQ) {
|
||
atQQ = atQQ.toString();
|
||
if (atQQ === 'all') {
|
||
sendElements.push(SendMsgElementConstructor.at(atQQ, atQQ, AtType.atAll, '全体成员'));
|
||
} else {
|
||
// const atMember = group?.members.find(m => m.uin == atQQ)
|
||
const atMember = await getGroupMember(group?.groupCode, atQQ);
|
||
if (atMember) {
|
||
sendElements.push(SendMsgElementConstructor.at(atQQ, atMember.uid, AtType.atUser, atMember.cardName || atMember.nick));
|
||
}
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
case OB11MessageDataType.reply: {
|
||
const replyMsgId = sendMsg.data.id;
|
||
if (replyMsgId) {
|
||
const replyMsg = await dbUtil.getMsgByShortId(parseInt(replyMsgId));
|
||
if (replyMsg) {
|
||
sendElements.push(SendMsgElementConstructor.reply(replyMsg.msgSeq, replyMsg.msgId, replyMsg.senderUin!, replyMsg.senderUin!));
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
case OB11MessageDataType.face: {
|
||
const faceId = sendMsg.data?.id;
|
||
if (faceId) {
|
||
sendElements.push(SendMsgElementConstructor.face(parseInt(faceId)));
|
||
}
|
||
}
|
||
break;
|
||
|
||
case OB11MessageDataType.image:
|
||
case OB11MessageDataType.file:
|
||
case OB11MessageDataType.video:
|
||
case OB11MessageDataType.voice: {
|
||
let file = sendMsg.data?.file;
|
||
const payloadFileName = sendMsg.data?.name;
|
||
if (file) {
|
||
const cache = await dbUtil.getFileCacheByName(file);
|
||
if (cache) {
|
||
if (fs.existsSync(cache.path)) {
|
||
file = 'file://' + cache.path;
|
||
} else if (cache.url) {
|
||
file = cache.url;
|
||
} else {
|
||
const fileMsg = await dbUtil.getMsgByLongId(cache.msgId);
|
||
if (fileMsg) {
|
||
const downloadPath = await NTQQFileApi.downloadMedia(fileMsg.msgId, fileMsg.chatType, fileMsg.peerUid,
|
||
cache.elementId, '', '');
|
||
cache.path = downloadPath!;
|
||
dbUtil.updateFileCache(cache).then();
|
||
file = 'file://' + cache.path;
|
||
}
|
||
// await sleep(1000);
|
||
|
||
// log('download result', downloadPath);
|
||
// log('下载完成后的msg', msg);
|
||
}
|
||
log('找到文件缓存', file);
|
||
}
|
||
const { path, isLocal, fileName, errMsg } = (await uri2local(file));
|
||
if (errMsg) {
|
||
log('文件下载失败', errMsg);
|
||
throw Error('文件下载失败' + errMsg);
|
||
// throw (errMsg);
|
||
// continue
|
||
}
|
||
if (path) {
|
||
if (!isLocal) { // 只删除http和base64转过来的文件
|
||
deleteAfterSentFiles.push(path);
|
||
}
|
||
if (sendMsg.type === OB11MessageDataType.file) {
|
||
log('发送文件', path, payloadFileName || fileName);
|
||
sendElements.push(await SendMsgElementConstructor.file(path, payloadFileName || fileName));
|
||
} else if (sendMsg.type === OB11MessageDataType.video) {
|
||
log('发送视频', path, payloadFileName || fileName);
|
||
let thumb = sendMsg.data?.thumb;
|
||
if (thumb) {
|
||
const uri2LocalRes = await uri2local(thumb);
|
||
if (uri2LocalRes.success) {
|
||
thumb = uri2LocalRes.path;
|
||
}
|
||
}
|
||
sendElements.push(await SendMsgElementConstructor.video(path, payloadFileName || fileName, thumb));
|
||
} else if (sendMsg.type === OB11MessageDataType.voice) {
|
||
sendElements.push(await SendMsgElementConstructor.ptt(path));
|
||
} else if (sendMsg.type === OB11MessageDataType.image) {
|
||
sendElements.push(await SendMsgElementConstructor.pic(path, sendMsg.data.summary || '', <PicSubType>parseInt(sendMsg.data?.subType?.toString() || '0')));
|
||
}
|
||
}
|
||
}
|
||
}
|
||
break;
|
||
case OB11MessageDataType.json: {
|
||
sendElements.push(SendMsgElementConstructor.ark(sendMsg.data.data));
|
||
}
|
||
break;
|
||
case OB11MessageDataType.dice: {
|
||
const resultId = sendMsg.data?.result;
|
||
sendElements.push(SendMsgElementConstructor.dice(resultId));
|
||
}
|
||
break;
|
||
case OB11MessageDataType.RPS: {
|
||
const resultId = sendMsg.data?.result;
|
||
sendElements.push(SendMsgElementConstructor.rps(resultId));
|
||
}
|
||
break;
|
||
case OB11MessageDataType.markdown: {
|
||
const content = sendMsg.data?.content;
|
||
sendElements.push(SendMsgElementConstructor.markdown(content));
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
return {
|
||
sendElements,
|
||
deleteAfterSentFiles
|
||
};
|
||
}
|
||
|
||
export async function sendMsg(peer: Peer, sendElements: SendMessageElement[], deleteAfterSentFiles: string[], waitComplete = true) {
|
||
if (!sendElements.length) {
|
||
throw ('消息体无法解析');
|
||
}
|
||
const returnMsg = await NTQQMsgApi.sendMsg(peer, sendElements, waitComplete, 20000);
|
||
try {
|
||
returnMsg.id = await dbUtil.addMsg(returnMsg, false);
|
||
} catch (e: any) {
|
||
log('发送消息id获取失败', e);
|
||
returnMsg.id = 0;
|
||
}
|
||
// log('消息发送结果', returnMsg);
|
||
deleteAfterSentFiles.map(f => fs.unlink(f, () => {
|
||
}));
|
||
return returnMsg;
|
||
}
|
||
|
||
export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
|
||
actionName = ActionName.SendMsg;
|
||
|
||
protected async check(payload: OB11PostSendMsg): Promise<BaseCheckResult> {
|
||
const messages = convertMessage2List(payload.message);
|
||
const fmNum = this.getSpecialMsgNum(payload, OB11MessageDataType.node);
|
||
if (fmNum && fmNum != messages.length) {
|
||
return {
|
||
valid: false,
|
||
message: '转发消息不能和普通消息混在一起发送,转发需要保证message只有type为node的元素'
|
||
};
|
||
}
|
||
if (payload.message_type !== 'private' && payload.group_id && !(await getGroup(payload.group_id))) {
|
||
return {
|
||
valid: false,
|
||
message: `群${payload.group_id}不存在`
|
||
};
|
||
}
|
||
if (payload.user_id && payload.message_type !== 'group') {
|
||
if (!(await getFriend(payload.user_id))) {
|
||
if (!ALLOW_SEND_TEMP_MSG
|
||
&& !(await dbUtil.getUidByTempUin(payload.user_id.toString()))
|
||
) {
|
||
return {
|
||
valid: false,
|
||
message: '不能发送临时消息'
|
||
};
|
||
}
|
||
}
|
||
}
|
||
return {
|
||
valid: true,
|
||
};
|
||
}
|
||
|
||
protected async _handle(payload: OB11PostSendMsg): Promise<{ message_id: number }> {
|
||
|
||
const peer: Peer = {
|
||
chatType: ChatType.friend,
|
||
peerUid: ''
|
||
};
|
||
let isTempMsg = false;
|
||
let group: Group | undefined = undefined;
|
||
const genGroupPeer = async () => {
|
||
if (payload.group_id) {
|
||
group = await getGroup(payload.group_id.toString());
|
||
if (group) {
|
||
peer.chatType = ChatType.group;
|
||
// peer.name = group.name
|
||
peer.peerUid = group.groupCode;
|
||
}
|
||
|
||
}
|
||
};
|
||
|
||
const genFriendPeer = async () => {
|
||
if (!payload.user_id) {
|
||
return;
|
||
}
|
||
const friend = await getFriend(payload.user_id.toString());
|
||
if (friend) {
|
||
// peer.name = friend.nickName
|
||
peer.peerUid = friend.uid;
|
||
} else {
|
||
peer.chatType = ChatType.temp;
|
||
const tempUserUid = getUidByUin(payload.user_id.toString());
|
||
if (!tempUserUid) {
|
||
throw (`找不到私聊对象${payload.user_id}`);
|
||
}
|
||
// peer.name = tempUser.nickName
|
||
isTempMsg = true;
|
||
peer.peerUid = tempUserUid;
|
||
}
|
||
};
|
||
if (payload?.group_id && payload.message_type === 'group') {
|
||
await genGroupPeer();
|
||
|
||
} else if (payload?.user_id) {
|
||
await genFriendPeer();
|
||
} else if (payload.group_id) {
|
||
await genGroupPeer();
|
||
} else {
|
||
throw ('发送消息参数错误, 请指定group_id或user_id');
|
||
}
|
||
const messages = convertMessage2List(payload.message, payload.auto_escape === true || payload.auto_escape === 'true');
|
||
if (this.getSpecialMsgNum(payload, OB11MessageDataType.node)) {
|
||
try {
|
||
const returnMsg = await this.handleForwardNode(peer, messages as OB11MessageNode[], group);
|
||
if (returnMsg) {
|
||
const msgShortId = await dbUtil.addMsg(returnMsg!, false);
|
||
return { message_id: msgShortId };
|
||
} else {
|
||
throw Error('发送转发消息失败');
|
||
}
|
||
} catch (e: any) {
|
||
throw Error('发送转发消息失败 ' + e.toString());
|
||
}
|
||
} else {
|
||
if (this.getSpecialMsgNum(payload, OB11MessageDataType.music)) {
|
||
const music: OB11MessageCustomMusic = messages[0] as OB11MessageCustomMusic;
|
||
if (music) {
|
||
const { url, audio, title, content, image } = music.data;
|
||
const selfPeer: Peer = { peerUid: selfInfo.uid, chatType: ChatType.friend };
|
||
// 搞不定！
|
||
// const musicMsg = await this.send(selfPeer, [this.genMusicElement(url, audio, title, content, image)], [], false)
|
||
// 转发
|
||
// const res = await NTQQApi.forwardMsg(selfPeer, peer, [musicMsg.msgId])
|
||
// log("转发音乐消息成功", res);
|
||
// return {message_id: musicMsg.msgShortId}
|
||
}
|
||
}
|
||
}
|
||
// log("send msg:", peer, sendElements)
|
||
const { sendElements, deleteAfterSentFiles } = await createSendElements(messages, group);
|
||
const returnMsg = await sendMsg(peer, sendElements, deleteAfterSentFiles);
|
||
deleteAfterSentFiles.map(f => fs.unlink(f, () => {
|
||
}));
|
||
|
||
const res = { message_id: returnMsg.id! };
|
||
// console.log(res);
|
||
return res;
|
||
}
|
||
|
||
|
||
private getSpecialMsgNum(payload: OB11PostSendMsg, msgType: OB11MessageDataType): number {
|
||
if (Array.isArray(payload.message)) {
|
||
return payload.message.filter(msg => msg.type == msgType).length;
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
private async cloneMsg(msg: RawMessage): Promise<RawMessage | undefined> {
|
||
log('克隆的目标消息', msg);
|
||
const sendElements: SendMessageElement[] = [];
|
||
for (const ele of msg.elements) {
|
||
sendElements.push(ele as SendMessageElement);
|
||
// Object.keys(ele).forEach((eleKey) => {
|
||
// if (eleKey.endsWith("Element")) {
|
||
// }
|
||
|
||
}
|
||
if (sendElements.length === 0) {
|
||
log('需要clone的消息无法解析，将会忽略掉', msg);
|
||
}
|
||
log('克隆消息', sendElements);
|
||
try {
|
||
const nodeMsg = await NTQQMsgApi.sendMsg({
|
||
chatType: ChatType.friend,
|
||
peerUid: selfInfo.uid
|
||
}, sendElements, true);
|
||
await sleep(500);
|
||
return nodeMsg;
|
||
} catch (e) {
|
||
log(e, '克隆转发消息失败,将忽略本条消息', msg);
|
||
}
|
||
|
||
}
|
||
|
||
// 返回一个合并转发的消息id
|
||
private async handleForwardNode(destPeer: Peer, messageNodes: OB11MessageNode[], group: Group | undefined): Promise<RawMessage | null> {
|
||
|
||
const selfPeer = {
|
||
chatType: ChatType.friend,
|
||
peerUid: selfInfo.uid
|
||
};
|
||
let nodeMsgIds: string[] = [];
|
||
// 先判断一遍是不是id和自定义混用
|
||
const needClone = messageNodes.filter(node => node.data.id).length && messageNodes.filter(node => !node.data.id).length;
|
||
for (const messageNode of messageNodes) {
|
||
// 一个node表示一个人的消息
|
||
const nodeId = messageNode.data.id;
|
||
// 有nodeId表示一个子转发消息卡片
|
||
if (nodeId) {
|
||
const nodeMsg = await dbUtil.getMsgByShortId(parseInt(nodeId));
|
||
if (!needClone) {
|
||
nodeMsgIds.push(nodeMsg!.msgId);
|
||
} else {
|
||
if (nodeMsg!.peerUid !== selfInfo.uid) {
|
||
const cloneMsg = await this.cloneMsg(nodeMsg!);
|
||
if (cloneMsg) {
|
||
nodeMsgIds.push(cloneMsg.msgId);
|
||
}
|
||
}
|
||
}
|
||
} else {
|
||
// 自定义的消息
|
||
// 提取消息段，发给自己生成消息id
|
||
try {
|
||
const {
|
||
sendElements,
|
||
deleteAfterSentFiles
|
||
} = await createSendElements(convertMessage2List(messageNode.data.content), group);
|
||
log('开始生成转发节点', sendElements);
|
||
const sendElementsSplit: SendMessageElement[][] = [];
|
||
let splitIndex = 0;
|
||
for (const ele of sendElements) {
|
||
if (!sendElementsSplit[splitIndex]) {
|
||
sendElementsSplit[splitIndex] = [];
|
||
}
|
||
|
||
if (ele.elementType === ElementType.FILE || ele.elementType === ElementType.VIDEO) {
|
||
if (sendElementsSplit[splitIndex].length > 0) {
|
||
splitIndex++;
|
||
}
|
||
sendElementsSplit[splitIndex] = [ele];
|
||
splitIndex++;
|
||
} else {
|
||
sendElementsSplit[splitIndex].push(ele);
|
||
}
|
||
log(sendElementsSplit);
|
||
}
|
||
// log("分割后的转发节点", sendElementsSplit)
|
||
for (const eles of sendElementsSplit) {
|
||
const nodeMsg = await sendMsg(selfPeer, eles, [], true);
|
||
nodeMsgIds.push(nodeMsg.msgId);
|
||
await sleep(500);
|
||
log('转发节点生成成功', nodeMsg.msgId);
|
||
}
|
||
deleteAfterSentFiles.map(f => fs.unlink(f, () => {
|
||
}));
|
||
|
||
} catch (e) {
|
||
log('生成转发消息节点失败', e);
|
||
}
|
||
}
|
||
}
|
||
|
||
// 检查srcPeer是否一致，不一致则需要克隆成自己的消息, 让所有srcPeer都变成自己的，使其保持一致才能够转发
|
||
const nodeMsgArray: Array<RawMessage> = [];
|
||
let srcPeer: Peer | undefined = undefined;
|
||
let needSendSelf = false;
|
||
for (const [index, msgId] of nodeMsgIds.entries()) {
|
||
const nodeMsg = await dbUtil.getMsgByLongId(msgId);
|
||
if (nodeMsg) {
|
||
nodeMsgArray.push(nodeMsg);
|
||
if (!srcPeer) {
|
||
srcPeer = { chatType: nodeMsg.chatType, peerUid: nodeMsg.peerUid };
|
||
} else if (srcPeer.peerUid !== nodeMsg.peerUid) {
|
||
needSendSelf = true;
|
||
srcPeer = selfPeer;
|
||
}
|
||
}
|
||
}
|
||
log('nodeMsgArray', nodeMsgArray);
|
||
nodeMsgIds = nodeMsgArray.map(msg => msg.msgId);
|
||
if (needSendSelf) {
|
||
log('需要克隆转发消息');
|
||
for (const [index, msg] of nodeMsgArray.entries()) {
|
||
if (msg.peerUid !== selfInfo.uid) {
|
||
const cloneMsg = await this.cloneMsg(msg);
|
||
if (cloneMsg) {
|
||
nodeMsgIds[index] = cloneMsg.msgId;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
// elements之间用换行符分隔
|
||
// let _sendForwardElements: SendMessageElement[] = []
|
||
// for(let i = 0; i < sendForwardElements.length; i++){
|
||
// _sendForwardElements.push(sendForwardElements[i])
|
||
// _sendForwardElements.push(SendMsgElementConstructor.text("\n\n"))
|
||
// }
|
||
// const nodeMsg = await NTQQApi.sendMsg(selfPeer, _sendForwardElements, true);
|
||
// nodeIds.push(nodeMsg.msgId)
|
||
// await sleep(500);
|
||
// 开发转发
|
||
if (nodeMsgIds.length === 0) {
|
||
throw Error('转发消息失败，生成节点为空');
|
||
}
|
||
try {
|
||
log('开发转发', srcPeer, destPeer, nodeMsgIds);
|
||
return await NTQQMsgApi.multiForwardMsg(srcPeer!, destPeer, nodeMsgIds);
|
||
} catch (e) {
|
||
log('forward failed', e);
|
||
return null;
|
||
}
|
||
}
|
||
|
||
|
||
private genMusicElement(url: string, audio: string, title: string, content: string, image: string): SendArkElement {
|
||
const musicJson = {
|
||
app: 'com.tencent.structmsg',
|
||
config: {
|
||
ctime: 1709689928,
|
||
forward: 1,
|
||
token: '5c1e4905f926dd3a64a4bd3841460351',
|
||
type: 'normal'
|
||
},
|
||
extra: { app_type: 1, appid: 100497308, uin: selfInfo.uin },
|
||
meta: {
|
||
news: {
|
||
action: '',
|
||
android_pkg_name: '',
|
||
app_type: 1,
|
||
appid: 100497308,
|
||
ctime: 1709689928,
|
||
desc: content || title,
|
||
jumpUrl: url,
|
||
musicUrl: audio,
|
||
preview: image,
|
||
source_icon: 'https://p.qpic.cn/qqconnect/0/app_100497308_1626060999/100?max-age=2592000&t=0',
|
||
source_url: '',
|
||
tag: 'QQ音乐',
|
||
title: title,
|
||
uin: selfInfo.uin,
|
||
}
|
||
},
|
||
prompt: content || title,
|
||
ver: '0.0.0.1',
|
||
view: 'news'
|
||
};
|
||
|
||
return SendMsgElementConstructor.ark(musicJson);
|
||
}
|
||
}
|
||
|
||
export default SendMsg;
|