feat: laana message to raw

src/laana-v0.1.1/index.ts

@@ -0,0 +1,12 @@
+import { InstanceContext, NapCatCore } from '@/core';
+import { NapCatPathWrapper } from '@/common/path';
+
+export class NapCatLaanaAdapter {
+    constructor(
+        public core: NapCatCore,
+        public context: InstanceContext,
+        public pathWrapper: NapCatPathWrapper,
+    ) {
+
+    }
+}

src/laana-v0.1.1/utils/message.ts

@@ -0,0 +1,195 @@
+import { AtType, ChatType, ElementType, NapCatCore, Peer, SendMessageElement, SendTextElement } from '@/core';
+import { NapCatLaanaAdapter } from '@/laana-v0.1.1';
+import { OutgoingMessage, SendMessagePing } from '@/laana-v0.1.1/types/action/message';
+import { Peer as LaanaPeer, Peer_Type } from '@/laana-v0.1.1/types/entity/message';
+import faceConfig from '@/core/external/face_config.json';
+
+type Laana2RawConverters = {
+    [key in Exclude<OutgoingMessage['content']['oneofKind'], undefined>]:
+    (
+        // eslint-disable-next-line
+        // @ts-ignore
+        msgContent: Extract<OutgoingMessage['content'], { oneofKind: key; }>[key],
+        params: SendMessagePing,
+    ) => PromiseLike<{
+        elements: SendMessageElement[],
+        fileCacheId?: string[],
+    }>
+}
+
+export class LaanaMessageUtils {
+    constructor(
+        public core: NapCatCore,
+        public laana: NapCatLaanaAdapter,
+    ) {
+    }
+
+    l2r: Laana2RawConverters = {
+        bubble: async (msgContent, params) => {
+            function at(atUid: string, atNtUid: string, atType: AtType, atName: string): SendTextElement {
+                return {
+                    elementType: ElementType.TEXT,
+                    elementId: '',
+                    textElement: {
+                        content: `@${atName}`,
+                        atType,
+                        atUid,
+                        atTinyId: '',
+                        atNtUid,
+                    },
+                };
+            }
+
+            const sendElements: SendMessageElement[] = [];
+
+            if (msgContent.repliedMsgId) {
+                const { msgSeq, msgId, senderUin } = (
+                    await this.core.apis.MsgApi.getMsgsByMsgId(
+                        await this.laanaPeerToRaw(params.targetPeer!),
+                        [msgContent.repliedMsgId]
+                    )
+                ).msgList[0];
+                sendElements.push({
+                    elementType: ElementType.REPLY,
+                    elementId: '',
+                    replyElement: {
+                        replayMsgSeq: msgSeq,
+                        replayMsgId: msgId,
+                        senderUin: senderUin,
+                        senderUinStr: senderUin,
+                    }
+                });
+            }
+
+            for (const seg of msgContent.segments) {
+                const content = seg.content;
+                if (content.oneofKind === 'text') {
+                    sendElements.push({
+                        elementType: ElementType.TEXT,
+                        elementId: '',
+                        textElement: {
+                            content: content.text,
+                            atType: AtType.notAt,
+                            atUid: '',
+                            atTinyId: '',
+                            atNtUid: '',
+                        },
+                    });
+                } else if (content.oneofKind === 'at') {
+                    if (params.targetPeer?.type !== Peer_Type.GROUP) {
+                        throw '试图在私聊会话中使用 At';
+                    }
+
+                    if (content.at.uin === '0') {
+                        sendElements.push(at(
+                            '0', '0',
+                            AtType.atAll,
+                            '所有人',
+                        ));
+                    }
+
+                    const atMember = await this.core.apis.GroupApi
+                        .getGroupMember(params.targetPeer.uin, content.at.uin);
+                    if (atMember) {
+                        sendElements.push(at(
+                            content.at.uin,
+                            atMember.uid,
+                            AtType.atUser,
+                            atMember.cardName || atMember.nick,
+                        ));
+                    } else {
+                        const uid = await this.core.apis.UserApi.getUidByUinV2(content.at.uin);
+                        if (!uid) {
+                            throw '查询用户 UID 失败';
+                        }
+                        const info = await this.core.apis.UserApi.getUserDetailInfo(uid);
+                        sendElements.push(at(
+                            content.at.uin,
+                            uid,
+                            AtType.atUser,
+                            info.nick || '未知用户',
+                        ));
+                    }
+                } else if (content.oneofKind === 'face') {
+                    const parsedFaceId = content.face;
+                    // 从face_config.json中获取表情名称
+                    const sysFaces = faceConfig.sysface;
+                    const face = sysFaces.find((systemFace) => systemFace.QSid === parsedFaceId.toString());
+                    if (!face) {
+                        throw '未知的表情 ID';
+                    }
+
+                    const faceType = parsedFaceId >= 222 ?
+                        face.AniStickerType ?
+                            3 : 2 : 1;
+                    sendElements.push({
+                        elementType: ElementType.FACE,
+                        elementId: '',
+                        faceElement: {
+                            faceIndex: parsedFaceId,
+                            faceType,
+                            faceText: face.QDes,
+                            stickerId: face.AniStickerId,
+                            stickerType: face.AniStickerType,
+                            packId: face.AniStickerPackId,
+                            sourceType: 1,
+                        },
+                    });
+                } else if (content.oneofKind === 'image') {
+                    // TODO: handle file-like messages
+                    throw 'Unimplemented';
+                } else {
+                    throw '未知的消息内容类型';
+                }
+            }
+
+            return { elements: sendElements };
+        },
+
+        file: () => { throw 'Unimplemented'; },
+
+        singleImage: () => { throw 'Unimplemented'; },
+
+        marketFace: async msgContent => ({
+            elements: [{
+                elementType: ElementType.MFACE,
+                marketFaceElement: {
+                    emojiPackageId: msgContent.facePackageId,
+                    emojiId: msgContent.faceId,
+                    key: msgContent.faceKey,
+                    faceName: msgContent.displayText ?? '[商城表情]',
+                },
+            }],
+        }),
+
+        video: () => { throw 'Unimplemented'; },
+
+        voice: () => { throw 'Unimplemented'; },
+
+        musicCard: () => { throw 'Unimplemented'; },
+    };
+
+    async laanaPeerToRaw(peer: LaanaPeer): Promise<Peer> {
+        const peerUid = await this.core.apis.UserApi.getUidByUinV2(peer.uin);
+        if (!peerUid) {
+            throw '查询用户 UID 失败';
+        }
+        return {
+            chatType: peer.type === Peer_Type.GROUP ? ChatType.KCHATTYPEGROUP : ChatType.KCHATTYPEC2C,
+            guildId: '',
+            peerUid,
+        };
+    }
+
+    async laanaMessageToRaw(msg: OutgoingMessage, params: SendMessagePing) {
+        if (!msg.content.oneofKind) {
+            throw '消息内容类型未知';
+        }
+        return this.l2r[msg.content.oneofKind](
+            // eslint-disable-next-line
+            // @ts-ignore
+            msg.content[msg.content.oneofKind],
+            params
+        );
+    }
+}