update:增加源加密功能

Author: hjdhnx

Diff for: .nomedia

@@ -0,0 +1 @@
+hjdhnx

Diff for: README.md

@@ -5,12 +5,13 @@ nodejs作为服务端的drpy实现。全面升级异步写法
 * [本地配置接口-动态本地](/config)
 * [本地配置接口-动态外网/局域网](/config/1)
 * [本地配置接口-静态](/index)
+* [代码加密工具](/admin/encoder)
 
 ## 更新记录
 
-### 20241205
+### 20241206
 
-1. 完善本地代理功能
+1. 增加源加密功能
 
 [点此查看完整更新记录](docs/updateRecord.md)
 

Diff for: controllers/encoder.js

@@ -0,0 +1,39 @@
+import {jsEncoder} from '../libs/drpyS.js';
+
+// 仅仅支持json post 如: {"type":"gzip","code":"xxx"}
+export default (fastify, options, done) => {
+    // 注册 POST 路由
+    fastify.post('/encoder', async (request, reply) => {
+        const {code, type} = request.body;
+
+        if (!code || !type) {
+            return reply.status(400).send({error: 'Missing required parameters: code and type'});
+        }
+
+        try {
+            let result;
+
+            switch (type) {
+                case 'base64':
+                    result = jsEncoder.base64Encode(code);
+                    break;
+                case 'gzip':
+                    result = jsEncoder.gzip(code);
+                    break;
+                case 'aes':
+                    result = jsEncoder.aes_encrypt(code);
+                    break;
+                case 'rsa':
+                    result = jsEncoder.rsa_encode(code);
+                    break;
+                default:
+                    throw new Error(`Unsupported type: ${type}`);
+            }
+
+            reply.send({success: true, result});
+        } catch (error) {
+            reply.status(500).send({error: error.message});
+        }
+    });
+    done();
+};

Diff for: controllers/index.js

@@ -2,10 +2,14 @@ import docsController from './docs.js';
 import configController from './config.js';
 import apiController from './api.js';
 import rootController from './root.js';
+import encoderController from './encoder.js';
+import webController from './web.js';
 
 export const registerRoutes = (fastify, options) => {
     fastify.register(docsController, options);
     fastify.register(configController, options);
     fastify.register(apiController, options);
     fastify.register(rootController, options);
+    fastify.register(encoderController, options);
+    fastify.register(webController, options);
 };

Diff for: controllers/web.js

@@ -0,0 +1,25 @@
+import {readFileSync, existsSync} from 'fs';
+import path from 'path';
+
+export default (fastify, options, done) => {
+    // 读取 views 目录下的 encoder.html 文件并返回
+    fastify.get('/admin/encoder', async (request, reply) => {
+        const encoderFilePath = path.join(options.viewsDir, 'encoder.html'); // 获取 encoder.html 文件的路径
+
+        // 检查文件是否存在
+        if (!existsSync(encoderFilePath)) {
+            return reply.status(404).send({error: 'encoder.html not found'});
+        }
+
+        try {
+            // 读取 HTML 文件内容
+            const htmlContent = readFileSync(encoderFilePath, 'utf-8');
+            reply.type('text/html').send(htmlContent); // 返回 HTML 文件内容
+        } catch (error) {
+            fastify.log.error(`Failed to read encoder.html: ${error.message}`);
+            return reply.status(500).send({error: 'Failed to load encoder page'});
+        }
+    });
+
+    done();
+};

Diff for: docs/updateRecord.md

@@ -1,5 +1,17 @@
 # drpyS更新记录
 
+### 20241206
+
+更新至V1.0.3
+
+1. 完善图片代理相关函数与功能
+2. 增加加密源的数据解析
+3. crypto-js-wasm.js兼容海阔调用CryptoJSW对象
+4. 更新金牌影视，本地代理修复播放问题
+5. 暴露更多函数给drpyS源使用。如gzip、ungzip等等
+6. 增加源加密功能
+7. 根目录增加.nomedia规避手机相册识别ts文件为媒体图片问题
+
 ### 20241205
 
 更新至V1.0.2

Diff for: index.js

@@ -24,6 +24,7 @@ registerRoutes(fastify, {
     rootDir: __dirname,
     docsDir: path.join(__dirname, 'docs'),
     jsDir: path.join(__dirname, 'js'),
+    viewsDir: path.join(__dirname, 'views'),
     PORT,
     indexFilePath: path.join(__dirname, 'index.json'),
     customFilePath: path.join(__dirname, 'custom.json'),

Diff for: index.json

@@ -4,31 +4,55 @@
       "key": "drpyS_人人视频",
       "name": "人人视频(drpyS)",
       "type": 4,
-      "api": "http://localhost:5757/api/人人视频",
+      "api": "http://127.0.0.1:5757/api/人人视频",
       "searchable": 1,
       "ext": ""
     },
     {
       "key": "drpyS_星芽短剧",
       "name": "星芽短剧(drpyS)",
       "type": 4,
-      "api": "http://localhost:5757/api/星芽短剧",
+      "api": "http://127.0.0.1:5757/api/星芽短剧",
       "searchable": 1,
       "ext": ""
     },
     {
       "key": "drpyS_番茄小说[书]",
       "name": "番茄小说[书](drpyS)",
       "type": 4,
-      "api": "http://localhost:5757/api/番茄小说[书]",
+      "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": ""
+    },
+    {
+      "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://localhost:5757/api/金牌影院",
+      "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 for: js/色花堂[密+].js

@@ -1,12 +1,12 @@
 // 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=金牌影院
+// http://localhost:5757/api/金牌影院?play=/vod/play/131374/sid/1125278&flag=金牌影院
 var rule = {
     类型: '影视',
     title: '金牌影院',
     desc: '金牌影院纯js版本',
-    host: 'https://www.cfkj86.com/',
+    host: 'https://www.cfkj86.com',
     homeUrl:'',
     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',
@@ -49,7 +49,7 @@ var rule = {
             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(),
+                'deviceId': '58a80c52-138c-48fd-8edb-138fd74d12c8',
                 'sign': key,
                 't': t
             }
@@ -68,7 +68,6 @@ var rule = {
         return setResult(d)
     },
     二级: async function (ids) {
-        log(this)
         let {input} = this;
         const html = (await req(`${input}`)).content;
         const $ = pq(html)
@@ -102,7 +101,7 @@ var rule = {
                 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(),
+                    'deviceId': '58a80c52-138c-48fd-8edb-138fd74d12c8',
                     'sign': key,
                     't': t
                 }
@@ -130,14 +129,40 @@ var rule = {
         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',
+                    'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36',
                     'Accept': 'application/json, text/plain, */*',
-                    'deviceId': misc.randUUID(),
+                    'Accept-Encoding': 'gzip, deflate, br, zstd',
+                    'sec-ch-ua-platform': '"Windows"',
+                    'deviceId': '58a80c52-138c-48fd-8edb-138fd74d12c8',
                     'sign': key,
-                    't': t
+                    't': t,
+                    'referer': `${rule.host}${input}`,
+                    'authorization': '',
                 }
         })).content)
-        return {parse: 0, url: html.data.playUrl, js: ''}
+        return {parse: 0, url: getProxyUrl()+'&url='+html.data.playUrl, js: ''}
+    },
+    proxy_rule: async function()  {
+        let {input} = this
+        if (input) {
+            let m3u8 = (await req(input)).content;
+            const lines = m3u8.split('\n');
+            const tsUrls = [];
+            let link_start = ''
+            lines.forEach(line => {
+                if (line.trim().startsWith('http') && line.endsWith('.ts')) {
+                    tsUrls.push(/line/,link_start + line.trim())
+                }
+                if (line.indexOf('.ts') > 0) { // 确保只匹配 TS 片段的 URL
+                    link_start = input.split('?')[0].replace(/([^/]+)(?=\.m3u8(?:$|[\?#]))/, '').replace('.m3u8', '')
+                    tsUrls.push(link_start + line.trim())
+                }else {
+                    tsUrls.push(line)
+                }
+            })
+            m3u8_text = tsUrls.join('\n')
+            return [200,'application/vnd.apple.mpegurl', m3u8_text];
+        }
     },
 };