update:增加自动端口，增加hipy嗅探器支持

Author: hjdhnx

README.md

@@ -46,3 +46,29 @@ yarn build
 ### 20250118
 
 1. 支持通用嗅探
+
+### hipy嗅探器说明
+
+支持参数如下
+
+```text
+let init_js = `Object.defineProperties(navigator, {platform: {get: () => 'iPhone'}});`;
+input = {
+    parse: 1,
+    url: input,
+    js: `try{location.href = document.querySelectorAll("iframe")[1].src;}catch(err) {}document.querySelector(".line").click()`,
+    parse_extra: '&init_script=' + encodeURIComponent(base64Encode(init_js)),
+}
+```
+
+* script 嗅探过程中需要执行的点击操作，传递值为base64编码后的js脚本
+
+parse_extra 额外的自定义query字符串如下
+
+* is_pc
+* css
+* init_script base64编码的初始化执行脚本
+* headers 嗅探请求头
+* timeout 嗅探超时
+* custom_regex 自定义嗅探规则正则
+* sniffer_exclude 嗅探排除规则正则

nodejs/package.json

@@ -4,7 +4,7 @@
     "description": "CatVodOpen nodejs config api server demo.",
     "type": "module",
     "scripts": {
-        "dev": "cross-env DEV_HTTP_PORT=3006 nodemon --config nodemon.json src/dev.js",
+        "dev": "cross-env DEV_HTTP_PORT=5758 nodemon --config nodemon.json src/dev.js",
         "_build": "rimraf dist && node esbuild.js && node esbuild-config.js",
         "build": "cross-env NODE_ENV=production npm run _build && node copyDist.js D:\\soft\\猫影视\\Release\\data\\flutter_assets\\asset\\js",
         "build:copy": "cross-env NODE_ENV=production npm run _build && node copyDist.js D:\\soft\\猫影视\\Release\\data\\flutter_assets\\asset\\js",

nodejs/src/index.config.js

@@ -5,6 +5,8 @@ export default {
         enable_dspush: 1,
         enable_home_site: 0,
         sniffer_rule: 'http((?!http).){12,}?\\.(m3u8|mp4|flv|avi|mkv|rm|wmv|mpg|m4a|mp3)\\?.*|http((?!http).){12,}\\.(m3u8|mp4|flv|avi|mkv|rm|wmv|mpg|m4a|mp3)|http((?!http).)*?video/tos*|http((?!http).)*?obj/tos*',
+        enable_hipy_sniffer: 0,
+        hipy_sniffer_url: 'http://127.0.0.1:5708/sniffer?url=',
     },
     ffm3u8: {
         url: 'https://cj.ffzyapi.com/api.php/provide/vod/from/ffm3u8',

nodejs/src/index.js

@@ -2,6 +2,7 @@ import fastify from 'fastify';
 import router from './router.js';
 import {JsonDB, Config} from 'node-json-db';
 import axios from 'axios';
+import {findAvailablePort} from './util/tool.js';
 
 let server = null;
 
@@ -58,8 +59,11 @@ export async function start(config) {
     // 推荐使用NODE_PATH做db存储的更目录，这个目录在应用中清除缓存时会被清空
     server.db = new JsonDB(new Config((process.env['NODE_PATH'] || '.') + '/db.json', true, true, '/', true));
     server.register(router);
+    const startPort = process.env['DEV_HTTP_PORT'] || 5758;
+    const availablePort = await findAvailablePort(startPort);
     // 注意 一定要监听ipv4地址 build后 app中使用时 端口使用0让系统自动分配可用端口
-    server.listen({port: process.env['DEV_HTTP_PORT'] || 0, host: '::'});
+    // server.listen({port: process.env['DEV_HTTP_PORT'] || 0, host: '::'});
+    server.listen({port: availablePort, host: '::'});
 }
 
 /**

nodejs/src/spider/video/drpyS.js

@@ -257,32 +257,57 @@ async function play(_inReq, _outResp) {
             if (realUrl && regex.test(realUrl)) {
                 result.parse = 0;
             } else if (realUrl && !regex.test(realUrl)) {
-                const sniffer = await inReq.server.messageToDart({
-                    action: 'sniff',
-                    opt: {
+                if (cfg.default.drpyS.enable_hipy_sniffer && cfg.default.drpyS.hipy_sniffer_url) {
+                    const _js = result.js;
+                    const _parse_extra = result.parse_extra;
+                    const _query = {
                         url: realUrl,
-                        timeout: 10000,
-                        rule: sniffer_rule,
-                    },
-                });
-                if (sniffer && sniffer.url) {
-                    const hds = {};
-                    if (sniffer.headers) {
-                        if (sniffer.headers['user-agent']) {
-                            hds['User-Agent'] = sniffer.headers['user-agent'];
-                        }
-                        if (sniffer.headers['referer']) {
-                            hds['Referer'] = sniffer.headers['referer'];
+                        script: _js ? base64Encode(_js) : undefined,
+                    }
+                    let _url = mergeQuery(cfg.default.drpyS.hipy_sniffer_url, _query);
+                    if (_parse_extra) {
+                        _url += _parse_extra;
+                    }
+                    try {
+                        let _result = await request(_url);
+                        console.log(`hipy嗅探器任务执行${_url} 完毕: ${_result.url}`);
+                        return {
+                            parse: 0,
+                            url: _result.url,
+                            header: _result.headers
                         }
-                        if (sniffer.headers['cookie']) {
-                            hds['Cookie'] = sniffer.headers['cookie'];
+                    } catch (e) {
+                        console.log(`hipy嗅探器嗅探错误: ${e.message}`);
+                    }
+
+                } else {
+                    const sniffer = await _inReq.server.messageToDart({
+                        action: 'sniff',
+                        opt: {
+                            url: realUrl,
+                            timeout: 10000,
+                            rule: sniffer_rule,
+                        },
+                    });
+                    if (sniffer && sniffer.url) {
+                        const hds = {};
+                        if (sniffer.headers) {
+                            if (sniffer.headers['user-agent']) {
+                                hds['User-Agent'] = sniffer.headers['user-agent'];
+                            }
+                            if (sniffer.headers['referer']) {
+                                hds['Referer'] = sniffer.headers['referer'];
+                            }
+                            if (sniffer.headers['cookie']) {
+                                hds['Cookie'] = sniffer.headers['cookie'];
+                            }
                         }
+                        return {
+                            parse: 0,
+                            url: sniffer.url,
+                            header: hds,
+                        };
                     }
-                    return {
-                        parse: 0,
-                        url: sniffer.url,
-                        header: hds,
-                    };
                 }
             }
         }

nodejs/src/util/tool.js

@@ -1,3 +1,28 @@
+import net from 'net';
+
+// 检查端口是否被占用
+function checkPort(port) {
+    return new Promise((resolve) => {
+        const server = net.createServer();
+        server.once('error', () => {
+            resolve(false); // 端口被占用
+        });
+        server.once('listening', () => {
+            server.close(() => resolve(true)); // 端口可用
+        });
+        server.listen(port);
+    });
+}
+
+// 查找可用端口
+export async function findAvailablePort(startPort) {
+    let port = Number(startPort);
+    while (!(await checkPort(port))) {
+        port += 1; // 递增端口
+    }
+    return port;
+}
+
 export function extractTags(filename) {
     // 正则匹配方括号内的内容
     const regex = /\[(.*?)\]/g;