index.js

import Fastify from 'fastify';
import * as drpy from './libs/drpy.js';
import path from 'path';
import {fileURLToPath} from 'url';
import {base64Encode, base64Decode, atob, btoa} from "./libs_drpy/crypto-util.js";

const fastify = Fastify({logger: true});

const __dirname = path.dirname(fileURLToPath(import.meta.url));
console.log('__dirname:', __dirname);

// 动态加载模块并根据 query 执行不同逻辑
fastify.get('/api/:module', async (request, reply) => {
    const moduleName = request.params.module;
    const query = request.query; // 获取 query 参数
    const modulePath = path.join(__dirname, 'js', `${moduleName}.js`);

    const pg = Number(query.pg) || 1;
    try {
        // 根据 query 参数决定执行逻辑
        if ('play' in query) {
            // 处理播放逻辑
            const result = await drpy.play(modulePath, query.flag, query.play);
            return reply.send(result);
        }

        if ('ac' in query && 't' in query) {
            let ext = query.ext;
            let extend = {};
            if (ext) {
                try {
                    extend = JSON.parse(base64Decode(ext))
                } catch (e) {
                }
            }
            // 分类逻辑
            const result = await drpy.cate(modulePath, query.t, pg, extend);
            return reply.send(result);
        }

        if ('ac' in query && 'ids' in query) {
            // 详情逻辑
            const result = await drpy.detail(modulePath, query.ids);
            return reply.send(result);
        }

        if ('wd' in query) {
            // 搜索逻辑
            if (!('quick' in query)) {
                query.quick = 0
            }
            const result = await drpy.search(modulePath, query.wd, query.quick, pg);
            return reply.send(result);
        }

        if ('refresh' in query) {
            // 强制刷新初始化逻辑
            const refreshedObject = await drpy.init(modulePath, true);
            return reply.send(refreshedObject);
        }
        if (!('filter' in query)) {
            query.filter = 1
        }
        // 默认逻辑，返回 home + homeVod 接口
        const result_home = await drpy.home(modulePath, query.filter);
        const result_homeVod = await drpy.homeVod(modulePath);
        const result = {
            ...result_home,
            list: result_homeVod
        }
        reply.send(result);

    } catch (error) {
        console.error('Error processing request:', error);
        reply.status(500).send({error: `Failed to process request for 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();