mirror of
https://github.com/NapNeko/NapCatQQ.git
synced 2026-02-06 13:05:09 +00:00
chore: build
Co-Authored-By: Wesley F. Young <25684570+Wesley-Young@users.noreply.github.com>
This commit is contained in:
手瓜一十雪
@@ -28,119 +28,95 @@ export async function NCoreInitShell() {
|
||||
let basicInfoWrapper = new QQBasicInfoWrapper({ logger });
|
||||
let wrapper = loadQQWrapper(basicInfoWrapper.getFullQQVesion());
|
||||
|
||||
// from constructor
|
||||
let engine = new wrapper.NodeIQQNTWrapperEngine();
|
||||
let util = new wrapper.NodeQQNTWrapperUtil();
|
||||
let loginService = new wrapper.NodeIKernelLoginService();
|
||||
let session = new wrapper.NodeIQQNTWrapperSession();
|
||||
|
||||
// from get dataPath
|
||||
let dataPath = util.getNTUserDataInfoConfig();
|
||||
if (!dataPath) {
|
||||
dataPath = path.resolve(os.homedir(), './.config/QQ');
|
||||
fs.mkdirSync(dataPath, { recursive: true });
|
||||
}
|
||||
let dataPathGlobal = path.resolve(dataPath, './nt_qq/global');
|
||||
|
||||
// from initConfig
|
||||
engine.initWithDeskTopConfig(
|
||||
{
|
||||
base_path_prefix: '',
|
||||
platform_type: 3,
|
||||
app_type: 4,
|
||||
app_version: basicInfoWrapper.getFullQQVesion(),
|
||||
os_version: 'Windows 10 Pro',
|
||||
use_xlog: true,
|
||||
qua: basicInfoWrapper.QQVersionQua!,
|
||||
global_path_config: {
|
||||
desktopGlobalPath: dataPathGlobal,
|
||||
},
|
||||
thumb_config: { maxSide: 324, minSide: 48, longLimit: 6, density: 2 }
|
||||
},
|
||||
new wrapper.NodeIGlobalAdapter(new GlobalAdapter())
|
||||
);
|
||||
loginService.initConfig({
|
||||
machineId: '',
|
||||
appid: basicInfoWrapper.QQVersionAppid!,
|
||||
platVer: systemVersion,
|
||||
commonPath: dataPathGlobal,
|
||||
clientVer: basicInfoWrapper.getFullQQVesion(),
|
||||
hostName: hostname
|
||||
});
|
||||
|
||||
let selfInfo = await new Promise<SelfInfo>((resolve) => {
|
||||
let loginListener = new LoginListener();
|
||||
|
||||
// from constructor
|
||||
loginListener.onUserLoggedIn = (userid: string) => {
|
||||
logger.logError('当前账号(' + userid + ')已登录,无法重复登录');
|
||||
};
|
||||
|
||||
loginListener.onQRCodeLoginSucceed = async (loginResult) => resolve({
|
||||
uid: loginResult.uid,
|
||||
uin: loginResult.uin,
|
||||
nick: '', // 获取不到
|
||||
online: true
|
||||
});
|
||||
loginService.addKernelLoginListener();
|
||||
loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
|
||||
proxiedListenerOf(loginListener, logger)));
|
||||
});
|
||||
|
||||
let ShellNapCat = new NapCatShell(logger, BasicInfo);
|
||||
ShellNapCat.loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
|
||||
proxiedListenerOf(loginListener, logger)));
|
||||
})
|
||||
// from initSession
|
||||
const sessionConfig = await genSessionConfig(
|
||||
basicInfoWrapper.QQVersionAppid!,
|
||||
basicInfoWrapper.getFullQQVesion(),
|
||||
selfInfo.uin,
|
||||
selfInfo.uid,
|
||||
dataPath
|
||||
);
|
||||
const sessionListener = new SessionListener();
|
||||
sessionListener.onSessionInitComplete = (r: unknown) => {
|
||||
if (r !== 0) {
|
||||
throw r;
|
||||
}
|
||||
};
|
||||
session.init(
|
||||
sessionConfig,
|
||||
new wrapper.NodeIDependsAdapter(new DependsAdapter()),
|
||||
new wrapper.NodeIDispatcherAdapter(new DispatcherAdapter()),
|
||||
new wrapper.NodeIKernelSessionListener(sessionListener)
|
||||
);
|
||||
try {
|
||||
session.startNT(0);
|
||||
} catch (__) {
|
||||
session.startNT(); // may still throw error; we do not catch that
|
||||
}
|
||||
// Initialization end!
|
||||
|
||||
const accountDataPath = path.resolve(dataPath, './NapCat/data');
|
||||
fs.mkdirSync(dataPath, { recursive: true });
|
||||
logger.logDebug('本账号数据/缓存目录：', accountDataPath);
|
||||
}
|
||||
|
||||
export class NapCatShell {
|
||||
public QQWrapper: WrapperNodeApi;
|
||||
public WorkMode: NapCatCoreWorkingEnv = NapCatCoreWorkingEnv.Shell;
|
||||
public Core: NapCatCore | undefined;
|
||||
public engine: NodeIQQNTWrapperEngine;
|
||||
public util: NodeQQNTWrapperUtil;
|
||||
loginService: NodeIKernelLoginService;
|
||||
session: NodeIQQNTWrapperSession;
|
||||
loginListener: LoginListener;
|
||||
|
||||
get dataPath(): string {
|
||||
let result = this.util.getNTUserDataInfoConfig();
|
||||
if (!result) {
|
||||
result = path.resolve(os.homedir(), './.config/QQ');
|
||||
fs.mkdirSync(result, { recursive: true });
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
get dataPathGlobal(): string {
|
||||
return path.resolve(this.dataPath, './nt_qq/global');
|
||||
}
|
||||
|
||||
private initSession(BasicInfo: QQBasicInfoWrapper, uin: string, uid: string): Promise<number> {
|
||||
return new Promise(async (res, rej) => {
|
||||
if (!BasicInfo.QQVersionAppid) throw new Error("QQVersionAppid must be provided");
|
||||
const sessionConfig = await genSessionConfig(BasicInfo.QQVersionAppid, BasicInfo.getFullQQVesion(), uin, uid, this.dataPath);
|
||||
const sessionListener = new SessionListener();
|
||||
sessionListener.onSessionInitComplete = (r: unknown) => {
|
||||
if ((r as number) === 0) {
|
||||
return res(0);
|
||||
}
|
||||
rej(r);
|
||||
};
|
||||
this.session.init(sessionConfig,
|
||||
new this.QQWrapper.NodeIDependsAdapter(new DependsAdapter()),
|
||||
new this.QQWrapper.NodeIDispatcherAdapter(new DispatcherAdapter()),
|
||||
new this.QQWrapper.NodeIKernelSessionListener(sessionListener)
|
||||
);
|
||||
try {
|
||||
this.session.startNT(0);
|
||||
} catch (__) { /* Empty */
|
||||
try {
|
||||
this.session.startNT();
|
||||
} catch (e) {
|
||||
rej('init failed ' + e);
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
constructor(logger: LogWrapper, QQBasic: QQBasicInfoWrapper) {
|
||||
this.QQWrapper = loadQQWrapper(QQBasic.getFullQQVesion());
|
||||
this.engine = new this.QQWrapper.NodeIQQNTWrapperEngine();
|
||||
this.util = new this.QQWrapper.NodeQQNTWrapperUtil();
|
||||
this.loginService = new this.QQWrapper.NodeIKernelLoginService();
|
||||
this.session = new this.QQWrapper.NodeIQQNTWrapperSession();
|
||||
this.loginListener = new LoginListener();
|
||||
this.loginListener.onUserLoggedIn = (userid: string) => {
|
||||
logger.logError('当前账号(' + userid + ')已登录,无法重复登录');
|
||||
};
|
||||
this.initConfig(QQBasic.getFullQQVesion(), QQBasic.QQVersionAppid, QQBasic.QQVersionQua);
|
||||
this.loginListener.onQRCodeLoginSucceed = (arg) => {
|
||||
this.initSession(QQBasic, arg.uin, arg.uid).then((r) => {
|
||||
selfInfo.uin = arg.uin;
|
||||
selfInfo.uid = arg.uid;
|
||||
const dataPath = path.resolve(this.dataPath, './NapCat/data');
|
||||
fs.mkdirSync(dataPath, { recursive: true });
|
||||
logger.logDebug('本账号数据/缓存目录：', dataPath);
|
||||
//this.initDataListener();
|
||||
}).catch((e) => {
|
||||
logger.logError('initSession failed', e);
|
||||
throw new Error(`启动失败: ${JSON.stringify(e)}`);
|
||||
});
|
||||
};
|
||||
}
|
||||
initConfig(QQVersion: string | undefined, QQVersionAppid: string | undefined, QQVersionQua: string | undefined) {
|
||||
if (!QQVersion || !QQVersionAppid || !QQVersionQua) throw new Error('QQVersion, QQVersionAppid, QQVersionQua must be provided');
|
||||
this.engine.initWithDeskTopConfig({
|
||||
base_path_prefix: '',
|
||||
platform_type: 3,
|
||||
app_type: 4,
|
||||
app_version: QQVersion,
|
||||
os_version: 'Windows 10 Pro',
|
||||
use_xlog: true,
|
||||
qua: QQVersionQua,
|
||||
global_path_config: {
|
||||
desktopGlobalPath: this.dataPathGlobal,
|
||||
},
|
||||
thumb_config: { maxSide: 324, minSide: 48, longLimit: 6, density: 2 }
|
||||
}, new this.QQWrapper.NodeIGlobalAdapter(new GlobalAdapter()));
|
||||
this.loginService.initConfig({
|
||||
machineId: '',
|
||||
appid: QQVersionAppid,
|
||||
platVer: systemVersion,
|
||||
commonPath: this.dataPathGlobal,
|
||||
clientVer: QQVersion,
|
||||
hostName: hostname
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user