perf: use cache in NapProto

src/core/packet/proto/NapProto.ts

@@ -91,15 +91,12 @@ export type NapProtoEncodeStructType<T> = NapProtoStructType<T, true>;
 
 export type NapProtoDecodeStructType<T> = NapProtoStructType<T, false>;
 
-const NapProtoMsgCache = new Map<ProtoMessageType, MessageType<NapProtoStructType<ProtoMessageType, boolean>>>();
-
-export class NapProtoMsg<T extends ProtoMessageType> {
-    private readonly _msg: T;
+class NapProtoRealMsg<T extends ProtoMessageType> {
     private readonly _field: PartialFieldInfo[];
     private readonly _proto_msg: MessageType<NapProtoStructType<T, boolean>>;
+    private static cache = new WeakMap<ProtoMessageType, NapProtoRealMsg<any>>();
 
-    constructor(fields: T) {
-        this._msg = fields;
+    private constructor(fields: T) {
         this._field = Object.keys(fields).map(key => {
             const field = fields[key];
             if (field.kind === 'scalar') {
@@ -122,13 +119,22 @@ export class NapProtoMsg<T extends ProtoMessageType> {
                     name: key,
                     kind: 'message',
                     repeat: field.repeat ? RepeatType.PACKED : RepeatType.NO,
-                    T: () => new NapProtoMsg(field.type())._proto_msg,
+                    T: () => NapProtoRealMsg.getInstance(field.type())._proto_msg,
                 };
             }
         }) as PartialFieldInfo[];
         this._proto_msg = new MessageType<NapProtoStructType<T, boolean>>('nya', this._field);
     }
 
+    static getInstance<T extends ProtoMessageType>(fields: T): NapProtoRealMsg<T> {
+        let instance = this.cache.get(fields);
+        if (!instance) {
+            instance = new NapProtoRealMsg(fields);
+            this.cache.set(fields, instance);
+        }
+        return instance;
+    }
+
     encode(data: NapProtoEncodeStructType<T>): Uint8Array {
         return this._proto_msg.toBinary(this._proto_msg.create(data as PartialMessage<NapProtoEncodeStructType<T>>));
     }
@@ -137,3 +143,19 @@ export class NapProtoMsg<T extends ProtoMessageType> {
         return this._proto_msg.fromBinary(data) as NapProtoDecodeStructType<T>;
     }
 }
+
+export class NapProtoMsg<T extends ProtoMessageType> {
+    private realMsg: NapProtoRealMsg<T>;
+
+    constructor(fields: T) {
+        this.realMsg = NapProtoRealMsg.getInstance(fields);
+    }
+
+    encode(data: NapProtoEncodeStructType<T>): Uint8Array {
+        return this.realMsg.encode(data);
+    }
+
+    decode(data: Uint8Array): NapProtoDecodeStructType<T> {
+        return this.realMsg.decode(data);
+    }
+}

src/onebot/action/group/SendGroupAiRecord.ts

@@ -4,8 +4,6 @@ import { GetPacketStatusDepends } from "@/onebot/action/packet/GetPacketStatus";
 import { AIVoiceChatType } from "@/core/packet/entities/aiChat";
 import { uri2local } from "@/common/file";
 import { ChatType, Peer } from "@/core";
-import { NapProtoEncodeStructType } from "@/core/packet/proto/NapProto";
-import { IndexNode } from "@/core/packet/proto/oidb/common/Ntv2.RichMediaReq";
 
 const SchemaData = {
     type: 'object',
@@ -20,7 +18,7 @@ const SchemaData = {
 type Payload = FromSchema<typeof SchemaData>;
 
 export class SendGroupAiRecord extends GetPacketStatusDepends<Payload, {
-    message_id: string
+    message_id: number
 }> {
     actionName = ActionName.SendGroupAiRecord;
     payloadSchema = SchemaData;
@@ -35,6 +33,6 @@ export class SendGroupAiRecord extends GetPacketStatusDepends<Payload, {
         const peer = { chatType: ChatType.KCHATTYPEGROUP, peerUid: payload.group_id.toString() } as Peer;
         const element = await this.core.apis.FileApi.createValidSendPttElement(path);
         const sendRes = await this.obContext.apis.MsgApi.sendMsgWithOb11UniqueId(peer, [element], [path]);
-        return { message_id: sendRes.msgId };
+        return { message_id: sendRes.id ?? -1 };
     }
 }