Compare commits

..

19 Commits

Author SHA1 Message Date
linyuchen
0a3ae76b89 v1.2.7 2024-01-20 23:24:49 +08:00
linyuchen
ddd60a6a79 fix voice record type 2024-01-20 23:24:24 +08:00
linyuchen
e4d8c5e72e Merge remote-tracking branch 'origin/main' 2024-01-20 22:28:03 +08:00
linyuchen
6d33fb8b14 check gif 2024-01-20 08:38:14 +08:00
linyuchen
2350e4dc75 Update README.md 2024-01-13 18:27:30 +08:00
linyuchen
600addbf82 fix: 打开插件设置界面导致插件多次监听 2023-12-14 02:10:30 +08:00
linyuchen
f07f0111cd perf: auto remove send files 2023-12-12 20:45:54 +08:00
linyuchen
923f72e5d3 perf: message data checker 2023-12-09 16:59:16 +08:00
linyuchen
5b4001e411 Merge pull request #2 from YDHusky/main
修改发送消息返回数据
2023-12-09 14:46:16 +08:00
husky
b950f01d51 修改发送消息返回数据 2023-12-08 23:24:22 +08:00
linyuchen
dc38275660 fix: send private msg 2023-12-08 16:52:31 +08:00
linyuchen
3d077550cd doc: example 2023-12-08 15:55:13 +08:00
linyuchen
44fe01f94b Update README.md 2023-12-08 01:13:35 -06:00
linyuchen
5f9679dfbf body size up to 500mb 2023-12-06 17:42:57 +08:00
linyuchen
bffa2d9a31 fix: body too large 2023-12-03 15:52:14 +08:00
linyuchen
0c131ff555 fix: get_group_member_list, send_private_msg, send_group_msg.
feat: auto identify qq to read config
2023-12-02 11:58:50 +08:00
linyuchen
a802e95d89 feat: auto copy manifest 2023-12-01 01:53:48 +08:00
linyuchen
5ae65e1cf8 feat: 支持多个事件上报地址(http) 2023-12-01 01:48:54 +08:00
linyuchen
a826232e96 ver 1.0.0 2023-11-30 22:18:41 +08:00
13 changed files with 320 additions and 114 deletions

View File

@@ -1,6 +1,6 @@
# LLOneBot API # LLOneBot API
将NTQQLiteLoaderAPI封装成OneBot11/12标准的API 将NTQQLiteLoaderAPI封装成OneBot11/12标准的API, V12没有完整测试
## 安装方法 ## 安装方法
@@ -18,7 +18,7 @@
## 支持的API ## 支持的API
目前只支持http协议不支持websocket事件上报也是http协议 目前只支持http协议POST方法不支持websocket事件上报也是http协议
- [x] 获取群列表 - [x] 获取群列表
- [x] 获取群成员列表 - [x] 获取群成员列表
@@ -38,4 +38,24 @@
- [ ] 转发消息记录 - [ ] 转发消息记录
- [ ] xml - [ ] xml
支持的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** **自己发送成功的消息也会上报可以用于获取需要撤回消息的id**
## 示例
![](doc/image/example.jpg)
*暂时不支持`"message": "hello"`这种message为字符串的形式*
## onebot11文档
<https://11.onebot.dev/>

BIN
doc/image/example.jpg Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 102 KiB

View File

@@ -4,7 +4,7 @@
"name": "LLOneBot", "name": "LLOneBot",
"slug": "LLOneBot", "slug": "LLOneBot",
"description": "LiteLoaderQQNT的OneBotApi", "description": "LiteLoaderQQNT的OneBotApi",
"version": "0.1.0", "version": "1.2.7",
"thumbnail": "./icon.png", "thumbnail": "./icon.png",
"author": { "author": {
"name": "linyuchen", "name": "linyuchen",

View File

@@ -9,9 +9,9 @@
"build-main": "webpack --config webpack.main.config.js", "build-main": "webpack --config webpack.main.config.js",
"build-preload": "webpack --config webpack.preload.config.js", "build-preload": "webpack --config webpack.preload.config.js",
"build-renderer": "webpack --config webpack.renderer.config.js", "build-renderer": "webpack --config webpack.renderer.config.js",
"build-mac": "npm run build && npm run deploy-mac", "build-mac": "npm run build && cp manifest.json dist/ && npm run deploy-mac",
"deploy-mac": "cp dist/* ~/Library/Containers/com.tencent.qq/Data/Documents/LiteLoaderQQNT/plugins/LLOnebot/", "deploy-mac": "cp dist/* ~/Library/Containers/com.tencent.qq/Data/Documents/LiteLoaderQQNT/plugins/LLOnebot/",
"build-win": "npm run build && npm run deploy-win", "build-win": "npm run build && cp manifest.json dist/ && npm run deploy-win",
"deploy-win": "cmd /c \"copy dist\\* %USERPROFILE%\\documents\\LiteLoaderQQNT\\plugins\\LLOnebot\\\"" "deploy-win": "cmd /c \"copy dist\\* %USERPROFILE%\\documents\\LiteLoaderQQNT\\plugins\\LLOnebot\\\""
}, },
"author": "", "author": "",

View File

@@ -7,5 +7,7 @@ export const CHANNEL_UPDATE_GROUPS = "llonebot_update_groups"
export const CHANNEL_UPDATE_FRIENDS = "llonebot_update_friends" export const CHANNEL_UPDATE_FRIENDS = "llonebot_update_friends"
export const CHANNEL_LOG = "llonebot_log" export const CHANNEL_LOG = "llonebot_log"
export const CHANNEL_POST_ONEBOT_DATA = "llonebot_post_onebot_data" export const CHANNEL_POST_ONEBOT_DATA = "llonebot_post_onebot_data"
export const CHANNEL_GET_SELF_INFO= "llonebot_get_self_info" export const CHANNEL_SET_SELF_INFO= "llonebot_set_self_info"
export const CHANNEL_DOWNLOAD_FILE= "llonebot_download_file" 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"

View File

@@ -114,7 +114,7 @@ export type SendMessage = {
text: string, // 纯文本 text: string, // 纯文本
} }
} | { } | {
type: "image" | "voice", type: "image" | "voice" | "record",
file: string, // 本地路径 file: string, // 本地路径
data?: { data?: {
file: string // 本地路径 file: string // 本地路径
@@ -139,7 +139,7 @@ export type SendMessage = {
} }
export type PostDataAction = "send_private_msg" | "send_group_msg" | "get_group_list" 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 type PostDataSendMsg = {
action: PostDataAction action: PostDataAction
@@ -156,5 +156,5 @@ export type PostDataSendMsg = {
export type Config = { export type Config = {
port: number, port: number,
host: string, hosts: string[],
} }

2
src/global.d.ts vendored
View File

@@ -44,6 +44,8 @@ declare var llonebot: {
getConfig():Promise<Config>; getConfig():Promise<Config>;
setSelfInfo(selfInfo: SelfInfo):void; setSelfInfo(selfInfo: SelfInfo):void;
downloadFile(arg: {uri: string, localFilePath: string}):Promise<string>; downloadFile(arg: {uri: string, localFilePath: string}):Promise<string>;
deleteFile(path: string[]):Promise<void>;
getRunningStatus(): Promise<boolean>;
}; };
declare global { declare global {

View File

@@ -1,10 +1,54 @@
import {sendIPCRecallQQMsg, sendIPCSendQQMsg} from "./IPCSend";
const express = require("express"); const express = require("express");
import {OnebotGroupMemberRole, PostDataAction, PostDataSendMsg} from "../common/types"; const bodyParser = require('body-parser');
import {sendIPCRecallQQMsg, sendIPCSendQQMsg} from "./IPCSend";
import {OnebotGroupMemberRole, PostDataAction, PostDataSendMsg, SendMessage} from "../common/types";
import {friends, groups, selfInfo} from "./data"; import {friends, groups, selfInfo} from "./data";
// @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"].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) { function handlePost(jsonData: any) {
if (!jsonData.params) {
jsonData.params = jsonData
}
let resData = { let resData = {
status: 0, status: 0,
retcode: 0, retcode: 0,
@@ -14,7 +58,22 @@ function handlePost(jsonData: any) {
if (jsonData.action == "get_login_info") { if (jsonData.action == "get_login_info") {
resData["data"] = selfInfo resData["data"] = selfInfo
} else if (jsonData.action == "send_private_msg" || jsonData.action == "send_group_msg") { } else if (jsonData.action == "send_private_msg" || jsonData.action == "send_group_msg") {
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); sendIPCSendQQMsg(jsonData);
} else {
resData.message = "发送失败, 请检查消息格式";
resData.data = jsonData.message;
}
// == end ==
} else if (jsonData.action == "get_group_list") { } else if (jsonData.action == "get_group_list") {
resData["data"] = groups.map(group => { resData["data"] = groups.map(group => {
return { return {
@@ -30,8 +89,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) let group = groups.find(group => group.uid == jsonData.params.group_id)
if (group) { if (group) {
resData["data"] = { resData["data"] = {
@@ -40,8 +98,7 @@ function handlePost(jsonData: any) {
member_count: group.members.length, 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) 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_id: member.uin,
@@ -51,8 +108,7 @@ function handlePost(jsonData: any) {
card: member.cardName, card: member.cardName,
role: OnebotGroupMemberRole[member.role], 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) let group = groups.find(group => group.uid == jsonData.params.group_id)
if (group) { if (group) {
resData["data"] = group?.members?.map(member => { resData["data"] = group?.members?.map(member => {
@@ -86,7 +142,8 @@ function handlePost(jsonData: any) {
export function startExpress(port: number) { export function startExpress(port: number) {
const app = express(); const app = express();
// 中间件用于解析POST请求的请求体 // 中间件用于解析POST请求的请求体
app.use(express.urlencoded({extended: true})); app.use(express.urlencoded({extended: true, limit: "500mb"}));
app.use(bodyParser({limit: '500mb'}))
app.use(express.json()); app.use(express.json());
function parseToOnebot12(action: PostDataAction) { function parseToOnebot12(action: PostDataAction) {
@@ -97,8 +154,9 @@ export function startExpress(port: number) {
res.send(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) { for (const action of actionList) {
parseToOnebot12(action as PostDataAction) parseToOnebot12(action as PostDataAction)

View File

@@ -11,10 +11,18 @@ export class ConfigUtil{
getConfig(): Config{ getConfig(): Config{
if (!fs.existsSync(this.configPath)) { if (!fs.existsSync(this.configPath)) {
return {"port":3000, "host": "http://localhost:5000/"} return {port:3000, hosts: ["http://192.168.1.2:5000/"]}
} else { } else {
const data = fs.readFileSync(this.configPath, "utf-8"); const data = fs.readFileSync(this.configPath, "utf-8");
return JSON.parse(data); let jsonData =JSON.parse(data);
if (!jsonData.hosts){
jsonData.hosts = []
}
return jsonData;
} }
} }
setConfig(config: Config){
fs.writeFileSync(this.configPath, JSON.stringify(config, null, 2), "utf-8")
}
} }

View File

@@ -1,36 +1,43 @@
// 运行在 Electron 主进程 下的插件入口 // 运行在 Electron 主进程 下的插件入口
import * as path from "path"; import * as path from "path";
const fs = require('fs');
import {ipcMain} from 'electron'; import {ipcMain} from 'electron';
import {Config, Group, SelfInfo, User} from "../common/types"; import {Config, Group, SelfInfo, User} from "../common/types";
import { import {
CHANNEL_DOWNLOAD_FILE, 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_SET_CONFIG,
CHANNEL_START_HTTP_SERVER, CHANNEL_UPDATE_FRIENDS, CHANNEL_START_HTTP_SERVER,
CHANNEL_UPDATE_GROUPS CHANNEL_UPDATE_FRIENDS,
CHANNEL_UPDATE_GROUPS, CHANNEL_DELETE_FILE, CHANNEL_GET_RUNNING_STATUS
} from "../common/IPCChannel"; } from "../common/IPCChannel";
import {ConfigUtil} from "./config"; import {ConfigUtil} from "./config";
import {startExpress} from "./HttpServer"; import {startExpress} from "./HttpServer";
import {log} from "./utils"; import {isGIF, log} from "./utils";
import {friends, groups, selfInfo} from "./data"; import {friends, groups, selfInfo} from "./data";
const fs = require('fs');
let running = false;
// 加载插件时触发 // 加载插件时触发
function onLoad(plugin: any) { function onLoad(plugin: any) {
log("main onLoaded");
const configFilePath = path.join(plugin.path.data, "config.json") function getConfigUtil() {
let configUtil = new ConfigUtil(configFilePath) const configFilePath = path.join(plugin.path.data, `config_${selfInfo.user_id}.json`)
return new ConfigUtil(configFilePath)
}
if (!fs.existsSync(plugin.path.data)) { if (!fs.existsSync(plugin.path.data)) {
fs.mkdirSync(plugin.path.data, {recursive: true}); fs.mkdirSync(plugin.path.data, {recursive: true});
} }
ipcMain.handle(CHANNEL_GET_CONFIG, (event: any, arg: any) => { 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, localFilePath: string}) => {
let url = new URL(arg.uri); let url = new URL(arg.uri);
@@ -48,14 +55,18 @@ function onLoad(plugin: any) {
let buffer = await blob.arrayBuffer(); let buffer = await blob.arrayBuffer();
fs.writeFileSync(arg.localFilePath, Buffer.from(buffer)); fs.writeFileSync(arg.localFilePath, Buffer.from(buffer));
} }
if (isGIF(arg.localFilePath)) {
fs.renameSync(arg.localFilePath, arg.localFilePath + ".gif");
arg.localFilePath += ".gif";
}
return arg.localFilePath; return arg.localFilePath;
}) })
ipcMain.on(CHANNEL_SET_CONFIG, (event: any, arg: Config) => { 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) => { 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[]) => { ipcMain.on(CHANNEL_UPDATE_GROUPS, (event: any, arg: Group[]) => {
@@ -89,8 +100,9 @@ function onLoad(plugin: any) {
}) })
ipcMain.on(CHANNEL_POST_ONEBOT_DATA, (event: any, arg: any) => { ipcMain.on(CHANNEL_POST_ONEBOT_DATA, (event: any, arg: any) => {
for(const host of getConfigUtil().getConfig().hosts) {
try { try {
fetch(configUtil.getConfig().host, { fetch(host, {
method: "POST", method: "POST",
headers: { headers: {
"Content-Type": "application/json", "Content-Type": "application/json",
@@ -105,15 +117,27 @@ function onLoad(plugin: any) {
} catch (e: any) { } catch (e: any) {
log(e.toString()) log(e.toString())
} }
}
}) })
ipcMain.on(CHANNEL_LOG, (event: any, arg: any) => { ipcMain.on(CHANNEL_LOG, (event: any, arg: any) => {
log(arg) 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.user_id = arg.user_id;
selfInfo.nickname = arg.nickname; 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;
}) })
} }

View File

@@ -6,3 +6,11 @@ export function log(msg: 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'
}

View File

@@ -3,10 +3,18 @@
import {Config, Group, PostDataSendMsg, SelfInfo, User} from "./common/types"; import {Config, Group, PostDataSendMsg, SelfInfo, User} from "./common/types";
import { import {
CHANNEL_DOWNLOAD_FILE, CHANNEL_DOWNLOAD_FILE,
CHANNEL_GET_CONFIG, CHANNEL_GET_SELF_INFO, CHANNEL_LOG, CHANNEL_POST_ONEBOT_DATA, CHANNEL_GET_CONFIG,
CHANNEL_RECALL_MSG, CHANNEL_SEND_MSG, CHANNEL_SET_SELF_INFO,
CHANNEL_LOG,
CHANNEL_POST_ONEBOT_DATA,
CHANNEL_RECALL_MSG,
CHANNEL_SEND_MSG,
CHANNEL_SET_CONFIG, 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
} from "./common/IPCChannel"; } from "./common/IPCChannel";
@@ -48,10 +56,16 @@ contextBridge.exposeInMainWorld("llonebot", {
return ipcRenderer.invoke(CHANNEL_GET_CONFIG); return ipcRenderer.invoke(CHANNEL_GET_CONFIG);
}, },
setSelfInfo(selfInfo: SelfInfo){ 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); 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);
}
// startExpress, // startExpress,
}); });

View File

@@ -3,6 +3,8 @@
// import express from "express"; // import express from "express";
// const { ipcRenderer } = require('electron'); // const { ipcRenderer } = require('electron');
import {AtType, Group, MessageElement, OnebotGroupMemberRole, Peer, PostDataSendMsg, User} from "./common/types"; import {AtType, Group, MessageElement, OnebotGroupMemberRole, Peer, PostDataSendMsg, User} from "./common/types";
import * as stream from "stream";
import {raw} from "express";
let self_qq: string = "" let self_qq: string = ""
let groups: Group[] = [] let groups: Group[] = []
@@ -19,8 +21,27 @@ async function getUserInfo(uid: string): Promise<User> {
return user return user
} }
function getFriend(qq: string) { async function getFriends() {
return friends.find(friend => friend.uid == qq) 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) { async function getGroup(qq: string) {
@@ -38,11 +59,11 @@ async function getGroups() {
group.members = []; group.members = [];
let existGroup = groups.find(g => g.uid == group.uid) let existGroup = groups.find(g => g.uid == group.uid)
if (!existGroup) { if (!existGroup) {
console.log("更新群列表", groups) // console.log("更新群列表", groups)
groups.push(group) groups.push(group)
}
}
window.llonebot.updateGroups(groups) window.llonebot.updateGroups(groups)
}
}
return groups return groups
} }
@@ -114,7 +135,7 @@ async function handleNewMessage(messages: MessageElement[]) {
console.log("收到群消息", onebot_message_data) console.log("收到群消息", onebot_message_data)
} else if (message.peer.chatType == "private") { } else if (message.peer.chatType == "private") {
onebot_message_data["user_id"] = message.peer.uid onebot_message_data["user_id"] = message.peer.uid
let friend = getFriend(message.sender.uid) let friend = await getFriend(message.sender.uid)
onebot_message_data.sender = { onebot_message_data.sender = {
user_id: friend!.uin, user_id: friend!.uin,
nickname: friend!.nickName nickname: friend!.nickName
@@ -170,12 +191,12 @@ async function listenSendMessage(postData: PostDataSendMsg) {
} }
} }
if (postData.action == "send_private_msg") { if (postData.action == "send_private_msg") {
let friend = getFriend(postData.params.user_id) let friend = await getFriend(postData.params.user_id)
if (friend) { if (friend) {
peer = { peer = {
chatType: "private", chatType: "private",
name: friend.nickName, name: friend.nickName,
uid: friend.uin uid: friend.uid
} }
} }
} else if (postData.action == "send_group_msg") { } else if (postData.action == "send_group_msg") {
@@ -192,6 +213,7 @@ async function listenSendMessage(postData: PostDataSendMsg) {
} }
} }
if (peer) { if (peer) {
let sendFiles: string[] = [];
for (let message of postData.params.message) { for (let message of postData.params.message) {
if (message.type == "at") { if (message.type == "at") {
// @ts-ignore // @ts-ignore
@@ -205,7 +227,7 @@ async function listenSendMessage(postData: PostDataSendMsg) {
message.content = `@${atMember.cardName || atMember.nick}` message.content = `@${atMember.cardName || atMember.nick}`
} else if (message.type == "text") { } else if (message.type == "text") {
message.content = message.data?.text || message.content message.content = message.data?.text || message.content
} else if (message.type == "image" || message.type == "voice") { } else if (message.type == "image" || message.type == "voice" || message.type == "record") {
// todo: 收到的应该是uri格式的需要转成本地的, uri格式有三种http, file, base64 // todo: 收到的应该是uri格式的需要转成本地的, uri格式有三种http, file, base64
let url = message.data?.file || message.file let url = message.data?.file || message.file
let uri = new URL(url); let uri = new URL(url);
@@ -213,17 +235,18 @@ async function listenSendMessage(postData: PostDataSendMsg) {
if (message.type == "image") { if (message.type == "image") {
ext = ".png" ext = ".png"
} }
if (message.type == "voice") { if (message.type == "voice" || message.type == "record") {
message.type = "voice"
ext = ".amr" ext = ".amr"
} }
let localFilePath = `${Date.now()}${ext}` let localFilePath = `${Date.now()}${ext}`
if (uri.protocol == "file:") { if (uri.protocol == "file:") {
localFilePath = url.split("file://")[1] localFilePath = url.split("file://")[1]
} } else {
else{ localFilePath = await window.llonebot.downloadFile({uri: url, localFilePath: localFilePath})
await window.llonebot.downloadFile({uri: url, localFilePath: localFilePath})
} }
message.file = localFilePath message.file = localFilePath
sendFiles.push(localFilePath);
} else if (message.type == "reply") { } else if (message.type == "reply") {
let msgId = message.data?.id || message.msgId let msgId = message.data?.id || message.msgId
let replyMessage = msgHistory.find(msg => msg.raw.msgId == msgId) let replyMessage = msgHistory.find(msg => msg.raw.msgId == msgId)
@@ -231,9 +254,13 @@ async function listenSendMessage(postData: PostDataSendMsg) {
message.msgSeq = replyMessage?.raw.msgSeq || "" message.msgSeq = replyMessage?.raw.msgSeq || ""
} }
} }
// 发送完之后要删除下载的文件
console.log("发送消息", postData) console.log("发送消息", postData)
window.LLAPI.sendMessage(peer, postData.params.message).then(res => console.log("消息发送成功:", res), window.LLAPI.sendMessage(peer, postData.params.message).then(res => {
console.log("消息发送成功:", peer, postData.params.message)
if (sendFiles.length) {
window.llonebot.deleteFile(sendFiles);
}
},
err => console.log("消息发送失败", postData, err)) err => console.log("消息发送失败", postData, err))
} }
} }
@@ -246,14 +273,11 @@ function recallMessage(msgId: string) {
let chatListEle: HTMLCollectionOf<Element> let chatListEle: HTMLCollectionOf<Element>
function onLoad() { async function onLoad(arg: any) {
window.llonebot.startExpress(); let runningStatus = await window.llonebot.getRunningStatus();
window.llonebot.listenSendMessage((postData: PostDataSendMsg) => { if (runningStatus) {
listenSendMessage(postData).then() return;
}); }
window.llonebot.listenRecallMessage((arg: { message_id: string }) => {
recallMessage(arg.message_id)
})
async function getGroupsMembers(groupsArg: Group[]) { async function getGroupsMembers(groupsArg: Group[]) {
// 批量获取群成员列表 // 批量获取群成员列表
@@ -270,9 +294,12 @@ function onLoad() {
getGroupsMembers(failedGroups).then() getGroupsMembers(failedGroups).then()
}, 1000) }, 1000)
} else { } else {
console.log("全部群成员获取完毕", groups) window.llonebot.log("全部群成员获取完毕")
} }
} }
await getFriends();
await getGroups();
await getGroupsMembers(groups);
function onNewMessages(messages: MessageElement[]) { function onNewMessages(messages: MessageElement[]) {
async function func(messages: MessageElement[]) { async function func(messages: MessageElement[]) {
@@ -285,24 +312,31 @@ function onLoad() {
func(messages).then(() => { func(messages).then(() => {
}) })
console.log("chatListEle", chatListEle) // console.log("chatListEle", chatListEle)
} }
getGroups().then(() => {
getGroupsMembers(groups).then(() => {
window.LLAPI.on("new-messages", onNewMessages); window.LLAPI.on("new-messages", onNewMessages);
window.LLAPI.on("new-send-messages", onNewMessages); window.LLAPI.on("new-send-messages", onNewMessages);
})
})
window.LLAPI.getAccountInfo().then(accountInfo => { let accountInfo = await window.LLAPI.getAccountInfo();
window.LLAPI.getUserInfo(accountInfo.uid).then(userInfo => { window.llonebot.log("getAccountInfo " + JSON.stringify(accountInfo));
if (!accountInfo.uid) {
return;
}
let selfInfo = await window.LLAPI.getUserInfo(accountInfo.uid);
window.llonebot.setSelfInfo({ window.llonebot.setSelfInfo({
user_id: accountInfo.uin, user_id: accountInfo.uin,
nickname: userInfo.nickName nickname: selfInfo.nickName
}) });
window.llonebot.log("selfInfo " + JSON.stringify(selfInfo))
window.llonebot.startExpress();
window.llonebot.listenSendMessage((postData: PostDataSendMsg) => {
listenSendMessage(postData).then().catch(err => console.log("listenSendMessage err", err))
}) })
window.llonebot.listenRecallMessage((arg: { message_id: string }) => {
recallMessage(arg.message_id)
}) })
window.llonebot.log("llonebot loaded");
window.LLAPI.add_qmenu((qContextMenu: Node) => { window.LLAPI.add_qmenu((qContextMenu: Node) => {
let btn = document.createElement("a") let btn = document.createElement("a")
@@ -339,7 +373,7 @@ function onLoad() {
} }
btn.innerText = "获取群成员列表" btn.innerText = "获取群成员列表"
console.log(qContextMenu) console.log(qContextMenu)
qContextMenu.appendChild(btn) // qContextMenu.appendChild(btn)
}) })
window.LLAPI.on("context-msg-menu", (event, target, msgIds) => { window.LLAPI.on("context-msg-menu", (event, target, msgIds) => {
@@ -388,41 +422,77 @@ function onLoad() {
// 打开设置界面时触发 // 打开设置界面时触发
async function onConfigView(view: any) { async function onConfigView(view: any) {
// 插件本体的路径 const {port, hosts} = await window.llonebot.getConfig()
// const plugin_path = (window as any).LiteLoader.plugins.LLOneBot.path;
const {port, host} = await window.llonebot.getConfig() function creatHostEleStr(host: string) {
let eleStr = `
<div class="hostItem vertical-list-item">
<h2>事件上报地址(http)</h2>
<input class="host" type="text" value="${host}"
style="width:60%;padding: 5px"
placeholder="不支持localhost,如果是本机请填写局域网ip"/>
</div>
`
return eleStr
}
let hostsEleStr = ""
for (const host of hosts) {
hostsEleStr += creatHostEleStr(host);
}
const html = ` const html = `
<section> <section class="wrap">
<div> <div class="vertical-list-item">
<label>监听端口</label> <h2>监听端口</h2>
<input id="port" type="number" value="${port}"/> <input id="port" type="number" value="${port}"/>
</div> </div>
<div> <div>
<label>事件上报地址(http)</label> <button id="addHost" class="q-button">添加上报地址</button>
<input id="host" type="text" value="${host}"/>
</div> </div>
<button id="save">保存(重启QQ后生效)</button> <div id="hostItems">
${hostsEleStr}
</div>
<button id="save" class="q-button">保存(监听端口重启QQ后生效)</button>
</section> </section>
` `
const parser = new DOMParser(); const parser = new DOMParser();
const doc = parser.parseFromString(html, "text/html"); const doc = parser.parseFromString(html, "text/html");
function addHostEle(initValue: string = "") {
let addressDoc = parser.parseFromString(creatHostEleStr(initValue), "text/html");
let addressEle = addressDoc.querySelector("div")
let hostItemsEle = document.getElementById("hostItems");
hostItemsEle.appendChild(addressEle);
}
doc.getElementById("addHost").addEventListener("click", () => addHostEle())
doc.getElementById("save")?.addEventListener("click", doc.getElementById("save")?.addEventListener("click",
() => { () => {
const portEle: HTMLInputElement = document.getElementById("port") as HTMLInputElement const portEle: HTMLInputElement = document.getElementById("port") as HTMLInputElement
const hostEle: HTMLInputElement = document.getElementById("host") as HTMLInputElement const hostEles: HTMLCollectionOf<HTMLInputElement> = document.getElementsByClassName("host") as HTMLCollectionOf<HTMLInputElement>;
// const port = doc.querySelector("input[type=number]")?.value // const port = doc.querySelector("input[type=number]")?.value
// const host = doc.querySelector("input[type=text]")?.value // const host = doc.querySelector("input[type=text]")?.value
// 获取端口和host // 获取端口和host
const port = portEle.value const port = portEle.value
const host = hostEle.value let hosts: string[] = [];
if (port && host) { for (const hostEle of hostEles) {
if (hostEle.value) {
hosts.push(hostEle.value);
}
}
window.llonebot.setConfig({ window.llonebot.setConfig({
port: parseInt(port), port: parseInt(port),
host: host hosts: hosts
}) })
} alert("保存成功");
}) })
doc.querySelectorAll("section").forEach((node) => view.appendChild(node)); doc.querySelectorAll("section").forEach((node) => view.appendChild(node));
} }
export { export {