update:发布1.1.4版本

Author: hjdhnx

README.md

@@ -1,7 +1,7 @@
 # drpyS(drpy-node)
 
 nodejs作为服务端的drpy实现。全面升级异步写法  
-积极开发中，每日一更，当前进度 `29%`
+积极开发中，每日一更，当前进度 `30%`
 
 * [本地配置接口-动态本地](/config?pwd=)
 * [本地配置接口-动态外网/局域网](/config/1?pwd=)
@@ -16,12 +16,13 @@ nodejs作为服务端的drpy实现。全面升级异步写法
 
 ## 更新记录
 
-### 20250107
+### 20250108
 
-更新至V1.1.3
+更新至V1.1.4
 
-1. req系列函数修复
-2. 增加新源，优化推送
+1. 更新文档
+2. 修复bug
+3. 增加 `batchExecute`
 
 [点此查看完整更新记录](docs/updateRecord.md)
 
@@ -112,3 +113,22 @@ pm2 restart drpys
 * [代理转发ds](/req/https://github.com/hjdhnx/drpy-node)
 * [代理转发百度](/req/https://www.baidu.com)
 * [代理转发范冰冰直播源](/req/https://live.fanmingming.com/tv/m3u/ipv6.m3u)
+
+## 友链(白嫖接口服务)
+
+* [猫影视git文件加速](https://github.catvod.com/)
+* [猫影视多功能主页](https://catvod.com/)
+
+## 版权
+
+本项目主体框架由道长开发，项目内相关源收集于互联网，可供学习交流测试使用，禁止商用或者直接转卖代码，转载代码请带上出处。
+
+## 免责声明
+
+1. 此程序仅用于学习研究，不保证其合法性、准确性、有效性，请根据情况自行判断，本人对此不承担任何保证责任。
+2. 由于此程序仅用于学习研究，您必须在下载后 24 小时内将所有内容从您的计算机或手机或任何存储设备中完全删除，若违反规定引起任何事件本人对此均不负责。
+3. 请勿将此程序用于任何商业或非法目的，若违反规定请自行对此负责。
+4. 此程序涉及应用与本人无关，本人对因此引起的任何隐私泄漏或其他后果不承担任何责任。
+5. 本人对任何程序引发的问题概不负责，包括但不限于由程序错误引起的任何损失和损害。
+6. 如果任何单位或个人认为此程序可能涉嫌侵犯其权利，应及时通知并提供身份证明，所有权证明，我们将在收到认证文件确认后删除此程序。
+7. 所有直接或间接使用、查看此程序的人均应该仔细阅读此声明。本人保留随时更改或补充此声明的权利。一旦您使用或复制了此程序，即视为您已接受此免责声明。

controllers/api.js

@@ -25,6 +25,7 @@ export default (fastify, options, done) => {
             // 根据请求方法选择参数来源
             const query = method === 'GET' ? request.query : request.body;
             const moduleExt = query.extend || '';
+            // console.log('moduleExt:', typeof moduleExt, moduleExt);
             const protocol = request.protocol;
             const hostname = request.hostname;
             // const proxyUrl = `${protocol}://${hostname}${request.url}`.split('?')[0].replace('/api/', '/proxy/') + '/?do=js';

controllers/config.js

@@ -5,6 +5,7 @@ import {naturalSort, urljoin} from '../utils/utils.js'
 import {ENV} from "../utils/env.js";
 import {validatePwd} from "../utils/api_validate.js";
 import {getSitesMap} from "../utils/sites-map.js";
+import batchExecute from '../libs_drpy/batchExecute.js';
 
 const {jsEncoder} = drpy;
 
@@ -44,66 +45,78 @@ async function generateSiteJSON(jsDir, configDir, requestHost, sub, subFilePath,
     }
     let SitesMap = getSitesMap(configDir);
     // console.log(SitesMap);
-    // 使用 Promise.all 并发执行文件的处理
-    const filePromises = valid_files.map(async (file) => {
-        const baseName = path.basename(file, '.js'); // 去掉文件扩展名
-        let api = `${requestHost}/api/${baseName}`;  // 使用请求的 host 地址，避免硬编码端口
-        if (pwd) {
-            api += `?pwd=${pwd}`;
-        }
-        let ruleObject = {
-            searchable: 0, // 固定值
-            filterable: 0, // 固定值
-            quickSearch: 0, // 固定值
-        };
-        try {
-            ruleObject = await drpy.getRuleObject(path.join(jsDir, file));
-            // console.log(file, ruleObject.title);
-        } catch (e) {
-            console.log(`file:${file} error:${e.message}`);
-        }
-        let fileSites = [];
-        if (baseName === 'push_agent') {
-            let key = 'push_agent';
-            let name = `${ruleObject.title}(DS)`;
-            fileSites.push({key, name})
-        } else if (SitesMap.hasOwnProperty(baseName) && Array.isArray(SitesMap[baseName])) {
-            SitesMap[baseName].forEach((it) => {
-                let key = `drpyS_${it.alias}`;
-                let name = `${it.alias}(DS)`;
-                let ext = '';
-                if (it.queryObject.type === 'url') {
-                    ext = it.queryObject.params;
-                } else {
-                    ext = it.queryStr;
+    const tasks = valid_files.map((file) => {
+        return {
+            func: async ({file, jsDir, requestHost, pwd, drpy, SitesMap, jsEncoder}) => {
+                const baseName = path.basename(file, '.js'); // 去掉文件扩展名
+                let api = `${requestHost}/api/${baseName}`;  // 使用请求的 host 地址，避免硬编码端口
+                if (pwd) {
+                    api += `?pwd=${pwd}`;
                 }
-                if (ext) {
-                    ext = jsEncoder.gzip(ext);
+                let ruleObject = {
+                    searchable: 0, // 固定值
+                    filterable: 0, // 固定值
+                    quickSearch: 0, // 固定值
+                };
+                try {
+                    ruleObject = await drpy.getRuleObject(path.join(jsDir, file));
+                } catch (e) {
+                    throw new Error(`Error parsing rule object for file: ${file}, ${e.message}`);
                 }
-                fileSites.push({key: key, name: name, ext: ext})
-            });
-        } else {
-            let key = `drpyS_${baseName}`;
-            let name = `${baseName}(DS)`;
-            fileSites.push({key, name})
-        }
-        fileSites.forEach((fileSite) => {
-            const site = {
-                key: fileSite.key,
-                name: fileSite.name,
-                type: 4, // 固定值
-                api,
-                searchable: ruleObject.searchable,
-                filterable: ruleObject.filterable,
-                quickSearch: ruleObject.quickSearch,
-                more: ruleObject.more,
-                ext: fileSite.ext || "", // 固定为空字符串
-            };
-            sites.push(site);
-        });
+
+                let fileSites = [];
+                if (baseName === 'push_agent') {
+                    let key = 'push_agent';
+                    let name = `${ruleObject.title}(DS)`;
+                    fileSites.push({key, name});
+                } else if (SitesMap.hasOwnProperty(baseName) && Array.isArray(SitesMap[baseName])) {
+                    SitesMap[baseName].forEach((it) => {
+                        let key = `drpyS_${it.alias}`;
+                        let name = `${it.alias}(DS)`;
+                        let ext = it.queryObject.type === 'url' ? it.queryObject.params : it.queryStr;
+                        if (ext) {
+                            ext = jsEncoder.gzip(ext);
+                        }
+                        fileSites.push({key, name, ext});
+                    });
+                } else {
+                    let key = `drpyS_${baseName}`;
+                    let name = `${baseName}(DS)`;
+                    fileSites.push({key, name});
+                }
+
+                fileSites.forEach((fileSite) => {
+                    const site = {
+                        key: fileSite.key,
+                        name: fileSite.name,
+                        type: 4, // 固定值
+                        api,
+                        searchable: ruleObject.searchable,
+                        filterable: ruleObject.filterable,
+                        quickSearch: ruleObject.quickSearch,
+                        more: ruleObject.more,
+                        ext: fileSite.ext || "", // 固定为空字符串
+                    };
+                    sites.push(site);
+                });
+            },
+            param: {file, jsDir, requestHost, pwd, drpy, SitesMap, jsEncoder},
+            id: file,
+        };
     });
-    // 等待所有的文件处理完成
-    await Promise.all(filePromises);
+
+    const listener = {
+        func: (param, id, error, result) => {
+            if (error) {
+                console.error(`Error processing file ${id}:`, error.message);
+            } else {
+                // console.log(`Successfully processed file ${id}:`, result);
+            }
+        },
+        param: {}, // 外部参数可以在这里传入
+    };
+
+    await batchExecute(tasks, listener);
     // 订阅再次处理别名的情况
     if (sub) {
         if (sub.mode === 0) {