feat: 增加邮箱推送，增加qjs性能测试

Author: Taois

.env.development

@@ -25,4 +25,8 @@ LIVE_URL = 'https://livetv.wqwqwq.sbs/tv.m3u'
 MAX_TASK = 8
 dingding_webhook=
 wechat_webhook=
-tx_news_guonei_api_key=
+tx_news_guonei_api_key=
+
+# QQ邮箱配置
+QQ_EMAIL =
+QQ_SMTP_AUTH_CODE =

package.json

@@ -1,6 +1,6 @@
 {
   "name": "drpy-node",
-  "version": "1.2.10",
+  "version": "1.2.11",
   "main": "index.js",
   "type": "module",
   "scripts": {
@@ -46,6 +46,7 @@
     "minizlib": "^3.0.1",
     "node-forge": "^1.3.1",
     "node-sqlite3-wasm": "^0.8.35",
+    "nodemailer": "^7.0.5",
     "p-queue": "^8.0.1",
     "pino": "^9.7.0",
     "pinyin": "^4.0.0",

scripts/cron/qqemail_test.mjs

@@ -0,0 +1,22 @@
+import MessageSender from '../../utils/message_sender.js';
+
+export default {
+    schedule: {
+        //cron: '0 */30 * * * *',
+        timezone: 'Asia/Shanghai', // 直接用北京时间时区
+        runOnInit: false // 启动时立即执行一次
+    },
+    run: async (fastify) => {
+        fastify.log.info('📊 版本监测...');
+            let vercode = "V1.0";
+            let config = {
+                //to: '[email protected],[email protected]', 不填默认发给自己
+                subject: '版本监听',
+                text: `有更新，版本${vercode}`,
+                html: `<div style="font-family:Arial,sans-serif;max-width:600px;margin:0 auto;padding:20px;background:#f8f9fa;border-radius:8px;">
+  <p style="font-size:16px;color:#333;margin:0 0 15px 0;"><span style="color:#4CAF50;font-weight:bold;">🔄 更新通知：</span>当前版本 <strong style="color:#2196F3;">${vercode}</strong> 已发布</p></div>`
+            };
+            await MessageSender.send(config,2);
+            fastify.log.info('📤 send qqemail message successfully');
+    }
+};

spider/catvod/猫测试.js

@@ -12,11 +12,22 @@ function init(ext) {
     console.log('init');
 }
 
-function home(filter) {
+function qjs_test() {
     console.log('typeof getProxyUrl:', typeof getProxyUrl);
     if (typeof getProxyUrl === 'function') {
         console.log('getProxyUrl():', getProxyUrl());
     }
+    const t1 = Date.now()
+    let str = '';
+    for (let i = 0; i < 1000_000; i++) {
+        str += 'a';
+    }
+    const t2 = Date.now()
+    console.log(`qjs字符串拼接测试耗时: ${Math.ceil(t2 - t1)} ms`);
+}
+
+function home(filter) {
+    qjs_test();
     let classes = [];
     classes.push({
         'type_id': 'test',

utils/message_sender.js

@@ -1,20 +1,33 @@
 import axios from 'axios';
+import nodemailer from 'nodemailer';
 
 export default class MessageSender {
     static TYPE = {
         DINGDING: 0,
         WECHAT: 1,
+        QQEMAIL: 2,
         // 未来可扩展更多类型...
     };
 
     /**
      * 发送消息
-     * @param {string} text 消息文本
-     * @param {number} type 消息类型（0: 钉钉，1: 企业微信），默认 0
+     * @param {string|object} text 消息文本（字符串或邮件配置对象）
+     * @param {number} type 消息类型（0: 钉钉，1: 企业微信，2: QQ邮箱），默认 0
      */
     static async send(text, type = MessageSender.TYPE.DINGDING) {
-        if (!text || typeof text !== 'string') {
-            console.warn('[MessageSender] 消息内容必须是字符串');
+        if (!text) {
+            console.warn('[MessageSender] 消息内容不能为空');
+            return;
+        }
+
+        // QQ邮箱只允许对象，其他类型必须为字符串
+        if (type === MessageSender.TYPE.QQEMAIL && typeof text !== 'object') {
+            console.warn('[MessageSender] QQ邮箱类型只支持配置对象');
+            return;
+        }
+        
+        if (type !== MessageSender.TYPE.QQEMAIL && typeof text !== 'string') {
+            console.warn('[MessageSender] 非邮箱类型消息内容必须是字符串');
             return;
         }
 
@@ -27,6 +40,10 @@ export default class MessageSender {
                 await this.#sendWeChat(text);
                 break;
 
+            case MessageSender.TYPE.QQEMAIL:
+                await this.#sendQQEmail(text);
+                break;
+
             default:
                 console.warn(`[MessageSender] 不支持的消息类型: ${type}`);
         }
@@ -65,4 +82,50 @@ export default class MessageSender {
             console.error('[MessageSender] 企业微信消息发送失败:', err.message);
         }
     }
+
+    /**
+     * 发送QQ邮件（支持文本/HTML/多收件人）
+     * @param {object} config 邮件配置对象
+     * @property {string} [to] 收件人邮箱，默认使用环境变量QQ_EMAIL
+     * @property {string} [subject] 邮件主题，默认"系统通知"
+     * @property {string} [text] 纯文本内容
+     * @property {string} [html] HTML内容
+     * @property {Array} [attachments] 邮件附件
+     */
+    static async #sendQQEmail(config) {
+        const {QQ_EMAIL, QQ_SMTP_AUTH_CODE} = process.env;
+        
+        if (!QQ_EMAIL || !QQ_SMTP_AUTH_CODE) {
+            console.log('[MessageSender] 未配置QQ邮箱或SMTP授权码，跳过邮件发送');
+            return;
+        }
+
+        // 创建带连接池的邮件传输器
+        const transporter = nodemailer.createTransport({
+            //pool: true, // 启用连接池
+            host: 'smtp.qq.com',
+            port: 465,
+            secure: true,
+            auth: {
+                user: QQ_EMAIL,
+                pass: QQ_SMTP_AUTH_CODE
+            }
+        });
+
+        try {
+            // 构建邮件选项，保护关键字段并提供默认值
+            const mailOptions = {
+                from: `"系统通知" <${QQ_EMAIL}>`, // 固定发件人
+                to: config.to || QQ_EMAIL, // 允许自定义收件人
+                ...config
+            };
+            
+            const info = await transporter.sendMail(mailOptions);
+            console.log('[MessageSender] QQ邮件已发送: %s', info.accepted);
+        } catch (err) {
+            console.error('[MessageSender] QQ邮件发送失败:', err.message);
+        } finally {
+            transporter.close(); // 关闭连接池
+        }
+    }
 }