fix: 不支持的消息不再上报

# Conflicts:
#	src/renderer.ts

.github/workflows/publish.yml

@@ -0,0 +1,36 @@
+name: "publish"
+on:
+  push:
+    tags:
+      - "v*"
+
+jobs:
+  build-and-publish:
+    runs-on: ubuntu-latest
+    steps:
+    - name: checkout
+      uses: actions/checkout@v3
+
+    - name: setup node
+      uses: actions/setup-node@v2
+      with:
+        node-version: 18
+
+    - name: install dependenies
+      run: npm install
+
+    - name: build
+      run: npm run build
+
+    - name: zip
+      run: |
+        sudo apt install zip -y
+        cp manifest.json ./dist/manifest.json
+        zip LLOneBot.zip ./dist/* -j
+    
+    - name: publish
+      uses: ncipollo/release-action@v1
+      with:
+        artifacts: "LLOneBot.zip"
+        draft: true
+        token: ${{ secrets.RELEASE_TOKEN }}

README.md

@@ -1,30 +1,32 @@
 # LLOneBot API
 
-将NTQQLiteLoaderAPI封装成OneBot11/12标准的API
+
+将NTQQLiteLoaderAPI封装成OneBot11/12标准的API, V12没有完整测试
+
+*注意：本文档对应的是 LiteLoader 1.0.0及以上版本，如果你使用的是旧版本请切换到本项目v1分支查看文档*
 
 ## 安装方法
 
-1.安装[NTQQLiteLoader](https://github.com/LiteLoaderQQNT/LiteLoaderQQNT)
+1.安装[LiteLoaderQQNT](https://liteloaderqqnt.github.io/guide/install.html)
 
-2.安装修改后的[LiteLoaderQQNT-Plugin-LLAPI](https://github.com/linyuchen/LiteLoaderQQNT-Plugin-LLAPI)，原版的功能有缺陷
+2.安装修改后的[LiteLoaderQQNT-Plugin-LLAPI](https://github.com/linyuchen/LiteLoaderQQNT-Plugin-LLAPI/releases)，原版的功能有缺陷
 
-3.安装本项目插件[OneBotApi](https://github.com/linyuchen/LiteLoaderQQNT-OneBotApi/releases/)
+3.安装本项目插件[OneBotApi](https://github.com/linyuchen/LiteLoaderQQNT-OneBotApi/releases/), 注意本插件2.0以下的版本不支持LiteLoader 1.0.0及以上版本
 
-*关于插件的安装方法: 上述的两个插件都没有上架NTQQLiteLoader插件市场，需要自己下载源码复制到插件目录*
+*关于插件的安装方法: 上述的两个插件都没有上架NTQQLiteLoader插件市场，需要自己下载复制到插件目录*
 
-*Windows插件目录:`%USERPROFILE%/Documents/LiteLoaderQQNT/plugins`*
-
-*Mac插件目录:`~/Library/Containers/com.tencent.qq/Data/Documents/LiteLoaderQQNT/plugins`*
+*插件目录:`LiteLoaderQQNT/plugins`*
 
 ## 支持的API
 
-目前只支持http协议，不支持websocket，事件上报也是http协议
+目前只支持http协议POST方法，不支持websocket，事件上报也是http协议
 
+主要功能:
+- [x] 发送好友消息
+- [x] 发送群消息
+- [x] 获取好友列表
 - [x] 获取群列表
 - [x] 获取群成员列表
-- [x] 获取好友列表
-- [x] 发送群消息
-- [x] 发送好友消息
 - [x] 撤回消息
 - [x] 上报好友消息
 - [x] 上报群消息
@@ -34,8 +36,95 @@
 - [x] 图片
 - [x] 引用消息
 - [x] @群成员
-- [x] 发送语音(只测试了silk编码的amr)
+- [x] 语音
+- [x] json消息(只上报)
+- [ ] 红包
 - [ ] 转发消息记录
 - [ ] xml
 
-**自己发送成功的消息也会上报，可以用于获取需要撤回消息的id**
+支持的api:
+- [x] get_login_info
+- [x] send_msg
+- [x] send_group_msg
+- [x] send_private_msg
+- [x] delete_msg
+- [x] get_group_list
+- [x] get_group_member_list
+- [x] get_group_member_info
+- [x] get_friend_list
+
+**自己发送成功的消息也会上报，可以用于获取需要撤回消息的id**
+
+## 示例
+
+![](doc/image/example.jpg)
+
+*暂时不支持`"message": "hello"`这种message为字符串的形式*
+
+## 一些坑
+
+<details>
+    <summary>下载了插件但是没有看到在NTQQ中生效</summary>
+<br/>
+    检查是否下载的是插件release的版本，如果是源码的话需要自行编译。依然不生效请查阅<a href="https://liteloaderqqnt.github.io/guide/plugins.html">LiteLoaderQQNT的文档</a>
+</details>
+<br/>
+
+<details>
+    <summary>调用接口报404</summary>
+<br/>
+    目前没有支持全部的onebot规范接口，请检查是否调用了不支持的接口，并且所有接口都只支持POST方法，调用GET方法会报404
+</details>
+<br/>
+
+<details>
+    <summary>发送不了图片和语音</summary>
+<br/>
+    检查当前操作用户是否有LiteLoaderQQNT/data/LLOneBot的写入权限，如Windows把QQ上安装到C盘有可能会出现无权限导致发送失败
+</details>
+<br/>
+
+<details>
+    <summary>不支持cq码</summary>
+<br/>
+    cq码已经过时了，没有支持的打算(主要是我不用这玩意儿，加上我懒)
+</details>
+<br/>
+
+<details>
+    <summary>onebot 12对接不了</summary>
+<br/>
+    onebot 12只写了部分兼容，没有完整测试，不保证能用，慎用
+</details>
+<br/>
+
+<details>
+    <summary>QQ变得很卡</summary>
+<br/>
+    这是你的群特别多导致的，因为启动后会批量获取群成员列表，获取完之后就正常了
+</details>
+<br/>
+
+<details>
+    <summary>撤回消息无效</summary>
+<br/>
+    如果接口调用的传的`message`是number类型会导致精度丢失，使用string类型可解决，详情见<a href="https://github.com/linyuchen/LiteLoaderQQNT-OneBotApi/issues/17">issue#17</a>
+</details>
+<br/>
+
+<details>
+    <summary>如何查看日志</summary>
+<br/>
+    LiteLoaderQQNT/data/LLOneBot/*.log
+</details>
+<br/>
+
+## TODO
+
+- [x] 接口返回更详细的错误信息，目前消息发不出去也会返回发送成功(这河里吗)
+- [ ] 转发消息记录 
+- [ ] 支持websocket，等个有缘人提PR实现
+- [ ] 重构摆脱LLAPI，目前调用LLAPI只能在renderer进程调用，需重构成在main进程调用
+
+## onebot11文档
+<https://11.onebot.dev/>

manifest.json

@@ -1,23 +1,23 @@
 {
-    "manifest_version": 3,
+    "manifest_version": 4,
     "type": "extension",
     "name": "LLOneBot",
     "slug": "LLOneBot",
     "description": "LiteLoaderQQNT的OneBotApi",
-    "version": "1.1.0",
+    "version": "2.2.0",
     "thumbnail": "./icon.png",
-    "author": {
+    "authors": [{
         "name": "linyuchen",
         "link": "https://github.com/linyuchen"
-    },
+    }],
     "repository": {
-        "repo": "linyuchen/LLOneBot",
-        "branch": "main",
-        "use_release": {
-            "tag": "latest",
-            "name": "LLOneBot.zip"
-        }
-    },
+    "repo": "linyuchen/LiteLoaderQQNT-OneBotApi",
+    "branch": "main",
+    "release": {
+        "tag": "latest",
+        "name": "LLOneBot.zip"
+    }
+},
     "platform": [
         "win32",
         "linux",

package-lock.json

@@ -9,7 +9,9 @@
       "version": "1.0.0",
       "license": "ISC",
       "dependencies": {
-        "express": "^4.18.2"
+        "express": "^4.18.2",
+        "json-bigint": "^1.0.0",
+        "uuid": "^9.0.1"
       },
       "devDependencies": {
         "@babel/preset-env": "^7.23.2",
@@ -2750,6 +2752,14 @@
         "@babel/core": "^7.4.0 || ^8.0.0-0 <8.0.0"
       }
     },
+    "node_modules/bignumber.js": {
+      "version": "9.1.2",
+      "resolved": "https://mirrors.cloud.tencent.com/npm/bignumber.js/-/bignumber.js-9.1.2.tgz",
+      "integrity": "sha512-2/mKyZH9K85bzOEfhXDBFZTGd1CTs+5IHpeFQo9luiBG7hghdC851Pj2WAhb6E3R6b9tZj/XKhbg4fum+Kepug==",
+      "engines": {
+        "node": "*"
+      }
+    },
     "node_modules/body-parser": {
       "version": "1.20.1",
       "resolved": "https://mirrors.cloud.tencent.com/npm/body-parser/-/body-parser-1.20.1.tgz",
@@ -4008,6 +4018,14 @@
         "node": ">=4"
       }
     },
+    "node_modules/json-bigint": {
+      "version": "1.0.0",
+      "resolved": "https://mirrors.cloud.tencent.com/npm/json-bigint/-/json-bigint-1.0.0.tgz",
+      "integrity": "sha512-SiPv/8VpZuWbvLSMtTDU8hEfrZWg/mH/nV/b4o0CYbSxu1UIQPLdwKOCIyLQX+VIPO5vrLX3i8qtqFyhdPSUSQ==",
+      "dependencies": {
+        "bignumber.js": "^9.0.0"
+      }
+    },
     "node_modules/json-buffer": {
       "version": "3.0.1",
       "resolved": "https://mirrors.cloud.tencent.com/npm/json-buffer/-/json-buffer-3.0.1.tgz",
@@ -5213,6 +5231,18 @@
         "node": ">= 0.4.0"
       }
     },
+    "node_modules/uuid": {
+      "version": "9.0.1",
+      "resolved": "https://mirrors.cloud.tencent.com/npm/uuid/-/uuid-9.0.1.tgz",
+      "integrity": "sha512-b+1eJOlsR9K8HJpow9Ok3fiWOWSIcIzXodvv0rQjVoOVNpWMpxf1wZNpt4y9h10odCNrqnYp1OBzRktckBe3sA==",
+      "funding": [
+        "https://github.com/sponsors/broofa",
+        "https://github.com/sponsors/ctavan"
+      ],
+      "bin": {
+        "uuid": "dist/bin/uuid"
+      }
+    },
     "node_modules/vary": {
       "version": "1.1.2",
       "resolved": "https://mirrors.cloud.tencent.com/npm/vary/-/vary-1.1.2.tgz",

package.json

@@ -17,16 +17,18 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "express": "^4.18.2"
+    "express": "^4.18.2",
+    "json-bigint": "^1.0.0",
+    "uuid": "^9.0.1"
   },
   "devDependencies": {
-    "electron": "^27.0.2",
     "@babel/preset-env": "^7.23.2",
     "@types/express": "^4.17.20",
     "babel-loader": "^9.1.3",
+    "electron": "^27.0.2",
     "ts-loader": "^9.5.0",
+    "typescript": "^5.2.2",
     "webpack": "^5.89.0",
-    "webpack-cli": "^5.1.4",
-    "typescript": "^5.2.2"
+    "webpack-cli": "^5.1.4"
   }
 }

src/common/IPCChannel.ts

@@ -7,5 +7,8 @@ export const CHANNEL_UPDATE_GROUPS = "llonebot_update_groups"
 export const CHANNEL_UPDATE_FRIENDS = "llonebot_update_friends"
 export const CHANNEL_LOG = "llonebot_log"
 export const CHANNEL_POST_ONEBOT_DATA = "llonebot_post_onebot_data"
-export const CHANNEL_GET_SELF_INFO= "llonebot_get_self_info"
-export const CHANNEL_DOWNLOAD_FILE= "llonebot_download_file"
+export const CHANNEL_SET_SELF_INFO= "llonebot_set_self_info"
+export const CHANNEL_DOWNLOAD_FILE= "llonebot_download_file"
+export const CHANNEL_DELETE_FILE= "llonebot_delete_file"
+export const CHANNEL_GET_RUNNING_STATUS= "llonebot_get_running_status"
+export const CHANNEL_FILE2BASE64= "llonebot_file2base64"

src/common/types.ts

@@ -1,9 +1,16 @@
 export enum AtType {
     notAt = 0,
+    atAll = 1,
     atUser = 2
 }
 
-export type GroupMemberInfo = {
+export enum ChatType {
+    friend = 1,
+    group = 2,
+    temp = 100
+}
+
+export interface GroupMemberInfo {
     avatarPath: string;
     cardName: string;
     cardType: number;
@@ -24,12 +31,12 @@ export const OnebotGroupMemberRole = {
 }
 
 
-export type SelfInfo = {
+export interface SelfInfo {
     user_id: string;
     nickname: string;
 }
 
-export type User = {
+export interface User {
     avatarUrl?: string;
     bio?: string;  // 签名
     nickName: string;
@@ -37,22 +44,52 @@ export type User = {
     uin: string; // QQ号
 }
 
-export type Group = {
+export interface Group {
     uid: string; // 群号
     name: string;
     members?: GroupMemberInfo[];
 }
 
-export type Peer = {
-    chatType: "private" | "group"
+export interface Peer {
+    chatType: ChatType
     name: string
     uid: string  // qq号
 }
 
-export type MessageElement = {
+export interface PttElement {
+    canConvert2Text: boolean
+    duration: number  // 秒数
+    fileBizId: null
+    fileId: number // 0
+    fileName: string // "e4d09c784d5a2abcb2f9980bdc7acfe6.amr"
+    filePath: string // "/Users//Library/Containers/com.tencent.qq/Data/Library/Application Support/QQ/nt_qq_a6b15c9820595d25a56c1633ce19ad40/nt_data/Ptt/2023-11/Ori/e4d09c784d5a2abcb2f9980bdc7acfe6.amr"
+    fileSize: string // "4261"
+    fileSubId: string // "0"
+    fileUuid: string // "90j3z7rmRphDPrdVgP9udFBaYar#oK0TWZIV"
+    formatType: string // 1
+    invalidState: number // 0
+    md5HexStr: string // "e4d09c784d5a2abcb2f9980bdc7acfe6"
+    playState: number // 0
+    progress: number // 0
+    text: string // ""
+    transferStatus: number // 0
+    translateStatus: number // 0
+    voiceChangeType: number // 0
+    voiceType: number // 0
+    waveAmplitudes: number[]
+}
+
+export interface ArkElement{
+    bytesData: string
+}
+
+export interface MessageElement {
     raw: {
         msgId: string,
+        msgTime: string,
         msgSeq: string,
+        senderUin: string; // 发送者QQ号
+        chatType: ChatType,
         elements: {
             replyElement: {
                 senderUid: string,  // 原消息发送者QQ号
@@ -74,31 +111,10 @@ export type MessageElement = {
                 fileName: string
                 fileUuid: string
             },
-            pttElement: {
-                canConvert2Text: boolean
-                duration: number  // 秒数
-                fileBizId: null
-                fileId: number // 0
-                fileName: string // "e4d09c784d5a2abcb2f9980bdc7acfe6.amr"
-                filePath: string // "/Users/C5366155/Library/Containers/com.tencent.qq/Data/Library/Application Support/QQ/nt_qq_a6b15c9820595d25a56c1633ce19ad40/nt_data/Ptt/2023-11/Ori/e4d09c784d5a2abcb2f9980bdc7acfe6.amr"
-                fileSize: string // "4261"
-                fileSubId: string // "0"
-                fileUuid: string // "90j3z7rmRphDPrdVgP9udFBaYar#oK0TWZIV"
-                formatType: string // 1
-                invalidState: number // 0
-                md5HexStr: string // "e4d09c784d5a2abcb2f9980bdc7acfe6"
-                playState: number // 0
-                progress: number // 0
-                text: string // ""
-                transferStatus: number // 0
-                translateStatus: number // 0
-                voiceChangeType: number // 0
-                voiceType: number // 0
-                waveAmplitudes: number[]
-            }
+            pttElement: PttElement,
+            arkElement: ArkElement
         }[]
     }
-
     peer: Peer,
     sender: {
         uid: string  // 一串加密的字符串
@@ -107,20 +123,29 @@ export type MessageElement = {
     }
 }
 
+export enum MessageType {
+    text = "text",
+    image = "image",
+    voice = "record",
+    at = "at",
+    reply = "reply",
+    json = "json"
+}
+
 export type SendMessage = {
-    type: "text",
+    type: MessageType.text,
     content: string,
     data?: {
         text: string, // 纯文本
     }
 } | {
-    type: "image" | "voice",
+    type: "image" | "voice" | "record",
     file: string, // 本地路径
     data?: {
         file: string // 本地路径
     }
 } | {
-    type: "at",
+    type: MessageType.at,
     atType?: AtType,
     content?: string,
     atUid?: string,
@@ -129,7 +154,7 @@ export type SendMessage = {
         qq: string // at的qq号
     }
 } | {
-    type: "reply",
+    type: MessageType.reply,
     msgId: string,
     msgSeq: string,
     senderUin: string,
@@ -139,9 +164,9 @@ export type SendMessage = {
 }
 
 export type PostDataAction = "send_private_msg" | "send_group_msg" | "get_group_list"
-| "get_friend_list" | "delete_msg" | "get_login_info"
+    | "get_friend_list" | "delete_msg" | "get_login_info" | "get_group_member_list" | "get_group_member_info"
 
-export type PostDataSendMsg = {
+export interface PostDataSendMsg {
     action: PostDataAction
     message_type?: "private" | "group"
     params?: {
@@ -152,9 +177,19 @@ export type PostDataSendMsg = {
     user_id: string,
     group_id: string,
     message: SendMessage[];
+    ipc_uuid?: string
 }
 
-export type Config = {
+export interface Config {
     port: number,
     hosts: string[],
+    enableBase64?: boolean
+    debug?: boolean
 }
+
+export interface SendMsgResult {
+    status: number,
+    retcode: number,
+    data: any,
+    message: string,
+}

src/global.d.ts

@@ -4,9 +4,9 @@ import {
     GroupMemberInfo,
     MessageElement,
     Peer,
-    PostDataSendMsg,
+    PostDataSendMsg, PttElement,
     SelfInfo,
-    SendMessage,
+    SendMessage, SendMsgResult,
     User
 } from "./common/types";
 
@@ -27,6 +27,7 @@ declare var LLAPI: {
     getGroupMemberList(group_id: string, num: number): Promise<{result: { infos: Map<string, GroupMemberInfo> }}>
     getPeer(): Promise<Peer>
     add_qmenu(func: (qContextMenu: Node)=>void): void
+    Ptt2Text(msgId:string, peer: Peer, elements: MessageElement[]): Promise<any>
 
 };
 
@@ -43,7 +44,11 @@ declare var llonebot: {
     setConfig(config: Config):void;
     getConfig():Promise<Config>;
     setSelfInfo(selfInfo: SelfInfo):void;
-    downloadFile(arg: {uri: string, localFilePath: string}):Promise<string>;
+    downloadFile(arg: {uri: string, fileName: string}):Promise<{errMsg: string, path: string}>;
+    deleteFile(path: string[]):Promise<void>;
+    getRunningStatus(): Promise<boolean>;
+    sendSendMsgResult(sessionId: string, msgResult: SendMsgResult): void;
+    file2base64(path: string): Promise<{err: string, data: string}>;
 };
 
 declare global {

src/main/HttpServer.ts

@@ -1,20 +1,82 @@
-import {sendIPCRecallQQMsg, sendIPCSendQQMsg} from "./IPCSend";
+import {log} from "./utils";
 
 const express = require("express");
-import {OnebotGroupMemberRole, PostDataAction, PostDataSendMsg} from "../common/types";
+const JSONbig = require('json-bigint');
+import {sendIPCRecallQQMsg, sendIPCSendQQMsg} from "./IPCSend";
+import {OnebotGroupMemberRole, PostDataAction, PostDataSendMsg, SendMessage, SendMsgResult} from "../common/types";
 import {friends, groups, selfInfo} from "./data";
 
-function handlePost(jsonData: any) {
+// @SiberianHusky 2021-08-15
+function checkSendMessage(sendMsgList: SendMessage[]) {
+    function checkUri(uri: string): boolean {
+        const pattern = /^(file:\/\/|http:\/\/|https:\/\/|base64:\/\/)/;
+        return pattern.test(uri);
+    }
+
+    for (let msg of sendMsgList) {
+        if (msg["type"] && msg["data"]) {
+            let type = msg["type"];
+            let data = msg["data"];
+            if (type === "text" && !data["text"]) {
+                return 400;
+            } else if (["image", "voice", "record"].includes(type)) {
+                if (!data["file"]) {
+                    return 400;
+                } else {
+                    if (checkUri(data["file"])) {
+                        return 200;
+                    } else {
+                        return 400;
+                    }
+                }
+
+            } else if (type === "at" && !data["qq"]) {
+                return 400;
+            } else if (type === "reply" && !data["id"]) {
+                return 400;
+            }
+        } else {
+            return 400
+        }
+    }
+    return 200;
+}
+
+// ==end==
+
+function handlePost(jsonData: any, handleSendResult: (data: SendMsgResult) => void) {
+    log("API receive post:" + JSON.stringify(jsonData))
+    if (!jsonData.params) {
+        jsonData.params = JSON.parse(JSON.stringify(jsonData));
+        delete jsonData.params.params;
+    }
     let resData = {
         status: 0,
         retcode: 0,
         data: {},
         message: ''
     }
+
     if (jsonData.action == "get_login_info") {
         resData["data"] = selfInfo
     } else if (jsonData.action == "send_private_msg" || jsonData.action == "send_group_msg") {
-        sendIPCSendQQMsg(jsonData);
+        if (jsonData.action == "send_private_msg") {
+            jsonData.message_type = "private"
+        } else {
+            jsonData.message_type = "group"
+        }
+        // @SiberianHuskY 2021-10-20 22:00:00
+        resData.status = checkSendMessage(jsonData.message);
+        if (resData.status == 200) {
+            resData.message = "发送成功";
+            resData.data = jsonData.message;
+            sendIPCSendQQMsg(jsonData, handleSendResult);
+            return;
+        } else {
+            resData.message = "发送失败, 请检查消息格式";
+            resData.data = jsonData.message;
+        }
+        // == end ==
     } else if (jsonData.action == "get_group_list") {
         resData["data"] = groups.map(group => {
             return {
@@ -30,8 +92,7 @@ function handlePost(jsonData: any) {
                 })
             }
         })
-    }
-    else if (jsonData.action == "get_group_info") {
+    } else if (jsonData.action == "get_group_info") {
         let group = groups.find(group => group.uid == jsonData.params.group_id)
         if (group) {
             resData["data"] = {
@@ -40,10 +101,9 @@ function handlePost(jsonData: any) {
                 member_count: group.members.length,
             }
         }
-    }
-    else if (jsonData.action == "get_group_member_info") {
+    } else if (jsonData.action == "get_group_member_info") {
         let member = groups.find(group => group.uid == jsonData.params.group_id)?.members?.find(member => member.uin == jsonData.params.user_id)
-        resData["data"] ={
+        resData["data"] = {
             user_id: member.uin,
             user_name: member.nick,
             user_display_name: member.cardName || member.nick,
@@ -51,8 +111,7 @@ function handlePost(jsonData: any) {
             card: member.cardName,
             role: OnebotGroupMemberRole[member.role],
         }
-    }
-    else if (jsonData.action == "get_group_member_list") {
+    } else if (jsonData.action == "get_group_member_list") {
         let group = groups.find(group => group.uid == jsonData.params.group_id)
         if (group) {
             resData["data"] = group?.members?.map(member => {
@@ -77,7 +136,7 @@ function handlePost(jsonData: any) {
             }
         })
     } else if (jsonData.action == "delete_msg") {
-        sendIPCRecallQQMsg(jsonData.message_id)
+        sendIPCRecallQQMsg(String(jsonData.message_id))
     }
     return resData
 }
@@ -86,19 +145,38 @@ function handlePost(jsonData: any) {
 export function startExpress(port: number) {
     const app = express();
     // 中间件，用于解析POST请求的请求体
-    app.use(express.urlencoded({extended: true}));
-    app.use(express.json());
+    app.use(express.urlencoded({extended: true, limit: "500mb"}));
+    app.use(express.json({
+        limit: '500mb',
+        verify: (req: any, res: any, buf: any, encoding: any) => {
+            req.rawBody = buf;
+        }
+    }));
+    app.use((req: any, res: any, next: any) => {
+        try {
+            req.body = JSONbig.parse(req.rawBody.toString());
+            next();
+        } catch (error) {
+            // next(error);
+            next();
+        }
+    });
 
     function parseToOnebot12(action: PostDataAction) {
         app.post('/' + action, (req: any, res: any) => {
             let jsonData: PostDataSendMsg = req.body;
             jsonData.action = action
-            let resData = handlePost(jsonData)
-            res.send(resData)
+            let resData = handlePost(jsonData, (data: SendMsgResult) => {
+                res.send(data)
+            })
+            if (resData) {
+                res.send(resData)
+            }
         });
     }
-    const actionList = ["get_login_info", "send_private_msg", "send_group_msg",
-        "get_group_list", "get_friend_list", "delete_msg"]
+
+    const actionList: PostDataAction[] = ["get_login_info", "send_private_msg", "send_group_msg",
+        "get_group_list", "get_friend_list", "delete_msg", "get_group_member_list", "get_group_member_info"]
 
     for (const action of actionList) {
         parseToOnebot12(action as PostDataAction)
@@ -112,8 +190,12 @@ export function startExpress(port: number) {
     // 处理POST请求的路由
     app.post('/', (req: any, res: any) => {
         let jsonData: PostDataSendMsg = req.body;
-        let resData = handlePost(jsonData)
-        res.send(resData)
+        let resData = handlePost(jsonData, (data: SendMsgResult) => {
+            res.send(data)
+        })
+        if (resData) {
+            res.send(resData)
+        }
     });
     app.post('/send_msg', (req: any, res: any) => {
         let jsonData: PostDataSendMsg = req.body;
@@ -128,11 +210,15 @@ export function startExpress(port: number) {
                 jsonData.action = "send_private_msg"
             }
         }
-        let resData = handlePost(jsonData)
-        res.send(resData)
+        let resData = handlePost(jsonData, (data: SendMsgResult) => {
+            res.send(data)
+        })
+        if (resData) {
+            res.send(resData)
+        }
     })
 
     app.listen(port, "0.0.0.0", () => {
-        console.log(`服务器已启动，监听端口 ${port}`);
+        console.log(`llonebot started 0.0.0.0:${port}`);
     });
 }

src/main/IPCSend.ts

@@ -1,6 +1,8 @@
 import {ipcMain, webContents} from 'electron';
-import {PostDataSendMsg} from "../common/types";
+import {PostDataSendMsg, SendMsgResult} from "../common/types";
 import {CHANNEL_RECALL_MSG, CHANNEL_SEND_MSG} from "../common/IPCChannel";
+import {v4 as uuid4} from "uuid";
+import {log} from "./utils";
 
 function sendIPCMsg(channel: string, data: any) {
     let contents = webContents.getAllWebContents();
@@ -8,15 +10,26 @@ function sendIPCMsg(channel: string, data: any) {
         try {
             content.send(channel, data)
         } catch (e) {
+            console.log("llonebot send ipc msg to render error:", e)
         }
     }
 }
 
 
-export function sendIPCSendQQMsg(postData: PostDataSendMsg) {
+export function sendIPCSendQQMsg(postData: PostDataSendMsg, handleSendResult: (data: SendMsgResult) => void) {
+    const onceSessionId = "llonebot_send_msg_" + uuid4();
+    postData.ipc_uuid = onceSessionId;
+    ipcMain.once(onceSessionId, (event: any, sendResult: SendMsgResult) => {
+        // log("llonebot send msg ipcMain.once:" + JSON.stringify(sendResult));
+        try {
+            handleSendResult(sendResult)
+        } catch (e) {
+            log("llonebot send msg ipcMain.once error:" + JSON.stringify(e))
+        }
+    })
     sendIPCMsg(CHANNEL_SEND_MSG, postData);
 }
 
 export function sendIPCRecallQQMsg(message_id: string) {
-    sendIPCMsg(CHANNEL_RECALL_MSG, {message_id});
+    sendIPCMsg(CHANNEL_RECALL_MSG, {message_id: message_id});
 }

src/main/config.ts

@@ -21,4 +21,8 @@ export class ConfigUtil{
             return jsonData;
         }
     }
+
+    setConfig(config: Config){
+        fs.writeFileSync(this.configPath, JSON.stringify(config, null, 2), "utf-8")
+    }
 }

src/main/main.ts

@@ -1,61 +1,113 @@
 // 运行在 Electron 主进程 下的插件入口
 
 import * as path from "path";
-
-const fs = require('fs');
 import {ipcMain} from 'electron';
+import * as util from 'util';
 
 import {Config, Group, SelfInfo, User} from "../common/types";
 import {
     CHANNEL_DOWNLOAD_FILE,
-    CHANNEL_GET_CONFIG, CHANNEL_GET_SELF_INFO, CHANNEL_LOG, CHANNEL_POST_ONEBOT_DATA,
+    CHANNEL_GET_CONFIG,
+    CHANNEL_SET_SELF_INFO,
+    CHANNEL_LOG,
+    CHANNEL_POST_ONEBOT_DATA,
     CHANNEL_SET_CONFIG,
-    CHANNEL_START_HTTP_SERVER, CHANNEL_UPDATE_FRIENDS,
-    CHANNEL_UPDATE_GROUPS
+    CHANNEL_START_HTTP_SERVER,
+    CHANNEL_UPDATE_FRIENDS,
+    CHANNEL_UPDATE_GROUPS, CHANNEL_DELETE_FILE, CHANNEL_GET_RUNNING_STATUS, CHANNEL_FILE2BASE64
 } from "../common/IPCChannel";
 import {ConfigUtil} from "./config";
 import {startExpress} from "./HttpServer";
-import {log} from "./utils";
+import {checkFileReceived, CONFIG_DIR, isGIF, log} from "./utils";
 import {friends, groups, selfInfo} from "./data";
+import {} from "../global";
 
+const fs = require('fs');
+
+let running = false;
 
 
 // 加载插件时触发
-function onLoad(plugin: any) {
+function onLoad() {
+    log("main onLoaded");
 
-    const configFilePath = path.join(plugin.path.data, "config.json")
-    let configUtil = new ConfigUtil(configFilePath)
+    // const config_dir = browserWindow.LiteLoader.plugins["LLOneBot"].path.data;
+    function getConfigUtil() {
+        const configFilePath = path.join(CONFIG_DIR, `config_${selfInfo.user_id}.json`)
+        return new ConfigUtil(configFilePath)
+    }
 
-    if (!fs.existsSync(plugin.path.data)) {
-        fs.mkdirSync(plugin.path.data, {recursive: true});
+    if (!fs.existsSync(CONFIG_DIR)) {
+        fs.mkdirSync(CONFIG_DIR, {recursive: true});
     }
     ipcMain.handle(CHANNEL_GET_CONFIG, (event: any, arg: any) => {
-        return configUtil.getConfig()
+        return getConfigUtil().getConfig()
     })
-    ipcMain.handle(CHANNEL_DOWNLOAD_FILE, async (event: any, arg: {uri: string, localFilePath: string}) => {
+    ipcMain.handle(CHANNEL_DOWNLOAD_FILE, async (event: any, arg: { uri: string, fileName: string }): Promise<{
+        success: boolean,
+        errMsg: string,
+        path: string
+    }> => {
+        let filePath = path.join(CONFIG_DIR, arg.fileName)
         let url = new URL(arg.uri);
-        if (url.protocol == "base64:"){
+        if (url.protocol == "base64:") {
             // base64转成文件
             let base64Data = arg.uri.split("base64://")[1]
-            const buffer = Buffer.from(base64Data, 'base64');
-
-            fs.writeFileSync(arg.localFilePath, buffer);
-        }
-        else if (url.protocol == "http:" || url.protocol == "https:") {
+            try {
+                const buffer = Buffer.from(base64Data, 'base64');
+                fs.writeFileSync(filePath, buffer);
+            } catch (e: any) {
+                return {
+                    success: false,
+                    errMsg: `base64文件下载失败,` + e.toString(),
+                    path: ""
+                }
+            }
+        } 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 blob = await res.blob();
             let buffer = await blob.arrayBuffer();
-            fs.writeFileSync(arg.localFilePath, Buffer.from(buffer));
+            try {
+                fs.writeFileSync(filePath, Buffer.from(buffer));
+            } catch (e: any) {
+                return {
+                    success: false,
+                    errMsg: `${url}下载失败,` + e.toString(),
+                    path: ""
+                }
+            }
         }
-        return arg.localFilePath;
+        else{
+            return {
+                success: false,
+                errMsg: `不支持的file协议,` + url.protocol,
+                path: ""
+            }
+        }
+        if (isGIF(filePath)) {
+            fs.renameSync(filePath, filePath + ".gif");
+            filePath += ".gif";
+        }
+        return {
+            success: true,
+            errMsg: "",
+            path: filePath
+        };
     })
     ipcMain.on(CHANNEL_SET_CONFIG, (event: any, arg: Config) => {
-        fs.writeFileSync(configFilePath, JSON.stringify(arg, null, 2), "utf-8")
+        getConfigUtil().setConfig(arg)
     })
 
     ipcMain.on(CHANNEL_START_HTTP_SERVER, (event: any, arg: any) => {
-        startExpress(configUtil.getConfig().port)
+        startExpress(getConfigUtil().getConfig().port)
     })
 
     ipcMain.on(CHANNEL_UPDATE_GROUPS, (event: any, arg: Group[]) => {
@@ -89,7 +141,7 @@ function onLoad(plugin: any) {
     })
 
     ipcMain.on(CHANNEL_POST_ONEBOT_DATA, (event: any, arg: any) => {
-        for(const host of configUtil.getConfig().hosts) {
+        for (const host of getConfigUtil().getConfig().hosts) {
             try {
                 fetch(host, {
                     method: "POST",
@@ -99,9 +151,9 @@ function onLoad(plugin: any) {
                     },
                     body: JSON.stringify(arg)
                 }).then((res: any) => {
-                    log("新消息事件上传");
+                    log(`新消息事件上传成功: ${host} ` + JSON.stringify(arg));
                 }, (err: any) => {
-                    log("新消息事件上传失败:" + err + JSON.stringify(arg));
+                    log(`新消息事件上传失败: ${host} ` + err + JSON.stringify(arg));
                 });
             } catch (e: any) {
                 log(e.toString())
@@ -113,20 +165,62 @@ function onLoad(plugin: any) {
         log(arg)
     })
 
-    ipcMain.on(CHANNEL_GET_SELF_INFO, (event: any, arg: SelfInfo) => {
+    ipcMain.handle(CHANNEL_SET_SELF_INFO, (event: any, arg: SelfInfo) => {
         selfInfo.user_id = arg.user_id;
         selfInfo.nickname = arg.nickname;
+        running = true;
+    })
+
+    ipcMain.on(CHANNEL_DELETE_FILE, (event: any, arg: string[]) => {
+        for (const path of arg) {
+            fs.unlinkSync(path);
+        }
+    })
+
+    ipcMain.handle(CHANNEL_GET_RUNNING_STATUS, (event: any, arg: any) => {
+        return running;
+    })
+
+    ipcMain.handle(CHANNEL_FILE2BASE64, async (event: any, path: string): Promise<{err: string, data: string}> => {
+        const readFile = util.promisify(fs.readFile);
+        let result = {
+            err: "",
+            data: ""
+        }
+        try {
+            // 读取文件内容
+            // if (!fs.existsSync(path)){
+            //     path = path.replace("\\Ori\\", "\\Thumb\\");
+            // }
+            try {
+                await checkFileReceived(path, 5000);
+            } catch (e: any) {
+                result.err = e.toString();
+                return result;
+            }
+            const data = await readFile(path);
+            // 转换为Base64编码
+            result.data = data.toString('base64');
+        } catch (err) {
+            result.err = err.toString();
+        }
+        return result;
     })
 }
 
 
 // 创建窗口时触发
-function onBrowserWindowCreated(window: any, plugin: any) {
+function onBrowserWindowCreated(window: any) {
 
 }
 
+try {
+    onLoad();
+} catch (e: any) {
+    console.log(e.toString())
+}
 
 // 这两个函数都是可选的
 export {
-    onLoad, onBrowserWindowCreated
+    onBrowserWindowCreated
 }

src/main/utils.ts

@@ -1,8 +1,47 @@
+import * as path from "path";
+import {json} from "express";
+import {selfInfo} from "./data";
+
 const fs = require('fs');
 
+export const CONFIG_DIR = global.LiteLoader.plugins["LLOneBot"].path.data;
 export function log(msg: any) {
     let currentDateTime = new Date().toLocaleString();
-    fs.appendFile("./llonebot.log", currentDateTime + ":" + msg + "\n", (err: any) => {
+    const date = new Date();
+    const year = date.getFullYear();
+    const month = date.getMonth() + 1;
+    const day = date.getDate();
+    const currentDate = `${year}-${month}-${day}`;
+    const userInfo = selfInfo.user_id ? `${selfInfo.nickname}(${selfInfo.user_id})` : ""
+    fs.appendFile(path.join(CONFIG_DIR , `llonebot-${currentDate}.log`), currentDateTime + ` ${userInfo}:` + JSON.stringify(msg) + "\n", (err: any) => {
 
     })
+}
+
+export function isGIF(path: string) {
+    const buffer = Buffer.alloc(4);
+    const fd = fs.openSync(path, 'r');
+    fs.readSync(fd, buffer, 0, 4, 0);
+    fs.closeSync(fd);
+    return buffer.toString() === 'GIF8'
+}
+
+
+// 定义一个异步函数来检查文件是否存在
+export function checkFileReceived(path: string, timeout: number=3000): Promise<void> {
+    return new Promise((resolve, reject) => {
+        const startTime = Date.now();
+
+        function check() {
+            if (fs.existsSync(path)) {
+                resolve();
+            } else if (Date.now() - startTime > timeout) {
+                reject(new Error(`文件不存在: ${path}`));
+            } else {
+                setTimeout(check, 100);
+            }
+        }
+
+        check();
+    });
 }

src/preload.ts

@@ -1,12 +1,20 @@
 // Electron 主进程 与 渲染进程 交互的桥梁
 
-import {Config, Group, PostDataSendMsg, SelfInfo, User} from "./common/types";
+import {Config, Group, PostDataSendMsg, SelfInfo, SendMsgResult, User} from "./common/types";
 import {
     CHANNEL_DOWNLOAD_FILE,
-    CHANNEL_GET_CONFIG, CHANNEL_GET_SELF_INFO, CHANNEL_LOG, CHANNEL_POST_ONEBOT_DATA,
-    CHANNEL_RECALL_MSG, CHANNEL_SEND_MSG,
+    CHANNEL_GET_CONFIG,
+    CHANNEL_SET_SELF_INFO,
+    CHANNEL_LOG,
+    CHANNEL_POST_ONEBOT_DATA,
+    CHANNEL_RECALL_MSG,
+    CHANNEL_SEND_MSG,
     CHANNEL_SET_CONFIG,
-    CHANNEL_START_HTTP_SERVER, CHANNEL_UPDATE_FRIENDS, CHANNEL_UPDATE_GROUPS
+    CHANNEL_START_HTTP_SERVER,
+    CHANNEL_UPDATE_FRIENDS,
+    CHANNEL_UPDATE_GROUPS,
+    CHANNEL_DELETE_FILE,
+    CHANNEL_GET_RUNNING_STATUS, CHANNEL_FILE2BASE64
 } from "./common/IPCChannel";
 
 
@@ -25,7 +33,11 @@ contextBridge.exposeInMainWorld("llonebot", {
     updateFriends: (friends: User[]) => {
         ipcRenderer.send(CHANNEL_UPDATE_FRIENDS, friends);
     },
+    sendSendMsgResult: (sessionId: string, msgResult: SendMsgResult)=>{
+        ipcRenderer.send(sessionId, msgResult);
+    },
     listenSendMessage: (handle: (jsonData: PostDataSendMsg) => void) => {
+        ipcRenderer.send(CHANNEL_LOG, "发送消息API已注册");
         ipcRenderer.on(CHANNEL_SEND_MSG, (event: any, args: PostDataSendMsg) => {
             handle(args)
         })
@@ -48,10 +60,19 @@ contextBridge.exposeInMainWorld("llonebot", {
         return ipcRenderer.invoke(CHANNEL_GET_CONFIG);
     },
     setSelfInfo(selfInfo: SelfInfo){
-        ipcRenderer.send(CHANNEL_GET_SELF_INFO, selfInfo)
+        ipcRenderer.invoke(CHANNEL_SET_SELF_INFO, selfInfo)
     },
-    downloadFile: async (arg: {uri: string, localFilePath: string}) => {
+    downloadFile: (arg: {uri: string, localFilePath: string}) => {
         return ipcRenderer.invoke(CHANNEL_DOWNLOAD_FILE, arg);
     },
+    deleteFile: async (localFilePath: string[]) => {
+        ipcRenderer.send(CHANNEL_DELETE_FILE, localFilePath);
+    },
+    getRunningStatus: () => {
+        return ipcRenderer.invoke(CHANNEL_GET_RUNNING_STATUS);
+    },
+    file2base64: (localFilePath: string) => {
+        return ipcRenderer.invoke(CHANNEL_FILE2BASE64, localFilePath);
+    }
     // startExpress,
 });

src/renderer.ts

@@ -2,14 +2,33 @@
 
 // import express from "express";
 // const { ipcRenderer } = require('electron');
-import {AtType, Group, MessageElement, OnebotGroupMemberRole, Peer, PostDataSendMsg, User} from "./common/types";
-import * as stream from "stream";
+import {
+    AtType,
+    ChatType,
+    Group,
+    MessageElement, MessageType,
+    OnebotGroupMemberRole,
+    Peer,
+    PostDataSendMsg,
+    SendMsgResult,
+    User
+} from "./common/types";
+import {checkFileReceived} from "./main/utils";
 
 let self_qq: string = ""
 let groups: Group[] = []
 let friends: User[] = []
 let msgHistory: MessageElement[] = []
 let uid_maps: Record<string, User> = {}  // 一串加密的字符串 -> qq号
+
+function getStrangerByUin(uin: string) {
+    for (const key in uid_maps) {
+        if (uid_maps[key].uin === uin) {
+            return uid_maps[key];
+        }
+    }
+}
+
 async function getUserInfo(uid: string): Promise<User> {
     let user = uid_maps[uid]
     if (!user) {
@@ -20,8 +39,25 @@ async function getUserInfo(uid: string): Promise<User> {
     return user
 }
 
-function getFriend(qq: string) {
-    return friends.find(friend => friend.uid == qq)
+async function getFriends() {
+    let _friends = await window.LLAPI.getFriendsList(false)
+    for (let friend of _friends) {
+        let existFriend = friends.find(f => f.uin == friend.uin)
+        if (!existFriend) {
+            friends.push(friend)
+        }
+    }
+    window.llonebot.updateFriends(friends)
+    return friends
+}
+
+async function getFriend(qq: string) {
+    let friend = friends.find(friend => friend.uin == qq)
+    if (!friend) {
+        await getFriends();
+        friend = friends.find(friend => friend.uin == qq);
+    }
+    return friend;
 }
 
 async function getGroup(qq: string) {
@@ -39,11 +75,11 @@ async function getGroups() {
         group.members = [];
         let existGroup = groups.find(g => g.uid == group.uid)
         if (!existGroup) {
-            console.log("更新群列表", groups)
+            // console.log("更新群列表", groups)
             groups.push(group)
-            window.llonebot.updateGroups(groups)
         }
     }
+    window.llonebot.updateGroups(groups)
     return groups
 }
 
@@ -62,6 +98,11 @@ async function getGroupMembers(group_qq: string, forced: boolean = false) {
             if (!group!.members!.find(m => m.uid == member.uid)) {
                 group!.members!.push(member)
             }
+            uid_maps[member.uid] = {
+                uin: member.uin,
+                uid: member.uid,
+                nickName: member.nick
+            };
         }
         window.llonebot.updateGroups(groups)
         console.log(`更新群${group.name}成员列表`, group)
@@ -82,8 +123,9 @@ async function getGroupMember(group_qq: string, member_uid: string) {
     }
 }
 
-
 async function handleNewMessage(messages: MessageElement[]) {
+    console.log("llonebot 收到消息:", messages);
+    const {debug, enableBase64} = await window.llonebot.getConfig();
     for (let message of messages) {
         let onebot_message_data: any = {
             self: {
@@ -91,18 +133,24 @@ async function handleNewMessage(messages: MessageElement[]) {
                 user_id: self_qq
             },
             self_id: self_qq,
-            time: 0,
+            time: parseInt(message.raw.msgTime || "0"),
             type: "message",
             post_type: "message",
             message_type: message.peer.chatType,
             detail_type: message.peer.chatType,
             message_id: message.raw.msgId,
             sub_type: "",
-            message: []
+            message: [],
+            raw_message: "",
+            font: 14
         }
-        if (message.peer.chatType == "group") {
+        if (debug) {
+            onebot_message_data.raw = JSON.parse(JSON.stringify(message))
+        }
+        if (message.raw.chatType == ChatType.group) {
             let group_id = message.peer.uid
             let group = (await getGroup(group_id))!
+            onebot_message_data.detail_type = onebot_message_data.message_type = onebot_message_data.sub_type = "group"
             onebot_message_data["group_id"] = message.peer.uid
             let groupMember = await getGroupMember(group_id, message.sender.uid)
             onebot_message_data["user_id"] = groupMember!.uin
@@ -112,24 +160,38 @@ async function handleNewMessage(messages: MessageElement[]) {
                 card: groupMember!.cardName,
                 role: OnebotGroupMemberRole[groupMember!.role]
             }
-            console.log("收到群消息", onebot_message_data)
-        } else if (message.peer.chatType == "private") {
-            onebot_message_data["user_id"] = message.peer.uid
-            let friend = getFriend(message.sender.uid)
+            // console.log("收到群消息", onebot_message_data)
+        } else if (message.raw.chatType == ChatType.friend) {
+            onebot_message_data["user_id"] = message.raw.senderUin;
+            onebot_message_data.detail_type = onebot_message_data.message_type = "private"
+            onebot_message_data.sub_type = "friend"
+            let friend = await getFriend(message.raw.senderUin);
             onebot_message_data.sender = {
                 user_id: friend!.uin,
                 nickname: friend!.nickName
             }
+        } else if (message.raw.chatType == ChatType.temp) {
+            let senderQQ = message.raw.senderUin;
+            let senderUid = message.sender.uid;
+            let sender = await getUserInfo(senderUid);
+            onebot_message_data["user_id"] = senderQQ;
+            onebot_message_data.detail_type = onebot_message_data.message_type = "private"
+            onebot_message_data.sub_type = "group";
+            onebot_message_data.sender = {
+                user_id: senderQQ,
+                nickname: sender.nickName
+            }
         }
         for (let element of message.raw.elements) {
             let message_data: any = {
                 data: {},
                 type: "unknown"
             }
-            if (element.textElement?.atType == AtType.atUser) {
+            if (element.textElement && element.textElement?.atType !== AtType.notAt) {
                 message_data["type"] = "at"
-                if (element.textElement.atUid != "0") {
-                    message_data["data"]["mention"] = element.textElement.atUid
+                if (element.textElement.atType == AtType.atAll) {
+                    message_data["data"]["mention"] = "all"
+                    message_data["data"]["qq"] = "all"
                 } else {
                     let uid = element.textElement.atNtUid
                     let atMember = await getGroupMember(message.peer.uid, uid)
@@ -143,16 +205,43 @@ async function handleNewMessage(messages: MessageElement[]) {
                 message_data["type"] = "image"
                 message_data["data"]["file_id"] = element.picElement.fileUuid
                 message_data["data"]["path"] = element.picElement.sourcePath
-                let startS = "file://"
-                if (!element.picElement.sourcePath.startsWith("/")) {
-                    startS += "/"
-                }
-                message_data["data"]["file"] = startS + element.picElement.sourcePath
+                message_data["data"]["file"] = element.picElement.sourcePath
             } else if (element.replyElement) {
                 message_data["type"] = "reply"
                 message_data["data"]["id"] = msgHistory.find(msg => msg.raw.msgSeq == element.replyElement.replayMsgSeq)?.raw.msgId
+            } else if (element.pttElement) {
+                message_data["type"] = MessageType.voice;
+                message_data["data"]["file"] = element.pttElement.filePath
+                message_data["data"]["file_id"] = element.pttElement.fileUuid
+                // console.log("收到语音消息", message.raw.msgId, message.peer, element.pttElement)
+                // window.LLAPI.Ptt2Text(message.raw.msgId, message.peer, messages).then(text => {
+                //     console.log("语音转文字结果", text);
+                // }).catch(err => {
+                //     console.log("语音转文字失败", err);
+                // })
+            } else if (element.arkElement) {
+                message_data["type"] = MessageType.json;
+                message_data["data"]["data"] = element.arkElement.bytesData;
             }
-            onebot_message_data.message.push(message_data)
+            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 window.llonebot.file2base64(filePath);
+                    if (err) {
+                        console.log("文件转base64失败", err)
+                    } else {
+                        message_data.data.file = "base64://" + data
+                    }
+                }
+            }
+            if (message_data.type !== "unknown"){
+                onebot_message_data.message.push(message_data);
+            }
+        }
+        if (msgHistory.length > 10000) {
+            msgHistory.splice(0, 100)
         }
         msgHistory.push(message)
         console.log("发送上传消息给ipc main", onebot_message_data)
@@ -161,6 +250,13 @@ async function handleNewMessage(messages: MessageElement[]) {
 }
 
 async function listenSendMessage(postData: PostDataSendMsg) {
+    console.log("收到发送消息请求", postData);
+    let sendMsgResult: SendMsgResult = {
+        retcode: 0,
+        status: 0,
+        data: {},
+        message: "发送成功"
+    }
     if (postData.action == "send_private_msg" || postData.action == "send_group_msg") {
         let peer: Peer | null = null;
         if (!postData.params) {
@@ -171,59 +267,101 @@ async function listenSendMessage(postData: PostDataSendMsg) {
             }
         }
         if (postData.action == "send_private_msg") {
-            let friend = getFriend(postData.params.user_id)
+            let friend = await getFriend(postData.params.user_id)
             if (friend) {
+                console.log("好友消息", postData)
                 peer = {
-                    chatType: "private",
+                    chatType: ChatType.friend,
                     name: friend.nickName,
-                    uid: friend.uin
+                    uid: friend.uid
+                }
+            } else {
+                // 临时消息
+                console.log("发送临时消息", postData)
+                let receiver = getStrangerByUin(postData.params.user_id);
+                if (receiver) {
+                    peer = {
+                        chatType: ChatType.temp,
+                        name: receiver.nickName,
+                        uid: receiver.uid
+                    }
+                } else {
+                    sendMsgResult.status = -1;
+                    sendMsgResult.retcode = -1;
+                    sendMsgResult.message = `发送失败，未找到对象${postData.params.user_id}，检查他是否为好友或是群友`;
                 }
             }
         } else if (postData.action == "send_group_msg") {
             let group = await getGroup(postData.params.group_id)
             if (group) {
                 peer = {
-                    chatType: "group",
+                    chatType: ChatType.group,
                     name: group.name,
                     uid: group.uid
                 }
 
             } else {
+                sendMsgResult.status = -1;
+                sendMsgResult.retcode = -1;
+                sendMsgResult.message = `发送失败，未找到群${postData.params.group_id}`;
                 console.log("未找到群, 发送群消息失败", postData)
             }
         }
         if (peer) {
+            let sendFiles: string[] = [];
             for (let message of postData.params.message) {
                 if (message.type == "at") {
                     // @ts-ignore
                     message.type = "text"
                     message.atType = AtType.atUser
                     let atUid = message.data?.qq || message.atUid
-                    let group = await getGroup(postData.params.group_id)
-                    let atMember = group.members.find(member => member.uin == atUid)
-                    message.atNtUid = atMember.uid
-                    message.atUid = atUid
-                    message.content = `@${atMember.cardName || atMember.nick}`
+                    if (atUid == "all") {
+                        message.atType = AtType.atAll
+                        atUid = "0";
+                        message.content = `@全体成员`
+                    }
+                    else {
+                        let group = await getGroup(postData.params.group_id)
+                        let atMember = group.members.find(member => member.uin == atUid)
+                        message.atNtUid = atMember.uid
+                        message.atUid = atUid
+                        message.content = `@${atMember.cardName || atMember.nick}`
+                    }
                 } else if (message.type == "text") {
                     message.content = message.data?.text || message.content
-                } else if (message.type == "image" || message.type == "voice") {
-                    // todo: 收到的应该是uri格式的，需要转成本地的, uri格式有三种，http, file, base64
+                } else if (message.type == "image" || message.type == "voice" || message.type == "record") {
+                    // 收到的是uri格式的，需要转成本地的, uri格式有三种，http, file, base64
                     let url = message.data?.file || message.file
                     let uri = new URL(url);
                     let ext: string;
                     if (message.type == "image") {
                         ext = ".png"
                     }
-                    if (message.type == "voice") {
+                    if (message.type == "voice" || message.type == "record") {
+                        message.type = "voice"
                         ext = ".amr"
                     }
                     let localFilePath = `${Date.now()}${ext}`
                     if (uri.protocol == "file:") {
                         localFilePath = url.split("file://")[1]
                     } else {
-                        await window.llonebot.downloadFile({uri: url, localFilePath: localFilePath})
+                        const {errMsg, path} = await window.llonebot.downloadFile({
+                            uri: url,
+                            fileName: `${Date.now()}${ext}`
+                        })
+                        console.log("下载文件结果", errMsg, path)
+                        if (errMsg) {
+                            console.log("下载文件失败", errMsg);
+                            sendMsgResult.status = -1;
+                            sendMsgResult.retcode = -1;
+                            sendMsgResult.message = `发送失败，下载文件失败，${errMsg}`;
+                            break;
+                        } else {
+                            localFilePath = path;
+                        }
                     }
                     message.file = localFilePath
+                    sendFiles.push(localFilePath);
                 } else if (message.type == "reply") {
                     let msgId = message.data?.id || message.msgId
                     let replyMessage = msgHistory.find(msg => msg.raw.msgId == msgId)
@@ -231,10 +369,28 @@ async function listenSendMessage(postData: PostDataSendMsg) {
                     message.msgSeq = replyMessage?.raw.msgSeq || ""
                 }
             }
-            // 发送完之后要删除下载的文件
             console.log("发送消息", postData)
-            window.LLAPI.sendMessage(peer, postData.params.message).then(res => console.log("消息发送成功:", res),
-                err => console.log("消息发送失败", postData, err))
+            if (sendMsgResult.status !== 0) {
+                window.llonebot.sendSendMsgResult(postData.ipc_uuid, sendMsgResult)
+                return;
+            }
+            window.LLAPI.sendMessage(peer, postData.params.message).then(res => {
+                    console.log("消息发送成功:", peer, postData.params.message)
+                    if (sendFiles.length) {
+                        window.llonebot.deleteFile(sendFiles);
+                    }
+                    window.llonebot.sendSendMsgResult(postData.ipc_uuid, sendMsgResult)
+                },
+                err => {
+                    sendMsgResult.status = -1;
+                    sendMsgResult.retcode = -1;
+                    sendMsgResult.message = `发送失败，${err}`;
+                    window.llonebot.sendSendMsgResult(postData.ipc_uuid, sendMsgResult)
+                    console.log("消息发送失败", postData, err)
+                })
+        } else {
+            console.log(sendMsgResult, postData);
+            window.llonebot.sendSendMsgResult(postData.ipc_uuid, sendMsgResult)
         }
     }
 }
@@ -246,180 +402,239 @@ function recallMessage(msgId: string) {
 
 let chatListEle: HTMLCollectionOf<Element>
 
-function onLoad() {
-    window.llonebot.startExpress();
-    window.llonebot.listenSendMessage((postData: PostDataSendMsg) => {
-        listenSendMessage(postData).then()
+async function getGroupsMembers(groupsArg: Group[]) {
+    // 批量获取群成员列表
+    let failedGroups: Group[] = []
+    for (const group of groupsArg) {
+        let handledGroup = await getGroupMembers(group.uid, true)
+        if (handledGroup.length == 0) {
+            failedGroups.push(group)
+        }
+    }
+    if (failedGroups.length > 0) {
+        console.log("获取群成员列表失败，重试", failedGroups.map(group => group.name))
+        setTimeout(() => {
+            getGroupsMembers(failedGroups).then()
+        }, 1000)
+    } else {
+        window.llonebot.log("全部群成员获取完毕")
+    }
+}
+
+function onNewMessages(messages: MessageElement[]) {
+    async function func(messages: MessageElement[]) {
+        console.log("收到新消息", messages)
+        if (!self_qq) {
+            self_qq = (await window.LLAPI.getAccountInfo()).uin
+        }
+        await handleNewMessage(messages);
+    }
+
+    func(messages).then(() => {
+    })
+    // console.log("chatListEle", chatListEle)
+}
+
+async function initAccountInfo() {
+    let accountInfo = await window.LLAPI.getAccountInfo();
+    window.llonebot.log("getAccountInfo " + JSON.stringify(accountInfo));
+    if (!accountInfo.uid) {
+        return false;
+    }
+    let selfInfo = await window.LLAPI.getUserInfo(accountInfo.uid);
+    window.llonebot.setSelfInfo({
+        user_id: accountInfo.uin,
+        nickname: selfInfo.nickName
     });
-    window.llonebot.listenRecallMessage((arg: { message_id: string }) => {
-        recallMessage(arg.message_id)
-    })
+    window.llonebot.log("selfInfo " + JSON.stringify(selfInfo));
+    return true;
+}
 
-    async function getGroupsMembers(groupsArg: Group[]) {
-        // 批量获取群成员列表
-        let failedGroups: Group[] = []
-        for (const group of groupsArg) {
-            let handledGroup = await getGroupMembers(group.uid, true)
-            if (handledGroup.length == 0) {
-                failedGroups.push(group)
-            }
+function onLoad() {
+    window.llonebot.log("llonebot render onLoad");
+    window.llonebot.getRunningStatus().then(running => {
+        if (running) {
+            return;
         }
-        if (failedGroups.length > 0) {
-            console.log("获取群成员列表失败，重试", failedGroups.map(group => group.name))
-            setTimeout(() => {
-                getGroupsMembers(failedGroups).then()
-            }, 1000)
-        } else {
-            console.log("全部群成员获取完毕", groups)
-        }
-    }
-
-    function onNewMessages(messages: MessageElement[]) {
-        async function func(messages: MessageElement[]) {
-            console.log("收到新消息", messages)
-            if (!self_qq) {
-                self_qq = (await window.LLAPI.getAccountInfo()).uin
-            }
-            await handleNewMessage(messages);
-        }
-
-        func(messages).then(() => {
-        })
-        console.log("chatListEle", chatListEle)
-    }
-
-    getGroups().then(() => {
-        getGroupsMembers(groups).then(() => {
-            window.LLAPI.on("new-messages", onNewMessages);
-            window.LLAPI.on("new-send-messages", onNewMessages);
-        })
-    })
-
-    window.LLAPI.getAccountInfo().then(accountInfo => {
-        window.LLAPI.getUserInfo(accountInfo.uid).then(userInfo => {
-            window.llonebot.setSelfInfo({
-                user_id: accountInfo.uin,
-                nickname: userInfo.nickName
-            })
-        })
-    })
-
-    window.LLAPI.add_qmenu((qContextMenu: Node) => {
-        let btn = document.createElement("a")
-        btn.className = "q-context-menu-item q-context-menu-item--normal vue-component"
-        btn.setAttribute("aria-disabled", "false")
-        btn.setAttribute("role", "menuitem")
-        btn.setAttribute("tabindex", "-1")
-        btn.onclick = () => {
-            // window.LLAPI.getPeer().then(peer => {
-            //     // console.log("current peer", peer)
-            //     if (peer && peer.chatType == "group") {
-            //         getGroupMembers(peer.uid, true).then(()=> {
-            //             console.log("获取群成员列表成功", groups);
-            //             alert("获取群成员列表成功")
-            //         })
-            //     }
-            // })
-            async function func() {
-                for (const group of groups) {
-                    await getGroupMembers(group.uid, true)
+        initAccountInfo().then(
+            (initSuccess) => {
+                if (!initSuccess) {
+                    return;
                 }
-            }
-
-            func().then(() => {
-                console.log("获取群成员列表结果", groups);
-                // 找到members数量为空的群
-                groups.map(group => {
-                    if (group.members.length == 0) {
-                        console.log(`${group.name}群成员为空`)
-                    }
-                })
-                window.llonebot.updateGroups(groups)
-            })
-        }
-        btn.innerText = "获取群成员列表"
-        console.log(qContextMenu)
-        qContextMenu.appendChild(btn)
-    })
-
-    window.LLAPI.on("context-msg-menu", (event, target, msgIds) => {
-        console.log("msg menu", event, target, msgIds);
-    })
-
-    // console.log("getAccountInfo", LLAPI.getAccountInfo());
-    function getChatListEle() {
-        chatListEle = document.getElementsByClassName("viewport-list__inner")
-        console.log("chatListEle", chatListEle)
-        if (chatListEle.length == 0) {
-            setTimeout(getChatListEle, 500)
-        } else {
-            try {
-                // 选择要观察的目标节点
-                const targetNode = chatListEle[0];
-
-                // 创建一个观察器实例并传入回调函数
-                const observer = new MutationObserver(function (mutations) {
-                    mutations.forEach(function (mutation) {
-                        // console.log("chat list changed", mutation.type); // 输出 mutation 的类型
-                        // 获得当前聊天窗口
-                        window.LLAPI.getPeer().then(peer => {
-                            // console.log("current peer", peer)
-                            if (peer && peer.chatType == "group") {
-                                getGroupMembers(peer.uid, false).then()
-                            }
-                        })
+                if (friends.length == 0) {
+                    getFriends().then(() => {
                     });
-                });
+                }
+                if (groups.length == 0) {
+                    getGroups().then(() => {
+                        getGroupsMembers(groups).then(() => {
+                        });
+                    });
+                }
+                window.LLAPI.on("new-messages", onNewMessages);
+                window.LLAPI.on("new-send-messages", onNewMessages);
+                window.llonebot.log("llonebot render start");
+                window.llonebot.startExpress();
 
-                // 配置观察选项
-                const config = {attributes: true, childList: true, subtree: true};
-
-                // 传入目标节点和观察选项
-                observer.observe(targetNode, config);
-
-            } catch (e) {
-                window.llonebot.log(e)
+                window.llonebot.listenSendMessage((postData: PostDataSendMsg) => {
+                    listenSendMessage(postData).then().catch(err => console.log("listenSendMessage err", err))
+                })
+                window.llonebot.listenRecallMessage((arg: { message_id: string }) => {
+                    // console.log("listenRecallMessage", arg)
+                    recallMessage(arg.message_id)
+                })
+                window.llonebot.log("llonebot loaded");
+                //     window.LLAPI.add_qmenu((qContextMenu: Node) => {
+                //         let btn = document.createElement("a")
+                //         btn.className = "q-context-menu-item q-context-menu-item--normal vue-component"
+                //         btn.setAttribute("aria-disabled", "false")
+                //         btn.setAttribute("role", "menuitem")
+                //         btn.setAttribute("tabindex", "-1")
+                //         btn.onclick = () => {
+                //             // window.LLAPI.getPeer().then(peer => {
+                //             //     // console.log("current peer", peer)
+                //             //     if (peer && peer.chatType == "group") {
+                //             //         getGroupMembers(peer.uid, true).then(()=> {
+                //             //             console.log("获取群成员列表成功", groups);
+                //             //             alert("获取群成员列表成功")
+                //             //         })
+                //             //     }
+                //             // })
+                //             async function func() {
+                //                 for (const group of groups) {
+                //                     await getGroupMembers(group.uid, true)
+                //                 }
+                //             }
+                //
+                //             func().then(() => {
+                //                 console.log("获取群成员列表结果", groups);
+                //                 // 找到members数量为空的群
+                //                 groups.map(group => {
+                //                     if (group.members.length == 0) {
+                //                         console.log(`${group.name}群成员为空`)
+                //                     }
+                //                 })
+                //                 window.llonebot.updateGroups(groups)
+                //             })
+                //         }
+                //         btn.innerText = "获取群成员列表"
+                //         console.log(qContextMenu)
+                //         // qContextMenu.appendChild(btn)
+                //     })
+                //
+                //     window.LLAPI.on("context-msg-menu", (event, target, msgIds) => {
+                //         console.log("msg menu", event, target, msgIds);
+                //     })
+                //
+                //     // console.log("getAccountInfo", LLAPI.getAccountInfo());
+                //     function getChatListEle() {
+                //         chatListEle = document.getElementsByClassName("viewport-list__inner")
+                //         console.log("chatListEle", chatListEle)
+                //         if (chatListEle.length == 0) {
+                //             setTimeout(getChatListEle, 500)
+                //         } else {
+                //             try {
+                //                 // 选择要观察的目标节点
+                //                 const targetNode = chatListEle[0];
+                //
+                //                 // 创建一个观察器实例并传入回调函数
+                //                 const observer = new MutationObserver(function (mutations) {
+                //                     mutations.forEach(function (mutation) {
+                //                         // console.log("chat list changed", mutation.type); // 输出 mutation 的类型
+                //                         // 获得当前聊天窗口
+                //                         window.LLAPI.getPeer().then(peer => {
+                //                             // console.log("current peer", peer)
+                //                             if (peer && peer.chatType == "group") {
+                //                                 getGroupMembers(peer.uid, false).then()
+                //                             }
+                //                         })
+                //                     });
+                //                 });
+                //
+                //                 // 配置观察选项
+                //                 const config = {attributes: true, childList: true, subtree: true};
+                //
+                //                 // 传入目标节点和观察选项
+                //                 observer.observe(targetNode, config);
+                //
+                //             } catch (e) {
+                //                 window.llonebot.log(e)
+                //             }
+                //         }
+                //     }
+                //
+                //     // getChatListEle();
             }
-        }
-    }
-
-    // getChatListEle();
+        );
+    });
 }
 
 // 打开设置界面时触发
-async function onConfigView(view: any) {
-    const {port, hosts} = await window.llonebot.getConfig()
+async function onSettingWindowCreated(view: Element) {
+    window.llonebot.log("setting window created");
+    let config = await window.llonebot.getConfig()
 
     function creatHostEleStr(host: string) {
         let eleStr = `
-            <div class="hostItem vertical-list-item">
+            <setting-item data-direction="row" class="hostItem vertical-list-item">
                 <h2>事件上报地址(http)</h2>
-                <input class="host" type="text" value="${host}" 
+                <input class="host input-text" type="text" value="${host}" 
                 style="width:60%;padding: 5px"
-                placeholder="不支持localhost,如果是本机请填写局域网ip"/>
-            </div>
+                placeholder="如果localhost上报失败试试局域网ip"/>
+            </setting-item>
+
             `
         return eleStr
     }
 
     let hostsEleStr = ""
-    for (const host of hosts) {
+    for (const host of config.hosts) {
         hostsEleStr += creatHostEleStr(host);
     }
-    const html = `
-    <section class="wrap">
-        <div class="vertical-list-item">
-            <h2>监听端口</h2>
-            <input id="port" type="number" value="${port}"/>
-        </div>
-        <div>
-            <button id="addHost" class="q-button">添加上报地址</button>
-        </div>
-        <div id="hostItems">
-            ${hostsEleStr}
-        </div>
-        <button id="save" class="q-button">保存(监听端口重启QQ后生效)</button>
-    </section>
+    let html = `
+    <div class="config_view">
+        <setting-section>
+            <setting-panel>
+                <setting-list class="wrap">
+                    <setting-item class="vertical-list-item" data-direction="row">
+                        <setting-text>监听端口</setting-text>
+                        <input id="port" type="number" value="${config.port}"/>
+                    </setting-item>
+                    <div>
+                        <button id="addHost" class="q-button">添加上报地址</button>
+                    </div>
+                    <div id="hostItems">
+                        ${hostsEleStr}
+                    </div>
+                    <button id="save" class="q-button">保存(监听端口重启QQ后生效)</button>
+                </setting-list>
+            </setting-panel>
+            <setting-panel>
+                <setting-item data-direction="row" class="hostItem vertical-list-item">
+                    <div>
+                        <div>上报文件进行base64编码</div>
+                        <div class="tips">不开启时，上报文件将以本地路径形式发送</div>
+                    </div>
+                    <setting-switch id="switchBase64" ${config.enableBase64 ? "is-active" : ""}></setting-switch>
+                </setting-item>
+                <setting-item data-direction="row" class="hostItem vertical-list-item">
+                    <div>
+                        <div>debug模式</div>
+                        <div class="tips">开启后上报消息添加raw字段附带原始消息</div>
+                    </div>
+                    <setting-switch id="debug" ${config.debug ? "is-active" : ""}></setting-switch>
+                </setting-item>
+            </setting-panel>
+        </setting-section>
+    </div>
+    <style>
+        setting-panel {
+            padding: 10px;
+        }
+        .tips {
+            font-size: 0.75rem;
+        }
+    </style>
     `
 
     const parser = new DOMParser();
@@ -428,7 +643,7 @@ async function onConfigView(view: any) {
 
     function addHostEle(initValue: string = "") {
         let addressDoc = parser.parseFromString(creatHostEleStr(initValue), "text/html");
-        let addressEle = addressDoc.querySelector("div")
+        let addressEle = addressDoc.querySelector("setting-item")
         let hostItemsEle = document.getElementById("hostItems");
         hostItemsEle.appendChild(addressEle);
     }
@@ -436,6 +651,23 @@ async function onConfigView(view: any) {
 
     doc.getElementById("addHost").addEventListener("click", () => addHostEle())
 
+    function switchClick(eleId: string, configKey: string) {
+        doc.getElementById(eleId)?.addEventListener("click", (e) => {
+            const switchEle = e.target as HTMLInputElement
+            if (config[configKey]) {
+                config[configKey] = false
+                switchEle.removeAttribute("is-active")
+            } else {
+                config[configKey] = true
+                switchEle.setAttribute("is-active", "")
+            }
+            window.llonebot.setConfig(config)
+        })
+    }
+
+    switchClick("debug", "debug");
+    switchClick("switchBase64", "enableBase64");
+
     doc.getElementById("save")?.addEventListener("click",
         () => {
             const portEle: HTMLInputElement = document.getElementById("port") as HTMLInputElement
@@ -450,18 +682,22 @@ async function onConfigView(view: any) {
                     hosts.push(hostEle.value);
                 }
             }
-            window.llonebot.setConfig({
-                port: parseInt(port),
-                hosts: hosts
-            })
+            config.port = parseInt(port);
+            config.hosts = hosts;
+            window.llonebot.setConfig(config);
             alert("保存成功");
         })
-    doc.querySelectorAll("section").forEach((node) => view.appendChild(node));
+
+
+    doc.body.childNodes.forEach(node => {
+        view.appendChild(node);
+    });
 
 
 }
 
+setTimeout(onLoad, 5000)
+
 export {
-    onLoad,
-    onConfigView
+    onSettingWindowCreated
 }