init:开发了一个基础架构

Author: hjdhnx

README.md

@@ -1,2 +1,10 @@
 # drpy-node
+
 nodejs作为服务端的drpy实现。全面升级异步写法
+
+## 基础框架
+
+todo:
+
+1. js里的源能否去除export开头，保持跟qjs一致
+2. js里的源，像一级这种异步js，里面调用未定义的函数，能否不通过函数参数传入直接注入调用

index.js

@@ -0,0 +1,56 @@
+import Fastify from 'fastify';  // 使用命名导入 Fastify
+import path from 'path';  // 使用 Node.js 的 path 模块来处理文件路径
+
+// 使用 pino-pretty 来格式化日志输出
+import pino from 'pino';
+import pinoPretty from 'pino-pretty';
+
+// 创建 pino-pretty 配置
+const prettyPrintOptions = {
+    colorize: true,  // 启用颜色输出
+    translateTime: 'SYS:standard',  // 显示标准时间
+    ignore: 'pid,hostname'  // 忽略 pid 和 hostname
+};
+
+// 创建 Fastify 实例
+const fastify = Fastify({
+    logger: pino({
+        level: 'info',  // 设置日志级别
+        prettyPrint: false  // 禁用内置 prettyPrint
+    }).child({}, {stream: pinoPretty(prettyPrintOptions)})  // 使用 pino-pretty 进行日志格式化
+});
+
+// 引入封装好的库
+import * as drpy from './libs/drpy.js';
+
+// API 接口: 根据模块名加载相应的 js 文件，并调用 drpy 的方法
+fastify.get('/api/:module', async (request, reply) => {
+    const moduleName = request.params.module;  // 获取模块名，例如 '360'
+    const modulePath = new URL(`./js/${moduleName}.js`, import.meta.url).pathname;  // 获取模块路径
+
+    try {
+        // 动态加载 js 文件
+        const module = await import(modulePath);  // 使用动态导入加载模块
+        console.log(module)
+
+        // 由于 `360.js` 使用的是全局的 `rule` 变量，我们通过 `module.default` 获取
+        const result = await drpy.init(module.rule);  // 使用 `module.rule` 直接调用
+        // 返回结果
+        return reply.send(result);
+    } catch (error) {
+        reply.status(500).send({error: `Failed to load module ${moduleName}: ${error.message}`});
+    }
+});
+
+// 启动服务
+const start = async () => {
+    try {
+        await fastify.listen(5757);
+        console.log('Server listening at http://localhost:5757');
+    } catch (err) {
+        fastify.log.error(err);
+        process.exit(1);
+    }
+};
+
+start();

js/360.js

@@ -0,0 +1,11 @@
+// js/360.js
+export var rule = {
+    title: '标题1',
+    description: '这是描述',
+    category: '视频',
+    一级:async (req)=>{
+        let html = await req('123');
+        // console.log(html);
+        return html
+    },
+};

libs/drpy.js

@@ -0,0 +1,63 @@
+// drpy.js: 封装模块，包含处理逻辑
+
+import * as utils from '../utils/utils.js';  // 使用 import 引入工具类
+const { req } = await import('../utils/req.js');
+
+export async function init(rule) {
+    // 假设我们传入的 moduleObject 是 js/360.js 中的 rule 对象
+    const moduleObject = utils.deepCopy(rule)
+    try {
+        // 读取并修改传入的对象
+        if (moduleObject && moduleObject.title) {
+            moduleObject.title += ' (drpy)';  // 修改 title 属性
+        }
+
+        // 你可以根据需要修改其他属性
+        if (moduleObject && moduleObject.description) {
+            moduleObject.description += ' [Modified]';
+        }
+        const title = moduleObject.title
+        console.log(moduleObject)
+        const titleLength = utils.getTitleLength(title);  // 使用 utils.js 中的方法
+
+
+        Object.assign(moduleObject, {
+            message: `Module initialized with title: ${title}`,
+            titleLength: titleLength
+        })
+
+        console.log(typeof moduleObject.一级)
+        if( typeof moduleObject.一级 === 'function'){
+            let html = await moduleObject.一级(req)
+            console.log(html)
+            moduleObject.html = html
+        }
+
+        // 返回修改后的对象
+        return moduleObject;
+    } catch (error) {
+        console.error('Error in drpy.init:', error);
+        throw new Error('Failed to initialize module');
+    }
+}
+
+// 其他方法可以依照需求继续添加
+export async function home() {
+    return {message: 'Home method'};
+}
+
+export async function cate() {
+    return {message: 'Cate method'};
+}
+
+export async function detail() {
+    return {message: 'Detail method'};
+}
+
+export async function play() {
+    return {message: 'Play method'};
+}
+
+export async function search() {
+    return {message: 'Search method'};
+}

package.json

@@ -0,0 +1,17 @@
+{
+  "name": "drpy-node",
+  "version": "1.0.0",
+  "main": "index.js",
+  "type": "module",
+  "scripts": {
+    "dev": "node index.js"
+  },
+  "repository": "https://github.com/hjdhnx/drpy-node.git",
+  "author": "晚风拂柳颜 <[email protected]>",
+  "license": "MIT",
+  "dependencies": {
+    "fastify": "^4.15.0",
+    "lodash": "^4.17.21",
+    "pino-pretty": "^13.0.0"
+  }
+}

utils/req.js

@@ -0,0 +1,8 @@
+export async function req(param) {
+    // 模拟异步请求
+    return new Promise((resolve) => {
+        setTimeout(() => {
+            resolve(`Response for ${param}`);
+        }, 1000);
+    });
+}

utils/utils.js

@@ -0,0 +1,10 @@
+// utils.js: 存放工具类方法
+import pkg from 'lodash';
+
+const {cloneDeep} = pkg;
+
+export function getTitleLength(title) {
+    return title.length;  // 返回标题长度
+}
+
+export const deepCopy = cloneDeep