QQ/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2024-11-16 04:45:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: shell

Browse Source
This commit is contained in:
Wesley F. Young 2024-08-08 22:10:42 +08:00
parent 004a65d933
commit 80c5259b05
1 changed files with 72 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

103
src/shell/napcat.ts
View File

@ -1,38 +1,42 @@
import type { WrapperNodeApi, NodeIQQNTWrapperEngine, NodeQQNTWrapperUtil, NodeIQQNTWrapperSession } from "@/core/wrapper/wrapper"; import type { SelfInfo } from '@/core/entities';
import type { NodeIKernelLoginService } from "@/core/services";
import type { NapCatCore } from "@/core";
import type { SelfInfo } from "@/core/entities";
import { LogWrapper } from "@/common/utils/log";
import { LoginListener, SessionListener } from "@/core/listeners";
import { DependsAdapter, DispatcherAdapter, GlobalAdapter } from "@/core/adapters";
import { NapCatPathWrapper } from "@/common/framework/napcat";
import { NapCatCoreWorkingEnv, loadQQWrapper } from "@/core";
import { QQBasicInfoWrapper } from "@/common/utils/QQBasicInfo";
import { hostname, systemVersion } from "@/common/utils/system";
import { genSessionConfig } from "@/core/wrapper/helper";
import { proxiedListenerOf } from "@/common/utils/proxy-handler";
import path from "path";
import fs from "fs";
import os from "os";
import { LogWrapper } from '@/common/utils/log';
import { LoginListener, SessionListener } from '@/core/listeners';
import { DependsAdapter, DispatcherAdapter, GlobalAdapter } from '@/core/adapters';
import { NapCatPathWrapper } from '@/common/framework/napcat';
import {
NapCatCoreWorkingEnv,
loadQQWrapper,
NapCatCore,
InstanceContext,
WrapperNodeApi,
NodeIQQNTWrapperSession
} from '@/core';
import { QQBasicInfoWrapper } from '@/common/utils/QQBasicInfo';
import { hostname, systemVersion } from '@/common/utils/system';
import { genSessionConfig } from '@/core/wrapper/helper';
import { proxiedListenerOf } from '@/common/utils/proxy-handler';
import path from 'path';
import fs from 'fs';
import os from 'os';
import { NodeIKernelLoginService } from '@/core/services';
import { NapCatOneBot11Adapter } from '@/onebot';
// NapCat Shell App ES 入口文件 // NapCat Shell App ES 入口文件
export async function NCoreInitShell() { export async function NCoreInitShell() {
console.log("NapCat Shell App Loading..."); console.log('NapCat Shell App Loading...');
let pathWrapper = new NapCatPathWrapper(); const pathWrapper = new NapCatPathWrapper();
let logger = new LogWrapper(pathWrapper.logsPath); const logger = new LogWrapper(pathWrapper.logsPath);
let basicInfoWrapper = new QQBasicInfoWrapper({ logger }); const basicInfoWrapper = new QQBasicInfoWrapper({ logger });
let wrapper = loadQQWrapper(basicInfoWrapper.getFullQQVesion()); const wrapper = loadQQWrapper(basicInfoWrapper.getFullQQVesion());
// from constructor // from constructor
let engine = new wrapper.NodeIQQNTWrapperEngine(); const engine = new wrapper.NodeIQQNTWrapperEngine();
let util = new wrapper.NodeQQNTWrapperUtil(); const util = new wrapper.NodeQQNTWrapperUtil();
let loginService = new wrapper.NodeIKernelLoginService(); const loginService = new wrapper.NodeIKernelLoginService();
let session = new wrapper.NodeIQQNTWrapperSession(); const session = new wrapper.NodeIQQNTWrapperSession();
// from get dataPath // from get dataPath
let dataPath = util.getNTUserDataInfoConfig(); let dataPath = util.getNTUserDataInfoConfig();
@ -40,7 +44,7 @@ export async function NCoreInitShell() {
dataPath = path.resolve(os.homedir(), './.config/QQ'); dataPath = path.resolve(os.homedir(), './.config/QQ');
fs.mkdirSync(dataPath, { recursive: true }); fs.mkdirSync(dataPath, { recursive: true });
} }
let dataPathGlobal = path.resolve(dataPath, './nt_qq/global'); const dataPathGlobal = path.resolve(dataPath, './nt_qq/global');
// from initConfig // from initConfig
engine.initWithDeskTopConfig( engine.initWithDeskTopConfig(
@ -68,12 +72,14 @@ export async function NCoreInitShell() {
hostName: hostname hostName: hostname
}); });
let selfInfo = await new Promise<SelfInfo>((resolve) => { console.log(wrapper);
let loginListener = new LoginListener();
const selfInfo = await new Promise<SelfInfo>((resolve) => {
const loginListener = new LoginListener();
// from constructor // from constructor
loginListener.onUserLoggedIn = (userid: string) => { loginListener.onUserLoggedIn = (userid: string) => {
logger.logError('当前账号(' + userid + ')已登录,无法重复登录'); logger.logError(`当前账号(${userid})已登录,无法重复登录`);
}; };
loginListener.onQRCodeLoginSucceed = async (loginResult) => resolve({ loginListener.onQRCodeLoginSucceed = async (loginResult) => resolve({
@ -116,7 +122,42 @@ export async function NCoreInitShell() {
const accountDataPath = path.resolve(dataPath, './NapCat/data'); const accountDataPath = path.resolve(dataPath, './NapCat/data');
fs.mkdirSync(dataPath, { recursive: true }); fs.mkdirSync(dataPath, { recursive: true });
logger.logDebug('本账号数据/缓存目录：', accountDataPath); logger.logDebug('本账号数据/缓存目录：', accountDataPath);
new NapCatShell(
wrapper,
session,
logger,
loginService,
selfInfo,
basicInfoWrapper
);
} }
export class NapCatShell { export class NapCatShell {
readonly core: NapCatCore;
readonly context: InstanceContext;
constructor(
wrapper: WrapperNodeApi,
session: NodeIQQNTWrapperSession,
logger: LogWrapper,
loginService: NodeIKernelLoginService,
selfInfo: SelfInfo,
basicInfoWrapper: QQBasicInfoWrapper,
) {
this.context = {
workingEnv: NapCatCoreWorkingEnv.Shell,
wrapper,
session,
logger,
loginService,
selfInfo,
basicInfoWrapper
};
this.core = new NapCatCore(this.context);
new NapCatOneBot11Adapter(this.core, this.context);
}
} }
NCoreInitShell();