update:升级AI支持

Author: hjdhnx

.env.development

@@ -8,5 +8,8 @@ LOG_WITH_FILE = 1
 # trace/debug/info/warn/error/fatal
 LOG_LEVEL = info
 COOKIE_AUTH_CODE = drpys
+API_AUTH_NAME = admin
+API_AUTH_CODE = drpys
+API_PWD = dzyyds
 LIVE_URL = 'https://livetv.wqwqwq.sbs/tv.m3u'
 # LIVE_URL = './lives/tv.m3u'

README.md

@@ -3,23 +3,24 @@
 nodejs作为服务端的drpy实现。全面升级异步写法  
 积极开发中，每日一更，当前进度 `23%`
 
-* [本地配置接口-动态本地](/config)
-* [本地配置接口-动态外网/局域网](/config/1)
+* [本地配置接口-动态本地](/config?pwd=)
+* [本地配置接口-动态外网/局域网](/config/1?pwd=)
 * [其他配置接口-订阅过滤](/docs/sub.md)
 * [代码加解密工具](/admin/encoder)
 * [V我50支付凭证生成器](/authcoder?len=10&number=1)
 * [接口压测教程](/docs/httpTest.md)
 * [央视点播解析工具](/proxy/央视大全[官]/index.html)
 * [cookie管理插件](/apps/cookie-butler/index.html)
+* [本站防止爬虫协议](/robots.txt)
 
 ## 更新记录
 
-### 20241230
+### 20241231
 
-更新至V1.0.26
+更新至V1.0.27
 
-1. 设置中心优化，样式适配装逼壳。并支持全局站源动作
-2. 新增AI动作交互，用设置中心的连续对话即可测试
+1. Ai多样化
+2. 接口授权支持
 
 [点此查看完整更新记录](docs/updateRecord.md)
 
@@ -46,6 +47,7 @@ todo:
 * [crypto-js-wasm使用教程](docs/crypto-js-wasm/readme-CN.md)
 * [puppeteer使用教程](docs/pupInstall.md)
 * [drpyS源属性说明](docs/ruleAttr.md)
+* [drpy2写源简述](docs/ruleDesc.md)
 * [讯飞星火开放平台](https://console.xfyun.cn/services/bm4)
 * [讯飞星火智能体数据集](https://xinghuo.xfyun.cn/botcenter/private-dataset)
 

controllers/api.js

@@ -3,12 +3,14 @@ import {existsSync} from 'fs';
 import {base64Decode} from '../libs_drpy/crypto-util.js';
 import * as drpy from '../libs/drpyS.js';
 import {ENV} from "../utils/env.js";
+import {validatePwd} from "../utils/api_validate.js";
 
 export default (fastify, options, done) => {
     // 动态加载模块并根据 query 执行不同逻辑
     fastify.route({
         method: ['GET', 'POST'], // 同时支持 GET 和 POST
         url: '/api/:module',
+        preHandler: validatePwd,
         schema: {
             consumes: ['application/json', 'application/x-www-form-urlencoded'], // 声明支持的内容类型
         },

controllers/config.js

@@ -3,9 +3,10 @@ import path from 'path';
 import * as drpy from '../libs/drpyS.js';
 import {naturalSort, urljoin} from '../utils/utils.js'
 import {ENV} from "../utils/env.js";
+import {validatePwd} from "../utils/api_validate.js";
 
 // 工具函数：生成 JSON 数据
-async function generateSiteJSON(jsDir, requestHost, sub, subFilePath) {
+async function generateSiteJSON(jsDir, requestHost, sub, subFilePath, pwd) {
     const files = readdirSync(jsDir);
     let valid_files = files.filter((file) => file.endsWith('.js') && !file.startsWith('_')); // 筛选出不是 "_" 开头的 .js 文件
     let sort_list = [];
@@ -42,7 +43,10 @@ async function generateSiteJSON(jsDir, requestHost, sub, subFilePath) {
         const baseName = path.basename(file, '.js'); // 去掉文件扩展名
         let key = `drpyS_${baseName}`;
         let name = `${baseName}(DS)`;
-        const api = `${requestHost}/api/${baseName}`;  // 使用请求的 host 地址，避免硬编码端口
+        let api = `${requestHost}/api/${baseName}`;  // 使用请求的 host 地址，避免硬编码端口
+        if (pwd) {
+            api += `?pwd=${pwd}`;
+        }
         let ruleObject = {
             searchable: 0, // 固定值
             filterable: 0, // 固定值
@@ -168,7 +172,7 @@ function getSubs(subFilePath) {
 
 export default (fastify, options, done) => {
 
-    fastify.get('/index', async (request, reply) => {
+    fastify.get('/index', {preHandler: validatePwd}, async (request, reply) => {
         if (!existsSync(options.indexFilePath)) {
             reply.code(404).send({error: 'index.json not found'});
             return;
@@ -179,9 +183,10 @@ export default (fastify, options, done) => {
     });
 
     // 接口：返回配置 JSON，同时写入 index.json
-    fastify.get('/config*', async (request, reply) => {
+    fastify.get('/config*', {preHandler: validatePwd}, async (request, reply) => {
         let t1 = (new Date()).getTime();
         const query = request.query; // 获取 query 参数
+        const pwd = query.pwd || '';
         const sub_code = query.sub || '';
         const cfg_path = request.params['*']; // 捕获整个路径
         try {
@@ -201,7 +206,7 @@ export default (fastify, options, done) => {
                 }
             }
 
-            const siteJSON = await generateSiteJSON(options.jsDir, requestHost, sub, options.subFilePath);
+            const siteJSON = await generateSiteJSON(options.jsDir, requestHost, sub, options.subFilePath, pwd);
             const parseJSON = generateParseJSON(options.jxDir, requestHost);
             const livesJSON = generateLivesJSON(requestHost);
             const playerJSON = generatePlayerJSON(options.configDir, requestHost);

controllers/root.js

@@ -2,10 +2,11 @@ import path from 'path';
 import {readdirSync, readFileSync, writeFileSync, existsSync} from 'fs';
 import '../utils/marked.min.js';
 import {computeHash} from '../utils/utils.js';
+import {validateBasicAuth} from "../utils/api_validate.js";
 
 export default (fastify, options, done) => {
     // 添加 / 接口
-    fastify.get('/', async (request, reply) => {
+    fastify.get('/', {preHandler: validateBasicAuth}, async (request, reply) => {
         let readmePath = null;
         const indexHtmlPath = path.join(options.rootDir, 'public/index.html');
         // console.log(`indexHtmlPath:${indexHtmlPath}`);
@@ -62,6 +63,11 @@ export default (fastify, options, done) => {
         reply.type('text/html;charset=utf-8').send(indexHtml);
     });
 
+    // 新增 /robots.txt 路由
+    fastify.get('/robots.txt', (request, reply) => {
+        reply.type('text/plain;charset=utf-8').sendFile('robots.txt', path.join(options.rootDir, 'public'));
+    });
+
     // 新增 /favicon.ico 路由
     fastify.get('/favicon.ico', async (request, reply) => {
         try {

custom.json

@@ -1,5 +1,5 @@
 {
-  "sites_count": 37,
+  "sites_count": 40,
   "sites": [
     {
       "key": "drpyS_设置中心",
@@ -14,7 +14,7 @@
         "actions": [
           {
             "name": "连续对话",
-            "action": "{\"actionId\":\"连续对话\",\"id\":\"talk\",\"type\":\"input\",\"title\":\"连续对话\",\"tip\":\"请输入消息\",\"value\":\"\",\"msg\":\"开始新的对话\",\"button\":3,\"imageUrl\":\"https://img2.baidu.com/it/u=1206278833,3265480730&fm=253&fmt=auto&app=120&f=JPEG?w=800&h=800\",\"imageHeight\":200,\"imageType\":\"card_pic_3\",\"keep\":true}"
+            "action": "{\"actionId\":\"连续对话\",\"id\":\"talk\",\"type\":\"input\",\"title\":\"连续对话\",\"tip\":\"请输入消息\",\"value\":\"\",\"msg\":\"开始新的对话\",\"button\":3,\"imageUrl\":\"https://img2.baidu.com/it/u=1206278833,3265480730&fm=253&fmt=auto&app=120&f=JPEG?w=800&h=800\",\"imageHeight\":200,\"imageType\":\"card_pic_3\",\"keep\":true,\"width\":680,\"height\":800,\"msgType\":\"long_text\",\"httpTimeout\":60,\"canceledOnTouchOutside\":false}"
           },
           {
             "name": "查看夸克cookie",
@@ -156,6 +156,16 @@
       "quickSearch": 0,
       "ext": ""
     },
+    {
+      "key": "drpyS_火车太堵",
+      "name": "火车太堵(DS)",
+      "type": 4,
+      "api": "http://localhost:5757/api/火车太堵",
+      "searchable": 1,
+      "filterable": 0,
+      "quickSearch": 0,
+      "ext": ""
+    },
     {
       "key": "drpyS_荐片",
       "name": "荐片(DS)",
@@ -256,6 +266,16 @@
       "quickSearch": 0,
       "ext": ""
     },
+    {
+      "key": "drpyS_团长资源[盘]",
+      "name": "团长资源[盘](DS)",
+      "type": 4,
+      "api": "http://localhost:5757/api/团长资源[盘]",
+      "searchable": 1,
+      "filterable": 0,
+      "quickSearch": 1,
+      "ext": ""
+    },
     {
       "key": "push_agent",
       "name": "推送(DS)",
@@ -326,6 +346,16 @@
       "quickSearch": 0,
       "ext": ""
     },
+    {
+      "key": "drpyS_专享影视",
+      "name": "专享影视(DS)",
+      "type": 4,
+      "api": "http://localhost:5757/api/专享影视",
+      "searchable": 1,
+      "filterable": 0,
+      "quickSearch": 0,
+      "ext": ""
+    },
     {
       "key": "drpyS_ACG漫画网[画]",
       "name": "ACG漫画网[画](DS)",