feat(package): 添加 start 脚本命令

- 在 package.json 中新增 "start" 脚本- 使用 node index.js 启动应用- 便于生产环境直接运行服务

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,50 @@
+const {randomUUID} = require("crypto");
+const ins = require("../../utils/http");
+const dayjs = require("dayjs");
+const getCookie = require("../../auth/3xuiLogin");
+
+module.exports = async (ctx) => {
+  let {id = 4, limitIp, expiryTime = 0, enable = !0, totalGB = 1, subId = "2rv0gb458kbfl532", email, uuid} = 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: `获取节点失败:${inbound}` });
+  uuid = uuid || randomUUID();
+  email = 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 setting = JSON.parse(streamSettings || "{}"), {network = "ws", security = "none"} = setting;
+    if (network === "ws") {
+      const {wsSettings: {host, path}} = setting
+      ctx.body = {
+        code: "0", message: "success",
+        data: `${protocol}://${uuid}@vless.jjcp52.com:${port}?type=${network}&path=${path}&host=${host}&security=${security}#${remark}-${email}`,
+      };
+    } else if (network === "tcp") {
+      // 生成的链接格式 vless://842f52b6-4945-46c8-89ed-165bf51123fc@206.237.11.232:34261?type=tcp&security=reality&pbk=3-yeUp9rz5KacCLJqaLt_rHUY_6EKw6tveLpVB2hxQI&fp=random&sni=yahoo.com&sid=0f7f86d03b646595&spx=%2F#temu-reality-kubbo
+      const {serverNames: [sni], shortIds: [sid], settings: {publicKey, fingerprint, spiderX}} = (setting.realitySettings || {})
+      ctx.body = {
+        code: "0", message: "success",
+        data: `${protocol}://${uuid}@vless.jjcp52.com:${port}?type=${network}&security=${security}&pbk=${publicKey}&fp=${fingerprint}&sni=${sni}&sid=${sid}&spx=${spiderX}#${remark}-${email}`,
+      };
+    }
+
+  } else {
+    ctx.body = {
+      code: 1,
+      message: "添加失败:" + result?.msg || "未知原因",
+      data: ctx.request.body,
+    };
+  }
+};

api/client/status.js

@@ -0,0 +1,19 @@
+const getCookie = require("../../auth/3xuiLogin");
+const instance = require("../../utils/http");
+
+module.exports = async (ctx) => {
+  let { id } = ctx.request.query;
+  if (!ctx.state.cookie) {
+    ctx.state.cookie = await getCookie();
+    instance.interceptors.request.use((config) => {
+      config.headers.Cookie = ctx.state.cookie;
+      return config;
+    });
+  }
+  const status = await instance.get(`/panel/api/inbounds/getClientTrafficsById/${id}`);
+  ctx.body = {
+    code: 0,
+    data: status.obj?.[0] || {},
+    msg: "success",
+  };
+};

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;

auth/verifyThirdPartyToken.js

@@ -1,3 +1,4 @@
 module.exports = (token) => {
-  return { token, username: token };
+  const AUTH_TOKEN = process.env.AUTH_TOKEN || "pJENcyWA0eg47CsyBaztb2zCyx77D294";
+  return token === AUTH_TOKEN ? { token, username: "lsw" } : null;
 };

index.js

@@ -0,0 +1 @@
+require("./app")

package.json

@@ -1,16 +1,17 @@
 {
   "name": "vless-api",
   "version": "1.0.0",
-  "description": "",
-  "main": "app.js",
+  "main": "index.js",
   "scripts": {
-    "start": "node app.js",
-    "dev": "nodemon app.js"
+    "start": "node index.js",
+    "dev": "nodemon index.js",
+    "build": "pkg index.js --targets=node18-win-x64,node18-linux-x64 --output=dist/"
   },
   "author": "kubbo",
   "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;