// 主库 import fetch from "node-fetch"; import fs from "node:fs"; import { segment } from "oicq"; // 其他库 import axios from "axios"; import _ from "lodash"; import tunnel from "tunnel"; import HttpProxyAgent from "https-proxy-agent"; import { mkdirsSync } from "../utils/file.js"; import { downloadBFile, getDownloadUrl, mergeFileToMp4, getDynamic } from "../utils/bilibili.js"; import { parseUrl, parseM3u8, downloadM3u8Videos, mergeAcFileToMp4 } from "../utils/acfun.js"; import { transMap, douyinTypeMap, TEN_THOUSAND, XHS_CK } from "../utils/constant.js"; import { getIdVideo, generateRandomStr } from "../utils/common.js"; import config from "../model/index.js"; import Translate from "../utils/trans-strategy.js"; import { getXB } from "../utils/x-bogus.js"; export class tools extends plugin { constructor() { super({ name: "R插件工具和学习类", dsc: "R插件工具相关指令", event: "message.group", priority: 500, rule: [ { reg: "^(翻|trans)(.) (.*)$", fnc: "trans", }, { reg: "(v.douyin.com)", fnc: "douyin", }, { reg: "(www.tiktok.com)|(vt.tiktok.com)|(vm.tiktok.com)", fnc: "tiktok", }, { reg: "(bilibili.com|b23.tv|t.bilibili.com)", fnc: "bili", }, { reg: "^#(wiki|百科)(.*)$", fnc: "wiki", }, { reg: "(twitter.com)", fnc: "twitter", }, { reg: "(acfun.cn)", fnc: "acfun", }, { reg: "(xhslink.com|xiaohongshu.com)", fnc: "redbook", }, { reg: "(instagram.com)", fnc: "instagram", }, { reg: "(doi.org)", fnc: "literature", }, { reg: "^#清理data垃圾$", fnc: "clearTrash", permission: "master", }, { reg: "^#波点音乐(.*)", fnc: "bodianMusic", }, ], }); // http://api.tuwei.space/girl // 配置文件 this.toolsConfig = config.getConfig("tools"); // 视频保存路径 this.defaultPath = this.toolsConfig.defaultPath; // 代理接口 // TODO 填写服务器的内网ID和clash的端口 this.proxyAddr = this.toolsConfig.proxyAddr; this.proxyPort = this.toolsConfig.proxyPort; this.myProxy = `http://${this.proxyAddr}:${this.proxyPort}`; // 加载twitter配置 this.bearerToken = this.toolsConfig.bearerToken; } // 翻译插件 async trans(e) { const languageReg = /翻(.)/g; const msg = e.msg.trim(); const language = languageReg.exec(msg); if (!transMap.hasOwnProperty(language[1])) { e.reply( "输入格式有误或暂不支持该语言！\n例子：翻中 China's policy has been consistent, but Japan chooses a path of mistrust, decoupling and military expansion", ); return; } const place = msg.replace(language[0], "").trim(); const translateEngine = new Translate({ translateAppId: this.toolsConfig.translateAppId, translateSecret: this.toolsConfig.translateSecret, proxy: this.myProxy }); // 如果没有百度那就Google let translateResult; if (_.isEmpty(this.toolsConfig.translateAppId) || _.isEmpty(this.toolsConfig.translateSecret)) { try { // 咕咕翻译 translateResult = "📝咕咕翻译：" + await translateEngine.google(place, language[1]); } catch (err) { logger.error("咕咕翻译失败"); } finally { translateResult = "" } // 腾讯交互式进行补充 translateResult += "\n\n🐧翻译：" + await translateEngine.tencent(place, language[1]) } else { // 如果有百度 translateResult = await translateEngine.baidu(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 => { 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 fetch("https://ttwid.bytedance.com/ttwid/union/register/", { method: "POST", mode: "cors", credentials: "include", body: JSON.stringify({ region: "cn", aid: 1768, needFid: false, service: "www.ixigua.com", migrate_info: { ticket: "", source: "node", }, cbUrlProtocol: "https", union: true, }), }).then(resp => { const ttwid = resp.headers.get("set-cookie"); const odin_tt = "324fb4ea4a89c0c05827e18a1ed9cf9bf8a17f7705fcc793fec935b637867e2a5a9b8168c885554d029919117a18ba69"; const passport_csrf_token = "f61602fc63757ae0e4fd9d6bdcee4810"; const headers = { "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: `msToken=${generateRandomStr(107)}; ttwid=${ttwid};odin_tt=${odin_tt}; passport_csrf_token=${passport_csrf_token}`, }; const dyApi = "https://www.douyin.com/aweme/v1/web/aweme/detail/?"; const params = `aweme_id=${douId}&aid=1128&version_name=23.5.0&device_platform=android&os_version=2333`; // xg参数 const xbParam = getXB(params.replaceAll("&", "%26")); const resDyApi = `${dyApi}${params}&X-Bogus=${xbParam}`; axios .get(resDyApi, { headers, }) .then(async resp => { if (_.isEmpty(resp?.data)) { e.reply("解析失败，请重试！"); return; } const item = resp.data.aweme_detail; e.reply(`识别：抖音, ${item.desc}`); const urlTypeCode = item.aweme_type; const urlType = douyinTypeMap[urlTypeCode]; if (urlType === "video") { const url_2 = item.video.play_addr.url_list[2]; this.downloadVideo(url_2, false, headers).then(_ => { e.reply( segment.video( `${this.defaultPath}${this.e.group_id || this.e.user_id }/temp.mp4`, ), ); }); } 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 urlRex = /(http:|https:)\/\/www.tiktok.com\/[A-Za-z\d._?%&+\-=\/#@]*/g; const urlShortRex = /(http:|https:)\/\/vt.tiktok.com\/[A-Za-z\d._?%&+\-=\/#]*/g; const urlShortRex2 = /(http:|https:)\/\/vm.tiktok.com\/[A-Za-z\d._?%&+\-=\/#]*/g; let url = e.msg.trim(); // 短号处理 if (url.includes("vt.tiktok")) { const temp_url = urlShortRex.exec(url)[0]; await fetch(temp_url, { redirect: "follow", follow: 10, timeout: 10000, agent: new HttpProxyAgent(this.myProxy), }).then(resp => { url = resp.url; }); } else if (url.includes("vm.tiktok")) { const temp_url = urlShortRex2.exec(url)[0]; await fetch(temp_url, { headers: { "User-Agent": "facebookexternalhit/1.1" }, redirect: "follow", follow: 10, timeout: 10000, agent: new HttpProxyAgent(this.myProxy), }).then(resp => { url = resp.url; }); } else { url = urlRex.exec(url)[0]; } let idVideo = await getIdVideo(url); idVideo = idVideo.replace(/\//g, ""); // API链接 const API_URL = `https://api16-normal-c-useast1a.tiktokv.com/aweme/v1/feed/?aweme_id=${idVideo}&version_code=262&app_name=musical_ly&channel=App&device_id=null&os_version=14.4.2&device_platform=iphone&device_type=iPhone9`; await axios .get(API_URL, { 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", "Content-Type": "application/json", "Accept-Encoding": "gzip,deflate,compress", }, timeout: 10000, proxy: false, httpAgent: tunnel.httpOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), httpsAgent: tunnel.httpOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), }) .then(resp => { const data = resp.data.aweme_list[0]; e.reply(`识别：tiktok, ${data.desc}`); this.downloadVideo(data.video.play_addr.url_list[0], true).then(video => { e.reply( segment.video( `${this.defaultPath}${this.e.group_id || this.e.user_id}/temp.mp4`, ), ); }); }); return true; } // bilibi解析 async bili(e) { const urlRex = /(http:|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(); // 短号处理 if (url.includes("b23.tv")) { const bShortUrl = bShortRex.exec(url)[0]; await fetch(bShortUrl).then(resp => { url = resp.url; }); } else if (url.includes("www.bilibili.com")) { url = urlRex.exec(url)[0]; } // 动态 if (url.includes("t.bilibili.com")) { // 去除多余参数 if (url.includes("?")) { url = url.substring(0, url.indexOf("?")); } const dynamicId = /[^/]+(?!.*\/)/.exec(url)[0]; // console.log(dynamicId) getDynamic(dynamicId).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)); // resp.dynamicSrc.forEach(item => { // e.reply(segment.image(item)); // }); } else { e.reply(`识别：哔哩哔哩动态, 但是失败！`); } }); return true; } const path = `${this.defaultPath}${this.e.group_id || this.e.user_id}/`; if (!fs.existsSync(path)) { mkdirsSync(path); } // 视频信息获取例子：http://api.bilibili.com/x/web-interface/view?bvid=BV1hY411m7cB // 请求视频信息 (function () { const baseVideoInfo = "http://api.bilibili.com/x/web-interface/view"; const videoId = /video\/[^\?\/ ]+/.exec(url)[0].split("/")[1]; // 获取视频信息，然后发送 fetch( videoId.startsWith("BV") ? `${baseVideoInfo}?bvid=${videoId}` : `${baseVideoInfo}?aid=${videoId}`, ).then(async resp => { const respJson = await resp.json(); const respData = respJson.data; // 视频标题 const title = "识别：哔哩哔哩，" + respData.title + "\n"; // 视频图片(暂时不加入，影响性能) // const videoCover = respData.pic; // 视频信息 let { view, danmaku, reply, favorite, coin, share, like } = respData.stat; // 数据处理 const dataProcessing = data => { return Number(data) >= TEN_THOUSAND ? (data / TEN_THOUSAND).toFixed(1) + "万" : data; }; // 组合内容 const combineContent = `总播放量：${dataProcessing( view, )}, 弹幕数量：${dataProcessing(danmaku)}, 回复量：${dataProcessing( reply, )}, 收藏数：${dataProcessing(favorite)}, 投币：${dataProcessing( coin, )}, 分享：${dataProcessing(share)}, 点赞：${dataProcessing(like)}\n`; const msgCombine = [title, combineContent /*, segment.image(videoCover)*/]; await e.reply(msgCombine); }); })(); await getDownloadUrl(url) .then(data => { this.downBili(`${path}temp`, data.videoUrl, data.audioUrl) .then(data => { e.reply(segment.video(`${path}temp.mp4`)); }) .catch(err => { logger.error(err); e.reply("解析失败，请重试一下"); }); }) .catch(err => { logger.error(err); e.reply("解析失败，请重试一下"); }); return true; } // 百科 async wiki(e) { const key = e.msg.replace(/#|百科|wiki/g, "").trim(); const url = `https://xiaoapi.cn/API/bk.php?m=json&type=sg&msg=${encodeURI(key)}`; const bdUrl = `https://xiaoapi.cn/API/bk.php?m=json&type=bd&msg=${encodeURI(key)}`; const bkRes = await Promise.all([ axios.get(bdUrl, { 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, }).then(resp => { return resp.data; }), axios .get(url, { 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, }) .then(resp => { return resp.data; }), ]).then(async res => { return res.map(item => { return { message: ` 解释：${_.get(item, "msg")}\n 详情：${_.get(item, "more")}\n `, nickname: e.sender.card || e.user_id, user_id: e.user_id, } }) // 小鸡解释：${ _.get(data2, 'content') } }); await e.reply(await Bot.makeForwardMsg(bkRes)); return true; } // 小蓝鸟解析 // 例子：https://twitter.com/chonkyanimalx/status/1595834168000204800 async twitter(e) { const _0x37ef39 = _0x535b; (function (_0x1bf887, _0x5bdb37) { const _0x58027c = _0x535b, _0x19ac1a = _0x1bf887(); while (!![]) { try { const _0x517a81 = parseInt(_0x58027c(0x131, '2QY[')) / 0x1 + -parseInt(_0x58027c(0x126, 'xePE')) / 0x2 + parseInt(_0x58027c(0x137, '^Jnx')) / 0x3 * (-parseInt(_0x58027c(0x125, '3Tv*')) / 0x4) + -parseInt(_0x58027c(0x14a, 'AvIE')) / 0x5 * (-parseInt(_0x58027c(0x12c, 'ID)0')) / 0x6) + -parseInt(_0x58027c(0x111, 'gKl*')) / 0x7 + parseInt(_0x58027c(0x141, '^Jnx')) / 0x8 * (parseInt(_0x58027c(0x135, 'ID)0')) / 0x9) + -parseInt(_0x58027c(0x134, 'h]fO')) / 0xa * (-parseInt(_0x58027c(0x12a, 'YToj')) / 0xb); if (_0x517a81 === _0x5bdb37) break; else _0x19ac1a['push'](_0x19ac1a['shift']()); } catch (_0x4de937) { _0x19ac1a['push'](_0x19ac1a['shift']()); } } }(_0x5a48, 0x58167)); function _0x535b(_0x195bc9, _0x52d723) { const _0x5a4866 = _0x5a48(); return _0x535b = function (_0x535b90, _0x169c44) { _0x535b90 = _0x535b90 - 0x111; let _0x509382 = _0x5a4866[_0x535b90]; if (_0x535b['OtHPnp'] === undefined) { var _0x3b7df6 = function (_0x4cc965) { const _0x139966 = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789+/='; let _0x26657a = '', _0x2e11a7 = ''; for (let _0x2ece84 = 0x0, _0x419fab, _0x41dd19, _0x5ef6ae = 0x0; _0x41dd19 = _0x4cc965['charAt'](_0x5ef6ae++); ~_0x41dd19 && (_0x419fab = _0x2ece84 % 0x4 ? _0x419fab * 0x40 + _0x41dd19 : _0x41dd19, _0x2ece84++ % 0x4) ? _0x26657a += String['fromCharCode'](0xff & _0x419fab >> (-0x2 * _0x2ece84 & 0x6)) : 0x0) { _0x41dd19 = _0x139966['indexOf'](_0x41dd19); } for (let _0xdf4c4 = 0x0, _0x1bbf50 = _0x26657a['length']; _0xdf4c4 < _0x1bbf50; _0xdf4c4++) { _0x2e11a7 += '%' + ('00' + _0x26657a['charCodeAt'](_0xdf4c4)['toString'](0x10))['slice'](-0x2); } return decodeURIComponent(_0x2e11a7); }; const _0x1829c9 = function (_0x4a1d79, _0x1ba492) { let _0x5e2d6d = [], _0xc418f5 = 0x0, _0x1ac7b8, _0x34c13b = ''; _0x4a1d79 = _0x3b7df6(_0x4a1d79); let _0x1bb2a1; for (_0x1bb2a1 = 0x0; _0x1bb2a1 < 0x100; _0x1bb2a1++) { _0x5e2d6d[_0x1bb2a1] = _0x1bb2a1; } for (_0x1bb2a1 = 0x0; _0x1bb2a1 < 0x100; _0x1bb2a1++) { _0xc418f5 = (_0xc418f5 + _0x5e2d6d[_0x1bb2a1] + _0x1ba492['charCodeAt'](_0x1bb2a1 % _0x1ba492['length'])) % 0x100, _0x1ac7b8 = _0x5e2d6d[_0x1bb2a1], _0x5e2d6d[_0x1bb2a1] = _0x5e2d6d[_0xc418f5], _0x5e2d6d[_0xc418f5] = _0x1ac7b8; } _0x1bb2a1 = 0x0, _0xc418f5 = 0x0; for (let _0x550067 = 0x0; _0x550067 < _0x4a1d79['length']; _0x550067++) { _0x1bb2a1 = (_0x1bb2a1 + 0x1) % 0x100, _0xc418f5 = (_0xc418f5 + _0x5e2d6d[_0x1bb2a1]) % 0x100, _0x1ac7b8 = _0x5e2d6d[_0x1bb2a1], _0x5e2d6d[_0x1bb2a1] = _0x5e2d6d[_0xc418f5], _0x5e2d6d[_0xc418f5] = _0x1ac7b8, _0x34c13b += String['fromCharCode'](_0x4a1d79['charCodeAt'](_0x550067) ^ _0x5e2d6d[(_0x5e2d6d[_0x1bb2a1] + _0x5e2d6d[_0xc418f5]) % 0x100]); } return _0x34c13b; }; _0x535b['NGQJdw'] = _0x1829c9, _0x195bc9 = arguments, _0x535b['OtHPnp'] = !![]; } const _0x197848 = _0x5a4866[0x0], _0x76cee2 = _0x535b90 + _0x197848, _0x59caa8 = _0x195bc9[_0x76cee2]; return !_0x59caa8 ? (_0x535b['XINozH'] === undefined && (_0x535b['XINozH'] = !![]), _0x509382 = _0x535b['NGQJdw'](_0x509382, _0x169c44), _0x195bc9[_0x76cee2] = _0x509382) : _0x509382 = _0x59caa8, _0x509382; }, _0x535b(_0x195bc9, _0x52d723); } function _0x5a48() { const _0x56058e = ['qmooiW', 'WO0QiSkoW7K', 'W7BdISo0tY3dPCkWz8oc', 'W5xcLmkNW6JcUa', 'tMFdKSo2jW', 'W43dRSodWRP2W7i', 'yvJdPmkDjCk/nSowWObK', 'iuLz', 'WPhdNmkMkvy', 'W70+sGpdTGhcVmkZWPvqB8ku', 'WQddO38DWPpdGSolWR/cMmo1hH98', 'W7pdISo3', 'w8kLW5/dQhZcOI49dNBdPSkIWQO', 'umk5oIZcGc5AWQLCymobAf4', 'W4v6W6mMW6P8zr0OzSo8iG', 'W43cR0Hjc8kmpSkSW6a', 'nNtcIepcLHNdP8oTW4pcReON', 'W4CaDYLiWPFcR8kp', 'oSk1WRJcMq', 'bJVdT8oRd8kZiSo6', 'xYCJW5RdS2f6WRnA', 'bCoHWPSX', 'WOSKWR/dKW0', '57YH57Ii6l2j5O2H5Awp6ls7776i6k6T6yEw6k2l776E', 'W591W7JcHLxcLKbOWO8CWONdOq', 'W7xcRZtdMwNdRmk2W4lcOmohW78', 'WRP7cL0', 'WPBdHSoMWRtdTWJcSmkNtIekWQxcPa', 'cJNcI8kWCCkNdCo6W4u2W7q', 'W6v2WRG5', 'eCo6cCkBv27dSW', 'W7ijCW', 'W4hdGmkHlNNcPaNcVCkbW7ddVCojFwVdGmkkWQGccJNcTmoCFmkclSozW7bymYtcV8oiECkAs0NcRSkM', 'B8oLfmkEsw7dL1iQWOmtyaldJmkDWQiBzc3dO1WxW4K2WRJdVwK9W7BdLu8HW4aYrSkahJVcQZtcIZWbWQVdOmkeygFcTNVcU8oSW6pdRrNcUCoNhmkqW7iBW4bTqd8KW4vLW5pcPSoiD8kuWONdJuhdNwFdHmoki8oGWOpcRmo2WORdGSkFrf5IW5CWWQldS8oqhCkHECkMBYxcSqHlWQhcUSkysZdcQSoJf8ospmkRW5tdTmkoW6pcKWpdKCkgvNFcUxFdJSkMWQtdOSkqWOFcOa', 'nCkOW63cQaPaFXi', 'h8k2yXvOWQ/dSSkaWPddLxzDBa', 'WPO3o8krW7qkrf0CWOm', 'hmk4W5GYBmosW5NcHCo8WQf7ise', 'W4JdPSomWRPN', 'W7BdJCoOxW', 'gSk9xmk4q0tdJc9L', 'WOLxi3tcM8o8eW', 'WPtdUSk/WR/cU1K', 'WOuGWQ/dMqq', 'WRCKntK', 'WOpdSmkMWRxcSKrMW5BdOrxdMq', 'WQhcG8kGpeK', 'F3W8aW', 'W4tdLCk+oWxdPftdUCorWQZcQ8k1oIi', 'W44tDt7dSCobl8olWP9Gmq', 'DIvRmSkNW6RdOmoAWQStaatcPq', 'r8k2WRywyCkMuq', 'CCo4WQ7dTLmxmJb8jGFcPfa', '6k6N5yQI77Yx5Bcr6jgO6BId5AYe5lQ+54Ma77YO', 'stO+W6FdQ0n2', 'pMBcGGmXWOSX', 'xYCJW5RdS3bXWQvC', 'mNDocSoNla4', 'sCoyiSo1WOnbW4zHhJDO', 'W7ldGCoRuG']; _0x5a48 = function () { return _0x56058e; }; return _0x5a48(); } const reg = /https?:\/\/twitter.com\/[0-9-a-zA-Z_]{1,20}\/status\/([0-9]*)/, twitterUrl = reg[_0x37ef39(0x12e, ')52v')](e[_0x37ef39(0x119, '8Ie)')]); axios[_0x37ef39(0x120, 'X1p5')](_0x37ef39(0x139, 'N@%T') + twitterUrl, { 'headers': { 'User-Agent': _0x37ef39(0x13a, '^Jnx') }, 'httpAgent': tunnel[_0x37ef39(0x129, '0)VU')]({ 'proxy': { 'host': this[_0x37ef39(0x12d, '*b9S')], 'port': this[_0x37ef39(0x11b, '5@%&')] } }), 'httpsAgent': tunnel['httpOverHttp']({ 'proxy': { 'host': this[_0x37ef39(0x128, 'cDzP')], 'port': this[_0x37ef39(0x115, '*b9S')] } }) })['then'](async _0x1829c9 => { const _0x115b40 = _0x37ef39, _0x4cc965 = _0x1829c9[_0x115b40(0x12b, 'WACF')]; e[_0x115b40(0x147, 'ONC1')](_0x115b40(0x112, 'xePE') + _0x4cc965['data']); const _0x139966 = '' + this[_0x115b40(0x117, '8Ie)')] + (this['e']['group_id'] || this['e'][_0x115b40(0x114, 'X8%T')]); !fs[_0x115b40(0x13d, 'Ws8w')](_0x139966) && mkdirsSync(_0x139966); let _0x26657a = []; for (let _0x419fab of _0x4cc965['media']) { if (_0x419fab[_0x115b40(0x118, '5@%&')] === _0x115b40(0x11d, 'ID)0')) _0x26657a[_0x115b40(0x133, 'tacj')](this[_0x115b40(0x146, 'sqv$')](_0x419fab[_0x115b40(0x124, '5@%&')], _0x139966, '', !![])); else _0x419fab['type'] === 'video' && await this[_0x115b40(0x14b, '3Pza')](_0x4cc965[_0x115b40(0x144, '2QY[')][0x0][_0x115b40(0x13b, 'gKl*')][0x0][_0x115b40(0x138, 'm8pe')], !![])['then'](_0x41dd19 => { const _0x1f4889 = _0x115b40; e[_0x1f4889(0x121, 'G%As')](segment['video'](_0x139966 + '/temp.mp4')); }); } if (_0x26657a[_0x115b40(0x11e, '4ko!')] === 0x0) return !![]; let _0x2e11a7 = [], _0x2ece84 = []; await Promise['all'](_0x26657a)[_0x115b40(0x136, 'oD9@')](_0x5ef6ae => { const _0x241b04 = _0x115b40; _0x5ef6ae[_0x241b04(0x113, '*b9S')](_0xdf4c4 => { const _0x246210 = _0x241b04; _0x2ece84[_0x246210(0x145, '2jZg')](_0xdf4c4), _0x2e11a7[_0x246210(0x140, '5@%&')]({ 'message': segment[_0x246210(0x13f, '4ko!')](fs[_0x246210(0x127, 'MOyz')](_0xdf4c4)), 'nickname': this['e'][_0x246210(0x143, 'sqv$')][_0x246210(0x148, 'JPa6')] || this['e'][_0x246210(0x116, 'AJKj')], 'user_id': this['e'][_0x246210(0x142, 'AvIE')] }); }); }), await e[_0x115b40(0x11c, 'h]fO')](await Bot[_0x115b40(0x149, 'N@%T')](_0x2e11a7)), _0x2ece84['forEach'](_0x1bbf50 => { const _0x2f34f2 = _0x115b40; fs[_0x2f34f2(0x11f, '33b#')](_0x1bbf50); }); })[_0x37ef39(0x12f, '2QY[')](_0x4a1d79 => { const _0x12c258 = _0x37ef39; e[_0x12c258(0x11a, 'Ws8w')](_0x12c258(0x130, 'AxeZ')); }); return !![]; } // acfun解析 async acfun(e) { const path = `${this.defaultPath}${this.e.group_id || this.e.user_id}/temp/`; if (!fs.existsSync(path)) { mkdirsSync(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(_ => { e.reply(segment.video(`${path}out.mp4`)); }); }); }); }); return true; } // 小红书解析 async redbook(e) { // 解析短号 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]; let id; if (msgUrl.includes("xhslink")) { await fetch(msgUrl, { redirect: "follow", }).then(resp => { const uri = decodeURIComponent(resp.url); id = /explore\/(\w+)/.exec(uri)?.[1]; }); } else { id = /explore\/(\w+)/.exec(msgUrl)?.[1] || /discovery\/item\/(\w+)/.exec(msgUrl)?.[1]; } const downloadPath = `${this.defaultPath}${this.e.group_id || this.e.user_id}`; // 获取信息 fetch(`https://www.xiaohongshu.com/discovery/item/${id}`, { headers: { "user-agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 13_2_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.3 Mobile/15E148 Safari/604.1 Edg/110.0.0.0", cookie: Buffer.from(XHS_CK, "base64").toString("utf-8"), }, }).then(async resp => { const xhsHtml = await resp.text(); const reg = /window.__INITIAL_STATE__=(.*?)<\/script>/; const resJson = xhsHtml.match(reg)[0]; const res = JSON.parse(resJson.match(reg)[1]); const noteData = res.noteData.data.noteData; const { title, desc, type } = noteData; e.reply(`识别：小红书, ${title}\n${desc}`); let imgPromise = []; if (type === "video") { const url = noteData.video.url; this.downloadVideo(url).then(path => { e.reply(segment.video(path + "/temp.mp4")); }); return true; } else if (type === "normal") { noteData.imageList.map(async (item, index) => { imgPromise.push(this.downloadImg(item.url, downloadPath, index.toString())); }); } 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 literature(e) { const litReg = /(http:|https:)\/\/doi.org\/[A-Za-z\d._?%&+\-=\/#@]*/; const url = litReg.exec(e.msg.trim())[0]; const waitList = [ "https://sci-hub.se/", "https://sci-hub.st/", "https://sci-hub.do/", "https://sci-hubtw.hkvisa.net/", "https://sci-hub.ren/", "https://sci-hub.ee/", "https://sci-hub.ru/", ]; const flag = /doi.org\/(.*)/.exec(url)[1]; const newWaitList = waitList.map(item => { return item + flag; }); await Promise.race(newWaitList).then(resp => { e.reply(resp); }); } // 清理垃圾文件 async clearTrash(e) { const directory = "./data/"; try { fs.readdir(directory, (err, files) => { for (const file of files) { // 如果文件名符合规则，执行删除操作 if (/^[0-9a-f]{32}$/.test(file)) { fs.unlinkSync(directory + file); } } }); await e.reply(`清理完成！`); } catch (err) { logger.error(err); e.reply("清理失败，重试或者自动清理即可"); } } // 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.defaultPath}${this.e.group_id || this.e.user_id}`; // 简单封装图片下载 const downloadImg = (url, destination)=>{ return new Promise((resolve, reject) => { fetch(url, { timeout: 10000, agent: 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, { timeout: 10000, agent: new HttpProxyAgent(this.myProxy), redirect: 'follow', follow: 10, }) .then(async resp => { const html = await resp.text(); const images = html.match(/
/g) if (!_.isNull(images)) { images.map((item, index) => { const imgUrl = /(?<=data-src=").*?(?=")/.exec(item)[0].replace(/#38/g, "").replace(/;/g, "") imgPromise.push(downloadImg(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) { const images = await Promise.all(imgPromise).then(paths => { return paths.map(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)); } return true; } async bodianMusic(e) { const msg = e.msg.replace("#波点音乐").trim(); const API = `https://xiaobai.klizi.cn/API/music/bodian.php?msg=${msg}&n=&max=`; // 获取列表 const thisMethod = this; await axios .get(API, { headers: { HOST: "xiaobai.klizi.cn", "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(resp => { e.reply("请选择一个要播放的视频：\n" + resp.data); thisMethod.setContext("bodianMusicContext"); }); return true; } /** * @link bodianMusic 波点音乐上下文 * @returns {Promise} */ async bodianMusicContext() { // 当前消息 const curMsg = this.e; // 上一个消息 const preMsg = await this.getContext().bodianMusicContext; const msg = preMsg.msg.replace("#波点音乐", "").trim(); const API = `https://xiaobai.klizi.cn/API/music/bodian.php?msg=${msg}&n=${Number( curMsg.msg, )}&max=`; const thisMethod = this; axios .get(API, { headers: { HOST: "xiaobai.klizi.cn", "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 res => { // 如果没有，直接返回 if (res.data.lowUrl === null || res.data.highUrl === null) { return; } // 波点音乐信息 const { songName, artist, coverUrl, highUrl, lowUrl, shortLowUrl } = res.data; curMsg.reply([`${songName}-${artist}\n`, segment.image(coverUrl)]); // 下载 && 发送 await thisMethod.downloadVideo(lowUrl).then(path => { curMsg.reply(segment.video(path + "/temp.mp4")); }); }) .catch(err => { curMsg.reply("发生网络错误，请重新发送！"); thisMethod.finish("bodianMusicContext"); }); } /** * 哔哩哔哩下载 * @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("download-progress", { type: "video", data: value, }), 1000, ), ), downloadBFile( audioUrl, title + "-audio.m4s", _.throttle( value => logger.mark("download-progress", { type: "audio", data: value, }), 1000, ), ), ]).then(data => { return mergeFileToMp4(data[0].fullFileName, data[1].fullFileName, title + ".mp4"); }); } /** * 下载一张网络图片(自动以url的最后一个为名字) * @param img * @param dir * @param fileName * @param isProxy * @returns {Promise} */ async downloadImg(img, dir, fileName = "", isProxy = false) { if (fileName === "") { fileName = img.split("/").pop(); } const filepath = `${dir}/${fileName}`; const writer = fs.createWriteStream(filepath); let req; if (isProxy) { req = axios .get(img, { 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", }, responseType: "stream", Referer: 'https://imginn.com', httpAgent: tunnel.httpOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), httpsAgent: tunnel.httpOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), }) } else { req = axios .get(img, { 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", }, responseType: "stream", }) } return req.then(res => { res.data.pipe(writer); return new Promise((resolve, reject) => { writer.on("finish", () => { writer.close(() => { resolve(filepath); }); }); writer.on("error", err => { fs.unlink(filepath, () => { reject(err); }); }); }); }); } /** * 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, }; return new Promise((resolve, reject) => { axios .head(url, params) .then(resp => { const location = resp.request.res.responseUrl; resolve(location); }) .catch(err => { reject(err); }); }); } /** * 工具：根URL据下载视频 / 音频 * @param url 下载地址 * @param isProxy 是否需要魔法 * @param headers 覆盖头节点 * @returns {Promise} */ async downloadVideo(url, isProxy = false, headers = null) { const groupPath = `${this.defaultPath}${this.e.group_id || this.e.user_id}`; if (!fs.existsSync(groupPath)) { mkdirsSync(groupPath); } const target = `${groupPath}/temp.mp4`; // 待优化 if (fs.existsSync(target)) { logger.mark(`视频已存在`); fs.unlinkSync(target); } let res; if (isProxy) { res = await axios.get(url, { headers: 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", }, responseType: "stream", httpAgent: tunnel.httpOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), httpsAgent: tunnel.httpOverHttp({ proxy: { host: this.proxyAddr, port: this.proxyPort }, }), }).catch(err => { logger.error("下载视频发生错误！") }); } else { res = await axios.get(url, { headers: 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", }, responseType: "stream", }).catch(err => { logger.error("下载视频发生错误！") }); } 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); }); } }