fix(api/client): 修复添加客户端时的总流量计算和数据获取问题

- 将 totalGB 转换为字节，以确保正确的流量限制
- 修正 inbound 数据获取路径，提高代码的健壮性

api/addClient.js

@@ -1,8 +0,0 @@
-
-
-module.exports = (ctx) => {
-  ctx.body = { 
-    message: 'Example POST API',
-    data: ctx.request.body 
-  };
-};

api/client/add.js

@@ -0,0 +1,45 @@
+const { randomUUID } = require("crypto");
+const ins = require("../../utils/http");
+const dayjs = require("dayjs");
+const getCookie = require("../../auth/3xuiLogin");
+const { log } = require("console");
+
+module.exports = async (ctx) => {
+  let { id = 4, limitIp, expiryTime = 0, enable = !0, totalGB = 1, subId = "2rv0gb458kbfl532" } = ctx.request.body;
+  if (!ctx.state.cookie) {
+    ctx.state.cookie = await getCookie();
+    ins.interceptors.request.use((config) => {
+      config.headers.Cookie = ctx.state.cookie;
+      return config;
+    });
+  }
+  const inbound = await ins.get(`/panel/api/inbounds/get/${id}`);
+  if (!inbound?.success) return (ctx.body = { code: "1", msg: "获取节点失败" });
+  const uuid = randomUUID(),
+    email = uuid.split("-")[0];
+  if (expiryTime > 0) {
+    expiryTime = dayjs(expiryTime, "YYYY-MM-DD HH:mm:ss").valueOf();
+  }
+  totalGB = totalGB * 1024 * 1024 * 1024;
+  const settings = { clients: [{ id: uuid, flow: "", email, limitIp, enable, tgId: "", subId, reset: 0, totalGB, expiryTime }] };
+  const result = await ins.post("/panel/api/inbounds/addClient", { id, settings: JSON.stringify(settings) });
+  if (result?.success) {
+    const { remark, port, protocol, streamSettings = "{}" } = inbound.obj || {};
+    const {
+      network = "ws",
+      security = "none",
+      wsSettings: { host, path },
+    } = JSON.parse(streamSettings);
+    ctx.body = {
+      code: "0",
+      data: `${protocol}://${uuid}@vless.jjcp52.com:${port}?type=${network}&path=${path}&host=${host}&security=${security}#${remark}-${email}`,
+      message: "success",
+    };
+  } else {
+    ctx.body = {
+      code: 1,
+      message: "添加失败",
+      data: ctx.request.body,
+    };
+  }
+};

app.js

@@ -12,22 +12,47 @@ app.use(bodyParser()); // 添加在路由中间件之前
 const router = new Router();
 
 // 自动加载API路由函数
-const loadAPIRoutes = () => {
-  const apiDir = path.join(__dirname, "api");
-  const files = fs.readdirSync(apiDir);
+const loadAPIRoutes = (baseDir = 'api', baseRoute = '/api') => {
+  const scanDirectory = (dir, routePrefix) => {
+    const entries = fs.readdirSync(dir, { withFileTypes: true });
 
-  files.forEach((file) => {
-    if (file.endsWith(".js") && file !== "index.js") {
-      const routePath = `/api/${file.replace(".js", "")}`;
-      const handler = require(path.join(apiDir, file));
+    entries.forEach(entry => {
+      const fullPath = path.join(dir, entry.name);
+      const relativePath = path.relative(baseDir, dir);
+      
+      // 构建路由路径：工程目录结构 -> URL路径
+      const routePath = path.join(
+        routePrefix,
+        relativePath,
+        entry.name.replace(/\.js$/, '')
+      ).replace(/\\/g, '/'); // Windows路径转URL路径
 
-      router.post(routePath, async (ctx) => {
-        await handler(ctx);
-      });
+      if (entry.isDirectory()) {
+        scanDirectory(fullPath, routePrefix); // 递归扫描子目录
+      } else if (
+        entry.isFile() && 
+        path.extname(entry.name) === '.js' &&
+        entry.name !== 'index.js'
+      ) {
+        registerRoute(fullPath, routePath);
+      }
+    });
+  };
+
+  // 路由注册器（支持扩展其他HTTP方法）
+  const registerRoute = (filePath, routePath) => {
+    try {
+      const handler = require(filePath);
+      router.post(routePath, async ctx => await handler(ctx));
+      console.log(`[Route] POST ${routePath} -> ${filePath}`);
+    } catch (err) {
+      console.error(`[Error] Failed to load route ${routePath}:`, err);
     }
-  });
-};
+  };
 
+  // 初始化扫描
+  scanDirectory(path.join(__dirname, baseDir), baseRoute);
+};
 // 公开路由
 router.get("/public", (ctx) => {
   ctx.body = "Public content";
@@ -50,7 +75,6 @@ app.use(async (ctx, next) => {
   }
   await next();
 });
-
 // JWT中间件（保护下方所有路由）
 app.use(
   koaJwt({

auth/3xuiLogin.js

@@ -0,0 +1,19 @@
+const instance = require("../utils/http");
+
+function getCookie() {
+  const formData = new FormData();
+  formData.append("username", "lsw");
+  formData.append("password", "lsw@2024");
+  formData.append("loginSecret", "IEuVG4csTWLuaq3ysuUSHdwOcnoQRfScURwJVBjCMjRRpjVyYhWcgaHIJvU0SV4P");
+  return instance
+    .post("/login", formData, {
+      maxRedirects: 0, // 禁止自动重定向以保留Cookie
+      withCredentials: true, // 确保携带凭证
+    })
+    .then((res) => {
+      const rawCookies = res.headers["set-cookie"] || [];
+      const cookies =["lang=zh-CN",rawCookies.at(-1)?.split(";")[0]].join(";");
+      return cookies;
+    });
+}
+module.exports = getCookie;

package.json

@@ -11,6 +11,7 @@
   "license": "ISC",
   "dependencies": {
     "axios": "^1.7.9",
+    "dayjs": "^1.11.13",
     "dotenv": "^16.4.7",
     "jsonwebtoken": "^9.0.2",
     "koa": "^2.15.4",

utils/http.js

@@ -1,3 +1,16 @@
 require("dotenv").config();
 const { default: axios } = require("axios");
-module.exports = (baseURL = process.env.BASE_URL) => axios.create({ baseURL: BASE_URL });
+const instance = axios.create({ baseURL: process.env.BASE_URL });
+instance.interceptors.response.use(
+  (response) => {
+    if (response.status === 200 && !["/login"].includes(response.config.url)) {
+      return response.data;
+    }
+    return response;
+  },
+  (error) => {
+    console.log(error);
+    return Promise.reject(error);
+  }
+);
+module.exports = instance;