feat: 发布新版本

Author: Taois

README.md

@@ -1,7 +1,7 @@
 # drpyS(drpy-node)
 
 nodejs作为服务端的drpy实现。全面升级异步写法  
-~~积极开发中，每日一更~~，当前进度 `65%`  
+~~积极开发中，每日一更~~，当前进度 `66%`  
 ~~找工作中，随缘更新~~  
 上班当牛马，下班要带娃，阶段性佛系趁娃睡觉熬夜更新
 
@@ -21,6 +21,10 @@ nodejs作为服务端的drpy实现。全面升级异步写法
 
 ## 更新记录
 
+### 20250806
+
+更新至V1.2.7
+
 ### 20250805
 
 更新至V1.2.6
@@ -29,34 +33,6 @@ nodejs作为服务端的drpy实现。全面升级异步写法
 
 更新至V1.2.5
 
-### 20250801
-
-更新至V1.2.4
-
-### 20250729
-
-更新至V1.2.3
-
-### 20250728
-
-更新至V1.2.2
-
-### 20250727
-
-更新至V1.2.1
-
-全新版本，大堆特性，性能优化，稳定性增强。
-
-### 20250726
-
-更新至V1.2.0
-
-1. 支持挂载py源
-
-### 20250310
-
-更新至V1.1.23
-
 [点此查看完整更新记录](docs/updateRecord.md)
 
 **注意事项**

config/map.txt

@@ -7,6 +7,7 @@
 采集之王[合]@?type=url&params=../json/采集[zy]静态.json$1@采王zy[密]
 采集之王[合]@?type=url&params=../json/采集[密]静态.json$1$@采王成人[密]
 采集之王[合]@?type=url&params=../json/采集2024静态.json$1$@采王2024
+采集之王[合]@?type=url&params=../json/采集2025静态.json$1$@采王2025
 UC分享@?type=url&params=../json/UC分享.json@UC分享[盘]
 16wMV[听]@?type=url&params=../json/十六万歌曲.txt
 点歌欢唱[B]@?type=url&params=../json/十六万歌曲.txt

controllers/config.js

@@ -20,6 +20,7 @@ async function generateSiteJSON(options, requestHost, sub, pwd) {
     const jsDir = options.jsDir;
     const dr2Dir = options.dr2Dir;
     const pyDir = options.pyDir;
+    const catDir = options.catDir;
     const configDir = options.configDir;
     const jsonDir = options.jsonDir;
     const subFilePath = options.subFilePath;
@@ -395,6 +396,92 @@ async function generateSiteJSON(options, requestHost, sub, pwd) {
 
     }
 
+    // 根据用户是否启用cat源去生成对应配置
+    if (ENV.get('enable_cat', '1') === '1') {
+        const cat_files = readdirSync(catDir);
+        let cat_valid_files = cat_files.filter((file) => file.endsWith('.js') && !file.startsWith('_')); // 筛选出不是 "_" 开头的 .py 文件
+        // log(py_valid_files);
+        log(`开始生成catvod的t3配置，catDir:${catDir},源数量: ${cat_valid_files.length}`);
+
+        const cat_tasks = cat_valid_files.map((file) => {
+            return {
+                func: async ({file, catDir, requestHost, pwd, SitesMap}) => {
+                    const baseName = path.basename(file, '.js'); // 去掉文件扩展名
+                    const extJson = path.join(catDir, baseName + '.json');
+                    let api = `${requestHost}/cat/${file}`;
+                    let ext = existsSync(extJson) ? `${requestHost}/cat/${file}` : '';
+                    if (pwd) {
+                        api += `?pwd=${pwd}`;
+                        if (ext) {
+                            ext += `?pwd=${pwd}`;
+                        }
+                    }
+                    let ruleObject = {
+                        searchable: 1, // 固定值
+                        filterable: 1, // 固定值
+                        quickSearch: 1, // 固定值
+                    };
+                    let ruleMeta = {...ruleObject};
+                    const filePath = path.join(catDir, file);
+                    const header = await FileHeaderManager.readHeader(filePath);
+                    // console.log('py header:', header);
+                    if (!header || forceHeader) {
+                        const fileContent = await readFile(filePath, 'utf-8');
+                        const title = extractNameFromCode(fileContent) || baseName;
+                        Object.assign(ruleMeta, {
+                            title: title,
+                            lang: 'cat',
+                        });
+                        // console.log('py ruleMeta:', ruleMeta);
+                        await FileHeaderManager.writeHeader(filePath, ruleMeta);
+                    } else {
+                        Object.assign(ruleMeta, header);
+                    }
+                    if (!isLoaded) {
+                        const sizeInBytes = await FileHeaderManager.getFileSize(filePath, {humanReadable: true});
+                        console.log(`Loading RuleObject: ${filePath} fileSize:${sizeInBytes}`);
+                    }
+                    ruleMeta.title = enableRuleName ? ruleMeta.title || baseName : baseName;
+
+                    let fileSites = [];
+                    if (baseName === 'push_agent') {
+                        let key = 'push_agent';
+                        let name = `${ruleMeta.title}(cat)`;
+                        fileSites.push({key, name, ext});
+                    } else if (SitesMap.hasOwnProperty(baseName) && Array.isArray(SitesMap[baseName])) {
+                        SitesMap[baseName].forEach((it) => {
+                            let key = `catvod_${it.alias}`;
+                            let name = `${it.alias}(cat)`;
+                            let _ext = updateQueryString(ext, it.queryStr);
+                            fileSites.push({key, name, ext: _ext});
+                        });
+                    } else {
+                        let key = `catvod_${ruleMeta.title}`;
+                        let name = `${ruleMeta.title}(cat)`;
+                        fileSites.push({key, name, ext});
+                    }
+
+                    fileSites.forEach((fileSite) => {
+                        const site = {
+                            key: fileSite.key,
+                            name: fileSite.name,
+                            type: 3, // 固定值
+                            api,
+                            ...ruleMeta,
+                            ext: fileSite.ext || "", // 固定为空字符串
+                        };
+                        sites.push(site);
+                    });
+                },
+                param: {file, catDir, requestHost, pwd, SitesMap},
+                id: file,
+            };
+        });
+
+        await batchExecute(cat_tasks, listener);
+
+    }
+
     // 根据用户是否启用挂载数据源去生成对应配置
     if (ENV.get('enable_link_data', '0') === '1') {
         log(`开始挂载外部T4数据`);

docs/updateRecord.md

@@ -1,5 +1,16 @@
 # drpyS更新记录
 
+### 20250808
+
+更新至V1.2.7
+
+catvod源支持，更新部分源
+
+1. 把月亮影视的底裤扒了，它的源配置为我所用 `采集2025静态.json`
+   ，原链接为[moontv](https://github.com/LunaTechLab/MoonTV/blob/main/config.json)
+2. spider/catvod目录新增原生js支持
+3. 增加 & 修复源
+
 ### 20250805
 
 更新至V1.2.6

index.js

@@ -61,6 +61,12 @@ fastify.register(fastifyStatic, {
     }
 });
 
+fastify.register(fastifyStatic, {
+    root: catDir,
+    prefix: '/cat/', // 新的访问路径前缀
+    decorateReply: false, // 禁用 sendFile
+});
+
 // 注册插件以支持 application/x-www-form-urlencoded
 fastify.register(formBody);