feat: get config

This commit is contained in:
手瓜一十雪
2024-05-08 15:42:22 +08:00
parent 790c4f589d
commit 6f5a6f353f
6 changed files with 36 additions and 27 deletions

View File

@@ -42,9 +42,10 @@ checkVersion().then((remoteVersion: string) => {
logError('[NapCat] 检测更新失败');
});
new NapCatOnebot11();
napCatCore.onLoginSuccess(() => {
napCatCore.onLoginSuccess((uin, uid) => {
console.log('登录成功!');
DataRuntime.setQQLoginStatus(true);
DataRuntime.setQQLoginUin(uin.toString());
postLoginStatus();
});
const showQRCode = async (qrCodeData: { url: string, base64: string, buffer: Buffer }) => {

View File

@@ -1,12 +1,12 @@
import { RequestHandler } from "express";
import { DataRuntime } from "../helper/Data";
import { existsSync } from "node:fs";
import { existsSync, readFileSync, writeFileSync } from "node:fs";
import { resolve } from "node:path";
import { OB11Config } from "@/webui/ui/components/WebApi";
const isEmpty = (data: any) => data === undefined || data === null || data === '';
export const OB11GetConfigHandler: RequestHandler = async (req, res) => {
let isLogin = await DataRuntime.getQQLoginStatus();
if(!isLogin){
if (!isLogin) {
res.send({
code: -1,
message: 'Not Login'
@@ -15,15 +15,16 @@ export const OB11GetConfigHandler: RequestHandler = async (req, res) => {
}
const uin = await DataRuntime.getQQLoginUin();
let configFilePath = resolve(__dirname, `./config/onebot_${uin}.json`);
console.log(configFilePath);
let data: OB11Config;
try {
data = existsSync(configFilePath) ? require(configFilePath) : require(resolve(__dirname, `./config/onebot.json`));
data = JSON.parse(existsSync(configFilePath) ? readFileSync(configFilePath).toString() : readFileSync(resolve(__dirname, `./config/onebot.json`)).toString());
}
catch (e) {
data = {} as OB11Config;
res.send({
code: -1,
message: 'QRCode Get Error'
message: 'Config Get Error'
});
return;
}
@@ -36,31 +37,31 @@ export const OB11GetConfigHandler: RequestHandler = async (req, res) => {
}
export const OB11SetConfigHandler: RequestHandler = async (req, res) => {
let isLogin = await DataRuntime.getQQLoginStatus();
if(!isLogin){
if (!isLogin) {
res.send({
code: -1,
message: 'Not Login'
});
return;
}
if(isEmpty(req.body.config)){
if (isEmpty(req.body.config)) {
res.send({
code: -1,
message: 'config is empty'
});
return;
}
let configFilePath = resolve(__dirname, `./config/onebot_${await DataRuntime.getQQLoginUin()}.json`);
try {
require(configFilePath);
}
catch (e) {
configFilePath = resolve(__dirname, `./config/onebot.json`);
}
require('fs').writeFileSync(configFilePath, JSON.stringify(req.body.config, null, 4));
res.send({
code: 0,
message: 'success'
});
return;
}
let configFilePath = resolve(__dirname, `./config/onebot_${await DataRuntime.getQQLoginUin()}.json`);
try {
require(configFilePath);
}
catch (e) {
configFilePath = resolve(__dirname, `./config/onebot.json`);
}
writeFileSync(configFilePath, JSON.stringify(req.body.config, null, 4));
res.send({
code: 0,
message: 'success'
});
return;
}

View File

@@ -3,7 +3,7 @@ interface LoginRuntimeType {
LoginCurrentRate: number;
QQLoginStatus: boolean;
QQQRCodeURL: string;
QQLoginUin: number;
QQLoginUin: string;
NapCatHelper: {
CoreQuickLogin: (uin: string) => Promise<{ result: boolean, message: string }>;
QQLoginList: string[]
@@ -14,7 +14,7 @@ let LoginRuntime: LoginRuntimeType = {
LoginCurrentRate: 0,
QQLoginStatus: false, //已实现 但太傻了 得去那边注册个回调刷新
QQQRCodeURL: "",
QQLoginUin: 0,
QQLoginUin: "",
NapCatHelper: {
CoreQuickLogin: async (uin: string) => { return { result: false, message: '' }; },
QQLoginList: []
@@ -51,11 +51,11 @@ export const DataRuntime = {
return LoginRuntime.QQQRCodeURL;
}
,
setQQLoginUin: async function (uin: number): Promise<void> {
setQQLoginUin: async function (uin: string): Promise<void> {
LoginRuntime.QQLoginUin = uin;
}
,
getQQLoginUin: async function (): Promise<number> {
getQQLoginUin: async function (): Promise<string> {
return LoginRuntime.QQLoginUin;
},
getQQQuickLoginList: async function (): Promise<any[]> {

View File

@@ -0,0 +1,6 @@
import { Router } from 'express';
import { OB11GetConfigHandler,OB11SetConfigHandler} from '../api/OB11Config';
const router = Router();
router.post('/GetConfig', OB11GetConfigHandler)
router.post('/SetConfig', OB11SetConfigHandler);
export { router as OB11ConfigRouter };

View File

@@ -1,6 +1,5 @@
import { Router } from 'express';
import { QQCheckLoginStatusHandler, QQGetQRcodeHandler, QQGetQuickLoginListHandler } from '../api/QQLogin';
const router = Router();
router.all('/GetQuickLoginList', QQGetQuickLoginListHandler)
router.post('/CheckLoginStatus', QQCheckLoginStatusHandler);

View File

@@ -3,6 +3,7 @@ import { AuthHelper } from '../../src/helper/SignToken';
import { NextFunction, Request, Response } from 'express';
import { QQLoginRouter } from "./QQLogin";
import { AuthRouter } from "./auth";
import { OB11ConfigRouter } from "./OB11Config";
const router = Router();
export async function AuthApi(req: Request, res: Response, next: NextFunction) {
//判断当前url是否为/api/login 如果是跳过鉴权
@@ -45,6 +46,7 @@ router.all("/test", (req, res) => {
msg: 'ok',
});
});
router.use('/auth', AuthRouter);//挂载权限路由
router.use('/auth', AuthRouter);
router.use('/QQLogin',QQLoginRouter);
router.use('/OB11Config',OB11ConfigRouter);
export { router as ALLRouter }