From 9844bc4d7878c45222cd379ccbc0cf514552889b Mon Sep 17 00:00:00 2001 From: qq27800734 <27800734@qq.com> Date: Sun, 20 Sep 2026 16:01:06 +0000 Subject: [PATCH] Publish mteam v1.0.2 --- adapters/mteam/adapter.js | 1101 +++++++++++++++++++++++++++---------- 1 file changed, 816 insertions(+), 285 deletions(-) diff --git a/adapters/mteam/adapter.js b/adapters/mteam/adapter.js index 7536953..38d711e 100644 --- a/adapters/mteam/adapter.js +++ b/adapters/mteam/adapter.js @@ -1,29 +1,83 @@ -// M-Team (mteam) 适配脚本 — JSON API 站点，使用 POST + x-api-key（Authorization 头）。 -// 由 mteam.groovy 参考移植；与 mediabot2 共享 Jint 沙箱环境。 -// mediabot2 注入：http, html, json, utils；注册中心 Jint SDK 注入：parseHtml / httpClient / console / __wrapNode。 -// 入口函数（与注册中心标准能力模板一一对应）： -// search(ctx) —— 搜索种子（能力: search，POST /api/torrent/search，JSON 体） -// userdetail(ctx) —— 用户资料（能力: userdetail，POST profile 接口，memberCount/invites/username） -// sync(ctx) —— 站点信息同步（mediabot2 Host 调用：profile + peerStats 合并上报） -// parse(content, url) —— 纯解析入口（校验沙箱 /validate 使用；pageKey 取 url 末段或默认 profile） -// download(ctx) —— 下载 .torrent 种子字节（能力: download，尽力而为） -// 站点配置（definition 选择器中可覆盖）：ctx.apiBase(默认为 baseUrl) / ctx.apiKey(或 xApiKey) / -// ctx.profilePath(默认 /api/user/profile) / ctx.peerStatsPath(默认 /api/torrent/seeding) / -// ctx.searchPath(默认 /api/torrent/search) / ctx.downloadPath(默认 /api/torrent/download)。 +// NexusPHP 框架共用脚本：所有 NexusPHP 站点用同一份，站点差异由各自的 definition 选择器提供。 +// mediabot2 经 Jint 沙箱执行，注入：content, url, http, html, json, utils +// 入口函数（与注册中心 7 个标准能力模板一一对应，能力名 = 函数名）： +// search(ctx) —— 搜索种子（能力: search） +// detail(ctx) —— 种子详情（能力: detail） +// index(ctx) —— 用户统计（能力: index，解析首页信息块） +// userdetail(ctx) —— 用户详情（能力: userdetail，解析 userdetails.php） +// signIn(ctx) —— 签到（能力: signIn） +// download(ctx) —— 下载 .torrent 种子文件字节（能力: download） +// sync(ctx) —— 站点信息同步（mediabot2 Host 调用：首页统计 + 账号资料） +// parse(content, url) —— 解析用户统计页（校验沙箱 /validate 使用，http 走 mock） +// rss(ctx) —— RSS 刷流（供 RssDiscoveryJob，非标准能力） // ==================== 运行环境兼容层 ==================== +// mediabot2 宿主注入: http / html / utils / json； +// 注册中心 Jint SDK 注入: parseHtml / httpClient / console / __wrapNode。 +// 以下兼容代码仅在注册中心沙箱中生效（mediabot2 环境已有同名对象，条件不成立时零影响）。 if (typeof http === 'undefined') { var http = { get: function(url) { return httpClient.getString(url); }, + // SDK 未提供 POST，注册中心沙箱中回退为 GET（mock 环境仅用于样本解析验证） post: function(url) { return httpClient.getString(url); }, getBytes: function(url) { return httpClient.getBytes(url); } }; } +if (typeof html === 'undefined') { + var html = { + parse: function(h) { + var doc = parseHtml(h); + var oQS = doc.querySelector, oQSA = doc.querySelectorAll; + var oGEI = doc.getElementById, oGET = doc.getElementsByTagName; + doc.querySelector = function(sel) { return __adapt(oQS.call(doc, sel)); }; + doc.querySelectorAll = function(sel) { + var r = oQSA.call(doc, sel) || [], out = []; + for (var i = 0; i < r.length; i++) out.push(__adapt(r[i])); + return out; + }; + doc.getElementById = function(id) { return __adapt(oGEI.call(doc, id)); }; + doc.getElementsByTagName = function(tag) { + var r = oGET.call(doc, tag) || [], out = []; + for (var j = 0; j < r.length; j++) out.push(__adapt(r[j])); + return out; + }; + doc.queryList = doc.querySelectorAll; + return doc; + } + }; +} -// 是否运行在注册中心沙箱（SDK 才有 parseHtml / __wrapNode） +// 为 SDK wrapNode 补齐 mediabot2 DOM 约定: attr / queryList / nextElementSibling +function __adapt(n) { + if (!n || typeof n !== 'object' || n.__adapted) return n; + try { + n.__adapted = true; + if (typeof n.attr !== 'function') n.attr = function(name) { return n.getAttribute(name); }; + if (typeof n.queryList !== 'function') n.queryList = function(sel) { return n.querySelectorAll(sel) || []; }; + if (typeof n.nextElementSibling === 'undefined' && n._node) { + try { n.nextElementSibling = __adapt(__wrapNode(n._node.NextElementSibling)); } + catch (e) { n.nextElementSibling = null; } + } + // 递归: 子查询返回的新包装对象也要经过 __adapt + if (typeof n.querySelector === 'function' && !n.__qsw) { + n.__qsw = true; + var oqs = n.querySelector, oqsa = n.querySelectorAll; + n.querySelector = function(sel) { return __adapt(oqs.call(n, sel)); }; + n.querySelectorAll = function(sel) { + var r = oqsa.call(n, sel) || [], out = []; + for (var i = 0; i < r.length; i++) out.push(__adapt(r[i])); + return out; + }; + } + } catch (e) {} + return n; +} + +// 是否运行在注册中心沙箱（SDK 才有 __wrapNode） var __inRegistrySandbox = (typeof __wrapNode === 'function'); // 注册中心 ParseInputArgs 把 testInput 原始 JSON 串按位置传参; mediabot2 直接传对象。 +// 入口函数统一经 __asCtx 归一化，两种调用方式都兼容。 function __asCtx(arg) { if (typeof arg === 'string' && arg.length > 0) { try { @@ -35,318 +89,703 @@ function __asCtx(arg) { return (arg && typeof arg === 'object') ? arg : {}; } -// 取 API base；注册中心沙箱中为空时用占位地址（mock http 回退，不影响解析链路） +// 取 baseUrl；注册中心沙箱中为空时用占位地址（mock http 会回退返回样本 HTML，不影响解析链路） function __resolveBase(ctx) { - var b = String(ctx && (ctx.apiBase || ctx.baseUrl) ? (ctx.apiBase || ctx.baseUrl) : '').replace(/\/+$/, ''); + var b = String(ctx && ctx.baseUrl ? ctx.baseUrl : '').replace(/\/+$/, ''); if (!b && __inRegistrySandbox) b = 'http://mock.local'; return b; } -// 声明式安全 JSON 解析（不用正则，兼容旧版 Jint） -function __parseJson(text) { - if (text === null || text === undefined) return null; - if (typeof text === 'object') return text; - var s = String(text).trim(); - if (!s) return null; - // 登录墙 / 错误页通常是 HTML 或非 JSON 文本 - if (s.charAt(0) !== '{' && s.charAt(0) !== '[') return null; - try { - return JSON.parse(s); - } catch (e) { - return null; +function unitToBytes(unit) { + if (!unit) return 1; + switch (String(unit).toUpperCase()) { + case 'PB': return 1024 * 1024 * 1024 * 1024 * 1024; + case 'TB': return 1024 * 1024 * 1024 * 1024; + case 'GB': return 1024 * 1024 * 1024; + case 'MB': return 1024 * 1024; + case 'KB': return 1024; + default: return 1; } } -// POST JSON 并返回解析后的对象；失败返回 null。注册中心沙箱回退 GET（仅用于快照解析验证）。 -function __apiPost(base, path, body, apiKey) { - var url = path && path.indexOf('http') === 0 ? path : base + path; - var headers = {}; - if (apiKey) headers['x-api-key'] = apiKey; - var raw = null; - try { - raw = http.post(url, JSON.stringify(body || {}), headers); - } catch (e1) { - try { - raw = http.post(url, JSON.stringify(body || {})); - } catch (e2) { - try { - raw = http.post(url); - } catch (e3) { - raw = null; - } - } +// 标签后直接匹配数值（兼容 "上传量: 1.23 TB" / "上传量 1.23 TB" / 表格布局） +function parseSize(text, labelPattern) { + var re = new RegExp(labelPattern + '\\s*[:：]?\\s*([\\d.,]+)\\s*(TB|GB|MB|KB|PB|B)?', 'i'); + var m = text.match(re); + if (!m) return null; + var num = parseFloat(m[1].replace(/,/g, '')); + if (isNaN(num)) return null; + return Math.round(num * unitToBytes(m[2])); +} + +function parseDecimal(text, labelPattern) { + var re = new RegExp(labelPattern + '\\s*[:：]?\\s*([\\d.,]+)', 'i'); + var m = text.match(re); + if (!m) return null; + var v = parseFloat(m[1].replace(/,/g, '')); + return isNaN(v) ? null : v; +} + +function parseInteger(text, labelPattern) { + var re = new RegExp(labelPattern + '\\s*[:：]?\\s*([\\d,]+)', 'i'); + var m = text.match(re); + if (!m) return null; + var v = parseInt(m[1].replace(/,/g, ''), 10); + return isNaN(v) ? null : v; +} + +// 从信息块解析 uid / 用户名（userdetails 链接） +function parseIdentity(block) { + var uid = null; + var userName = null; + var link = block ? block.querySelector('a[href*="userdetails"]') : null; + if (link) { + var href = link.attr('href') || ''; + var um = href.match(/[?&]id=(\d+)/i); + if (um) uid = um[1]; + var t = link.text(); + if (t) userName = t; } - return __parseJson(raw); + return { uid: uid, userName: userName }; } -// 视数字为 GiB 时换算成字节（M-Team memberCount.uploaded/downloaded 单位） -var __GIB = 1073741824; +// 解析首页统计：上传/下载/魔力/分享率/做种/下载活动/H&R +function parseIndexStats(indexHtml) { + var doc = html.parse(indexHtml); + var block = doc.querySelector('#info_block'); + var text = block ? block.text() : indexHtml; -function __toLong(v) { - if (v === null || v === undefined) return null; - var n = Number(v); - return isNaN(n) ? null : Math.round(n); -} + var up = parseSize(text, '(?:上传量?|上傳量?)'); + var down = parseSize(text, '(?:下载量?|下載量?)'); + if (up === null && down === null) return null; -function __toInt(v) { - var n = __toLong(v); - return n === null ? 0 : n; -} - -function __toDouble(v) { - if (v === null || v === undefined) return null; - var n = Number(v); - return isNaN(n) ? null : n; -} - -// M-Team discount 促销状态 → 标记 -function __promoOf(discount, makeFree) { - var d = String(discount || '').toUpperCase(); - if (makeFree || d === 'FREE' || d.indexOf('FREE') >= 0) return 'free'; - if (d === '2X' || d === '2XUP' || d.indexOf('2X') >= 0) return '2x'; - if (d.indexOf('50') >= 0) return 'half'; - return d || null; -} - -// ===================== 解析器（移植 mteam.groovy） ===================== - -// profile: root.data { username, invites, memberCount:{ uploaded, downloaded, bonus, shareRate } } -function parseProfile(d) { - if (!d) return { pageName: '用户信息', matched: false, message: 'data 为空', incomplete: true }; - var mc = (d.memberCount && typeof d.memberCount === 'object') ? d.memberCount : {}; - var r = { pageName: '用户信息', matched: true, incomplete: false }; - if (mc.uploaded !== undefined && mc.uploaded !== null) r.upload = __toInt(mc.uploaded) * __GIB; - if (mc.downloaded !== undefined && mc.downloaded !== null) r.download = __toInt(mc.downloaded) * __GIB; - if (mc.bonus !== undefined && mc.bonus !== null) r.bonus = __toDouble(mc.bonus); - if (mc.shareRate !== undefined && mc.shareRate !== null) r.shareRate = __toDouble(mc.shareRate); - if (d.invites !== undefined && d.invites !== null) r.invites = __toInt(d.invites); - if (d.username) r.username = String(d.username); - if (!r.upload && !r.download) r.incomplete = true; - return r; -} - -// peerStats: root.data { seederCount }（兼容 { total } 或 { data:[...] } 取长度） -function parsePeerStats(d) { - if (!d) return { pageName: '做种统计', matched: false, message: 'data 为空', incomplete: true }; - var seeding = null; - if (d.seederCount !== undefined && d.seederCount !== null) seeding = __toInt(d.seederCount); - else if (d.total !== undefined && d.total !== null) seeding = __toInt(d.total); - else if (d.data && typeof d.data.length === 'number') seeding = d.data.length; - if (seeding === null) return { pageName: '做种统计', matched: false, message: '无法解析做种数', incomplete: true }; - return { pageName: '做种统计', matched: true, incomplete: false, seeding: seeding }; -} - -// search: root.data.data = [ { id, name, smallDescr, size, status:{...}, createdDate, category, -// author, labelsNew, dobby, douban, doubanRating, imdb, hasChineseSubtitle, standard } ] -function parseSearch(items) { - if (!items || items.length === 0) { - return { pageName: '搜索', matched: true, items: [], message: '无结果', incomplete: false }; + var bonus = parseDecimal(text, '魔力值(?:\\[\\s*使用\\s*\\])?'); + if (bonus === null) { + // PTTIME: 魔力值(77.45魔力/小时)[使用&说明]: 799327.2 + var bm = text.match(/魔力值.*?[:：]\s*([\d.,]+)/i); + if (bm) bonus = parseFloat(bm[1].replace(/,/g, '')); } - var rows = []; - for (var i = 0; i < items.length; i++) { - var it = items[i]; - if (it === null || typeof it !== 'object') continue; - var st = (it.status && typeof it.status === 'object') ? it.status : {}; - var size = __toLong(it.size); - var free = String(st.discount || '').toUpperCase() === 'FREE' - || String(st.discount || '').toUpperCase() === '_2X_FREE' - || String(st.discount || '').toUpperCase() === '2X_FREE'; - var tags = ''; - if (it.labelsNew && typeof it.labelsNew.length === 'number') { - var parts = []; - for (var t = 0; t < it.labelsNew.length; t++) { - var lb = it.labelsNew[t]; - if (lb === null || lb === undefined) continue; - var tv = (typeof lb === 'object') ? (lb.name || lb.label || '') : String(lb); - if (tv) parts.push(tv); - } - tags = parts.join(','); - } - var rating = it.doubanRating !== undefined && it.doubanRating !== null ? String(it.doubanRating) : ''; - var cnSub = it.hasChineseSubtitle !== undefined && it.hasChineseSubtitle !== null - ? String(it.hasChineseSubtitle) : ''; - var row = { - id: it.id !== undefined && it.id !== null ? String(it.id) : '', - title: it.name || '', - subTitle: it.smallDescr || '', - size: size, - seeders: __toInt(st.seeders), - leechers: __toInt(st.leechers), - completed: __toInt(st.timesCompleted), - publishDate: it.createdDate || '', - category: it.category || '', - free: free, - freeEndTime: st.discountEndTime || '', - publisher: it.author || '', - tags: tags, - doubanUrl: it.douban || '', - doubanId: (function(){ var m = String(it.douban || '').match(/douban\.com\/subject\/(\d+)/i); return m ? m[1] : ''; })(), - doubanRating: rating, - imdbUrl: it.imdb || '', - imdbId: (function(){ var m = String(it.imdb || '').match(/imdb\.com\/title\/(tt\d+)/i); return m ? m[1] : ''; })(), - cnSub: cnSub, - standard: it.standard || '', - detailUrl: it.id !== undefined && it.id !== null ? 'detail/' + String(it.id) : '', - promo: __promoOf(st.discount, free) - }; - rows.push(row); - } - return { pageName: '搜索', extracted: rows, items: rows, matched: true, message: '共 ' + rows.length + ' 条', incomplete: false }; -} + var ratio = parseDecimal(text, '(?:分享率|分享比率)'); -// 从 url 末段推断 pageKey（parse 入口用）；无匹配时默认 profile -function __pageKeyOf(url) { - var u = String(url || '').replace(/\/+$/, ''); - var seg = u.substring(u.lastIndexOf('/') + 1); - if (seg === 'search' || seg === 'torrent-search') return 'search'; - if (seg === 'seeding' || seg === 'peerStats' || seg === 'peerstats') return 'peerStats'; - return 'profile'; -} - -// ===================== 纯解析入口（注册中心 /validate 使用） ===================== -// content：接口原始 JSON 文本；url：以末段路径携带 pageKey（search/peerStats/profile）。 -// 与 groovy parse(content, pageKey) 语义一致。 -function parse(content, url) { - var root = __parseJson(content); - if (root === null) { - return { pageName: '解析失败', message: '响应非 JSON（可能是登录墙/错误页）', incomplete: true }; + var seeding = null, leeching = null; + var act = text.match(/当前活动\s*[:：]\s*(\d+)\s+(\d+)/i); + if (!act) act = text.match(/活动\s*[:：]\s*[^\d]*(\d+)[^\d]*(\d+)/i); // PTTIME: "活动: ⬆16 ⬇2" + if (act) { + seeding = parseInt(act[1], 10); + leeching = parseInt(act[2], 10); + } else { + seeding = parseInteger(text, '(?:做种|做種)'); } - var data = root.data !== undefined ? root.data : root; - var pageKey = __pageKeyOf(url); - switch (pageKey) { - case 'profile': - var p = parseProfile(data); - if (!p.matched && root.status !== undefined && String(root.status) !== '0') { - p.message = '接口返回异常: ' + String(root.message || root.msg || root.status); - } - return p; - case 'peerStats': - return parsePeerStats(data); - case 'search': - return parseSearch(data && data.data !== undefined ? data.data : []); - default: - return { pageName: '未知接口', error: '未知 pageKey: ' + pageKey, incomplete: true }; - } -} -// ===================== 能力: userdetail（用户资料） ===================== -// ctx: { baseUrl, apiKey, ... }，POST profile 接口，返回用户资料。 -function userdetail(input) { - var ctx = __asCtx(input); - var base = __resolveBase(ctx); - if (!base || base === 'http://mock.local') return { error: 'no_base_url' }; - var root = __apiPost(base, ctx.profilePath || '/api/user/profile', {}, ctx.apiKey || ctx.xApiKey); - if (root === null) return { error: 'profile_fetch_failed' }; - var data = root.data !== undefined ? root.data : root; - var p = parseProfile(data); - if (!p.matched) return { error: 'profile_no_match' }; + var hr = null; + var hrM = text.match(/H&R\s*[:：]\s*\[\s*\d+\s*\/\s*(\d+)\s*\/\s*\d+\s*\]/i); + if (hrM) hr = parseInt(hrM[1], 10); + + var identity = parseIdentity(block || doc); return { - userName: p.username || null, - invites: p.invites, - uploaded: p.upload, - downloaded: p.download, - bonus: p.bonus, - shareRate: p.shareRate + uploaded: up, + downloaded: down, + bonus: bonus, + ratio: ratio, + seeding: seeding, + leeching: leeching, + hr: hr, + uid: identity.uid, + userName: identity.userName }; } -// ===================== 能力: search（搜索种子） ===================== -// ctx: { baseUrl, apiKey, keyword, page(=1), pageSize(=100), searchPath(可选) } -// 走 http POST JSON 体 { keyword, pageNumber, pageSize }。 +// 解析 userdetails.php 账号资料：邮箱/等级/注册日期/最近动向/做种积分/封存状态 + uid/用户名 +// 注意：userdetails 的字段在 #info_block 之外的资料表格中，故用整页 body 文本解析 +function parseUserDetails(userHtml) { + var doc = html.parse(userHtml); + var body = doc.querySelector('body') || doc; + var text = body.text() || userHtml; + + var email = null; + // DOM 优先：从 提取最准确 + var mailLink = doc.querySelector('a[href*="mailto:"]'); + if (mailLink) { + var href = mailLink.attr('href') || ''; + var mm = href.match(/mailto:([\w.+-]+@[\w.-]+\.\w+)/i); + if (mm) email = mm[1]; + else email = mailLink.text(); + } + // 退路：正则从 body text 搜 + if (!email) { + var em = text.match(/(?:邮箱|Email|E-mail)\s*[:：]?\s*([\w.+-]+@[\w.-]+\.\w+)/i); + if (em) email = em[1]; + } + + // 等级：DOM 解析，遍历每行 tr，找 label td 文本为 等级/级别/Class 的行，取其右边 td 的内容 + var classLevel = null; + var rows = doc.queryList('tr'); + for (var i = 0; i < rows.length && !classLevel; i++) { + var cells = rows[i].queryList('td'); + if (cells.length >= 2) { + var label = cells[0].text(); + if (label === '等级' || label === '级别' || label === 'Class' || label === '用户等级') { + var img = cells[1].querySelector('img'); + var b = cells[1].querySelector('b'); + if (img) { + classLevel = img.attr('alt'); + } else if (b) { + classLevel = b.text(); // PTTIME: 等级在 内 + } else { + classLevel = cells[1].text(); + } + // 去掉前导括号前缀，如 "(幼儿园)User" → "User" + if (classLevel) { + classLevel = classLevel.replace(/^\s*\([^)]*\)\s*/, ''); + } + } + } + } + + var registerDate = null; + var regM = text.match(/(?:注册日期|加入日期|Registered)\s*[:：]?\s*(\d{4}-\d{2}-\d{2})/i); + if (regM) registerDate = regM[1]; + + // 最近动向：NexusPHP 常为 "xx 天/时 前" 或绝对时间，原样截取供上层判断 + var lastActivityAt = null; + var laM = text.match(/(?:最近动向|最近活动|最后活动|最近上站|Last\s*(?:Seen|Active|Activity))\s*[:：]?\s*([^\n\r]{1,40})/i); + if (laM) lastActivityAt = laM[1].trim(); + + // 做种积分 + var seedingScore = null; + var ssM = text.match(/(?:做种积分|做種積分|Seeding\s*(?:Bonus|Points?))\s*[:：]?\s*([\d.,]+)/i); + if (ssM) { + var sv = parseFloat(ssM[1].replace(/,/g, '')); + if (!isNaN(sv)) seedingScore = sv; + } + + // 封存/封禁检测 + var isSealed = /封存|帳號已?被封|账号已?被封/.test(text); + + var identity = parseIdentity(doc.querySelector('#info_block') || doc); + return { + uid: identity.uid, + userName: identity.userName, + email: email, + classLevel: classLevel, + registerDate: registerDate, + lastActivityAt: lastActivityAt, + seedingScore: seedingScore, + isSealed: isSealed + }; +} + +// ================= 能力: index（用户统计）================= +// ctx: { baseUrl, ... }。解析首页信息块，返回当前登录用户统计。 +function index(input) { + var ctx = __asCtx(input); + var base = __resolveBase(ctx); + if (!base) return { error: 'no_base_url' }; + + var indexHtml = null; + var paths = ['/index.php', '/']; + for (var i = 0; i < paths.length; i++) { + try { + indexHtml = http.get(base + paths[i]); + } catch (e) { + indexHtml = null; + } + if (indexHtml && indexHtml.length > 0) break; + } + if (!indexHtml) return { error: 'index_fetch_failed' }; + + var stats = parseIndexStats(indexHtml); + if (!stats) return { error: 'index_no_match', html: indexHtml }; + return stats; +} + +// ================= 能力: userdetail（用户详情）================= +// ctx: { baseUrl, userId (或 uid) } +function userdetail(input) { + var ctx = __asCtx(input); + var base = __resolveBase(ctx); + if (!base) return { error: 'no_base_url' }; + var uid = (ctx && (ctx.userId || ctx.uid)) || ''; + if (!uid) return { error: 'no_user_id' }; + + var userHtml; + try { + userHtml = http.get(base + '/userdetails.php?id=' + encodeURIComponent(uid)); + } catch (e) { + return { error: String((e && e.message) || e) }; + } + if (!userHtml) return { error: 'userdetails_fetch_failed' }; + + var profile = parseUserDetails(userHtml); + if (!profile) return { error: 'userdetails_no_match', html: userHtml }; + return { + uid: profile.uid || uid, + userName: profile.userName, + userClass: profile.classLevel, + registeredAt: profile.registerDate, + lastActivityAt: profile.lastActivityAt, + seedingScore: profile.seedingScore, + profileEmail: profile.email, + isSealed: profile.isSealed + }; +} + +// ================= 站点信息同步（mediabot2 Host 调用）================= +// ctx: { siteCode, siteId, baseUrl, uid, userName, utcNow, frameworkVersion } +// Success: returns stats object. Failure: returns { error, html?, userHtml? } carrying raw HTML +// so Host can report it verbatim to Registry. NEVER return null; always include `error`. +function sync(input) { + var ctx = __asCtx(input); + var base = __resolveBase(ctx); + if (!base) return { error: 'no_base_url' }; + + // 1. fetch index page (index.php first, root fallback) + var indexHtml = null; + var paths = ['/index.php', '/']; + for (var i = 0; i < paths.length; i++) { + try { + indexHtml = http.get(base + paths[i]); + } catch (e) { + indexHtml = null; + } + if (indexHtml && indexHtml.length > 0) break; + } + if (!indexHtml) return { error: 'index_fetch_failed' }; + + var indexStats = parseIndexStats(indexHtml); + if (!indexStats) return { error: 'index_no_match', html: indexHtml }; + + // 2. if uid known, fetch userdetails.php?id={uid} to parse profile + var uid = indexStats.uid || (ctx && ctx.uid) || null; + var profile = null; + var userHtml = null; + if (uid) { + try { + userHtml = http.get(base + '/userdetails.php?id=' + encodeURIComponent(uid)); + if (userHtml && userHtml.length > 0) { + profile = parseUserDetails(userHtml); + // content fetched but no profile fields parsed (CAPTCHA / login wall): treat as failure + if (profile && profile.email === null && profile.classLevel === null && profile.registerDate === null) { + profile = null; + } + } + } catch (e) { + profile = null; + } + } + // userdetails fetch/parse failed: stats available, attach userHtml for Host reporting + if (uid && !profile) { + return { + uploaded: indexStats.uploaded, + downloaded: indexStats.downloaded, + bonus: indexStats.bonus, + ratio: indexStats.ratio, + seeding: indexStats.seeding, + leeching: indexStats.leeching, + hr: indexStats.hr, + uid: uid, + userName: indexStats.userName || (ctx && ctx.userName) || null, + email: null, + classLevel: null, + registerDate: null, + error: 'userdetails_no_match', + html: indexHtml, + userHtml: userHtml + }; + } + + return { + uploaded: indexStats.uploaded, + downloaded: indexStats.downloaded, + bonus: indexStats.bonus, + ratio: indexStats.ratio, + seeding: indexStats.seeding, + leeching: indexStats.leeching, + hr: indexStats.hr, + uid: uid, + userName: (profile && profile.userName) || indexStats.userName || (ctx && ctx.userName) || null, + email: (profile && profile.email) || null, + classLevel: (profile && profile.classLevel) || null, + registerDate: (profile && profile.registerDate) || null + }; +} + +function parse(content, url) { + var doc = html.parse(content); + return { + uploaded: doc.queryText('#seedup a'), + downloaded: doc.queryText('#seeddown a'), + bonus: doc.queryText('#seedbonus') + }; +} + +// ================= 能力: signIn（签到）================= +// 签到（signInPath 默认 /attendance.php，可在站点 definition 中覆盖，如 BTSCHOOL: /index.php?action=addbonus） +// 成功时若响应页含 #info_block (含魔力值) 则一并返回 bonus 供服务端更新 Site.Statistics.Bonus; +// 站点页面不含 / 解析不到时缺省不返回该字段, 服务端不处理 (report §四 签到奖励自动更新). +function signIn(input) { + var ctx = __asCtx(input); + var signPath = ctx.signInPath || '/attendance.php'; + var res = http.post(signPath); + if (res && res.indexOf('成功') >= 0) { + var out = { signed: true, message: '签到成功' }; + try { + var stats = parseIndexStats(res); + if (stats && stats.bonus !== null && stats.bonus !== undefined && !isNaN(stats.bonus)) { + out.bonus = stats.bonus; + } + } catch (e) { + // bonus 解析失败不影响签到成功结果 + } + return out; + } + if (res && (res.indexOf('已签到') >= 0 || res.indexOf('已经签到') >= 0 || res.indexOf('已經簽到') >= 0 || res.indexOf('重复签到') >= 0 || res.indexOf('重複簽到') >= 0)) { + return { signed: true, message: '今日已签到' }; + } + return { signed: false, message: (res && res.length > 0) ? '未识别签到结果' : '签到请求失败' }; +} + +// 解析裸大小文本 "1.23 GB" / "986.5 MB" / "1.2 TB" → 字节数 +function parseSizeText(text) { + if (!text) return 0; + var m = String(text).match(/([\d.,]+)\s*(TB|GB|MB|KB|PB|B)\b/i); + if (!m) return 0; + var num = parseFloat(m[1].replace(/,/g, '')); + if (isNaN(num)) return 0; + return Math.round(num * unitToBytes(m[2])); +} + +// 提取非负整数（忽略逗号与装饰性字符） +function toInt(text) { + if (text === null || text === undefined) return 0; + var m = String(text).match(/[\d,]+/); + if (!m) return 0; + var v = parseInt(m[0].replace(/,/g, ''), 10); + return isNaN(v) ? 0 : v; +} + +// 从标题里按正则提取首个媒体标签 (分辨率/来源/编码)，供订阅偏好过滤与质量评分 +function parseMediaTag(title, re) { + if (!title) return null; + var m = String(title).match(re); + if (!m) return null; + var v = m[1] || m[0]; + return v ? v.toUpperCase() : null; +} + +// ================= 能力: search（搜索种子）================= +// ctx: { siteCode, baseUrl, keyword, page(=1), searchPath(可选, 默认 /torrents.php) } +// 走 http（已注入 Cookie 的 HttpClient），解析 table.torrents 种子行。 function search(input) { var ctx = __asCtx(input); var keyword = ctx && ctx.keyword ? String(ctx.keyword) : ''; if (!keyword) return []; var base = __resolveBase(ctx); - if (!base || base === 'http://mock.local') return []; - var page = ctx.page ? __toInt(ctx.page) : 1; - if (page < 1) page = 1; - var pageSize = ctx.pageSize ? __toInt(ctx.pageSize) : 100; - var body = { keyword: keyword, pageNumber: page, pageSize: pageSize }; - var root = __apiPost(base, ctx.searchPath || '/api/torrent/search', body, ctx.apiKey || ctx.xApiKey); - if (root === null) return []; - var data = root.data !== undefined ? root.data : root; - var list = (data && data.data !== undefined) ? data.data : []; - var res = parseSearch(list); - return res.items || []; + if (!base) return []; + var page = ctx.page ? parseInt(ctx.page, 10) : 1; + if (isNaN(page) || page < 1) page = 1; + var searchPath = ctx.searchPath || '/torrents.php'; + + // 首页不拼 &page=N：NexusPHP 分页分 0 基/1 基两种，部分站点(如 carpt)在 + // ?search=X&page=1 时实际请求的是"第 2 页"，而结果往往只有一页 → 返回空表(仅搜索框)。 + // 统一用裸 ?search=X 取首页，对两种索引方案都正确返回第 1 页。 + var query = '?search=' + encodeURIComponent(keyword); + var url = (page > 1) + ? (base + searchPath + query + '&page=' + page) + : (base + searchPath + query); + var htmlText = http.get(url); + if (!htmlText) return []; + var doc = html.parse(htmlText); + if (!doc) return []; + + // ---- 诊断: 校验返回结构, 便于排查搜索空结果 (源码原始 html 特征) ---- + // 注意: 不能用 "Powered by NexusPHP" 或站名判断登录墙 —— 这些字串每个 NexusPHP 站页面都有. + // 登录墙的可靠特征是: 存在登录表单 (带 password input / action 指向 login 页). + var htmlTag = null; + var titleTag = (htmlText.match(/([^<]*)<\/title>/i) || [])[1] || ''; + var tableCount = (htmlText.match(/<table[^>]*class="torrents"[^>]*>/i) || []).length; + var hasLoginForm = /<input[^>]*type="Password"[^>]*>/i.test(htmlText) + || /<form[^>]*action="[^"]*login[^"]*"[^>]*>/i.test(htmlText) + || /name="(?:username|loginusername|userpasswd)"[^>]*>/i.test(htmlText) + || /登录到|login in|请登陆|请登录/i.test(titleTag); + // 采集页面所有的 table class + 种子详情链接数, 用于判断选择器是否匹配. + var tableClasses = []; + var tcm = htmlText.match(/<table[^>]*class="([^"]*)"[^>]*>/gi); + if (tcm) for (var tc = 0; tc < tcm.length; tc++) { + var cls = (tcm[tc].match(/class="([^"]*)"/i) || [])[1] || ''; + if (cls && tableClasses.indexOf(cls) < 0) tableClasses.push(cls); + } + var detailLinkCount = (htmlText.match(/href="[^"]*details\.php[^"]*"/gi) || []).length; + if (hasLoginForm) { + htmlTag = 'loginwall'; + } else if (detailLinkCount > 0) { + htmlTag = 'has_details_' + detailLinkCount; + } else if (titleTag && /无.*种子|没有|未找到|No|结果/i.test(titleTag)) { + htmlTag = 'noresult:' + titleTag; + } else if (tableCount === 0) { + htmlTag = 'no_torrents_table'; + } else { + htmlTag = 'ok'; + } + // 候选选择器命中数: 定位 carpt 种子列表的真实容器 (标准 nexusphp 是 table.torrents, 自定义皮站常不同) + var selCands = ['table.torrents tr', 'table[class*="torrent"] tr', '#torrents tr', 'tr.rowfollow', '.torrent_name', '.torrenttitle', 'td.rowfollow', 'table tr']; + var selHits = []; + for (var si = 0; si < selCands.length; si++) { + try { selHits.push(selCands[si] + '=' + doc.queryList(selCands[si]).length); } catch (e) { selHits.push(selCands[si] + '=ERR'); } + } + // 原始响应 HTML 关键片段: 后端会将其落盘为快照文件 (search-snapshots/) 便于调试, 此处保留完整内容. + // ---- 诊断结束 ---- + + // 取所有表格行, 再由 td.rowfollow + details 链接 过滤出真实种子行. + // 注意: 不能用 table.torrents —— 不少自定义皮站 (如 carpt) 种子列表父表 class 不是 torrents. + // 侧边搜索/筛选区同样含 td.rowfollow, 故必须额外要求含 details* 链接才算种子行. + var rows = doc.queryList('table tr'); + var results = []; + for (var i = 0; i < rows.length; i++) { + var row = rows[i]; + // 仅取直接子 td：carpt 等站点在标题单元格内嵌套了 torrentname 子表， + // 用 'td' 会把后代 td(embedded) 一并计入，导致列索引错位、体积/做种数全变 0. + var tds = row.queryList(':scope > td'); + // 种子行判定：含 td.rowfollow(排除搜索/筛选/表头) 且拥有多个直接子 td(标准约 9 列)。 + // 仅 1 个直接子 td 的 tr 多为置顶/推荐/嵌套区块的重复条目(数字无法解析)，直接跳过. + if (tds.length < 6) continue; + if (row.queryList('td.rowfollow').length === 0) continue; + var titleEl = row.querySelector('a[href*="details"]'); + if (!titleEl) continue; + var title = titleEl.text(); + if (!title) continue; + + var href = titleEl.attr('href'); + var detailUrl = null; + if (href) { + detailUrl = (href.indexOf('http') === 0) ? href : (base + (href[0] === '/' ? href : '/' + href)); + } + + // 行内下载链接: 下载图标指向 download.php?… (passkey 站点已带 passkey/uid 等完整参数, 如 pttime; + // 仅需 Cookie 的站点如 carpt 则不带额外参数). 下载时直接复用该链接, 无需再拼 passkey. + var downloadUrl = null; + var dlLink = row.querySelector('a[href*="download.php"]'); + if (dlLink) { + var dhref = dlLink.attr('href') || ''; + if (dhref) { + downloadUrl = (dhref.indexOf('http') === 0) ? dhref : (base + (dhref[0] === '/' ? dhref : '/' + dhref)); + } + } + + var size = 0, seeders = 0, leechers = 0, completed = 0; + if (tds.length > 7) { + size = parseSizeText(tds[4] ? tds[4].text() : ''); + seeders = toInt(tds[5] ? tds[5].text() : ''); + leechers = toInt(tds[6] ? tds[6].text() : ''); + completed = toInt(tds[7] ? tds[7].text() : ''); + } + + var yearM = title.match(/\b(19|20)\d{2}\b/); + var year = yearM ? parseInt(yearM[0], 10) : null; + + // 促销/免费/H&R 标记：图标位于标题单元格内 (img.pro_free / img.pro_50pctdown / img.hitandrun / alt) + var isFree = false, isHr = false, freeDeadline = null, promo = null; + var imgs = row.queryList('img'); + for (var pi = 0; pi < imgs.length; pi++) { + var pcls = imgs[pi].attr('class') || ''; + var palt = imgs[pi].attr('alt') || ''; + if (/pro_free|pro_100pctdown/i.test(pcls) || /\bfree\b|100%/i.test(palt)) { isFree = true; promo = 'free'; } + else if (/pro_50pctdown|pro_free2up/i.test(pcls) || /50%|2x/i.test(palt)) { promo = 'half'; } + if (/hitandrun/i.test(pcls) || /\bH&?R\b/i.test(palt)) isHr = true; + } + // 免费/促销截止时间 + 发布时间：行内真实存在的 <span title="2027-03-02 10:33:29">（"剩余时间："后）， + // 取最大者(未来截止>过去添加时间)为免费截止，取最小者(最早)为种子发布时间. + var spans = row.queryList('span[title]'); + var maxDt = null, minDt = null; + for (var si = 0; si < spans.length; si++) { + var sttl = spans[si].attr('title') || ''; + var sdm = sttl.match(/^(\d{4}-\d{2}-\d{2}[ T]\d{2}:\d{2}:\d{2})/); + if (!sdm) continue; + if (maxDt === null || sdm[1] > maxDt) maxDt = sdm[1]; + if (minDt === null || sdm[1] < minDt) minDt = sdm[1]; + } + if (maxDt) freeDeadline = maxDt.replace(' ', 'T'); + var uploadAt = minDt ? minDt.replace(' ', 'T') : null; + + // 分类：行首分类图标 (class 以 c_ 开头, alt/title=音乐/Music 等)，取首个匹配 + var category = null; + var cimgs = row.queryList('td.rowfollow img'); + for (var ci = 0; ci < cimgs.length; ci++) { + var ccls = cimgs[ci].attr('class') || ''; + if (/^c_/i.test(ccls)) { + category = cimgs[ci].attr('title') || cimgs[ci].attr('alt') || null; + break; + } + } + + // 分辨率/来源/编码：从标题文本解析，供订阅偏好过滤 (PreferredResolution/Source/Encoding) 与质量评分 + var resolution = parseMediaTag(title, /\b(\d{3,4}[pi])\b/i); + var source = parseMediaTag(title, /\b(WEB-DL|WEBRip|WEB|HDTV|Blu-?Ray|DVD|Remux|BDrip|BDRip|HDrip|DVDRip)\b/i); + var encoding = parseMediaTag(title, /\b(x264|x265|H\.?265|H\.?264|AVC|HEVC|VC-?1|XviD|AV1)\b/i); + + results.push({ + title: title, + detailUrl: detailUrl, + downloadUrl: downloadUrl, + size: size, + seeders: seeders, + leechers: leechers, + completed: completed, + year: year, + resolution: resolution, + source: source, + encoding: encoding, + category: category, + isFree: isFree, + isHr: isHr, + uploadAt: uploadAt, + freeDeadline: freeDeadline, + promo: promo + }); + } + if (results.length === 0) { + // 无结果时附加诊断信息: 供后端日志区分登录墙/无结果页/选择器不匹配, 前端会按空 title 过滤 + results.push({ + title: '', + __diag: htmlTag || 'unknown', + __url: url, + __len: htmlText ? htmlText.length : 0, + __tables: tableClasses.join(','), + __details: detailLinkCount, + __sel: selHits.join(' | '), + __html: htmlText || '' + }); + } + return results; } -// ===================== 站点信息同步（mediabot2 Host 调用） ===================== -// ctx: { siteCode, siteId, baseUrl, apiKey, utcNow, frameworkVersion } -// Success: 合并 profile + peerStats 的统计对象；Failure: { error, ... } 便于 Host 上报。 -// 绝不返回 null，始终带 error 字段。 -function sync(input) { +// 从详情页 DOM 中提取外部 ID (doubanId / imdbId / tmdbId / tvdbId). +// NexusPHP 详情页的外部链接通常放在 #kdescr 描述块、#info_block 标签区或页面底部, +// 通过遍历所有 <a> 的 href 正则命中即可覆盖多数站点布局。 +function extractExternalIds(doc) { + var ids = {}; + try { + var links = doc.queryList('a'); + for (var i = 0; i < links.length; i++) { + var href = links[i].attr('href') || ''; + if (!ids.doubanId) { + var dbm = href.match(/douban\.com\/subject\/(\d+)/i); + if (dbm) ids.doubanId = dbm[1]; + } + if (!ids.imdbId) { + var imm = href.match(/imdb\.com\/title\/(tt\d+)/i); + if (imm) ids.imdbId = imm[1]; + } + if (!ids.tmdbId) { + var tmm = href.match(/themoviedb\.org\/(?:movie|tv)\/(\d+)/i); + if (tmm) ids.tmdbId = parseInt(tmm[1], 10); + } + if (!ids.tvdbId) { + var tvm = href.match(/thetvdb\.com\/series\/(\d+)/i) || href.match(/tvdbid=(\d+)/i); + if (tvm) ids.tvdbId = parseInt(tvm[1], 10); + } + // 四个全齐就提前退出 + if (ids.doubanId && ids.imdbId && ids.tmdbId && ids.tvdbId) break; + } + } catch (e) { /* 任何异常都静默降级, 返回部分结果 */ } + return ids; +} + +// ================= 能力: detail（种子详情）================= +// ctx: { baseUrl, id (或 detailId), detailUrl?(可选, 直接指定详情页地址) } +// 输出字段与能力模板 detail 一致（size/seeders 等保留页面原始文本）。 +function detail(input) { var ctx = __asCtx(input); var base = __resolveBase(ctx); - if (!base || base === 'http://mock.local') return { error: 'no_base_url' }; - var apiKey = ctx.apiKey || ctx.xApiKey; + if (!base) return { error: 'no_base_url' }; + var url = ctx && ctx.detailUrl ? String(ctx.detailUrl) : ''; + if (!url) { + var id = (ctx && (ctx.id || ctx.detailId)) || ''; + if (!id) return { error: 'no_detail_id' }; + url = base + '/details.php?id=' + encodeURIComponent(id); + } + if (url.indexOf('http') !== 0) url = base + (url[0] === '/' ? url : '/' + url); - // 1. profile - var profileRoot = __apiPost(base, ctx.profilePath || '/api/user/profile', {}, apiKey); - if (profileRoot === null) return { error: 'profile_fetch_failed' }; - var profileData = profileRoot.data !== undefined ? profileRoot.data : profileRoot; - var p = parseProfile(profileData); - if (!p.matched) return { error: 'profile_no_match' }; + var htmlText; + try { + htmlText = http.get(url); + } catch (e) { + return { error: String((e && e.message) || e), url: url }; + } + if (!htmlText) return { error: 'empty_response', url: url }; + var doc = html.parse(htmlText); + if (!doc) return { error: 'parse_failed', url: url, html: htmlText }; - // 2. peerStats - var seeding = null; - var statsRoot = __apiPost(base, ctx.peerStatsPath || '/api/torrent/seeding', {}, apiKey); - if (statsRoot !== null) { - var statsData = statsRoot.data !== undefined ? statsRoot.data : statsRoot; - var ps = parsePeerStats(statsData); - if (ps.matched) seeding = ps.seeding; + var out = { url: url }; + + var titleEl = doc.querySelector('#top h1') || doc.querySelector('h1'); + if (titleEl) out.title = titleEl.text(); + var subEl = doc.querySelector('td.embedded'); + if (subEl) out.subtitle = subEl.text(); + var descEl = doc.querySelector('#kdescr'); + if (descEl) out.description = descEl.text(); + + // 行式字段：遍历 td.rowhead，取 label → 下一格文本（兼容表格布局） + var heads = doc.queryList('td.rowhead'); + for (var i = 0; i < heads.length; i++) { + var label = (heads[i].text() || '').trim(); + var next = heads[i].nextElementSibling; + var val = next ? (next.text() || '').trim() : ''; + if (!val) continue; + if (out.size === undefined && /^(大小|尺寸|體積|Size)$/i.test(label)) out.size = val; + else if (out.seeders === undefined && /(做种者|做種者|当前做种|當前做種|Seeders?)/i.test(label)) out.seeders = val; + else if (out.leechers === undefined && /(下载者|下載者|当前下载|當前下載|Leechers?)/i.test(label)) out.leechers = val; + else if (out.completed === undefined && /(完成|Completed?)/i.test(label)) out.completed = val; } - return { - uploaded: p.upload, - downloaded: p.download, - bonus: p.bonus, - shareRate: p.shareRate, - invites: p.invites, - userName: p.username, - seeding: seeding - }; + // 促销/免费标记（img.pro_free 等，同 search 判定） + var imgs = doc.queryList('img'); + for (var p = 0; p < imgs.length; p++) { + var pcls = imgs[p].attr('class') || ''; + var palt = imgs[p].attr('alt') || ''; + if (/pro_free|pro_100pctdown/i.test(pcls) || /^free$|100%/i.test(palt)) { out.free = 'free'; break; } + if (/pro_50pctdown|pro_free2up/i.test(pcls) || /50%|2x/i.test(palt)) { out.free = '50%'; break; } + } + + // 磁力链（部分站点详情页直接提供） + var links = doc.queryList('a'); + for (var m = 0; m < links.length; m++) { + var mhref = links[m].attr('href') || ''; + if (mhref.indexOf('magnet:') === 0) { out.magnet = mhref; break; } + } + + // 提取外部 ID (doubanId / imdbId / tmdbId / tvdbId) + var extIds = extractExternalIds(doc); + for (var k in extIds) if (extIds[k] !== undefined) out[k] = extIds[k]; + + return out; } -// ===================== 能力: download（下载种子） ===================== -// ctx: { baseUrl, apiKey, downloadUrl?(可选) | id/detailId } -// M-Team API 不暴露直接下载接口（swagger 里没有 /torrent/download）, 必须两步: -// 1) POST /api/torrent/genDlToken?id={detailId} → 拿到 Result.data (下载 URL 或 token) -// 2) GET 下载 URL (通常是 CDN) -// 返回 { downloadUrl, url, bytes, size } 或 { error, url? }。 +// fetchDetail: C# DetailVerifyJob 调用入口, 别名到 detail 函数. +// C# 端 Invoke("fetchDetail") 是外部约定, 这里保持兼容. +function fetchDetail(input) { return detail(input); } + +// ================= 能力: download（下载种子）================= +// 优先直接使用 ctx.downloadUrl / ctx.detailUrl (搜索解析时抓取的行内下载链接, 已含 passkey/uid 等完整参数, 如 pttime); +// 无行内链接时由 ctx.id (或 detailId) 构造, 可带 ctx.passkey (仅需 Cookie 的站点如 carpt 不传即可)。 +// 站点会话 (Cookie) 已在 http 客户端注入, Referer 由 Host 设置。 +// 必须走脚本内 http, 不能由外部用裸链接直接 GET。 +// 返回 { downloadUrl, url, bytes, size } 或 { error, url? }. function download(input) { var ctx = __asCtx(input); var base = __resolveBase(ctx); - var apiKey = ctx && (ctx.apiKey || ctx.xApiKey); - var detailId = ctx && (ctx.id || ctx.detailId) ? String(ctx.id || ctx.detailId) : ''; var url = null; - if (ctx && ctx.downloadUrl) { - url = String(ctx.downloadUrl); - if (url.indexOf('http') !== 0) url = base + (url.charAt(0) === '/' ? url : '/' + url); - } else if (detailId) { - // 先 genDlToken 拿下载 URL / token - var tokenPath = '/api/torrent/genDlToken?id=' + encodeURIComponent(detailId); - var tokenRoot = __apiPost(base, tokenPath, {}, apiKey); - if (tokenRoot === null) return { error: 'gen_dl_token_failed_no_response', url: base + tokenPath }; - - // genDlToken 返回 Result<T>, T 可能是 string (完整下载 URL) 或对象 - var tokenData = (tokenRoot.data !== undefined ? tokenRoot.data : tokenRoot); - var dlUrl = null; - if (typeof tokenData === 'string' && tokenData.length > 0) { - dlUrl = tokenData; - } else if (tokenData && typeof tokenData === 'object') { - dlUrl = tokenData.url || tokenData.downloadUrl || tokenData.link || tokenData.token; - } - if (!dlUrl) { - // 把原始响应带回来供 C# 端日志诊断真实格式 - var raw = ''; - try { raw = typeof JSON !== 'undefined' ? JSON.stringify(tokenRoot) : String(tokenRoot); } catch(e) { raw = String(tokenRoot); } - if (raw.length > 500) raw = raw.substring(0, 500) + '...'; - return { error: 'gen_dl_token_failed_no_download_url', url: base + tokenPath, rawResponse: raw }; - } - url = String(dlUrl); + if (ctx.downloadUrl || ctx.detailUrl) { + url = String(ctx.downloadUrl || ctx.detailUrl); + if (url.indexOf('http') !== 0) url = base + (url[0] === '/' ? url : '/' + url); } else { - return { error: 'no_detail_id' }; + var detailId = ctx && (ctx.id || ctx.detailId) ? String(ctx.id || ctx.detailId) : ''; + if (!detailId) return { error: 'no_detail_id' }; + if (!base) return { error: 'no_base_url' }; + var path = ctx.downloadPath || '/download.php'; + url = base + path + '?id=' + encodeURIComponent(detailId); + var passkey = ctx.passkey ? String(ctx.passkey) : ''; + if (passkey) url += '&passkey=' + encodeURIComponent(passkey); } try { var bytes = http.getBytes(url); @@ -355,4 +794,96 @@ function download(input) { } catch (e) { return { error: String((e && e.message) || e), url: url }; } -} \ No newline at end of file +} + +// 刷流入口：拉取站点 RSS/Atom feed 并解析为标准条目列表，供 RssDiscoveryJob 刷流。 +// 必须走脚本内 http（带站点 Cookie），与 search/download 一致的会话上下文。 +// ctx: { siteCode, baseUrl, feedUrl, rssPath?(可选, 默认 /torrentrss.php) } +// 优先使用 ctx.feedUrl（RssSubscription 配置的完整 RSS 链接，已含 passkey 等参数）； +// 缺省时回退到 baseUrl + rssPath 拼装。 +// 返回: [{ title, detailUrl, downloadUrl, description, pubDate, guid }] 或 { error } +function rss(ctx) { + var base = String(ctx.baseUrl || '').replace(/\/+$/, ''); + var url = ctx.feedUrl ? String(ctx.feedUrl) : ''; + if (!url) { + var rssPath = ctx.rssPath || '/torrentrss.php'; + if (!base) return { error: 'no_feed_url' }; + url = base + rssPath; + } + var xml; + try { + xml = http.get(url); + } catch (e) { + return { error: String((e && e.message) || e), url: url }; + } + if (!xml) return { error: 'empty_feed', url: url }; + + // Atom (<entry>) 与 RSS (<item>) 都支持：分别抽取后合并。 + var items = []; + + function tag(block, name) { + var m = block.match(new RegExp('<' + name + '[^>]*>([\\s\\S]*?)<\\/' + name + '>', 'i')); + return m ? m[1].replace(/<!\[CDATA\[([\s\S]*?)\]\]>/g, '$1').trim() : ''; + } + function attr(block, name, an) { + var m = block.match(new RegExp(name + '\\s+' + an + '\\s*=\\s*["\']([^"\']*)["\']', 'i')); + return m ? m[1] : ''; + } + + // RSS 2.0: <item>…</item> + var blocks = xml.match(/<item[\s\S]*?<\/item>/gi); + if (blocks) { + for (var i = 0; i < blocks.length; i++) { + var b = blocks[i]; + var title = tag(b, 'title'); + var link = tag(b, 'link'); + var desc = tag(b, 'description'); + var guid = tag(b, 'guid') || link; + var pub = tag(b, 'pubDate'); + var enc = (b.match(/<enclosure[^>]*>/i) || [])[0] || ''; + var enclosureUrl = attr(enc, 'enclosure', 'url'); + items.push({ + title: title, + detailUrl: link, + downloadUrl: enclosureUrl || link, + description: desc, + pubDate: pub, + guid: guid + }); + } + } + + // Atom: <entry>…</entry> + var atomBlocks = xml.match(/<entry[\s\S]*?<\/entry>/gi); + if (atomBlocks) { + for (var j = 0; j < atomBlocks.length; j++) { + var a = atomBlocks[j]; + var at = tag(a, 'title'); + var aid = tag(a, 'id'); + var updated = tag(a, 'updated') || tag(a, 'published'); + var summary = tag(a, 'summary') || tag(a, 'content'); + // Atom link：优先 rel="alternate" 的 href；无则取首个 href + var links = a.match(/<link[^>]*>/gi) || []; + var altHref = '', firstHref = ''; + for (var k = 0; k < links.length; k++) { + var lh = attr(links[k], 'link', 'href'); + if (!firstHref) firstHref = lh; + if (/rel=["']alternate["']/i.test(links[k])) altHref = lh; + } + var href = altHref || firstHref; + items.push({ + title: at, + detailUrl: href, + downloadUrl: href, + description: summary, + pubDate: updated, + guid: aid + }); + } + } + + if (items.length === 0) { + return { error: 'no_items', url: url, __len: xml.length, __html: xml }; + } + return items; +}