// 主库 import fetch from "node-fetch"; import fs from "node:fs"; import { Buffer } from 'node:buffer'; // 其他库 import axios from "axios"; import _ from "lodash"; import tunnel from "tunnel"; import HttpProxyAgent from "https-proxy-agent"; import { exec, execSync } from "child_process"; import { checkAndRemoveFile, deleteFolderRecursive, mkdirIfNotExists } from "../utils/file.js"; import { downloadBFile, filterBiliDescLink, getBiliAudio, getBiliVideoWithSession, getDownloadUrl, getDynamic, getScanCodeData, getVideoInfo, m4sToMp3, mergeFileToMp4 } from "../utils/bilibili.js"; import { downloadM3u8Videos, mergeAcFileToMp4, parseM3u8, parseUrl } from "../utils/acfun.js"; import { BILI_DEFAULT_INTRO_LEN_LIMIT, DIVIDING_LINE, douyinTypeMap, HELP_DOC, REDIS_YUNZAI_ISOVERSEA, REDIS_YUNZAI_LAGRANGE, SUMMARY_PROMPT, transMap, TWITTER_BEARER_TOKEN, XHS_NO_WATERMARK_HEADER, } from "../constants/constant.js"; import { checkCommandExists, downloadAudio, downloadImg, estimateReadingTime, formatBiliInfo, getIdVideo, retryAxiosReq, secondsToTime, testProxy, truncateString } from "../utils/common.js"; import config from "../model/index.js"; import Translate from "../utils/trans-strategy.js"; import * as aBogus from "../utils/a-bogus.cjs"; import { getBodianAudio, getBodianMusicInfo, getBodianMv } from "../utils/bodian.js"; import { av2BV } from "../utils/bilibili-bv-av-convert.js"; import querystring from "querystring"; import TokenBucket from "../utils/token-bucket.js"; import PQueue from 'p-queue'; import { getWbi } from "../utils/biliWbi.js"; import { BILI_SUMMARY, DY_INFO, DY_TOUTIAO_INFO, GENERAL_REQ_LINK, MIYOUSHE_ARTICLE, NETEASE_API_CN, NETEASE_SONG_DETAIL, NETEASE_SONG_DOWNLOAD, NETEASE_TEMP_API, TIKTOK_INFO, TWITTER_TWEET_INFO, WEIBO_SINGLE_INFO, WEISHI_VIDEO_INFO, XHS_REQ_LINK } from "../constants/tools.js"; import { processTikTokUrl } from "../utils/tiktok.js"; import { getDS } from "../utils/mihoyo.js"; import GeneralLinkAdapter from "../utils/general-link-adapter.js"; import { mid2id } from "../utils/weibo.js"; import { LagrangeAdapter } from "../utils/lagrange-adapter.js"; import path from "path"; import { OpenaiBuilder } from "../utils/openai-builder.js"; import { contentEstimator } from "../utils/link-share-summary-util.js"; export class tools extends plugin { /** * 用于计数applemusic，达到一定数量清理文件 * @type {number} */ static #amCount = 0; /** * 构造安全的命令 * @type {{existsPromptKey: string, existsTransKey: string}} */ static Constants = { existsTransKey: Object.keys(transMap).join("|"), }; /** * 构造令牌桶，防止解析致使服务器宕机（默认限制5s调用一次） * @type {TokenBucket} */ static #tokenBucket = new TokenBucket(1, 1, 5); constructor() { super({ name: "R插件工具和学习类", dsc: "R插件工具相关指令", event: "message.group", priority: 300, rule: [ { reg: `^(翻|trans)[${ tools.Constants.existsTransKey }]`, fnc: "trans", }, { reg: "(v.douyin.com)", fnc: "douyin", }, { reg: "(www.tiktok.com)|(vt.tiktok.com)|(vm.tiktok.com)", fnc: "tiktok", }, { reg: "^#(RBQ|rbq)$", fnc: "biliScan", permission: 'master', }, { reg: "(bilibili.com|b23.tv|t.bilibili.com|^BV[1-9a-zA-Z]{10}$)", fnc: "bili", }, { reg: "https?:\\/\\/x.com\\/[0-9-a-zA-Z_]{1,20}\\/status\\/([0-9]*)", fnc: "twitter_x", }, { reg: "(acfun.cn)", fnc: "acfun", }, { reg: "(xhslink.com|xiaohongshu.com)", fnc: "xhs", }, { reg: "(instagram.com)", fnc: "instagram", }, { reg: "(h5app.kuwo.cn)", fnc: "bodianMusic", }, { reg: "(kuaishou.com|ixigua.com|h5.pipix.com|h5.pipigx.com|tieba.baidu.com|s.xsj.qq.com|m.okjike.com)", fnc: "general", }, { reg: "(youtube.com|youtu.be|music.youtube.com)", fnc: "sy2b" }, { reg: "(miyoushe.com)", fnc: "miyoushe" }, { reg: "(music.163.com|163cn.tv)", fnc: "netease", }, { reg: "(weibo.com|m.weibo.cn)", fnc: "weibo", }, { reg: "(pixivision.net)", fnc: "pixivision" }, { reg: "(isee.weishi.qq.com)", fnc: "weishi" }, { reg: "share.xiaochuankeji.cn", fnc: "zuiyou" }, { reg: "(music.apple.com|open.spotify.com)", fnc: "freyr" }, { reg: "(mp.weixin|arxiv.org|sspai.com)", fnc: "linkShareSummary" } ], }); // 配置文件 this.toolsConfig = config.getConfig("tools"); // 视频保存路径 this.defaultPath = this.toolsConfig.defaultPath; // 魔法接口 this.proxyAddr = this.toolsConfig.proxyAddr; this.proxyPort = this.toolsConfig.proxyPort; this.myProxy = `http://${ this.proxyAddr }:${ this.proxyPort }`; // 加载哔哩哔哩配置 this.biliSessData = this.toolsConfig.biliSessData; // 加载哔哩哔哩的限制时长 this.biliDuration = this.toolsConfig.biliDuration; // 加载抖音Cookie this.douyinCookie = this.toolsConfig.douyinCookie; // 加载抖音是否压缩 this.douyinCompression = this.toolsConfig.douyinCompression; // 翻译引擎 this.translateEngine = new Translate({ translateAppId: this.toolsConfig.translateAppId, translateSecret: this.toolsConfig.translateSecret, proxy: this.myProxy, }); // 并发队列 this.queue = new PQueue({ concurrency: Number(this.toolsConfig.queueConcurrency) }); // 视频下载的并发数量 this.videoDownloadConcurrency = this.toolsConfig.videoDownloadConcurrency; // ai接口 this.aiBaseURL = this.toolsConfig.aiBaseURL; // ai api key this.aiApiKey = this.toolsConfig.aiApiKey; // ai模型 this.aiModel = this.toolsConfig.aiModel; } // 翻译插件 async trans(e) { const languageReg = /翻(.)/s; const msg = e.msg.trim(); const language = languageReg.exec(msg); if (!(language[1] in transMap)) { e.reply( "输入格式有误或暂不支持该语言！\n例子：翻中 China's policy has been consistent, but Japan chooses a path of mistrust, decoupling and military expansion", ); return; } const place = msg.slice(1 + language[1].length) // 如果没有百度那就Google const translateResult = await this.translateEngine.translate(place, language[1]); e.reply(translateResult.trim(), true); return true; } // 抖音解析 async douyin(e) { const urlRex = /(http:|https:)\/\/v.douyin.com\/[A-Za-z\d._?%&+\-=\/#]*/g; const douUrl = urlRex.exec(e.msg.trim())[0]; await this.douyinRequest(douUrl).then(async res => { // 当前版本需要填入cookie if (_.isEmpty(this.douyinCookie)) { e.reply(`检测到没有Cookie，无法解析抖音${HELP_DOC}`); return; } const douId = /note\/(\d+)/g.exec(res)?.[1] || /video\/(\d+)/g.exec(res)?.[1]; // 以下是更新了很多次的抖音API历史，且用且珍惜 // const url = `https://www.iesdouyin.com/web/api/v2/aweme/iteminfo/?item_ids=${ douId }`; // const url = `https://www.iesdouyin.com/aweme/v1/web/aweme/detail/?aweme_id=${ douId }&aid=1128&version_name=23.5.0&device_platform=android&os_version=2333`; // 感谢 Evil0ctal（https://github.com/Evil0ctal）提供的header 和 B1gM8c（https://github.com/B1gM8c）的逆向算法X-Bogus const headers = { "Accept-Language": "zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2", "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/109.0.0.0 Safari/537.36", Referer: "https://www.douyin.com/", cookie: this.douyinCookie, }; const dyApi = DY_INFO.replace("{}", douId); // a-bogus参数 const abParam = aBogus.generate_a_bogus( new URLSearchParams(new URL(dyApi).search).toString(), headers["User-Agent"], ); // const param = resp.data.result[0].paramsencode; const resDyApi = `${ dyApi }&a_bogus=${ abParam }`; headers['Referer'] = `https://www.douyin.com/video/${ douId }` // 定义一个dy请求 const dyResponse = () => axios.get(resDyApi, { headers, }); // 如果失败进行3次重试 const data = await retryAxiosReq(dyResponse) // logger.info(data) const item = await data.aweme_detail; e.reply(`识别：抖音, ${ item.desc }`); const urlTypeCode = item.aweme_type; const urlType = douyinTypeMap[urlTypeCode]; if (urlType === "video") { // logger.info(item.video); // 多位面选择：play_addr、play_addr_265、play_addr_h264 let resUrl; // 判断是否使用压缩格式 const { play_addr_265, play_addr_h264, play_addr } = item.video; // 使用今日头条 CDN 进一步加快解析速度 if (this.douyinCompression === 1) { const videoAddrURI = Math.random() > 0.5 ? play_addr_265.uri : play_addr_h264.uri; resUrl = DY_TOUTIAO_INFO.replace("1080p", "720p").replace("{}", videoAddrURI); } else { // 原始格式，ps. videoAddrList这里[0]、[1]是 http，[最后一个]是 https const videoAddrURI = play_addr.uri; resUrl = DY_TOUTIAO_INFO.replace("{}", videoAddrURI); } // ⚠️ 暂时废弃代码 /*if (this.douyinCompression === 1) { // H.265压缩率更高、流量省一半. 相对于H.264 // 265 和 264 随机均衡负载 const videoAddrList = Math.random() > 0.5 ? play_addr_265.url_list : play_addr_h264.url_list; resUrl = videoAddrList[videoAddrList.length - 1] || videoAddrList[0]; } else { // 原始格式，ps. videoAddrList这里[0]、[1]是 http，[最后一个]是 https const videoAddrList = play_addr.url_list; resUrl = videoAddrList[videoAddrList.length - 1] || videoAddrList[0]; }*/ // logger.info(resUrl); const path = `${ this.getCurDownloadPath(e) }/temp.mp4`; await this.downloadVideo(resUrl).then(() => { this.sendVideoToUpload(e, path) }); } else if (urlType === "image") { // 无水印图片列表 let no_watermark_image_list = []; // 有水印图片列表 // let watermark_image_list = []; for (let i of item.images) { // 无水印图片列表 no_watermark_image_list.push({ message: segment.image(i.url_list[0]), nickname: this.e.sender.card || this.e.user_id, user_id: this.e.user_id, }); // 有水印图片列表 // watermark_image_list.push(i.download_url_list[0]); // e.reply(segment.image(i.url_list[0])); } // console.log(no_watermark_image_list) await this.reply(await Bot.makeForwardMsg(no_watermark_image_list)); } }); return true; } // tiktok解析 async tiktok(e) { // 判断海外 const isOversea = await this.isOverseasServer(); // 如果不是海外用户且没有梯子直接返回 if (!isOversea && !(await testProxy(this.proxyAddr, this.proxyPort))) { e.reply("检测到没有梯子，无法解析TikTok"); return false; } // 处理链接 let url = await processTikTokUrl(e.msg.trim(), isOversea); // 处理ID let tiktokVideoId = await getIdVideo(url); tiktokVideoId = tiktokVideoId.replace(/\//g, ""); const config = { headers: { "User-Agent": "Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Mobile Safari/537.36", }, // redirect: "follow", follow: 10, timeout: 10000, } // 如果不是海外，则使用代理 if (!isOversea) { config.httpsAgent = tunnel.httpsOverHttp({ proxy: new HttpProxyAgent(this.myProxy), }); } const params = new URLSearchParams({ "iid": "7318518857994389254", "device_id": "7318517321748022790", "channel": "googleplay", "app_name": "musical_ly", "version_code": "300904", "device_platform": "android", "device_type": "ASUS_Z01QD", "os_version": "9", "aweme_id": tiktokVideoId }) // console.log(`${TIKTOK_INFO}?${params.toString()}`) await fetch(`${ TIKTOK_INFO }?${ params.toString() }`, config) .then(async resp => { const respJson = await resp.json(); const data = respJson.aweme_list[0]; e.reply(`识别：tiktok, ${ data.desc }`); this.downloadVideo(data.video.play_addr.url_list[0], !isOversea).then(video => { e.reply( segment.video( `${ this.getCurDownloadPath(e) }/temp.mp4`, ), ); }); }); return true; } async biliScan(e) { e.reply('R插件开源免责声明:\n您将通过扫码完成获取哔哩哔哩refresh_token以及ck。\n本Bot将不会保存您的登录状态。\n我方仅提供视频解析及相关B站内容服务,若您的账号封禁、被盗等处罚与我方无关。\n害怕风险请勿扫码 ~', { recallMsg: 180 }); // 图片发送钩子 const imgSendHook = function (e, path) { e.reply([segment.image(path), segment.at(e.user_id), '请扫码以完成获取'], { recallMsg: 180 }) }; // 发送请求 const saveCodePath = `${ this.defaultPath }qrcode.png`; const { SESSDATA, refresh_token } = await getScanCodeData(saveCodePath, 8, () => imgSendHook(e, saveCodePath)) // 更新到配置文件 config.updateField("tools", "biliSessData", SESSDATA); e.reply('登录成功！相关信息已保存至配置文件', true) return true; } // bilibi解析 async bili(e) { await this.limitUserUse(e, () => { this.biliCore(e); }); } async biliCore(e) { const urlRex = /(?:https?:\/\/)?www\.bilibili\.com\/[A-Za-z\d._?%&+\-=\/#]*/g; const bShortRex = /(http:|https:)\/\/b23.tv\/[A-Za-z\d._?%&+\-=\/#]*/g; let url = e.msg === undefined ? e.message.shift().data.replaceAll("\\", "") : e.msg.trim().replaceAll("\\", ""); // 直接发送BV号的处理 if (/^BV[1-9a-zA-Z]{10}$/.exec(url)?.[0]) { url = `https://www.bilibili.com/video/${ url }`; logger.info(url) } // 短号处理 if (url.includes("b23.tv")) { const bShortUrl = bShortRex.exec(url)?.[0]; await fetch(bShortUrl, { method: "HEAD" }).then(resp => { url = resp.url; }); } else if (url.includes("www.bilibili.com")) { url = urlRex.exec(url)[0]; } // 补充https url = url.startsWith("https://") ? url : "https://" + url; // av处理 const matched = url.match(/\/(AV|av)(\w+)/); if (matched) { url = url.replace(matched[0].replace("\/", ""), av2BV(Number(matched[2]))); } // 处理下载逻辑 if (e.msg !== undefined && e.msg.startsWith("下载")) { // 检测是否扫码了，如果没有扫码数据终止下载 if (_.isEmpty(this.biliSessData)) { e.reply("检测到没有填写biliSessData，下载终止！"); return true; } await this.downloadBiliVideo(e, url, this.biliSessData); return true; } // 只提取音乐处理 if (e.msg !== undefined && e.msg.includes("bili音乐")) { return await this.biliMusic(e, url); } // 动态处理 if (url.includes("t.bilibili.com") || url.includes("bilibili.com\/opus")) { if (_.isEmpty(this.biliSessData)) { e.reply("检测到没有填写biliSessData，无法解析动态"); return true; } url = this.biliDynamic(e, url, this.biliSessData); return true; } // 视频信息获取例子：http://api.bilibili.com/x/web-interface/view?bvid=BV1hY411m7cB // 请求视频信息 const videoInfo = await getVideoInfo(url); const { title, pic, desc, duration, dynamic, stat, bvid, aid, cid, owner, pages } = videoInfo; // 视频信息 let { view, danmaku, reply, favorite, coin, share, like } = stat; // 限制时长 & 考虑分页视频情况 const query = querystring.parse(url); const curPage = query?.p || 0; const curDuration = pages?.[curPage]?.duration || duration; const isLimitDuration = curDuration > this.biliDuration // 构造一个可扩展的Map const dataProcessMap = { "点赞": like, "硬币": coin, "收藏": favorite, "分享": share, "总播放量": view, "弹幕数量": danmaku, "评论": reply }; // 过滤简介中的一些链接 const filteredDesc = await filterBiliDescLink(desc); // 格式化数据 const combineContent = `\n${ formatBiliInfo(dataProcessMap) }\n简介：${ truncateString(filteredDesc, this.toolsConfig.biliIntroLenLimit || BILI_DEFAULT_INTRO_LEN_LIMIT) }`; let biliInfo = [`识别：哔哩哔哩：${ title }`, combineContent] // 总结 const summary = await this.getBiliSummary(bvid, cid, owner.mid); // 不提取音乐，正常处理 if (isLimitDuration) { // 加入图片 biliInfo.unshift(segment.image(pic)) // 限制视频解析 const durationInMinutes = (curDuration / 60).toFixed(0); biliInfo.push(`${ DIVIDING_LINE.replace('{}', '限制说明') }\n当前视频时长约：${ durationInMinutes }分钟，\n大于管理员设置的最大时长 ${ this.biliDuration / 60 } 分钟！`) summary && biliInfo.push(`\n${ summary }`); e.reply(biliInfo); return true; } else { summary && biliInfo.push(`\n${ summary }`); e.reply(biliInfo); } // 创建文件，如果不存在 const path = `${ this.getCurDownloadPath(e) }/`; await mkdirIfNotExists(path); // 下载文件 getDownloadUrl(url) .then(data => { this.downBili(`${ path }temp`, data.videoUrl, data.audioUrl) .then(_ => { this.sendVideoToUpload(e, `${ path }temp.mp4`) }) .catch(err => { logger.error(err); e.reply("解析失败，请重试一下"); }); }) .catch(err => { logger.error(err); e.reply("解析失败，请重试一下"); }); return true; } /** * 下载哔哩哔哩最高画质视频 * @param e 交互事件 * @param url 下载链接 * @param SESSDATA ck * @returns {Promise} */ async downloadBiliVideo(e, url, SESSDATA) { const videoId = /video\/[^\?\/ ]+/.exec(url)[0].split("/")[1]; const dash = await getBiliVideoWithSession(videoId, "", SESSDATA); // 限制时长，防止下载大视频卡死。暂时这样设计 const curDuration = dash.duration; const isLimitDuration = curDuration > this.biliDuration; if (isLimitDuration) { const durationInMinutes = (curDuration / 60).toFixed(0); e.reply(`当前视频（${ videoId }）时长为 ${ durationInMinutes } 分钟，大于管理员设置的时长 ${ this.biliDuration / 60 } 分钟`); return true; } // 获取关键信息 const { video, audio } = dash; const videoData = video?.[0]; const audioData = audio?.[0]; // 提取信息 const { height, frameRate, baseUrl: videoBaseUrl } = videoData; const { baseUrl: audioBaseUrl } = audioData; e.reply(`正在下载${ height }p ${ Math.trunc(frameRate) }帧数 视频，请稍候...`); const path = `${ this.getCurDownloadPath(e) }/`; const that = this; // 添加下载任务到并发队列 this.queue.add(() => that.downBili(`${ path }temp`, videoBaseUrl, audioBaseUrl) .then(_ => { that.sendVideoToUpload(e, `${ path }temp.mp4`); }) .catch(err => { logger.error(`[R插件][B站下载引擎] ${ err }`); e.reply("解析失败，请重试一下"); }) ); logger.mark(`[R插件][B站下载引擎] 当前下载队列大小${ this.queue.size }`); return true; } // 下载哔哩哔哩音乐 async biliMusic(e, url) { const videoId = /video\/[^\?\/ ]+/.exec(url)[0].split("/")[1]; getBiliAudio(videoId, "").then(async audioUrl => { const path = this.getCurDownloadPath(e); e.reply(segment.record(await m4sToMp3(audioUrl, path))); }) return true } // 发送哔哩哔哩动态的算法 biliDynamic(e, url, session) { // 去除多余参数 if (url.includes("?")) { url = url.substring(0, url.indexOf("?")); } const dynamicId = /[^/]+(?!.*\/)/.exec(url)[0]; getDynamic(dynamicId, session).then(async resp => { if (resp.dynamicSrc.length > 0) { e.reply(`识别：哔哩哔哩动态, ${ resp.dynamicDesc }`); let dynamicSrcMsg = []; resp.dynamicSrc.forEach(item => { dynamicSrcMsg.push({ message: segment.image(item), nickname: e.sender.card || e.user_id, user_id: e.user_id, }); }); await this.reply(await Bot.makeForwardMsg(dynamicSrcMsg)); } else { e.reply(`识别：哔哩哔哩动态, 但是失败！`); } }); return url; } /** * 哔哩哔哩总结 * @author zhiyu1998 * @param bvid 稿件 * @param cid 视频 cid * @param up_mid UP主 mid * @return {Promise} */ async getBiliSummary(bvid, cid, up_mid) { // 这个有点用，但不多 let wbi = "wts=1701546363&w_rid=1073871926b3ccd99bd790f0162af634" if (!_.isEmpty(this.biliSessData)) { wbi = await getWbi({ bvid, cid, up_mid }, this.biliSessData); } // 构造API const summaryUrl = `${ BILI_SUMMARY }?${ wbi }`; logger.info(summaryUrl) // 构造结果：https://api.bilibili.com/x/web-interface/view/conclusion/get?bvid=BV1L94y1H7CV&cid=1335073288&up_mid=297242063&wts=1701546363&w_rid=1073871926b3ccd99bd790f0162af634 return axios.get(summaryUrl) .then(resp => { const data = resp.data.data?.model_result; // logger.info(data) const summary = data?.summary; const outline = data?.outline; let resReply = ""; // 总体总结 if (summary) { resReply = `\n摘要：${ summary }\n` } // 分段总结 if (outline) { const specificTimeSummary = outline.map(item => { const smallTitle = item.title; const keyPoint = item?.part_outline; // 时间点的总结 const specificContent = keyPoint.map(point => { const { timestamp, content } = point const specificTime = secondsToTime(timestamp) return `${ specificTime } ${ content }\n`; }).join(""); return `- ${ smallTitle }\n${ specificContent }\n`; }); resReply += specificTimeSummary.join(""); } return resReply; }) } // 例子：https://twitter.com/chonkyanimalx/status/1595834168000204800 async twitter(e) { // 配置参数及解析 const reg = /https?:\/\/twitter.com\/[0-9-a-zA-Z_]{1,20}\/status\/([0-9]*)/; const twitterUrl = reg.exec(e.msg); const id = twitterUrl[1]; // 判断是否是海外服务器，默认为false const isOversea = !(await this.isOverseasServer()); // 请求 const params = { "ids": id, "media.fields": "duration_ms,height,media_key,preview_image_url,public_metrics,type,url,width,alt_text,variants", "expansions": ["entities.mentions.username", "attachments.media_keys"], } await fetch(TWITTER_TWEET_INFO.replace("{}", id), { headers: { "User-Agent": "v2TweetLookupJS", "authorization": `Bearer ${ Buffer.from(TWITTER_BEARER_TOKEN, "base64").toString() }` }, ...params, agent: !isOversea ? '' : new HttpProxyAgent(this.myProxy), }).then(async resp => { logger.info(resp) e.reply(`识别：小蓝鸟学习版，${ resp.data.text }`); const downloadPath = `${ this.getCurDownloadPath(e) }`; // 创建文件夹（如果没有过这个群） if (!fs.existsSync(downloadPath)) { mkdirsSync(downloadPath); } // 逐个遍历判断 let task = []; for (let item of resp.includes.media) { if (item.type === "photo") { // 图片 task.push(downloadImg(item.url, downloadPath, "", true)); } else if (item.type === "video") { // 视频 await this.downloadVideo(resp.includes.media[0].variants[0].url, true).then( _ => { e.reply(segment.video(`${ downloadPath }/temp.mp4`)); }, ); } } // 如果没有图片直接返回走 if (task.length === 0) { return true; } // 下面是有图片的情况 let images = []; let path = []; // 获取所有图片的promise await Promise.all(task).then(resp => { // console.log(resp) resp.forEach(item => { path.push(item); images.push({ message: segment.image(fs.readFileSync(item)), nickname: this.e.sender.card || this.e.user_id, user_id: this.e.user_id, }); }); }); await e.reply(await Bot.makeForwardMsg(images)); // 清理文件 path.forEach(item => { fs.unlinkSync(item); }); }); return true; } // 使用现有api解析小蓝鸟 async twitter_x(e) { // 配置参数及解析 const reg = /https?:\/\/x.com\/[0-9-a-zA-Z_]{1,20}\/status\/([0-9]*)/; const twitterUrl = reg.exec(e.msg)[0]; // 提取视频 const videoUrl = GENERAL_REQ_LINK.link.replace("{}", twitterUrl); e.reply("识别：小蓝鸟学习版"); const config = { headers: { 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7', 'Accept-Language': 'zh-CN,zh;q=0.9', 'Cache-Control': 'no-cache', 'Connection': 'keep-alive', 'Pragma': 'no-cache', 'Sec-Fetch-Dest': 'document', 'Sec-Fetch-Mode': 'navigate', 'Sec-Fetch-Site': 'none', 'Sec-Fetch-User': '?1', 'Upgrade-Insecure-Requests': '1', 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.0.0 Safari/537.36', }, timeout: 10000 // 设置超时时间 } axios.get(videoUrl, config).then(resp => { const url = resp.data.data?.url; if (url && (url.endsWith(".jpg") || url.endsWith(".png"))) { e.reply(segment.image(url)); } else { this.downloadVideo(url).then(path => { e.reply(segment.video(path + "/temp.mp4")); }); } }); } // acfun解析 async acfun(e) { const path = `${ this.getCurDownloadPath(e) }/temp/`; await mkdirIfNotExists(path); let inputMsg = e.msg; // 适配手机分享：https://m.acfun.cn/v/?ac=32838812&sid=d2b0991bd6ad9c09 if (inputMsg.includes("m.acfun.cn")) { inputMsg = `https://www.acfun.cn/v/ac${ /ac=([^&?]*)/.exec(inputMsg)[1] }`; } parseUrl(inputMsg).then(res => { e.reply(`识别：猴山，${ res.videoName }`); parseM3u8(res.urlM3u8s[res.urlM3u8s.length - 1]).then(res2 => { downloadM3u8Videos(res2.m3u8FullUrls, path).then(_ => { mergeAcFileToMp4(res2.tsNames, path, `${ path }out.mp4`).then(_ => { this.sendVideoToUpload(e, `${ path }out.mp4`) }); }); }); }); return true; } // 小红书解析 async xhs(e) { // 正则说明：匹配手机链接、匹配小程序、匹配PC链接 let msgUrl = /(http:|https:)\/\/(xhslink|xiaohongshu).com\/[A-Za-z\d._?%&+\-=\/#@]*/.exec( e.msg, )?.[0] || /(http:|https:)\/\/www\.xiaohongshu\.com\/discovery\/item\/(\w+)/.exec( e.message[0].data, )?.[0] || /(http:|https:)\/\/www\.xiaohongshu\.com\/explore\/(\w+)/.exec( e.msg, )?.[0] // 解析短号 let id; if (msgUrl.includes("xhslink")) { await fetch(msgUrl, { redirect: "follow", }).then(resp => { const uri = decodeURIComponent(resp.url); // 如果出现了网页验证uri:https://www.xiaohongshu.com/website-login/captcha?redirectPath=https://www.xiaohongshu.com/discovery/item/63c93ac3000000002203b28a?app_platform=android&app_version=8.23.1&author_share=1&ignoreEngage=true&share_from_user_hidden=true&type=normal&xhsshare=CopyLink&appuid=62c58b90000000000303dc54&apptime=1706149572&exSource=&verifyUuid=a5f32b62-453e-426b-98fe-2cfe0c16776d&verifyType=102&verifyBiz=461 const verify = uri.match(/\/item\/([0-9a-fA-F]+)/); // 一般情况下不会出现问题就使用这个正则 id = /explore\/(\w+)/.exec(uri)?.[1] ?? verify?.[1]; }); } else { id = /explore\/(\w+)/.exec(msgUrl)?.[1] || /discovery\/item\/(\w+)/.exec(msgUrl)?.[1]; } const downloadPath = `${ this.getCurDownloadPath(e) }`; // 获取信息 fetch(`${ XHS_REQ_LINK }${ id }`, { headers: XHS_NO_WATERMARK_HEADER, }).then(async resp => { const xhsHtml = await resp.text(); const reg = /window\.__INITIAL_STATE__=(.*?)<\/script>/; const res = xhsHtml.match(reg)[1].replace(/undefined/g, "null"); const resJson = JSON.parse(res); const noteData = resJson.note.noteDetailMap[id].note; const { title, desc, type } = noteData; let imgPromise = []; if (type === "video") { // 封面 const cover = noteData.imageList?.[0].urlDefault; e.reply([segment.image(cover), `识别：小红书, ${ title }\n${ desc }`]); // 构造xhs视频链接 const xhsVideoUrl = noteData.video.media.stream.h264?.[0]?.masterUrl; // 下载视频 this.downloadVideo(xhsVideoUrl).then(path => { if (path === undefined) { // 创建文件，如果不存在 path = `${ this.getCurDownloadPath(e) }/`; } this.sendVideoToUpload(e, `${ path }/temp.mp4`) }); return true; } else if (type === "normal") { e.reply(`识别：小红书, ${ title }\n${ desc }`); noteData.imageList.map(async (item, index) => { imgPromise.push(downloadImg(item.urlDefault, downloadPath, index.toString())); }); } const paths = await Promise.all(imgPromise); const imagesData = await Promise.all( paths.map(async item => { const fileContent = await fs.promises.readFile(item); return { message: segment.image(fileContent), nickname: e.sender.card || e.user_id, user_id: e.user_id, }; }), ); // Reply with forward message e.reply(await Bot.makeForwardMsg(imagesData)); // Clean up files await Promise.all(paths.map(item => fs.promises.unlink(item))); }); return true; } // ins解析 async instagram(e) { let suffix = e.msg.match(/(?<=com\/)[\/a-z0-9A-Z].*/)[0]; if (suffix.startsWith("reel")) { suffix = suffix.replace("reel/", "p/"); } const API = `https://imginn.com/${ suffix }`; // logger.info(API); let imgPromise = []; const downloadPath = `${ this.getCurDownloadPath(e) }`; // 判断是否是海外服务器 const isOversea = await this.isOverseasServer(); // 简单封装图片下载 const downloadInsImg = (url, destination) => { return new Promise((resolve, reject) => { fetch(url, { timeout: 10000, agent: isOversea ? '' : new HttpProxyAgent(this.myProxy), redirect: "follow", follow: 10, }) .then(res => { const dest = fs.createWriteStream(destination); res.body.pipe(dest); dest.on("finish", () => resolve(destination)); }) .catch(err => reject(err)); }); }; await fetch(API, { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/87.0.4280.88 Safari/537.36", }, }).then(async resp => { const html = await resp.text(); const desc = html.match(/(?<=content=").*?(?=\")/g)?.[2]; const images = html.match(/
/g); if (!_.isNull(images)) { e.reply(`识别：Insta，${ desc || "暂无描述" }\n`); images.map((item, index) => { const imgUrl = /(?<=data-src=").*?(?=")/ .exec(item)[0] .replace(/#38/g, "") .replace(/;/g, ""); imgPromise.push(downloadInsImg(imgUrl, `${ downloadPath }/${ index }.jpg`)); }); } // TODO 视频，会出bug暂时不做 // if (html.includes("data-video")) { // const video = html.match(/(?<=data-video=").*?(?=")/g)[0].replace(/#38/g, "").replace(/;/g, "") // this.downloadVideo(video, true).then(path => { // e.reply(segment.video(path)); // }) // } }); if (imgPromise.length > 0) { let path = []; const images = await Promise.all(imgPromise).then(paths => { return paths.map(item => { path.push(item); return { message: segment.image(fs.readFileSync(item)), nickname: e.sender.card || e.user_id, user_id: e.user_id, }; }); }); await this.reply(await Bot.makeForwardMsg(images)); // 清理 path.forEach(item => { fs.unlinkSync(item); }); } return true; } // 波点音乐解析 async bodianMusic(e) { // 音频例子：https://h5app.kuwo.cn/m/bodian/playMusic.html?uid=3216773&musicId=192015898&opusId=&extendType=together // 视频例子：https://h5app.kuwo.cn/m/bodian/play.html?uid=3216773&mvId=118987&opusId=770096&extendType=together const id = /(?=musicId).*?(?=&)/.exec(e.msg.trim())?.[0].replace("musicId=", "") || /(?=mvId).*?(?=&)/.exec(e.msg.trim())?.[0].replace("mvId=", ""); const { name, album, artist, albumPic120, categorys } = await getBodianMusicInfo(id); e.reply([ `识别：波点音乐，${ name }-${ album }-${ artist }\n标签：${ categorys .map(item => item.name) .join(" | ") }`, segment.image(albumPic120), ]); if (e.msg.includes("musicId")) { const path = `${ this.getCurDownloadPath(e) }`; await getBodianAudio(id, path, `${ name }-${ artist }`).then(sendPath => { // 发送语音 e.reply(segment.record(sendPath)); // 上传群文件 this.uploadGroupFile(e, sendPath); // 删除文件 checkAndRemoveFile(sendPath); }); } else if (e.msg.includes("mvId")) { await getBodianMv(id).then(res => { // 下载 && 发送 const { coverUrl, highUrl, lowUrl, shortLowUrl } = res; this.downloadVideo(lowUrl).then(path => { e.reply(segment.video(path + "/temp.mp4")); }); }); } return true; } // 网易云解析 async netease(e) { let message = e.msg === undefined ? e.message.shift().data.replaceAll("\\", "") : e.msg.trim(); // 处理短号，此时会变成y.music.163.com if (message.includes("163cn.tv")) { message = /(http:|https:)\/\/163cn\.tv\/([a-zA-Z0-9]+)/.exec(message)?.[0] // logger.info(message) message = await axios.head(message).then((resp) => { return resp.request.res.responseUrl; }); } // 处理网页链接 const musicUrlReg = /(http:|https:)\/\/music.163.com\/song\/media\/outer\/url\?id=(\d+)/; const musicUrlReg2 = /(http:|https:)\/\/y.music.163.com\/m\/song\?(.*)&id=(\d+)/; const id = musicUrlReg2.exec(message)?.[3] || musicUrlReg.exec(message)?.[2] || /id=(\d+)/.exec(message)[1]; // 如果没有下载地址跳出if if (_.isEmpty(id)) { e.reply(`识别：网易云音乐，解析失败！`); logger.error("[R插件][网易云解析] 没有找到id，无法进行下一步！") return } // 判断海外 const isOversea = await this.isOverseasServer(); // 国内解决方案，替换为国内API (其中，NETEASE_API_CN是国内基址) const AUTO_NETEASE_SONG_DOWNLOAD = isOversea ? NETEASE_SONG_DOWNLOAD : `${NETEASE_API_CN}/song/url?id={}`; const AUTO_NETEASE_SONG_DETAIL = isOversea ? NETEASE_SONG_DETAIL : `${NETEASE_API_CN}/song/detail?ids={}`; logger.info(AUTO_NETEASE_SONG_DOWNLOAD.replace("{}", id)); // 请求netease数据 axios.get(AUTO_NETEASE_SONG_DOWNLOAD.replace("{}", id), { headers: { "User-Agent": "Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.25 Mobile Safari/537.36", }, }).then(async resp => { // 国内解决方案，替换API后这里也需要修改 let url = await resp.data.data?.[0]?.url || null; // 获取歌曲信息 let title = await axios.get(AUTO_NETEASE_SONG_DETAIL.replace("{}", id)).then(res => { const song = res.data.songs[0]; return `${ song?.name }-${ song?.ar?.[0].name }`.replace(/[\/\?<>\\:\*\|".… ]/g, ""); }); // 一般这个情况是VIP歌曲 (如果没有url或者是国内, 国内全走临时接口，后续如果不要删除逻辑'!isOversea ||') if (!isOversea || url == null) { url = await this.musicTempApi(e, title, "网易云音乐"); } else { // 不是VIP歌曲，直接识别完就下一步 e.reply(`识别：网易云音乐，${ title }`); } // 动态判断后缀名 const extensionPattern = /\.([a-zA-Z0-9]+)$/; const musicExt = url.match(extensionPattern)?.[0].replace("\.", ""); // 下载音乐 downloadAudio(url, this.getCurDownloadPath(e), title, 'follow', musicExt).then(async path => { // 发送语音 await e.reply(segment.record(path)); // 上传群文件 await this.uploadGroupFile(e, path); // 删除文件 await checkAndRemoveFile(path); }).catch(err => { logger.error(`下载音乐失败，错误信息为: ${ err.message }`); }); }); return true; } // 临时接口 async musicTempApi(e, title, musicType) { // 临时接口，title经过变换后搜索到的音乐质量提升 const vipMusicData = await axios.get(NETEASE_TEMP_API.replace("{}", title.replace("-", " ")), { headers: { "User-Agent": "Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.25 Mobile Safari/537.36", }, }); const messageTitle = title + "\nR插件检测到当前为VIP音乐，正在转换..."; const url = vipMusicData.data.mp3; const cover = vipMusicData.data.img; e.reply([segment.image(cover), `识别：${musicType}，${ messageTitle }`]); return url; } // 微博解析 async weibo(e) { let weiboId; // 对已知情况进行判断 if (e.msg.includes("m.weibo.cn")) { // https://m.weibo.cn/detail/4976424138313924 weiboId = /(?<=detail\/)[A-Za-z\d]+/.exec(e.msg)?.[0] || /(?<=m.weibo.cn\/)[A-Za-z\d]+\/[A-Za-z\d]+/.exec(e.msg)?.[0]; } else if (e.msg.includes("weibo.com\/tv\/show") && e.msg.includes("mid=")) { // https://weibo.com/tv/show/1034:5007449447661594?mid=5007452630158934 weiboId = /(?<=mid=)[A-Za-z\d]+/.exec(e.msg)?.[0]; weiboId = mid2id(weiboId); } else if (e.msg.includes("weibo.com")) { // https://weibo.com/1707895270/5006106478773472 weiboId = /(?<=weibo.com\/)[A-Za-z\d]+\/[A-Za-z\d]+/.exec(e.msg)?.[0]; } // 无法获取id就结束 if (!weiboId) { e.reply("解析失败：无法获取到wb的id"); return; } const id = weiboId.split("/")[1] || weiboId; const that = this; axios.get(WEIBO_SINGLE_INFO.replace("{}", id), { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.0.0 Safari/537.36", "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9", "cookie": "_T_WM=40835919903; WEIBOCN_FROM=1110006030; MLOGIN=0; XSRF-TOKEN=4399c8", } }) .then(async resp => { const wbData = resp.data.data; const { text, status_title, source, region_name, pics, page_info } = wbData; e.reply(`识别：微博，${ text.replace(/<[^>]+>/g, '') }\n${ status_title }\n${ source }\t${ region_name }`); if (pics) { const removePath = []; // 图片 const imagesPromise = pics.map(item => { // 下载 return downloadImg(item?.large.url || item.url, this.getCurDownloadPath(e), "", false, { "Referer": "http://blog.sina.com.cn/", }); }) const images = await Promise.all(imagesPromise).then(paths => { return paths.map(item => { // 记录删除的路径 removePath.push(item); // 格式化发送图片 return { message: segment.image(fs.readFileSync(item)), nickname: e.sender.card || e.user_id, user_id: e.user_id, } }) }) await e.reply(await Bot.makeForwardMsg(images)); // 发送完就删除 removePath.forEach(async item => { checkAndRemoveFile(item); }) } if (page_info) { // 视频 const videoUrl = page_info.urls?.mp4_720p_mp4 || page_info.urls?.mp4_hd_mp4; // 文章 if (!videoUrl) return true try { this.downloadVideo(videoUrl, false, { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.0.0 Safari/537.36", "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9", "referer": "https://weibo.com/", }).then(path => { this.sendVideoToUpload(e, `${ path }/temp.mp4`) }); } catch (err) { e.reply("视频资源获取失败"); logger.error("403错误：", err); } } }); return true; } /** * 通用解析 * @param e * @return {Promise} */ async general(e) { try { const adapter = await GeneralLinkAdapter.create(e.msg); e.reply(`识别：${ adapter.name }${ adapter.desc ? `, ${ adapter.desc }` : '' }`); logger.mark(adapter); if (adapter.images && adapter.images.length > 0) { const images = adapter.images.map(item => { return { message: segment.image(item), nickname: this.e.sender.card || this.e.user_id, user_id: this.e.user_id, } }) e.reply(Bot.makeForwardMsg(images)); } else if (adapter.video && adapter.video !== '') { // 视频：https://www.kuaishou.com/short-video/3xhjgcmir24m4nm const url = adapter.video; this.downloadVideo(url).then(path => { this.sendVideoToUpload(e, `${ path }/temp.mp4`) }); } else { e.reply("解析失败：无法获取到资源"); } } catch (err) { logger.error("解析失败 ", err); return true } return true } /** * yt-dlp工具类 * @returns {Promise} * @param path 下载路径 * @param url 下载链接 * @param isOversea 是否是海外用户 */ async dy2b(path, url, isOversea) { return new Promise((resolve, reject) => { const command = `yt-dlp ${ isOversea ? "" : `--proxy ${ this.myProxy }` } -P ${ path } -o "temp.%(ext)s" -f 'best[height<=720][ext=mp4]' --merge-output-format "mp4" ${ url }`; exec(command, (error, stdout) => { if (error) { console.error(`Error executing command: ${ error }`); reject(error); } else { console.log(`Command output: ${ stdout }`); resolve(stdout); } }); }); } // 油管解析 async sy2b(e) { let videoSizeLimit = 30 const isOversea = await this.isOverseasServer(); if (!isOversea && !(await testProxy(this.proxyAddr, this.proxyPort))) { e.reply("检测到没有梯子，无法解析油管"); return false; } try { const urlRex = /(?:https?:\/\/)?(www\.|music\.)?youtube\.com\/[A-Za-z\d._?%&+\-=\/#]*/g; const url2Rex = /(?:https?:\/\/)?youtu\.be\/[A-Za-z\d._?%&+\-=\/#]*/g; let url = urlRex.exec(e.msg)?.[0] || url2Rex.exec(e.msg)?.[0]; // 适配 YouTube Music if (url.includes("music")) { // https://music.youtube.com/watch?v=F4sRtMoIgUs&si=7ZYrHjlI3fHAha0F url = url.replace("music", "www"); } const path = this.getCurDownloadPath(e); await checkAndRemoveFile(path + "/temp.mp4") const title = execSync(`yt-dlp --get-title ${ url } ${ isOversea ? "" : `--proxy ${ this.myProxy }` }`) e.reply(`识别：油管，视频下载中请耐心等待 \n${ title }`); await this.dy2b(path, url, isOversea); this.sendVideoToUpload(e, `${ path }/temp.mp4`, videoSizeLimit) } catch (error) { console.error(error); throw error; // Rethrow the error so it can be handled by the caller } return true; } // 米游社 async miyoushe(e) { let url = e.msg === undefined ? e.message.shift().data.replaceAll("\\", "") : e.msg.trim(); let msg = /(?:https?:\/\/)?(m|www)\.miyoushe\.com\/[A-Za-z\d._?%&+\-=\/#]*/.exec(url)?.[0]; const id = /\/(\d+)$/.exec(msg)?.[0].replace("\/", ""); fetch(MIYOUSHE_ARTICLE.replace("{}", id), { headers: { "Accept-Encoding": "gzip, deflate, br", "Accept-Language": "zh-cn", "Connection": "keep-alive", "Host": "api-takumi.mihoyo.com", "x-rpc-app_version": "2.11.0", "x-rpc-client_type": "4", "Referer": "https://bbs.mihoyo.com/", "DS": getDS(), } }).then(async resp => { const respJson = await resp.json(); // debug专用 // fs.writeFile('data.json', JSON.stringify(respJson), (err) => { // if (err) { // console.error('Error writing file:', err); // } else { // console.log('JSON saved to file successfully.'); // } // }); // return; const data = respJson.data.post.post; // 分别获取：封面、主题、内容、图片 const { cover, subject, content, images } = data; let realContent = ""; // safe JSON.parse try { realContent = JSON.parse(content); } catch (e) { realContent = content; } const normalMsg = `识别：米游社，${ subject }\n${ realContent?.describe || "" }`; const replyMsg = cover ? [segment.image(cover), normalMsg] : normalMsg; e.reply(replyMsg); // 图片 if (images && images.length > 1) { const replyImages = images.map(item => { return { message: segment.image(item), nickname: this.e.sender.card || this.e.user_id, user_id: this.e.user_id, } }); e.reply(Bot.makeForwardMsg(replyImages)); } // 视频 let vod_list = respJson.data.post?.vod_list; if (vod_list.length > 0) { const resolutions = vod_list?.[0]?.resolutions; // 逐个遍历是否包含url for (let i = 0; i < resolutions.length; i++) { if (resolutions) { // 暂时选取分辨率较低的video进行解析 const videoUrl = resolutions[i].url; this.downloadVideo(videoUrl).then(path => { this.sendVideoToUpload(e, `${ path }/temp.mp4`) }); break; } } } }) } // pixivision 解析 async pixivision(e) { let msg = /https:\/\/www\.pixivision\.net\/zh\/a\/(\d+)/.exec(e.msg)[0]; if (!msg) { e.reply("pixivision 无法获取到信息"); return; } fetch(msg, { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.0.0 Safari/537.36", } }).then(async resp => { const html = await resp.text(); // 正则表达式来匹配包含特定类名的img标签，并捕获src属性的值 const regex = /]*src="([^"]*)"[^>]*class="[^"]*am__work__illust[^"]*"[^>]*>/g; let matches; const srcs = []; // 获取图片信息 while ((matches = regex.exec(html)) !== null) { // matches[1] 是正则表达式中第一个括号捕获的内容，即src属性的值 srcs.push(matches[1]); } // 获取下载路径 const curPath = this.getCurDownloadPath(e); // 下载图片 Promise.all(srcs.map((item) => { return new Promise((resolve, reject) => { // 使用新的Promise来控制异步流程 axios.get(item, { responseType: 'stream', headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.0.0 Safari/537.36", "Referer": "https://www.pixiv.net/", } }).then(response => { const downloadPath = `${ curPath }/${ item.split('/').pop() }`; const writer = fs.createWriteStream(downloadPath); response.data.pipe(writer); writer.on('finish', () => resolve(downloadPath)); // 在文件写入完成后解决Promise writer.on('error', reject); // 监听错误事件 }).catch(reject); // 处理axios请求的错误 }); })).then(path => { // 在这里，path数组包含的是所有下载并成功写入的文件路径 // 你可以在这里执行e.reply，此时所有文件都已经准备好了 try { // 假设e.reply返回一个Promise e.reply(Bot.makeForwardMsg(path.map(item => ({ message: segment.image(fs.readFileSync(item)), nickname: this.e.sender.card || this.e.user_id, user_id: this.e.user_id, })))); // 删除文件操作 path.forEach(item => { try { fs.unlinkSync(item); } catch (err) { logger.error(`删除文件${ item }失败，请使用命令”清理data垃圾“进行清理`, err); } }); } catch (error) { logger.error(`发送消息失败`, error); } }); }); return true; } // 微视 async weishi(e) { // 拦截恶意链接 【后续如果有小程序检测可以删除这个逻辑】 if (!e.msg.includes('https://isee.weishi.qq.com/ws/app-pages/share/index.html')) { e.reply("识别：微视，但无法完整检测到视频ID"); // 打个日志 方便后面出bug知道位置 logger.error("[R插件][微视] 无法检测链接") return true; } const url = e.msg; try { const idMatch = url.match(/id=(.*)&spid/); if (!idMatch || idMatch.length !== 2) { e.reply("识别：微视，但无法完整检测到视频ID"); // 打个日志 方便后面出bug知道位置 logger.error("[R插件][微视] 无法检测到ID，逻辑大概问题在正则表达式") return true; } const feedId = idMatch[1]; const response = await axios.get(WEISHI_VIDEO_INFO.replace("{}", feedId), { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.0.0 Safari/537.36", } }); const weishiResponse = response.data; const firstFeed = weishiResponse.data.feeds[0]; // 标题、封面、视频链接 const title = firstFeed.feed_desc; const cover = firstFeed.images[0].url; const noWatermarkDownloadUrl = firstFeed.video_url; e.reply([segment.image(cover), `识别：微视，${ title }`]); this.downloadVideo(noWatermarkDownloadUrl).then(path => { this.sendVideoToUpload(e, `${ path }/temp.mp4`) }); } catch (err) { logger.error(err); return true; } return true; } async zuiyou(e) { // #最右#分享一条有趣的内容给你，不好看算我输。请戳链接>>https://share.xiaochuankeji.cn/hybrid/share/post?pid=365367131&zy_to=applink&share_count=1&m=dc114ccc8e55492642f6a702b510c1f6&d=9e18ca2dace030af656baea96321e0ea353fe5c46097a7f3962b93f995641e962796dd5faa231feea5531ac65547045f&app=zuiyou&recommend=r0&name=n0&title_type=t0 let msg = e.msg === undefined ? e.message.shift().data.replaceAll("\\", "") : e.msg.trim(); const url = /(?:https?:\/\/)?(share|share.xiaochuankeji)\.cn\/[A-Za-z\d._?%&+\-=\/#]*/.exec(msg)[0]; try { const response = await axios.get(url, { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.0.0 Safari/537.36", } }); const html = response.data; const videoUrlRegex = /fullscreen="false" src="(.*?)"/; const videoTitleRegex = /:<\/span>

(.*?)<\/h1><\/div>
(.*?)<\/span>/; const videoUrlMatch = html.match(videoUrlRegex); const videoTitleMatch = html.match(videoTitleRegex); const videoCoverMatch = html.match(videoCoverRegex); const videoAuthorMatch = html.match(videoAuthorRegex); const imgSrcRegex = /]*src="([^"]*)"[^>]*\/>/gi; let match; const imgSrcs = []; while ((match = imgSrcRegex.exec(html)) !== null) { imgSrcs.push(match[1]); // Adds the content of the src attribute to the array } const images = imgSrcs.filter(item => item.startsWith("http://bd-tbfile.izuiyou.com/img/view/id")) // Construct the response object const shortVideoInfo = { authorName: videoAuthorMatch ? videoAuthorMatch[1] : '', title: videoTitleMatch ? videoTitleMatch[1] : '', cover: videoCoverMatch ? videoCoverMatch[1] : '' || images[0], noWatermarkDownloadUrl: videoUrlMatch ? videoUrlMatch[1] : '', images, }; e.reply([segment.image(shortVideoInfo.cover), `识别：最右，${ shortVideoInfo.authorName }\n${ shortVideoInfo.title }`]) if (shortVideoInfo.images.length > 0) { const replyImages = shortVideoInfo.images.map(item => { return { message: segment.image(item), nickname: this.e.sender.card || this.e.user_id, user_id: this.e.user_id, } }); e.reply(Bot.makeForwardMsg(replyImages)); } if (shortVideoInfo.noWatermarkDownloadUrl) { this.downloadVideo(shortVideoInfo.noWatermarkDownloadUrl).then(path => { this.sendVideoToUpload(e, `${ path }/temp.mp4`) }); } } catch (error) { console.error(error); throw error; // Rethrow the error so it can be handled by the caller } } async freyr(e) { // https://music.apple.com/cn/album/hectopascal-from-yagate-kimi-ni-naru-piano-arrangement/1468323115?i=1468323724 // 过滤参数 const message = e.msg.replace("&ls", ""); // 匹配名字 const freyrName = message.includes("spotify") ? "Spotify" : "Apple Music"; // 找到R插件保存目录 const currentWorkingDirectory = path.resolve(this.defaultPath); // 如果没有文件夹就创建一个 await mkdirIfNotExists(currentWorkingDirectory + "/am") // 检测是否存在框架 const isExistFreyr = await checkCommandExists("freyr"); if (!isExistFreyr) { e.reply(`检测到没有${freyrName}需要的环境，无法解析！${HELP_DOC}`); return; } // 执行命令 const result = await execSync(`freyr -d ${ currentWorkingDirectory + "/am/" } get ${ message }`); logger.info(result.toString()); // 获取信息 let { title, album, artist } = await this.parseFreyrLog(result.toString()); // 兜底策略 if (freyrName === "Apple Music" && (title === "N/A" || album === "N/A" || artist === "N/A")) { const data = await axios.get(`https://api.fabdl.com/apple-music/get?url=${message}`, { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/118.0.0.0 Safari/537.36", "Referer": "https://apple-music-downloader.com/", "Origin": "https://apple-music-downloader.com", "Accept": "application/json, text/plain, */*", }, }) const { name, artists } = data.data.result; title = name; artist = artists; } // 判断是否是海外服务器 const isOversea = await this.isOverseasServer(); // 国内服务器解决方案 if (!isOversea && !(await testProxy(this.proxyAddr, this.proxyPort))) { // 临时接口 const url = await this.musicTempApi(e, `${title} ${artist}`, freyrName); // 下载音乐 downloadAudio(url, this.getCurDownloadPath(e), title, 'follow').then(async path => { // 发送语音 await e.reply(segment.record(path)); // 判断是不是icqq await this.uploadGroupFile(e, path); await checkAndRemoveFile(path); }).catch(err => { logger.error(`下载音乐失败，错误信息为: ${ err.message }`); }); return true; } e.reply(`识别：${ freyrName }，${ title }--${ artist }`); // 检查目录是否存在 const musicPath = currentWorkingDirectory + "/am/" + artist + "/" + album; const that = this; // 找到音频文件 if (fs.existsSync(musicPath)) { logger.info('目录存在。正在获取.m4a文件...'); // 读取目录中的所有文件和文件夹 fs.readdir(musicPath, (err, files) => { if (err) { e.reply(`${ freyrName }解析出错，请查看日志！`) logger.error('读取目录时出错:', err); return; } // 过滤出以.m4a结尾的文件 const m4aFiles = files.filter(file => path.extname(file).toLowerCase() === '.m4a'); // 打印出所有.m4a文件 logger.info('找到以下.m4a文件:'); m4aFiles.forEach(file => { that.uploadGroupFile(e, path.join(musicPath, file)); }); }); } else { e.reply(`下载失败！没有找到${ freyrName }下载下来文件！`); } // 计数 tools.#amCount += 1; logger.info(`当前${ freyrName }已经下载了：${ tools.#amCount }次`); // 定时清理 if (tools.#amCount >= 5) { await deleteFolderRecursive(currentWorkingDirectory + "/am"); // 重置 tools.#amCount = 0; } return true; } /** * 用于Apple Music抓取部分信息的函数 * @link {applemusic} * @param log * @returns {Promise<{artist: (*|string), album: (*|string), title: (*|string)}>} */ async parseFreyrLog(log) { const titleMatch = log.match(/Title: (.*)/); const albumMatch = log.match(/Album: (.*)/); const artistMatch = log.match(/Artist: (.*)/); const title = titleMatch ? titleMatch[1] : 'N/A'; const album = albumMatch ? albumMatch[1] : 'N/A'; const artist = artistMatch ? artistMatch[1] : 'N/A'; return { title, album, artist }; } async linkShareSummary(e) { // 判断是否有总结的条件 if (_.isEmpty(this.aiApiKey) || _.isEmpty(this.aiApiKey)) { e.reply(`没有配置 Kimi，无法为您总结！${HELP_DOC}`) return true; } const { name, summaryLink } = contentEstimator(e.msg); const builder = await new OpenaiBuilder() .setBaseURL(this.aiBaseURL) .setApiKey(this.aiApiKey) .setModel(this.aiModel) .setPrompt(SUMMARY_PROMPT) .build(); e.reply(`识别：${name}，正在为您总结，请稍等...`, true, { recallMsg: 60 }); const { ans: kimiAns, model } = await builder.kimi(summaryLink); // 计算阅读时间 const stats = estimateReadingTime(kimiAns); e.reply(`当前 ${name} 预计阅读时间: ${stats.minutes} 分钟，总字数: ${stats.words}`) const Msg = await this.makeForwardMsg(e, [`「R插件 x ${ model }」联合为您总结内容：`,kimiAns]); await e.reply(Msg); return true; } /** * 哔哩哔哩下载 * @param title * @param videoUrl * @param audioUrl * @returns {Promise} */ async downBili(title, videoUrl, audioUrl) { return Promise.all([ downloadBFile( videoUrl, title + "-video.m4s", _.throttle( value => logger.mark("视频下载进度", { data: value, }), 1000, ), ), downloadBFile( audioUrl, title + "-audio.m4s", _.throttle( value => logger.mark("音频下载进度", { data: value, }), 1000, ), ), ]).then(data => { return mergeFileToMp4(data[0].fullFileName, data[1].fullFileName, `${ title }.mp4`); }); } /** * douyin 请求参数 * @param url * @returns {Promise} */ async douyinRequest(url) { const params = { headers: { "User-Agent": "Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.25 Mobile Safari/537.36", }, timeout: 10000, }; try { const resp = await axios.head(url, params); const location = resp.request.res.responseUrl; return location; } catch (error) { console.error(error); throw error; } } /** * 获取当前发送人/群的下载路径 * @param e Yunzai 机器人事件 * @returns {string} */ getCurDownloadPath(e) { return `${ this.defaultPath }${ e.group_id || e.user_id }` } /** * 提取视频下载位置 * @returns {{groupPath: string, target: string}} */ getGroupPathAndTarget() { const groupPath = `${ this.defaultPath }${ this.e.group_id || this.e.user_id }`; const target = `${ groupPath }/temp.mp4`; return { groupPath, target }; } /** * 工具：根据URL多线程下载视频 / 音频 * @param url * @param isProxy * @param headers * @param numThreads * @returns {Promise} */ async downloadVideo(url, isProxy = false, headers = null, numThreads = 1) { // 构造群信息参数 const { groupPath, target } = this.getGroupPathAndTarget.call(this); await mkdirIfNotExists(groupPath); // 构造header部分内容 const userAgent = "Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.25 Mobile Safari/537.36"; // 用户设置优先策略，逻辑解释：如果使用了这个函数优先查看用户是否设置了大于1的线程，如果设置了优先使用，没设置就开发者设定的函数设置 numThreads = this.videoDownloadConcurrency !== 1 ? this.videoDownloadConcurrency : numThreads; // 构造代理参数 const proxyOption = { ...(isProxy && { httpAgent: tunnel.httpOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), httpsAgent: tunnel.httpsOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), }), } /** * 构造下载视频参数 * 构造信息：链接、头信息、userAgent、代理信息、下载位置、返回的路径 * @type {{headers: null, userAgent: string, groupPath: string, url, proxyOption: {}, target: string}} */ const downloadVideoParams = { url, headers, userAgent, proxyOption, target, groupPath, } // 如果是用户设置了单线程，则不分片下载 if (numThreads === 1) { return await this.downloadVideoWithSingleThread(downloadVideoParams); } else { return await this.downloadVideoWithMultiThread(downloadVideoParams, numThreads); } } /** * 多线程下载视频 * @link {downloadVideo} * @param downloadVideoParams * @param numThreads * @returns {Promise<*>} */ async downloadVideoWithMultiThread(downloadVideoParams, numThreads) { const { url, headers, userAgent, proxyOption, target, groupPath } = downloadVideoParams; try { // Step 1: 请求视频资源获取 Content-Length const headRes = await axios.head(url, { headers: headers || { "User-Agent": userAgent }, ...proxyOption }); const contentLength = headRes.headers['content-length']; if (!contentLength) { throw new Error("无法获取视频大小"); } // Step 2: 计算每个线程应该下载的文件部分 const partSize = Math.ceil(contentLength / numThreads); let promises = []; for (let i = 0; i < numThreads; i++) { const start = i * partSize; let end = start + partSize - 1; if (i === numThreads - 1) { end = contentLength - 1; // 确保最后一部分可以下载完整 } // Step 3: 并发下载文件的不同部分 const partAxiosConfig = { headers: { "User-Agent": userAgent, "Range": `bytes=${ start }-${ end }` }, responseType: "stream", ...proxyOption }; promises.push(axios.get(url, partAxiosConfig).then(res => { return new Promise((resolve, reject) => { const partPath = `${ target }.part${ i }`; logger.mark(`[R插件][视频下载引擎] 正在下载 part${ i }`) const writer = fs.createWriteStream(partPath); res.data.pipe(writer); writer.on("finish", () => { logger.mark(`[R插件][视频下载引擎] part${ i + 1 } 下载完成`); // 记录线程下载完成 resolve(partPath); }); writer.on("error", reject); }); })); } // 等待所有部分都下载完毕 const parts = await Promise.all(promises); // Step 4: 合并下载的文件部分 await checkAndRemoveFile(target); // 确保目标文件不存在 const writer = fs.createWriteStream(target, { flags: 'a' }); for (const partPath of parts) { await new Promise((resolve, reject) => { const reader = fs.createReadStream(partPath); reader.pipe(writer, { end: false }); reader.on('end', () => { fs.unlinkSync(partPath); // 删除部分文件 resolve(); }); reader.on('error', reject); }); } writer.close(); return groupPath; } catch (err) { logger.error(`下载视频发生错误！\ninfo:${ err }`); } } /** * 单线程下载视频 * @link {downloadVideo} * @returns {Promise} * @param downloadVideoParams */ async downloadVideoWithSingleThread(downloadVideoParams) { const { url, headers, userAgent, proxyOption, target, groupPath } = downloadVideoParams; const axiosConfig = { headers: headers || { "User-Agent": userAgent }, responseType: "stream", ...proxyOption }; try { await checkAndRemoveFile(target); const res = await axios.get(url, axiosConfig); logger.mark(`开始下载: ${ url }`); const writer = fs.createWriteStream(target); res.data.pipe(writer); return new Promise((resolve, reject) => { writer.on("finish", () => resolve(groupPath)); writer.on("error", reject); }); } catch (err) { logger.error(`下载视频发生错误！\ninfo:${ err }`); } } /** * 判断是否是海外服务器 * @return {Promise} */ async isOverseasServer() { // 如果第一次使用没有值就设置 if (!(await redis.exists(REDIS_YUNZAI_ISOVERSEA))) { await redis.set( REDIS_YUNZAI_ISOVERSEA, JSON.stringify({ os: false, }), ); return true; } // 如果有就取出来 return JSON.parse((await redis.get(REDIS_YUNZAI_ISOVERSEA))).os; } /** * 判断是否是拉格朗日驱动 * @returns {Promise} */ async isLagRangeDriver() { // 如果第一次使用没有值就设置 if (!(await redis.exists(REDIS_YUNZAI_LAGRANGE))) { await redis.set( REDIS_YUNZAI_LAGRANGE, JSON.stringify({ driver: 0, }), ); return true; } // 如果有就取出来 return JSON.parse((await redis.get(REDIS_YUNZAI_LAGRANGE))).driver; } /** * 限制用户调用 * @param e * @param func * @return {Promise} */ async limitUserUse(e, func) { if (tools.#tokenBucket.consume(e.user_id, 1)) { await func(); } else { logger.warn(`解析被限制使用`); } } /** * 发送转上传视频 * @param e 交互事件 * @param path 视频所在路径 * @param videoSizeLimit 发送转上传视频的大小限制，默认70MB */ async sendVideoToUpload(e, path, videoSizeLimit = 70) { const isLag = await this.isLagRangeDriver(); // 判断是否是拉格朗日 if (isLag === 1) { // 构造拉格朗日适配器 const lagrange = new LagrangeAdapter(this.toolsConfig.lagrangeForwardWebSocket); // 上传群文件 await lagrange.uploadGroupFile(e.user_id || e.sender.card, e.group_id, path); // 上传完直接返回 return; } // 判断文件是否存在 if (!fs.existsSync(path)) { return e.reply('视频不存在'); } const stats = fs.statSync(path); const videoSize = (stats.size / (1024 * 1024)).toFixed(2); if (videoSize > videoSizeLimit) { e.reply(`当前视频大小：${ videoSize }MB，\n大于设置的最大限制，\n改为上传群文件`); await this.uploadGroupFile(e, path); } else { e.reply(segment.video(path)); } } /** * 上传到群文件 * @param e 交互事件 * @param path 上传的文件所在路径 * @return {Promise} */ async uploadGroupFile(e, path) { // 判断是否是ICQQ if (e.bot?.sendUni) { await e.group.fs.upload(path); } else { await e.group.sendFile(path); } } async makeForwardMsg (e, msg = [], dec = '') { let userInfo = { nickname: e.nickname, user_id: e.user_id } let forwardMsg = [] msg.forEach(v => { forwardMsg.push({ ...userInfo, message: v }) }) if (e.isGroup) { forwardMsg = await e.group.makeForwardMsg(forwardMsg) } else if (e.friend) { forwardMsg = await e.friend.makeForwardMsg(forwardMsg) } else { return false } if (dec) { if (typeof (forwardMsg.data) === 'object') { let detail = forwardMsg.data?.meta?.detail if (detail) { detail.news = [{ text: dec }] } } else { forwardMsg.data = forwardMsg.data .replace('', '') .replace(/\n/g, '') .replace(/(.+?)<\/title>/g, '___') .replace(/___+/, `<title color="#777777" size="26">${dec}`) } } return forwardMsg } }