fix: self nickname

fix: @member msg report fix: send file:// on Windows ver: 3.0.2
fix: self nickname
2024-11-22 01:56:33 +00:00 · 2024-02-13 18:37:01 +08:00 · 2024-02-13 13:12:16 +08:00
9 changed files with 213 additions and 167 deletions
--- a/manifest.json
+++ b/manifest.json
@@ -4,7 +4,7 @@
    "name": "LLOneBot",
    "slug": "LLOneBot",
    "description": "LiteLoaderQQNT的OneBotApi",
-    "version": "2.5.0",
+    "version": "3.0.2",
    "thumbnail": "./icon.png",
    "authors": [{
        "name": "linyuchen",
--- a/src/common/data.ts
+++ b/src/common/data.ts
@@ -1,5 +1,5 @@
 import { NTQQApi } from '../ntqqapi/ntcall';
-import { Friend, Group, RawMessage, SelfInfo } from "../ntqqapi/types";
+import { Friend, Group, GroupMember, RawMessage, SelfInfo } from "../ntqqapi/types";

 export let groups: Group[] = []
 export let friends: Friend[] = []
@@ -23,16 +23,23 @@ export async function getGroup(qq: string): Promise<Group | undefined> {
    return group
 }

-export async function getGroupMember(groupQQ: string, memberQQ: string) {
+export async function getGroupMember(groupQQ: string, memberQQ: string=null, memberUid: string=null) {
    const group = await getGroup(groupQQ)
    if (group) {
-        let member = group.members?.find(member => member.uin === memberQQ)
+        let filterFunc: (member: GroupMember) => boolean
+        if (memberQQ){
+            filterFunc = member => member.uin === memberQQ
+        }
+        else if (memberUid){
+            filterFunc = member => member.uid === memberUid
+        }
+        let member = group.members?.find(filterFunc)
        if (!member){
            const _members = await NTQQApi.getGroupMembers(groupQQ)
            if (_members.length){
                group.members = _members
            }
-            member = group.members?.find(member => member.uin === memberQQ)
+            member = group.members?.find(filterFunc)
        }
        return member
    }
--- a/src/main/main.ts
+++ b/src/main/main.ts
@@ -32,7 +32,7 @@ function onLoad() {


    if (!fs.existsSync(CONFIG_DIR)) {
-        fs.mkdirSync(CONFIG_DIR, { recursive: true });
+        fs.mkdirSync(CONFIG_DIR, {recursive: true});
    }
    ipcMain.handle(CHANNEL_GET_CONFIG, (event: any, arg: any) => {
        return getConfigUtil().getConfig()
@@ -47,7 +47,7 @@ function onLoad() {


    function postRawMsg(msgList: RawMessage[]) {
-        const { debug, reportSelfMessage } = getConfigUtil().getConfig();
+        const {debug, reportSelfMessage} = getConfigUtil().getConfig();
        for (const message of msgList) {
            OB11Constructor.message(message).then((msg) => {
                if (debug) {
@@ -61,77 +61,67 @@ function onLoad() {
        }
    }

-    registerReceiveHook<{ msgList: Array<RawMessage> }>(ReceiveCmd.NEW_MSG, (payload) => {
-        try {
-            postRawMsg(payload.msgList);
-        } catch (e) {
-            log("report message error: ", e.toString())
-        }
-    })

-    registerReceiveHook<{ msgRecord: RawMessage }>(ReceiveCmd.SELF_SEND_MSG, (payload) => {
-        const { reportSelfMessage } = getConfigUtil().getConfig()
-        if (!reportSelfMessage) {
-            return
-        }
-        log("reportSelfMessage", payload)
-        try {
-            postRawMsg([payload.msgRecord]);
-        } catch (e) {
-            log("report self message error: ", e.toString())
-        }
-    })
+    function start() {
+        registerReceiveHook<{ msgList: Array<RawMessage> }>(ReceiveCmd.NEW_MSG, (payload) => {
+            try {
+                postRawMsg(payload.msgList);
+            } catch (e) {
+                log("report message error: ", e.toString())
+            }
+        })
+
+        registerReceiveHook<{ msgRecord: RawMessage }>(ReceiveCmd.SELF_SEND_MSG, (payload) => {
+            const {reportSelfMessage} = getConfigUtil().getConfig()
+            if (!reportSelfMessage) {
+                return
+            }
+            log("reportSelfMessage", payload)
+            try {
+                postRawMsg([payload.msgRecord]);
+            } catch (e) {
+                log("report self message error: ", e.toString())
+            }
+        })
+        NTQQApi.getGroups(true).then()
+        startExpress(getConfigUtil().getConfig().port)
+    }

    async function getSelfInfo() {
-        try{
+        try {
            const _ = await NTQQApi.getSelfInfo()
            Object.assign(selfInfo, _)
            selfInfo.nick = selfInfo.uin
            log("get self simple info", _)
-        }catch(e){
+        } catch (e) {
            log("retry get self info")

        }
        if (selfInfo.uin) {
            try {
                const userInfo = (await NTQQApi.getUserInfo(selfInfo.uid))
+                log("self info", userInfo);
                if (userInfo) {
                    selfInfo.nick = userInfo.nick
+                } else {
+                    return setTimeout(() => {
+                        getSelfInfo().then()
+                    }, 100)
                }
-            }
-            catch (e) {
+            } catch (e) {
                log("get self nickname failed", e.toString())
+                return setTimeout(() => {
+                    getSelfInfo().then()
+                }, 100)
            }
-            // try {
-            //     friends.push(...(await NTQQApi.getFriends(true)))
-            //     log("get friends", friends)
-            //     let _groups: Group[] = []
-            //     for(let i=0; i++; i<3){
-            //         try{
-            //             _groups = await NTQQApi.getGroups(true)
-            //             log("get groups sucess", _groups)
-            //             break
-            //         } catch(e) {
-            //             log("get groups failed", e)
-            //         }
-            //     }
-            //     for (let g of _groups) {
-            //         g.members = (await NTQQApi.getGroupMembers(g.groupCode))
-            //         log("group members", g.members)
-            //         groups.push(g)
-            //     }
-
-            // } catch (e) {
-            //     log("!!!初始化失败", e.stack.toString())
-            // }
-            startExpress(getConfigUtil().getConfig().port)
-        }
-        else{
+            start();
+        } else {
            setTimeout(() => {
                getSelfInfo().then()
            }, 100)
        }
    }
+
    getSelfInfo().then()
 }

--- a/src/ntqqapi/hook.ts
+++ b/src/ntqqapi/hook.ts
@@ -1,24 +1,24 @@
-import {BrowserWindow} from 'electron';
-import {getConfigUtil, log} from "../common/utils";
-import {NTQQApi, NTQQApiClass, sendMessagePool} from "./ntcall";
+import { BrowserWindow } from 'electron';
+import { getConfigUtil, log } from "../common/utils";
+import { NTQQApi, NTQQApiClass, sendMessagePool } from "./ntcall";
 import { Group, User } from "./types";
 import { RawMessage } from "./types";
-import {friends, groups, msgHistory} from "../common/data";
+import { friends, groups, msgHistory } from "../common/data";
 import { v4 as uuidv4 } from 'uuid';

-export let hookApiCallbacks: Record<string, (apiReturn: any)=>void>={}
+export let hookApiCallbacks: Record<string, (apiReturn: any) => void> = {}

 export enum ReceiveCmd {
    UPDATE_MSG = "nodeIKernelMsgListener/onMsgInfoListUpdate",
    NEW_MSG = "nodeIKernelMsgListener/onRecvMsg",
    SELF_SEND_MSG = "nodeIKernelMsgListener/onAddSendMsg",
-    USER_INFO = "nodeIKernelProfileListener/onProfileDetailInfoChanged",
+    USER_INFO = "nodeIKernelProfileListener/onProfileSimpleChanged",
    GROUPS = "nodeIKernelGroupListener/onGroupListUpdate",
    GROUPS_UNIX = "onGroupListUpdate",
    FRIENDS = "onBuddyListChange"
 }

-interface NTQQApiReturnData<PayloadType=unknown> extends Array<any> {
+interface NTQQApiReturnData<PayloadType = unknown> extends Array<any> {
    0: {
        "type": "request",
        "eventName": NTQQApiClass,
@@ -51,7 +51,7 @@ export function hookNTQQApiReceive(window: BrowserWindow) {
                        new Promise((resolve, reject) => {
                            try {
                                hook.hookFunc(receiveData.payload);
-                            }catch (e) {
+                            } catch (e) {
                                log("hook error", e, receiveData.payload)
                            }
                        }).then()
@@ -59,10 +59,10 @@ export function hookNTQQApiReceive(window: BrowserWindow) {
                }
            }
        }
-        if (args[0]?.callbackId){
+        if (args[0]?.callbackId) {
            // log("hookApiCallback", hookApiCallbacks, args)
            const callbackId = args[0].callbackId;
-            if (hookApiCallbacks[callbackId]){
+            if (hookApiCallbacks[callbackId]) {
                // log("callback found")
                new Promise((resolve, reject) => {
                    hookApiCallbacks[callbackId](args[1]);
@@ -85,36 +85,43 @@ export function registerReceiveHook<PayloadType>(method: ReceiveCmd, hookFunc: (
    return id;
 }

-export function removeReceiveHook(id: string){
-    const index = receiveHooks.findIndex(h=>h.id === id)
+export function removeReceiveHook(id: string) {
+    const index = receiveHooks.findIndex(h => h.id === id)
    receiveHooks.splice(index, 1);
 }

-async function updateGroups(_groups: Group[]){
-    for(let group of _groups){
-        let existGroup = groups.find(g=>g.groupCode == group.groupCode)
-        if (!existGroup){
-            // log("update group")
-            let _membeers = await NTQQApi.getGroupMembers(group.groupCode)
-            if (_membeers){
-                group.members = _membeers
-            }
+async function updateGroups(_groups: Group[]) {
+    for (let group of _groups) {
+        let existGroup = groups.find(g => g.groupCode == group.groupCode)
+        if (!existGroup) {
+            NTQQApi.getGroupMembers(group.groupCode).then(members => {
+                if (members) {
+                    group.members = members
+                }
+            })
+            groups.push(group)
            log("update group members", group.members)
-        }
-        else{
-            group.members = [...existGroup.members]
+        } else {
+            Object.assign(existGroup, group)
        }
    }
-    groups.length = 0;
-    groups.push(..._groups)
 }

-registerReceiveHook<{groupList: Group[]}>(ReceiveCmd.GROUPS, (payload)=>updateGroups(payload.groupList).then())
-registerReceiveHook<{groupList: Group[]}>(ReceiveCmd.GROUPS_UNIX, (payload)=>updateGroups(payload.groupList).then())
-registerReceiveHook<{data:{categoryId: number, categroyName: string, categroyMbCount: number, buddyList: User[]}[]}>(ReceiveCmd.FRIENDS, payload=>{
-    friends.length = 0
+registerReceiveHook<{ groupList: Group[] }>(ReceiveCmd.GROUPS, (payload) => updateGroups(payload.groupList).then())
+registerReceiveHook<{ groupList: Group[] }>(ReceiveCmd.GROUPS_UNIX, (payload) => updateGroups(payload.groupList).then())
+registerReceiveHook<{
+    data: { categoryId: number, categroyName: string, categroyMbCount: number, buddyList: User[] }[]
+}>(ReceiveCmd.FRIENDS, payload => {
    for (const fData of payload.data) {
-        friends.push(...fData.buddyList)
+        const _friends = fData.buddyList;
+        for (let friend of _friends) {
+            let existFriend = friends.find(f => f.uin == friend.uin)
+            if (!existFriend) {
+                friends.push(friend)
+            } else {
+                Object.assign(existFriend, friend)
+            }
+        }
    }
 })

@@ -131,24 +138,27 @@ registerReceiveHook<{ msgList: Array<RawMessage> }>(ReceiveCmd.UPDATE_MSG, (payl
 registerReceiveHook<{ msgList: Array<RawMessage> }>(ReceiveCmd.NEW_MSG, (payload) => {
    for (const message of payload.msgList) {
        log("收到新消息，push到历史记录", message)
-        if (!msgHistory[message.msgId]){
+        if (!msgHistory[message.msgId]) {
            msgHistory[message.msgId] = message
-        }
-        else{
+        } else {
            Object.assign(msgHistory[message.msgId], message)
        }
    }
+    const msgIds = Object.keys(msgHistory);
+    if (msgIds.length > 3000) {
+        delete msgHistory[msgIds.sort()[0]]
+    }
 })

-registerReceiveHook<{msgRecord: RawMessage}>(ReceiveCmd.SELF_SEND_MSG, ({msgRecord})=>{
+registerReceiveHook<{ msgRecord: RawMessage }>(ReceiveCmd.SELF_SEND_MSG, ({msgRecord}) => {
    const message = msgRecord;
    const peerUid = message.peerUid;
    // log("收到自己发送成功的消息", Object.keys(sendMessagePool), message);
    const sendCallback = sendMessagePool[peerUid];
-    if (sendCallback){
-        try{
+    if (sendCallback) {
+        try {
            sendCallback(message);
-        }catch(e){
+        } catch (e) {
            log("receive self msg error", e.stack)
        }
    }
--- a/src/ntqqapi/ntcall.ts
+++ b/src/ntqqapi/ntcall.ts
@@ -2,11 +2,12 @@ import { ipcMain } from "electron";
 import { v4 as uuidv4 } from "uuid";
 import { ReceiveCmd, hookApiCallbacks, registerReceiveHook, removeReceiveHook } from "./hook";
 import { log } from "../common/utils";
-import { ChatType, Friend, SelfInfo, User } from "./types";
+import { ChatType, Friend, PicElement, SelfInfo, User } from "./types";
 import { Group } from "./types";
 import { GroupMember } from "./types";
 import { RawMessage } from "./types";
 import { SendMessageElement } from "./types";
+import * as fs from "fs";

 interface IPCReceiveEvent {
    eventName: string
@@ -43,6 +44,7 @@ export enum NTQQApiMethod {
    MEDIA_FILE_PATH = "nodeIKernelMsgService/getRichMediaFilePathForGuild",
    RECALL_MSG = "nodeIKernelMsgService/recallMsg",
    SEND_MSG = "nodeIKernelMsgService/sendMsg",
+    DOWNLOAD_MEDIA = "nodeIKernelMsgService/downloadRichMedia"
 }

 enum NTQQApiChannel {
@@ -140,10 +142,9 @@ export class NTQQApi {
    }

    static async getUserInfo(uid: string) {
-        const result = await callNTQQApi<{ info: User }>(NTQQApiChannel.IPC_UP_2, NTQQApiClass.NT_API, NTQQApiMethod.USER_INFO,
+        const result = await callNTQQApi<{ profiles: Map<string, User> }>(NTQQApiChannel.IPC_UP_2, NTQQApiClass.NT_API, NTQQApiMethod.USER_INFO,
            [{ force: true, uids: [uid] }, undefined], ReceiveCmd.USER_INFO)
-        return result.info
-
+        return result.profiles.get(uid)
    }

    static async getFriends(forced = false) {
@@ -244,6 +245,28 @@ export class NTQQApi {
        }
    }

+    static async downloadMedia(msgId: string, chatType: ChatType, peerUid: string, elementId: string, thumbPath: string, sourcePath: string){
+        // 用于下载收到的消息中的图片等
+        if (fs.existsSync(sourcePath)){
+            return sourcePath
+        }
+        const apiParams = [
+            {
+                getReq: {
+                    msgId: msgId,
+                    chatType: chatType,
+                    peerUid: peerUid,
+                    elementId: elementId,
+                    thumbSize: 0,
+                    downloadType: 1,
+                    filePath: thumbPath,
+                },
+            },
+            undefined,
+        ]
+        await callNTQQApi(NTQQApiChannel.IPC_UP_2, NTQQApiClass.NT_API, NTQQApiMethod.DOWNLOAD_MEDIA, apiParams)
+        return sourcePath
+    }
    static recallMsg(peer: Peer, msgIds: string[]) {
        return callNTQQApi(NTQQApiChannel.IPC_UP_2, NTQQApiClass.NT_API, NTQQApiMethod.RECALL_MSG, [{ peer, msgIds }, null])
    }
@@ -293,4 +316,5 @@ export class NTQQApi {
        })

    }
+
 }
--- a/src/ntqqapi/types.ts
+++ b/src/ntqqapi/types.ts
@@ -167,6 +167,19 @@ export interface ArkElement {
    bytesData: string;
 }

+export const IMAGE_HTTP_HOST = "https://gchat.qpic.cn"
+
+export interface PicElement {
+    originImageUrl: string;  // http url, 没有host，host是https://gchat.qpic.cn/
+    sourcePath: string; // 图片本地路径
+    thumbPath: Map<number, string>;
+    picWidth: number;
+    picHeight: number;
+    fileSize: number;
+    fileName: string;
+    fileUuid: string;
+}
+
 export interface RawMessage {
    msgId: string;
    msgTime: string;
@@ -178,6 +191,7 @@ export interface RawMessage {
    sendMemberName?: string; // 发送者群名片
    chatType: ChatType;
    elements: {
+        elementId: string,
        replyElement: {
            senderUid: string; // 原消息发送者QQ号
            sourceMsgIsIncPic: boolean; // 原消息是否有图片
@@ -186,18 +200,11 @@ export interface RawMessage {
        };
        textElement: {
            atType: AtType;
-            atUid: string;
+            atUid: string; // QQ号
            content: string;
-            atNtUid: string;
-        };
-        picElement: {
-            sourcePath: string; // 图片本地路径
-            picWidth: number;
-            picHeight: number;
-            fileSize: number;
-            fileName: string;
-            fileUuid: string;
+            atNtUid: string; // uid号
        };
+        picElement: PicElement;
        pttElement: PttElement;
        arkElement: ArkElement;
    }[];
--- a/src/onebot11/actions/SendMsg.ts
+++ b/src/onebot11/actions/SendMsg.ts
@@ -10,6 +10,7 @@ import { v4 as uuid4 } from 'uuid';
 import { log } from "../../common/utils";
 import BaseAction from "./BaseAction";
 import { ActionName } from "./types";
+import * as fs from "fs";

 export interface ReturnDataType {
    message_id: string
@@ -23,6 +24,7 @@ class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
            chatType: ChatType.friend,
            peerUid: ""
        }
+        let deleteAfterSentFiles: string[] = []
        let group: Group | undefined = undefined;
        if (payload?.group_id) {
            group = await getGroup(payload.group_id.toString())
@@ -94,21 +96,21 @@ class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
                        }
                    }
                } break;
-                case OB11MessageDataType.image: {
-                    const file = sendMsg.data?.file
-                    if (file) {
-                        const picPath = await (await uri2local(uuid4(), file)).path
-                        if (picPath) {
-                            sendElements.push(await SendMsgElementConstructor.pic(picPath))
-                        }
-                    }
-                } break;
+                case OB11MessageDataType.image:
                case OB11MessageDataType.voice: {
                    const file = sendMsg.data?.file
                    if (file) {
-                        const voicePath = await (await uri2local(uuid4(), file)).path
-                        if (voicePath) {
-                            sendElements.push(await SendMsgElementConstructor.ptt(voicePath))
+                        const {path, isLocal} = (await uri2local(uuid4(), file))
+                        if (path) {
+                            if (!isLocal){ // 只删除http和base64转过来的文件
+                                deleteAfterSentFiles.push(path)
+                            }
+                            if (sendMsg.type === OB11MessageDataType.image){
+                                sendElements.push(await SendMsgElementConstructor.pic(path))
+                            }
+                            else {
+                                sendElements.push(await SendMsgElementConstructor.ptt(path))
+                            }
                        }
                    }
                }
@@ -117,6 +119,7 @@ class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
        // log("send msg:", peer, sendElements)
        try {
            const returnMsg = await NTQQApi.sendMsg(peer, sendElements)
+            deleteAfterSentFiles.map(f=>fs.unlink(f, ()=>{}))
            return { message_id: returnMsg.msgId }
        } catch (e) {
            throw(e.toString())
--- a/src/onebot11/constructor.ts
+++ b/src/onebot11/constructor.ts
@@ -1,7 +1,8 @@
 import {OB11MessageDataType, OB11GroupMemberRole, OB11Message, OB11MessageData, OB11Group, OB11GroupMember, OB11User} from "./types";
-import { AtType, ChatType, Group, GroupMember, RawMessage, SelfInfo, User } from '../ntqqapi/types';
+import { AtType, ChatType, Group, GroupMember, IMAGE_HTTP_HOST, RawMessage, SelfInfo, User } from '../ntqqapi/types';
 import { getFriend, getGroupMember, getHistoryMsgBySeq, selfInfo } from '../common/data';
 import {file2base64, getConfigUtil, log} from "../common/utils";
+import { NTQQApi } from "../ntqqapi/ntcall";


 export class OB11Constructor {
@@ -53,10 +54,18 @@ export class OB11Constructor {
                    message_data["data"]["mention"] = "all"
                    message_data["data"]["qq"] = "all"
                } else {
-                    let uid = element.textElement.atUid
-                    let atMember = await getGroupMember(msg.peerUin, uid)
-                    message_data["data"]["mention"] = atMember?.uin
-                    message_data["data"]["qq"] = atMember?.uin
+                    let atUid = element.textElement.atNtUid
+                    let atQQ = element.textElement.atUid
+                    if (!atQQ || atQQ === "0"){
+                        const atMember = await getGroupMember(msg.peerUin, null, atUid)
+                        if (atMember){
+                            atQQ = atMember.uin
+                        }
+                    }
+                    if (atQQ){
+                        message_data["data"]["mention"] = atQQ
+                        message_data["data"]["qq"] = atQQ
+                    }
                }
            } else if (element.textElement) {
                message_data["type"] = "text"
@@ -66,6 +75,12 @@ export class OB11Constructor {
                message_data["data"]["file_id"] = element.picElement.fileUuid
                message_data["data"]["path"] = element.picElement.sourcePath
                message_data["data"]["file"] = element.picElement.sourcePath
+                try {
+                    await NTQQApi.downloadMedia(msg.msgId, msg.chatType, msg.peerUid,
+                        element.elementId, element.picElement.thumbPath.get(0), element.picElement.sourcePath)
+                }catch (e) {
+                    message_data["data"]["http_file"] = IMAGE_HTTP_HOST + element.picElement.originImageUrl
+                }
            } else if (element.replyElement) {
                message_data["type"] = "reply"
                const replyMsg = getHistoryMsgBySeq(element.replyElement.replayMsgSeq)
@@ -89,11 +104,13 @@ export class OB11Constructor {
                message_data["type"] = OB11MessageDataType.json;
                message_data["data"]["data"] = element.arkElement.bytesData;
            }
-            if (message_data.data.file) {
+            if (message_data.data.http_file){
+                message_data.data.file = message_data.data.http_file
+            }
+            else if (message_data.data.file) {
                let filePath: string = message_data.data.file;
                message_data.data.file = "file://" + filePath
                if (enableBase64) {
-                    // filePath = filePath.replace("\\Ori\\", "\\Thumb\\")
                    let {err, data} = await file2base64(filePath);
                    if (err) {
                        console.log("文件转base64失败", err)
@@ -106,16 +123,6 @@ export class OB11Constructor {
                resMsg.message.push(message_data);
            }
        }
-        // if (msgHistory.length > 10000) {
-        //     msgHistory.splice(0, 100)
-        // }
-        // msgHistory.push(message)
-        // if (!reportSelfMessage && onebot_message_data["user_id"] == self_qq) {
-        //     console.log("开启了不上传自己发送的消息，进行拦截 ", onebot_message_data);
-        // } else {
-        //     console.log("发送上传消息给ipc main", onebot_message_data);
-        //     window.llonebot.postData(onebot_message_data);
-        // }
        return resMsg;
    }
    
--- a/src/onebot11/utils.ts
+++ b/src/onebot11/utils.ts
@@ -6,6 +6,12 @@ const fs = require("fs").promises;
 export async function uri2local(fileName: string, uri: string){
    let filePath = path.join(CONFIG_DIR, fileName)
    let url = new URL(uri);
+    let res = {
+        success: false,
+        errMsg: "",
+        path: "",
+        isLocal: false
+    }
    if (url.protocol == "base64:") {
        // base64转成文件
        let base64Data = uri.split("base64://")[1]
@@ -13,51 +19,43 @@ export async function uri2local(fileName: string, uri: string){
            const buffer = Buffer.from(base64Data, 'base64');
            await fs.writeFile(filePath, buffer);
        } catch (e: any) {
-            return {
-                success: false,
-                errMsg: `base64文件下载失败,` + e.toString(),
-                path: ""
-            }
+            res.errMsg = `base64文件下载失败,` + e.toString()
+            return res
        }
    } else if (url.protocol == "http:" || url.protocol == "https:") {
        // 下载文件
-        let res = await fetch(url)
-        if (!res.ok) {
-            return {
-                success: false,
-                errMsg: `${url}下载失败,` + res.statusText,
-                path: ""
-            }
+        let fetchRes = await fetch(url)
+        if (!fetchRes.ok) {
+            res.errMsg = `${url}下载失败,` + fetchRes.statusText
+            return res
        }
-        let blob = await res.blob();
+        let blob = await fetchRes.blob();
        let buffer = await blob.arrayBuffer();
        try {
            await fs.writeFile(filePath, Buffer.from(buffer));
        } catch (e: any) {
-            return {
-                success: false,
-                errMsg: `${url}下载失败,` + e.toString(),
-                path: ""
-            }
+            res.errMsg = `${url}下载失败,` + e.toString()
+            return res
        }
    } else if (url.protocol === "file:"){
-        await fs.copyFile(url.pathname, filePath);
-        // filePath = (await NTQQApi.uploadFile(url.pathname)).path;
+        // await fs.copyFile(url.pathname, filePath);
+        if (process.platform === "win32"){
+            filePath = url.pathname.slice(1)
+        }
+        else{
+            filePath = url.pathname
+        }
+        res.isLocal = true
    }
    else{
-        return {
-            success: false,
-            errMsg: `不支持的file协议,` + url.protocol,
-            path: ""
-        }
+        res.errMsg = `不支持的file协议,` + url.protocol
+        return res
    }
-    if (isGIF(filePath)) {
+    if (isGIF(filePath) && !res.isLocal) {
        await fs.rename(filePath, filePath + ".gif");
        filePath += ".gif";
    }
-    return {
-        success: true,
-        errMsg: "",
-        path: filePath
-    };
+    res.success = true
+    res.path = filePath
+    return res
 }
Author	SHA1	Message	Date
linyuchen	1936671cb3	fix: self nickname fix: @member msg report fix: send file:// on Windows ver: 3.0.2	2024-02-13 18:37:01 +08:00
linyuchen	6a8d67a8ae	fix: self nickname fix: auto download receive image fix: @member msg report ver: 3.0.1	2024-02-13 13:12:16 +08:00