mirror of https://github.com/Nofated095/Q2TG.git
30 lines
1.1 KiB
TypeScript
30 lines
1.1 KiB
TypeScript
import Instance from '../models/Instance';
|
||
import Telegram from '../client/Telegram';
|
||
import OicqClient from '../client/OicqClient';
|
||
import { GroupMessageEvent, MiraiElem, PrivateMessageEvent } from 'icqq';
|
||
|
||
export default class {
|
||
constructor(private readonly instance: Instance,
|
||
private readonly tgBot: Telegram,
|
||
// private readonly tgUser: Telegram,
|
||
private readonly qqBot: OicqClient) {
|
||
qqBot.addNewMessageEventHandler(this.onQqMessage);
|
||
}
|
||
|
||
// 当 mapInstance 用同服务器其他个人模式账号发送消息后，message mirai 会带 q2tgSkip=true
|
||
// 防止 bot 重新收到消息再转一圈回来重新转发或者重新响应命令
|
||
private onQqMessage = async (event: PrivateMessageEvent | GroupMessageEvent) => {
|
||
if ('friend' in event) return;
|
||
if (!event.message) return;
|
||
const messageMirai = event.message.find(it => it.type === 'mirai') as MiraiElem;
|
||
if (messageMirai) {
|
||
try {
|
||
const miraiData = JSON.parse(messageMirai.data);
|
||
if (miraiData.q2tgSkip) return true;
|
||
}
|
||
catch {
|
||
}
|
||
}
|
||
};
|
||
}
|