mirror of
https://github.com/NapNeko/NapCatQQ.git
synced 2025-07-19 12:03:37 +00:00
Compare commits
14 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
f59248cc5a | ||
![]() |
8647c5c607 | ||
![]() |
6699ff38a1 | ||
![]() |
d79b98bd55 | ||
![]() |
5065a052fb | ||
![]() |
45603bb78c | ||
![]() |
40948995b4 | ||
![]() |
4ccdd8d1d3 | ||
![]() |
30d0174f47 | ||
![]() |
5a986ba25c | ||
![]() |
fe63c24ac3 | ||
![]() |
c384bd6875 | ||
![]() |
dcbff3f569 | ||
![]() |
7d91e05a69 |
@@ -7,10 +7,12 @@
|
|||||||
NapCatQQ (aka 猫猫框架) 是现代化的基于 NTQQ 的 Bot 协议端实现。
|
NapCatQQ (aka 猫猫框架) 是现代化的基于 NTQQ 的 Bot 协议端实现。
|
||||||
|
|
||||||
## 猫猫技能
|
## 猫猫技能
|
||||||
|
- [x] **高性能**:1K+ 群聊数目、20 线程并行发送消息毫无压力
|
||||||
- [x] **多种启动方式**:支持以无头、LiteLoader 插件、仅 QQ GUI 三种方式启动
|
- [x] **多种启动方式**:支持以无头、LiteLoader 插件、仅 QQ GUI 三种方式启动
|
||||||
- [x] **低占用**:无头模式占用资源极低,适合在服务器上运行
|
- [x] **低占用**:无头模式占用资源极低,适合在服务器上运行
|
||||||
- [x] **超多接口**:在实现大部分Onebot接口上扩展了一套私有API
|
- [x] **超多接口**:实现大部分 OneBot 和 go-cqhttp 接口,超多扩展 API
|
||||||
- [x] **WebUI**:自带 WebUI 支持,远程管理更加便捷
|
- [x] **WebUI**:自带 WebUI 支持,远程管理更加便捷
|
||||||
|
- [x] **低故障率**:快速适配最新版本,日常保证 0 Issue
|
||||||
|
|
||||||
## 使用猫猫
|
## 使用猫猫
|
||||||
|
|
||||||
|
@@ -4,7 +4,7 @@
|
|||||||
"name": "NapCatQQ",
|
"name": "NapCatQQ",
|
||||||
"slug": "NapCat.Framework",
|
"slug": "NapCat.Framework",
|
||||||
"description": "高性能的 OneBot 11 协议实现",
|
"description": "高性能的 OneBot 11 协议实现",
|
||||||
"version": "2.2.36",
|
"version": "2.2.43",
|
||||||
"icon": "./logo.png",
|
"icon": "./logo.png",
|
||||||
"authors": [
|
"authors": [
|
||||||
{
|
{
|
||||||
|
@@ -2,7 +2,7 @@
|
|||||||
"name": "napcat",
|
"name": "napcat",
|
||||||
"private": true,
|
"private": true,
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"version": "2.2.36",
|
"version": "2.2.43",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"build:framework": "vite build --mode framework",
|
"build:framework": "vite build --mode framework",
|
||||||
"build:shell": "vite build --mode shell",
|
"build:shell": "vite build --mode shell",
|
||||||
|
@@ -1 +1 @@
|
|||||||
export const napCatVersion = '2.2.36';
|
export const napCatVersion = '2.2.43';
|
||||||
|
@@ -121,51 +121,6 @@ export class NTQQGroupApi {
|
|||||||
return group;
|
return group;
|
||||||
}
|
}
|
||||||
|
|
||||||
async getGroupMemberLatestSendTimeCache(GroupCode: string, uids: string[]) {
|
|
||||||
return this.getGroupMemberLatestSendTime(GroupCode, uids);
|
|
||||||
}
|
|
||||||
|
|
||||||
async getGroupMemberLatestSendTime(GroupCode: string, uids: string[]) {
|
|
||||||
const getData = async (uid: string) => {
|
|
||||||
const msgListWrapper = await this.getLatestMsgByUids(GroupCode, [uid]);
|
|
||||||
if (msgListWrapper.result !== 0 && msgListWrapper.msgList.length < 1) {
|
|
||||||
return undefined;
|
|
||||||
}
|
|
||||||
return { sendUin: msgListWrapper.msgList[0].senderUin, sendTime: msgListWrapper.msgList[0].msgTime };
|
|
||||||
};
|
|
||||||
const PromiseData: Promise<({
|
|
||||||
sendUin: string;
|
|
||||||
sendTime: string;
|
|
||||||
} | undefined)>[] = [];
|
|
||||||
const ret: Map<string, string> = new Map();
|
|
||||||
for (const uid of uids) {
|
|
||||||
PromiseData.push(getData(uid).catch(() => undefined));
|
|
||||||
}
|
|
||||||
const allRet = await runAllWithTimeout(PromiseData, 2500);
|
|
||||||
for (const PromiseDo of allRet) {
|
|
||||||
if (PromiseDo) {
|
|
||||||
ret.set(PromiseDo.sendUin, PromiseDo.sendTime);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return ret;
|
|
||||||
}
|
|
||||||
|
|
||||||
async getLatestMsgByUids(GroupCode: string, uids: string[]) {
|
|
||||||
return await this.context.session.getMsgService().queryMsgsWithFilterEx('0', '0', '0', {
|
|
||||||
chatInfo: {
|
|
||||||
peerUid: GroupCode,
|
|
||||||
chatType: ChatType.KCHATTYPEGROUP,
|
|
||||||
},
|
|
||||||
filterMsgType: [],
|
|
||||||
filterSendersUid: uids,
|
|
||||||
filterMsgToTime: '0',
|
|
||||||
filterMsgFromTime: '0',
|
|
||||||
isReverseOrder: false,
|
|
||||||
isIncludeCurrent: true,
|
|
||||||
pageLimit: 1,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async getGroupMemberAll(GroupCode: string, forced = false) {
|
async getGroupMemberAll(GroupCode: string, forced = false) {
|
||||||
return this.context.session.getGroupService().getAllMemberList(GroupCode, forced);
|
return this.context.session.getGroupService().getAllMemberList(GroupCode, forced);
|
||||||
}
|
}
|
||||||
@@ -202,30 +157,6 @@ export class NTQQGroupApi {
|
|||||||
}
|
}
|
||||||
return member;
|
return member;
|
||||||
}
|
}
|
||||||
|
|
||||||
async getLatestMsg(GroupCode: string, uins: string[]) {
|
|
||||||
const uids: Array<string> = [];
|
|
||||||
for (const uin of uins) {
|
|
||||||
const uid = await this.core.apis.UserApi.getUidByUinV2(uin);
|
|
||||||
if (uid) {
|
|
||||||
uids.push(uid);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return await this.context.session.getMsgService().queryMsgsWithFilterEx('0', '0', '0', {
|
|
||||||
chatInfo: {
|
|
||||||
peerUid: GroupCode,
|
|
||||||
chatType: ChatType.KCHATTYPEGROUP,
|
|
||||||
},
|
|
||||||
filterMsgType: [],
|
|
||||||
filterSendersUid: uids,
|
|
||||||
filterMsgToTime: '0',
|
|
||||||
filterMsgFromTime: '0',
|
|
||||||
isReverseOrder: false,
|
|
||||||
isIncludeCurrent: true,
|
|
||||||
pageLimit: 1,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async getGroupRecommendContactArkJson(GroupCode: string) {
|
async getGroupRecommendContactArkJson(GroupCode: string) {
|
||||||
return this.context.session.getGroupService().getGroupRecommendContactArkJson(GroupCode);
|
return this.context.session.getGroupService().getGroupRecommendContactArkJson(GroupCode);
|
||||||
}
|
}
|
||||||
@@ -383,9 +314,6 @@ export class NTQQGroupApi {
|
|||||||
return this.context.session.getRichMediaService().batchGetGroupFileCount(Gids);
|
return this.context.session.getRichMediaService().batchGetGroupFileCount(Gids);
|
||||||
}
|
}
|
||||||
|
|
||||||
async getGroupIgnoreNotifies() {
|
|
||||||
}
|
|
||||||
|
|
||||||
async getArkJsonGroupShare(GroupCode: string) {
|
async getArkJsonGroupShare(GroupCode: string) {
|
||||||
const ret = await this.core.eventWrapper.callNoListenerEvent(
|
const ret = await this.core.eventWrapper.callNoListenerEvent(
|
||||||
'NodeIKernelGroupService/getGroupRecommendContactArkJson',
|
'NodeIKernelGroupService/getGroupRecommendContactArkJson',
|
||||||
|
@@ -54,19 +54,6 @@ export class NTQQMsgApi {
|
|||||||
return this.context.session.getMsgService().forwardMsg(msgIds, peer, [peer], new Map());
|
return this.context.session.getMsgService().forwardMsg(msgIds, peer, [peer], new Map());
|
||||||
}
|
}
|
||||||
|
|
||||||
async getLatestMsgByUids(peer: Peer, count: number = 20, isReverseOrder: boolean = false) {
|
|
||||||
return await this.context.session.getMsgService().queryMsgsWithFilterEx('0', '0', '0', {
|
|
||||||
chatInfo: peer,
|
|
||||||
filterMsgType: [],
|
|
||||||
filterSendersUid: [],
|
|
||||||
filterMsgToTime: '0',
|
|
||||||
filterMsgFromTime: '0',
|
|
||||||
isReverseOrder: isReverseOrder,//此参数有点离谱 注意不是本次查询的排序 而是全部消历史信息的排序 默认false 从新消息拉取到旧消息
|
|
||||||
isIncludeCurrent: true,
|
|
||||||
pageLimit: count,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async getMsgsByMsgId(peer: Peer | undefined, msgIds: string[] | undefined) {
|
async getMsgsByMsgId(peer: Peer | undefined, msgIds: string[] | undefined) {
|
||||||
if (!peer) throw new Error('peer is not allowed');
|
if (!peer) throw new Error('peer is not allowed');
|
||||||
if (!msgIds) throw new Error('msgIds is not allowed');
|
if (!msgIds) throw new Error('msgIds is not allowed');
|
||||||
@@ -94,11 +81,41 @@ export class NTQQMsgApi {
|
|||||||
pageLimit: 1,
|
pageLimit: 1,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
async queryMsgsWithFilterExWithSeqV2(peer: Peer, msgSeq: string, MsgTime: string, SendersUid: string[]) {
|
||||||
|
return await this.context.session.getMsgService().queryMsgsWithFilterEx('0', '0', msgSeq, {
|
||||||
|
chatInfo: peer,
|
||||||
|
filterMsgType: [],
|
||||||
|
filterSendersUid: SendersUid,
|
||||||
|
filterMsgToTime: MsgTime,
|
||||||
|
filterMsgFromTime: MsgTime,
|
||||||
|
isReverseOrder: false,
|
||||||
|
isIncludeCurrent: true,
|
||||||
|
pageLimit: 1,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
async queryFirstMsgBySeq(peer: Peer, msgSeq: string) {
|
||||||
|
return await this.context.session.getMsgService().queryMsgsWithFilterEx('0', '0', msgSeq, {
|
||||||
|
chatInfo: peer,
|
||||||
|
filterMsgType: [],
|
||||||
|
filterSendersUid: [],
|
||||||
|
filterMsgToTime: '0',
|
||||||
|
filterMsgFromTime: '0',
|
||||||
|
isReverseOrder: true,
|
||||||
|
isIncludeCurrent: true,
|
||||||
|
pageLimit: 1,
|
||||||
|
});
|
||||||
|
}
|
||||||
async getMsgsBySeqAndCount(peer: Peer, seq: string, count: number, desc: boolean, z: boolean) {
|
async getMsgsBySeqAndCount(peer: Peer, seq: string, count: number, desc: boolean, z: boolean) {
|
||||||
return await this.context.session.getMsgService().getMsgsBySeqAndCount(peer, seq, count, desc, z);
|
return await this.context.session.getMsgService().getMsgsBySeqAndCount(peer, seq, count, desc, z);
|
||||||
}
|
}
|
||||||
|
async getMsgBySeqList(peer: Peer, msgSeqList: string[]) {
|
||||||
|
//坏的
|
||||||
|
return await this.context.session.getMsgService().getMsgsBySeqList(peer, msgSeqList);
|
||||||
|
}
|
||||||
|
async getMsgBySeqExFirstMsg(peer: Peer, rootMsgId: string, replyMsgId: string) {
|
||||||
|
let reply = await this.context.session.getMsgService().getSourceOfReplyMsgV2(peer, rootMsgId, replyMsgId);
|
||||||
|
console.log(reply);
|
||||||
|
}
|
||||||
async getMsgExBySeq(peer: Peer, msgSeq: string) {
|
async getMsgExBySeq(peer: Peer, msgSeq: string) {
|
||||||
const DateNow = Math.floor(Date.now() / 1000);
|
const DateNow = Math.floor(Date.now() / 1000);
|
||||||
const filterMsgFromTime = (DateNow - 300).toString();
|
const filterMsgFromTime = (DateNow - 300).toString();
|
||||||
@@ -233,7 +250,7 @@ export class NTQQMsgApi {
|
|||||||
() => true,
|
() => true,
|
||||||
(msgRecords) => msgRecords.some(
|
(msgRecords) => msgRecords.some(
|
||||||
msgRecord => msgRecord.peerUid === destPeer.peerUid
|
msgRecord => msgRecord.peerUid === destPeer.peerUid
|
||||||
&& msgRecord.senderUid === this.core.selfInfo.uid
|
&& msgRecord.senderUid === this.core.selfInfo.uid
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
for (const msg of msgList) {
|
for (const msg of msgList) {
|
||||||
|
@@ -370,7 +370,8 @@ export interface ReplyElement {
|
|||||||
replayMsgSeq: string;
|
replayMsgSeq: string;
|
||||||
replayMsgId: string;
|
replayMsgId: string;
|
||||||
senderUin: string;
|
senderUin: string;
|
||||||
senderUinStr: string;
|
senderUidStr?: string;
|
||||||
|
replyMsgTime?: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface SendReplyElement {
|
export interface SendReplyElement {
|
||||||
|
@@ -24,7 +24,7 @@ import path from 'node:path';
|
|||||||
import fs from 'node:fs';
|
import fs from 'node:fs';
|
||||||
import { getMachineId, hostname, systemName, systemVersion } from '@/common/system';
|
import { getMachineId, hostname, systemName, systemVersion } from '@/common/system';
|
||||||
import { NTEventWrapper } from '@/common/event';
|
import { NTEventWrapper } from '@/common/event';
|
||||||
import { DataSource, GroupMember, SelfInfo } from '@/core/entities';
|
import { DataSource, GroupMember, KickedOffLineInfo, SelfInfo, SelfStatusInfo } from '@/core/entities';
|
||||||
import { NapCatConfigLoader } from '@/core/helper/config';
|
import { NapCatConfigLoader } from '@/core/helper/config';
|
||||||
import os from 'node:os';
|
import os from 'node:os';
|
||||||
import { NodeIKernelGroupListener, NodeIKernelMsgListener, NodeIKernelProfileListener } from '@/core/listeners';
|
import { NodeIKernelGroupListener, NodeIKernelMsgListener, NodeIKernelProfileListener } from '@/core/listeners';
|
||||||
@@ -113,6 +113,11 @@ export class NapCatCore {
|
|||||||
// Renamed from 'InitDataListener'
|
// Renamed from 'InitDataListener'
|
||||||
async initNapCatCoreListeners() {
|
async initNapCatCoreListeners() {
|
||||||
const msgListener = new NodeIKernelMsgListener();
|
const msgListener = new NodeIKernelMsgListener();
|
||||||
|
msgListener.onKickedOffLine = (Info: KickedOffLineInfo) => {
|
||||||
|
// 下线通知
|
||||||
|
this.context.logger.logError('[KickedOffLine] [' + Info.tipsTitle + '] ' + Info.tipsDesc);
|
||||||
|
this.selfInfo.online = false;
|
||||||
|
};
|
||||||
msgListener.onRecvMsg = (msgs) => {
|
msgListener.onRecvMsg = (msgs) => {
|
||||||
msgs.forEach(msg => this.context.logger.logMessage(msg, this.selfInfo));
|
msgs.forEach(msg => this.context.logger.logMessage(msg, this.selfInfo));
|
||||||
};
|
};
|
||||||
@@ -130,10 +135,12 @@ export class NapCatCore {
|
|||||||
Object.assign(this.selfInfo, profile);
|
Object.assign(this.selfInfo, profile);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
profileListener.onSelfStatusChanged = (/* Info: SelfStatusInfo */) => {
|
profileListener.onSelfStatusChanged = (Info: SelfStatusInfo) => {
|
||||||
// if (Info.status == 20) {
|
if (Info.status == 20) {
|
||||||
// log("账号状态变更为离线")
|
this.selfInfo.online = false;
|
||||||
// }
|
this.context.logger.log("账号状态变更为离线");
|
||||||
|
}
|
||||||
|
this.selfInfo.online = true;
|
||||||
};
|
};
|
||||||
this.context.session.getProfileService().addKernelProfileListener(
|
this.context.session.getProfileService().addKernelProfileListener(
|
||||||
proxiedListenerOf(profileListener, this.context.logger),
|
proxiedListenerOf(profileListener, this.context.logger),
|
||||||
|
@@ -54,7 +54,7 @@ abstract class BaseAction<PayloadType, ReturnDataType> {
|
|||||||
public async websocketHandle(payload: PayloadType, echo: any): Promise<OB11Return<ReturnDataType | null>> {
|
public async websocketHandle(payload: PayloadType, echo: any): Promise<OB11Return<ReturnDataType | null>> {
|
||||||
const result = await this.check(payload);
|
const result = await this.check(payload);
|
||||||
if (!result.valid) {
|
if (!result.valid) {
|
||||||
return OB11Response.error(result.message, 1400);
|
return OB11Response.error(result.message, 1400, echo);
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
const resData = await this._handle(payload);
|
const resData = await this._handle(payload);
|
||||||
|
@@ -28,18 +28,14 @@ class DeleteMsg extends BaseAction<Payload, void> {
|
|||||||
const ret = this.core.eventWrapper.registerListen(
|
const ret = this.core.eventWrapper.registerListen(
|
||||||
'NodeIKernelMsgListener/onMsgInfoListUpdate',
|
'NodeIKernelMsgListener/onMsgInfoListUpdate',
|
||||||
1,
|
1,
|
||||||
5000,
|
1000,
|
||||||
(msgs) => !!msgs.find(m => m.msgId === msg.MsgId && m.recallTime !== '0'),
|
(msgs) => !!msgs.find(m => m.msgId === msg.MsgId && m.recallTime !== '0'),
|
||||||
).catch(() => new Promise<undefined>((resolve) => {
|
).catch(() => undefined);
|
||||||
resolve(undefined);
|
|
||||||
}));
|
|
||||||
await this.core.apis.MsgApi.recallMsg(msg.Peer, [msg.MsgId]);
|
await this.core.apis.MsgApi.recallMsg(msg.Peer, [msg.MsgId]);
|
||||||
const data = await ret;
|
const data = await ret;
|
||||||
if (!data) {
|
if (!data) throw new Error('Recall failed');
|
||||||
//throw new Error('Recall failed');
|
} else {
|
||||||
}
|
throw new Error('Recall failed');
|
||||||
//await sleep(100);
|
|
||||||
//await NTQQMsgApi.getMsgsByMsgId(msg.Peer, [msg.MsgId]);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -173,9 +173,18 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
|
|||||||
}
|
}
|
||||||
const { sendElements } = await this.obContext.apis.MsgApi
|
const { sendElements } = await this.obContext.apis.MsgApi
|
||||||
.createSendElements(OB11Data, destPeer);
|
.createSendElements(OB11Data, destPeer);
|
||||||
|
|
||||||
//拆分消息
|
//拆分消息
|
||||||
const MixElement = sendElements.filter(element => element.elementType !== ElementType.FILE && element.elementType !== ElementType.VIDEO);
|
|
||||||
const SingleElement = sendElements.filter(element => element.elementType === ElementType.FILE || element.elementType === ElementType.VIDEO).map(e => [e]);
|
const MixElement = sendElements.filter(
|
||||||
|
element =>
|
||||||
|
element.elementType !== ElementType.FILE && element.elementType !== ElementType.VIDEO && element.elementType !== ElementType.ARK
|
||||||
|
);
|
||||||
|
const SingleElement = sendElements.filter(
|
||||||
|
element =>
|
||||||
|
element.elementType === ElementType.FILE || element.elementType === ElementType.VIDEO || element.elementType === ElementType.ARK
|
||||||
|
).map(e => [e]);
|
||||||
|
|
||||||
const AllElement: SendMessageElement[][] = [MixElement, ...SingleElement].filter(e => e !== undefined && e.length !== 0);
|
const AllElement: SendMessageElement[][] = [MixElement, ...SingleElement].filter(e => e !== undefined && e.length !== 0);
|
||||||
const MsgNodeList: Promise<RawMessage | undefined>[] = [];
|
const MsgNodeList: Promise<RawMessage | undefined>[] = [];
|
||||||
for (const sendElementsSplitElement of AllElement) {
|
for (const sendElementsSplitElement of AllElement) {
|
||||||
|
@@ -271,14 +271,11 @@ export class OneBotGroupApi {
|
|||||||
guildId: '',
|
guildId: '',
|
||||||
peerUid: groupCode,
|
peerUid: groupCode,
|
||||||
};
|
};
|
||||||
const replyMsgList = (await this.core.apis.MsgApi.getMsgExBySeq(peer, msgSeq)).msgList;
|
const replyMsgList = (await this.core.apis.MsgApi.queryFirstMsgBySeq(peer, msgSeq)).msgList;
|
||||||
if (replyMsgList.length < 1) {
|
if (replyMsgList.length < 1) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
const replyMsg = replyMsgList
|
const replyMsg = replyMsgList[0];
|
||||||
.filter(e => e.msgSeq == msgSeq)
|
|
||||||
.sort((a, b) => parseInt(a.msgTime) - parseInt(b.msgTime))[0];
|
|
||||||
//console.log("表情回应消息长度检测", msgSeq, replyMsg.elements);
|
|
||||||
if (!replyMsg) {
|
if (!replyMsg) {
|
||||||
this.core.context.logger.logError('解析表情回应消息失败: 未找到回应消息');
|
this.core.context.logger.logError('解析表情回应消息失败: 未找到回应消息');
|
||||||
return undefined;
|
return undefined;
|
||||||
|
@@ -219,7 +219,7 @@ export class OneBotMsgApi {
|
|||||||
peerUid: msg.peerUid,
|
peerUid: msg.peerUid,
|
||||||
guildId: '',
|
guildId: '',
|
||||||
};
|
};
|
||||||
if (!records) {
|
if (!records || !element.replyMsgTime || !element.senderUidStr) {
|
||||||
this.core.context.logger.logError('获取不到引用的消息', element.replayMsgSeq);
|
this.core.context.logger.logError('获取不到引用的消息', element.replayMsgSeq);
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
@@ -234,29 +234,13 @@ export class OneBotMsgApi {
|
|||||||
if (records.peerUin === '284840486') {
|
if (records.peerUin === '284840486') {
|
||||||
return createReplyData(records.msgId);
|
return createReplyData(records.msgId);
|
||||||
}
|
}
|
||||||
|
let replyMsg = (await this.core.apis.MsgApi.queryMsgsWithFilterExWithSeqV2(peer, element.replayMsgSeq, element.replyMsgTime, [element.senderUidStr]))
|
||||||
let replyMsg: RawMessage | undefined;
|
.msgList.find(msg => msg.msgRandom === records.msgRandom);
|
||||||
// Attempt 1
|
|
||||||
replyMsg = (await this.core.apis.MsgApi.getMsgsBySeqAndCount(peer,element.replayMsgSeq, 1, true, true))
|
|
||||||
.msgList
|
|
||||||
.find(msg => msg.msgRandom === records.msgRandom);
|
|
||||||
|
|
||||||
if (!replyMsg || records.msgRandom !== replyMsg.msgRandom) {
|
if (!replyMsg || records.msgRandom !== replyMsg.msgRandom) {
|
||||||
// Attempt 2
|
this.core.context.logger.logError('获取不到引用的消息', element.replayMsgSeq);
|
||||||
replyMsg = (await this.core.apis.MsgApi.getSingleMsg(peer, element.replayMsgSeq)).msgList[0];
|
return null;
|
||||||
|
|
||||||
if (!replyMsg || records.msgRandom !== replyMsg.msgRandom) {
|
|
||||||
// Attempt 3
|
|
||||||
const replyMsgList = (await this.core.apis.MsgApi.getMsgExBySeq(peer, records.msgSeq)).msgList;
|
|
||||||
if (replyMsgList.length < 1) {
|
|
||||||
this.core.context.logger.logError('回复消息消息验证失败', element.replayMsgSeq);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
replyMsg = replyMsgList.filter(e => e.msgSeq == records.msgSeq)
|
|
||||||
.sort((a, b) => parseInt(a.msgTime) - parseInt(b.msgTime))[0];
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return createReplyData(replyMsg.msgId);
|
return createReplyData(replyMsg.msgId);
|
||||||
},
|
},
|
||||||
|
|
||||||
@@ -725,6 +709,9 @@ export class OneBotMsgApi {
|
|||||||
message_format: messagePostFormat === 'string' ? 'string' : 'array',
|
message_format: messagePostFormat === 'string' ? 'string' : 'array',
|
||||||
post_type: this.core.selfInfo.uin == msg.senderUin ? EventType.MESSAGE_SENT : EventType.MESSAGE,
|
post_type: this.core.selfInfo.uin == msg.senderUin ? EventType.MESSAGE_SENT : EventType.MESSAGE,
|
||||||
};
|
};
|
||||||
|
if (this.core.selfInfo.uin == msg.senderUin) {
|
||||||
|
resMsg.message_sent_type = 'self';
|
||||||
|
}
|
||||||
if (msg.chatType == ChatType.KCHATTYPEGROUP) {
|
if (msg.chatType == ChatType.KCHATTYPEGROUP) {
|
||||||
resMsg.sub_type = 'normal'; // 这里go-cqhttp是group,而onebot11标准是normal, 蛋疼
|
resMsg.sub_type = 'normal'; // 这里go-cqhttp是group,而onebot11标准是normal, 蛋疼
|
||||||
resMsg.group_id = parseInt(msg.peerUin);
|
resMsg.group_id = parseInt(msg.peerUin);
|
||||||
|
@@ -242,31 +242,31 @@ export class NapCatOneBot11Adapter {
|
|||||||
const msgListener = new NodeIKernelMsgListener();
|
const msgListener = new NodeIKernelMsgListener();
|
||||||
|
|
||||||
msgListener.onRecvSysMsg = async msg => {
|
msgListener.onRecvSysMsg = async msg => {
|
||||||
const sysMsg = SysMessage.fromBinary(Uint8Array.from(msg));
|
// const sysMsg = SysMessage.fromBinary(Uint8Array.from(msg));
|
||||||
if (sysMsg.msgSpec.length === 0) {
|
// if (sysMsg.msgSpec.length === 0) {
|
||||||
return;
|
// return;
|
||||||
}
|
// }
|
||||||
const { msgType, subType, subSubType } = sysMsg.msgSpec[0];
|
// const { msgType, subType, subSubType } = sysMsg.msgSpec[0];
|
||||||
if (msgType === 732 && subType === 16 && subSubType === 16) {
|
// if (msgType === 732 && subType === 16 && subSubType === 16) {
|
||||||
const greyTip = GreyTipWrapper.fromBinary(Uint8Array.from(sysMsg.bodyWrapper!.wrappedBody.slice(7)));
|
// const greyTip = GreyTipWrapper.fromBinary(Uint8Array.from(sysMsg.bodyWrapper!.wrappedBody.slice(7)));
|
||||||
if (greyTip.subTypeId === 36) {
|
// if (greyTip.subTypeId === 36) {
|
||||||
const emojiLikeToOthers = EmojiLikeToOthersWrapper1
|
// const emojiLikeToOthers = EmojiLikeToOthersWrapper1
|
||||||
.fromBinary(greyTip.rest)
|
// .fromBinary(greyTip.rest)
|
||||||
.wrapper!
|
// .wrapper!
|
||||||
.body!;
|
// .body!;
|
||||||
if (emojiLikeToOthers.attributes?.operation !== 1) { // Un-like
|
// if (emojiLikeToOthers.attributes?.operation !== 1) { // Un-like
|
||||||
return;
|
// return;
|
||||||
}
|
// }
|
||||||
const eventOrEmpty = await this.apis.GroupApi.createGroupEmojiLikeEvent(
|
// const eventOrEmpty = await this.apis.GroupApi.createGroupEmojiLikeEvent(
|
||||||
greyTip.groupCode.toString(),
|
// greyTip.groupCode.toString(),
|
||||||
await this.core.apis.UserApi.getUinByUidV2(emojiLikeToOthers.attributes!.senderUid),
|
// await this.core.apis.UserApi.getUinByUidV2(emojiLikeToOthers.attributes!.senderUid),
|
||||||
emojiLikeToOthers.msgSpec!.msgSeq.toString(),
|
// emojiLikeToOthers.msgSpec!.msgSeq.toString(),
|
||||||
emojiLikeToOthers.attributes!.emojiId,
|
// emojiLikeToOthers.attributes!.emojiId,
|
||||||
);
|
// );
|
||||||
// eslint-disable-next-line @typescript-eslint/no-unused-expressions
|
// // eslint-disable-next-line @typescript-eslint/no-unused-expressions
|
||||||
eventOrEmpty && await this.networkManager.emitEvent(eventOrEmpty);
|
// eventOrEmpty && await this.networkManager.emitEvent(eventOrEmpty);
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
};
|
};
|
||||||
|
|
||||||
msgListener.onInputStatusPush = async data => {
|
msgListener.onInputStatusPush = async data => {
|
||||||
|
@@ -131,23 +131,24 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
|
|||||||
private async handleMessage(message: any) {
|
private async handleMessage(message: any) {
|
||||||
let receiveData: { action: ActionName, params?: any, echo?: any } = { action: ActionName.Unknown, params: {} };
|
let receiveData: { action: ActionName, params?: any, echo?: any } = { action: ActionName.Unknown, params: {} };
|
||||||
let echo = undefined;
|
let echo = undefined;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
try {
|
receiveData = JSON.parse(message.toString());
|
||||||
receiveData = JSON.parse(message.toString());
|
echo = receiveData.echo;
|
||||||
echo = receiveData.echo;
|
this.logger.logDebug('[OneBot] [WebSocket Client] 收到正向Websocket消息', receiveData);
|
||||||
this.logger.logDebug('[OneBot] [WebSocket Client] 收到正向Websocket消息', receiveData);
|
|
||||||
} catch (e) {
|
|
||||||
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
|
||||||
const retdata = await this.actions.get(receiveData.action)
|
|
||||||
?.websocketHandle(receiveData.params, echo ?? '');
|
|
||||||
const packet = Object.assign({}, retdata);
|
|
||||||
this.checkStateAndReply<any>(packet);
|
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
this.logger.logError('[OneBot] [WebSocket Client] 发生错误', e);
|
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo));
|
||||||
this.checkStateAndReply<any>(OB11Response.error('不支持的api ' + receiveData.action, 1404, echo));
|
return;
|
||||||
}
|
}
|
||||||
|
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
||||||
|
const action = this.actions.get(receiveData.action);
|
||||||
|
if (!action) {
|
||||||
|
this.logger.logError('[OneBot] [WebSocket Client] 发生错误', '不支持的api ' + receiveData.action);
|
||||||
|
this.checkStateAndReply<any>(OB11Response.error('不支持的api ' + receiveData.action, 1404, echo));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
const retdata = await action.websocketHandle(receiveData.params, echo ?? '');
|
||||||
|
const packet = Object.assign({}, retdata);
|
||||||
|
this.checkStateAndReply<any>(packet);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -146,22 +146,23 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
|
|||||||
let receiveData: { action: ActionName, params?: any, echo?: any } = { action: ActionName.Unknown, params: {} };
|
let receiveData: { action: ActionName, params?: any, echo?: any } = { action: ActionName.Unknown, params: {} };
|
||||||
let echo = undefined;
|
let echo = undefined;
|
||||||
try {
|
try {
|
||||||
try {
|
receiveData = JSON.parse(message.toString());
|
||||||
receiveData = JSON.parse(message.toString());
|
echo = receiveData.echo;
|
||||||
echo = receiveData.echo;
|
//this.logger.logDebug('收到正向Websocket消息', receiveData);
|
||||||
//this.logger.logDebug('收到正向Websocket消息', receiveData);
|
|
||||||
} catch (e) {
|
|
||||||
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo), wsClient);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
|
||||||
const retdata = await this.actions.get(receiveData.action)?.websocketHandle(receiveData.params, echo ?? '');
|
|
||||||
const packet = Object.assign({}, retdata);
|
|
||||||
this.checkStateAndReply<any>(packet, wsClient);
|
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
this.checkStateAndReply<any>(OB11Response.error('不支持的api ' + receiveData.action, 1404, echo), wsClient);
|
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo), wsClient);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
||||||
|
const action = this.actions.get(receiveData.action);
|
||||||
|
if (!action) {
|
||||||
|
this.logger.logError('[OneBot] [WebSocket Client] 发生错误', '不支持的api ' + receiveData.action);
|
||||||
|
this.checkStateAndReply<any>(OB11Response.error('不支持的api ' + receiveData.action, 1404, echo), wsClient);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
const retdata = await action.websocketHandle(receiveData.params, echo ?? '');
|
||||||
|
const packet = Object.assign({}, retdata);
|
||||||
|
this.checkStateAndReply<any>(packet, wsClient);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -8,6 +8,7 @@ export enum OB11MessageType {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export interface OB11Message {
|
export interface OB11Message {
|
||||||
|
message_sent_type?: string;
|
||||||
target_id?: number; // 自己发送的消息才有此字段
|
target_id?: number; // 自己发送的消息才有此字段
|
||||||
self_id?: number,
|
self_id?: number,
|
||||||
time: number,
|
time: number,
|
||||||
|
@@ -30,7 +30,7 @@ async function onSettingWindowCreated(view: Element) {
|
|||||||
SettingItem(
|
SettingItem(
|
||||||
'<span id="napcat-update-title">Napcat</span>',
|
'<span id="napcat-update-title">Napcat</span>',
|
||||||
undefined,
|
undefined,
|
||||||
SettingButton('V2.2.36', 'napcat-update-button', 'secondary'),
|
SettingButton('V2.2.43', 'napcat-update-button', 'secondary'),
|
||||||
),
|
),
|
||||||
]),
|
]),
|
||||||
SettingList([
|
SettingList([
|
||||||
|
@@ -164,7 +164,7 @@ async function onSettingWindowCreated(view) {
|
|||||||
SettingItem(
|
SettingItem(
|
||||||
'<span id="napcat-update-title">Napcat</span>',
|
'<span id="napcat-update-title">Napcat</span>',
|
||||||
void 0,
|
void 0,
|
||||||
SettingButton("V2.2.36", "napcat-update-button", "secondary")
|
SettingButton("V2.2.43", "napcat-update-button", "secondary")
|
||||||
)
|
)
|
||||||
]),
|
]),
|
||||||
SettingList([
|
SettingList([
|
||||||
|
Reference in New Issue
Block a user