Compare commits

..

14 Commits

Author SHA1 Message Date
linyuchen
128091dff9 chore: ver 3.20.0 2024-03-27 21:29:56 +08:00
linyuchen
c7b6fd89fd fix: bot join group event 2024-03-27 21:27:34 +08:00
linyuchen
b55f35549d feat: report forward msg,get_forward_msg 2024-03-27 20:07:56 +08:00
linyuchen
ca0a6cfb22 chore: ver 3.19.4 2024-03-25 19:04:30 +08:00
linyuchen
3303b30c4c Merge branch 'main' into dev 2024-03-25 19:01:34 +08:00
linyuchen
429d8deb5c feat: gocq api router add send_forward_msg 2024-03-25 19:01:28 +08:00
linyuchen
48f12fc30b fix: pic subType 2024-03-25 18:52:15 +08:00
linyuchen
41f0e8f574 Merge pull request #159 from MisakaTAT/main
feat: added an gocqhttp extended api send_forward_msg
2024-03-25 18:11:05 +08:00
MisakaTAT
cd50df3a56 feat: added an gocqhttp extended api send_forward_msg 2024-03-25 17:51:04 +08:00
linyuchen
4461c7ed47 fix: group card event old_card 2024-03-25 15:07:35 +08:00
linyuchen
e5f4992eb3 feat: market face 2024-03-24 21:32:25 +08:00
linyuchen
468f1710b9 fix: group member role not sync 2024-03-24 20:21:18 +08:00
linyuchen
626d445dc3 chore: ver 3.19.2 2024-03-24 12:10:23 +08:00
linyuchen
b413a224be fix: send forward 2024-03-24 12:02:56 +08:00
18 changed files with 253 additions and 53 deletions

View File

@@ -1,10 +1,10 @@
{ {
"manifest_version": 4, "manifest_version": 4,
"type": "extension", "type": "extension",
"name": "LLOneBot v3.19.1", "name": "LLOneBot v3.20.0",
"slug": "LLOneBot", "slug": "LLOneBot",
"description": "LiteLoaderQQNT的OneBotApi,不支持商店在线更新", "description": "使你的NTQQ支持OneBot11协议进行QQ机器人开发, 不支持商店在线更新",
"version": "3.19.1", "version": "3.20.0",
"icon": "./icon.jpg", "icon": "./icon.jpg",
"authors": [ "authors": [
{ {

View File

@@ -4,28 +4,36 @@ import {BrowserWindow, dialog, ipcMain} from 'electron';
import * as fs from 'node:fs'; import * as fs from 'node:fs';
import {Config} from "../common/types"; import {Config} from "../common/types";
import { import {
CHANNEL_CHECK_VERSION,
CHANNEL_ERROR, CHANNEL_ERROR,
CHANNEL_GET_CONFIG, CHANNEL_GET_CONFIG,
CHANNEL_LOG, CHANNEL_LOG,
CHANNEL_CHECK_VERSION,
CHANNEL_SELECT_FILE, CHANNEL_SELECT_FILE,
CHANNEL_SET_CONFIG, CHANNEL_SET_CONFIG,
CHANNEL_UPDATE, CHANNEL_UPDATE,
} from "../common/channels"; } from "../common/channels";
import {ob11WebsocketServer} from "../onebot11/server/ws/WebsocketServer"; import {ob11WebsocketServer} from "../onebot11/server/ws/WebsocketServer";
import {DATA_DIR, wrapText} from "../common/utils"; import {DATA_DIR} from "../common/utils";
import { import {
friendRequests, friendRequests,
getFriend, getFriend,
getGroup, getGroup,
getGroupMember, groups, getGroupMember,
llonebotError, llonebotError,
refreshGroupMembers, refreshGroupMembers,
selfInfo, uidMaps selfInfo,
uidMaps
} from "../common/data"; } from "../common/data";
import {hookNTQQApiCall, hookNTQQApiReceive, ReceiveCmdS, registerReceiveHook} from "../ntqqapi/hook"; import {hookNTQQApiCall, hookNTQQApiReceive, ReceiveCmdS, registerReceiveHook} from "../ntqqapi/hook";
import {OB11Constructor} from "../onebot11/constructor"; import {OB11Constructor} from "../onebot11/constructor";
import {ChatType, FriendRequestNotify, GroupNotifies, GroupNotifyTypes, RawMessage} from "../ntqqapi/types"; import {
ChatType,
FriendRequestNotify,
GroupMemberRole,
GroupNotifies,
GroupNotifyTypes,
RawMessage
} from "../ntqqapi/types";
import {ob11HTTPServer} from "../onebot11/server/http"; import {ob11HTTPServer} from "../onebot11/server/http";
import {OB11FriendRecallNoticeEvent} from "../onebot11/event/notice/OB11FriendRecallNoticeEvent"; import {OB11FriendRecallNoticeEvent} from "../onebot11/event/notice/OB11FriendRecallNoticeEvent";
import {OB11GroupRecallNoticeEvent} from "../onebot11/event/notice/OB11GroupRecallNoticeEvent"; import {OB11GroupRecallNoticeEvent} from "../onebot11/event/notice/OB11GroupRecallNoticeEvent";
@@ -285,6 +293,7 @@ function onLoad() {
log("变动管理员获取成功") log("变动管理员获取成功")
groupAdminNoticeEvent.user_id = parseInt(member1.uin); groupAdminNoticeEvent.user_id = parseInt(member1.uin);
groupAdminNoticeEvent.sub_type = notify.type == GroupNotifyTypes.ADMIN_UNSET ? "unset" : "set"; groupAdminNoticeEvent.sub_type = notify.type == GroupNotifyTypes.ADMIN_UNSET ? "unset" : "set";
// member1.role = notify.type == GroupNotifyTypes.ADMIN_SET ? GroupMemberRole.admin : GroupMemberRole.normal;
postOB11Event(groupAdminNoticeEvent, true); postOB11Event(groupAdminNoticeEvent, true);
} else { } else {
log("获取群通知的成员信息失败", notify, getGroup(notify.group.groupCode)); log("获取群通知的成员信息失败", notify, getGroup(notify.group.groupCode));

View File

@@ -47,7 +47,7 @@ export class NTQQFileApi {
} }
// 上传文件到QQ的文件夹 // 上传文件到QQ的文件夹
static async uploadFile(filePath: string, elementType: ElementType = ElementType.PIC) { static async uploadFile(filePath: string, elementType: ElementType = ElementType.PIC, elementSubType: number = 0) {
const md5 = await NTQQFileApi.getFileMd5(filePath); const md5 = await NTQQFileApi.getFileMd5(filePath);
let ext = (await NTQQFileApi.getFileType(filePath))?.ext let ext = (await NTQQFileApi.getFileType(filePath))?.ext
if (ext) { if (ext) {
@@ -66,7 +66,7 @@ export class NTQQFileApi {
md5HexStr: md5, md5HexStr: md5,
fileName: fileName, fileName: fileName,
elementType: elementType, elementType: elementType,
elementSubType: 0, elementSubType,
thumbSize: 0, thumbSize: 0,
needCreate: true, needCreate: true,
downloadType: 1, downloadType: 1,
@@ -81,7 +81,8 @@ export class NTQQFileApi {
md5, md5,
fileName, fileName,
path: mediaPath, path: mediaPath,
fileSize fileSize,
ext
} }
} }

View File

@@ -16,6 +16,17 @@ export interface Peer {
} }
export class NTQQMsgApi { export class NTQQMsgApi {
static async getMultiMsg(peer: Peer, rootMsgId: string, parentMsgId: string) {
return await callNTQQApi<GeneralCallResult & {msgList: RawMessage[]}>({
methodName: NTQQApiMethod.GET_MULTI_MSG,
args: [{
peer,
rootMsgId,
parentMsgId
}, null]
})
}
static async activateGroupChat(groupCode: string) { static async activateGroupChat(groupCode: string) {
// await this.fetchRecentContact(); // await this.fetchRecentContact();
// await sleep(500); // await sleep(500);

View File

@@ -62,32 +62,32 @@ export class SendMsgElementConstructor {
} }
} }
static async pic(picPath: string, summary: string = ""): Promise<SendPicElement> { static async pic(picPath: string, summary: string = "", subType: 0|1=0): Promise<SendPicElement> {
const {md5, fileName, path, fileSize} = await NTQQFileApi.uploadFile(picPath, ElementType.PIC); const {md5, fileName, path, fileSize, ext} = await NTQQFileApi.uploadFile(picPath, ElementType.PIC, subType);
if (fileSize === 0) { if (fileSize === 0) {
throw "文件异常大小为0"; throw "文件异常大小为0";
} }
const imageSize = await NTQQFileApi.getImageSize(picPath); const imageSize = await NTQQFileApi.getImageSize(picPath);
const picElement = { const picElement = {
md5HexStr: md5, md5HexStr: md5,
fileSize: fileSize, fileSize: fileSize.toString(),
picWidth: imageSize.width, picWidth: imageSize.width,
picHeight: imageSize.height, picHeight: imageSize.height,
fileName: fileName, fileName: md5 + ext,
sourcePath: path, sourcePath: path,
original: true, original: true,
picType: isGIF(picPath) ? PicType.gif : PicType.jpg, picType: isGIF(picPath) ? PicType.gif : PicType.jpg,
picSubType: 0, picSubType: subType,
fileUuid: "", fileUuid: "",
fileSubId: "", fileSubId: "",
thumbFileSize: 0, thumbFileSize: 0,
summary, summary
}; };
log("图片信息", picElement)
return { return {
elementType: ElementType.PIC, elementType: ElementType.PIC,
elementId: "", elementId: "",
picElement picElement,
}; };
} }
@@ -118,7 +118,7 @@ export class SendMsgElementConstructor {
let thumb = path.replace(`${pathLib.sep}Ori${pathLib.sep}`, `${pathLib.sep}Thumb${pathLib.sep}`) let thumb = path.replace(`${pathLib.sep}Ori${pathLib.sep}`, `${pathLib.sep}Thumb${pathLib.sep}`)
thumb = pathLib.dirname(thumb) thumb = pathLib.dirname(thumb)
// log("thumb 目录", thumb) // log("thumb 目录", thumb)
let videoInfo ={ let videoInfo = {
width: 1920, height: 1080, width: 1920, height: 1080,
time: 15, time: 15,
format: "mp4", format: "mp4",
@@ -128,7 +128,7 @@ export class SendMsgElementConstructor {
try { try {
videoInfo = await getVideoInfo(path); videoInfo = await getVideoInfo(path);
log("视频信息", videoInfo) log("视频信息", videoInfo)
}catch (e) { } catch (e) {
log("获取视频信息失败", e) log("获取视频信息失败", e)
} }
const createThumb = new Promise<string>((resolve, reject) => { const createThumb = new Promise<string>((resolve, reject) => {

View File

@@ -2,7 +2,7 @@ import {BrowserWindow} from 'electron';
import {NTQQApiClass} from "./ntcall"; import {NTQQApiClass} from "./ntcall";
import {NTQQMsgApi, sendMessagePool} from "./api/msg" import {NTQQMsgApi, sendMessagePool} from "./api/msg"
import {ChatType, Group, GroupMember, RawMessage, User} from "./types"; import {ChatType, Group, GroupMember, RawMessage, User} from "./types";
import {friends, groups, selfInfo, tempGroupCodeMap, uidMaps} from "../common/data"; import {friends, getGroupMember, groups, selfInfo, tempGroupCodeMap, uidMaps} from "../common/data";
import {OB11GroupDecreaseEvent} from "../onebot11/event/notice/OB11GroupDecreaseEvent"; import {OB11GroupDecreaseEvent} from "../onebot11/event/notice/OB11GroupDecreaseEvent";
import {v4 as uuidv4} from "uuid" import {v4 as uuidv4} from "uuid"
import {postOB11Event} from "../onebot11/server/postOB11Event"; import {postOB11Event} from "../onebot11/server/postOB11Event";
@@ -244,8 +244,8 @@ async function processGroupEvent(payload: {groupList: Group[]}) {
} }
for (const member of oldMembers) { for (const member of oldMembers) {
if (!newMembersSet.has(member.uin)) { if (!newMembersSet.has(member.uin) && member.uin != selfInfo.uin) {
postOB11Event(new OB11GroupDecreaseEvent(parseInt(group.groupCode), parseInt(member.uin))); postOB11Event(new OB11GroupDecreaseEvent(parseInt(group.groupCode), parseInt(member.uin), parseInt(member.uin), "leave"));
break; break;
} }
} }
@@ -263,6 +263,8 @@ async function processGroupEvent(payload: {groupList: Group[]}) {
// 群列表变动 // 群列表变动
registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROUPS, (payload) => { registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROUPS, (payload) => {
// updateType 3是群列表变动2是群成员变动
// log("群列表变动", payload.updateType, payload.groupList)
if (payload.updateType != 2) { if (payload.updateType != 2) {
updateGroups(payload.groupList).then(); updateGroups(payload.groupList).then();
} else { } else {
@@ -272,6 +274,8 @@ registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROU
} }
}) })
registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROUPS_STORE, (payload) => { registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROUPS_STORE, (payload) => {
// updateType 3是群列表变动2是群成员变动
// log("群列表变动", payload.updateType, payload.groupList)
if (payload.updateType != 2) { if (payload.updateType != 2) {
updateGroups(payload.groupList).then(); updateGroups(payload.groupList).then();
} else { } else {
@@ -281,10 +285,16 @@ registerReceiveHook<{ groupList: Group[], updateType: number }>(ReceiveCmdS.GROU
} }
}) })
registerReceiveHook<{groupCode: string, dataSource: number, members: Set<GroupMember>}>(ReceiveCmdS.GROUP_MEMBER_INFO_UPDATE, (payload) => { registerReceiveHook<{groupCode: string, dataSource: number, members: Set<GroupMember>}>(ReceiveCmdS.GROUP_MEMBER_INFO_UPDATE, async (payload) => {
const groupCode = payload.groupCode; const groupCode = payload.groupCode;
const members = Array.from(payload.members.values()); const members = Array.from(payload.members.values());
// log("群成员变动", groupCode, payload.members.keys(), payload.members.values()) // log("群成员信息变动", groupCode, members)
for(const member of members) {
const existMember = await getGroupMember(groupCode, member.uin);
if (existMember){
Object.assign(existMember, member);
}
}
// const existGroup = groups.find(g => g.groupCode == groupCode); // const existGroup = groups.find(g => g.groupCode == groupCode);
// if (existGroup) { // if (existGroup) {
// log("对比群成员", existGroup.members, members) // log("对比群成员", existGroup.members, members)

View File

@@ -25,6 +25,8 @@ export enum NTQQApiMethod {
ADD_ACTIVE_CHAT = "nodeIKernelMsgService/getAioFirstViewLatestMsgsAndAddActiveChat", // 激活群助手内的聊天窗口,这样才能收到消息 ADD_ACTIVE_CHAT = "nodeIKernelMsgService/getAioFirstViewLatestMsgsAndAddActiveChat", // 激活群助手内的聊天窗口,这样才能收到消息
HISTORY_MSG_998 = "nodeIKernelMsgService/getMsgsIncludeSelfAndAddActiveChat", HISTORY_MSG_998 = "nodeIKernelMsgService/getMsgsIncludeSelfAndAddActiveChat",
HISTORY_MSG = "nodeIKernelMsgService/getMsgsIncludeSelf", HISTORY_MSG = "nodeIKernelMsgService/getMsgsIncludeSelf",
GET_MULTI_MSG = "nodeIKernelMsgService/getMultiMsg",
LIKE_FRIEND = "nodeIKernelProfileLikeService/setBuddyProfileLike", LIKE_FRIEND = "nodeIKernelProfileLikeService/setBuddyProfileLike",
SELF_INFO = "fetchAuthData", SELF_INFO = "fetchAuthData",
FRIENDS = "nodeIKernelBuddyService/getBuddyList", FRIENDS = "nodeIKernelBuddyService/getBuddyList",

View File

@@ -1,4 +1,5 @@
import {GroupMemberRole} from "./group"; import {GroupMemberRole} from "./group";
import exp from "constants";
export enum ElementType { export enum ElementType {
TEXT = 1, TEXT = 1,
@@ -48,24 +49,29 @@ export enum PicType {
jpg = 1000 jpg = 1000
} }
export enum PicSubType {
normal = 0, // 普通图片,大图
face = 1 // 表情包小图
}
export interface SendPicElement { export interface SendPicElement {
elementType: ElementType.PIC, elementType: ElementType.PIC,
elementId: "", elementId: "",
picElement: { picElement: {
md5HexStr: string, md5HexStr: string,
fileSize: number, fileSize: number | string,
picWidth: number, picWidth: number,
picHeight: number, picHeight: number,
fileName: string, fileName: string,
sourcePath: string, sourcePath: string,
original: boolean, original: boolean,
picType: PicType, picType: PicType,
picSubType: number, picSubType: PicSubType,
fileUuid: string, fileUuid: string,
fileSubId: string, fileSubId: string,
thumbFileSize: number, thumbFileSize: number,
summary: string, summary: string,
} },
} }
export interface SendReplyElement { export interface SendReplyElement {
@@ -199,7 +205,7 @@ export interface GrayTipElement {
xmlElement: { xmlElement: {
content: string; content: string;
}, },
jsonGrayTipElement:{ jsonGrayTipElement: {
jsonStr: string; jsonStr: string;
} }
} }
@@ -209,6 +215,45 @@ export interface FaceElement {
faceType: 1 faceType: 1
} }
export interface MarketFaceElement {
"itemType": 6,
"faceInfo": 1,
"emojiPackageId": 203875,
"subType": 3,
"mediaType": 0,
"imageWidth": 200,
"imageHeight": 200,
"faceName": string,
"emojiId": "094d53bd1c9ac5d35d04b08e8a6c992c",
"key": "a8b1dd0aebc8d910",
"param": null,
"mobileParam": null,
"sourceType": null,
"startTime": null,
"endTime": null,
"emojiType": 1,
"hasIpProduct": null,
"voiceItemHeightArr": null,
"sourceName": null,
"sourceJumpUrl": null,
"sourceTypeName": null,
"backColor": null,
"volumeColor": null,
"staticFacePath": "E:\\SystemDocuments\\QQ\\721011692\\nt_qq\\nt_data\\Emoji\\marketface\\203875\\094d53bd1c9ac5d35d04b08e8a6c992c_aio.png",
"dynamicFacePath": "E:\\SystemDocuments\\QQ\\721011692\\nt_qq\\nt_data\\Emoji\\marketface\\203875\\094d53bd1c9ac5d35d04b08e8a6c992c",
"supportSize": [
{
"width": 300,
"height": 300
},
{
"width": 200,
"height": 200
}
],
"apngSupportSize": null
}
export interface VideoElement { export interface VideoElement {
"filePath": string, "filePath": string,
"fileName": string, "fileName": string,
@@ -234,6 +279,34 @@ export interface VideoElement {
"sourceVideoCodecFormat"?: number "sourceVideoCodecFormat"?: number
} }
export interface MarkdownElement {
content: string,
}
export interface InlineKeyboardElementRowButton{
"id": "",
"label": string,
"visitedLabel": string,
"style": 1, // 未知
"type": 2, // 未知
"clickLimit": 0, // 未知
"unsupportTips": "请升级新版手机QQ",
"data": string,
"atBotShowChannelList": false,
"permissionType": 2,
"specifyRoleIds": [],
"specifyTinyids": [],
"isReply": false,
"anchor": 0,
"enter": false,
"subscribeDataTemplateIds": []
}
export interface InlineKeyboardElement {
rows: [{
buttons: InlineKeyboardElementRowButton[]
}]
}
export interface TipAioOpGrayTipElement { // 这是什么提示来着? export interface TipAioOpGrayTipElement { // 这是什么提示来着?
operateType: number, operateType: number,
peerUid: string, peerUid: string,
@@ -242,6 +315,7 @@ export interface TipAioOpGrayTipElement { // 这是什么提示来着?
export enum TipGroupElementType { export enum TipGroupElementType {
memberIncrease = 1, memberIncrease = 1,
kicked = 3, // 被移出群
ban = 8 ban = 8
} }
@@ -252,7 +326,7 @@ export interface TipGroupElement {
"memberUid": string, "memberUid": string,
"memberNick": string, "memberNick": string,
"memberRemark": string, "memberRemark": string,
"adminUid": string, // 同意加群的管理员uid "adminUid": string,
"adminNick": string, "adminNick": string,
"adminRemark": string, "adminRemark": string,
"createGroup": null, "createGroup": null,
@@ -284,6 +358,11 @@ export interface TipGroupElement {
} }
} }
export interface MultiForwardMsgElement{
xmlContent: string, // xml格式的消息内容
resId: string,
fileName: string,
}
export interface RawMessage { export interface RawMessage {
msgId: string; msgId: string;
@@ -321,5 +400,9 @@ export interface RawMessage {
faceElement: FaceElement; faceElement: FaceElement;
videoElement: VideoElement; videoElement: VideoElement;
fileElement: FileElement; fileElement: FileElement;
marketFaceElement: MarketFaceElement;
inlineKeyboardElement: InlineKeyboardElement;
markdownElement: MarkdownElement;
multiForwardMsgElement: MultiForwardMsgElement;
}[]; }[];
} }

View File

@@ -0,0 +1,39 @@
import BaseAction from "../BaseAction";
import {OB11ForwardMessage, OB11Message, OB11MessageData} from "../../types";
import {NTQQMsgApi, Peer} from "../../../ntqqapi/api";
import {dbUtil} from "../../../common/db";
import {OB11Constructor} from "../../constructor";
import {ActionName} from "../types";
interface Payload {
message_id: string; // long msg id
}
interface Response{
messages: (OB11Message & {content: OB11MessageData})[]
}
export class GoCQHTTGetForwardMsgAction extends BaseAction<Payload, any>{
actionName = ActionName.GoCQHTTP_GetForwardMsg
protected async _handle(payload: Payload): Promise<any> {
const rootMsg = await dbUtil.getMsgByLongId(payload.message_id)
if (!rootMsg){
throw Error("msg not found")
}
let data = await NTQQMsgApi.getMultiMsg({chatType: rootMsg.chatType, peerUid: rootMsg.peerUid}, rootMsg.msgId, rootMsg.msgId)
if (data.result !== 0){
throw Error("找不到相关的聊天记录" + data.errMsg)
}
let msgList = data.msgList
let messages = await Promise.all(msgList.map(async msg => {
let resMsg = await OB11Constructor.message(msg)
resMsg.message_id = await dbUtil.addMsg(msg);
return resMsg
}))
messages.map(msg => {
(<OB11ForwardMessage>msg).content = msg.message;
delete msg.message;
})
return {messages}
}
}

View File

@@ -1,18 +1,20 @@
import SendMsg from "../msg/SendMsg"; import SendMsg, {convertMessage2List} from "../msg/SendMsg";
import {OB11PostSendMsg} from "../../types"; import {OB11PostSendMsg} from "../../types";
import {ActionName} from "../types"; import {ActionName} from "../types";
export class GoCQHTTPSendGroupForwardMsg extends SendMsg { export class GoCQHTTPSendForwardMsg extends SendMsg {
actionName = ActionName.GoCQHTTP_SendGroupForwardMsg; actionName = ActionName.GoCQHTTP_SendForwardMsg;
protected async check(payload: OB11PostSendMsg) { protected async check(payload: OB11PostSendMsg) {
if (payload.messages){ if (payload.messages) payload.message = convertMessage2List(payload.messages);
payload.message = this.convertMessage2List(payload.messages);
}
return super.check(payload); return super.check(payload);
} }
} }
export class GoCQHTTPSendPrivateForwardMsg extends GoCQHTTPSendGroupForwardMsg { export class GoCQHTTPSendPrivateForwardMsg extends GoCQHTTPSendForwardMsg {
actionName = ActionName.GoCQHTTP_SendPrivateForwardMsg; actionName = ActionName.GoCQHTTP_SendPrivateForwardMsg;
}
export class GoCQHTTPSendGroupForwardMsg extends GoCQHTTPSendForwardMsg {
actionName = ActionName.GoCQHTTP_SendGroupForwardMsg;
} }

View File

@@ -14,7 +14,7 @@ import GetVersionInfo from "./system/GetVersionInfo";
import CanSendRecord from "./system/CanSendRecord"; import CanSendRecord from "./system/CanSendRecord";
import CanSendImage from "./system/CanSendImage"; import CanSendImage from "./system/CanSendImage";
import GetStatus from "./system/GetStatus"; import GetStatus from "./system/GetStatus";
import {GoCQHTTPSendGroupForwardMsg, GoCQHTTPSendPrivateForwardMsg} from "./go-cqhttp/SendForwardMsg"; import {GoCQHTTPSendForwardMsg, GoCQHTTPSendGroupForwardMsg, GoCQHTTPSendPrivateForwardMsg} from "./go-cqhttp/SendForwardMsg";
import GoCQHTTPGetStrangerInfo from "./go-cqhttp/GetStrangerInfo"; import GoCQHTTPGetStrangerInfo from "./go-cqhttp/GetStrangerInfo";
import SendLike from "./user/SendLike"; import SendLike from "./user/SendLike";
import SetGroupAddRequest from "./group/SetGroupAddRequest"; import SetGroupAddRequest from "./group/SetGroupAddRequest";
@@ -39,6 +39,7 @@ import SetQQAvatar from './llonebot/SetQQAvatar'
import GoCQHTTPDownloadFile from "./go-cqhttp/DownloadFile"; import GoCQHTTPDownloadFile from "./go-cqhttp/DownloadFile";
import GoCQHTTPGetGroupMsgHistory from "./go-cqhttp/GetGroupMsgHistory"; import GoCQHTTPGetGroupMsgHistory from "./go-cqhttp/GetGroupMsgHistory";
import GetFile from "./file/GetFile"; import GetFile from "./file/GetFile";
import {GoCQHTTGetForwardMsgAction} from "./go-cqhttp/GetForwardMsg";
export const actionHandlers = [ export const actionHandlers = [
new GetFile(), new GetFile(),
@@ -73,6 +74,7 @@ export const actionHandlers = [
new CleanCache(), new CleanCache(),
//以下为go-cqhttp api //以下为go-cqhttp api
new GoCQHTTPSendForwardMsg(),
new GoCQHTTPSendGroupForwardMsg(), new GoCQHTTPSendGroupForwardMsg(),
new GoCQHTTPSendPrivateForwardMsg(), new GoCQHTTPSendPrivateForwardMsg(),
new GoCQHTTPGetStrangerInfo(), new GoCQHTTPGetStrangerInfo(),
@@ -81,6 +83,7 @@ export const actionHandlers = [
new GoCQHTTPMarkMsgAsRead(), new GoCQHTTPMarkMsgAsRead(),
new GoCQHTTPUploadGroupFile(), new GoCQHTTPUploadGroupFile(),
new GoCQHTTPGetGroupMsgHistory(), new GoCQHTTPGetGroupMsgHistory(),
new GoCQHTTGetForwardMsgAction(),
] ]

View File

@@ -2,7 +2,7 @@ import {
AtType, AtType,
ChatType, ChatType,
ElementType, ElementType,
Group, Group, PicSubType,
RawMessage, RawMessage,
SendArkElement, SendArkElement,
SendMessageElement SendMessageElement
@@ -188,7 +188,7 @@ export async function createSendElements(messageData: OB11MessageData[], group:
} else if (sendMsg.type === OB11MessageDataType.voice) { } else if (sendMsg.type === OB11MessageDataType.voice) {
sendElements.push(await SendMsgElementConstructor.ptt(path)); sendElements.push(await SendMsgElementConstructor.ptt(path));
} else if (sendMsg.type === OB11MessageDataType.image) { } else if (sendMsg.type === OB11MessageDataType.image) {
sendElements.push(await SendMsgElementConstructor.pic(path, sendMsg.data.summary || "")); sendElements.push(await SendMsgElementConstructor.pic(path, sendMsg.data.summary || "", <PicSubType>parseInt(sendMsg.data?.subType?.toString()) || 0));
} }
} }
} }

View File

@@ -51,6 +51,7 @@ export enum ActionName {
GetRecord = "get_record", GetRecord = "get_record",
CleanCache = "clean_cache", CleanCache = "clean_cache",
// 以下为go-cqhttp api // 以下为go-cqhttp api
GoCQHTTP_SendForwardMsg = "send_forward_msg",
GoCQHTTP_SendGroupForwardMsg = "send_group_forward_msg", GoCQHTTP_SendGroupForwardMsg = "send_group_forward_msg",
GoCQHTTP_SendPrivateForwardMsg = "send_private_forward_msg", GoCQHTTP_SendPrivateForwardMsg = "send_private_forward_msg",
GoCQHTTP_GetStrangerInfo = "get_stranger_info", GoCQHTTP_GetStrangerInfo = "get_stranger_info",
@@ -59,4 +60,5 @@ export enum ActionName {
GoCQHTTP_UploadGroupFile = "upload_group_file", GoCQHTTP_UploadGroupFile = "upload_group_file",
GoCQHTTP_DownloadFile = "download_file", GoCQHTTP_DownloadFile = "download_file",
GoCQHTTP_GetGroupMsgHistory = "get_group_msg_history", GoCQHTTP_GetGroupMsgHistory = "get_group_msg_history",
GoCQHTTP_GetForwardMsg = "get_forward_msg",
} }

View File

@@ -19,7 +19,8 @@ import {
SelfInfo, SelfInfo,
Sex, Sex,
TipGroupElementType, TipGroupElementType,
User, VideoElement User,
VideoElement
} from '../ntqqapi/types'; } from '../ntqqapi/types';
import {getFriend, getGroupMember, selfInfo, tempGroupCodeMap} from '../common/data'; import {getFriend, getGroupMember, selfInfo, tempGroupCodeMap} from '../common/data';
import {EventType} from "./event/OB11BaseEvent"; import {EventType} from "./event/OB11BaseEvent";
@@ -37,6 +38,7 @@ import {sleep} from "../common/utils/helper";
import {getConfigUtil} from "../common/config"; import {getConfigUtil} from "../common/config";
import {OB11GroupTitleEvent} from "./event/notice/OB11GroupTitleEvent"; import {OB11GroupTitleEvent} from "./event/notice/OB11GroupTitleEvent";
import {OB11GroupCardEvent} from "./event/notice/OB11GroupCardEvent"; import {OB11GroupCardEvent} from "./event/notice/OB11GroupCardEvent";
import {OB11GroupDecreaseEvent} from "./event/notice/OB11GroupDecreaseEvent";
export class OB11Constructor { export class OB11Constructor {
@@ -203,6 +205,15 @@ export class OB11Constructor {
} else if (element.faceElement) { } else if (element.faceElement) {
message_data["type"] = OB11MessageDataType.face; message_data["type"] = OB11MessageDataType.face;
message_data["data"]["id"] = element.faceElement.faceIndex.toString(); message_data["data"]["id"] = element.faceElement.faceIndex.toString();
} else if (element.marketFaceElement) {
message_data["type"] = OB11MessageDataType.mface;
message_data["data"]["text"] = element.marketFaceElement.faceName;
} else if (element.markdownElement){
message_data["type"] = OB11MessageDataType.markdown;
message_data["data"]["data"] = element.markdownElement.content;
} else if (element.multiForwardMsgElement){
message_data["type"] = OB11MessageDataType.forward;
message_data["data"]["id"] = msg.msgId
} }
if (message_data.type !== "unknown" && message_data.data) { if (message_data.type !== "unknown" && message_data.data) {
const cqCode = encodeCQCode(message_data); const cqCode = encodeCQCode(message_data);
@@ -224,8 +235,9 @@ export class OB11Constructor {
if (msg.senderUin){ if (msg.senderUin){
let member = await getGroupMember(msg.peerUid, msg.senderUin); let member = await getGroupMember(msg.peerUid, msg.senderUin);
if (member && member.cardName !== msg.sendMemberName) { if (member && member.cardName !== msg.sendMemberName) {
const event = new OB11GroupCardEvent(parseInt(msg.peerUid), parseInt(msg.senderUin), msg.sendMemberName, member.cardName)
member.cardName = msg.sendMemberName; member.cardName = msg.sendMemberName;
return new OB11GroupCardEvent(parseInt(msg.peerUid), parseInt(msg.senderUin), msg.sendMemberName, member.cardName) return event
} }
} }
// log("group msg", msg); // log("group msg", msg);
@@ -271,6 +283,13 @@ export class OB11Constructor {
return new OB11GroupBanEvent(parseInt(msg.peerUid), parseInt(memberUin), parseInt(adminUin), duration, sub_type); return new OB11GroupBanEvent(parseInt(msg.peerUid), parseInt(memberUin), parseInt(adminUin), duration, sub_type);
} }
} }
else if (groupElement.type == TipGroupElementType.kicked){
log("收到我被踢出提示", groupElement)
const adminUin = (await getGroupMember(msg.peerUid, groupElement.adminUid))?.uin || (await NTQQUserApi.getUserDetailInfo(groupElement.adminUid))?.uin
if (adminUin) {
return new OB11GroupDecreaseEvent(parseInt(msg.peerUid), parseInt(selfInfo.uin), parseInt(adminUin), "kick_me");
}
}
} else if (element.fileElement) { } else if (element.fileElement) {
return new OB11GroupUploadNoticeEvent(parseInt(msg.peerUid), parseInt(msg.senderUin), { return new OB11GroupUploadNoticeEvent(parseInt(msg.peerUid), parseInt(msg.senderUin), {
id: element.fileElement.fileUuid, id: element.fileElement.fileUuid,
@@ -293,6 +312,7 @@ export class OB11Constructor {
while ((match = regex.exec(xmlElement.content)) !== null) { while ((match = regex.exec(xmlElement.content)) !== null) {
matches.push(match[1]); matches.push(match[1]);
} }
// log("新人进群匹配到的QQ号", matches)
if (matches.length === 2) { if (matches.length === 2) {
const [inviter, invitee] = matches; const [inviter, invitee] = matches;
return new OB11GroupIncreaseEvent(parseInt(msg.peerUid), parseInt(invitee), parseInt(inviter), "invite"); return new OB11GroupIncreaseEvent(parseInt(msg.peerUid), parseInt(invitee), parseInt(inviter), "invite");

View File

@@ -1,14 +1,17 @@
import {OB11GroupNoticeEvent} from "./OB11GroupNoticeEvent"; import {OB11GroupNoticeEvent} from "./OB11GroupNoticeEvent";
export type GroupDecreaseSubType = "leave" | "kick" | "kick_me";
export class OB11GroupDecreaseEvent extends OB11GroupNoticeEvent { export class OB11GroupDecreaseEvent extends OB11GroupNoticeEvent {
notice_type = "group_decrease"; notice_type = "group_decrease";
sub_type: "leave" | "kick" | "kick_me" = "leave"; // TODO: 实现其他几种子类型的识别 ("leave" | "kick" | "kick_me") sub_type: GroupDecreaseSubType = "leave"; // TODO: 实现其他几种子类型的识别 ("leave" | "kick" | "kick_me")
operator_id: number; operator_id: number;
constructor(groupId: number, userId: number) { constructor(groupId: number, userId: number, operatorId: number, subType: GroupDecreaseSubType = "leave") {
super(); super();
this.group_id = groupId; this.group_id = groupId;
this.operator_id = userId; // 实际上不应该这么实现,但是现在还没有办法识别用户是被踢出的,还是自己主动退出的 this.operator_id = operatorId; // 实际上不应该这么实现,但是现在还没有办法识别用户是被踢出的,还是自己主动退出的
this.user_id = userId; this.user_id = userId;
this.sub_type = subType;
} }
} }

View File

@@ -73,7 +73,7 @@ export function postOB11Event(msg: PostEventType, reportSelf = false) {
const config = getConfigUtil().getConfig(); const config = getConfigUtil().getConfig();
// 判断msg是否是event // 判断msg是否是event
if (!config.reportSelfMessage && !reportSelf) { if (!config.reportSelfMessage && !reportSelf) {
if ((msg as OB11Message).user_id.toString() == selfInfo.uin) { if (msg.post_type === "message" && (msg as OB11Message).user_id.toString() == selfInfo.uin) {
return return
} }
} }

View File

@@ -1,4 +1,4 @@
import {RawMessage} from "../ntqqapi/types"; import {PicSubType, RawMessage} from "../ntqqapi/types";
import {EventType} from "./event/OB11BaseEvent"; import {EventType} from "./event/OB11BaseEvent";
export interface OB11User { export interface OB11User {
@@ -88,6 +88,10 @@ export interface OB11Message {
raw?: RawMessage raw?: RawMessage
} }
export interface OB11ForwardMessage extends OB11Message {
content: OB11MessageData[] | string;
}
export interface OB11Return<DataType> { export interface OB11Return<DataType> {
status: string status: string
retcode: number retcode: number
@@ -108,10 +112,19 @@ export enum OB11MessageDataType {
reply = "reply", reply = "reply",
json = "json", json = "json",
face = "face", face = "face",
mface = "face", // 商城表情 mface = "mface", // 商城表情
node = "node", // 合并转发消息 markdown = "markdown",
node = "node", // 合并转发消息节点
forward = "forward", // 合并转发消息,用于上报
xml = "xml"
} }
export interface OB11MessageMFace{
type: OB11MessageDataType.mface,
data: {
text: string
}
}
export interface OB11MessageText { export interface OB11MessageText {
type: OB11MessageDataType.text, type: OB11MessageDataType.text,
data: { data: {
@@ -128,11 +141,13 @@ interface OB11MessageFileBase {
} }
} }
export interface OB11MessageImage extends OB11MessageFileBase { export interface OB11MessageImage extends OB11MessageFileBase {
type: OB11MessageDataType.image type: OB11MessageDataType.image
data: OB11MessageFileBase['data'] & { data: OB11MessageFileBase['data'] & {
summary ? : string; // 图片摘要 summary ? : string; // 图片摘要
} subType?: PicSubType
},
} }
export interface OB11MessageRecord extends OB11MessageFileBase { export interface OB11MessageRecord extends OB11MessageFileBase {
@@ -199,7 +214,7 @@ export interface OB11MessageJson {
export type OB11MessageData = export type OB11MessageData =
OB11MessageText | OB11MessageText |
OB11MessageFace | OB11MessageFace | OB11MessageMFace |
OB11MessageAt | OB11MessageReply | OB11MessageAt | OB11MessageReply |
OB11MessageImage | OB11MessageRecord | OB11MessageFile | OB11MessageVideo | OB11MessageImage | OB11MessageRecord | OB11MessageFile | OB11MessageVideo |
OB11MessageNode | OB11MessageCustomMusic | OB11MessageJson OB11MessageNode | OB11MessageCustomMusic | OB11MessageJson

View File

@@ -1 +1 @@
export const version = "3.19.1" export const version = "3.20.0"