update:修正规则类型可以看小说

hjdhnx · hjdhnx · commit 81f0b835938a · 2024-12-03T12:04:36.000+08:00
diff --git a/README.md b/README.md
@@ -2,9 +2,12 @@
 
 nodejs作为服务端的drpy实现。全面升级异步写法
 
+[本地配置接口](/config)
+
 ## 更新记录
 
 20241203
+
 1. 新增misc工具类
 2. 新增utils工具类
 3. 更新atob、btoa函数逻辑
@@ -24,10 +27,10 @@ todo:
 2. js里的源，像一级这种异步js，里面调用未定义的函数，能否不通过函数参数传入直接注入调用
 3. 在源的各个函数调用的时候动态注入input、MY_URL等局部变量不影响全局。搞了半天没成功，有点难受，待解决
 
-
 写源的函数不可以使用箭头函数，箭头函数无法拿到this作用域就没法获取input和MY_URL变量
 
 精简去除的库:
+
 1. axios
 2. jsonpath
 3. underscore
diff --git a/custom.json b/custom.json
@@ -0,0 +1,20 @@
+{
+  "sites": [
+    {
+      "key": "drpyS_番茄小说",
+      "name": "番茄小说(drpyS)",
+      "type": 4,
+      "api": "http://127.0.0.1:5757/api/番茄小说[书]",
+      "searchable": 1,
+      "ext": ""
+    },
+    {
+      "key": "drpyS_金牌影视",
+      "name": "金牌影视(drpyS)",
+      "type": 4,
+      "api": "http://127.0.0.1:5757/api/金牌影视",
+      "searchable": 1,
+      "ext": ""
+    }
+  ]
+}
diff --git a/index.js b/index.js
@@ -9,8 +9,13 @@ import './utils/marked.min.js';
 
 const fastify = Fastify({logger: true});
 
+const PORT = 5757;
 const __dirname = path.dirname(fileURLToPath(import.meta.url));
 console.log('__dirname:', __dirname);
+// 配置目标目录
+const jsDir = path.join(__dirname, 'js');
+console.log('jsDir:', jsDir);
+
 
 // 添加 / 接口
 fastify.get('/', async (request, reply) => {
@@ -53,6 +58,38 @@ fastify.get('/', async (request, reply) => {
             `);
 });
 
+// 工具函数：生成 JSON 数据
+function generateSiteJSON() {
+    const files = readdirSync(jsDir);
+    const sites = files
+        .filter((file) => file.endsWith('.js') && !file.startsWith('_')) // 筛选出不是 "_" 开头的 .js 文件
+        .map((file) => {
+            const baseName = path.basename(file, '.js'); // 去掉文件扩展名
+            const key = `drpyS_${baseName}`;
+            const name = `${baseName}(drpyS)`;
+            const api = `http://127.0.0.1:${PORT}/api/${baseName}`;
+            return {
+                key,
+                name,
+                type: 4, // 固定值
+                api,
+                searchable: 1, // 固定值
+                ext: "", // 固定为空字符串
+            };
+        });
+    return { sites };
+}
+
+// 定义接口
+fastify.get('/config', async (request, reply) => {
+    try {
+        const siteJSON = generateSiteJSON();
+        reply.send(siteJSON);
+    } catch (error) {
+        reply.status(500).send({ error: 'Failed to generate site JSON', details: error.message });
+    }
+});
+
 // 动态加载模块并根据 query 执行不同逻辑
 fastify.get('/api/:module', async (request, reply) => {
     const moduleName = request.params.module;
@@ -124,10 +161,10 @@ fastify.get('/api/:module', async (request, reply) => {
 const start = async () => {
     try {
         // 监听 0.0.0.0
-        await fastify.listen({port: 5757, host: '0.0.0.0'});
+        await fastify.listen({port: PORT, host: '0.0.0.0'});
 
         // 获取本地地址
-        const localAddress = `http://localhost:5757`;
+        const localAddress = `http://localhost:${PORT}`;
 
         // 获取局域网地址
         const interfaces = os.networkInterfaces();
@@ -136,7 +173,7 @@ const start = async () => {
             if (!iface) continue;
             for (const config of iface) {
                 if (config.family === 'IPv4' && !config.internal) {
-                    lanAddress = `http://${config.address}:5757`;
+                    lanAddress = `http://${config.address}:${PORT}`;
                     break;
                 }
             }
diff --git a/js/_360.js b/js/_360.js
@@ -1,4 +1,4 @@
-// js/360.js
+// js/_360.js
 
 var rule = {
     title: '标题1',
diff --git a/js/_fq.js b/js/_fq.js
diff --git a/js/_qq.js b/js/_qq.js
diff --git a/js/_test.js b/js/_test.js
@@ -1,4 +1,4 @@
-// js/test.js
+// js/_test.js
 console.log('加载test...')
 globalThis.check = ()=>{
     console.log('check...')
diff --git a/js/金牌影院.js b/js/金牌影院.js
@@ -0,0 +1,142 @@
+// http://localhost:5757/api/金牌影院?ac=list&t=1&pg=1
+// http://localhost:5757/api/金牌影院?ac=detail&ids=/detail/131374
+// http://localhost:5757/api/金牌影院?wd=我的&pg=1
+// http://localhost:5757/api/金牌影院?play=&flag=金牌影院
+var rule = {
+    类型: '影视',
+    title: '金牌影院',
+    desc: '金牌影院纯js版本',
+    host: 'https://m.cfkj86.com/',
+    homeUrl:'https://www.cfkj86.com',
+    url: 'https://m.cfkj86.com/api/mw-movie/anonymous/video/list?pageNum=fypage&pageSize=30&sort=1&sortBy=1&type1=fyclass',
+    searchUrl: '/api/mw-movie/anonymous/video/searchByWordPageable?keyword=**&pageNum=fypage&pageSize=12&type=false',
+    searchable: 2,
+    quickSearch: 0,
+    timeout: 5000,
+    play_parse: true,
+    class_parse: async () => {
+         let classes = [{
+                type_id: '1',
+                type_name: '电影',
+            },{
+                type_id: '2',
+                type_name: '剧集',
+            },{
+                type_id: '3',
+                type_name: '综艺',
+            },{
+                type_id: '4',
+                type_name: '动漫',
+            }];
+        return {
+            class: classes,
+        }
+    },
+    预处理: async () => {
+        return []
+    },
+    推荐: async () => {
+        return []
+    },
+    一级: async function (tid, pg, filter, extend) {
+        let {MY_CATE, input} = this;
+        if (pg <= 0) pg = 1;
+        const t = new Date().getTime()
+        const signkey = `pageNum=${pg}&pageSize=30&sort=1&sortBy=1&type1=${tid}&key=cb808529bae6b6be45ecfab29a4889bc&t=`+t
+        const key = CryptoJS.SHA1(CryptoJS.MD5(signkey).toString()).toString()
+        const html = JSON.parse((await req(`https://m.cfkj86.com/api/mw-movie/anonymous/video/list?pageNum=${pg}&pageSize=30&sort=1&sortBy=1&type1=${tid}`,
+            {
+            headers:{
+                'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36',
+                'Accept': 'application/json, text/plain, */*',
+                'deviceId': misc.randUUID(),
+                'sign': key,
+                't': t
+            }
+        })).content);
+        let d = [];
+        const list = html.data.list
+        list.forEach((it)=>{
+            d.push({
+                title: it.vodName,
+                url: '/detail/'+it.vodId,
+                desc: it.vodRemarks || '暂无更新',
+                pic_url: it.vodPic,
+            })
+        })
+        return setResult(d)
+    },
+    二级: async function (ids) {
+        log(this)
+        let {input} = this;
+        const html = (await req(`${input}`)).content;
+        const $ = pq(html)
+        const vod = {
+            vod_id: input,
+            vod_name: $('h1').text().trim(),
+        };
+        let playFroms = [];
+        let playUrls = [];
+        const temp = [];
+        let playlist=$('div.main-list-sections__BodyArea-sc-8bb7334b-2 .listitem')
+        for (const it of playlist) {
+            const a = $(it).find('a')[0]
+            temp.push(a.children[0].data+'$'+a.attribs.href)
+        }
+        playFroms.push('不知道倾情打造');
+        playUrls.push(temp.join('#'));
+        vod.vod_play_from = playFroms.join('$$$');
+        vod.vod_play_url = playUrls.join('$$$');
+
+        return vod
+    },
+    搜索: async function (wd, quick, pg) {
+        let {input} = this
+        const t = new Date().getTime()
+        //keyword=你&pageNum=1&pageSize=12&type=false&key=cb808529bae6b6be45ecfab29a4889bc&t=1722904806016
+        const signkey = 'keyword='+wd+'&pageNum='+pg+'&pageSize=12&type=false&key=cb808529bae6b6be45ecfab29a4889bc&t='+t
+        const key = CryptoJS.SHA1(CryptoJS.MD5(signkey).toString()).toString()
+        let html = JSON.parse((await req(`${rule.homeUrl}${input}`,
+            {
+                headers:{
+                    'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36',
+                    'Accept': 'application/json, text/plain, */*',
+                    'deviceId': misc.randUUID(),
+                    'sign': key,
+                    't': t
+                }
+        })).content);
+        let d = [];
+        const list = html.data.list
+        list.forEach((it)=>{
+            d.push({
+                title: it.vodName,
+                url: '/detail/'+it.vodId,
+                desc: it.vodRemarks || '暂无更新',
+                pic_url: it.vodPic,
+            })
+        })
+        return setResult(d)
+    },
+    lazy: async function (flag, id, flags) {
+        let {input} = this;
+        const pid = input.split('/')[3]
+        const nid = input.split('/')[5]
+        const t = new Date().getTime()
+        const signkey = 'id='+pid+'&nid='+nid+'&key=cb808529bae6b6be45ecfab29a4889bc&t='+t
+        const key = CryptoJS.SHA1(CryptoJS.MD5(signkey).toString()).toString()
+        const relurl = rule.homeUrl+'/api/mw-movie/anonymous/v1/video/episode/url?id='+pid+'&nid='+nid
+        const html = JSON.parse((await req(relurl,
+            {
+                headers:{
+                    'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36',
+                    'Accept': 'application/json, text/plain, */*',
+                    'deviceId': misc.randUUID(),
+                    'sign': key,
+                    't': t
+                }
+        })).content)
+        return {parse: 0, url: html.data.playUrl, js: ''}
+    },
+};
+
diff --git a/jstest/360test.js b/jstest/360test.js
@@ -8,7 +8,7 @@ console.log('__dirname:', __dirname);
 
 (async () => {
     // 使用 __dirname 来确保正确的相对路径，避免路径出错
-    const modulePath = path.join(__dirname, '../js/360.js');
+    const modulePath = path.join(__dirname, '../js/_360.js');
 
     try {
         console.log('Initializing module...');
diff --git a/libs/drpyS.js b/libs/drpyS.js
@@ -81,6 +81,7 @@ export async function init(filePath, refresh) {
             pjfh,
             pj,
             pjfa,
+            pq,
             local,
             md5X,
             rsaX,
@@ -179,6 +180,9 @@ async function invokeWithInjectVars(rule, method, injectVars, args) {
     // 这样每次调用时，方法内部的 `this` 会指向 `injectVars`，避免了共享状态，确保数据的隔离性。
     let result = await method.apply(injectVars, args);  // 使用 apply 临时注入 injectVars 作为上下文，并执行方法
     switch (injectVars['method']) {
+        case 'class_parse':
+            result = await homeParseAfter(result,rule.类型);
+            break;
         case '一级':
             result = await cateParseAfter(result, args[1]);
             break;
@@ -328,6 +332,11 @@ async function initParse(rule) {
     return rule
 }
 
+async function homeParseAfter(d, _type) {
+    d.type = _type||'影视';
+    return d
+}
+
 async function cateParse(rule, tid, pg, filter, extend) {
     log(tid, pg, filter, extend);
     let url = rule.url.replaceAll('fyclass', tid);
diff --git a/对话1.txt b/对话1.txt
@@ -232,8 +232,8 @@ export function sleepSync(ms) {
 export const deepCopy = cloneDeep
 
 
-5. js/360.js
-// js/360.js
+5. js/_360.js
+// js/_360.js
 
 var rule = {
     title: '标题1',

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-// js/360.js`
	`1`	`+// js/_360.js`
`2`	`2`
`3`	`3`	`var rule = {`
`4`	`4`	`title: '标题1',`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-// js/test.js`
	`1`	`+// js/_test.js`
`2`	`2`	`console.log('加载test...')`
`3`	`3`	`globalThis.check = ()=>{`
`4`	`4`	`console.log('check...')`