feat: 修复了一些源，支持了猫源导入依赖

Author: Taois

.env.development

@@ -33,4 +33,4 @@ QQ_EMAIL =
 QQ_SMTP_AUTH_CODE =
 
 # 调试猫源
-CAT_DEBUG=0
+CAT_DEBUG=1

README.md

@@ -1,7 +1,7 @@
 # drpyS(drpy-node)
 
 nodejs作为服务端的drpy实现。全面升级异步写法  
-~~积极开发中，每日一更~~，当前进度 `73%`  
+~~积极开发中，每日一更~~，当前进度 `75%`  
 ~~找工作中，随缘更新~~  
 上班当牛马，下班要带娃，阶段性佛系趁娃睡觉熬夜更新
 
@@ -24,6 +24,10 @@ nodejs作为服务端的drpy实现。全面升级异步写法
 
 ## 更新记录
 
+### 20250815
+
+更新至V1.2.12
+
 ### 20250814
 
 更新至V1.2.11

controllers/api.js

@@ -184,6 +184,7 @@ export default (fastify, options, done) => {
                     ...resultHome,
                     // list: resultHomeVod,
                 };
+                // console.log('resultHomeVod:',resultHomeVod);
                 if (Array.isArray(resultHomeVod) && resultHomeVod.length > 0) {
                     Object.assign(result, {list: resultHomeVod})
                 }

docs/updateRecord.md

@@ -1,5 +1,19 @@
 # drpyS更新记录
 
+### 20250815
+
+更新至V1.2.12
+
+关键更新说明: 前面版本不支持cat源内import其他依赖，相对路径都不支持更别说 assets开头的了。
+此版本解决了，用法跟壳子一样，支持`assets://`（映射到spider/catLib） 和相对路径 `./` `../`开头的依赖
+
+1. 修复 `番茄小说` 分类 by 二群 `ƪ(˘⌣˘)ʃ优雅`
+2. 修复 `抖音弹幕直播` by 二群 `ƪ(˘⌣˘)ʃ优雅`
+3. catvod猫源支持import assets开头依赖，ds非调试模式下已经补齐依赖。
+4. 增加 `esm-register.mjs` 通过拦截import导入的esm模块，实现猫源的 `assets:` 导入识别，路径映射到 `spider/catLib`
+5. 增加 cat源 `河南电视代理.js` 用于演示正确的猫源本代写法。action也支持。
+6. 修复猫源T4首页推荐数据问题。
+
 ### 20250814
 
 更新至V1.2.11
@@ -8,7 +22,8 @@
 2. `cat源` 增加调试模式，但是不支持 `getProxyUrl` 等方法，需要在环境变量.env文件里启用 `CAT_DEBUG=1`。
    详情参考 [猫源调试教程](/docs/catDebug.md)
 3. `getProxyUrl` 换成 `getProxy`，兼容T3猫源使用壳子的本地代理,修复 `央视大全` 错误的本地代理获取
-4. 修复`番茄小说` 的正文阅读和搜索。分类接口坏的没能力修。央视最新视频高清下载方案目前只有通过 [`CCTV-GO`](https://wwvy.lanzouo.com/ieEq533kiofe) 包含的 `cbox.exe` 本地解密，无法适配本项目。
+4. 修复`番茄小说` 的正文阅读和搜索。分类接口坏的没能力修。央视最新视频高清下载方案目前只有通过 [
+   `CCTV-GO`](https://wwvy.lanzouo.com/ieEq533kiofe) 包含的 `cbox.exe` 本地解密，无法适配本项目。
 
 ### 20250813
 

index.js

@@ -6,6 +6,8 @@ import qs from 'qs';
 import {fileURLToPath} from 'url';
 import formBody from '@fastify/formbody';
 import {validateBasicAuth, validateJs, validatePwd} from "./utils/api_validate.js";
+// 注册自定义import钩子
+import './utils/esm-register.mjs';
 // 注册控制器
 import {registerRoutes} from './controllers/index.js';
 

libs/catvod.js

@@ -25,33 +25,56 @@ const json2Object = function (json) {
     return JSON.parse(json);
 }
 
-const loadEsmWithHash = async function (filePath, fileHash) {
+const loadEsmWithHash = async function (filePath, fileHash, env) {
     const scriptUrl = `${pathToFileURL(filePath).href}?v=${fileHash}`;
-    return await import(scriptUrl);
+    const module = await import(scriptUrl);
+    const initEnv = module.initEnv;
+    if (typeof initEnv === 'function' && env) {
+        initEnv(env);
+    }
+    return module
 }
 
 const loadEsmWithEnv = async function (filePath, env) {
     const rawCode = await readFile(filePath, 'utf8');
     let injectedCode = rawCode;
+    // let injectedCode = rawCode.replaceAll('assets://js/lib/', '../catLib/'); // esm-rregister处理了，这里不管
+    // console.log('loadEsmWithEnv:', env);
     const esm_flag1 = 'export function __jsEvalReturn';
     const esm_flag2 = 'export default';
     const polyfill_code = `
 var _ENV={};
 var getProxyUrl=null;
 var getProxy=null;
-export const initEnv = (env)=>{
+export function initEnv(env){
     _ENV = env;
     if(env.getProxyUrl){
         getProxyUrl=env.getProxyUrl;
         getProxy=env.getProxyUrl
     }
-};`.trim() + '\n';
-    if (rawCode.includes(esm_flag1)) {
-        injectedCode = rawCode.replace(esm_flag1, `${polyfill_code}${esm_flag1}`)
-    } else if (rawCode.includes('export default')) {
-        injectedCode = rawCode.replace(esm_flag2, `${polyfill_code}${esm_flag2}`)
+}`.trim() + '\n';
+    if (injectedCode.includes(esm_flag1)) {
+        injectedCode = injectedCode.replace(esm_flag1, `${polyfill_code}${esm_flag1}`)
+    } else if (injectedCode.includes('export default')) {
+        injectedCode = injectedCode.replace(esm_flag2, `${polyfill_code}${esm_flag2}`)
     }
-    // console.log(injectedCode);
+
+    // 改为在 esm-register.mjs 里实现，这里注释掉
+    // if (injectedCode.includes('../catLib/crypto-js.js')) {
+    //     const cryptoJsPath = path.join(_lib_path, '../catLib', 'crypto-js.js');
+    //     // console.log('cryptoJsPath:',cryptoJsPath);
+    //     const cryptoHref = pathToFileURL(cryptoJsPath).href;
+    //     console.log('cryptoHref:', cryptoHref);
+    //     // const cryptoJsCode = await readFile(cryptoJsPath, 'utf-8');
+    //     // const cryptoJsBase64 = Buffer.from(cryptoJsCode).toString('base64');
+    //     injectedCode = injectedCode.replace(
+    //         '../catLib/crypto-js.js',
+    //         // `data:text/javascript;base64,${cryptoJsBase64}`
+    //         cryptoHref
+    //     );
+    // }
+
+    // console.log('injectedCode:\n', injectedCode);
     // // 创建数据URI模块
     const dataUri = `data:text/javascript;base64,${Buffer.from(injectedCode).toString('base64')}`;
     const module = await import(dataUri);
@@ -73,6 +96,12 @@ const init = async function (filePath, env = {}, refresh) {
         const fileHash = computeHash(fileContent);
         const moduleName = path.basename(filePath, '.js');
         let moduleExt = env.ext || '';
+        const default_init_cfg = {
+            stype: 4, //T3/T4 源类型
+            skey: `catvod_${moduleName}`,
+            sourceKey: `catvod_${moduleName}`,
+            ext: moduleExt,
+        };
         let SitesMap = getSitesMap(_config_path);
         if (moduleExt && SitesMap[moduleName]) {
             try {
@@ -96,7 +125,7 @@ const init = async function (filePath, env = {}, refresh) {
         let t1 = getNowTime();
         let module;
         if (enable_cat_debug) {
-            module = await loadEsmWithHash(filePath, fileHash);
+            module = await loadEsmWithHash(filePath, fileHash, env);
         } else {
             module = await loadEsmWithEnv(filePath, env);
         }
@@ -111,7 +140,7 @@ const init = async function (filePath, env = {}, refresh) {
         // console.log('globalThis.ENV:', globalThis.ENV);
         // console.log('globalThis.getProxyUrl:', globalThis.getProxyUrl);
         // 加载 init
-        await rule.init(moduleExt || {});
+        await rule.init(default_init_cfg);
         let t2 = getNowTime();
         const moduleObject = deepCopy(rule);
         moduleObject.cost = t2 - t1;
@@ -130,7 +159,8 @@ const home = async function (filePath, env, filter = 1) {
 
 const homeVod = async function (filePath, env) {
     const moduleObject = await init(filePath, env);
-    return json2Object(await moduleObject.homeVod());
+    const homeVodResult = json2Object(await moduleObject.homeVod());
+    return homeVodResult && homeVodResult.list ? homeVodResult.list : homeVodResult;
 }
 
 

libs_drpy/drpyInject.js

@@ -3,7 +3,7 @@ import axiosX from './axios.min.js';
 import crypto from 'crypto';
 import http from "http";
 import https from 'https';
-import fs from 'node:fs';
+import fs from 'fs';
 import qs from 'qs';
 import _ from './underscore-esm.min.js'
 // import _ from './underscore-esm.js'

package.json

@@ -1,13 +1,14 @@
 {
   "name": "drpy-node",
-  "version": "1.2.11",
+  "version": "1.2.12",
   "main": "index.js",
   "type": "module",
   "scripts": {
     "build": "node index.js",
     "dev": "node index.js",
     "dev-win": "chcp 65001 && node --trace-deprecation index.js",
     "dev-win-debug": "chcp 65001 && node --trace-deprecation --inspect index.js",
+    "dev-win-debug2": "chcp 65001 && node --trace-deprecation --inspect --experimental-loader ./utils/esm-loader.mjs index.js",
     "pm2": "pm2 start index.js --name drpys",
     "node22": "node --experimental-sqlite index.js",
     "node22-win": "chcp 65001 && node --trace-deprecation --experimental-sqlite index.js",

public/index.html

@@ -8,7 +8,7 @@
                 </head>
                 <body>
                     <h1 id="drpysdrpy-node">drpyS(drpy-node)</h1>
-<p>nodejs作为服务端的drpy实现。全面升级异步写法<br><del>积极开发中，每日一更</del>，当前进度 <code>72%</code><br><del>找工作中，随缘更新</del><br>上班当牛马，下班要带娃，阶段性佛系趁娃睡觉熬夜更新</p>
+<p>nodejs作为服务端的drpy实现。全面升级异步写法<br><del>积极开发中，每日一更</del>，当前进度 <code>75%</code><br><del>找工作中，随缘更新</del><br>上班当牛马，下班要带娃，阶段性佛系趁娃睡觉熬夜更新</p>
 <ul>
 <li><a href="docs/apidoc.md">接口文档</a> | <a href="docs/apiList.md">接口列表如定时任务</a> | <a href="https://github.com/waifu-project/movie/pull/135">小猫影视-待对接T4</a></li>
 <li><a href="/config?pwd=dzyyds">本地配置接口-动态本地</a></li>
@@ -28,6 +28,8 @@ <h1 id="drpysdrpy-node">drpyS(drpy-node)</h1>
 <li><a href="/cat/index.html">在线猫ds源主页</a></li>
 </ul>
 <h2 id="更新记录">更新记录</h2>
+<h3 id="20250815">20250815</h3>
+<p>更新至V1.2.12</p>
 <h3 id="20250814">20250814</h3>
 <p>更新至V1.2.11</p>
 <h3 id="20250813">20250813</h3>