mirror of
https://github.com/LLOneBot/LLOneBot.git
synced 2024-11-22 01:56:33 +00:00
Compare commits
21 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
9284fc7e8a | ||
![]() |
ceb063143a | ||
![]() |
ed55a5a54c | ||
![]() |
2c4fdbfa6a | ||
![]() |
1132495eb3 | ||
![]() |
2ac2c68435 | ||
![]() |
6477366ba6 | ||
![]() |
1d63473a04 | ||
![]() |
692ba5163e | ||
![]() |
8bcea090ec | ||
![]() |
67568a662d | ||
![]() |
66b3706524 | ||
![]() |
6d82dd1dad | ||
![]() |
20f2e66b11 | ||
![]() |
efefb963c0 | ||
![]() |
92d780cf70 | ||
![]() |
ce6886011f | ||
![]() |
319b275e4f | ||
![]() |
9738c3f63c | ||
![]() |
3de054600c | ||
![]() |
da0ebd3f80 |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -11,5 +11,6 @@ node_modules
|
||||
dist
|
||||
out
|
||||
|
||||
.idea/
|
||||
.DS_Store
|
||||
.idea
|
||||
.vscode
|
||||
|
@@ -4,7 +4,7 @@
|
||||
"name": "LLOneBot",
|
||||
"slug": "LLOneBot",
|
||||
"description": "实现 OneBot 11 协议,用于 QQ 机器人开发",
|
||||
"version": "3.32.0",
|
||||
"version": "3.32.4",
|
||||
"icon": "./icon.webp",
|
||||
"authors": [
|
||||
{
|
||||
|
15
package.json
15
package.json
@@ -7,11 +7,12 @@
|
||||
"scripts": {
|
||||
"build": "electron-vite build",
|
||||
"build-mac": "npm run build && npm run deploy-mac",
|
||||
"deploy-mac": "cp -r dist/* ~/Library/Containers/com.tencent.qq/Data/LiteLoaderQQNT/plugins/LLOneBot/",
|
||||
"deploy-mac": "cp -r dist/* ~/Library/Containers/com.tencent.qq/Data/Documents/LiteLoaderQQNT/plugins/LLOneBot/",
|
||||
"build-win": "npm run build && npm run deploy-win",
|
||||
"deploy-win": "cmd /c \"xcopy /C /S /Y dist\\* %USERPROFILE%\\documents\\LiteLoaderQQNT\\plugins\\LLOneBot\\\"",
|
||||
"deploy-win": "cmd /c \"xcopy /C /S /Y dist\\* %LITELOADERQQNT_PROFILE%\\plugins\\LLOneBot\\\"",
|
||||
"format": "prettier -cw .",
|
||||
"check": "tsc"
|
||||
"check": "tsc",
|
||||
"compile:proto": "pbjs --no-convert --no-encode --no-verify -t static-module -w es6 -p src/ntqqapi/proto -o src/ntqqapi/proto/compiled.js systemMessage.proto profileLikeTip.proto && pbts -o src/ntqqapi/proto/compiled.d.ts src/ntqqapi/proto/compiled.js"
|
||||
},
|
||||
"author": "",
|
||||
"license": "MIT",
|
||||
@@ -21,11 +22,12 @@
|
||||
"cordis": "^3.18.0",
|
||||
"cors": "^2.8.5",
|
||||
"cosmokit": "^1.6.2",
|
||||
"express": "^4.19.2",
|
||||
"express": "^5.0.0",
|
||||
"fast-xml-parser": "^4.5.0",
|
||||
"file-type": "^19.5.0",
|
||||
"fluent-ffmpeg": "^2.1.3",
|
||||
"minato": "^3.5.1",
|
||||
"protobufjs": "^7.4.0",
|
||||
"silk-wasm": "^3.6.1",
|
||||
"ws": "^8.18.0"
|
||||
},
|
||||
@@ -37,8 +39,9 @@
|
||||
"@types/ws": "^8.5.12",
|
||||
"electron": "^31.4.0",
|
||||
"electron-vite": "^2.3.0",
|
||||
"typescript": "^5.5.4",
|
||||
"vite": "^5.4.3",
|
||||
"protobufjs-cli": "^1.1.3",
|
||||
"typescript": "^5.6.2",
|
||||
"vite": "^5.4.4",
|
||||
"vite-plugin-cp": "^4.0.8"
|
||||
},
|
||||
"packageManager": "yarn@4.4.1"
|
||||
|
@@ -133,7 +133,7 @@ export async function uri2local(uri: string, filename?: string, needExt?: boolea
|
||||
|
||||
if (type === FileUriType.RemoteURL) {
|
||||
try {
|
||||
const res = await fetchFile(uri)
|
||||
const res = await fetchFile(uri, { 'Referer': uri })
|
||||
const match = res.url.match(/.+\/([^/?]*)(?=\?)?/)
|
||||
if (match?.[1]) {
|
||||
filename ??= match[1].replace(/[/\\:*?"<>|]/g, '_')
|
||||
|
@@ -16,12 +16,11 @@ export class LimitedHashTable<K, V> {
|
||||
this.keyToValue.set(key, value)
|
||||
this.valueToKey.set(value, key)
|
||||
while (this.keyToValue.size !== this.valueToKey.size) {
|
||||
console.log('keyToValue.size !== valueToKey.size Error Atom')
|
||||
this.keyToValue.clear()
|
||||
this.valueToKey.clear()
|
||||
}
|
||||
while (this.keyToValue.size > this.maxSize || this.valueToKey.size > this.maxSize) {
|
||||
const oldestKey = this.keyToValue.keys().next().value
|
||||
const oldestKey = this.keyToValue.keys().next().value!
|
||||
this.valueToKey.delete(this.keyToValue.get(oldestKey)!)
|
||||
this.keyToValue.delete(oldestKey)
|
||||
}
|
||||
@@ -56,7 +55,7 @@ export class LimitedHashTable<K, V> {
|
||||
}
|
||||
|
||||
//获取最近刚写入的几个值
|
||||
getHeads(size: number): { key: K; value: V }[] | undefined {
|
||||
getHeads(size: number): { key: K, value: V }[] | undefined {
|
||||
const keyList = this.getKeyList()
|
||||
if (keyList.length === 0) {
|
||||
return undefined
|
||||
|
@@ -5,20 +5,22 @@ import { version } from '../../version'
|
||||
import { copyFolder, log, fetchFile } from '.'
|
||||
import { PLUGIN_DIR, TEMP_DIR } from '../globalVars'
|
||||
|
||||
const downloadMirrorHosts = ['https://mirror.ghproxy.com/']
|
||||
const checkVersionMirrorHosts = ['https://kkgithub.com']
|
||||
const downloadMirrorHosts = ['https://ghp.ci/']
|
||||
const releasesMirrorHosts = ['https://kkgithub.com']
|
||||
|
||||
export async function checkNewVersion() {
|
||||
const latestVersionText = await getRemoteVersion()
|
||||
const latestVersion = latestVersionText.split('.')
|
||||
//log('llonebot last version', latestVersion)
|
||||
const currentVersion: string[] = version.split('.')
|
||||
log('LLOneBot latest version', latestVersion)
|
||||
const currentVersion = version.split('.')
|
||||
//log('llonebot current version', currentVersion)
|
||||
for (const k of [0, 1, 2]) {
|
||||
if (parseInt(latestVersion[k]) > parseInt(currentVersion[k])) {
|
||||
const latest = parseInt(latestVersion[k])
|
||||
const current = parseInt(currentVersion[k])
|
||||
if (latest > current) {
|
||||
log('')
|
||||
return { result: true, version: latestVersionText }
|
||||
} else if (parseInt(latestVersion[k]) < parseInt(currentVersion[k])) {
|
||||
} else if (latest < current) {
|
||||
break
|
||||
}
|
||||
}
|
||||
@@ -28,7 +30,7 @@ export async function checkNewVersion() {
|
||||
export async function upgradeLLOneBot() {
|
||||
const latestVersion = await getRemoteVersion()
|
||||
if (latestVersion && latestVersion != '') {
|
||||
const downloadUrl = 'https://github.com/LLOneBot/LLOneBot/releases/download/v' + latestVersion + '/LLOneBot.zip'
|
||||
const downloadUrl = `https://github.com/LLOneBot/LLOneBot/releases/download/v${latestVersion}/LLOneBot.zip`
|
||||
const filePath = path.join(TEMP_DIR, './update-' + latestVersion + '.zip')
|
||||
let downloadSuccess = false
|
||||
// 多镜像下载
|
||||
@@ -73,26 +75,34 @@ export async function upgradeLLOneBot() {
|
||||
}
|
||||
|
||||
export async function getRemoteVersion() {
|
||||
let Version = ''
|
||||
for (let i = 0; i < checkVersionMirrorHosts.length; i++) {
|
||||
const mirrorGithub = checkVersionMirrorHosts[i]
|
||||
const tVersion = await getRemoteVersionByMirror(mirrorGithub)
|
||||
if (tVersion && tVersion != '') {
|
||||
Version = tVersion
|
||||
break
|
||||
for (const mirror of releasesMirrorHosts) {
|
||||
const version = await getRemoteVersionByReleasesMirror(mirror)
|
||||
if (version) {
|
||||
return version
|
||||
}
|
||||
}
|
||||
for (const mirror of downloadMirrorHosts) {
|
||||
const version = await getRemoteVersionByDownloadMirror(mirror)
|
||||
if (version) {
|
||||
return version
|
||||
}
|
||||
}
|
||||
return Version
|
||||
}
|
||||
|
||||
export async function getRemoteVersionByMirror(mirrorGithub: string) {
|
||||
let releasePage = 'error'
|
||||
|
||||
try {
|
||||
releasePage = (await fetchFile(mirrorGithub + '/LLOneBot/LLOneBot/releases')).data.toString()
|
||||
// log("releasePage", releasePage);
|
||||
if (releasePage === 'error') return ''
|
||||
return releasePage.match(new RegExp('(?<=(tag/v)).*?(?=("))'))?.[0]
|
||||
} catch { }
|
||||
return ''
|
||||
}
|
||||
|
||||
export async function getRemoteVersionByDownloadMirror(mirrorGithub: string) {
|
||||
try {
|
||||
const source = 'https://raw.githubusercontent.com/LLOneBot/LLOneBot/main/src/version.ts'
|
||||
const page = (await fetchFile(mirrorGithub + source)).data.toString()
|
||||
return page.match(/(\d+\.\d+\.\d+)/)?.[0]
|
||||
} catch (e) {
|
||||
log(e?.toString())
|
||||
}
|
||||
}
|
||||
|
||||
export async function getRemoteVersionByReleasesMirror(mirrorGithub: string) {
|
||||
try {
|
||||
const page = (await fetchFile(mirrorGithub + '/LLOneBot/LLOneBot/releases')).data.toString()
|
||||
return page.match(new RegExp('(?<=(tag/v)).*?(?=("))'))?.[0]
|
||||
} catch { }
|
||||
}
|
||||
|
@@ -38,7 +38,7 @@ export class NTQQFileApi extends Service {
|
||||
|
||||
constructor(protected ctx: Context) {
|
||||
super(ctx, 'ntFileApi', true)
|
||||
this.rkeyManager = new RkeyManager(ctx, 'http://napcat-sign.wumiao.wang:2082/rkey')
|
||||
this.rkeyManager = new RkeyManager(ctx, 'https://llob.linyuchen.net/rkey')
|
||||
}
|
||||
|
||||
async getVideoUrl(peer: Peer, msgId: string, elementId: string) {
|
||||
|
@@ -296,4 +296,19 @@ export class NTQQUserApi extends Service {
|
||||
}
|
||||
}, null])
|
||||
}
|
||||
|
||||
async getProfileLike(uid: string) {
|
||||
return await invoke('nodeIKernelProfileLikeService/getBuddyProfileLike', [{
|
||||
req: {
|
||||
friendUids: [uid],
|
||||
basic: 1,
|
||||
vote: 1,
|
||||
favorite: 0,
|
||||
userProfile: 1,
|
||||
type: 2,
|
||||
start: 0,
|
||||
limit: 20,
|
||||
}
|
||||
}, null])
|
||||
}
|
||||
}
|
||||
|
@@ -1,6 +1,6 @@
|
||||
import { invoke, NTClass, NTMethod } from '../ntcall'
|
||||
import { GeneralCallResult } from '../services'
|
||||
import { ReceiveCmd } from '../hook'
|
||||
import { ReceiveCmdS } from '../hook'
|
||||
import { BrowserWindow } from 'electron'
|
||||
import { Service, Context } from 'cordis'
|
||||
|
||||
@@ -39,7 +39,7 @@ export class NTQQWindowApi extends Service {
|
||||
async openWindow<R = GeneralCallResult>(
|
||||
ntQQWindow: NTQQWindow,
|
||||
args: unknown[],
|
||||
cbCmd: ReceiveCmd | undefined,
|
||||
cbCmd: ReceiveCmdS | undefined,
|
||||
autoCloseSeconds: number = 2,
|
||||
) {
|
||||
const result = await invoke<R>(
|
||||
|
@@ -19,6 +19,7 @@ import {
|
||||
} from './types'
|
||||
import { selfInfo } from '../common/globalVars'
|
||||
import { version } from '../version'
|
||||
import { invoke } from './ntcall'
|
||||
|
||||
declare module 'cordis' {
|
||||
interface Context {
|
||||
@@ -31,6 +32,7 @@ declare module 'cordis' {
|
||||
'nt/group-notify': (input: GroupNotify[]) => void
|
||||
'nt/friend-request': (input: FriendRequest[]) => void
|
||||
'nt/group-member-info-updated': (input: { groupCode: string, members: GroupMember[] }) => void
|
||||
'nt/system-message-created': (input: Uint8Array) => void
|
||||
}
|
||||
}
|
||||
|
||||
@@ -185,12 +187,6 @@ class Core extends Service {
|
||||
})
|
||||
|
||||
registerReceiveHook<{ msgRecord: RawMessage }>(ReceiveCmdS.SELF_SEND_MSG, payload => {
|
||||
const { msgId, chatType, peerUid } = payload.msgRecord
|
||||
const peer = {
|
||||
chatType,
|
||||
peerUid
|
||||
}
|
||||
MessageUnique.createMsg(peer, msgId)
|
||||
if (!this.config.reportSelfMessage) {
|
||||
return
|
||||
}
|
||||
@@ -225,6 +221,14 @@ class Core extends Service {
|
||||
registerReceiveHook<FriendRequestNotify>(ReceiveCmdS.FRIEND_REQUEST, payload => {
|
||||
this.ctx.parallel('nt/friend-request', payload.data.buddyReqs)
|
||||
})
|
||||
|
||||
invoke('nodeIKernelMsgListener/onRecvSysMsg', [], { classNameIsRegister: true })
|
||||
|
||||
registerReceiveHook<{
|
||||
msgBuf: number[]
|
||||
}>('nodeIKernelMsgListener/onRecvSysMsg', payload => {
|
||||
this.ctx.parallel('nt/system-message-created', Uint8Array.from(payload.msgBuf))
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
|
@@ -1,4 +1,4 @@
|
||||
import { Context } from "cordis"
|
||||
import { Context } from 'cordis'
|
||||
|
||||
interface ServerRkeyData {
|
||||
group_rkey: string
|
||||
|
@@ -6,48 +6,46 @@ import { Dict } from 'cosmokit'
|
||||
|
||||
export const hookApiCallbacks: Record<string, (res: any) => void> = {}
|
||||
|
||||
export const ReceiveCmdS = {
|
||||
RECENT_CONTACT: 'nodeIKernelRecentContactListener/onRecentContactListChangedVer2',
|
||||
UPDATE_MSG: 'nodeIKernelMsgListener/onMsgInfoListUpdate',
|
||||
UPDATE_ACTIVE_MSG: 'nodeIKernelMsgListener/onActiveMsgInfoUpdate',
|
||||
NEW_MSG: `nodeIKernelMsgListener/onRecvMsg`,
|
||||
NEW_ACTIVE_MSG: `nodeIKernelMsgListener/onRecvActiveMsg`,
|
||||
SELF_SEND_MSG: 'nodeIKernelMsgListener/onAddSendMsg',
|
||||
USER_INFO: 'nodeIKernelProfileListener/onProfileSimpleChanged',
|
||||
USER_DETAIL_INFO: 'nodeIKernelProfileListener/onProfileDetailInfoChanged',
|
||||
GROUPS: 'nodeIKernelGroupListener/onGroupListUpdate',
|
||||
GROUPS_STORE: 'onGroupListUpdate',
|
||||
GROUP_MEMBER_INFO_UPDATE: 'nodeIKernelGroupListener/onMemberInfoChange',
|
||||
FRIENDS: 'onBuddyListChange',
|
||||
MEDIA_DOWNLOAD_COMPLETE: 'nodeIKernelMsgListener/onRichMediaDownloadComplete',
|
||||
UNREAD_GROUP_NOTIFY: 'nodeIKernelGroupListener/onGroupNotifiesUnreadCountUpdated',
|
||||
GROUP_NOTIFY: 'nodeIKernelGroupListener/onGroupSingleScreenNotifies',
|
||||
FRIEND_REQUEST: 'nodeIKernelBuddyListener/onBuddyReqChange',
|
||||
SELF_STATUS: 'nodeIKernelProfileListener/onSelfStatusChanged',
|
||||
CACHE_SCAN_FINISH: 'nodeIKernelStorageCleanListener/onFinishScan',
|
||||
MEDIA_UPLOAD_COMPLETE: 'nodeIKernelMsgListener/onRichMediaUploadComplete',
|
||||
SKEY_UPDATE: 'onSkeyUpdate',
|
||||
} as const
|
||||
export enum ReceiveCmdS {
|
||||
RECENT_CONTACT = 'nodeIKernelRecentContactListener/onRecentContactListChangedVer2',
|
||||
UPDATE_MSG = 'nodeIKernelMsgListener/onMsgInfoListUpdate',
|
||||
UPDATE_ACTIVE_MSG = 'nodeIKernelMsgListener/onActiveMsgInfoUpdate',
|
||||
NEW_MSG = 'nodeIKernelMsgListener/onRecvMsg',
|
||||
NEW_ACTIVE_MSG = 'nodeIKernelMsgListener/onRecvActiveMsg',
|
||||
SELF_SEND_MSG = 'nodeIKernelMsgListener/onAddSendMsg',
|
||||
USER_INFO = 'nodeIKernelProfileListener/onProfileSimpleChanged',
|
||||
USER_DETAIL_INFO = 'nodeIKernelProfileListener/onProfileDetailInfoChanged',
|
||||
GROUPS = 'nodeIKernelGroupListener/onGroupListUpdate',
|
||||
GROUPS_STORE = 'onGroupListUpdate',
|
||||
GROUP_MEMBER_INFO_UPDATE = 'nodeIKernelGroupListener/onMemberInfoChange',
|
||||
FRIENDS = 'onBuddyListChange',
|
||||
MEDIA_DOWNLOAD_COMPLETE = 'nodeIKernelMsgListener/onRichMediaDownloadComplete',
|
||||
UNREAD_GROUP_NOTIFY = 'nodeIKernelGroupListener/onGroupNotifiesUnreadCountUpdated',
|
||||
GROUP_NOTIFY = 'nodeIKernelGroupListener/onGroupSingleScreenNotifies',
|
||||
FRIEND_REQUEST = 'nodeIKernelBuddyListener/onBuddyReqChange',
|
||||
SELF_STATUS = 'nodeIKernelProfileListener/onSelfStatusChanged',
|
||||
CACHE_SCAN_FINISH = 'nodeIKernelStorageCleanListener/onFinishScan',
|
||||
MEDIA_UPLOAD_COMPLETE = 'nodeIKernelMsgListener/onRichMediaUploadComplete',
|
||||
SKEY_UPDATE = 'onSkeyUpdate',
|
||||
}
|
||||
|
||||
export type ReceiveCmd = string
|
||||
|
||||
interface NTQQApiReturnData extends Array<unknown> {
|
||||
0: {
|
||||
type NTReturnData = [
|
||||
{
|
||||
type: 'request'
|
||||
eventName: NTClass
|
||||
callbackId?: string
|
||||
}
|
||||
1: {
|
||||
cmdName: ReceiveCmd
|
||||
},
|
||||
{
|
||||
cmdName: ReceiveCmdS
|
||||
cmdType: 'event'
|
||||
payload: unknown
|
||||
}[]
|
||||
}
|
||||
]
|
||||
|
||||
const logHook = false
|
||||
|
||||
const receiveHooks: Array<{
|
||||
method: ReceiveCmd[]
|
||||
method: ReceiveCmdS[]
|
||||
hookFunc: (payload: any) => void | Promise<void>
|
||||
id: string
|
||||
}> = []
|
||||
@@ -58,62 +56,44 @@ const callHooks: Array<{
|
||||
}> = []
|
||||
|
||||
export function hookNTQQApiReceive(window: BrowserWindow, onlyLog: boolean) {
|
||||
const originalSend = window.webContents.send
|
||||
const patchSend = (channel: string, ...args: NTQQApiReturnData) => {
|
||||
try {
|
||||
const isLogger = args[0]?.eventName?.startsWith('ns-LoggerApi')
|
||||
if (logHook && !isLogger) {
|
||||
log(`received ntqq api message: ${channel}`, args)
|
||||
}
|
||||
} catch { }
|
||||
if (!onlyLog) {
|
||||
if (args?.[1] instanceof Array) {
|
||||
for (const receiveData of args[1]) {
|
||||
const ntQQApiMethodName = receiveData.cmdName
|
||||
// log(`received ntqq api message: ${channel} ${ntQQApiMethodName}`, JSON.stringify(receiveData))
|
||||
for (const hook of receiveHooks) {
|
||||
if (hook.method.includes(ntQQApiMethodName)) {
|
||||
new Promise(resolve => {
|
||||
try {
|
||||
hook.hookFunc(receiveData.payload)
|
||||
} catch (e) {
|
||||
log('hook error', ntQQApiMethodName, (e as Error).stack?.toString())
|
||||
}
|
||||
resolve(undefined)
|
||||
}).then()
|
||||
window.webContents.send = new Proxy(window.webContents.send, {
|
||||
apply(target, thisArg, args: [channel: string, ...args: NTReturnData]) {
|
||||
try {
|
||||
if (logHook && !args[1]?.eventName?.startsWith('ns-LoggerApi')) {
|
||||
log('received ntqq api message', args)
|
||||
}
|
||||
} catch { }
|
||||
if (!onlyLog) {
|
||||
if (args[2] instanceof Array) {
|
||||
for (const receiveData of args[2]) {
|
||||
const ntMethodName = receiveData.cmdName
|
||||
for (const hook of receiveHooks) {
|
||||
if (hook.method.includes(ntMethodName)) {
|
||||
Promise.resolve(hook.hookFunc(receiveData.payload))
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
if (args[0]?.callbackId) {
|
||||
// log("hookApiCallback", hookApiCallbacks, args)
|
||||
const callbackId = args[0].callbackId
|
||||
if (hookApiCallbacks[callbackId]) {
|
||||
new Promise(resolve => {
|
||||
hookApiCallbacks[callbackId](args[1])
|
||||
resolve(undefined)
|
||||
}).then()
|
||||
delete hookApiCallbacks[callbackId]
|
||||
if (args[1]?.callbackId) {
|
||||
const callbackId = args[1].callbackId
|
||||
if (hookApiCallbacks[callbackId]) {
|
||||
Promise.resolve(hookApiCallbacks[callbackId](args[2]))
|
||||
delete hookApiCallbacks[callbackId]
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
originalSend.call(window.webContents, channel, ...args)
|
||||
}
|
||||
window.webContents.send = patchSend
|
||||
return target.apply(thisArg, args)
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
export function hookNTQQApiCall(window: BrowserWindow, onlyLog: boolean) {
|
||||
// 监听调用NTQQApi
|
||||
const webContents = window.webContents as Dict
|
||||
const ipc_message_proxy = webContents._events['-ipc-message']?.[0] || webContents._events['-ipc-message']
|
||||
|
||||
const proxyIpcMsg = new Proxy(ipc_message_proxy, {
|
||||
apply(target, thisArg, args) {
|
||||
// console.log(thisArg, args);
|
||||
let isLogger = false
|
||||
try {
|
||||
isLogger = args[3][0].eventName.startsWith('ns-LoggerApi')
|
||||
} catch (e) { }
|
||||
const isLogger = args[3]?.[0]?.eventName?.startsWith('ns-LoggerApi')
|
||||
if (!isLogger) {
|
||||
try {
|
||||
logHook && log('call NTQQ api', thisArg, args)
|
||||
@@ -121,21 +101,14 @@ export function hookNTQQApiCall(window: BrowserWindow, onlyLog: boolean) {
|
||||
if (!onlyLog) {
|
||||
try {
|
||||
const _args: unknown[] = args[3][1]
|
||||
const cmdName: NTMethod = _args[0] as NTMethod
|
||||
const cmdName = _args[0] as NTMethod
|
||||
const callParams = _args.slice(1)
|
||||
callHooks.forEach((hook) => {
|
||||
if (hook.method.includes(cmdName)) {
|
||||
new Promise(resolve => {
|
||||
try {
|
||||
hook.hookFunc(callParams)
|
||||
} catch (e) {
|
||||
log('hook call error', e, _args)
|
||||
}
|
||||
resolve(undefined)
|
||||
}).then()
|
||||
Promise.resolve(hook.hookFunc(callParams))
|
||||
}
|
||||
})
|
||||
} catch (e) { }
|
||||
} catch { }
|
||||
}
|
||||
}
|
||||
return target.apply(thisArg, args)
|
||||
@@ -147,7 +120,7 @@ export function hookNTQQApiCall(window: BrowserWindow, onlyLog: boolean) {
|
||||
webContents._events['-ipc-message'] = proxyIpcMsg
|
||||
}
|
||||
|
||||
const ipc_invoke_proxy = webContents._events['-ipc-invoke']?.[0] || webContents._events['-ipc-invoke']
|
||||
/*const ipc_invoke_proxy = webContents._events['-ipc-invoke']?.[0] || webContents._events['-ipc-invoke']
|
||||
const proxyIpcInvoke = new Proxy(ipc_invoke_proxy, {
|
||||
apply(target, thisArg, args) {
|
||||
//HOOK_LOG && log('call NTQQ invoke api', thisArg, args)
|
||||
@@ -157,9 +130,7 @@ export function hookNTQQApiCall(window: BrowserWindow, onlyLog: boolean) {
|
||||
},
|
||||
})
|
||||
const ret = target.apply(thisArg, args)
|
||||
/*try {
|
||||
HOOK_LOG && log('call NTQQ invoke api return', ret)
|
||||
} catch (e) { }*/
|
||||
//HOOK_LOG && log('call NTQQ invoke api return', ret)
|
||||
return ret
|
||||
},
|
||||
})
|
||||
@@ -167,11 +138,11 @@ export function hookNTQQApiCall(window: BrowserWindow, onlyLog: boolean) {
|
||||
webContents._events['-ipc-invoke'][0] = proxyIpcInvoke
|
||||
} else {
|
||||
webContents._events['-ipc-invoke'] = proxyIpcInvoke
|
||||
}
|
||||
}*/
|
||||
}
|
||||
|
||||
export function registerReceiveHook<PayloadType>(
|
||||
method: ReceiveCmd | ReceiveCmd[],
|
||||
method: string | string[],
|
||||
hookFunc: (payload: PayloadType) => void,
|
||||
): string {
|
||||
const id = randomUUID()
|
||||
@@ -179,7 +150,7 @@ export function registerReceiveHook<PayloadType>(
|
||||
method = [method]
|
||||
}
|
||||
receiveHooks.push({
|
||||
method,
|
||||
method: method as ReceiveCmdS[],
|
||||
hookFunc,
|
||||
id,
|
||||
})
|
||||
|
@@ -136,7 +136,6 @@ export function invoke<
|
||||
// 这里的callback比较特殊,QQ后端先返回是否调用成功,再返回一条结果数据
|
||||
const secondCallback = () => {
|
||||
const hookId = registerReceiveHook<R>(options.cbCmd!, (payload) => {
|
||||
// log(methodName, "second callback", cbCmd, payload, cmdCB);
|
||||
if (options.cmdCB) {
|
||||
if (options.cmdCB(payload, result)) {
|
||||
removeReceiveHook(hookId)
|
||||
|
460
src/ntqqapi/proto/compiled.d.ts
vendored
Normal file
460
src/ntqqapi/proto/compiled.d.ts
vendored
Normal file
@@ -0,0 +1,460 @@
|
||||
import * as $protobuf from "protobufjs";
|
||||
import Long = require("long");
|
||||
/** Namespace SysMsg. */
|
||||
export namespace SysMsg {
|
||||
|
||||
/** Properties of a SystemMessage. */
|
||||
interface ISystemMessage {
|
||||
|
||||
/** SystemMessage header */
|
||||
header?: (SysMsg.ISystemMessageHeader[]|null);
|
||||
|
||||
/** SystemMessage msgSpec */
|
||||
msgSpec?: (SysMsg.ISystemMessageMsgSpec[]|null);
|
||||
|
||||
/** SystemMessage bodyWrapper */
|
||||
bodyWrapper?: (SysMsg.ISystemMessageBodyWrapper|null);
|
||||
}
|
||||
|
||||
/** Represents a SystemMessage. */
|
||||
class SystemMessage implements ISystemMessage {
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessage.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: SysMsg.ISystemMessage);
|
||||
|
||||
/** SystemMessage header. */
|
||||
public header: SysMsg.ISystemMessageHeader[];
|
||||
|
||||
/** SystemMessage msgSpec. */
|
||||
public msgSpec: SysMsg.ISystemMessageMsgSpec[];
|
||||
|
||||
/** SystemMessage bodyWrapper. */
|
||||
public bodyWrapper?: (SysMsg.ISystemMessageBodyWrapper|null);
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessage instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns SystemMessage instance
|
||||
*/
|
||||
public static create(properties?: SysMsg.ISystemMessage): SysMsg.SystemMessage;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessage message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns SystemMessage
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): SysMsg.SystemMessage;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessage message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns SystemMessage
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): SysMsg.SystemMessage;
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessage
|
||||
* @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns The default type url
|
||||
*/
|
||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||
}
|
||||
|
||||
/** Properties of a SystemMessageHeader. */
|
||||
interface ISystemMessageHeader {
|
||||
|
||||
/** SystemMessageHeader peerNumber */
|
||||
peerNumber?: (number|null);
|
||||
|
||||
/** SystemMessageHeader peerString */
|
||||
peerString?: (string|null);
|
||||
|
||||
/** SystemMessageHeader uin */
|
||||
uin?: (number|null);
|
||||
|
||||
/** SystemMessageHeader uid */
|
||||
uid?: (string|null);
|
||||
}
|
||||
|
||||
/** Represents a SystemMessageHeader. */
|
||||
class SystemMessageHeader implements ISystemMessageHeader {
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessageHeader.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: SysMsg.ISystemMessageHeader);
|
||||
|
||||
/** SystemMessageHeader peerNumber. */
|
||||
public peerNumber: number;
|
||||
|
||||
/** SystemMessageHeader peerString. */
|
||||
public peerString: string;
|
||||
|
||||
/** SystemMessageHeader uin. */
|
||||
public uin: number;
|
||||
|
||||
/** SystemMessageHeader uid. */
|
||||
public uid?: (string|null);
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessageHeader instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns SystemMessageHeader instance
|
||||
*/
|
||||
public static create(properties?: SysMsg.ISystemMessageHeader): SysMsg.SystemMessageHeader;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageHeader message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns SystemMessageHeader
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): SysMsg.SystemMessageHeader;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageHeader message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns SystemMessageHeader
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): SysMsg.SystemMessageHeader;
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessageHeader
|
||||
* @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns The default type url
|
||||
*/
|
||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||
}
|
||||
|
||||
/** Properties of a SystemMessageMsgSpec. */
|
||||
interface ISystemMessageMsgSpec {
|
||||
|
||||
/** SystemMessageMsgSpec msgType */
|
||||
msgType?: (number|null);
|
||||
|
||||
/** SystemMessageMsgSpec subType */
|
||||
subType?: (number|null);
|
||||
|
||||
/** SystemMessageMsgSpec subSubType */
|
||||
subSubType?: (number|null);
|
||||
|
||||
/** SystemMessageMsgSpec msgSeq */
|
||||
msgSeq?: (number|null);
|
||||
|
||||
/** SystemMessageMsgSpec time */
|
||||
time?: (number|null);
|
||||
|
||||
/** SystemMessageMsgSpec other */
|
||||
other?: (number|null);
|
||||
}
|
||||
|
||||
/** Represents a SystemMessageMsgSpec. */
|
||||
class SystemMessageMsgSpec implements ISystemMessageMsgSpec {
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessageMsgSpec.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: SysMsg.ISystemMessageMsgSpec);
|
||||
|
||||
/** SystemMessageMsgSpec msgType. */
|
||||
public msgType: number;
|
||||
|
||||
/** SystemMessageMsgSpec subType. */
|
||||
public subType: number;
|
||||
|
||||
/** SystemMessageMsgSpec subSubType. */
|
||||
public subSubType: number;
|
||||
|
||||
/** SystemMessageMsgSpec msgSeq. */
|
||||
public msgSeq: number;
|
||||
|
||||
/** SystemMessageMsgSpec time. */
|
||||
public time: number;
|
||||
|
||||
/** SystemMessageMsgSpec other. */
|
||||
public other: number;
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessageMsgSpec instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns SystemMessageMsgSpec instance
|
||||
*/
|
||||
public static create(properties?: SysMsg.ISystemMessageMsgSpec): SysMsg.SystemMessageMsgSpec;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageMsgSpec message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns SystemMessageMsgSpec
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): SysMsg.SystemMessageMsgSpec;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageMsgSpec message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns SystemMessageMsgSpec
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): SysMsg.SystemMessageMsgSpec;
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessageMsgSpec
|
||||
* @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns The default type url
|
||||
*/
|
||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||
}
|
||||
|
||||
/** Properties of a SystemMessageBodyWrapper. */
|
||||
interface ISystemMessageBodyWrapper {
|
||||
|
||||
/** SystemMessageBodyWrapper body */
|
||||
body?: (Uint8Array|null);
|
||||
}
|
||||
|
||||
/** Represents a SystemMessageBodyWrapper. */
|
||||
class SystemMessageBodyWrapper implements ISystemMessageBodyWrapper {
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessageBodyWrapper.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: SysMsg.ISystemMessageBodyWrapper);
|
||||
|
||||
/** SystemMessageBodyWrapper body. */
|
||||
public body: Uint8Array;
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessageBodyWrapper instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns SystemMessageBodyWrapper instance
|
||||
*/
|
||||
public static create(properties?: SysMsg.ISystemMessageBodyWrapper): SysMsg.SystemMessageBodyWrapper;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageBodyWrapper message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns SystemMessageBodyWrapper
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): SysMsg.SystemMessageBodyWrapper;
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageBodyWrapper message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns SystemMessageBodyWrapper
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): SysMsg.SystemMessageBodyWrapper;
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessageBodyWrapper
|
||||
* @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns The default type url
|
||||
*/
|
||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||
}
|
||||
|
||||
/** Properties of a LikeDetail. */
|
||||
interface ILikeDetail {
|
||||
|
||||
/** LikeDetail txt */
|
||||
txt?: (string|null);
|
||||
|
||||
/** LikeDetail uin */
|
||||
uin?: (number|null);
|
||||
|
||||
/** LikeDetail nickname */
|
||||
nickname?: (string|null);
|
||||
}
|
||||
|
||||
/** Represents a LikeDetail. */
|
||||
class LikeDetail implements ILikeDetail {
|
||||
|
||||
/**
|
||||
* Constructs a new LikeDetail.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: SysMsg.ILikeDetail);
|
||||
|
||||
/** LikeDetail txt. */
|
||||
public txt: string;
|
||||
|
||||
/** LikeDetail uin. */
|
||||
public uin: number;
|
||||
|
||||
/** LikeDetail nickname. */
|
||||
public nickname: string;
|
||||
|
||||
/**
|
||||
* Creates a new LikeDetail instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns LikeDetail instance
|
||||
*/
|
||||
public static create(properties?: SysMsg.ILikeDetail): SysMsg.LikeDetail;
|
||||
|
||||
/**
|
||||
* Decodes a LikeDetail message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns LikeDetail
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): SysMsg.LikeDetail;
|
||||
|
||||
/**
|
||||
* Decodes a LikeDetail message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns LikeDetail
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): SysMsg.LikeDetail;
|
||||
|
||||
/**
|
||||
* Gets the default type url for LikeDetail
|
||||
* @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns The default type url
|
||||
*/
|
||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||
}
|
||||
|
||||
/** Properties of a LikeMsg. */
|
||||
interface ILikeMsg {
|
||||
|
||||
/** LikeMsg count */
|
||||
count?: (number|null);
|
||||
|
||||
/** LikeMsg time */
|
||||
time?: (number|null);
|
||||
|
||||
/** LikeMsg detail */
|
||||
detail?: (SysMsg.ILikeDetail|null);
|
||||
}
|
||||
|
||||
/** Represents a LikeMsg. */
|
||||
class LikeMsg implements ILikeMsg {
|
||||
|
||||
/**
|
||||
* Constructs a new LikeMsg.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: SysMsg.ILikeMsg);
|
||||
|
||||
/** LikeMsg count. */
|
||||
public count: number;
|
||||
|
||||
/** LikeMsg time. */
|
||||
public time: number;
|
||||
|
||||
/** LikeMsg detail. */
|
||||
public detail?: (SysMsg.ILikeDetail|null);
|
||||
|
||||
/**
|
||||
* Creates a new LikeMsg instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns LikeMsg instance
|
||||
*/
|
||||
public static create(properties?: SysMsg.ILikeMsg): SysMsg.LikeMsg;
|
||||
|
||||
/**
|
||||
* Decodes a LikeMsg message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns LikeMsg
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): SysMsg.LikeMsg;
|
||||
|
||||
/**
|
||||
* Decodes a LikeMsg message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns LikeMsg
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): SysMsg.LikeMsg;
|
||||
|
||||
/**
|
||||
* Gets the default type url for LikeMsg
|
||||
* @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns The default type url
|
||||
*/
|
||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||
}
|
||||
|
||||
/** Properties of a ProfileLikeTip. */
|
||||
interface IProfileLikeTip {
|
||||
|
||||
/** ProfileLikeTip msg */
|
||||
msg?: (SysMsg.ILikeMsg|null);
|
||||
}
|
||||
|
||||
/** Represents a ProfileLikeTip. */
|
||||
class ProfileLikeTip implements IProfileLikeTip {
|
||||
|
||||
/**
|
||||
* Constructs a new ProfileLikeTip.
|
||||
* @param [properties] Properties to set
|
||||
*/
|
||||
constructor(properties?: SysMsg.IProfileLikeTip);
|
||||
|
||||
/** ProfileLikeTip msg. */
|
||||
public msg?: (SysMsg.ILikeMsg|null);
|
||||
|
||||
/**
|
||||
* Creates a new ProfileLikeTip instance using the specified properties.
|
||||
* @param [properties] Properties to set
|
||||
* @returns ProfileLikeTip instance
|
||||
*/
|
||||
public static create(properties?: SysMsg.IProfileLikeTip): SysMsg.ProfileLikeTip;
|
||||
|
||||
/**
|
||||
* Decodes a ProfileLikeTip message from the specified reader or buffer.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @param [length] Message length if known beforehand
|
||||
* @returns ProfileLikeTip
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): SysMsg.ProfileLikeTip;
|
||||
|
||||
/**
|
||||
* Decodes a ProfileLikeTip message from the specified reader or buffer, length delimited.
|
||||
* @param reader Reader or buffer to decode from
|
||||
* @returns ProfileLikeTip
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): SysMsg.ProfileLikeTip;
|
||||
|
||||
/**
|
||||
* Gets the default type url for ProfileLikeTip
|
||||
* @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns The default type url
|
||||
*/
|
||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||
}
|
||||
}
|
975
src/ntqqapi/proto/compiled.js
Normal file
975
src/ntqqapi/proto/compiled.js
Normal file
@@ -0,0 +1,975 @@
|
||||
/*eslint-disable block-scoped-var, id-length, no-control-regex, no-magic-numbers, no-prototype-builtins, no-redeclare, no-shadow, no-var, sort-vars*/
|
||||
import * as $protobuf from "protobufjs/minimal";
|
||||
|
||||
// Common aliases
|
||||
const $Reader = $protobuf.Reader, $util = $protobuf.util;
|
||||
|
||||
// Exported root namespace
|
||||
const $root = $protobuf.roots["default"] || ($protobuf.roots["default"] = {});
|
||||
|
||||
export const SysMsg = $root.SysMsg = (() => {
|
||||
|
||||
/**
|
||||
* Namespace SysMsg.
|
||||
* @exports SysMsg
|
||||
* @namespace
|
||||
*/
|
||||
const SysMsg = {};
|
||||
|
||||
SysMsg.SystemMessage = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a SystemMessage.
|
||||
* @memberof SysMsg
|
||||
* @interface ISystemMessage
|
||||
* @property {Array.<SysMsg.ISystemMessageHeader>|null} [header] SystemMessage header
|
||||
* @property {Array.<SysMsg.ISystemMessageMsgSpec>|null} [msgSpec] SystemMessage msgSpec
|
||||
* @property {SysMsg.ISystemMessageBodyWrapper|null} [bodyWrapper] SystemMessage bodyWrapper
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessage.
|
||||
* @memberof SysMsg
|
||||
* @classdesc Represents a SystemMessage.
|
||||
* @implements ISystemMessage
|
||||
* @constructor
|
||||
* @param {SysMsg.ISystemMessage=} [properties] Properties to set
|
||||
*/
|
||||
function SystemMessage(properties) {
|
||||
this.header = [];
|
||||
this.msgSpec = [];
|
||||
if (properties)
|
||||
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* SystemMessage header.
|
||||
* @member {Array.<SysMsg.ISystemMessageHeader>} header
|
||||
* @memberof SysMsg.SystemMessage
|
||||
* @instance
|
||||
*/
|
||||
SystemMessage.prototype.header = $util.emptyArray;
|
||||
|
||||
/**
|
||||
* SystemMessage msgSpec.
|
||||
* @member {Array.<SysMsg.ISystemMessageMsgSpec>} msgSpec
|
||||
* @memberof SysMsg.SystemMessage
|
||||
* @instance
|
||||
*/
|
||||
SystemMessage.prototype.msgSpec = $util.emptyArray;
|
||||
|
||||
/**
|
||||
* SystemMessage bodyWrapper.
|
||||
* @member {SysMsg.ISystemMessageBodyWrapper|null|undefined} bodyWrapper
|
||||
* @memberof SysMsg.SystemMessage
|
||||
* @instance
|
||||
*/
|
||||
SystemMessage.prototype.bodyWrapper = null;
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessage instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof SysMsg.SystemMessage
|
||||
* @static
|
||||
* @param {SysMsg.ISystemMessage=} [properties] Properties to set
|
||||
* @returns {SysMsg.SystemMessage} SystemMessage instance
|
||||
*/
|
||||
SystemMessage.create = function create(properties) {
|
||||
return new SystemMessage(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessage message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof SysMsg.SystemMessage
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {SysMsg.SystemMessage} SystemMessage
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessage.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
let end = length === undefined ? reader.len : reader.pos + length, message = new $root.SysMsg.SystemMessage();
|
||||
while (reader.pos < end) {
|
||||
let tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 1: {
|
||||
if (!(message.header && message.header.length))
|
||||
message.header = [];
|
||||
message.header.push($root.SysMsg.SystemMessageHeader.decode(reader, reader.uint32()));
|
||||
break;
|
||||
}
|
||||
case 2: {
|
||||
if (!(message.msgSpec && message.msgSpec.length))
|
||||
message.msgSpec = [];
|
||||
message.msgSpec.push($root.SysMsg.SystemMessageMsgSpec.decode(reader, reader.uint32()));
|
||||
break;
|
||||
}
|
||||
case 3: {
|
||||
message.bodyWrapper = $root.SysMsg.SystemMessageBodyWrapper.decode(reader, reader.uint32());
|
||||
break;
|
||||
}
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessage message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof SysMsg.SystemMessage
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {SysMsg.SystemMessage} SystemMessage
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessage.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessage
|
||||
* @function getTypeUrl
|
||||
* @memberof SysMsg.SystemMessage
|
||||
* @static
|
||||
* @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns {string} The default type url
|
||||
*/
|
||||
SystemMessage.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
|
||||
if (typeUrlPrefix === undefined) {
|
||||
typeUrlPrefix = "type.googleapis.com";
|
||||
}
|
||||
return typeUrlPrefix + "/SysMsg.SystemMessage";
|
||||
};
|
||||
|
||||
return SystemMessage;
|
||||
})();
|
||||
|
||||
SysMsg.SystemMessageHeader = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a SystemMessageHeader.
|
||||
* @memberof SysMsg
|
||||
* @interface ISystemMessageHeader
|
||||
* @property {number|null} [peerNumber] SystemMessageHeader peerNumber
|
||||
* @property {string|null} [peerString] SystemMessageHeader peerString
|
||||
* @property {number|null} [uin] SystemMessageHeader uin
|
||||
* @property {string|null} [uid] SystemMessageHeader uid
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessageHeader.
|
||||
* @memberof SysMsg
|
||||
* @classdesc Represents a SystemMessageHeader.
|
||||
* @implements ISystemMessageHeader
|
||||
* @constructor
|
||||
* @param {SysMsg.ISystemMessageHeader=} [properties] Properties to set
|
||||
*/
|
||||
function SystemMessageHeader(properties) {
|
||||
if (properties)
|
||||
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* SystemMessageHeader peerNumber.
|
||||
* @member {number} peerNumber
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageHeader.prototype.peerNumber = 0;
|
||||
|
||||
/**
|
||||
* SystemMessageHeader peerString.
|
||||
* @member {string} peerString
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageHeader.prototype.peerString = "";
|
||||
|
||||
/**
|
||||
* SystemMessageHeader uin.
|
||||
* @member {number} uin
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageHeader.prototype.uin = 0;
|
||||
|
||||
/**
|
||||
* SystemMessageHeader uid.
|
||||
* @member {string|null|undefined} uid
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageHeader.prototype.uid = null;
|
||||
|
||||
// OneOf field names bound to virtual getters and setters
|
||||
let $oneOfFields;
|
||||
|
||||
// Virtual OneOf for proto3 optional field
|
||||
Object.defineProperty(SystemMessageHeader.prototype, "_uid", {
|
||||
get: $util.oneOfGetter($oneOfFields = ["uid"]),
|
||||
set: $util.oneOfSetter($oneOfFields)
|
||||
});
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessageHeader instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @static
|
||||
* @param {SysMsg.ISystemMessageHeader=} [properties] Properties to set
|
||||
* @returns {SysMsg.SystemMessageHeader} SystemMessageHeader instance
|
||||
*/
|
||||
SystemMessageHeader.create = function create(properties) {
|
||||
return new SystemMessageHeader(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageHeader message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {SysMsg.SystemMessageHeader} SystemMessageHeader
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessageHeader.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
let end = length === undefined ? reader.len : reader.pos + length, message = new $root.SysMsg.SystemMessageHeader();
|
||||
while (reader.pos < end) {
|
||||
let tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 1: {
|
||||
message.peerNumber = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 2: {
|
||||
message.peerString = reader.string();
|
||||
break;
|
||||
}
|
||||
case 5: {
|
||||
message.uin = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 6: {
|
||||
message.uid = reader.string();
|
||||
break;
|
||||
}
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageHeader message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {SysMsg.SystemMessageHeader} SystemMessageHeader
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessageHeader.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessageHeader
|
||||
* @function getTypeUrl
|
||||
* @memberof SysMsg.SystemMessageHeader
|
||||
* @static
|
||||
* @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns {string} The default type url
|
||||
*/
|
||||
SystemMessageHeader.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
|
||||
if (typeUrlPrefix === undefined) {
|
||||
typeUrlPrefix = "type.googleapis.com";
|
||||
}
|
||||
return typeUrlPrefix + "/SysMsg.SystemMessageHeader";
|
||||
};
|
||||
|
||||
return SystemMessageHeader;
|
||||
})();
|
||||
|
||||
SysMsg.SystemMessageMsgSpec = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a SystemMessageMsgSpec.
|
||||
* @memberof SysMsg
|
||||
* @interface ISystemMessageMsgSpec
|
||||
* @property {number|null} [msgType] SystemMessageMsgSpec msgType
|
||||
* @property {number|null} [subType] SystemMessageMsgSpec subType
|
||||
* @property {number|null} [subSubType] SystemMessageMsgSpec subSubType
|
||||
* @property {number|null} [msgSeq] SystemMessageMsgSpec msgSeq
|
||||
* @property {number|null} [time] SystemMessageMsgSpec time
|
||||
* @property {number|null} [other] SystemMessageMsgSpec other
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessageMsgSpec.
|
||||
* @memberof SysMsg
|
||||
* @classdesc Represents a SystemMessageMsgSpec.
|
||||
* @implements ISystemMessageMsgSpec
|
||||
* @constructor
|
||||
* @param {SysMsg.ISystemMessageMsgSpec=} [properties] Properties to set
|
||||
*/
|
||||
function SystemMessageMsgSpec(properties) {
|
||||
if (properties)
|
||||
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* SystemMessageMsgSpec msgType.
|
||||
* @member {number} msgType
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageMsgSpec.prototype.msgType = 0;
|
||||
|
||||
/**
|
||||
* SystemMessageMsgSpec subType.
|
||||
* @member {number} subType
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageMsgSpec.prototype.subType = 0;
|
||||
|
||||
/**
|
||||
* SystemMessageMsgSpec subSubType.
|
||||
* @member {number} subSubType
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageMsgSpec.prototype.subSubType = 0;
|
||||
|
||||
/**
|
||||
* SystemMessageMsgSpec msgSeq.
|
||||
* @member {number} msgSeq
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageMsgSpec.prototype.msgSeq = 0;
|
||||
|
||||
/**
|
||||
* SystemMessageMsgSpec time.
|
||||
* @member {number} time
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageMsgSpec.prototype.time = 0;
|
||||
|
||||
/**
|
||||
* SystemMessageMsgSpec other.
|
||||
* @member {number} other
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageMsgSpec.prototype.other = 0;
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessageMsgSpec instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @static
|
||||
* @param {SysMsg.ISystemMessageMsgSpec=} [properties] Properties to set
|
||||
* @returns {SysMsg.SystemMessageMsgSpec} SystemMessageMsgSpec instance
|
||||
*/
|
||||
SystemMessageMsgSpec.create = function create(properties) {
|
||||
return new SystemMessageMsgSpec(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageMsgSpec message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {SysMsg.SystemMessageMsgSpec} SystemMessageMsgSpec
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessageMsgSpec.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
let end = length === undefined ? reader.len : reader.pos + length, message = new $root.SysMsg.SystemMessageMsgSpec();
|
||||
while (reader.pos < end) {
|
||||
let tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 1: {
|
||||
message.msgType = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 2: {
|
||||
message.subType = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 3: {
|
||||
message.subSubType = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 5: {
|
||||
message.msgSeq = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 6: {
|
||||
message.time = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 13: {
|
||||
message.other = reader.uint32();
|
||||
break;
|
||||
}
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageMsgSpec message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {SysMsg.SystemMessageMsgSpec} SystemMessageMsgSpec
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessageMsgSpec.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessageMsgSpec
|
||||
* @function getTypeUrl
|
||||
* @memberof SysMsg.SystemMessageMsgSpec
|
||||
* @static
|
||||
* @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns {string} The default type url
|
||||
*/
|
||||
SystemMessageMsgSpec.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
|
||||
if (typeUrlPrefix === undefined) {
|
||||
typeUrlPrefix = "type.googleapis.com";
|
||||
}
|
||||
return typeUrlPrefix + "/SysMsg.SystemMessageMsgSpec";
|
||||
};
|
||||
|
||||
return SystemMessageMsgSpec;
|
||||
})();
|
||||
|
||||
SysMsg.SystemMessageBodyWrapper = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a SystemMessageBodyWrapper.
|
||||
* @memberof SysMsg
|
||||
* @interface ISystemMessageBodyWrapper
|
||||
* @property {Uint8Array|null} [body] SystemMessageBodyWrapper body
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new SystemMessageBodyWrapper.
|
||||
* @memberof SysMsg
|
||||
* @classdesc Represents a SystemMessageBodyWrapper.
|
||||
* @implements ISystemMessageBodyWrapper
|
||||
* @constructor
|
||||
* @param {SysMsg.ISystemMessageBodyWrapper=} [properties] Properties to set
|
||||
*/
|
||||
function SystemMessageBodyWrapper(properties) {
|
||||
if (properties)
|
||||
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* SystemMessageBodyWrapper body.
|
||||
* @member {Uint8Array} body
|
||||
* @memberof SysMsg.SystemMessageBodyWrapper
|
||||
* @instance
|
||||
*/
|
||||
SystemMessageBodyWrapper.prototype.body = $util.newBuffer([]);
|
||||
|
||||
/**
|
||||
* Creates a new SystemMessageBodyWrapper instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof SysMsg.SystemMessageBodyWrapper
|
||||
* @static
|
||||
* @param {SysMsg.ISystemMessageBodyWrapper=} [properties] Properties to set
|
||||
* @returns {SysMsg.SystemMessageBodyWrapper} SystemMessageBodyWrapper instance
|
||||
*/
|
||||
SystemMessageBodyWrapper.create = function create(properties) {
|
||||
return new SystemMessageBodyWrapper(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageBodyWrapper message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof SysMsg.SystemMessageBodyWrapper
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {SysMsg.SystemMessageBodyWrapper} SystemMessageBodyWrapper
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessageBodyWrapper.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
let end = length === undefined ? reader.len : reader.pos + length, message = new $root.SysMsg.SystemMessageBodyWrapper();
|
||||
while (reader.pos < end) {
|
||||
let tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 2: {
|
||||
message.body = reader.bytes();
|
||||
break;
|
||||
}
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a SystemMessageBodyWrapper message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof SysMsg.SystemMessageBodyWrapper
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {SysMsg.SystemMessageBodyWrapper} SystemMessageBodyWrapper
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
SystemMessageBodyWrapper.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Gets the default type url for SystemMessageBodyWrapper
|
||||
* @function getTypeUrl
|
||||
* @memberof SysMsg.SystemMessageBodyWrapper
|
||||
* @static
|
||||
* @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns {string} The default type url
|
||||
*/
|
||||
SystemMessageBodyWrapper.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
|
||||
if (typeUrlPrefix === undefined) {
|
||||
typeUrlPrefix = "type.googleapis.com";
|
||||
}
|
||||
return typeUrlPrefix + "/SysMsg.SystemMessageBodyWrapper";
|
||||
};
|
||||
|
||||
return SystemMessageBodyWrapper;
|
||||
})();
|
||||
|
||||
SysMsg.LikeDetail = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a LikeDetail.
|
||||
* @memberof SysMsg
|
||||
* @interface ILikeDetail
|
||||
* @property {string|null} [txt] LikeDetail txt
|
||||
* @property {number|null} [uin] LikeDetail uin
|
||||
* @property {string|null} [nickname] LikeDetail nickname
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new LikeDetail.
|
||||
* @memberof SysMsg
|
||||
* @classdesc Represents a LikeDetail.
|
||||
* @implements ILikeDetail
|
||||
* @constructor
|
||||
* @param {SysMsg.ILikeDetail=} [properties] Properties to set
|
||||
*/
|
||||
function LikeDetail(properties) {
|
||||
if (properties)
|
||||
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* LikeDetail txt.
|
||||
* @member {string} txt
|
||||
* @memberof SysMsg.LikeDetail
|
||||
* @instance
|
||||
*/
|
||||
LikeDetail.prototype.txt = "";
|
||||
|
||||
/**
|
||||
* LikeDetail uin.
|
||||
* @member {number} uin
|
||||
* @memberof SysMsg.LikeDetail
|
||||
* @instance
|
||||
*/
|
||||
LikeDetail.prototype.uin = 0;
|
||||
|
||||
/**
|
||||
* LikeDetail nickname.
|
||||
* @member {string} nickname
|
||||
* @memberof SysMsg.LikeDetail
|
||||
* @instance
|
||||
*/
|
||||
LikeDetail.prototype.nickname = "";
|
||||
|
||||
/**
|
||||
* Creates a new LikeDetail instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof SysMsg.LikeDetail
|
||||
* @static
|
||||
* @param {SysMsg.ILikeDetail=} [properties] Properties to set
|
||||
* @returns {SysMsg.LikeDetail} LikeDetail instance
|
||||
*/
|
||||
LikeDetail.create = function create(properties) {
|
||||
return new LikeDetail(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a LikeDetail message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof SysMsg.LikeDetail
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {SysMsg.LikeDetail} LikeDetail
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
LikeDetail.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
let end = length === undefined ? reader.len : reader.pos + length, message = new $root.SysMsg.LikeDetail();
|
||||
while (reader.pos < end) {
|
||||
let tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 1: {
|
||||
message.txt = reader.string();
|
||||
break;
|
||||
}
|
||||
case 3: {
|
||||
message.uin = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 5: {
|
||||
message.nickname = reader.string();
|
||||
break;
|
||||
}
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a LikeDetail message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof SysMsg.LikeDetail
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {SysMsg.LikeDetail} LikeDetail
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
LikeDetail.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Gets the default type url for LikeDetail
|
||||
* @function getTypeUrl
|
||||
* @memberof SysMsg.LikeDetail
|
||||
* @static
|
||||
* @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns {string} The default type url
|
||||
*/
|
||||
LikeDetail.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
|
||||
if (typeUrlPrefix === undefined) {
|
||||
typeUrlPrefix = "type.googleapis.com";
|
||||
}
|
||||
return typeUrlPrefix + "/SysMsg.LikeDetail";
|
||||
};
|
||||
|
||||
return LikeDetail;
|
||||
})();
|
||||
|
||||
SysMsg.LikeMsg = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a LikeMsg.
|
||||
* @memberof SysMsg
|
||||
* @interface ILikeMsg
|
||||
* @property {number|null} [count] LikeMsg count
|
||||
* @property {number|null} [time] LikeMsg time
|
||||
* @property {SysMsg.ILikeDetail|null} [detail] LikeMsg detail
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new LikeMsg.
|
||||
* @memberof SysMsg
|
||||
* @classdesc Represents a LikeMsg.
|
||||
* @implements ILikeMsg
|
||||
* @constructor
|
||||
* @param {SysMsg.ILikeMsg=} [properties] Properties to set
|
||||
*/
|
||||
function LikeMsg(properties) {
|
||||
if (properties)
|
||||
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* LikeMsg count.
|
||||
* @member {number} count
|
||||
* @memberof SysMsg.LikeMsg
|
||||
* @instance
|
||||
*/
|
||||
LikeMsg.prototype.count = 0;
|
||||
|
||||
/**
|
||||
* LikeMsg time.
|
||||
* @member {number} time
|
||||
* @memberof SysMsg.LikeMsg
|
||||
* @instance
|
||||
*/
|
||||
LikeMsg.prototype.time = 0;
|
||||
|
||||
/**
|
||||
* LikeMsg detail.
|
||||
* @member {SysMsg.ILikeDetail|null|undefined} detail
|
||||
* @memberof SysMsg.LikeMsg
|
||||
* @instance
|
||||
*/
|
||||
LikeMsg.prototype.detail = null;
|
||||
|
||||
/**
|
||||
* Creates a new LikeMsg instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof SysMsg.LikeMsg
|
||||
* @static
|
||||
* @param {SysMsg.ILikeMsg=} [properties] Properties to set
|
||||
* @returns {SysMsg.LikeMsg} LikeMsg instance
|
||||
*/
|
||||
LikeMsg.create = function create(properties) {
|
||||
return new LikeMsg(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a LikeMsg message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof SysMsg.LikeMsg
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {SysMsg.LikeMsg} LikeMsg
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
LikeMsg.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
let end = length === undefined ? reader.len : reader.pos + length, message = new $root.SysMsg.LikeMsg();
|
||||
while (reader.pos < end) {
|
||||
let tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 1: {
|
||||
message.count = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 2: {
|
||||
message.time = reader.uint32();
|
||||
break;
|
||||
}
|
||||
case 3: {
|
||||
message.detail = $root.SysMsg.LikeDetail.decode(reader, reader.uint32());
|
||||
break;
|
||||
}
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a LikeMsg message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof SysMsg.LikeMsg
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {SysMsg.LikeMsg} LikeMsg
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
LikeMsg.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Gets the default type url for LikeMsg
|
||||
* @function getTypeUrl
|
||||
* @memberof SysMsg.LikeMsg
|
||||
* @static
|
||||
* @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns {string} The default type url
|
||||
*/
|
||||
LikeMsg.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
|
||||
if (typeUrlPrefix === undefined) {
|
||||
typeUrlPrefix = "type.googleapis.com";
|
||||
}
|
||||
return typeUrlPrefix + "/SysMsg.LikeMsg";
|
||||
};
|
||||
|
||||
return LikeMsg;
|
||||
})();
|
||||
|
||||
SysMsg.ProfileLikeTip = (function() {
|
||||
|
||||
/**
|
||||
* Properties of a ProfileLikeTip.
|
||||
* @memberof SysMsg
|
||||
* @interface IProfileLikeTip
|
||||
* @property {SysMsg.ILikeMsg|null} [msg] ProfileLikeTip msg
|
||||
*/
|
||||
|
||||
/**
|
||||
* Constructs a new ProfileLikeTip.
|
||||
* @memberof SysMsg
|
||||
* @classdesc Represents a ProfileLikeTip.
|
||||
* @implements IProfileLikeTip
|
||||
* @constructor
|
||||
* @param {SysMsg.IProfileLikeTip=} [properties] Properties to set
|
||||
*/
|
||||
function ProfileLikeTip(properties) {
|
||||
if (properties)
|
||||
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
|
||||
if (properties[keys[i]] != null)
|
||||
this[keys[i]] = properties[keys[i]];
|
||||
}
|
||||
|
||||
/**
|
||||
* ProfileLikeTip msg.
|
||||
* @member {SysMsg.ILikeMsg|null|undefined} msg
|
||||
* @memberof SysMsg.ProfileLikeTip
|
||||
* @instance
|
||||
*/
|
||||
ProfileLikeTip.prototype.msg = null;
|
||||
|
||||
/**
|
||||
* Creates a new ProfileLikeTip instance using the specified properties.
|
||||
* @function create
|
||||
* @memberof SysMsg.ProfileLikeTip
|
||||
* @static
|
||||
* @param {SysMsg.IProfileLikeTip=} [properties] Properties to set
|
||||
* @returns {SysMsg.ProfileLikeTip} ProfileLikeTip instance
|
||||
*/
|
||||
ProfileLikeTip.create = function create(properties) {
|
||||
return new ProfileLikeTip(properties);
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a ProfileLikeTip message from the specified reader or buffer.
|
||||
* @function decode
|
||||
* @memberof SysMsg.ProfileLikeTip
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @param {number} [length] Message length if known beforehand
|
||||
* @returns {SysMsg.ProfileLikeTip} ProfileLikeTip
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
ProfileLikeTip.decode = function decode(reader, length) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = $Reader.create(reader);
|
||||
let end = length === undefined ? reader.len : reader.pos + length, message = new $root.SysMsg.ProfileLikeTip();
|
||||
while (reader.pos < end) {
|
||||
let tag = reader.uint32();
|
||||
switch (tag >>> 3) {
|
||||
case 14: {
|
||||
message.msg = $root.SysMsg.LikeMsg.decode(reader, reader.uint32());
|
||||
break;
|
||||
}
|
||||
default:
|
||||
reader.skipType(tag & 7);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return message;
|
||||
};
|
||||
|
||||
/**
|
||||
* Decodes a ProfileLikeTip message from the specified reader or buffer, length delimited.
|
||||
* @function decodeDelimited
|
||||
* @memberof SysMsg.ProfileLikeTip
|
||||
* @static
|
||||
* @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
|
||||
* @returns {SysMsg.ProfileLikeTip} ProfileLikeTip
|
||||
* @throws {Error} If the payload is not a reader or valid buffer
|
||||
* @throws {$protobuf.util.ProtocolError} If required fields are missing
|
||||
*/
|
||||
ProfileLikeTip.decodeDelimited = function decodeDelimited(reader) {
|
||||
if (!(reader instanceof $Reader))
|
||||
reader = new $Reader(reader);
|
||||
return this.decode(reader, reader.uint32());
|
||||
};
|
||||
|
||||
/**
|
||||
* Gets the default type url for ProfileLikeTip
|
||||
* @function getTypeUrl
|
||||
* @memberof SysMsg.ProfileLikeTip
|
||||
* @static
|
||||
* @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
|
||||
* @returns {string} The default type url
|
||||
*/
|
||||
ProfileLikeTip.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
|
||||
if (typeUrlPrefix === undefined) {
|
||||
typeUrlPrefix = "type.googleapis.com";
|
||||
}
|
||||
return typeUrlPrefix + "/SysMsg.ProfileLikeTip";
|
||||
};
|
||||
|
||||
return ProfileLikeTip;
|
||||
})();
|
||||
|
||||
return SysMsg;
|
||||
})();
|
||||
|
||||
export { $root as default };
|
18
src/ntqqapi/proto/profileLikeTip.proto
Normal file
18
src/ntqqapi/proto/profileLikeTip.proto
Normal file
@@ -0,0 +1,18 @@
|
||||
syntax = "proto3";
|
||||
package SysMsg;
|
||||
|
||||
message LikeDetail {
|
||||
string txt = 1;
|
||||
uint32 uin = 3;
|
||||
string nickname = 5;
|
||||
}
|
||||
|
||||
message LikeMsg {
|
||||
uint32 count = 1;
|
||||
uint32 time = 2;
|
||||
LikeDetail detail = 3;
|
||||
}
|
||||
|
||||
message ProfileLikeTip {
|
||||
LikeMsg msg = 14;
|
||||
}
|
30
src/ntqqapi/proto/systemMessage.proto
Normal file
30
src/ntqqapi/proto/systemMessage.proto
Normal file
@@ -0,0 +1,30 @@
|
||||
syntax = "proto3";
|
||||
package SysMsg;
|
||||
|
||||
message SystemMessage {
|
||||
repeated SystemMessageHeader header = 1;
|
||||
repeated SystemMessageMsgSpec msgSpec = 2;
|
||||
SystemMessageBodyWrapper bodyWrapper = 3;
|
||||
}
|
||||
|
||||
message SystemMessageHeader {
|
||||
uint32 peerNumber = 1;
|
||||
string peerString = 2;
|
||||
uint32 uin = 5;
|
||||
optional string uid = 6;
|
||||
}
|
||||
|
||||
message SystemMessageMsgSpec {
|
||||
uint32 msgType = 1;
|
||||
uint32 subType = 2;
|
||||
uint32 subSubType = 3;
|
||||
uint32 msgSeq = 5;
|
||||
uint32 time = 6;
|
||||
//uint64 msgId = 12;
|
||||
uint32 other = 13;
|
||||
}
|
||||
|
||||
message SystemMessageBodyWrapper {
|
||||
bytes body = 2;
|
||||
// Find the first [08], or ignore the first 7 bytes?
|
||||
}
|
@@ -1,5 +1,6 @@
|
||||
import { BuddyProfileLikeReq } from '../types'
|
||||
import { GeneralCallResult } from './common'
|
||||
import { Dict } from 'cosmokit'
|
||||
|
||||
export interface NodeIKernelProfileLikeService {
|
||||
addKernelProfileLikeListener(listener: NodeIKernelProfileLikeService): void
|
||||
@@ -10,8 +11,18 @@ export interface NodeIKernelProfileLikeService {
|
||||
|
||||
getBuddyProfileLike(req: BuddyProfileLikeReq): Promise<GeneralCallResult & {
|
||||
info: {
|
||||
userLikeInfos: Array<unknown>,
|
||||
friendMaxVotes: number,
|
||||
userLikeInfos: {
|
||||
uid: string
|
||||
time: string
|
||||
favoriteInfo: {
|
||||
total_count: number
|
||||
last_time: number
|
||||
today_count: number
|
||||
userInfos: Dict[]
|
||||
}
|
||||
voteInfo: Dict
|
||||
}[]
|
||||
friendMaxVotes: number
|
||||
start: number
|
||||
}
|
||||
}>
|
||||
|
@@ -20,9 +20,9 @@ export class UploadGroupFile extends BaseAction<UploadGroupFilePayload, null> {
|
||||
if (!success) {
|
||||
throw new Error(errMsg)
|
||||
}
|
||||
const sendFileEle = await SendElementEntities.file(this.ctx, path, payload.name || fileName, payload.folder_id)
|
||||
const file = await SendElementEntities.file(this.ctx, path, payload.name || fileName, payload.folder ?? payload.folder_id)
|
||||
const peer = await createPeer(this.ctx, payload, CreatePeerMode.Group)
|
||||
await sendMsg(this.ctx, peer, [sendFileEle], [])
|
||||
await sendMsg(this.ctx, peer, [file], [])
|
||||
return null
|
||||
}
|
||||
}
|
||||
|
@@ -62,6 +62,7 @@ import { GetGroupAtAllRemain } from './go-cqhttp/GetGroupAtAllRemain'
|
||||
import { GetGroupRootFiles } from './go-cqhttp/GetGroupRootFiles'
|
||||
import { SetOnlineStatus } from './llonebot/SetOnlineStatus'
|
||||
import { SendGroupNotice } from './go-cqhttp/SendGroupNotice'
|
||||
import { GetProfileLike } from './llonebot/GetProfileLike'
|
||||
|
||||
export function initActionMap(adapter: Adapter) {
|
||||
const actionHandlers = [
|
||||
@@ -74,6 +75,7 @@ export function initActionMap(adapter: Adapter) {
|
||||
new GetFriendWithCategory(adapter),
|
||||
new GetEvent(adapter),
|
||||
new SetOnlineStatus(adapter),
|
||||
new GetProfileLike(adapter),
|
||||
// onebot11
|
||||
new SendLike(adapter),
|
||||
new GetMsg(adapter),
|
||||
|
17
src/onebot11/action/llonebot/GetProfileLike.ts
Normal file
17
src/onebot11/action/llonebot/GetProfileLike.ts
Normal file
@@ -0,0 +1,17 @@
|
||||
import BaseAction from '../BaseAction'
|
||||
import { ActionName } from '../types'
|
||||
import { selfInfo } from '@/common/globalVars'
|
||||
import { Dict } from 'cosmokit'
|
||||
|
||||
export class GetProfileLike extends BaseAction<void, Dict[]> {
|
||||
actionName = ActionName.GetProfileLike
|
||||
|
||||
async _handle() {
|
||||
const ret = await this.ctx.ntUserApi.getProfileLike(selfInfo.uid)
|
||||
const listdata = ret.info.userLikeInfos[0].favoriteInfo.userInfos
|
||||
for (const item of listdata) {
|
||||
item.uin = Number(await this.ctx.ntUserApi.getUinByUid(item.uid)) || 0
|
||||
}
|
||||
return listdata
|
||||
}
|
||||
}
|
@@ -20,6 +20,7 @@ export enum ActionName {
|
||||
GetFriendsWithCategory = 'get_friends_with_category',
|
||||
GetEvent = 'get_event',
|
||||
SetOnlineStatus = 'set_online_status',
|
||||
GetProfileLike = 'get_profile_like',
|
||||
// onebot 11
|
||||
SendLike = 'send_like',
|
||||
GetLoginInfo = 'get_login_info',
|
||||
@@ -65,9 +66,9 @@ export enum ActionName {
|
||||
GoCQHTTP_DownloadFile = 'download_file',
|
||||
GoCQHTTP_GetGroupMsgHistory = 'get_group_msg_history',
|
||||
GoCQHTTP_GetForwardMsg = 'get_forward_msg',
|
||||
GoCQHTTP_GetEssenceMsg = "get_essence_msg_list",
|
||||
GoCQHTTP_HandleQuickOperation = ".handle_quick_operation",
|
||||
GetGroupHonorInfo = "get_group_honor_info",
|
||||
GoCQHTTP_GetEssenceMsg = 'get_essence_msg_list',
|
||||
GoCQHTTP_HandleQuickOperation = '.handle_quick_operation',
|
||||
GetGroupHonorInfo = 'get_group_honor_info',
|
||||
GoCQHTTP_SetEssenceMsg = 'set_essence_msg',
|
||||
GoCQHTTP_DelEssenceMsg = 'delete_essence_msg',
|
||||
GoCQHTTP_DelGroupFile = 'delete_group_file',
|
||||
|
@@ -27,6 +27,8 @@ import { initActionMap } from './action'
|
||||
import { llonebotError } from '../common/globalVars'
|
||||
import { OB11GroupCardEvent } from './event/notice/OB11GroupCardEvent'
|
||||
import { OB11GroupAdminNoticeEvent } from './event/notice/OB11GroupAdminNoticeEvent'
|
||||
import { OB11ProfileLikeEvent } from './event/notice/OB11ProfileLikeEvent'
|
||||
import { SysMsg } from '@/ntqqapi/proto/compiled'
|
||||
|
||||
declare module 'cordis' {
|
||||
interface Context {
|
||||
@@ -410,6 +412,18 @@ class OneBot11Adapter extends Service {
|
||||
this.ctx.on('nt/group-member-info-updated', input => {
|
||||
this.handleGroupMemberInfoUpdated(input.groupCode, input.members)
|
||||
})
|
||||
this.ctx.on('nt/system-message-created', input => {
|
||||
const sysMsg = SysMsg.SystemMessage.decode(input)
|
||||
const { msgType, subType, subSubType } = sysMsg.msgSpec[0] ?? {}
|
||||
if (msgType === 528 && subType === 39 && subSubType === 39) {
|
||||
const tip = SysMsg.ProfileLikeTip.decode(sysMsg.bodyWrapper!.body!.slice(12))
|
||||
const detail = tip.msg?.detail
|
||||
if (!detail) return
|
||||
const [times] = detail.txt?.match(/\d+/) ?? ['0']
|
||||
const profileLikeEvent = new OB11ProfileLikeEvent(detail.uin!, detail.nickname!, +times)
|
||||
this.dispatch(profileLikeEvent)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
|
@@ -489,7 +489,7 @@ export namespace OB11Entities {
|
||||
}
|
||||
}
|
||||
else if (element.fileElement) {
|
||||
return new OB11GroupUploadNoticeEvent(parseInt(msg.peerUid), parseInt(msg.senderUin!), {
|
||||
return new OB11GroupUploadNoticeEvent(+msg.peerUid, +msg.senderUin!, {
|
||||
id: element.fileElement.fileUuid!,
|
||||
name: element.fileElement.fileName,
|
||||
size: parseInt(element.fileElement.fileSize),
|
||||
@@ -587,7 +587,7 @@ export namespace OB11Entities {
|
||||
{ txt: '头衔', type: 'nor' }
|
||||
]
|
||||
}
|
||||
|
||||
|
||||
* */
|
||||
if (grayTipElement.jsonGrayTipElement.busiId == 1061) {
|
||||
//判断业务类型
|
||||
|
@@ -1,4 +1,4 @@
|
||||
import { selfInfo } from "@/common/globalVars"
|
||||
import { selfInfo } from '@/common/globalVars'
|
||||
|
||||
export enum EventType {
|
||||
META = 'meta_event',
|
||||
|
16
src/onebot11/event/notice/OB11ProfileLikeEvent.ts
Normal file
16
src/onebot11/event/notice/OB11ProfileLikeEvent.ts
Normal file
@@ -0,0 +1,16 @@
|
||||
import { OB11BaseNoticeEvent } from './OB11BaseNoticeEvent'
|
||||
|
||||
export class OB11ProfileLikeEvent extends OB11BaseNoticeEvent {
|
||||
notice_type = 'notify'
|
||||
sub_type = 'profile_like'
|
||||
operator_id: number
|
||||
operator_nick: string
|
||||
times: number
|
||||
|
||||
constructor(operatorId: number, operatorNick: string, times: number) {
|
||||
super()
|
||||
this.operator_id = operatorId
|
||||
this.operator_nick = operatorNick
|
||||
this.times = times
|
||||
}
|
||||
}
|
@@ -1 +1 @@
|
||||
export const version = '3.32.0'
|
||||
export const version = '3.32.4'
|
||||
|
@@ -24,11 +24,7 @@
|
||||
"noEmit": true
|
||||
},
|
||||
"include": [
|
||||
"src/*",
|
||||
"src/**/*",
|
||||
"scripts/*"
|
||||
],
|
||||
"exclude": [
|
||||
"node_modules"
|
||||
"src",
|
||||
"scripts"
|
||||
]
|
||||
}
|
Reference in New Issue
Block a user