mirror of
https://github.com/NapNeko/NapCatQQ.git
synced 2025-07-19 12:03:37 +00:00
Compare commits
24 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
68216415b6 | ||
![]() |
ba53da18d1 | ||
![]() |
9b76fa3582 | ||
![]() |
13d8d10a7f | ||
![]() |
5c6c1bb09d | ||
![]() |
12105d96ea | ||
![]() |
4054756035 | ||
![]() |
16769c7838 | ||
![]() |
cd076c5959 | ||
![]() |
f52e1aa131 | ||
![]() |
fdc1ef7e9a | ||
![]() |
9cccf2d47b | ||
![]() |
0796f27f2a | ||
![]() |
6c84014e0d | ||
![]() |
cd496a22bf | ||
![]() |
0200343780 | ||
![]() |
47fb629d26 | ||
![]() |
5b75e753a7 | ||
![]() |
326e9b86ce | ||
![]() |
e430cc54f2 | ||
![]() |
fd26a9c698 | ||
![]() |
e79b608f77 | ||
![]() |
03098ee024 | ||
![]() |
a2bfdd003c |
76
.github/workflows/release.yml
vendored
76
.github/workflows/release.yml
vendored
@@ -30,34 +30,34 @@ jobs:
|
|||||||
ls
|
ls
|
||||||
node ./script/checkVersion.cjs
|
node ./script/checkVersion.cjs
|
||||||
sh ./checkVersion.sh
|
sh ./checkVersion.sh
|
||||||
Build-LiteLoader:
|
# Build-LiteLoader:
|
||||||
needs: [check-version]
|
# needs: [check-version]
|
||||||
runs-on: ubuntu-latest
|
# runs-on: ubuntu-latest
|
||||||
steps:
|
# steps:
|
||||||
- name: Clone Main Repository
|
# - name: Clone Main Repository
|
||||||
uses: actions/checkout@v4
|
# uses: actions/checkout@v4
|
||||||
with:
|
# with:
|
||||||
repository: 'NapNeko/NapCatQQ'
|
# repository: 'NapNeko/NapCatQQ'
|
||||||
submodules: true
|
# submodules: true
|
||||||
ref: main
|
# ref: main
|
||||||
token: ${{ secrets.NAPCAT_BUILD }}
|
# token: ${{ secrets.NAPCAT_BUILD }}
|
||||||
- name: Use Node.js 20.X
|
# - name: Use Node.js 20.X
|
||||||
uses: actions/setup-node@v4
|
# uses: actions/setup-node@v4
|
||||||
with:
|
# with:
|
||||||
node-version: 20.x
|
# node-version: 20.x
|
||||||
|
|
||||||
- name: Build NuCat Framework
|
# - name: Build NuCat Framework
|
||||||
run: |
|
# run: |
|
||||||
npm i
|
# npm i
|
||||||
npm run build:framework
|
# npm run build:framework
|
||||||
cd dist
|
# cd dist
|
||||||
npm i --omit=dev
|
# npm i --omit=dev
|
||||||
cd ..
|
# cd ..
|
||||||
- name: Upload Artifact
|
# - name: Upload Artifact
|
||||||
uses: actions/upload-artifact@v4
|
# uses: actions/upload-artifact@v4
|
||||||
with:
|
# with:
|
||||||
name: NapCat.Framework
|
# name: NapCat.Framework
|
||||||
path: dist
|
# path: dist
|
||||||
Build-Shell:
|
Build-Shell:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
needs: [check-version]
|
needs: [check-version]
|
||||||
@@ -90,24 +90,31 @@ jobs:
|
|||||||
path: dist
|
path: dist
|
||||||
|
|
||||||
release-napcat:
|
release-napcat:
|
||||||
needs: [Build-LiteLoader,Build-Shell]
|
needs: [Build-Shell]
|
||||||
|
# needs: [Build-LiteLoader,Build-Shell]
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- name: Download All Artifact
|
- name: Download All Artifact
|
||||||
uses: actions/download-artifact@v4
|
uses: actions/download-artifact@v4
|
||||||
|
|
||||||
- name: Compress subdirectories
|
- name: Compress subdirectories
|
||||||
run: |
|
run: |
|
||||||
cd ./NapCat.Shell/
|
cd ./NapCat.Shell/
|
||||||
zip -q -r NapCat.Shell.zip *
|
zip -q -r NapCat.Shell.zip *
|
||||||
cd ..
|
cd ..
|
||||||
cd ./NapCat.Framework/
|
|
||||||
zip -q -r NapCat.Framework.zip *
|
|
||||||
cd ..
|
|
||||||
rm ./NapCat.Shell.zip -rf
|
rm ./NapCat.Shell.zip -rf
|
||||||
rm ./NapCat.Framework.zip -rf
|
|
||||||
mv ./NapCat.Shell/NapCat.Shell.zip ./
|
mv ./NapCat.Shell/NapCat.Shell.zip ./
|
||||||
mv ./NapCat.Framework/NapCat.Framework.zip ./
|
# - name: Compress subdirectories
|
||||||
|
# run: |
|
||||||
|
# cd ./NapCat.Shell/
|
||||||
|
# zip -q -r NapCat.Shell.zip *
|
||||||
|
# cd ..
|
||||||
|
# cd ./NapCat.Framework/
|
||||||
|
# zip -q -r NapCat.Framework.zip *
|
||||||
|
# cd ..
|
||||||
|
# rm ./NapCat.Shell.zip -rf
|
||||||
|
# rm ./NapCat.Framework.zip -rf
|
||||||
|
# mv ./NapCat.Shell/NapCat.Shell.zip ./
|
||||||
|
# mv ./NapCat.Framework/NapCat.Framework.zip ./
|
||||||
- name: Extract version from tag
|
- name: Extract version from tag
|
||||||
run: echo "VERSION=${GITHUB_REF#refs/tags/v}" >> $GITHUB_ENV
|
run: echo "VERSION=${GITHUB_REF#refs/tags/v}" >> $GITHUB_ENV
|
||||||
|
|
||||||
@@ -121,6 +128,5 @@ jobs:
|
|||||||
token: ${{ secrets.GITHUB_TOKEN }}
|
token: ${{ secrets.GITHUB_TOKEN }}
|
||||||
body_path: CHANGELOG.md
|
body_path: CHANGELOG.md
|
||||||
files: |
|
files: |
|
||||||
NapCat.Framework.zip
|
|
||||||
NapCat.Shell.zip
|
NapCat.Shell.zip
|
||||||
draft: true
|
draft: true
|
||||||
|
@@ -14,6 +14,7 @@ NapCatQQ 是现代化的基于 NTQQ 的 Bot 协议端实现。
|
|||||||
## 项目优势
|
## 项目优势
|
||||||
- [x] **多种启动方式**:支持以无头、LiteLoader 插件、仅 QQ GUI 三种方式启动
|
- [x] **多种启动方式**:支持以无头、LiteLoader 插件、仅 QQ GUI 三种方式启动
|
||||||
- [x] **低占用**:无头模式占用资源极低,适合在服务器上运行
|
- [x] **低占用**:无头模式占用资源极低,适合在服务器上运行
|
||||||
|
- [x] **超多接口**:在实现大部分Onebot接口上扩展了一套私有API
|
||||||
- [x] **WebUI**:自带 WebUI 支持,远程管理更加便捷
|
- [x] **WebUI**:自带 WebUI 支持,远程管理更加便捷
|
||||||
|
|
||||||
## 如何使用
|
## 如何使用
|
||||||
|
@@ -4,7 +4,7 @@
|
|||||||
"name": "NapCatQQ",
|
"name": "NapCatQQ",
|
||||||
"slug": "NapCat.Framework",
|
"slug": "NapCat.Framework",
|
||||||
"description": "高性能的 OneBot 11 协议实现",
|
"description": "高性能的 OneBot 11 协议实现",
|
||||||
"version": "2.0.35",
|
"version": "2.1.0",
|
||||||
"icon": "./logo.png",
|
"icon": "./logo.png",
|
||||||
"authors": [
|
"authors": [
|
||||||
{
|
{
|
||||||
|
@@ -2,7 +2,7 @@
|
|||||||
"name": "napcat",
|
"name": "napcat",
|
||||||
"private": true,
|
"private": true,
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"version": "2.0.35",
|
"version": "2.1.0",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"build:framework": "vite build --mode framework",
|
"build:framework": "vite build --mode framework",
|
||||||
"build:shell": "vite build --mode shell",
|
"build:shell": "vite build --mode shell",
|
||||||
|
@@ -16,16 +16,13 @@ export interface ListenerIBase {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export class LegacyNTEventWrapper {
|
export class LegacyNTEventWrapper {
|
||||||
private listenerMapping: Record<string, ListenerIBase>; //ListenerName-Unique -> Listener构造函数
|
|
||||||
private WrapperSession: NodeIQQNTWrapperSession | undefined; //WrapperSession
|
private WrapperSession: NodeIQQNTWrapperSession | undefined; //WrapperSession
|
||||||
private listenerManager: Map<string, ListenerClassBase> = new Map<string, ListenerClassBase>(); //ListenerName-Unique -> Listener实例
|
private listenerManager: Map<string, ListenerClassBase> = new Map<string, ListenerClassBase>(); //ListenerName-Unique -> Listener实例
|
||||||
private EventTask = new Map<string, Map<string, Map<string, Internal_MapKey>>>(); //tasks ListenerMainName -> ListenerSubName-> uuid -> {timeout,createtime,func}
|
private EventTask = new Map<string, Map<string, Map<string, Internal_MapKey>>>(); //tasks ListenerMainName -> ListenerSubName-> uuid -> {timeout,createtime,func}
|
||||||
|
|
||||||
constructor(
|
constructor(
|
||||||
listenerMapping: Record<string, ListenerIBase>,
|
wrapperSession: NodeIQQNTWrapperSession
|
||||||
wrapperSession: NodeIQQNTWrapperSession,
|
|
||||||
) {
|
) {
|
||||||
this.listenerMapping = listenerMapping;
|
|
||||||
this.WrapperSession = wrapperSession;
|
this.WrapperSession = wrapperSession;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -72,18 +69,17 @@ export class LegacyNTEventWrapper {
|
|||||||
}
|
}
|
||||||
|
|
||||||
createListenerFunction<T>(listenerMainName: string, uniqueCode: string = ''): T {
|
createListenerFunction<T>(listenerMainName: string, uniqueCode: string = ''): T {
|
||||||
const ListenerType = this.listenerMapping![listenerMainName];
|
let existListener = this.listenerManager.get(listenerMainName + uniqueCode);
|
||||||
let Listener = this.listenerManager.get(listenerMainName + uniqueCode);
|
if (!existListener) {
|
||||||
if (!Listener && ListenerType) {
|
let Listener = this.createProxyDispatch(listenerMainName);
|
||||||
Listener = new ListenerType(this.createProxyDispatch(listenerMainName));
|
|
||||||
const ServiceSubName = listenerMainName.match(/^NodeIKernel(.*?)Listener$/)![1];
|
const ServiceSubName = listenerMainName.match(/^NodeIKernel(.*?)Listener$/)![1];
|
||||||
const Service = 'NodeIKernel' + ServiceSubName + 'Service/addKernel' + ServiceSubName + 'Listener';
|
const Service = 'NodeIKernel' + ServiceSubName + 'Service/addKernel' + ServiceSubName + 'Listener';
|
||||||
const addfunc = this.createEventFunction<(listener: T) => number>(Service);
|
const addfunc = this.createEventFunction<(listener: T) => number>(Service);
|
||||||
addfunc!(Listener as T);
|
addfunc!(Listener as T);
|
||||||
//console.log(addfunc!(Listener as T));
|
|
||||||
this.listenerManager.set(listenerMainName + uniqueCode, Listener);
|
this.listenerManager.set(listenerMainName + uniqueCode, Listener);
|
||||||
|
return Listener as T;
|
||||||
}
|
}
|
||||||
return Listener as T;
|
return existListener as T;
|
||||||
}
|
}
|
||||||
|
|
||||||
//统一回调清理事件
|
//统一回调清理事件
|
||||||
|
@@ -2,7 +2,7 @@ import path, { dirname } from 'path';
|
|||||||
import { fileURLToPath } from 'url';
|
import { fileURLToPath } from 'url';
|
||||||
import fs from 'fs';
|
import fs from 'fs';
|
||||||
|
|
||||||
export const napcat_version = '2.0.35';
|
export const napcat_version = '2.1.0';
|
||||||
|
|
||||||
export class NapCatPathWrapper {
|
export class NapCatPathWrapper {
|
||||||
binaryPath: string;
|
binaryPath: string;
|
||||||
|
@@ -74,7 +74,7 @@ export class QQBasicInfoWrapper {
|
|||||||
this.context.logger.log(
|
this.context.logger.log(
|
||||||
`[QQ版本兼容性检测] ${this.getFullQQVesion()} 版本兼容性不佳,可能会导致一些功能无法正常使用`,
|
`[QQ版本兼容性检测] ${this.getFullQQVesion()} 版本兼容性不佳,可能会导致一些功能无法正常使用`,
|
||||||
);
|
);
|
||||||
return { appid: systemPlatform === 'linux' ? '537237950' : '537237765', qua: this.getQUAInternal() };
|
return { appid: systemPlatform === 'linux' ? '537240645' : '537240610', qua: this.getQUAInternal() };
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -259,7 +259,7 @@ export async function uri2local(dir: string, uri: string, filename: string | und
|
|||||||
if (success) {
|
if (success) {
|
||||||
filePath = fileTypePath;
|
filePath = fileTypePath;
|
||||||
fileExt = ext;
|
fileExt = ext;
|
||||||
filename = path.basename(filePath, fileExt);
|
filename = filename + '.' + ext;
|
||||||
}
|
}
|
||||||
return { success: true, errMsg: '', fileName: filename, ext: fileExt, path: filePath, isLocal: true };
|
return { success: true, errMsg: '', fileName: filename, ext: fileExt, path: filePath, isLocal: true };
|
||||||
}
|
}
|
||||||
|
@@ -97,19 +97,19 @@ export function isEqual(obj1: any, obj2: any) {
|
|||||||
export function getDefaultQQVersionConfigInfo(): QQVersionConfigType {
|
export function getDefaultQQVersionConfigInfo(): QQVersionConfigType {
|
||||||
if (os.platform() === 'linux') {
|
if (os.platform() === 'linux') {
|
||||||
return {
|
return {
|
||||||
baseVersion: '3.2.12-26702',
|
baseVersion: '3.2.12-27206',
|
||||||
curVersion: '3.2.12-26702',
|
curVersion: '3.2.12-27206',
|
||||||
prevVersion: '',
|
prevVersion: '',
|
||||||
onErrorVersions: [],
|
onErrorVersions: [],
|
||||||
buildId: '26702',
|
buildId: '27206',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
return {
|
return {
|
||||||
baseVersion: '9.9.15-26702',
|
baseVersion: '9.9.15-27206',
|
||||||
curVersion: '9.9.15-26702',
|
curVersion: '9.9.15-27206',
|
||||||
prevVersion: '',
|
prevVersion: '',
|
||||||
onErrorVersions: [],
|
onErrorVersions: [],
|
||||||
buildId: '26702',
|
buildId: '27206',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -44,8 +44,8 @@ export class NapCatCore {
|
|||||||
constructor(context: InstanceContext, selfInfo: SelfInfo) {
|
constructor(context: InstanceContext, selfInfo: SelfInfo) {
|
||||||
this.selfInfo = selfInfo;
|
this.selfInfo = selfInfo;
|
||||||
this.context = context;
|
this.context = context;
|
||||||
this.util = new this.context.wrapper.NodeQQNTWrapperUtil();
|
this.util = this.context.wrapper.NodeQQNTWrapperUtil;
|
||||||
this.eventWrapper = new LegacyNTEventWrapper(context.wrapper, context.session);
|
this.eventWrapper = new LegacyNTEventWrapper(context.session);
|
||||||
this.apis = {
|
this.apis = {
|
||||||
FileApi: new NTQQFileApi(this.context, this),
|
FileApi: new NTQQFileApi(this.context, this),
|
||||||
SystemApi: new NTQQSystemApi(this.context, this),
|
SystemApi: new NTQQSystemApi(this.context, this),
|
||||||
@@ -79,7 +79,7 @@ export class NapCatCore {
|
|||||||
}
|
}
|
||||||
|
|
||||||
get dataPath(): string {
|
get dataPath(): string {
|
||||||
let result = this.util.getNTUserDataInfoConfig();
|
let result = this.context.wrapper.NodeQQNTWrapperUtil.getNTUserDataInfoConfig();
|
||||||
if (!result) {
|
if (!result) {
|
||||||
result = path.resolve(os.homedir(), './.config/QQ');
|
result = path.resolve(os.homedir(), './.config/QQ');
|
||||||
fs.mkdirSync(result, { recursive: true });
|
fs.mkdirSync(result, { recursive: true });
|
||||||
@@ -98,7 +98,7 @@ export class NapCatCore {
|
|||||||
};
|
};
|
||||||
//await sleep(2500);
|
//await sleep(2500);
|
||||||
this.context.session.getMsgService().addKernelMsgListener(
|
this.context.session.getMsgService().addKernelMsgListener(
|
||||||
new this.context.wrapper.NodeIKernelMsgListener(proxiedListenerOf(msgListener, this.context.logger)),
|
proxiedListenerOf(msgListener, this.context.logger) as any
|
||||||
);
|
);
|
||||||
|
|
||||||
const profileListener = new ProfileListener();
|
const profileListener = new ProfileListener();
|
||||||
@@ -113,7 +113,7 @@ export class NapCatCore {
|
|||||||
// }
|
// }
|
||||||
};
|
};
|
||||||
this.context.session.getProfileService().addKernelProfileListener(
|
this.context.session.getProfileService().addKernelProfileListener(
|
||||||
new this.context.wrapper.NodeIKernelProfileListener(proxiedListenerOf(profileListener, this.context.logger)),
|
proxiedListenerOf(profileListener, this.context.logger),
|
||||||
);
|
);
|
||||||
|
|
||||||
// 群相关
|
// 群相关
|
||||||
@@ -197,7 +197,7 @@ export class NapCatCore {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
this.context.session.getGroupService().addKernelGroupListener(
|
this.context.session.getGroupService().addKernelGroupListener(
|
||||||
new this.context.wrapper.NodeIKernelGroupListener(proxiedListenerOf(groupListener, this.context.logger)),
|
proxiedListenerOf(profileListener, this.context.logger) as any
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
checkAdminEvent(groupCode: string, memberNew: GroupMember, memberOld: GroupMember | undefined): boolean {
|
checkAdminEvent(groupCode: string, memberNew: GroupMember, memberOld: GroupMember | undefined): boolean {
|
||||||
|
68
src/core/external/appid.json
vendored
68
src/core/external/appid.json
vendored
@@ -1,58 +1,26 @@
|
|||||||
{
|
{
|
||||||
"3.1.2-13107": {
|
"3.2.12-27187": {
|
||||||
"appid": 537146866,
|
"appid": 537240645,
|
||||||
"qua": "V1_LNX_NQ_3.1.2-13107_RDM_B"
|
"qua": "V1_LNX_NQ_3.2.12_27187_GW_B"
|
||||||
},
|
},
|
||||||
"3.2.10-25765": {
|
"3.2.12-27206": {
|
||||||
"appid": 537234773,
|
"appid": 537240645,
|
||||||
"qua": "V1_LNX_NQ_3.2.10_25765_GW_B"
|
"qua": "V1_LNX_NQ_3.2.12_27206_GW_B"
|
||||||
},
|
},
|
||||||
"3.2.12-26702": {
|
"3.2.12-27254":{
|
||||||
"appid": 537237950,
|
"appid": 537240795,
|
||||||
"qua": "V1_LNX_NQ_3.2.12_26702_GW_B"
|
"qua": "V1_LNX_NQ_3.2.12_27254_GW_B"
|
||||||
},
|
},
|
||||||
"3.2.12-26740": {
|
"9.9.15-27187":{
|
||||||
"appid": 537237950,
|
"appid": 537240610,
|
||||||
"qua": "V1_WIN_NQ_9.9.15_26740_GW_B"
|
"qua": "V1_WIN_NQ_9.9.15_27187_GW_B"
|
||||||
},
|
},
|
||||||
"3.2.12-26909": {
|
"9.9.15-27206":{
|
||||||
"appid": 537237923,
|
"appid": 537240610,
|
||||||
"qua": "V1_LNX_NQ_3.2.12_26909_GW_B"
|
"qua": "V1_WIN_NQ_9.9.15_27206_GW_B"
|
||||||
},
|
},
|
||||||
"9.9.11-24815": {
|
"9.9.15-27254":{
|
||||||
"appid": 537226656,
|
"appid": 537240709,
|
||||||
"qua": "V1_WIN_NQ_9.9.11_24815_GW_B"
|
"qua": "V1_WIN_NQ_9.9.15_27254_GW_B"
|
||||||
},
|
|
||||||
"9.9.12-25493": {
|
|
||||||
"appid": 537231759,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.12_25493_GW_B"
|
|
||||||
},
|
|
||||||
"9.9.12-25765": {
|
|
||||||
"appid": 537234702,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.12_25765_GW_B"
|
|
||||||
},
|
|
||||||
"9.9.12-26299": {
|
|
||||||
"appid": 537234826,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.12_26299_GW_B"
|
|
||||||
},
|
|
||||||
"9.9.12-26339": {
|
|
||||||
"appid": 537234826,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.12_26339_GW_B"
|
|
||||||
},
|
|
||||||
"9.9.12-26466": {
|
|
||||||
"appid": 537234826,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.12_26466_GW_B"
|
|
||||||
},
|
|
||||||
"9.9.15-26702": {
|
|
||||||
"appid": 537237765,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.15_26702_GW_B"
|
|
||||||
},
|
|
||||||
"9.9.15-26740": {
|
|
||||||
"appid": 537237765,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.15_26702_GW_B"
|
|
||||||
},
|
|
||||||
"9.9.15-26909": {
|
|
||||||
"appid": 537237802,
|
|
||||||
"qua": "V1_WIN_NQ_9.9.15_26909_GW_B"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
@@ -1,6 +1,6 @@
|
|||||||
import { Group, GroupListUpdateType, GroupMember, GroupNotify } from '@/core/entities';
|
import { Group, GroupListUpdateType, GroupMember, GroupNotify } from '@/core/entities';
|
||||||
|
|
||||||
interface IGroupListener {
|
export interface IGroupListener {
|
||||||
onGroupListUpdate(updateType: GroupListUpdateType, groupList: Group[]): void;
|
onGroupListUpdate(updateType: GroupListUpdateType, groupList: Group[]): void;
|
||||||
|
|
||||||
onGroupExtListUpdate(...args: unknown[]): void;
|
onGroupExtListUpdate(...args: unknown[]): void;
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
import { NodeIKernelGroupListener } from '@/core/listeners/NodeIKernelGroupListener';
|
import { IGroupListener, NodeIKernelGroupListener } from '@/core/listeners/NodeIKernelGroupListener';
|
||||||
import {
|
import {
|
||||||
GroupExtParam,
|
GroupExtParam,
|
||||||
GroupMember,
|
GroupMember,
|
||||||
@@ -104,7 +104,7 @@ export interface NodeIKernelGroupService {
|
|||||||
|
|
||||||
setHeader(uid: string, path: string): unknown;
|
setHeader(uid: string, path: string): unknown;
|
||||||
|
|
||||||
addKernelGroupListener(listener: NodeIKernelGroupListener): number;
|
addKernelGroupListener(listener: IGroupListener): number;
|
||||||
|
|
||||||
removeKernelGroupListener(listenerId: unknown): void;
|
removeKernelGroupListener(listenerId: unknown): void;
|
||||||
|
|
||||||
|
@@ -1,6 +1,6 @@
|
|||||||
import { AnyCnameRecord } from 'node:dns';
|
import { AnyCnameRecord } from 'node:dns';
|
||||||
import { BizKey, ModifyProfileParams, SimpleInfo, UserDetailInfoByUin } from '../entities';
|
import { BizKey, ModifyProfileParams, SimpleInfo, UserDetailInfoByUin } from '../entities';
|
||||||
import { NodeIKernelProfileListener } from '../listeners';
|
import { NodeIKernelProfileListener, ProfileListener } from '../listeners';
|
||||||
import { GeneralCallResult } from '@/core/services/common';
|
import { GeneralCallResult } from '@/core/services/common';
|
||||||
|
|
||||||
export enum UserDetailSource {
|
export enum UserDetailSource {
|
||||||
@@ -35,7 +35,7 @@ export interface NodeIKernelProfileService {
|
|||||||
|
|
||||||
fetchUserDetailInfo(trace: string, uids: string[], arg2: number, arg3: number[]): Promise<unknown>;
|
fetchUserDetailInfo(trace: string, uids: string[], arg2: number, arg3: number[]): Promise<unknown>;
|
||||||
|
|
||||||
addKernelProfileListener(listener: NodeIKernelProfileListener): number;
|
addKernelProfileListener(listener: ProfileListener): number;
|
||||||
|
|
||||||
removeKernelProfileListener(listenerId: number): void;
|
removeKernelProfileListener(listenerId: number): void;
|
||||||
|
|
||||||
|
@@ -35,6 +35,7 @@ import { NodeIkernelTestPerformanceService } from '../services/NodeIkernelTestPe
|
|||||||
import { NodeIKernelECDHService } from '../services/NodeIKernelECDHService';
|
import { NodeIKernelECDHService } from '../services/NodeIKernelECDHService';
|
||||||
|
|
||||||
export interface NodeQQNTWrapperUtil {
|
export interface NodeQQNTWrapperUtil {
|
||||||
|
get(): unknown;
|
||||||
// eslint-disable-next-line @typescript-eslint/no-misused-new
|
// eslint-disable-next-line @typescript-eslint/no-misused-new
|
||||||
new(): NodeQQNTWrapperUtil;
|
new(): NodeQQNTWrapperUtil;
|
||||||
|
|
||||||
|
@@ -41,8 +41,7 @@ export async function NCoreInitFramework(
|
|||||||
online: true,
|
online: true,
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
|
loginService.addKernelLoginListener(proxiedListenerOf(loginListener, logger) as any);
|
||||||
proxiedListenerOf(loginListener, logger)));
|
|
||||||
});
|
});
|
||||||
// 过早进入会导致addKernelMsgListener等Listener添加失败
|
// 过早进入会导致addKernelMsgListener等Listener添加失败
|
||||||
// await sleep(2500);
|
// await sleep(2500);
|
||||||
|
@@ -79,6 +79,7 @@ import { NapCatOneBot11Adapter } from '@/onebot';
|
|||||||
import GetGuildProfile from './guild/GetGuildProfile';
|
import GetGuildProfile from './guild/GetGuildProfile';
|
||||||
import SetModelShow from './go-cqhttp/SetModelShow';
|
import SetModelShow from './go-cqhttp/SetModelShow';
|
||||||
import { SetInputStatus } from './extends/SetInputStatus';
|
import { SetInputStatus } from './extends/SetInputStatus';
|
||||||
|
import { GetCSRF } from './system/GetCSRF';
|
||||||
|
|
||||||
export type ActionMap = Map<string, BaseAction<any, any>>;
|
export type ActionMap = Map<string, BaseAction<any, any>>;
|
||||||
|
|
||||||
@@ -167,6 +168,7 @@ export function createActionMap(onebotContext: NapCatOneBot11Adapter, coreContex
|
|||||||
new GetGuildProfile(onebotContext, coreContext),
|
new GetGuildProfile(onebotContext, coreContext),
|
||||||
new SetModelShow(onebotContext, coreContext),
|
new SetModelShow(onebotContext, coreContext),
|
||||||
new SetInputStatus(onebotContext, coreContext),
|
new SetInputStatus(onebotContext, coreContext),
|
||||||
|
new GetCSRF(onebotContext, coreContext),
|
||||||
];
|
];
|
||||||
const actionMap = new Map();
|
const actionMap = new Map();
|
||||||
for (const action of actionHandlers) {
|
for (const action of actionHandlers) {
|
||||||
|
@@ -56,7 +56,7 @@ const _handlers: {
|
|||||||
if (atQQ === 'all') return SendMsgElementConstructor.at(coreContext, atQQ, atQQ, AtType.atAll, '全体成员');
|
if (atQQ === 'all') return SendMsgElementConstructor.at(coreContext, atQQ, atQQ, AtType.atAll, '全体成员');
|
||||||
|
|
||||||
// then the qq is a group member
|
// then the qq is a group member
|
||||||
// Mlikiowa V2.0.35 Refactor Todo
|
// Mlikiowa V2.1.0 Refactor Todo
|
||||||
const uid = await coreContext.apis.UserApi.getUidByUinV2(`${atQQ}`);
|
const uid = await coreContext.apis.UserApi.getUidByUinV2(`${atQQ}`);
|
||||||
if (!uid) throw new Error('Get Uid Error');
|
if (!uid) throw new Error('Get Uid Error');
|
||||||
return SendMsgElementConstructor.at(coreContext, atQQ, uid, AtType.atUser, '');
|
return SendMsgElementConstructor.at(coreContext, atQQ, uid, AtType.atUser, '');
|
||||||
@@ -161,7 +161,7 @@ const _handlers: {
|
|||||||
} else {
|
} else {
|
||||||
postData = data;
|
postData = data;
|
||||||
}
|
}
|
||||||
// Mlikiowa V2.0.35 Refactor Todo
|
// Mlikiowa V2.1.0 Refactor Todo
|
||||||
const signUrl = obContext.configLoader.configData.musicSignUrl;
|
const signUrl = obContext.configLoader.configData.musicSignUrl;
|
||||||
if (!signUrl) {
|
if (!signUrl) {
|
||||||
if (data.type === 'qq') {
|
if (data.type === 'qq') {
|
||||||
|
12
src/onebot/action/system/GetCSRF.ts
Normal file
12
src/onebot/action/system/GetCSRF.ts
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
import BaseAction from '../BaseAction';
|
||||||
|
import { ActionName } from '../types';
|
||||||
|
|
||||||
|
export class GetCSRF extends BaseAction<any, any> {
|
||||||
|
actionName = ActionName.GetCSRF;
|
||||||
|
|
||||||
|
async _handle(payload: any) {
|
||||||
|
return {
|
||||||
|
token: "",
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
@@ -107,5 +107,6 @@ export enum ActionName {
|
|||||||
FetchEmojiLike = 'fetch_emoji_like',
|
FetchEmojiLike = 'fetch_emoji_like',
|
||||||
GetGuildProfile = "get_guild_service_profile",
|
GetGuildProfile = "get_guild_service_profile",
|
||||||
SetModelShow = "_set_model_show",
|
SetModelShow = "_set_model_show",
|
||||||
SetInputStatus = "set_input_status"
|
SetInputStatus = "set_input_status",
|
||||||
|
GetCSRF = "get_csrf_token",
|
||||||
}
|
}
|
||||||
|
@@ -275,7 +275,7 @@ export class NapCatOneBot11Adapter {
|
|||||||
};
|
};
|
||||||
|
|
||||||
this.context.session.getMsgService().addKernelMsgListener(
|
this.context.session.getMsgService().addKernelMsgListener(
|
||||||
new this.context.wrapper.NodeIKernelMsgListener(proxiedListenerOf(msgListener, this.context.logger)),
|
proxiedListenerOf(msgListener, this.context.logger) as any
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -302,7 +302,7 @@ export class NapCatOneBot11Adapter {
|
|||||||
};
|
};
|
||||||
|
|
||||||
this.context.session.getBuddyService().addKernelBuddyListener(
|
this.context.session.getBuddyService().addKernelBuddyListener(
|
||||||
new this.context.wrapper.NodeIKernelBuddyListener(proxiedListenerOf(buddyListener, this.context.logger)),
|
proxiedListenerOf(buddyListener, this.context.logger) as any
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -438,7 +438,7 @@ export class NapCatOneBot11Adapter {
|
|||||||
};
|
};
|
||||||
|
|
||||||
this.context.session.getGroupService().addKernelGroupListener(
|
this.context.session.getGroupService().addKernelGroupListener(
|
||||||
new this.context.wrapper.NodeIKernelGroupListener(proxiedListenerOf(groupListener, this.context.logger)),
|
proxiedListenerOf(groupListener, this.context.logger)
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -71,6 +71,8 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
|
|||||||
|
|
||||||
this.connection = new WebSocket(this.url, {
|
this.connection = new WebSocket(this.url, {
|
||||||
maxPayload: 1024 * 1024 * 1024,
|
maxPayload: 1024 * 1024 * 1024,
|
||||||
|
handshakeTimeout: 2000,
|
||||||
|
perMessageDeflate: false,
|
||||||
headers: {
|
headers: {
|
||||||
'X-Self-ID': this.coreContext.selfInfo.uin,
|
'X-Self-ID': this.coreContext.selfInfo.uin,
|
||||||
'Authorization': `Bearer ${this.token}`,
|
'Authorization': `Bearer ${this.token}`,
|
||||||
@@ -134,6 +136,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
|
|||||||
this.logger.logDebug('[OneBot] [WebSocket Client] 收到正向Websocket消息', receiveData);
|
this.logger.logDebug('[OneBot] [WebSocket Client] 收到正向Websocket消息', receiveData);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo));
|
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo));
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
||||||
const retdata = await this.actions.get(receiveData.action)
|
const retdata = await this.actions.get(receiveData.action)
|
||||||
|
@@ -36,7 +36,11 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
|
|||||||
this.logger = coreContext.context.logger;
|
this.logger = coreContext.context.logger;
|
||||||
|
|
||||||
this.heartbeatInterval = heartbeatInterval;
|
this.heartbeatInterval = heartbeatInterval;
|
||||||
this.wsServer = new WebSocketServer({ port: port, host: ip, maxPayload: 1024 * 1024 * 1024, });
|
this.wsServer = new WebSocketServer({
|
||||||
|
port: port,
|
||||||
|
host: ip,
|
||||||
|
maxPayload: 1024 * 1024 * 1024,
|
||||||
|
});
|
||||||
const core = coreContext;
|
const core = coreContext;
|
||||||
this.wsServer.on('connection', async (wsClient, wsReq) => {
|
this.wsServer.on('connection', async (wsClient, wsReq) => {
|
||||||
if (!this.isOpen) {
|
if (!this.isOpen) {
|
||||||
@@ -151,6 +155,7 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
|
|||||||
//this.logger.logDebug('收到正向Websocket消息', receiveData);
|
//this.logger.logDebug('收到正向Websocket消息', receiveData);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo), wsClient);
|
this.checkStateAndReply<any>(OB11Response.error('json解析失败,请检查数据格式', 1400, echo), wsClient);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
receiveData.params = (receiveData?.params) ? receiveData.params : {};//兼容类型验证
|
||||||
const retdata = await this.actions.get(receiveData.action)?.websocketHandle(receiveData.params, echo || '');
|
const retdata = await this.actions.get(receiveData.action)?.websocketHandle(receiveData.params, echo || '');
|
||||||
|
@@ -43,12 +43,12 @@ export async function NCoreInitShell() {
|
|||||||
|
|
||||||
// from constructor
|
// from constructor
|
||||||
const engine = new wrapper.NodeIQQNTWrapperEngine();
|
const engine = new wrapper.NodeIQQNTWrapperEngine();
|
||||||
const util = new wrapper.NodeQQNTWrapperUtil();
|
//const util = wrapper.NodeQQNTWrapperUtil.get();
|
||||||
const loginService = new wrapper.NodeIKernelLoginService();
|
const loginService = new wrapper.NodeIKernelLoginService();
|
||||||
const session = new wrapper.NodeIQQNTWrapperSession();
|
const session = new wrapper.NodeIQQNTWrapperSession();
|
||||||
|
|
||||||
// from get dataPath
|
// from get dataPath
|
||||||
let dataPath = util.getNTUserDataInfoConfig();
|
let dataPath = wrapper.NodeQQNTWrapperUtil.getNTUserDataInfoConfig();
|
||||||
if (!dataPath) {
|
if (!dataPath) {
|
||||||
dataPath = path.resolve(os.homedir(), './.config/QQ');
|
dataPath = path.resolve(os.homedir(), './.config/QQ');
|
||||||
fs.mkdirSync(dataPath, { recursive: true });
|
fs.mkdirSync(dataPath, { recursive: true });
|
||||||
@@ -70,7 +70,7 @@ export async function NCoreInitShell() {
|
|||||||
},
|
},
|
||||||
thumb_config: { maxSide: 324, minSide: 48, longLimit: 6, density: 2 },
|
thumb_config: { maxSide: 324, minSide: 48, longLimit: 6, density: 2 },
|
||||||
},
|
},
|
||||||
new wrapper.NodeIGlobalAdapter(new GlobalAdapter()),
|
new GlobalAdapter() as any,
|
||||||
);
|
);
|
||||||
loginService.initConfig({
|
loginService.initConfig({
|
||||||
machineId: '',
|
machineId: '',
|
||||||
@@ -140,8 +140,7 @@ export async function NCoreInitShell() {
|
|||||||
logger.logError('[Core] [Login] Login Error , ErrInfo: ', args);
|
logger.logError('[Core] [Login] Login Error , ErrInfo: ', args);
|
||||||
};
|
};
|
||||||
|
|
||||||
loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
|
loginService.addKernelLoginListener(proxiedListenerOf(loginListener, logger) as any);
|
||||||
proxiedListenerOf(loginListener, logger)));
|
|
||||||
|
|
||||||
// 实现WebUi快速登录
|
// 实现WebUi快速登录
|
||||||
loginService.getLoginList().then((res) => {
|
loginService.getLoginList().then((res) => {
|
||||||
@@ -188,11 +187,10 @@ export async function NCoreInitShell() {
|
|||||||
} else {
|
} else {
|
||||||
logger.log('没有 -q 指令指定快速登录,将使用二维码登录方式');
|
logger.log('没有 -q 指令指定快速登录,将使用二维码登录方式');
|
||||||
if (historyLoginList.length > 0) {
|
if (historyLoginList.length > 0) {
|
||||||
logger.log(`可用于快速登录的 QQ:\n${
|
logger.log(`可用于快速登录的 QQ:\n${historyLoginList
|
||||||
historyLoginList
|
.map((u, index) => `${index + 1}. ${u.uin} ${u.nickName}`)
|
||||||
.map((u, index) => `${index + 1}. ${u.uin} ${u.nickName}`)
|
.join('\n')
|
||||||
.join('\n')
|
}`);
|
||||||
}`);
|
|
||||||
}
|
}
|
||||||
loginService.getQRCodePicture();
|
loginService.getQRCodePicture();
|
||||||
}
|
}
|
||||||
@@ -220,9 +218,9 @@ export async function NCoreInitShell() {
|
|||||||
};
|
};
|
||||||
session.init(
|
session.init(
|
||||||
sessionConfig,
|
sessionConfig,
|
||||||
new wrapper.NodeIDependsAdapter(new DependsAdapter()),
|
new DependsAdapter() as any,
|
||||||
new wrapper.NodeIDispatcherAdapter(new DispatcherAdapter()),
|
new DispatcherAdapter() as any,
|
||||||
new wrapper.NodeIKernelSessionListener(sessionListener),
|
sessionListener as any,
|
||||||
);
|
);
|
||||||
try {
|
try {
|
||||||
session.startNT(0);
|
session.startNT(0);
|
||||||
|
@@ -30,7 +30,7 @@ async function onSettingWindowCreated(view: Element) {
|
|||||||
SettingItem(
|
SettingItem(
|
||||||
'<span id="napcat-update-title">Napcat</span>',
|
'<span id="napcat-update-title">Napcat</span>',
|
||||||
undefined,
|
undefined,
|
||||||
SettingButton('V2.0.35', 'napcat-update-button', 'secondary'),
|
SettingButton('V2.1.0', 'napcat-update-button', 'secondary'),
|
||||||
),
|
),
|
||||||
]),
|
]),
|
||||||
SettingList([
|
SettingList([
|
||||||
|
@@ -164,7 +164,7 @@ async function onSettingWindowCreated(view) {
|
|||||||
SettingItem(
|
SettingItem(
|
||||||
'<span id="napcat-update-title">Napcat</span>',
|
'<span id="napcat-update-title">Napcat</span>',
|
||||||
void 0,
|
void 0,
|
||||||
SettingButton("V2.0.35", "napcat-update-button", "secondary")
|
SettingButton("V2.1.0", "napcat-update-button", "secondary")
|
||||||
)
|
)
|
||||||
]),
|
]),
|
||||||
SettingList([
|
SettingList([
|
||||||
|
Reference in New Issue
Block a user