mirror of
https://github.com/LLOneBot/LLOneBot.git
synced 2024-11-22 01:56:33 +00:00
Compare commits
14 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
600addbf82 | ||
![]() |
f07f0111cd | ||
![]() |
923f72e5d3 | ||
![]() |
5b4001e411 | ||
![]() |
b950f01d51 | ||
![]() |
dc38275660 | ||
![]() |
3d077550cd | ||
![]() |
44fe01f94b | ||
![]() |
5f9679dfbf | ||
![]() |
bffa2d9a31 | ||
![]() |
0c131ff555 | ||
![]() |
a802e95d89 | ||
![]() |
5ae65e1cf8 | ||
![]() |
a826232e96 |
23
README.md
23
README.md
@@ -1,6 +1,6 @@
|
||||
# LLOneBot API
|
||||
|
||||
将NTQQLiteLoaderAPI封装成OneBot11/12标准的API
|
||||
将NTQQLiteLoaderAPI封装成OneBot11/12标准的API, V12没有完整测试
|
||||
|
||||
## 安装方法
|
||||
|
||||
@@ -18,7 +18,7 @@
|
||||
|
||||
## 支持的API
|
||||
|
||||
目前只支持http协议,不支持websocket,事件上报也是http协议
|
||||
目前只支持http协议POST方法,不支持websocket,事件上报也是http协议
|
||||
|
||||
- [x] 获取群列表
|
||||
- [x] 获取群成员列表
|
||||
@@ -38,4 +38,21 @@
|
||||
- [ ] 转发消息记录
|
||||
- [ ] 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**
|
||||
|
||||
## 示例
|
||||
|
||||

|
||||
|
||||
*暂时不支持`"message": "hello"`这种message为字符串的形式*
|
||||
|
BIN
doc/image/example.jpg
Normal file
BIN
doc/image/example.jpg
Normal file
Binary file not shown.
After Width: | Height: | Size: 102 KiB |
@@ -4,7 +4,7 @@
|
||||
"name": "LLOneBot",
|
||||
"slug": "LLOneBot",
|
||||
"description": "LiteLoaderQQNT的OneBotApi",
|
||||
"version": "0.1.0",
|
||||
"version": "1.2.6",
|
||||
"thumbnail": "./icon.png",
|
||||
"author": {
|
||||
"name": "linyuchen",
|
||||
|
@@ -9,9 +9,9 @@
|
||||
"build-main": "webpack --config webpack.main.config.js",
|
||||
"build-preload": "webpack --config webpack.preload.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/",
|
||||
"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\\\""
|
||||
},
|
||||
"author": "",
|
||||
|
@@ -7,5 +7,7 @@ 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"
|
@@ -139,7 +139,7 @@ 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 = {
|
||||
action: PostDataAction
|
||||
@@ -156,5 +156,5 @@ export type PostDataSendMsg = {
|
||||
|
||||
export type Config = {
|
||||
port: number,
|
||||
host: string,
|
||||
hosts: string[],
|
||||
}
|
||||
|
2
src/global.d.ts
vendored
2
src/global.d.ts
vendored
@@ -44,6 +44,8 @@ declare var llonebot: {
|
||||
getConfig():Promise<Config>;
|
||||
setSelfInfo(selfInfo: SelfInfo):void;
|
||||
downloadFile(arg: {uri: string, localFilePath: string}):Promise<string>;
|
||||
deleteFile(path: string[]):Promise<void>;
|
||||
getRunningStatus(): Promise<boolean>;
|
||||
};
|
||||
|
||||
declare global {
|
||||
|
@@ -1,10 +1,54 @@
|
||||
import {sendIPCRecallQQMsg, sendIPCSendQQMsg} from "./IPCSend";
|
||||
|
||||
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";
|
||||
|
||||
// @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) {
|
||||
if (!jsonData.params) {
|
||||
jsonData.params = jsonData
|
||||
|
||||
}
|
||||
let resData = {
|
||||
status: 0,
|
||||
retcode: 0,
|
||||
@@ -14,7 +58,22 @@ function handlePost(jsonData: any) {
|
||||
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);
|
||||
} else {
|
||||
resData.message = "发送失败, 请检查消息格式";
|
||||
resData.data = jsonData.message;
|
||||
}
|
||||
// == end ==
|
||||
} else if (jsonData.action == "get_group_list") {
|
||||
resData["data"] = groups.map(group => {
|
||||
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)
|
||||
if (group) {
|
||||
resData["data"] = {
|
||||
@@ -40,10 +98,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 +108,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 => {
|
||||
@@ -86,7 +142,8 @@ function handlePost(jsonData: any) {
|
||||
export function startExpress(port: number) {
|
||||
const app = express();
|
||||
// 中间件,用于解析POST请求的请求体
|
||||
app.use(express.urlencoded({extended: true}));
|
||||
app.use(express.urlencoded({extended: true, limit: "500mb"}));
|
||||
app.use(bodyParser({limit: '500mb'}))
|
||||
app.use(express.json());
|
||||
|
||||
function parseToOnebot12(action: PostDataAction) {
|
||||
@@ -97,8 +154,9 @@ export function startExpress(port: number) {
|
||||
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)
|
||||
|
@@ -11,10 +11,18 @@ export class ConfigUtil{
|
||||
|
||||
getConfig(): Config{
|
||||
if (!fs.existsSync(this.configPath)) {
|
||||
return {"port":3000, "host": "http://localhost:5000/"}
|
||||
return {port:3000, hosts: ["http://192.168.1.2:5000/"]}
|
||||
} else {
|
||||
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")
|
||||
}
|
||||
}
|
||||
|
@@ -1,36 +1,43 @@
|
||||
// 运行在 Electron 主进程 下的插件入口
|
||||
|
||||
import * as path from "path";
|
||||
|
||||
const fs = require('fs');
|
||||
import {ipcMain} from 'electron';
|
||||
|
||||
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
|
||||
} from "../common/IPCChannel";
|
||||
import {ConfigUtil} from "./config";
|
||||
import {startExpress} from "./HttpServer";
|
||||
import {log} from "./utils";
|
||||
import {friends, groups, selfInfo} from "./data";
|
||||
|
||||
const fs = require('fs');
|
||||
|
||||
let running = false;
|
||||
|
||||
|
||||
// 加载插件时触发
|
||||
function onLoad(plugin: any) {
|
||||
|
||||
const configFilePath = path.join(plugin.path.data, "config.json")
|
||||
let configUtil = new ConfigUtil(configFilePath)
|
||||
log("main onLoaded");
|
||||
function getConfigUtil() {
|
||||
const configFilePath = path.join(plugin.path.data, `config_${selfInfo.user_id}.json`)
|
||||
return new ConfigUtil(configFilePath)
|
||||
}
|
||||
|
||||
if (!fs.existsSync(plugin.path.data)) {
|
||||
fs.mkdirSync(plugin.path.data, {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}) => {
|
||||
let url = new URL(arg.uri);
|
||||
@@ -48,14 +55,15 @@ function onLoad(plugin: any) {
|
||||
let buffer = await blob.arrayBuffer();
|
||||
fs.writeFileSync(arg.localFilePath, Buffer.from(buffer));
|
||||
}
|
||||
// todo: 需要识别gif格式
|
||||
return arg.localFilePath;
|
||||
})
|
||||
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,21 +97,23 @@ function onLoad(plugin: any) {
|
||||
})
|
||||
|
||||
ipcMain.on(CHANNEL_POST_ONEBOT_DATA, (event: any, arg: any) => {
|
||||
try {
|
||||
fetch(configUtil.getConfig().host, {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
"x-self-id": selfInfo.user_id
|
||||
},
|
||||
body: JSON.stringify(arg)
|
||||
}).then((res: any) => {
|
||||
log("新消息事件上传");
|
||||
}, (err: any) => {
|
||||
log("新消息事件上传失败:" + err + JSON.stringify(arg));
|
||||
});
|
||||
} catch (e: any) {
|
||||
log(e.toString())
|
||||
for(const host of getConfigUtil().getConfig().hosts) {
|
||||
try {
|
||||
fetch(host, {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
"x-self-id": selfInfo.user_id
|
||||
},
|
||||
body: JSON.stringify(arg)
|
||||
}).then((res: any) => {
|
||||
log("新消息事件上传");
|
||||
}, (err: any) => {
|
||||
log("新消息事件上传失败:" + err + JSON.stringify(arg));
|
||||
});
|
||||
} catch (e: any) {
|
||||
log(e.toString())
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
@@ -111,9 +121,20 @@ 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;
|
||||
})
|
||||
}
|
||||
|
||||
|
@@ -3,10 +3,18 @@
|
||||
import {Config, Group, PostDataSendMsg, SelfInfo, 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
|
||||
} from "./common/IPCChannel";
|
||||
|
||||
|
||||
@@ -48,10 +56,16 @@ 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);
|
||||
}
|
||||
// startExpress,
|
||||
});
|
172
src/renderer.ts
172
src/renderer.ts
@@ -3,6 +3,8 @@
|
||||
// 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 {raw} from "express";
|
||||
|
||||
let self_qq: string = ""
|
||||
let groups: Group[] = []
|
||||
@@ -19,8 +21,27 @@ 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) {
|
||||
@@ -38,11 +59,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
|
||||
}
|
||||
|
||||
@@ -114,7 +135,7 @@ async function handleNewMessage(messages: MessageElement[]) {
|
||||
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)
|
||||
let friend = await getFriend(message.sender.uid)
|
||||
onebot_message_data.sender = {
|
||||
user_id: friend!.uin,
|
||||
nickname: friend!.nickName
|
||||
@@ -170,12 +191,12 @@ 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) {
|
||||
peer = {
|
||||
chatType: "private",
|
||||
name: friend.nickName,
|
||||
uid: friend.uin
|
||||
uid: friend.uid
|
||||
}
|
||||
}
|
||||
} else if (postData.action == "send_group_msg") {
|
||||
@@ -192,6 +213,7 @@ async function listenSendMessage(postData: PostDataSendMsg) {
|
||||
}
|
||||
}
|
||||
if (peer) {
|
||||
let sendFiles: string[] = [];
|
||||
for (let message of postData.params.message) {
|
||||
if (message.type == "at") {
|
||||
// @ts-ignore
|
||||
@@ -211,6 +233,7 @@ async function listenSendMessage(postData: PostDataSendMsg) {
|
||||
let uri = new URL(url);
|
||||
let ext: string;
|
||||
if (message.type == "image") {
|
||||
// todo: 需要识别gif格式
|
||||
ext = ".png"
|
||||
}
|
||||
if (message.type == "voice") {
|
||||
@@ -219,11 +242,11 @@ async function listenSendMessage(postData: PostDataSendMsg) {
|
||||
let localFilePath = `${Date.now()}${ext}`
|
||||
if (uri.protocol == "file:") {
|
||||
localFilePath = url.split("file://")[1]
|
||||
}
|
||||
else{
|
||||
} else {
|
||||
await window.llonebot.downloadFile({uri: url, localFilePath: localFilePath})
|
||||
}
|
||||
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,9 +254,13 @@ 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),
|
||||
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))
|
||||
}
|
||||
}
|
||||
@@ -246,14 +273,11 @@ function recallMessage(msgId: string) {
|
||||
|
||||
let chatListEle: HTMLCollectionOf<Element>
|
||||
|
||||
function onLoad() {
|
||||
window.llonebot.startExpress();
|
||||
window.llonebot.listenSendMessage((postData: PostDataSendMsg) => {
|
||||
listenSendMessage(postData).then()
|
||||
});
|
||||
window.llonebot.listenRecallMessage((arg: { message_id: string }) => {
|
||||
recallMessage(arg.message_id)
|
||||
})
|
||||
async function onLoad(arg: any) {
|
||||
let runningStatus = await window.llonebot.getRunningStatus();
|
||||
if (runningStatus) {
|
||||
return;
|
||||
}
|
||||
|
||||
async function getGroupsMembers(groupsArg: Group[]) {
|
||||
// 批量获取群成员列表
|
||||
@@ -270,9 +294,12 @@ function onLoad() {
|
||||
getGroupsMembers(failedGroups).then()
|
||||
}, 1000)
|
||||
} else {
|
||||
console.log("全部群成员获取完毕", groups)
|
||||
window.llonebot.log("全部群成员获取完毕")
|
||||
}
|
||||
}
|
||||
await getFriends();
|
||||
await getGroups();
|
||||
await getGroupsMembers(groups);
|
||||
|
||||
function onNewMessages(messages: MessageElement[]) {
|
||||
async function func(messages: MessageElement[]) {
|
||||
@@ -285,24 +312,31 @@ function onLoad() {
|
||||
|
||||
func(messages).then(() => {
|
||||
})
|
||||
console.log("chatListEle", chatListEle)
|
||||
// console.log("chatListEle", chatListEle)
|
||||
}
|
||||
window.LLAPI.on("new-messages", onNewMessages);
|
||||
window.LLAPI.on("new-send-messages", onNewMessages);
|
||||
|
||||
getGroups().then(() => {
|
||||
getGroupsMembers(groups).then(() => {
|
||||
window.LLAPI.on("new-messages", onNewMessages);
|
||||
window.LLAPI.on("new-send-messages", onNewMessages);
|
||||
})
|
||||
})
|
||||
let accountInfo = await window.LLAPI.getAccountInfo();
|
||||
window.llonebot.log("getAccountInfo " + JSON.stringify(accountInfo));
|
||||
if (!accountInfo.uid) {
|
||||
return;
|
||||
}
|
||||
let selfInfo = await window.LLAPI.getUserInfo(accountInfo.uid);
|
||||
window.llonebot.setSelfInfo({
|
||||
user_id: accountInfo.uin,
|
||||
nickname: selfInfo.nickName
|
||||
});
|
||||
window.llonebot.log("selfInfo " + JSON.stringify(selfInfo))
|
||||
window.llonebot.startExpress();
|
||||
|
||||
window.LLAPI.getAccountInfo().then(accountInfo => {
|
||||
window.LLAPI.getUserInfo(accountInfo.uid).then(userInfo => {
|
||||
window.llonebot.setSelfInfo({
|
||||
user_id: accountInfo.uin,
|
||||
nickname: userInfo.nickName
|
||||
})
|
||||
})
|
||||
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) => {
|
||||
let btn = document.createElement("a")
|
||||
@@ -339,7 +373,7 @@ function onLoad() {
|
||||
}
|
||||
btn.innerText = "获取群成员列表"
|
||||
console.log(qContextMenu)
|
||||
qContextMenu.appendChild(btn)
|
||||
// qContextMenu.appendChild(btn)
|
||||
})
|
||||
|
||||
window.LLAPI.on("context-msg-menu", (event, target, msgIds) => {
|
||||
@@ -388,41 +422,77 @@ function onLoad() {
|
||||
|
||||
// 打开设置界面时触发
|
||||
async function onConfigView(view: any) {
|
||||
// 插件本体的路径
|
||||
// const plugin_path = (window as any).LiteLoader.plugins.LLOneBot.path;
|
||||
const {port, host} = await window.llonebot.getConfig()
|
||||
const {port, hosts} = 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 = `
|
||||
<section>
|
||||
<div>
|
||||
<label>监听端口</label>
|
||||
<section class="wrap">
|
||||
<div class="vertical-list-item">
|
||||
<h2>监听端口</h2>
|
||||
<input id="port" type="number" value="${port}"/>
|
||||
</div>
|
||||
<div>
|
||||
<label>事件上报地址(http)</label>
|
||||
<input id="host" type="text" value="${host}"/>
|
||||
<button id="addHost" class="q-button">添加上报地址</button>
|
||||
</div>
|
||||
<button id="save">保存(重启QQ后生效)</button>
|
||||
<div id="hostItems">
|
||||
${hostsEleStr}
|
||||
</div>
|
||||
<button id="save" class="q-button">保存(监听端口重启QQ后生效)</button>
|
||||
</section>
|
||||
`
|
||||
|
||||
const parser = new DOMParser();
|
||||
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",
|
||||
() => {
|
||||
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 host = doc.querySelector("input[type=text]")?.value
|
||||
// 获取端口和host
|
||||
const port = portEle.value
|
||||
const host = hostEle.value
|
||||
if (port && host) {
|
||||
window.llonebot.setConfig({
|
||||
port: parseInt(port),
|
||||
host: host
|
||||
})
|
||||
let hosts: string[] = [];
|
||||
for (const hostEle of hostEles) {
|
||||
if (hostEle.value) {
|
||||
hosts.push(hostEle.value);
|
||||
}
|
||||
}
|
||||
window.llonebot.setConfig({
|
||||
port: parseInt(port),
|
||||
hosts: hosts
|
||||
})
|
||||
alert("保存成功");
|
||||
})
|
||||
doc.querySelectorAll("section").forEach((node) => view.appendChild(node));
|
||||
|
||||
|
||||
}
|
||||
|
||||
export {
|
||||
|
Reference in New Issue
Block a user