mirror of
https://github.com/LLOneBot/LLOneBot.git
synced 2024-11-22 01:56:33 +00:00
Compare commits
17 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
f6263375f1 | ||
![]() |
f79581d97e | ||
![]() |
1f02c98c8f | ||
![]() |
e1e5c278b9 | ||
![]() |
104839f7ea | ||
![]() |
bb8771a5b4 | ||
![]() |
5c5105ce88 | ||
![]() |
1bf5e41bdc | ||
![]() |
cd679cc041 | ||
![]() |
eabee466bb | ||
![]() |
d3f93257ce | ||
![]() |
33f340ca81 | ||
![]() |
479e8c9d25 | ||
![]() |
30b8793ee1 | ||
![]() |
47b068737d | ||
![]() |
bfb67188ce | ||
![]() |
7ad384d407 |
@@ -39,6 +39,7 @@ const config: ElectronViteConfig = {
|
||||
...external.map(genCpModule),
|
||||
{ src: './manifest.json', dest: 'dist' },
|
||||
{ src: './icon.webp', dest: 'dist' },
|
||||
{ src: './src/ntqqapi/native/napcat-protocol-packet/Moehoo/*', dest: 'dist/main/Moehoo' },
|
||||
],
|
||||
}),
|
||||
],
|
||||
|
@@ -4,12 +4,16 @@
|
||||
"name": "LLOneBot",
|
||||
"slug": "LLOneBot",
|
||||
"description": "实现 OneBot 11 和 Satori 协议,用于 QQ 机器人开发",
|
||||
"version": "4.1.2",
|
||||
"version": "4.2.2",
|
||||
"icon": "./icon.webp",
|
||||
"authors": [
|
||||
{
|
||||
"name": "linyuchen",
|
||||
"link": "https://github.com/linyuchen"
|
||||
},
|
||||
{
|
||||
"name": "idranme",
|
||||
"link": "https://github.com/idranme"
|
||||
}
|
||||
],
|
||||
"repository": {
|
||||
|
@@ -26,7 +26,7 @@
|
||||
"cosmokit": "^1.6.3",
|
||||
"express": "^5.0.1",
|
||||
"fluent-ffmpeg": "^2.1.3",
|
||||
"minato": "^3.6.0",
|
||||
"minato": "^3.6.1",
|
||||
"protobufjs": "^7.4.0",
|
||||
"silk-wasm": "^3.6.3",
|
||||
"ts-case-convert": "^2.1.0",
|
||||
@@ -35,14 +35,14 @@
|
||||
"devDependencies": {
|
||||
"@types/cors": "^2.8.17",
|
||||
"@types/express": "^5.0.0",
|
||||
"@types/fluent-ffmpeg": "^2.1.26",
|
||||
"@types/fluent-ffmpeg": "^2.1.27",
|
||||
"@types/node": "^20.14.15",
|
||||
"@types/ws": "^8.5.12",
|
||||
"@types/ws": "^8.5.13",
|
||||
"electron": "^31.4.0",
|
||||
"electron-vite": "^2.3.0",
|
||||
"protobufjs-cli": "^1.1.3",
|
||||
"typescript": "^5.6.3",
|
||||
"vite": "^5.4.10 ",
|
||||
"vite": "^5.4.10",
|
||||
"vite-plugin-cp": "^4.0.8"
|
||||
},
|
||||
"packageManager": "yarn@4.5.1"
|
||||
|
@@ -13,6 +13,10 @@ const manifest = {
|
||||
{
|
||||
name: 'linyuchen',
|
||||
link: 'https://github.com/linyuchen'
|
||||
},
|
||||
{
|
||||
"name": "idranme",
|
||||
"link": "https://github.com/idranme"
|
||||
}
|
||||
],
|
||||
repository: {
|
||||
|
@@ -27,9 +27,10 @@ export function checkFileReceived(path: string, timeout: number = 3000): Promise
|
||||
|
||||
export function calculateFileMD5(filePath: string): Promise<string> {
|
||||
return new Promise((resolve, reject) => {
|
||||
const hash = createHash('md5')
|
||||
|
||||
// 创建一个流式读取器
|
||||
const stream = fs.createReadStream(filePath)
|
||||
const hash = createHash('md5')
|
||||
|
||||
stream.on('data', (data: Buffer) => {
|
||||
// 当读取到数据时,更新哈希对象的状态
|
||||
@@ -122,8 +123,11 @@ export async function uri2local(ctx: Context, uri: string, needExt?: boolean): P
|
||||
const { type } = checkUriType(uri)
|
||||
|
||||
if (type === FileUriType.FileURL) {
|
||||
const filePath = fileURLToPath(uri)
|
||||
const fileUri = uri.replace('%', '%25').replace('#', '%23')
|
||||
const filePath = fileURLToPath(fileUri)
|
||||
const fileName = path.basename(filePath)
|
||||
// console.log('fileURLToPath', filePath)
|
||||
// console.log('fileName', fileName)
|
||||
return { success: true, errMsg: '', fileName, path: filePath, isLocal: true }
|
||||
}
|
||||
|
||||
|
9
src/common/utils/window.ts
Normal file
9
src/common/utils/window.ts
Normal file
@@ -0,0 +1,9 @@
|
||||
import { BrowserWindow } from 'electron'
|
||||
import { log } from '@/common/utils'
|
||||
|
||||
export function getAllWindowIds(): number[] {
|
||||
const allWindows = BrowserWindow.getAllWindows();
|
||||
const ids = allWindows.map(window => window.id);
|
||||
log('getAllWindowIds', ids);
|
||||
return ids;
|
||||
}
|
@@ -180,7 +180,6 @@ function onLoad() {
|
||||
if (self.uin) {
|
||||
clearInterval(intervalId)
|
||||
log('process pid', process.pid)
|
||||
|
||||
const config = getConfigUtil().getConfig()
|
||||
|
||||
if (config.enableLLOB && (config.satori.enable || config.ob11.enable)) {
|
||||
@@ -191,7 +190,6 @@ function onLoad() {
|
||||
log('LLOneBot 开关设置为关闭,不启动 LLOneBot')
|
||||
return
|
||||
}
|
||||
|
||||
ctx.plugin(Log, {
|
||||
enable: config.log!,
|
||||
filename: logFileName
|
||||
@@ -230,6 +228,9 @@ function onLoad() {
|
||||
|
||||
// 创建窗口时触发
|
||||
function onBrowserWindowCreated(window: BrowserWindow) {
|
||||
if (window.id === 2) {
|
||||
mainWindow = window
|
||||
}
|
||||
}
|
||||
|
||||
try {
|
||||
|
@@ -19,7 +19,8 @@ import {
|
||||
import { selfInfo } from '../common/globalVars'
|
||||
import { version } from '../version'
|
||||
import { invoke } from './ntcall'
|
||||
import { Native } from './native/index'
|
||||
import { Native } from './native/crychic'
|
||||
import { initWrapperSession, NTQQPacketApi } from './native/napcat-protocol-packet'
|
||||
|
||||
declare module 'cordis' {
|
||||
interface Context {
|
||||
@@ -40,10 +41,14 @@ class Core extends Service {
|
||||
static inject = ['ntMsgApi', 'ntFriendApi', 'ntGroupApi', 'store']
|
||||
public startTime = 0
|
||||
public native
|
||||
public packet!: NTQQPacketApi
|
||||
|
||||
constructor(protected ctx: Context, public config: Core.Config) {
|
||||
super(ctx, 'app', true)
|
||||
this.native = new Native(ctx)
|
||||
initWrapperSession().then(session => {
|
||||
this.packet = new NTQQPacketApi(session)
|
||||
})
|
||||
}
|
||||
|
||||
public start() {
|
||||
|
@@ -2,6 +2,7 @@ import { NTMethod } from './ntcall'
|
||||
import { log } from '@/common/utils'
|
||||
import { randomUUID } from 'node:crypto'
|
||||
import { ipcMain } from 'electron'
|
||||
import { Dict } from 'cosmokit'
|
||||
|
||||
export const hookApiCallbacks: Record<string, (res: any) => void> = {}
|
||||
|
||||
@@ -40,30 +41,31 @@ const callHooks: Array<{
|
||||
}> = []
|
||||
|
||||
export function startHook() {
|
||||
log('start hook')
|
||||
|
||||
const senderExclude = Symbol()
|
||||
|
||||
ipcMain.emit = new Proxy(ipcMain.emit, {
|
||||
apply(target, thisArg, args: [eventName: string, ...args: any]) {
|
||||
if (args[2]?.eventName.startsWith('ns-LoggerApi')) {
|
||||
apply(target, thisArg, args: [channel: string, ...args: any]) {
|
||||
if (args[2]?.eventName?.startsWith('ns-LoggerApi')) {
|
||||
return target.apply(thisArg, args)
|
||||
}
|
||||
if (logHook) {
|
||||
log('request', args)
|
||||
}
|
||||
|
||||
const event = args[1]
|
||||
if (event.sender && !event.sender[senderExclude]) {
|
||||
event.sender[senderExclude] = true
|
||||
event.sender.send = new Proxy(event.sender.send, {
|
||||
apply(target, thisArg, args: any[]) {
|
||||
if (args[1].eventName?.startsWith('ns-LoggerApi')) {
|
||||
apply(target, thisArg, args: [channel: string, meta: Dict, data: Dict[]]) {
|
||||
if (args[1]?.eventName?.startsWith('ns-LoggerApi')) {
|
||||
return target.apply(thisArg, args)
|
||||
}
|
||||
if (logHook) {
|
||||
log('received', args)
|
||||
}
|
||||
|
||||
const callbackId = args[1].callbackId
|
||||
const callbackId = args[1]?.callbackId
|
||||
if (callbackId) {
|
||||
if (hookApiCallbacks[callbackId]) {
|
||||
Promise.resolve(hookApiCallbacks[callbackId](args[2]))
|
||||
@@ -95,7 +97,7 @@ export function startHook() {
|
||||
}
|
||||
}
|
||||
return target.apply(thisArg, args)
|
||||
}
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
|
@@ -1,9 +1,9 @@
|
||||
import { Context } from 'cordis'
|
||||
import { Dict } from 'cosmokit'
|
||||
import { getBuildVersion } from '@/common/utils/misc'
|
||||
import { TEMP_DIR } from '@/common/globalVars'
|
||||
import { getBuildVersion } from '../../../common/utils/misc'
|
||||
import { TEMP_DIR } from '../../../common/globalVars'
|
||||
import { copyFile } from 'fs/promises'
|
||||
import { ChatType, Peer } from '../types'
|
||||
import { ChatType, Peer } from '../../types'
|
||||
import path from 'node:path'
|
||||
import addon from './external/crychic-win32-x64.node?asset'
|
||||
|
||||
@@ -11,7 +11,7 @@ export class Native {
|
||||
public activated = false
|
||||
private crychic?: Dict
|
||||
private seq = 0
|
||||
private cb: Map<number, Function> = new Map()
|
||||
private cb: Map<number, (res: any) => void> = new Map()
|
||||
|
||||
constructor(private ctx: Context) {
|
||||
ctx.on('ready', () => {
|
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
17
src/ntqqapi/native/napcat-protocol-packet/index.d.ts
vendored
Normal file
17
src/ntqqapi/native/napcat-protocol-packet/index.d.ts
vendored
Normal file
@@ -0,0 +1,17 @@
|
||||
import { WrapperSession } from './wrapper-session/types';
|
||||
export { initWrapperSession } from './wrapper-session';
|
||||
export declare class NTQQPacketApi {
|
||||
private qqVersion;
|
||||
private packetSession;
|
||||
private logger;
|
||||
private readonly wrapperSession;
|
||||
constructor(wrapperSession: WrapperSession);
|
||||
get available(): boolean;
|
||||
private checkQQVersion;
|
||||
private InitSendPacket;
|
||||
private sendPacket;
|
||||
private sendOidbPacket;
|
||||
sendPokePacket(peer: number, group?: number): Promise<void>;
|
||||
sendGroupSignPacket(selfUin: string, groupCode: string): Promise<void>;
|
||||
sendSetSpecialTittlePacket(groupCode: string, uid: string, tittle: string): Promise<void>;
|
||||
}
|
7187
src/ntqqapi/native/napcat-protocol-packet/index.mjs
Normal file
7187
src/ntqqapi/native/napcat-protocol-packet/index.mjs
Normal file
File diff suppressed because one or more lines are too long
1
src/ntqqapi/native/napcat-protocol-packet/wrapper-session/index.d.ts
vendored
Normal file
1
src/ntqqapi/native/napcat-protocol-packet/wrapper-session/index.d.ts
vendored
Normal file
@@ -0,0 +1 @@
|
||||
export declare function initWrapperSession(): Promise<any>;
|
6
src/ntqqapi/native/napcat-protocol-packet/wrapper-session/types.d.ts
vendored
Normal file
6
src/ntqqapi/native/napcat-protocol-packet/wrapper-session/types.d.ts
vendored
Normal file
@@ -0,0 +1,6 @@
|
||||
export interface MsgService {
|
||||
sendSsoCmdReqByContend: (cmd: string, trace_id: string) => Promise<unknown>;
|
||||
}
|
||||
export type WrapperSession = {
|
||||
getMsgService(): MsgService;
|
||||
};
|
@@ -1,6 +1,6 @@
|
||||
import { ipcMain } from 'electron'
|
||||
import { hookApiCallbacks, registerReceiveHook, removeReceiveHook } from './hook'
|
||||
import { getBuildVersion, log } from '../common/utils'
|
||||
import { log } from '../common/utils'
|
||||
import { randomUUID } from 'node:crypto'
|
||||
import {
|
||||
GeneralCallResult,
|
||||
@@ -108,13 +108,26 @@ interface InvokeOptions<ReturnType> {
|
||||
timeout?: number
|
||||
}
|
||||
|
||||
let channel: NTChannel
|
||||
|
||||
function getChannel() {
|
||||
if (channel) {
|
||||
return channel
|
||||
}
|
||||
if (ipcMain.eventNames().includes(NTChannel.IPC_UP_2)) {
|
||||
return channel = NTChannel.IPC_UP_2
|
||||
} else {
|
||||
return channel = NTChannel.IPC_UP_3
|
||||
}
|
||||
}
|
||||
|
||||
export function invoke<
|
||||
R extends Awaited<ReturnType<Extract<NTService[S][M], (...args: any) => unknown>>>,
|
||||
S extends keyof NTService = any,
|
||||
M extends keyof NTService[S] & string = any
|
||||
>(method: Extract<unknown, `${S}/${M}`> | string, args: unknown[], options: InvokeOptions<R> = {}) {
|
||||
const className = options.className ?? NTClass.NT_API
|
||||
const channel = options.channel ?? getBuildVersion() >= 28788 ? NTChannel.IPC_UP_3 : NTChannel.IPC_UP_2
|
||||
const channel = options.channel ?? getChannel()
|
||||
const timeout = options.timeout ?? 5000
|
||||
const afterFirstCmd = options.afterFirstCmd ?? true
|
||||
let eventName = className + '-' + channel[channel.length - 1]
|
||||
|
@@ -442,6 +442,7 @@ export interface RawMessage {
|
||||
attrType: number
|
||||
attrId: string
|
||||
}>
|
||||
isOnlineMsg: boolean
|
||||
}
|
||||
|
||||
export interface Peer {
|
||||
|
@@ -23,8 +23,8 @@ interface FileResponse {
|
||||
export class DownloadFile extends BaseAction<Payload, FileResponse> {
|
||||
actionName = ActionName.GoCQHTTP_DownloadFile
|
||||
payloadSchema = Schema.object({
|
||||
url: String,
|
||||
base64: String,
|
||||
url: Schema.string(),
|
||||
base64: Schema.string(),
|
||||
headers: Schema.union([String, Schema.array(String)])
|
||||
})
|
||||
|
||||
|
@@ -12,6 +12,7 @@ interface Payload {
|
||||
interface Response extends OB11User {
|
||||
reg_time: number
|
||||
long_nick: string
|
||||
city: string
|
||||
}
|
||||
|
||||
export class GetStrangerInfo extends BaseAction<Payload, Response> {
|
||||
@@ -33,7 +34,8 @@ export class GetStrangerInfo extends BaseAction<Payload, Response> {
|
||||
level: data.detail.commonExt.qqLevel && calcQQLevel(data.detail.commonExt.qqLevel) || 0,
|
||||
login_days: 0,
|
||||
reg_time: data.detail.commonExt.regTime,
|
||||
long_nick: data.detail.simpleInfo.baseInfo.longNick
|
||||
long_nick: data.detail.simpleInfo.baseInfo.longNick,
|
||||
city: data.detail.commonExt.city
|
||||
}
|
||||
} else {
|
||||
const data = await this.ctx.ntUserApi.getUserDetailInfoByUin(uin)
|
||||
@@ -46,7 +48,8 @@ export class GetStrangerInfo extends BaseAction<Payload, Response> {
|
||||
level: data.info.qqLevel && calcQQLevel(data.info.qqLevel) || 0,
|
||||
login_days: 0,
|
||||
reg_time: data.info.regTime,
|
||||
long_nick: data.info.longNick
|
||||
long_nick: data.info.longNick,
|
||||
city: data.info.city
|
||||
}
|
||||
}
|
||||
}
|
||||
|
19
src/onebot11/action/go-cqhttp/SendGroupSign.ts
Normal file
19
src/onebot11/action/go-cqhttp/SendGroupSign.ts
Normal file
@@ -0,0 +1,19 @@
|
||||
import { BaseAction, Schema } from '../BaseAction'
|
||||
import { ActionName } from '../types'
|
||||
import { selfInfo } from '@/common/globalVars'
|
||||
|
||||
interface Payload {
|
||||
group_id: number | string
|
||||
}
|
||||
|
||||
export class SendGroupSign extends BaseAction<Payload, null> {
|
||||
actionName = ActionName.GoCQHTTP_SendGroupSign
|
||||
payloadSchema = Schema.object({
|
||||
group_id: Schema.union([Number, String]).required(),
|
||||
})
|
||||
|
||||
async _handle(payload: Payload) {
|
||||
await this.ctx.app.packet.sendGroupSignPacket(selfInfo.uin, payload.group_id.toString())
|
||||
return null
|
||||
}
|
||||
}
|
30
src/onebot11/action/go-cqhttp/SetGroupSpecialTitle.ts
Normal file
30
src/onebot11/action/go-cqhttp/SetGroupSpecialTitle.ts
Normal file
@@ -0,0 +1,30 @@
|
||||
import { BaseAction, Schema } from '../BaseAction'
|
||||
import { ActionName } from '../types'
|
||||
import { selfInfo } from '@/common/globalVars'
|
||||
import { GroupMemberRole } from '@/ntqqapi/types'
|
||||
|
||||
interface Payload {
|
||||
group_id: number | string
|
||||
user_id: number | string
|
||||
special_title?: string
|
||||
}
|
||||
|
||||
export class SetGroupSpecialTitle extends BaseAction<Payload, null> {
|
||||
actionName = ActionName.GoCQHTTP_SetGroupSpecialTitle
|
||||
payloadSchema = Schema.object({
|
||||
group_id: Schema.union([Number, String]).required(),
|
||||
user_id: Schema.union([Number, String]).required(),
|
||||
special_title: Schema.string()
|
||||
})
|
||||
|
||||
async _handle(payload: Payload) {
|
||||
const uid = await this.ctx.ntUserApi.getUidByUin(payload.user_id.toString(), payload.group_id.toString())
|
||||
if (!uid) throw new Error(`用户${payload.user_id}的uid获取失败`)
|
||||
const self = await this.ctx.ntGroupApi.getGroupMember(payload.group_id.toString(), selfInfo.uid, false)
|
||||
if (self.role !== GroupMemberRole.Owner){
|
||||
throw new Error(`不是群${payload.group_id}的群主,无法设置群头衔`)
|
||||
}
|
||||
await this.ctx.app.packet.sendSetSpecialTittlePacket(payload.group_id.toString(), uid, payload.special_title || "")
|
||||
return null
|
||||
}
|
||||
}
|
@@ -78,6 +78,8 @@ import { GroupPoke } from './llonebot/GroupPoke'
|
||||
import { FriendPoke } from './llonebot/FriendPoke'
|
||||
import { GetGroupFileSystemInfo } from './go-cqhttp/GetGroupFileSystemInfo'
|
||||
import { GetCredentials } from './system/GetCredentials'
|
||||
import { SetGroupSpecialTitle } from '@/onebot11/action/go-cqhttp/SetGroupSpecialTitle'
|
||||
import { SendGroupSign } from '@/onebot11/action/go-cqhttp/SendGroupSign'
|
||||
|
||||
export function initActionMap(adapter: Adapter) {
|
||||
const actionHandlers = [
|
||||
@@ -161,6 +163,8 @@ export function initActionMap(adapter: Adapter) {
|
||||
new DeleteFriend(adapter),
|
||||
new OCRImage(adapter),
|
||||
new GetGroupFileSystemInfo(adapter),
|
||||
new SetGroupSpecialTitle(adapter),
|
||||
new SendGroupSign(adapter),
|
||||
]
|
||||
const actionMap = new Map()
|
||||
for (const action of actionHandlers) {
|
||||
|
@@ -1,6 +1,5 @@
|
||||
import { BaseAction, Schema } from '../BaseAction'
|
||||
import { ActionName } from '../types'
|
||||
import { getBuildVersion } from '@/common/utils/misc'
|
||||
|
||||
interface Payload {
|
||||
user_id: number | string
|
||||
@@ -13,13 +12,15 @@ export class FriendPoke extends BaseAction<Payload, null> {
|
||||
})
|
||||
|
||||
async _handle(payload: Payload) {
|
||||
if (!this.ctx.app.native.checkPlatform()) {
|
||||
throw new Error('当前系统平台或架构不支持')
|
||||
}
|
||||
if (!this.ctx.app.native.checkVersion()) {
|
||||
throw new Error(`当前 QQ 版本 ${getBuildVersion()} 不支持,可尝试其他版本 27333—27597`)
|
||||
}
|
||||
await this.ctx.app.native.sendFriendPoke(+payload.user_id)
|
||||
// if (!this.ctx.app.native.checkPlatform()) {
|
||||
// throw new Error('当前系统平台或架构不支持')
|
||||
// }
|
||||
// if (!this.ctx.app.native.checkVersion()) {
|
||||
// throw new Error(`当前 QQ 版本 ${getBuildVersion()} 不支持,可尝试其他版本 27333—27597`)
|
||||
// }
|
||||
// await this.ctx.app.native.sendFriendPoke(+payload.user_id)
|
||||
|
||||
await this.ctx.app.packet.sendPokePacket(+payload.user_id)
|
||||
return null
|
||||
}
|
||||
}
|
||||
|
@@ -1,6 +1,5 @@
|
||||
import { BaseAction, Schema } from '../BaseAction'
|
||||
import { ActionName } from '../types'
|
||||
import { getBuildVersion } from '@/common/utils/misc'
|
||||
|
||||
interface Payload {
|
||||
group_id: number | string
|
||||
@@ -15,13 +14,14 @@ export class GroupPoke extends BaseAction<Payload, null> {
|
||||
})
|
||||
|
||||
async _handle(payload: Payload) {
|
||||
if (!this.ctx.app.native.checkPlatform()) {
|
||||
throw new Error('当前系统平台或架构不支持')
|
||||
}
|
||||
if (!this.ctx.app.native.checkVersion()) {
|
||||
throw new Error(`当前 QQ 版本 ${getBuildVersion()} 不支持,可尝试其他版本 27333—27597`)
|
||||
}
|
||||
await this.ctx.app.native.sendGroupPoke(+payload.group_id, +payload.user_id)
|
||||
// if (!this.ctx.app.native.checkPlatform()) {
|
||||
// throw new Error('当前系统平台或架构不支持')
|
||||
// }
|
||||
// if (!this.ctx.app.native.checkVersion()) {
|
||||
// throw new Error(`当前 QQ 版本 ${getBuildVersion()} 不支持,可尝试其他版本 27333—27597`)
|
||||
// }
|
||||
// await this.ctx.app.native.sendGroupPoke(+payload.group_id, +payload.user_id)
|
||||
await this.ctx.app.packet.sendPokePacket(+payload.user_id, +payload.group_id)
|
||||
return null
|
||||
}
|
||||
}
|
||||
|
@@ -7,62 +7,52 @@ import { ChatCacheListItemBasic, CacheFileType } from '@/ntqqapi/types'
|
||||
export default class CleanCache extends BaseAction<void, void> {
|
||||
actionName = ActionName.CleanCache
|
||||
|
||||
protected _handle(): Promise<void> {
|
||||
return new Promise<void>(async (res, rej) => {
|
||||
try {
|
||||
// dbUtil.clearCache()
|
||||
const cacheFilePaths: string[] = []
|
||||
protected async _handle(): Promise<void> {
|
||||
const cacheFilePaths: string[] = []
|
||||
|
||||
await this.ctx.ntFileCacheApi.setCacheSilentScan(false)
|
||||
await this.ctx.ntFileCacheApi.setCacheSilentScan(false)
|
||||
|
||||
cacheFilePaths.push(await this.ctx.ntFileCacheApi.getHotUpdateCachePath())
|
||||
cacheFilePaths.push(await this.ctx.ntFileCacheApi.getDesktopTmpPath())
|
||||
cacheFilePaths.push(await this.ctx.ntFileCacheApi.getHotUpdateCachePath())
|
||||
cacheFilePaths.push(await this.ctx.ntFileCacheApi.getDesktopTmpPath())
|
||||
|
||||
const list = await this.ctx.ntFileCacheApi.getCacheSessionPathList()
|
||||
list.forEach((e) => cacheFilePaths.push(e.value))
|
||||
const list = await this.ctx.ntFileCacheApi.getCacheSessionPathList()
|
||||
list.forEach((e) => cacheFilePaths.push(e.value))
|
||||
|
||||
// await NTQQApi.addCacheScannedPaths(); // XXX: 调用就崩溃,原因目前还未知
|
||||
const cacheScanResult = await this.ctx.ntFileCacheApi.scanCache()
|
||||
const cacheSize = parseInt(cacheScanResult.size[6])
|
||||
// await NTQQApi.addCacheScannedPaths(); // XXX: 调用就崩溃,原因目前还未知
|
||||
const cacheScanResult = await this.ctx.ntFileCacheApi.scanCache()
|
||||
const cacheSize = parseInt(cacheScanResult.size[6])
|
||||
|
||||
if (cacheScanResult.result !== 0) {
|
||||
throw 'Something went wrong while scanning cache. Code: ' + cacheScanResult.result
|
||||
}
|
||||
if (cacheScanResult.result !== 0) {
|
||||
throw 'Something went wrong while scanning cache. Code: ' + cacheScanResult.result
|
||||
}
|
||||
|
||||
await this.ctx.ntFileCacheApi.setCacheSilentScan(true)
|
||||
if (cacheSize > 0 && cacheFilePaths.length > 2) {
|
||||
// 存在缓存文件且大小不为 0 时执行清理动作
|
||||
// await NTQQApi.clearCache([ 'tmp', 'hotUpdate', ...cacheScanResult ]) // XXX: 也是调用就崩溃,调用 fs 删除得了
|
||||
deleteCachePath(cacheFilePaths)
|
||||
}
|
||||
await this.ctx.ntFileCacheApi.setCacheSilentScan(true)
|
||||
if (cacheSize > 0 && cacheFilePaths.length > 2) {
|
||||
// 存在缓存文件且大小不为 0 时执行清理动作
|
||||
// await NTQQApi.clearCache([ 'tmp', 'hotUpdate', ...cacheScanResult ]) // XXX: 也是调用就崩溃,调用 fs 删除得了
|
||||
deleteCachePath(cacheFilePaths)
|
||||
}
|
||||
|
||||
// 获取聊天记录列表
|
||||
// NOTE: 以防有人不需要删除聊天记录,暂时先注释掉,日后加个开关
|
||||
// const privateChatCache = await getCacheList(ChatType.friend); // 私聊消息
|
||||
// const groupChatCache = await getCacheList(ChatType.group); // 群聊消息
|
||||
// const chatCacheList = [ ...privateChatCache, ...groupChatCache ];
|
||||
const chatCacheList: ChatCacheListItemBasic[] = []
|
||||
// 获取聊天记录列表
|
||||
// NOTE: 以防有人不需要删除聊天记录,暂时先注释掉,日后加个开关
|
||||
// const privateChatCache = await getCacheList(ChatType.friend); // 私聊消息
|
||||
// const groupChatCache = await getCacheList(ChatType.group); // 群聊消息
|
||||
// const chatCacheList = [ ...privateChatCache, ...groupChatCache ];
|
||||
const chatCacheList: ChatCacheListItemBasic[] = []
|
||||
|
||||
// 获取聊天缓存文件列表
|
||||
const cacheFileList: string[] = []
|
||||
// 获取聊天缓存文件列表
|
||||
const cacheFileList: string[] = []
|
||||
|
||||
for (const name in CacheFileType) {
|
||||
if (!isNaN(parseInt(name))) continue
|
||||
for (const name in CacheFileType) {
|
||||
if (!isNaN(parseInt(name))) continue
|
||||
|
||||
const fileTypeAny: any = CacheFileType[name]
|
||||
const fileType: CacheFileType = fileTypeAny
|
||||
const fileType = CacheFileType[name] as unknown as CacheFileType
|
||||
|
||||
cacheFileList.push(...(await this.ctx.ntFileCacheApi.getFileCacheInfo(fileType)).infos.map((file) => file.fileKey))
|
||||
}
|
||||
cacheFileList.push(...(await this.ctx.ntFileCacheApi.getFileCacheInfo(fileType)).infos.map((file) => file.fileKey))
|
||||
}
|
||||
|
||||
// 一并清除
|
||||
await this.ctx.ntFileCacheApi.clearChatCache(chatCacheList, cacheFileList)
|
||||
res()
|
||||
} catch (e) {
|
||||
console.error('清理缓存时发生了错误')
|
||||
rej(e)
|
||||
}
|
||||
})
|
||||
// 一并清除
|
||||
await this.ctx.ntFileCacheApi.clearChatCache(chatCacheList, cacheFileList)
|
||||
}
|
||||
}
|
||||
|
||||
|
@@ -91,4 +91,6 @@ export enum ActionName {
|
||||
GoCQHTTP_DeleteFriend = 'delete_friend',
|
||||
GoCQHTTP_OCRImage = 'ocr_image',
|
||||
GoCQHTTP_GetGroupFileSystemInfo = 'get_group_file_system_info',
|
||||
GoCQHTTP_SetGroupSpecialTitle = 'set_group_special_title',
|
||||
GoCQHTTP_SendGroupSign = 'send_group_sign',
|
||||
}
|
||||
|
@@ -221,7 +221,7 @@ export class MessageEncoder {
|
||||
}
|
||||
}
|
||||
|
||||
async generate(content: any[]) {
|
||||
async generate(content: OB11MessageData[]) {
|
||||
await this.render(content)
|
||||
return {
|
||||
multiMsgItems: [{
|
||||
|
@@ -11,6 +11,10 @@ function isEmpty(value: unknown) {
|
||||
}
|
||||
|
||||
async function onSettingWindowCreated(view: Element) {
|
||||
console.log(view)
|
||||
if (!view){
|
||||
return
|
||||
}
|
||||
const config = await window.llonebot.getConfig()
|
||||
const ob11Config = { ...config.ob11 }
|
||||
|
||||
@@ -247,7 +251,9 @@ async function onSettingWindowCreated(view: Element) {
|
||||
} else {
|
||||
errDom?.classList.add('show')
|
||||
}
|
||||
errCodeDom!.innerHTML = errMsg
|
||||
if (errCodeDom) {
|
||||
errCodeDom.innerHTML = errMsg
|
||||
}
|
||||
}
|
||||
showError().then()
|
||||
|
||||
@@ -456,8 +462,8 @@ async function onSettingWindowCreated(view: Element) {
|
||||
}
|
||||
window.llonebot.checkVersion().then(checkVersionFunc)
|
||||
window.addEventListener('beforeunload', () => {
|
||||
window.llonebot.getConfig().then(oldConfig=>{
|
||||
if(JSON.stringify(oldConfig) !== JSON.stringify(config)){
|
||||
window.llonebot.getConfig().then(oldConfig => {
|
||||
if (JSON.stringify(oldConfig) !== JSON.stringify(config)) {
|
||||
window.llonebot.setConfig(true, config)
|
||||
}
|
||||
})
|
||||
|
@@ -91,7 +91,7 @@ class SatoriAdapter extends Service {
|
||||
input.subMsgType === 12 &&
|
||||
input.elements[0]?.grayTipElement?.xmlElement?.templId === '10382'
|
||||
) {
|
||||
|
||||
// 机器人被表情回应
|
||||
}
|
||||
else {
|
||||
// 普通的消息
|
||||
|
@@ -1 +1 @@
|
||||
export const version = '4.1.2'
|
||||
export const version = '4.2.2'
|
||||
|
Reference in New Issue
Block a user