chore: old webui

Co-Authored-By: Wesley F. Young <25684570+Wesley-Young@users.noreply.github.com>

src/core/core.ts

@@ -1,9 +1,8 @@
-import { LogWrapper } from "@/common/utils/log";
-import { NodeIQQNTWrapperSession, WrapperNodeApi } from "./wrapper/wrapper";
+import { WrapperNodeApi } from "./wrapper/wrapper";
 import path from "node:path";
 import fs from "node:fs";
-import { NodeIKernelLoginService } from "./services";
-import { SelfInfo } from "./entities";
+import { InstanceContext } from "./wrapper";
+import { NTEventChannel } from "@/common/framework/event";
 
 export enum NapCatCoreWorkingEnv {
     Unknown = 0,
@@ -21,22 +20,13 @@ export function loadQQWrapper(QQVersion: string): WrapperNodeApi {
     return nativemodule.exports;
 }
 
-export interface InstanceContext {
-    readonly workingEnv: NapCatCoreWorkingEnv;
-    readonly core: NapCatCore;
-    readonly wrapper: WrapperNodeApi;
-    readonly session: NodeIQQNTWrapperSession;
-    readonly logger: LogWrapper;
-    readonly loginService: NodeIKernelLoginService;
-    readonly selfInfo: SelfInfo;
-    readonly QQVersion: string;
-}
-
 export class NapCatCore {
     readonly context: InstanceContext;
+    readonly eventChannel: NTEventChannel;
 
     constructor(context: InstanceContext) {
         this.context = context;
+        this.eventChannel = new NTEventChannel(context.wrapper, context.session);
     }
 
     // Renamed from 'InitDataListener'

src/core/index.ts

@@ -1 +1,2 @@
-export * from './core';
+export * from './core';
+export * from './wrapper'

src/core/wrapper/context.ts

@@ -0,0 +1,16 @@
+import { LogWrapper } from "@/common/utils/log";
+import { QQBasicInfoWrapper } from "@/common/utils/QQBasicInfo";
+import { NapCatCoreWorkingEnv } from "../core";
+import { SelfInfo } from "../entities";
+import { NodeIKernelLoginService } from "../services";
+import { WrapperNodeApi, NodeIQQNTWrapperSession } from "./wrapper";
+
+export interface InstanceContext {
+    readonly workingEnv: NapCatCoreWorkingEnv;
+    readonly wrapper: WrapperNodeApi;
+    readonly session: NodeIQQNTWrapperSession;
+    readonly logger: LogWrapper;
+    readonly loginService: NodeIKernelLoginService;
+    readonly selfInfo: SelfInfo;
+    readonly basicInfoWrapper: QQBasicInfoWrapper;
+}

src/core/wrapper/index.ts

@@ -0,0 +1,4 @@
+export * from './wrapper';
+export * from './data';
+export * from './helper';
+export * from './context';

src/liteloader/napcat.ts

@@ -1,14 +1,13 @@
 import { NTEventChannel } from "@/common/framework/event";
 import { NapCatPathWrapper } from "@/common/framework/napcat";
-import { sleep } from "@/common/utils/helper";
 import { LogWrapper } from "@/common/utils/log";
 import { proxiedListenerOf } from "@/common/utils/proxy-handler";
 import { QQBasicInfoWrapper } from "@/common/utils/QQBasicInfo";
-import { NapCatCoreWorkingEnv, loadQQWrapper } from "@/core/core";
+import { NapCatCore, NapCatCoreWorkingEnv, loadQQWrapper } from "@/core/core";
+import { InstanceContext } from "@/core";
 import { SelfInfo } from "@/core/entities";
 import { LoginListener } from "@/core/listeners";
 import { NodeIKernelLoginService } from "@/core/services";
-import { selfInfo } from "@/core/wrapper/data";
 import { WrapperNodeApi, NodeIQQNTWrapperSession } from "@/core/wrapper/wrapper";
 import { NapCatOneBot11Adapter } from "@/onebot";
 
@@ -16,59 +15,53 @@ import { NapCatOneBot11Adapter } from "@/onebot";
 export async function NCoreInitLiteLoader(session: NodeIQQNTWrapperSession, loginService: NodeIKernelLoginService) {
     //在进入本层前是否登录未进行判断
     console.log("NapCat LiteLoader App Loading...");
-    let Basicframework = new NapCatPathWrapper();
-    let logger = new LogWrapper(Basicframework.logsPath);
-    let BasicInfo = new QQBasicInfoWrapper({ logger });
-    let LLNC = new NapCatLiteLoader(logger, session, loginService, BasicInfo);
-    
+    let pathWrapper = new NapCatPathWrapper();
+    let logger = new LogWrapper(pathWrapper.logsPath);
+    let basicInfoWrapper = new QQBasicInfoWrapper({ logger });
+    let wrapper = loadQQWrapper(basicInfoWrapper.getFullQQVesion());
     //直到登录成功后，执行下一步
     let selfInfo = await new Promise<SelfInfo>((resolve) => {
-        let OBLoginListener = new LoginListener();
-        OBLoginListener.onQRCodeLoginSucceed = async (loginResult) => resolve({
+        let loginListener = new LoginListener();
+        loginListener.onQRCodeLoginSucceed = async (loginResult) => resolve({
             uid: loginResult.uid,
             uin: loginResult.uin,
             nick: '', // 获取不到
             online: true
         });
-        loginService.addKernelLoginListener(new LLNC.wrapper.NodeIKernelLoginListener(proxiedListenerOf(OBLoginListener, logger)));
+        loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
+            proxiedListenerOf(loginListener, logger)));
     });
+
+    // 初始化 NapCatLiteLoader
+    let loaderObject = new NapCatLiteLoader(wrapper, session, logger, loginService, selfInfo, basicInfoWrapper);
+
     //启动WebUi
 
     //初始化LLNC的Onebot实现
-    new NapCatOneBot11Adapter();
-    
+    new NapCatOneBot11Adapter(loaderObject.core, loaderObject.context);
 }
 
 export class NapCatLiteLoader {
-    public workingEnv: NapCatCoreWorkingEnv = NapCatCoreWorkingEnv.LiteLoader;
-    public wrapper: WrapperNodeApi;
-    public EventChannel: NTEventChannel;
-    public session: NodeIQQNTWrapperSession;
-    public logger: LogWrapper;
-    public loginListener: LoginListener;
-    //public core: NapCatCore;
+    public core: NapCatCore;
+    context: InstanceContext;
+    
     constructor(
-        logger: LogWrapper,
+        wrapper: WrapperNodeApi,
         session: NodeIQQNTWrapperSession,
+        logger: LogWrapper,
         loginService: NodeIKernelLoginService,
-        QQBasic: QQBasicInfoWrapper
+        selfInfo: SelfInfo,
+        basicInfoWrapper: QQBasicInfoWrapper,
     ) {
-        this.session = session;
-        this.logger = logger;
-        //context保存
-        this.wrapper = loadQQWrapper(QQBasic.getFullQQVesion());
-        //载入Wrapper.node
-        this.EventChannel = new NTEventChannel(this.wrapper, session);
-        this.loginListener = new LoginListener();
-        this.loginListener.onQRCodeLoginSucceed = async (arg) => {
-            await sleep(2500); // TODO: 等待登录完成 init那堆不知道多久完成 搞清楚之前先用个sleep 2500顶着
-            selfInfo.uin = arg.uin;
-            selfInfo.uid = arg.uid;
-            // 保存基础登录信息
-            // 初始化DataListener
+       this.context = {
+            workingEnv: NapCatCoreWorkingEnv.LiteLoader,
+            wrapper,
+            session,
+            logger,
+            loginService,
+            selfInfo,
+            basicInfoWrapper
         };
-        loginService.addKernelLoginListener(new this.wrapper.NodeIKernelLoginListener(
-            proxiedListenerOf(this.loginListener, logger)
-        ));
+        this.core = new NapCatCore(this.context);
     }
 }

src/onebot/index.ts

@@ -1,4 +1,12 @@
+import { InstanceContext, NapCatCore } from "@/core";
+
 //OneBot实现类
 export class NapCatOneBot11Adapter{
-    
+    readonly core: NapCatCore;
+    readonly context: InstanceContext;
+
+    constructor(core: NapCatCore, context: InstanceContext) {
+        this.core = core;
+        this.context = context;
+    }
 }

src/shell/napcat.ts

@@ -1,26 +1,49 @@
-import { NapCatPathWrapper } from "@/common/framework/napcat";
+import type { WrapperNodeApi, NodeIQQNTWrapperEngine, NodeQQNTWrapperUtil, NodeIQQNTWrapperSession } from "@/core/wrapper/wrapper";
+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 { DependsAdapter, DispatcherAdapter, GlobalAdapter } from "@/core/adapters";
-import { NapCatCoreWorkingEnv, NapCatCore, loadQQWrapper } from "@/core/core";
-import { LoginListener, SessionListener } from "@/core/listeners";
-import { NodeIKernelLoginService } from "@/core/services";
-import { WrapperNodeApi, NodeIQQNTWrapperEngine, NodeQQNTWrapperUtil, NodeIQQNTWrapperSession } from "@/core/wrapper/wrapper";
+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 { genSessionConfig } from "@/core/wrapper/helper";
-import { selfInfo } from "@/core/wrapper/data";
+
+
 
 // NapCat Shell App ES 入口文件
 export async function NCoreInitShell() {
     console.log("NapCat Shell App Loading...");
-    let Basicframework = new NapCatPathWrapper();
-    let logger = new LogWrapper(Basicframework.logsPath);
-    let BasicInfo = new QQBasicInfoWrapper({ logger });
-    new NapCatShell(logger, BasicInfo);
+
+    let pathWrapper = new NapCatPathWrapper();
+    let logger = new LogWrapper(pathWrapper.logsPath);
+    let basicInfoWrapper = new QQBasicInfoWrapper({ logger });
+    let wrapper = loadQQWrapper(basicInfoWrapper.getFullQQVesion());
+
+    let selfInfo = await new Promise<SelfInfo>((resolve) => {
+        let loginListener = new LoginListener();
+        loginListener.onQRCodeLoginSucceed = async (loginResult) => resolve({
+            uid: loginResult.uid,
+            uin: loginResult.uin,
+            nick: '', // 获取不到
+            online: true
+        });
+        loginService.addKernelLoginListener();
+
+    let ShellNapCat = new NapCatShell(logger, BasicInfo);
+    ShellNapCat.loginService.addKernelLoginListener(new wrapper.NodeIKernelLoginListener(
+        proxiedListenerOf(loginListener, logger)));
+})
 }
+
 export class NapCatShell {
     public QQWrapper: WrapperNodeApi;
     public WorkMode: NapCatCoreWorkingEnv = NapCatCoreWorkingEnv.Shell;
@@ -43,6 +66,7 @@ export class NapCatShell {
     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");
@@ -54,11 +78,6 @@ export class NapCatShell {
                 }
                 rej(r);
             };
-            // const oldOnSendOidbRepl = this.session.onSendOidbRepl;
-            // this.session.onSendOidbRepl = (...args: unknown[]) => {
-            //   console.log('onSendOidbRepl', args);
-            //   return oldOnSendOidbRepl(...args);
-            // };
             this.session.init(sessionConfig,
                 new this.QQWrapper.NodeIDependsAdapter(new DependsAdapter()),
                 new this.QQWrapper.NodeIDispatcherAdapter(new DispatcherAdapter()),

src/webui/Readme.md

@@ -0,0 +1,2 @@
+# The Path of NapCatQQ
+Tiny WebUi for NapCatQQ

src/webui/index.ts

@@ -0,0 +1,45 @@
+import express from 'express';
+import { NextFunction, Request, Response } from 'express';
+import { AuthHelper } from './src/helper/SignToken';
+import { resolve } from 'node:path';
+import { ALLRouter } from './src/router';
+import { WebUiConfig } from './src/helper/config';
+const app = express();
+import { dirname } from 'node:path';
+import { fileURLToPath } from 'node:url';
+import { log } from '@/common/utils/log';
+
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+
+/**
+ * 初始化并启动WebUI服务。
+ * 该函数配置了Express服务器以支持JSON解析和静态文件服务，并监听6099端口。
+ * 无需参数。
+ * @returns {Promise<void>} 无返回值。
+ */
+export async function InitWebUi() {
+  const config = await WebUiConfig.GetWebUIConfig();
+  if (config.port == 0) {
+    log('[NapCat] [WebUi] Current WebUi is not run.');
+    return;
+  }
+  app.use(express.json());
+  // 初始服务
+  // WebUI只在config.prefix所示路径上提供服务，可配合Nginx挂载到子目录中
+  app.all(config.prefix + '/', (_req, res) => {
+    res.json({
+      msg: 'NapCat WebAPI is now running!',
+    });
+  });
+  // 配置静态文件服务，提供./static目录下的文件服务，访问路径为/webui
+  app.use(config.prefix + '/webui', express.static(resolve(__dirname, './static')));
+  //挂载API接口
+  app.use(config.prefix + '/api', ALLRouter);
+  app.listen(config.port, config.host, async () => {
+    log(`[NapCat] [WebUi] Current WebUi is running at http://${config.host}:${config.port}${config.prefix}`);
+    log(`[NapCat] [WebUi] Login URL is http://${config.host}:${config.port}${config.prefix}/webui`);
+    log(`[NapCat] [WebUi] Login Token is ${config.token}`);
+  });
+}

src/webui/src/api/Auth.ts

@@ -0,0 +1,68 @@
+import { RequestHandler } from 'express';
+import { AuthHelper } from '../helper/SignToken';
+import { WebUiConfig } from '../helper/config';
+import { WebUiDataRuntime } from '../helper/Data';
+const isEmpty = (data: any) => data === undefined || data === null || data === '';
+export const LoginHandler: RequestHandler = async (req, res) => {
+  const WebUiConfigData = await WebUiConfig.GetWebUIConfig();
+  const { token } = req.body;
+  if (isEmpty(token)) {
+    res.json({
+      code: -1,
+      message: 'token is empty'
+    });
+    return;
+  } 
+  if (!await WebUiDataRuntime.checkLoginRate(WebUiConfigData.loginRate)) {
+    res.json({
+      code: -1,
+      message: 'login rate limit'
+    });
+    return;
+  }
+  //验证config.token是否等于token
+  if (WebUiConfigData.token !== token) {
+    res.json({
+      code: -1,
+      message: 'token is invalid'
+    });
+    return;
+  }
+  const signCredential = Buffer.from(JSON.stringify(await AuthHelper.signCredential(WebUiConfigData.token))).toString('base64');
+  res.json({
+    code: 0,
+    message: 'success',
+    data: {
+      'Credential': signCredential
+    }
+  });
+  return;
+};
+export const LogoutHandler: RequestHandler = (req, res) => {
+  // 这玩意无状态销毁个灯 得想想办法
+  res.json({
+    code: 0,
+    message: 'success'
+  });
+  return;
+};
+export const checkHandler: RequestHandler = async (req, res) => {
+  const WebUiConfigData = await WebUiConfig.GetWebUIConfig();
+  const authorization = req.headers.authorization;
+  try {
+    const CredentialBase64:string = authorization?.split(' ')[1] as string;
+    const Credential = JSON.parse(Buffer.from(CredentialBase64, 'base64').toString());
+    await AuthHelper.validateCredentialWithinOneHour(WebUiConfigData.token,Credential);
+    res.json({
+      code: 0,
+      message: 'success'
+    });
+    return;
+  } catch (e) {
+    res.json({
+      code: -1,
+      message: 'failed'
+    });
+  }
+  return;
+};

src/webui/src/api/LogConsole.ts

@@ -0,0 +1,54 @@
+import { RequestHandler } from 'express';
+import { resolve } from 'path';
+import { readdir, stat } from 'fs/promises';
+import { existsSync } from 'fs';
+import { dirname } from 'node:path';
+import { fileURLToPath } from 'node:url';
+
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+export const GetLogFileListHandler: RequestHandler = async (req, res) => {
+  try {
+    const LogsPath = resolve(__dirname, './logs/');
+    const LogFiles = await readdir(LogsPath);
+    res.json({
+      code: 0,
+      data: LogFiles
+    });
+  } catch (error) {
+    res.json({ code: -1, msg: 'Failed to retrieve log file list.' });
+  }
+};
+
+export const GetLogFileHandler: RequestHandler = async (req, res) => {
+  const LogsPath = resolve(__dirname, './logs/');
+  const LogFile = req.query.file as string;
+
+  // if (!isValidFileName(LogFile)) {
+  //   res.json({ code: -1, msg: 'LogFile is not safe' });
+  //   return;
+  // }
+
+  const filePath = `${LogsPath}/${LogFile}`;
+  if (!existsSync(filePath)) {
+    res.status(404).json({ code: -1, msg: 'LogFile does not exist' });
+    return;
+  }
+
+  try {
+    const fileStats = await stat(filePath);
+    if (!fileStats.isFile()) {
+      res.json({ code: -1, msg: 'LogFile must be a file' });
+      return;
+    }
+
+    res.sendFile(filePath);
+  } catch (error) {
+    res.json({ code: -1, msg: 'Failed to send log file.' });
+  }
+};
+// export function isValidFileName(fileName: string): boolean {
+//   const invalidChars = /[\.\:\*\?\"\<\>\|\/\\]/;
+//   return !invalidChars.test(fileName);
+// }

src/webui/src/api/OB11Config.ts

@@ -0,0 +1,97 @@
+import { RequestHandler } from 'express';
+import { WebUiDataRuntime } from '../helper/Data';
+import { existsSync, readFileSync, writeFileSync } from 'node:fs';
+import { resolve } from 'node:path';
+import { OB11Config } from '@/webui/ui/components/WebUiApiOB11Config';
+import { dirname } from 'node:path';
+import { fileURLToPath } from 'node:url';
+
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+
+const isEmpty = (data: any) =>
+  data === undefined || data === null || data === '';
+export const OB11GetConfigHandler: RequestHandler = async (req, res) => {
+  const isLogin = await WebUiDataRuntime.getQQLoginStatus();
+  if (!isLogin) {
+    res.send({
+      code: -1,
+      message: 'Not Login',
+    });
+    return;
+  }
+  const uin = await WebUiDataRuntime.getQQLoginUin();
+  const configFilePath = resolve(__dirname, `./config/onebot11_${uin}.json`);
+  //console.log(configFilePath);
+  let data: OB11Config;
+  try {
+    data = JSON.parse(
+      existsSync(configFilePath)
+        ? readFileSync(configFilePath).toString()
+        : readFileSync(resolve(__dirname, './config/onebot11.json')).toString()
+    );
+  } catch (e) {
+    data = {} as OB11Config;
+    res.send({
+      code: -1,
+      message: 'Config Get Error',
+    });
+    return;
+  }
+  res.send({
+    code: 0,
+    message: 'success',
+    data: data,
+  });
+  return;
+};
+export const OB11SetConfigHandler: RequestHandler = async (req, res) => {
+  const isLogin = await WebUiDataRuntime.getQQLoginStatus();
+  if (!isLogin) {
+    res.send({
+      code: -1,
+      message: 'Not Login',
+    });
+    return;
+  }
+  if (isEmpty(req.body.config)) {
+    res.send({
+      code: -1,
+      message: 'config is empty',
+    });
+    return;
+  }
+  let SetResult;
+  try {
+    await WebUiDataRuntime.setOB11Config(JSON.parse(req.body.config));
+    SetResult = true;
+  } catch (e) {
+    SetResult = false;
+  }
+
+  // let configFilePath = resolve(__dirname, `./config/onebot11_${await WebUiDataRuntime.getQQLoginUin()}.json`);
+  // try {
+  //     JSON.parse(req.body.config)
+  //     readFileSync(configFilePath);
+  // }
+  // catch (e) {
+  //     //console.log(e);
+  //     configFilePath = resolve(__dirname, `./config/onebot11.json`);
+  // }
+  // //console.log(configFilePath,JSON.parse(req.body.config));
+  // writeFileSync(configFilePath, JSON.stringify(JSON.parse(req.body.config), null, 4));
+  if (SetResult) {
+    res.send({
+      code: 0,
+      message: 'success',
+    });
+  } else {
+    res.send({
+      code: -1,
+      message: 'Config Set Error',
+    });
+  }
+
+  return;
+};

src/webui/src/api/QQLogin.ts

@@ -0,0 +1,77 @@
+import { RequestHandler } from 'express';
+import { WebUiDataRuntime } from '../helper/Data';
+import { sleep } from '@/common/utils/helper';
+const isEmpty = (data: any) => data === undefined || data === null || data === '';
+export const QQGetQRcodeHandler: RequestHandler = async (req, res) => {
+  if (await WebUiDataRuntime.getQQLoginStatus()) {
+    res.send({
+      code: -1,
+      message: 'QQ Is Logined'
+    });
+    return;
+  }
+  const qrcodeUrl = await WebUiDataRuntime.getQQLoginQrcodeURL();
+  if (isEmpty(qrcodeUrl)) {
+    res.send({
+      code: -1,
+      message: 'QRCode Get Error'
+    });
+    return;
+  }
+  res.send({
+    code: 0,
+    message: 'success',
+    data: {
+      qrcode: qrcodeUrl
+    }
+  });
+  return;
+};
+export const QQCheckLoginStatusHandler: RequestHandler = async (req, res) => {
+  res.send({
+    code: 0,
+    message: 'success',
+    data: {
+      isLogin: await WebUiDataRuntime.getQQLoginStatus()
+    }
+  });
+};
+export const QQSetQuickLoginHandler: RequestHandler = async (req, res) => {
+  const { uin } = req.body;
+  const isLogin = await WebUiDataRuntime.getQQLoginStatus();
+  if (isLogin) {
+    res.send({
+      code: -1,
+      message: 'QQ Is Logined'
+    });
+    return;
+  }
+  if (isEmpty(uin)) {
+    res.send({
+      code: -1,
+      message: 'uin is empty'
+    });
+    return;
+  }
+  const { result, message } = await WebUiDataRuntime.getQQQuickLogin(uin);
+  if (!result) {
+    res.send({
+      code: -1,
+      message: message
+    });
+    return;
+  }
+  //本来应该验证 但是http不宜这么搞 建议前端验证
+  //isLogin = await WebUiDataRuntime.getQQLoginStatus();
+  res.send({
+    code: 0,
+    message: 'success'
+  });
+};
+export const QQGetQuickLoginListHandler: RequestHandler = async (req, res) => {
+  const quickLoginList = await WebUiDataRuntime.getQQQuickLoginList();
+  res.send({
+    code: 0,
+    data: quickLoginList
+  });
+};

src/webui/src/helper/Data.ts

@@ -0,0 +1,83 @@
+import { OB11Config } from '@/onebot11/config';
+
+interface LoginRuntimeType {
+    LoginCurrentTime: number;
+    LoginCurrentRate: number;
+    QQLoginStatus: boolean;
+    QQQRCodeURL: string;
+    QQLoginUin: string;
+    NapCatHelper: {
+        CoreQuickLoginCall: (uin: string) => Promise<{ result: boolean, message: string }>;
+        SetOb11ConfigCall: (ob11: OB11Config) => Promise<void>;
+        QQLoginList: string[]
+    }
+}
+const LoginRuntime: LoginRuntimeType = {
+  LoginCurrentTime: Date.now(),
+  LoginCurrentRate: 0,
+  QQLoginStatus: false, //已实现 但太傻了 得去那边注册个回调刷新
+  QQQRCodeURL: '',
+  QQLoginUin: '',
+  NapCatHelper: {
+    SetOb11ConfigCall: async (ob11: OB11Config) => { return; },
+    CoreQuickLoginCall: async (uin: string) => { return { result: false, message: '' }; },
+    QQLoginList: []
+  }
+};
+export const WebUiDataRuntime = {
+  checkLoginRate: async function (RateLimit: number): Promise<boolean> {
+    LoginRuntime.LoginCurrentRate++;
+    //console.log(RateLimit, LoginRuntime.LoginCurrentRate, Date.now() - LoginRuntime.LoginCurrentTime);
+    if (Date.now() - LoginRuntime.LoginCurrentTime > 1000 * 60) {
+      LoginRuntime.LoginCurrentRate = 0;//超出时间重置限速
+      LoginRuntime.LoginCurrentTime = Date.now();
+      return true;
+    }
+    if (LoginRuntime.LoginCurrentRate <= RateLimit) {
+      return true;
+    }
+    return false;
+  }
+  ,
+  getQQLoginStatus: async function (): Promise<boolean> {
+    return LoginRuntime.QQLoginStatus;
+  }
+  ,
+  setQQLoginStatus: async function (status: boolean): Promise<void> {
+    LoginRuntime.QQLoginStatus = status;
+  }
+  ,
+  setQQLoginQrcodeURL: async function (url: string): Promise<void> {
+    LoginRuntime.QQQRCodeURL = url;
+  }
+  ,
+  getQQLoginQrcodeURL: async function (): Promise<string> {
+    return LoginRuntime.QQQRCodeURL;
+  }
+  ,
+  setQQLoginUin: async function (uin: string): Promise<void> {
+    LoginRuntime.QQLoginUin = uin;
+  }
+  ,
+  getQQLoginUin: async function (): Promise<string> {
+    return LoginRuntime.QQLoginUin;
+  },
+  getQQQuickLoginList: async function (): Promise<any[]> {
+    return LoginRuntime.NapCatHelper.QQLoginList;
+  },
+  setQQQuickLoginList: async function (list: string[]): Promise<void> {
+    LoginRuntime.NapCatHelper.QQLoginList = list;
+  },
+  setQQQuickLoginCall(func: (uin: string) => Promise<{ result: boolean, message: string }>): void {
+    LoginRuntime.NapCatHelper.CoreQuickLoginCall = func;
+  },
+  getQQQuickLogin: async function (uin: string): Promise<{ result: boolean, message: string }> {
+    return await LoginRuntime.NapCatHelper.CoreQuickLoginCall(uin);
+  },
+  setOB11ConfigCall: async function (func: (ob11: OB11Config) => Promise<void>): Promise<void> {
+    LoginRuntime.NapCatHelper.SetOb11ConfigCall = func;
+  },
+  setOB11Config: async function (ob11: OB11Config): Promise<void> {
+    await LoginRuntime.NapCatHelper.SetOb11ConfigCall(ob11);
+  }
+};

src/webui/src/helper/SignToken.ts

@@ -0,0 +1,68 @@
+import crypto from 'crypto';
+
+interface WebUiCredentialInnerJson {
+    CreatedTime: number;
+    TokenEncoded: string;
+}
+
+interface WebUiCredentialJson {
+    Data: WebUiCredentialInnerJson;
+    Hmac: string;
+}
+
+export class AuthHelper {
+  private static secretKey = Math.random().toString(36).slice(2);
+
+  /**
+     * 签名凭证方法。
+     * @param token 待签名的凭证字符串。
+     * @returns 签名后的凭证对象。
+     */
+  public static async signCredential(token: string): Promise<WebUiCredentialJson> {
+    const innerJson: WebUiCredentialInnerJson = {
+      CreatedTime: Date.now(),
+      TokenEncoded: token,
+    };
+    const jsonString = JSON.stringify(innerJson);
+    const hmac = crypto.createHmac('sha256', AuthHelper.secretKey)
+      .update(jsonString, 'utf8')
+      .digest('hex');
+    return { Data: innerJson, Hmac: hmac };
+  }
+
+  /**
+     * 检查凭证是否被篡改的方法。
+     * @param credentialJson 凭证的JSON对象。
+     * @returns 布尔值，表示凭证是否有效。
+     */
+  public static async checkCredential(credentialJson: WebUiCredentialJson): Promise<boolean> {
+    try {
+      const jsonString = JSON.stringify(credentialJson.Data);
+      const calculatedHmac = crypto.createHmac('sha256', AuthHelper.secretKey)
+        .update(jsonString, 'utf8')
+        .digest('hex');
+      return calculatedHmac === credentialJson.Hmac;
+    } catch (error) {
+      return false;
+    }
+  }
+
+  /**
+     * 验证凭证在1小时内有效且token与原始token相同。
+     * @param token 待验证的原始token。
+     * @param credentialJson 已签名的凭证JSON对象。
+     * @returns 布尔值，表示凭证是否有效且token匹配。
+     */
+  public static async validateCredentialWithinOneHour(token: string, credentialJson: WebUiCredentialJson): Promise<boolean> {
+    const isValid = await AuthHelper.checkCredential(credentialJson);
+    if (!isValid) {
+      return false;
+    }
+
+    const currentTime = Date.now() / 1000;
+    const createdTime = credentialJson.Data.CreatedTime;
+    const timeDifference = currentTime - createdTime;
+
+    return timeDifference <= 3600 && credentialJson.Data.TokenEncoded === token;
+  }
+}

src/webui/src/helper/config.ts

@@ -0,0 +1,142 @@
+import { existsSync, readFileSync, writeFileSync } from 'node:fs';
+import { resolve } from 'node:path';
+import * as net from 'node:net';
+import { dirname } from 'node:path';
+import { fileURLToPath } from 'node:url';
+import { logError } from '@/common/utils/log';
+
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+
+// 限制尝试端口的次数，避免死循环
+const MAX_PORT_TRY = 100;
+
+async function tryUseHost(host: string): Promise<string> {
+  return new Promise(async (resolve, reject) => {
+    try {
+      const server = net.createServer();
+      server.on('listening', () => {
+        server.close();
+        resolve(host);
+      });
+
+      server.on('error', (err: any) => {
+        if (err.code === 'EADDRNOTAVAIL') {
+          reject('主机地址验证失败，可能为非本机地址');
+        } else {
+          reject(`遇到错误: ${err.code}`);
+        }
+      });
+
+      // 尝试监听 让系统随机分配一个端口
+      server.listen(0, host);
+    } catch (error) {
+      // 这里捕获到的错误应该是启动服务器时的同步错误
+      reject(`服务器启动时发生错误: ${error}`);
+    }
+  });
+}
+
+async function tryUsePort(port: number, host: string, tryCount: number = 0): Promise<number> {
+  return new Promise(async (resolve, reject) => {
+    try {
+      const server = net.createServer();
+      server.on('listening', () => {
+        server.close();
+        resolve(port);
+      });
+
+      server.on('error', (err: any) => {
+        if (err.code === 'EADDRINUSE') {
+          if (tryCount < MAX_PORT_TRY) {
+            // 使用循环代替递归
+            resolve(tryUsePort(port + 1, host, tryCount + 1));
+          } else {
+            reject(`端口尝试失败，达到最大尝试次数: ${MAX_PORT_TRY}`);
+          }
+        } else {
+          reject(`遇到错误: ${err.code}`);
+        }
+      });
+
+      // 尝试监听端口
+      server.listen(port, host);
+    } catch (error) {
+      // 这里捕获到的错误应该是启动服务器时的同步错误
+      reject(`服务器启动时发生错误: ${error}`);
+    }
+  });
+}
+
+export interface WebUiConfigType {
+    host: string;
+    port: number;
+    prefix: string;
+    token: string;
+    loginRate: number
+}
+// 读取当前目录下名为 webui.json 的配置文件，如果不存在则创建初始化配置文件
+class WebUiConfigWrapper {
+  WebUiConfigData: WebUiConfigType | undefined = undefined;
+  private applyDefaults<T>(obj: Partial<T>, defaults: T): T {
+    return { ...defaults, ...obj };
+  }
+  async GetWebUIConfig(): Promise<WebUiConfigType> {
+    if (this.WebUiConfigData) {
+      return this.WebUiConfigData;
+    }
+    const defaultconfig: WebUiConfigType = {
+      host: '0.0.0.0',
+      port: 6099,
+      prefix: '',
+      token: '', // 默认先填空，空密码无法登录
+      loginRate: 3
+    };
+    try {
+      defaultconfig.token = Math.random().toString(36).slice(2); //生成随机密码
+    } catch (e) {
+      logError('随机密码生成失败', e);
+    }
+    try {
+      const configPath = resolve(__dirname, './config/webui.json');
+
+      if (!existsSync(configPath)) {
+        writeFileSync(configPath, JSON.stringify(defaultconfig, null, 4));
+      }
+
+      const fileContent = readFileSync(configPath, 'utf-8');
+      // 更新配置字段后新增字段可能会缺失，同步一下
+      const parsedConfig = this.applyDefaults(JSON.parse(fileContent) as Partial<WebUiConfigType>, defaultconfig);
+
+      if (!parsedConfig.prefix.startsWith('/')) parsedConfig.prefix = '/' + parsedConfig.prefix;
+      if (parsedConfig.prefix.endsWith('/')) parsedConfig.prefix = parsedConfig.prefix.slice(0, -1);
+      // 配置已经被操作过了，还是回写一下吧，不然新配置不会出现在配置文件里
+      writeFileSync(configPath, JSON.stringify(parsedConfig, null, 4));
+      // 不希望回写的配置放后面
+
+      // 查询主机地址是否可用
+      const [host_err, host] = await tryUseHost(parsedConfig.host).then(data => [null, data as string]).catch(err => [err, null]);
+      if (host_err) {
+        logError('host不可用', host_err);
+        parsedConfig.port = 0; // 设置为0，禁用WebUI
+      } else {
+        parsedConfig.host = host;
+        // 修正端口占用情况
+        const [port_err, port] = await tryUsePort(parsedConfig.port, parsedConfig.host).then(data => [null, data as number]).catch(err => [err, null]);
+        if (port_err) {
+          logError('port不可用', port_err);
+          parsedConfig.port = 0; // 设置为0，禁用WebUI
+        } else {
+          parsedConfig.port = port;
+        }
+      }
+      this.WebUiConfigData = parsedConfig;
+      return this.WebUiConfigData;
+    } catch (e) {
+      logError('读取配置文件失败', e);
+    }
+    return defaultconfig; // 理论上这行代码到不了，到了只能返回默认配置了
+  }
+}
+export const WebUiConfig = new WebUiConfigWrapper();

src/webui/src/router/OB11Config.ts

@@ -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 };

src/webui/src/router/QQLogin.ts

@@ -0,0 +1,8 @@
+import { Router } from 'express';
+import { QQCheckLoginStatusHandler, QQGetQRcodeHandler, QQGetQuickLoginListHandler, QQSetQuickLoginHandler } from '../api/QQLogin';
+const router = Router();
+router.all('/GetQuickLoginList', QQGetQuickLoginListHandler);
+router.post('/CheckLoginStatus', QQCheckLoginStatusHandler);
+router.post('/GetQQLoginQrcode', QQGetQRcodeHandler);
+router.post('/SetQuickLogin', QQSetQuickLoginHandler);
+export { router as QQLoginRouter };

src/webui/src/router/auth.ts

@@ -0,0 +1,9 @@
+import { Router } from 'express';
+import { LoginHandler, LogoutHandler, checkHandler } from '../api/Auth';
+
+const router = Router();
+
+router.post('/login', LoginHandler);
+router.post('/check', checkHandler);
+router.post('/logout', LogoutHandler);
+export { router as AuthRouter };

src/webui/src/router/index.ts

@@ -0,0 +1,65 @@
+import { Router } from 'express';
+import { AuthHelper } from '../../src/helper/SignToken';
+import { NextFunction, Request, Response } from 'express';
+import { QQLoginRouter } from './QQLogin';
+import { AuthRouter } from './auth';
+import { OB11ConfigRouter } from './OB11Config';
+import { WebUiConfig } from '../helper/config';
+const router = Router();
+export async function AuthApi(req: Request, res: Response, next: NextFunction) {
+  //判断当前url是否为/login 如果是跳过鉴权
+  if (req.url == '/auth/login') {
+    next();
+    return;
+  }
+  if (req.headers?.authorization) {
+    const authorization = req.headers.authorization.split(' ');
+    if (authorization.length < 2) {
+      res.json({
+        code: -1,
+        msg: 'Unauthorized',
+      });
+      return;
+    }
+    const token = authorization[1];
+    let Credential: any;
+    try {
+      Credential = JSON.parse(Buffer.from(token, 'base64').toString('utf-8'));
+    } catch (e) {
+      res.json({
+        code: -1,
+        msg: 'Unauthorized',
+      });
+      return;
+    }
+    const config = await WebUiConfig.GetWebUIConfig();
+    const credentialJson = await AuthHelper.validateCredentialWithinOneHour(config.token, Credential);
+    if (credentialJson) {
+      //通过验证
+      next();
+      return;
+    }
+    res.json({
+      code: -1,
+      msg: 'Unauthorized',
+    });
+    return;
+  }
+
+  res.json({
+    code: -1,
+    msg: 'Server Error',
+  });
+  return;
+}
+router.use(AuthApi);
+router.all('/test', (req, res) => {
+  res.json({
+    code: 0,
+    msg: 'ok',
+  });
+});
+router.use('/auth', AuthRouter);
+router.use('/QQLogin', QQLoginRouter);
+router.use('/OB11Config', OB11ConfigRouter);
+export { router as ALLRouter };

src/webui/ui/NapCat.ts

@@ -0,0 +1,392 @@
+import { SettingList } from './components/SettingList';
+import { SettingItem } from './components/SettingItem';
+import { SettingButton } from './components/SettingButton';
+import { SettingSwitch } from './components/SettingSwitch';
+import { SettingSelect } from './components/SettingSelect';
+import { OB11Config, OB11ConfigWrapper } from './components/WebUiApiOB11Config';
+async function onSettingWindowCreated(view: Element) {
+  const isEmpty = (value: any) => value === undefined || value === undefined || value === '';
+  await OB11ConfigWrapper.Init(localStorage.getItem('auth') as string);
+  const ob11Config: OB11Config = await OB11ConfigWrapper.GetOB11Config();
+  const setOB11Config = (key: string, value: any) => {
+    const configKey = key.split('.');
+    if (configKey.length === 2) {
+      ob11Config[configKey[1]] = value;
+    } else if (configKey.length === 3) {
+      ob11Config[configKey[1]][configKey[2]] = value;
+    }
+    // OB11ConfigWrapper.SetOB11Config(ob11Config); // 只有当点保存时才下发配置，而不是在修改值后立即下发
+  };
+
+  const parser = new DOMParser();
+  const doc = parser.parseFromString(
+    [
+      '<div>',
+      `<setting-section id="napcat-error">
+            <setting-panel><pre><code></code></pre></setting-panel>
+        </setting-section>`,
+      SettingList([
+        SettingItem(
+          '<span id="napcat-update-title">Napcat</span>',
+          undefined,
+          SettingButton('V1.8.3', 'napcat-update-button', 'secondary')
+        ),
+      ]),
+      SettingList([
+        SettingItem(
+          '启用 HTTP 服务',
+          undefined,
+          SettingSwitch('ob11.http.enable', ob11Config.http.enable, {
+            'control-display-id': 'config-ob11-http-port',
+          })
+        ),
+        SettingItem(
+          'HTTP 服务监听端口',
+          undefined,
+          `<div class="q-input"><input class="q-input__inner" data-config-key="ob11.http.port" type="number" min="1" max="65534" value="${ob11Config.http.port}" placeholder="${ob11Config.http.port}" /></div>`,
+          'config-ob11-http-port',
+          ob11Config.http.enable
+        ),
+        SettingItem(
+          '启用 HTTP 心跳',
+          undefined,
+          SettingSwitch('ob11.http.enableHeart', ob11Config.http.enableHeart, {
+            'control-display-id': 'config-ob11-HTTP.enableHeart',
+          })
+        ),
+        SettingItem(
+          '启用 HTTP 事件上报',
+          undefined,
+          SettingSwitch('ob11.http.enablePost', ob11Config.http.enablePost, {
+            'control-display-id': 'config-ob11-http-postUrls',
+          })
+        ),
+        `<div class="config-host-list" id="config-ob11-http-postUrls" ${ob11Config.http.enablePost ? '' : 'is-hidden'
+        }>
+                <setting-item data-direction="row">
+                    <div>
+                        <setting-text>HTTP 事件上报密钥</setting-text>
+                    </div>
+                    <div class="q-input">
+                        <input id="config-ob11-http-secret" class="q-input__inner" data-config-key="ob11.http.secret" type="text" value="${ob11Config.http.secret
+}" placeholder="未设置" />
+                    </div>
+                </setting-item>
+                <setting-item data-direction="row">
+                    <div>
+                        <setting-text>HTTP 事件上报地址</setting-text>
+                    </div>
+                    <setting-button id="config-ob11-http-postUrls-add" data-type="primary">添加</setting-button>
+                </setting-item>
+                <div id="config-ob11-http-postUrls-list"></div>
+            </div>`,
+        SettingItem(
+          '启用正向 WebSocket 服务',
+          undefined,
+          SettingSwitch('ob11.ws.enable', ob11Config.ws.enable, {
+            'control-display-id': 'config-ob11-ws-port',
+          })
+        ),
+        SettingItem(
+          '正向 WebSocket 服务监听端口',
+          undefined,
+          `<div class="q-input"><input class="q-input__inner" data-config-key="ob11.ws.port" type="number" min="1" max="65534" value="${ob11Config.ws.port}" placeholder="${ob11Config.ws.port}" /></div>`,
+          'config-ob11-ws-port',
+          ob11Config.ws.enable
+        ),
+        SettingItem(
+          '启用反向 WebSocket 服务',
+          undefined,
+          SettingSwitch('ob11.reverseWs.enable', ob11Config.reverseWs.enable, {
+            'control-display-id': 'config-ob11-reverseWs-urls',
+          })
+        ),
+        `<div class="config-host-list" id="config-ob11-reverseWs-urls" ${ob11Config.reverseWs.enable ? '' : 'is-hidden'}>
+                <setting-item data-direction="row">
+                    <div>
+                        <setting-text>反向 WebSocket 监听地址</setting-text>
+                    </div>
+                    <setting-button id="config-ob11-reverseWs-urls-add" data-type="primary">添加</setting-button>
+                </setting-item>
+                <div id="config-ob11-reverseWs-urls-list"></div>
+            </div>`,
+        SettingItem(
+          ' WebSocket 服务心跳间隔',
+          '控制每隔多久发送一个心跳包，单位为毫秒',
+          `<div class="q-input"><input class="q-input__inner" data-config-key="ob11.heartInterval" type="number" min="1000" value="${ob11Config.heartInterval}" placeholder="${ob11Config.heartInterval}" /></div>`
+        ),
+        SettingItem(
+          'Access token',
+          undefined,
+          `<div class="q-input" style="width:210px;"><input class="q-input__inner" data-config-key="ob11.token" type="text" value="${ob11Config.token}" placeholder="未设置" /></div>`
+        ),
+        SettingItem(
+          '新消息上报格式',
+          '如客户端无特殊需求推荐保持默认设置，两者的详细差异可参考 <a href="javascript:LiteLoader.api.openExternal(\'https://github.com/botuniverse/onebot-11/tree/master/message#readme\');">OneBot v11 文档</a>',
+          SettingSelect(
+            [
+              { text: '消息段', value: 'array' },
+              { text: 'CQ码', value: 'string' },
+            ],
+            'ob11.messagePostFormat',
+            ob11Config.messagePostFormat
+          )
+        ),
+        SettingItem(
+          '音乐卡片签名地址',
+          undefined,
+          `<div class="q-input" style="width:210px;"><input class="q-input__inner" data-config-key="ob11.musicSignUrl" type="text" value="${ob11Config.musicSignUrl}" placeholder="未设置" /></div>`,
+          'ob11.musicSignUrl'
+        ),
+        SettingItem(
+          '启用本地进群时间与发言时间记录',
+          undefined,
+          SettingSwitch('ob11.GroupLocalTime.Record', ob11Config.GroupLocalTime.Record, {
+            'control-display-id': 'config-ob11-GroupLocalTime-RecordList',
+          })
+        ),
+        `<div class="config-host-list" id="config-ob11-GroupLocalTime-RecordList" ${ob11Config.GroupLocalTime.Record ? '' : 'is-hidden'}>
+                <setting-item data-direction="row">
+                    <div>
+                        <setting-text>群列表</setting-text>
+                    </div>
+                    <setting-button id="config-ob11-GroupLocalTime-RecordList-add" data-type="primary">添加</setting-button>
+                </setting-item>
+                <div id="config-ob11-GroupLocalTime-RecordList-list"></div>
+            </div>`,
+        SettingItem(
+          '',
+          undefined,
+          SettingButton('保存', 'config-ob11-save', 'primary')
+        ),
+      ]),
+      SettingList([
+        SettingItem(
+          '上报 Bot 自身发送的消息',
+          '上报 event 为 message_sent',
+          SettingSwitch('ob11.reportSelfMessage', ob11Config.reportSelfMessage)
+        ),
+      ]),
+      SettingList([
+        SettingItem(
+          'GitHub 仓库',
+          'https://github.com/NapNeko/NapCatQQ',
+          SettingButton('点个星星', 'open-github')
+        ),
+        SettingItem('NapCat 文档', '', SettingButton('看看文档', 'open-docs')),
+        SettingItem(
+          'Telegram 群',
+          'https://t.me/+nLZEnpne-pQ1OWFl',
+          SettingButton('进去逛逛', 'open-telegram')
+        ),
+        SettingItem(
+          'QQ 群',
+          '545402644',
+          SettingButton('我要进去', 'open-qq-group')
+        ),
+      ]),
+      '</div>',
+    ].join(''),
+    'text/html'
+  );
+
+  // 外链按钮
+  doc.querySelector('#open-github')?.addEventListener('click', () => {
+    window.open('https://github.com/NapNeko/NapCatQQ', '_blank');
+  });
+  doc.querySelector('#open-telegram')?.addEventListener('click', () => {
+    window.open('https://t.me/+nLZEnpne-pQ1OWFl');
+  });
+  doc.querySelector('#open-qq-group')?.addEventListener('click', () => {
+    window.open('https://qm.qq.com/q/bDnHRG38aI');
+  });
+  doc.querySelector('#open-docs')?.addEventListener('click', () => {
+    window.open('https://napneko.github.io/', '_blank');
+  });
+  // 生成反向地址列表
+  const buildHostListItem = (
+    type: string,
+    host: string,
+    index: number,
+    inputAttrs: any = {}
+  ) => {
+    const dom = {
+      container: document.createElement('setting-item'),
+      input: document.createElement('input'),
+      inputContainer: document.createElement('div'),
+      deleteBtn: document.createElement('setting-button'),
+    };
+    dom.container.classList.add('setting-host-list-item');
+    dom.container.dataset.direction = 'row';
+    Object.assign(dom.input, inputAttrs);
+    dom.input.classList.add('q-input__inner');
+    dom.input.type = 'url';
+    dom.input.value = host;
+    dom.input.addEventListener('input', () => {
+      ob11Config[type.split('-')[0]][type.split('-')[1]][index] =
+        dom.input.value;
+    });
+
+    dom.inputContainer.classList.add('q-input');
+    dom.inputContainer.appendChild(dom.input);
+
+    dom.deleteBtn.innerHTML = '删除';
+    dom.deleteBtn.dataset.type = 'secondary';
+    dom.deleteBtn.addEventListener('click', () => {
+      ob11Config[type.split('-')[0]][type.split('-')[1]].splice(index, 1);
+      initReverseHost(type);
+    });
+
+    dom.container.appendChild(dom.inputContainer);
+    dom.container.appendChild(dom.deleteBtn);
+
+    return dom.container;
+  };
+  const buildHostList = (
+    hosts: string[],
+    type: string,
+    inputAttr: any = {}
+  ) => {
+    const result: HTMLElement[] = [];
+
+    hosts?.forEach((host, index) => {
+      result.push(buildHostListItem(type, host, index, inputAttr));
+    });
+
+    return result;
+  };
+  const addReverseHost = (
+    type: string,
+    doc: Document = document,
+    inputAttr: any = {}
+  ) => {
+    type = type.replace(/\./g, '-');//替换操作
+    const hostContainerDom = doc.body.querySelector(
+      `#config-ob11-${type}-list`
+    );
+    hostContainerDom?.appendChild(
+      buildHostListItem(
+        type,
+        '',
+        ob11Config[type.split('-')[0]][type.split('-')[1]].length,
+        inputAttr
+      )
+    );
+    ob11Config[type.split('-')[0]][type.split('-')[1]].push('');
+  };
+  const initReverseHost = (type: string, doc: Document = document) => {
+    type = type.replace(/\./g, '-');//替换操作
+    const hostContainerDom = doc.body?.querySelector(
+      `#config-ob11-${type}-list`
+    );
+    if (hostContainerDom) {
+      [...hostContainerDom.childNodes].forEach((dom) => dom.remove());
+      buildHostList(
+        ob11Config[type.split('-')[0]][type.split('-')[1]],
+        type
+      ).forEach((dom) => {
+        hostContainerDom?.appendChild(dom);
+      });
+    }
+  };
+
+  initReverseHost('http.postUrls', doc);
+  initReverseHost('reverseWs.urls', doc);
+  initReverseHost('GroupLocalTime.RecordList', doc);
+
+  doc
+    .querySelector('#config-ob11-http-postUrls-add')
+    ?.addEventListener('click', () =>
+      addReverseHost('http.postUrls', document, {
+        placeholder: '如：http://127.0.0.1:5140/onebot',
+      })
+    );
+
+  doc
+    .querySelector('#config-ob11-reverseWs-urls-add')
+    ?.addEventListener('click', () =>
+      addReverseHost('reverseWs.urls', document, {
+        placeholder: '如：ws://127.0.0.1:5140/onebot',
+      })
+    );
+  doc
+    .querySelector('#config-ob11-GroupLocalTime-RecordList-add')
+    ?.addEventListener('click', () =>
+      addReverseHost('GroupLocalTime.RecordList', document, {
+        placeholder: '此处填写群号 -1为全部',
+      })
+    );
+  doc.querySelector('#config-ffmpeg-select')?.addEventListener('click', () => {
+    //选择ffmpeg
+  });
+
+  doc.querySelector('#config-open-log-path')?.addEventListener('click', () => {
+    //打开日志
+  });
+
+  // 开关
+  doc
+    .querySelectorAll('setting-switch[data-config-key]')
+    .forEach((dom: Element) => {
+      dom.addEventListener('click', () => {
+        const active = dom.getAttribute('is-active') == undefined;
+        //@ts-expect-error 等待修复
+        setOB11Config(dom.dataset.configKey, active);
+        if (active) dom.setAttribute('is-active', '');
+        else dom.removeAttribute('is-active');
+        //@ts-expect-error 等待修复
+        if (!isEmpty(dom.dataset.controlDisplayId)) {
+          const displayDom = document.querySelector(
+            //@ts-expect-error 等待修复
+            `#${dom.dataset.controlDisplayId}`
+          );
+          if (active) displayDom?.removeAttribute('is-hidden');
+          else displayDom?.setAttribute('is-hidden', '');
+        }
+      });
+    });
+
+  // 输入框
+  doc
+    .querySelectorAll(
+      'setting-item .q-input input.q-input__inner[data-config-key]'
+    )
+    .forEach((dom: Element) => {
+      dom.addEventListener('input', () => {
+        const Type = dom.getAttribute('type');
+        //@ts-expect-error等待修复
+        const configKey = dom.dataset.configKey;
+        const configValue =
+          Type === 'number'
+            ? parseInt((dom as HTMLInputElement).value) >= 1
+              ? parseInt((dom as HTMLInputElement).value)
+              : 1
+            : (dom as HTMLInputElement).value;
+
+        setOB11Config(configKey, configValue);
+      });
+    });
+
+  // 下拉框
+  doc
+    .querySelectorAll('ob-setting-select[data-config-key]')
+    .forEach((dom: Element) => {
+      //@ts-expect-error等待修复
+      dom?.addEventListener('selected', (e: CustomEvent) => {
+        //@ts-expect-error等待修复
+        const configKey = dom.dataset.configKey;
+        const configValue = e.detail.value;
+        setOB11Config(configKey, configValue);
+      });
+    });
+
+  // 保存按钮
+  doc.querySelector('#config-ob11-save')?.addEventListener('click', () => {
+    OB11ConfigWrapper.SetOB11Config(ob11Config);
+    alert('保存成功');
+  });
+  doc.body.childNodes.forEach((node) => {
+    view.appendChild(node);
+  });
+}
+export { onSettingWindowCreated };

src/webui/ui/components/SettingButton.ts

@@ -0,0 +1,3 @@
+export const SettingButton = (text: string, id?: string, type: string = 'secondary') => {
+  return `<setting-button ${type ? `data-type="${type}"` : ''} ${id ? `id="${id}"` : ''}>${text}</setting-button>`;
+};

src/webui/ui/components/SettingItem.ts

@@ -0,0 +1,15 @@
+export const SettingItem = (
+  title: string,
+  subtitle?: string,
+  action?: string,
+  id?: string,
+  visible: boolean = true,
+) => {
+  return `<setting-item ${id ? `id="${id}"` : ''} ${!visible ? 'is-hidden' : ''}>
+      <div>
+          <setting-text>${title}</setting-text>
+          ${subtitle ? `<setting-text data-type="secondary">${subtitle}</setting-text>` : ''}
+      </div>
+      ${action ? `<div>${action}</div>` : ''}
+  </setting-item>`;
+};

src/webui/ui/components/SettingList.ts

@@ -0,0 +1,14 @@
+export const SettingList = (
+  items: string[],
+  title?: string,
+  isCollapsible: boolean = false,
+  direction: string = 'column',
+) => {
+  return `<setting-section ${title && !isCollapsible ? `data-title="${title}"` : ''}>
+      <setting-panel>
+          <setting-list ${direction ? `data-direction="${direction}"` : ''} ${isCollapsible ? 'is-collapsible' : ''} ${title && isCollapsible ? `data-title="${title}"` : ''}>
+              ${items.join('')}
+          </setting-list>
+      </setting-panel>
+  </setting-section>`;
+};

src/webui/ui/components/SettingOption.ts

@@ -0,0 +1,3 @@
+export const SettingOption = (text: string, value?: string, isSelected: boolean = false) => {
+  return `<setting-option ${value ? `data-value="${value}"` : ''} ${isSelected ? 'is-selected' : ''}>${text}</setting-option>`;
+};

src/webui/ui/components/SettingSelect.ts

@@ -0,0 +1,84 @@
+import { SettingOption } from './SettingOption';
+
+interface MouseEventExtend extends MouseEvent {
+  target: HTMLElement
+}
+
+// <ob-setting-select>
+const SelectTemplate = document.createElement('template');
+SelectTemplate.innerHTML = `<style>
+    .hidden { display: none !important; }
+</style>
+<div part="parent">
+        <div part="button">
+            <input type="text" placeholder="请选择" part="current-text" />
+            <svg viewBox="0 0 16 16" fill="none" xmlns="http://www.w3.org/2000/svg" part="button-arrow">
+                <path d="M12 6.0001L8.00004 10L4 6" stroke="currentColor" stroke-linejoin="round"></path>
+            </svg>
+        </div>
+    <ul class="hidden" part="option-list"><slot></slot></ul>
+</div>`;
+
+window.customElements.define(
+  'ob-setting-select',
+  class extends HTMLElement {
+    readonly _button: HTMLDivElement;
+    readonly _text: HTMLInputElement;
+    readonly _context: HTMLUListElement;
+
+    constructor() {
+      super();
+
+      this.attachShadow({ mode: 'open' });
+      this.shadowRoot?.append(SelectTemplate.content.cloneNode(true));
+
+      this._button = this.shadowRoot.querySelector('div[part="button"]');
+      this._text = this.shadowRoot.querySelector('input[part="current-text"]');
+      this._context = this.shadowRoot.querySelector('ul[part="option-list"]');
+
+      const buttonClick = () => {
+        const isHidden = this._context.classList.toggle('hidden');
+        window[`${isHidden ? 'remove' : 'add'}EventListener`]('pointerdown', windowPointerDown);
+      };
+
+      const windowPointerDown = ({ target }) => {
+        if (!this.contains(target)) buttonClick();
+      };
+
+      this._button.addEventListener('click', buttonClick);
+      this._context.addEventListener('click', ({ target }: MouseEventExtend) => {
+        if (target.tagName !== 'SETTING-OPTION') return;
+        buttonClick();
+
+        if (target.hasAttribute('is-selected')) return;
+
+        this.querySelectorAll('setting-option[is-selected]').forEach((dom) => dom.toggleAttribute('is-selected'));
+        target.toggleAttribute('is-selected');
+
+        this._text.value = target.textContent as string;
+        this.dispatchEvent(
+          new CustomEvent('selected', {
+            bubbles: true,
+            composed: true,
+            detail: {
+              name: target.textContent,
+              value: target.dataset.value,
+            },
+          }),
+        );
+      });
+
+      this._text.value = this.querySelector('setting-option[is-selected]')?.textContent as string;
+    }
+  },
+);
+
+export const SettingSelect = (items: Array<{ text: string; value: string }>, configKey?: string, configValue?: any) => {
+  return `<ob-setting-select ${configKey ? `data-config-key="${configKey}"` : ''}>
+    ${items
+    .map((e, i) => {
+      return SettingOption(e.text, e.value, configKey && configValue ? configValue === e.value : i === 0);
+    })
+    .join('')}
+</ob-setting-select>`;
+};

src/webui/ui/components/SettingSwitch.ts

@@ -0,0 +1,8 @@
+export const SettingSwitch = (configKey?: string, isActive: boolean = false, extraData?: Record<string, string>) => {
+  return `<setting-switch 
+      ${configKey ? `data-config-key="${configKey}"` : ''} 
+      ${isActive ? 'is-active' : ''} 
+      ${extraData ? Object.keys(extraData).map((key) => `data-${key}="${extraData[key]}"`) : ''} 
+      >
+  </setting-switch>`;
+};

src/webui/ui/components/WebUiApiOB11Config.ts

@@ -0,0 +1,74 @@
+export interface OB11Config {
+  [key: string]: any;
+  http: {
+    enable: boolean;
+    host: '';
+    port: number;
+    secret: '';
+    enableHeart: boolean;
+    enablePost: boolean;
+    postUrls: string[];
+  };
+  ws: {
+    enable: boolean;
+    host: '';
+    port: number;
+  };
+  reverseWs: {
+    enable: boolean;
+    urls: string[];
+  };
+  GroupLocalTime: {
+    Record: boolean,
+    RecordList: Array<string>
+  };
+  debug: boolean;
+  heartInterval: number;
+  messagePostFormat: 'array' | 'string';
+  enableLocalFile2Url: boolean;
+  musicSignUrl: '';
+  reportSelfMessage: boolean;
+  token: '';
+
+}
+
+class WebUiApiOB11ConfigWrapper {
+  private retCredential: string = '';
+  async Init(Credential: string) {
+    this.retCredential = Credential;
+  }
+  async GetOB11Config(): Promise<OB11Config> {
+    const ConfigResponse = await fetch('../api/OB11Config/GetConfig', {
+      method: 'POST',
+      headers: {
+        Authorization: 'Bearer ' + this.retCredential,
+        'Content-Type': 'application/json',
+      },
+    });
+    if (ConfigResponse.status == 200) {
+      const ConfigResponseJson = await ConfigResponse.json();
+      if (ConfigResponseJson.code == 0) {
+        return ConfigResponseJson?.data;
+      }
+    }
+    return {} as OB11Config;
+  }
+  async SetOB11Config(config: OB11Config): Promise<boolean> {
+    const ConfigResponse = await fetch('../api/OB11Config/SetConfig', {
+      method: 'POST',
+      headers: {
+        Authorization: 'Bearer ' + this.retCredential,
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify({ config: JSON.stringify(config) }),
+    });
+    if (ConfigResponse.status == 200) {
+      const ConfigResponseJson = await ConfigResponse.json();
+      if (ConfigResponseJson.code == 0) {
+        return true;
+      }
+    }
+    return false;
+  }
+}
+export const OB11ConfigWrapper = new WebUiApiOB11ConfigWrapper();

src/webui/vite.config.ts

@@ -0,0 +1,13 @@
+import { defineConfig } from 'vite';
+
+export default defineConfig({
+  build:{
+    target: 'esnext',
+    minify: false,
+    lib: {
+      entry: 'ui/NapCat.ts',
+      formats: ['es'],
+      fileName: () => 'renderer.js',
+    }
+  }
+});

src/webui/webui.json

@@ -0,0 +1,8 @@
+{
+    "host": "0.0.0.0",
+    "port": 6099,
+    "prefix": "",
+    "token": "random",
+    "loginRate": 3
+    
+}