refactor: make methods in event.ts instance methods

src/onebot/api/group.ts

@@ -1,4 +1,11 @@
-import { ChatType, GrayTipElement, NapCatCore } from '@/core';
+import {
+    ChatType,
+    GrayTipElement,
+    NapCatCore,
+    NTGrayTipElementSubTypeV2,
+    RawMessage,
+    TipGroupElementType,
+} from '@/core';
 import { NapCatOneBot11Adapter } from '@/onebot';
 import { OB11GroupBanEvent } from '../event/notice/OB11GroupBanEvent';
 import { OB11GroupIncreaseEvent } from '../event/notice/OB11GroupIncreaseEvent';
@@ -6,6 +13,11 @@ import { OB11GroupDecreaseEvent } from '../event/notice/OB11GroupDecreaseEvent';
 import fastXmlParser from 'fast-xml-parser';
 import { OB11GroupMsgEmojiLikeEvent } from '../event/notice/OB11MsgEmojiLikeEvent';
 import { MessageUnique } from '@/common/message-unique';
+import { OB11GroupCardEvent } from '@/onebot/event/notice/OB11GroupCardEvent';
+import { OB11GroupUploadNoticeEvent } from '@/onebot/event/notice/OB11GroupUploadNoticeEvent';
+import { OB11GroupPokeEvent } from '@/onebot/event/notice/OB11PokeEvent';
+import { OB11GroupEssenceEvent } from '@/onebot/event/notice/OB11GroupEssenceEvent';
+import { OB11GroupTitleEvent } from '@/onebot/event/notice/OB11GroupTitleEvent';
 
 export class OneBotGroupApi {
     obContext: NapCatOneBot11Adapter;
@@ -16,6 +28,126 @@ export class OneBotGroupApi {
         this.core = core;
     }
 
+    async parseGroupEvent(msg: RawMessage) {
+        const NTQQGroupApi = this.core.apis.GroupApi;
+        const NTQQUserApi = this.core.apis.UserApi;
+        const NTQQMsgApi = this.core.apis.MsgApi;
+        const logger = this.core.context.logger;
+        if (msg.chatType !== ChatType.KCHATTYPEGROUP) {
+            return;
+        }
+        //log("group msg", msg);
+        if (msg.senderUin && msg.senderUin !== '0') {
+            const member = await NTQQGroupApi.getGroupMember(msg.peerUid, msg.senderUin);
+            if (member && member.cardName !== msg.sendMemberName) {
+                const newCardName = msg.sendMemberName || '';
+                const event = new OB11GroupCardEvent(this.core, parseInt(msg.peerUid), parseInt(msg.senderUin), newCardName, member.cardName);
+                member.cardName = newCardName;
+                return event;
+            }
+        }
+
+        for (const element of msg.elements) {
+            if (element.grayTipElement && element.grayTipElement.groupElement) {
+                const groupElement = element.grayTipElement.groupElement;
+                if (groupElement.type == TipGroupElementType.memberIncrease) {
+                    const MemberIncreaseEvent = await this.obContext.apis.GroupApi.parseGroupMemberIncreaseEvent(msg.peerUid, element.grayTipElement);
+                    if (MemberIncreaseEvent) return MemberIncreaseEvent;
+                } else if (groupElement.type === TipGroupElementType.ban) {
+                    const BanEvent = await this.obContext.apis.GroupApi.parseGroupBanEvent(msg.peerUid, element.grayTipElement);
+                    if (BanEvent) return BanEvent;
+                } else if (groupElement.type == TipGroupElementType.kicked) {
+                    NTQQGroupApi.quitGroup(msg.peerUid).then();
+                    try {
+                        const KickEvent = await this.obContext.apis.GroupApi.parseGroupKickEvent(msg.peerUid, element.grayTipElement);
+                        if (KickEvent) return KickEvent;
+                    } catch (e) {
+                        return new OB11GroupDecreaseEvent(
+                            this.core,
+                            parseInt(msg.peerUid),
+                            parseInt(this.core.selfInfo.uin),
+                            0,
+                            'leave',
+                        );
+                    }
+                }
+            } else if (element.fileElement) {
+                return new OB11GroupUploadNoticeEvent(
+                    this.core,
+                    parseInt(msg.peerUid), parseInt(msg.senderUin || ''),
+                    {
+                        id: element.fileElement.fileUuid!,
+                        name: element.fileElement.fileName,
+                        size: parseInt(element.fileElement.fileSize),
+                        busid: element.fileElement.fileBizId || 0,
+                    },
+                );
+            }
+            if (element.grayTipElement) {
+                if (element.grayTipElement.xmlElement?.templId === '10382') {
+                    const emojiLikeEvent = await this.obContext.apis.GroupApi.parseGroupEmojiLikeEventByGrayTip(msg.peerUid, element.grayTipElement);
+                    if (emojiLikeEvent) return emojiLikeEvent;
+                }
+                if (element.grayTipElement.subElementType == NTGrayTipElementSubTypeV2.GRAYTIP_ELEMENT_SUBTYPE_XMLMSG) {
+                    const GroupIncreaseEvent = await this.obContext.apis.GroupApi.parseGroupIncreaseEvent(msg.peerUid, element.grayTipElement);
+                    if (GroupIncreaseEvent) return GroupIncreaseEvent;
+                }
+
+                //代码歧义 GrayTipElementSubType.MEMBER_NEW_TITLE
+                else if (element.grayTipElement.subElementType == NTGrayTipElementSubTypeV2.GRAYTIP_ELEMENT_SUBTYPE_JSON) {
+                    const json = JSON.parse(element.grayTipElement.jsonGrayTipElement.jsonStr);
+                    if (element.grayTipElement.jsonGrayTipElement.busiId == 1061) {
+                        //判断业务类型
+                        //Poke事件
+                        const pokedetail: any[] = json.items;
+                        //筛选item带有uid的元素
+                        const poke_uid = pokedetail.filter(item => item.uid);
+                        if (poke_uid.length == 2) {
+                            return new OB11GroupPokeEvent(
+                                this.core,
+                                parseInt(msg.peerUid),
+                                parseInt((await NTQQUserApi.getUinByUidV2(poke_uid[0].uid))!),
+                                parseInt((await NTQQUserApi.getUinByUidV2(poke_uid[1].uid))!),
+                                pokedetail,
+                            );
+                        }
+                    }
+                    if (element.grayTipElement.jsonGrayTipElement.busiId == 2401) {
+                        const searchParams = new URL(json.items[0].jp).searchParams;
+                        const msgSeq = searchParams.get('msgSeq')!;
+                        const Group = searchParams.get('groupCode');
+                        // const businessId = searchParams.get('businessid');
+                        const Peer = {
+                            guildId: '',
+                            chatType: ChatType.KCHATTYPEGROUP,
+                            peerUid: Group!,
+                        };
+                        const msgData = await NTQQMsgApi.getMsgsBySeqAndCount(Peer, msgSeq.toString(), 1, true, true);
+                        return new OB11GroupEssenceEvent(
+                            this.core,
+                            parseInt(msg.peerUid),
+                            MessageUnique.getShortIdByMsgId(msgData.msgList[0].msgId)!,
+                            parseInt(msgData.msgList[0].senderUin),
+                        );
+                        // 获取MsgSeq+Peer可获取具体消息
+                    }
+                    if (element.grayTipElement.jsonGrayTipElement.busiId == 2407) {
+                        //下面得改 上面也是错的grayTipElement.subElementType == GrayTipElementSubType.MEMBER_NEW_TITLE
+                        const memberUin = json.items[1].param[0];
+                        const title = json.items[3].txt;
+                        logger.logDebug('收到群成员新头衔消息', json);
+                        return new OB11GroupTitleEvent(
+                            this.core,
+                            parseInt(msg.peerUid),
+                            parseInt(memberUin),
+                            title,
+                        );
+                    }
+                }
+            }
+        }
+    }
+
     async parseGroupBanEvent(GroupCode: string, grayTipElement: GrayTipElement) {
         const groupElement = grayTipElement?.groupElement;
         const NTQQGroupApi = this.core.apis.GroupApi;