From d9c8da47c02d827d4cc89694c8a627bbad9ddf46 Mon Sep 17 00:00:00 2001 From: Jerrypluay Date: Thu, 27 Nov 2025 18:30:46 +0800 Subject: [PATCH] =?UTF-8?q?=F0=9F=8E=A8=20chore(apps/rssPush.js):=20clean?= =?UTF-8?q?=20up=20import=20statements=20and=20improve=20logging=20message?= =?UTF-8?q?s=20for=20better=20clarity=20and=20consistency?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/rssPush.js | 61 +++++++++++-------------------------------------- 1 file changed, 13 insertions(+), 48 deletions(-) diff --git a/apps/rssPush.js b/apps/rssPush.js index df3c472..8161569 100644 --- a/apps/rssPush.js +++ b/apps/rssPush.js @@ -6,7 +6,6 @@ import fs from 'fs'; import rssCache from '../lib/rss/rssCache.js'; import schedule from 'node-schedule'; import tools from '../components/tool.js'; -// 移除了重复的 import ConfigControl export default class RssPlugin extends plugin { constructor() { @@ -31,7 +30,6 @@ export default class RssPlugin extends plugin { permission: 'master', priority: 100, }, - // 【新增】查看列表功能 { reg: '^#rss列表$', fnc: 'listFeeds', @@ -45,14 +43,11 @@ export default class RssPlugin extends plugin { }, ], }); - - // 【修复】定时任务启动逻辑 - // 只要插件加载，且未注册过任务，就启动定时器 if (!global.__rss_job_scheduled) { // 默认每10分钟执行一次 schedule.scheduleJob('*/10 * * * *', () => this.pushFeeds()); global.__rss_job_scheduled = true; - logger.mark('[RSS] 定时检测任务已启动'); + logger.mark('[crystelf-rss] 定时检测任务已启动'); } } @@ -95,23 +90,21 @@ export default class RssPlugin extends plugin { } /** - * 【新增】查看当前群组订阅列表 + * 查看当前群组订阅列表 */ async listFeeds(e) { const feeds = configControl.get('feeds') || []; const groupId = e.group_id; - - // 筛选当前群组的订阅，保留全局索引以便移除 const currentGroupFeeds = feeds .map((feed, index) => ({ index, ...feed })) .filter((feed) => feed.targetGroups.includes(groupId)); if (currentGroupFeeds.length === 0) { - return e.reply('当前群组暂无任何RSS订阅。', true); + return e.reply('当前群组暂无任何RSS订阅..', true); } const msg = [ - `≡ 当前群组订阅列表 (${currentGroupFeeds.length}) ≡`, + `当前群组订阅列表 (${currentGroupFeeds.length})`, ...currentGroupFeeds.map((f) => `[${f.index}] ${f.url}`), '----------------', '提示: 使用 #rss移除+索引号 取消订阅' @@ -121,47 +114,35 @@ export default class RssPlugin extends plugin { } /** - * 【修复】移除rss (增强健壮性) + * 移除rss */ async removeFeed(e) { - // 提取数字 const match = e.msg.match(/#rss移除\s*(\d+)/); if (!match || !match[1]) { - return e.reply('请指定要移除的订阅索引，例如：#rss移除0', true); + return e.reply('请指定要移除的订阅索引,例如：#rss移除0', true); } const index = parseInt(match[1], 10); const feeds = configControl.get('feeds') || []; const groupId = e.group_id; - - // 越界与有效性检查 if (isNaN(index) || index < 0 || index >= feeds.length) { - return e.reply('索引无效，请发送 #rss列表 查看正确索引。', true); + return e.reply('索引无效,请发送 #rss列表 查看正确索引..', true); } const targetFeed = feeds[index]; - if (!targetFeed) return e.reply('未找到该配置。', true); - - // 兼容性处理 + if (!targetFeed) return e.reply('未找到该配置..', true); if (!Array.isArray(targetFeed.targetGroups)) { targetFeed.targetGroups = []; } - - // 检查本群是否已订阅 if (!targetFeed.targetGroups.includes(groupId)) { - return e.reply('当前群组未订阅此源，无需移除。', true); + return e.reply('当前群组未订阅此源,无需移除..', true); } - - // 执行移除 targetFeed.targetGroups = targetFeed.targetGroups.filter((id) => id !== groupId); await configControl.set('feeds', feeds); return await e.reply(`已取消订阅：${targetFeed.title || targetFeed.url}`); } - /** - * 【修复】手动拉取 (增加错误处理) - */ async pullFeedNow(e) { const url = e.msg.replace(/^#rss拉取/, '').trim(); if (!url) return e.reply('请提供RSS链接', true); @@ -170,7 +151,7 @@ export default class RssPlugin extends plugin { try { latest = await rssTools.fetchFeed(url); } catch (err) { - logger.error(`[RSS] 手动拉取失败: ${err.message}`); + logger.error(`[crystelf-rss] 手动拉取失败: ${err.message}`); return await e.reply(`拉取失败: ${err.message}`, true); } @@ -186,20 +167,14 @@ export default class RssPlugin extends plugin { await screenshot.generateScreenshot(post, tempPath); await e.reply([segment.image(tempPath)]); } catch (err) { - logger.error(`[RSS] 截图失败: ${err}`); + logger.error(`[crystelf-rss] 截图失败: ${err}`); await e.reply('生成预览图失败..', true); } finally { if (fs.existsSync(tempPath)) fs.unlinkSync(tempPath); } } - - /** - * 【修复】核心逻辑：检查rss更新 - * 修复了时区问题、逻辑死循环问题和报错导致插件停止的问题 - */ async pushFeeds() { const feeds = configControl.get('feeds') || []; - // logger.mark(`正在检查rss流更新..`); // 调试时可解开 for (const feed of feeds) { let latest; @@ -213,21 +188,15 @@ export default class RssPlugin extends plugin { if (!latest || !latest.length) continue; const newItems = []; - // 限制只检查前3条，避免刷屏 const checkLimit = Math.min(latest.length, 3); for (let i = 0; i < checkLimit; i++) { const item = latest[i]; if (!item.link) continue; - - // 【核心修复】不再强制对比 todayStr (解决时区问题) - // 而是依赖 rssCache 判断是否推送过 const isCached = await rssCache.has(feed.url, item.link); if (!isCached) { - // 增加一个宽松的时间检查 (48小时内)，防止第一次添加把几年前的文章全发出来 const pubDate = item.date ? new Date(item.date).getTime() : Date.now(); - // 如果文章没有时间，默认允许推送；如果有时间，则必须在48小时内 if (!item.date || (Date.now() - pubDate < 172800000)) { newItems.push(item); } @@ -235,21 +204,18 @@ export default class RssPlugin extends plugin { } if (newItems.length > 0) { - // 【优化】倒序排列，先发旧的，后发新的 newItems.reverse(); - for (const post of newItems) { // 写入缓存 await rssCache.set(feed.url, post.link); for (const groupId of feed.targetGroups) { - // 稍微延迟，防止风控 await tools.sleep(2000); const tempPath = path.join(process.cwd(), 'data', `rss-${Date.now()}.png`); try { if (feed.screenshot) { - logger.info(`[RSS] 推送更新: ${post.title} -> 群 ${groupId}`); + logger.info(`[crystelf-rss] 推送更新: ${post.title} -> 群 ${groupId}`); // 先发个文字提示 await Bot.pickGroup(groupId)?.sendMsg( `[RSS] ${post.feedTitle || '订阅更新'}\n${post.title}` @@ -262,9 +228,8 @@ export default class RssPlugin extends plugin { await Bot.pickGroup(groupId)?.sendMsg(`[RSS推送]\n${post.title}\n${post.link}`); } } catch (err) { - logger.error(`[RSS] 推送消息异常: ${err.message}`); + logger.error(`[crystelf-rss] 推送消息异常: ${err.message}`); } finally { - // 确保删除临时文件 if (fs.existsSync(tempPath)) { fs.unlinkSync(tempPath); }