update:更新一大堆内容，不想描述了。

Author: hjdhnx

.gitignore

@@ -128,3 +128,4 @@ dist
 .yarn/build-state.yml
 .yarn/install-state.gz
 .pnp.*
+/local/

.nomedia

@@ -1 +1 @@
-hjdhnx
+DM8U8pJ0qw0O5YK/a9FfWRh7mj3m+j9WtKTfOMvdDFUrbU1kT+yeBvoxwGdrZ1KXVfDJ/Smh4LSq3+A07ebBNwfxy7V3aRJuEAJQ9gLETBJ1oYahMY2WOwmxl8yeqUcBzcbaI45HpFKzqYnsZrV34ddBzRIac11sammtk4UbppFzfoSSOY0HdcLahBWc7UOBV+t/CSl1y5ut5qXdbKorYOK+t789Ifb7fTrhzpmG21l4y+AqwGLKyDiHAWQA76nMVBWyJSdNRu9EQ8CtRPBnpTi03h8eQNWopr8KUs8ghbTLEndyn/q/mBkrQ5i05DilDexDN3DRq4p3UpNli00piWSwTm+P8OnYiENoOVMAMc3F87CQkdTwTxmnPCZsrIM5VM7Dgaea4KCsIwsLxnZ9o5lZ02AWPB/3a9GPEBwOEQeuOW2sz7LD7nuSWxOA4fujjSTQogdfrMzyUtJbSNr/iTBm6XhFAlokvJpNX7HzjDXanq9CVhp1bOw3qQ7WsOloke95ITC6Ou89n+qg6A/2oMzvms94E9CZ1JzoR7EG2WM6djeAugx79Sd3+jH6uSkfYP1qiSUK48mtrQUooxJ7SzEVGHkD33Q3bxX2K2rnX5SdtgYlS99JsoMmjOPaSHsnaK6Y7OTi1hZl1jPcwYT54UutJwAc2XgWhgmOXRpI7RU9qFvPbYnLvplCIjAtsSnRdrJTOIjkDwm3IoNaevIdHZ2y9/lR/u2WH2gFJEzOLuqLS8rSY7uBSq3tzpay8hPqo6KB1eOos7hp3/zdOlABVUaJHkZ+WSCWPmzXUW0WTKKQiOOrIFXeFmccnmljR33iKPecMVugHxr3+2xgDY487Qt9F1EUHZwcVJ6CeVYhpsZUSnsyyJ6iNfNiG33+KA9q5/+pMKQgf2iaB0uJmeI+/pwmfd8hZrDxskRYy23wPVv5fz/GOoTk7ply/keZpF4iJHW/hI5wbhgjhq4kgvkcA8vY7nKhhTvlPStZ8o+jDqB3lOxyzpCzrfd2mwdOCDRDUF7Jy6ljB2ABizIYDMlyPMaiV2QjIAUGv+va0k1E2EKsPgefezQ9q7io+RNY6vUHcILCFw2duBixZnBGZPIJ70srGS6UsLN+AmMkeTCMH1j4k6q/JnQFE1qQGL+m2kM5BYun+pFvwHwrBw3SmQVq2ProW2LLFw/5nuNTePHXpJSc3kQNZ0RDCn202HRG6495DHS3q9cFF74RP+PpJmlYnxuGgjGUqkyg3Fro37fgW2m1Etqprs9ZIuDxvOGhz5DkqIf9swzMpW8VUU+qQD2TB/nRncHLA/qhmReh87YyyMHzxLsMt3A5Q+LdFnBxlGAFjpL2+2FnsSalgf2jwVGKecO1iyzePzvJWM+pQQTrt6RW6Y7PWEZQlLwTZd5US8RI4EprbhS7sVFwyH6MnbaiIM0BJekVk0PGbcIqSbFjdLQNNcdAt6Zvh2s0mSQwIcAjZ2f3/ZA31RrNS76lGUEI0A==

README.md

@@ -6,12 +6,16 @@ nodejs作为服务端的drpy实现。全面升级异步写法
 * [本地配置接口-动态外网/局域网](/config/1)
 * [本地配置接口-静态](/index)
 * [代码加解密工具](/admin/encoder)
+* [V我50支付凭证生成器](/authcoder?len=10&number=1)
+* [接口压测教程](/docs/httpTest.md)
 
 ## 更新记录
 
-### 20241206
+### 20241207
 
-1. 增加源加密功能
+更新至V1.0.4
+
+1. 修复黑料搜索
 
 [点此查看完整更新记录](docs/updateRecord.md)
 
@@ -33,8 +37,11 @@ todo:
 4. pino-pretty
 5. deasync
 
-
 ## 参考资料
 
 * [crypto-js-wasm使用教程](docs/crypto-js-wasm/readme-CN.md)
 * [puppeteer使用教程](docs/pupInstall.md)
+
+## 问题说明
+
+1. windows上直接运行index.js可能会发现运行过程中的日志打印出中文乱码。建议通过yarn dev运行或者在package.json里点击dev脚本运行

controllers/api.js

@@ -81,7 +81,7 @@ export default (fastify, options, done) => {
             // console.error('Error processing request:', error);
             // reply.status(500).send({error: `Failed to process request for module ${moduleName}: ${error.message}`});
 
-            fastify.log.error(`Error processing module ${moduleName}:`, error);
+            fastify.log.error(`Error proxy module ${moduleName}:${error.message}`);
             reply.status(500).send({error: `Failed to process module ${moduleName}: ${error.message}`});
         }
     });
@@ -95,7 +95,7 @@ export default (fastify, options, done) => {
             return;
         }
         const proxy_url = request.params['*']; // 捕获整个路径
-        fastify.log.info(`try proxy for ${moduleName} -> ${proxy_url}:`);
+        fastify.log.info(`try proxy for ${moduleName} -> ${proxy_url}: ${JSON.stringify(query)}`);
         const protocol = request.protocol;
         const hostname = request.hostname;
         const proxyUrl = `${protocol}://${hostname}${request.url}`.split('?')[0].replace(proxy_url, '') + '?do=js';
@@ -152,7 +152,7 @@ export default (fastify, options, done) => {
             }
 
         } catch (error) {
-            fastify.log.error(`Error proxy module ${moduleName}:`, error);
+            fastify.log.error(`Error proxy module ${moduleName}:${error.message}`);
             reply.status(500).send({error: `Failed to proxy module ${moduleName}: ${error.message}`});
         }
     });

controllers/authcoder.js

@@ -0,0 +1,34 @@
+import * as misc from '../utils/misc.js';
+
+export default (fastify, options, done) => {
+    // 注册 /authcoder 路由
+    fastify.get('/authcoder', async (request, reply) => {
+        const {len, number} = request.query;
+
+        // 参数校验
+        if (!len || !number || isNaN(len) || isNaN(number)) {
+            return reply.status(400).send('Missing or invalid required parameters: len and number');
+        }
+
+        const length = parseInt(len, 10);
+        const count = parseInt(number, 10);
+
+        if (length <= 0 || count <= 0) {
+            return reply.status(400).send('Parameters len and number must be positive integers.');
+        }
+
+        try {
+            // 生成随机字符串集合
+            const result = Array.from({length: count}, () => misc.randStr(length)).join('\n');
+
+            // 返回 text/plain 响应
+            reply.type('text/plain').send(result);
+        } catch (error) {
+            // 异常处理
+            fastify.log.error(error);
+            reply.status(500).send('An error occurred while generating strings.');
+        }
+    });
+
+    done();
+};

controllers/decoder.js

@@ -1,4 +1,4 @@
-import {getOriginalJs} from '../libs/drpyS.js';
+import {getOriginalJs, jsDecoder} from '../libs/drpyS.js';
 import {readFileSync, existsSync} from 'fs';
 import path from "path";
 
@@ -17,11 +17,16 @@ export default (fastify, options, done) => {
         if (!existsSync(authFilePath)) {
             return reply.status(404).send({error: '.nomedia file not found'});
         }
-        const local_auto_code = readFileSync(authFilePath, 'utf-8').trim();
-        console.log('local_auto_code:',local_auto_code);
-        console.log('auth_code:',auth_code);
-        if (auth_code !== local_auto_code) {
-            return reply.status(200).send({error: 'your auth_code is not correct'});
+        try {
+            const local_auto_code = readFileSync(authFilePath, 'utf-8').trim();
+            const auth_codes = jsDecoder.aes_decrypt(local_auto_code).trim().split('\n');
+            // console.log('auth_codes:',auth_codes);
+            // console.log('auth_code:', auth_code);
+            if (!auth_codes.includes(auth_code)) {
+                return reply.status(200).send({error: 'your auth_code is not correct'});
+            }
+        } catch (error) {
+            return reply.status(200).send({error: error.message});
         }
 
         try {

controllers/fastlogger.js

@@ -0,0 +1,71 @@
+import fs from "fs";
+import path from 'path';
+import pino from "pino";
+import Fastify from "fastify";
+import {fileURLToPath} from 'url';
+import {createStream} from 'rotating-file-stream';
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = path.dirname(__filename);
+const logDirectory = path.join(__dirname, '../logs');
+if (!fs.existsSync(logDirectory)) {
+    fs.mkdirSync(logDirectory);
+}
+// 自定义时间戳函数，格式为 YYYY-MM-DD HH:mm:ss
+const customTimestamp = () => {
+    const now = new Date();
+    const yyyy = now.getFullYear();
+    const mm = String(now.getMonth() + 1).padStart(2, '0');
+    const dd = String(now.getDate()).padStart(2, '0');
+    const hours = String(now.getHours()).padStart(2, '0');
+    const minutes = String(now.getMinutes()).padStart(2, '0');
+    const seconds = String(now.getSeconds()).padStart(2, '0');
+    const formattedTime = `${yyyy}-${mm}-${dd} ${hours}:${minutes}:${seconds}`;
+    return `,"time":"${formattedTime}"`; // 返回格式化后的时间戳
+};
+
+// const logStream = fs.createWriteStream(path.join(logDirectory, 'output.log'), {
+//     flags: 'a',
+//     encoding: 'utf8',
+// });
+// 配置日志文件的轮转
+
+const logStream = createStream(path.join(logDirectory, 'output.log'), {
+    size: '500M',          // 设置最大文件大小为 500MB
+    compress: true,      // 自动压缩旧的日志文件
+    encoding: 'utf8',    // 设置日志文件的编码为 utf8
+    interval: '1d'       // 每天轮转一次日志
+});
+export const fileLogger = pino(
+    {
+        // 使用标准的时间戳函数并格式化为 ISO 格式
+        // timestamp: pino.stdTimeFunctions.isoTime,
+        timestamp: customTimestamp,
+    },
+    logStream
+);
+
+// 创建两个 logger 实例
+const consoleLogger = pino({
+    level: "debug", // 设置记录的最低日志级别
+    serializers: {
+        req: pino.stdSerializers.req, // 标准请求序列化器
+        res: pino.stdSerializers.res, // 标准响应序列化器
+    },
+    // timestamp: pino.stdTimeFunctions.isoTime,
+    timestamp: customTimestamp,
+    // transport: {
+    //     target: 'pino-pretty',
+    //     options: {
+    //         translateTime: true,
+    //         singleLine: true, // 强制单行输出
+    //         colorize: false,  // 禁用颜色，保持纯 JSON
+    //         ignore: 'reqId,remoteAddress,remotePort',
+    //     },
+    // },
+}, logStream);
+// const fastify = Fastify({logger: true});
+// 初始化 Fastify 实例，使用 consoleLogger 输出控制台日志
+export const fastify = Fastify({
+    logger: consoleLogger,
+});

controllers/index.js

@@ -4,6 +4,7 @@ import apiController from './api.js';
 import rootController from './root.js';
 import encoderController from './encoder.js';
 import decoderController from './decoder.js';
+import authCoderController from './authcoder.js';
 import webController from './web.js';
 
 export const registerRoutes = (fastify, options) => {
@@ -13,5 +14,6 @@ export const registerRoutes = (fastify, options) => {
     fastify.register(rootController, options);
     fastify.register(encoderController, options);
     fastify.register(decoderController, options);
+    fastify.register(authCoderController, options);
     fastify.register(webController, options);
 };

custom.json

@@ -1,5 +1,13 @@
 {
   "sites": [
+    {
+      "key": "drpyS_xvideos[密]",
+      "name": "xvideos[密](drpyS)",
+      "type": 4,
+      "api": "http://192.168.31.49:5757/api/xvideos[密]",
+      "searchable": 1,
+      "ext": ""
+    },
     {
       "key": "drpyS_人人视频",
       "name": "人人视频(drpyS)",
@@ -8,6 +16,14 @@
       "searchable": 1,
       "ext": ""
     },
+    {
+      "key": "drpyS_动漫巴士[漫]",
+      "name": "动漫巴士[漫](drpyS)",
+      "type": 4,
+      "api": "http://192.168.31.49:5757/api/动漫巴士[漫]",
+      "searchable": 1,
+      "ext": ""
+    },
     {
       "key": "drpyS_星芽短剧",
       "name": "星芽短剧(drpyS)",

docs/authCoder.md

@@ -0,0 +1,5 @@
+# V我50支付凭证生成工具
+
+1. 访问 http://localhost:5757/authcoder?len=10&number=1
+2. 将生成的结果复制到加密工具，选择aes加密
+3. 将加密后的结果放到凭证验证文件里