[\s\S]*?<\/div>\s*<\/div>\s*<\/div>/.exec(htmlContent);
+
+ if (sjxjContainerMatch) {
+ log("debug", `找到数字选集容器`);
+ return this.parseEpisodesFromHtml(sjxjContainerMatch[0], id);
+ }
+
+ // 如果以上都没找到，尝试查找整个剧集区域
+ log("debug", `未找到特定选集容器，尝试查找第一集视频列表...`);
+
+ const firstVideoListMatch = /
0) {
+ log("info", `[Leshi] 从HTML内容中匹配到 ${episodes.length} 个剧集链接`);
+ return episodes;
+ }
+
+ return [];
+
+ } catch (error) {
+ log("error", "[Leshi] 获取分集出错:", error.message);
+ return [];
+ }
+ }
+
+ parseEpisodesFromHtml(htmlContent, mediaId) {
+ try {
+ // 根据提供的HTML结构，首先查找所有包含剧集的div.col_4元素
+ // 每个div.col_4包含一个dl.dl_temp剧集元素
+ const episodeContainerRegex = /
]*>[\s\S]*?<\/div>/g;
+ const containerMatches = htmlContent.match(episodeContainerRegex);
+
+ if (!containerMatches || containerMatches.length === 0) {
+ log("debug", `在HTML中未找到剧集容器div.col_4，尝试查找dl.dl_temp元素`);
+ // 如果没找到div.col_4，直接查找dl.dl_temp
+ const episodeRegex = /
[\s\S]*?<\/dl>/g;
+ const matches = htmlContent.match(episodeRegex);
+
+ if (!matches || matches.length === 0) {
+ log("debug", `在HTML中未找到剧集元素，尝试更广泛的选择器`);
+ // 尝试更广泛的匹配
+ const broaderRegex = /]*class="[^"]*dl_temp[^"]*"[^>]*>[\s\S]*?<\/dl>/g;
+ const broaderMatches = htmlContent.match(broaderRegex);
+
+ if (!broaderMatches || broaderMatches.length === 0) {
+ log("error", `无法从HTML中解析到任何剧集: media_id=${mediaId}`);
+ return [];
+ }
+
+ return this.extractEpisodes(broaderMatches, mediaId);
+ }
+
+ return this.extractEpisodes(matches, mediaId);
+ }
+
+ // 从每个div.col_4中提取内部的dl.dl_temp元素
+ const dlElements = [];
+ for (const container of containerMatches) {
+ const dlMatch = /[\s\S]*?<\/dl>/.exec(container);
+ if (dlMatch) {
+ dlElements.push(dlMatch[0]);
+ }
+ }
+
+ if (dlElements.length === 0) {
+ log("error", `从容器中未能提取到任何dl.dl_temp元素: media_id=${mediaId}`);
+ return [];
+ }
+
+ return this.extractEpisodes(dlElements, mediaId);
+ } catch (error) {
+ log("error", `[Leshi] 解析剧集HTML失败: ${error.message}`);
+ return [];
+ }
+ }
+
+ extractEpisodes(episodeElements, mediaId) {
+ const episodes = [];
+
+ for (const element of episodeElements) {
+ try {
+ // 提取链接 - 优先匹配 vplay 链接
+ const linkMatch = /]+href="(\/\/www\.le\.com\/ptv\/vplay\/(\d+)\.html)"[^>]*>/.exec(element);
+ if (!linkMatch) {
+ log("debug", `跳过无法解析链接的剧集元素`);
+ continue;
+ }
+
+ const fullUrl = linkMatch[1];
+ const videoId = linkMatch[2];
+ const absoluteUrl = `https:${fullUrl}`;
+
+ // 提取标题 - 更精确的匹配
+ let title = '';
+
+ // 优先从 dt.d_tit 中获取标题
+ const titleMatch = /- [\s\n\r]*]*title="([^"]*)"[^>]*>([^<]*)<\/a>/.exec(element);
+ if (titleMatch && titleMatch[1]) {
+ title = titleMatch[1].trim(); // 使用title属性
+ } else if (titleMatch && titleMatch[2]) {
+ title = titleMatch[2].trim(); // 使用链接文本
+ } else {
+ // 如果dt.d_tit中没有找到，尝试其他方式
+ const altTitleMatch = /]*title="([^"]*)"[^>]*>[\s\S]*?
- /.exec(element) ||
+ /
- [\s\S]*?]*title="([^"]*)"/.exec(element);
+ if (altTitleMatch && altTitleMatch[1]) {
+ title = altTitleMatch[1].trim();
+ } else {
+ // 再尝试从dd.d_cnt中获取
+ const ddMatch = /
- ]*>([^<]*)/.exec(element);
+ if (ddMatch && ddMatch[1]) {
+ title = ddMatch[1].trim();
+ } else {
+ // 最后尝试从链接本身获取文本
+ const linkTextMatch = /]*title="[^"]*"[^>]*>([^<]*)/.exec(element);
+ if (linkTextMatch && linkTextMatch[1]) {
+ title = linkTextMatch[1].trim();
+ }
+ }
+ }
+ }
+
+ // 如果仍然没有标题，尝试从剧集编号获取
+ if (!title) {
+ const episodeNumMatch = /第(\d+)集|(\d+)(?:\s*预告)?/.exec(element);
+ if (episodeNumMatch) {
+ const num = episodeNumMatch[1] || episodeNumMatch[2];
+ title = `第${num}集`;
+ } else {
+ title = `第${episodes.length + 1}集`;
+ }
+ }
+
+ // 过滤掉预告片或其他非正常剧集（可选）
+ const isPreview = /预告|Preview|preview/.test(title);
+ if (isPreview) {
+ log("debug", `跳过预告片: ${title}`);
+ continue;
+ }
+
+ const episode = {
+ vid: videoId,
+ title: title,
+ url: absoluteUrl,
+ episodeId: `${videoId}:${mediaId}` // vid:aid
+ };
+
+ episodes.push(episode);
+
+ } catch (e) {
+ log("warning", `[Leshi] 解析单个剧集失败: ${e.message}`);
+ continue;
+ }
+ }
+
+ log("info", `[Leshi] 成功解析剧集列表: media_id=${mediaId}, 共 ${episodes.length} 集`);
+ return episodes;
+ }
+
+ async handleAnimes(sourceAnimes, queryTitle, curAnimes) {
+ const tmpAnimes = [];
+
+ // 添加错误处理，确保sourceAnimes是数组
+ if (!sourceAnimes || !Array.isArray(sourceAnimes)) {
+ log("error", "[Leshi] sourceAnimes is not a valid array");
+ return [];
+ }
+
+ // 使用 map 和 async 时需要返回 Promise 数组，并等待所有 Promise 完成
+ const processLeshiAnimes = await Promise.all(sourceAnimes
+ .filter(s => titleMatches(s.title, queryTitle))
+ .map(async (anime) => {
+ try {
+ const eps = await this.getEpisodes(anime.mediaId);
+ let links = [];
+
+ for (let i = 0; i < eps.length; i++) {
+ const ep = eps[i];
+ const epTitle = ep.title || `第${i + 1}集`;
+ links.push({
+ "name": (i + 1).toString(),
+ "url": `${ep.url}`,
+ "title": `【leshi】 ${epTitle}`
+ });
+ }
+
+ if (links.length > 0) {
+ // 将字符串mediaId转换为数字ID (使用哈希函数)
+ const numericAnimeId = convertToAsciiSum(anime.mediaId);
+ let transformedAnime = {
+ animeId: numericAnimeId,
+ bangumiId: anime.mediaId,
+ animeTitle: `${anime.title}(${anime.year || new Date().getFullYear()})【${anime.type}】from leshi`,
+ type: anime.type,
+ typeDescription: anime.type,
+ imageUrl: anime.imageUrl,
+ startDate: generateValidStartDate(anime.year || new Date().getFullYear()),
+ episodeCount: links.length,
+ rating: 0,
+ isFavorited: true,
+ source: "leshi",
+ };
+
+ tmpAnimes.push(transformedAnime);
+
+ addAnime({...transformedAnime, links: links});
+
+ if (globals.animes.length > globals.MAX_ANIMES) removeEarliestAnime();
+ }
+ } catch (error) {
+ log("error", `[Leshi] Error processing anime: ${error.message}`);
+ }
+ })
+ );
+
+ this.sortAndPushAnimesByYear(tmpAnimes, curAnimes);
+
+ return processLeshiAnimes;
+ }
+
+ async getEpisodeDanmu(id) {
+ log("info", "开始从本地请求乐视网弹幕...", id);
+
+ // 获取弹幕分段数据
+ const segmentResult = await this.getEpisodeDanmuSegments(id);
+ if (!segmentResult || !segmentResult.segmentList || segmentResult.segmentList.length === 0) {
+ return [];
+ }
+
+ const segmentList = segmentResult.segmentList;
+ log("info", `弹幕分段数量: ${segmentList.length}`);
+
+ // 并发请求所有弹幕段，限制并发数量为5
+ const MAX_CONCURRENT = 10;
+ const allComments = [];
+
+ // 将segmentList分批处理，每批最多MAX_CONCURRENT个请求
+ for (let i = 0; i < segmentList.length; i += MAX_CONCURRENT) {
+ const batch = segmentList.slice(i, i + MAX_CONCURRENT);
+
+ // 并发处理当前批次的请求
+ const batchPromises = batch.map(segment => this.getDanmuSegment(segment));
+ const batchResults = await Promise.allSettled(batchPromises);
+
+ // 处理结果
+ for (let j = 0; j < batchResults.length; j++) {
+ const result = batchResults[j];
+ const segment = batch[j];
+ const start = segment.segment_start;
+ const end = segment.segment_end;
+
+ if (result.status === 'fulfilled') {
+ const comments = result.value;
+
+ if (comments && comments.length > 0) {
+ allComments.push(...comments);
+ } else if (start > 600) { // 10分钟后无数据可能到末尾
+ // 如果某个分段超过10分钟且没有数据，可以提前结束
+ // 但需要确保当前批次的所有请求都完成
+ break;
+ }
+ } else {
+ log("error", `获取弹幕段失败 (${start}-${end}s):`, result.reason.message);
+ }
+ }
+
+ // 批次之间稍作延迟，避免过于频繁的请求
+ if (i + MAX_CONCURRENT < segmentList.length) {
+ await new Promise(resolve => setTimeout(resolve, 200));
+ }
+ }
+
+ if (allComments.length === 0) {
+ log("info", `乐视网: 该视频暂无弹幕数据 (vid=${id})`);
+ return [];
+ }
+
+ printFirst200Chars(allComments);
+
+ return allComments;
+ }
+
+ async getDanmuSegment(segment) {
+ try {
+ const response = await httpGet(segment.url, {
+ headers: {
+ "Content-Type": "application/json",
+ "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36",
+ },
+ retries: 1,
+ });
+
+ // 处理响应数据并返回 contents 格式的弹幕
+ let contents = [];
+ if (response && response.data) {
+ const data = typeof response.data === "string" ? response.data : JSON.stringify(response.data);
+
+ // 解析JSONP响应
+ const jsonMatch = /vjs_\d+\((.*)\)/.exec(data);
+ if (jsonMatch) {
+ const jsonData = JSON.parse(jsonMatch[1]);
+ if (jsonData.code === 200 && jsonData.data) {
+ contents.push(...(jsonData.data.list || []));
+ }
+ }
+ }
+
+ return contents;
+ } catch (error) {
+ log("error", "请求分片弹幕失败:", error);
+ return [];
+ }
+ }
+
+ async getEpisodeDanmuSegments(id) {
+ log("info", "获取乐视网弹幕分段列表...", id);
+
+ // 从ID中提取video_id
+ let videoId = id;
+ const match = id.match(/\/vplay\/(\d+)\.html/);
+ if (match) {
+ videoId = match[1];
+ }
+
+ // 获取视频时长
+ const duration = await this.getVideoDuration(videoId);
+
+ // 计算需要请求的时间段（每段5分钟）
+ const segments = [];
+ for (let i = 0; i < Math.ceil(duration / 300); i++) {
+ const startTime = i * 300;
+ const endTime = Math.min((i + 1) * 300, duration);
+ segments.push({
+ "type": "leshi",
+ "segment_start": startTime,
+ "segment_end": endTime,
+ "url": `https://hd-my.le.com/danmu/list?vid=${videoId}&start=${startTime}&end=${endTime}&callback=vjs_${Date.now()}`
+ });
+ }
+
+ log("info", `乐视网: 视频时长 ${duration}秒，分为 ${segments.length} 个时间段`);
+
+ return new SegmentListResponse({
+ "type": "leshi",
+ "segmentList": segments
+ });
+ }
+
+ async getEpisodeSegmentDanmu(segment) {
+ return this.getDanmuSegment(segment);
+ }
+
+ async getVideoDuration(videoId) {
+ try {
+ const response = await httpGet(`https://www.le.com/ptv/vplay/${videoId}.html`, { timeout: 10000 });
+
+ if (!response || !response.data) {
+ log("warning", `乐视网: 获取视频时长失败，使用默认值2400秒`);
+ return 2400;
+ }
+
+ // 从页面中提取时长信息 - 支持 HH:MM:SS, MM:SS 或纯数字格式
+ // 匹配格式如: duration:'02:23:58', duration: "02:23:58", duration:02:23:58, duration:12345
+ const durationMatch = /duration['"]?\s*:\s*['"]?(\d{2}):(\d{2}):(\d{2})['"]?|duration['"]?\s*:\s*['"]?(\d{2}):(\d{2})['"]?|duration['"]?\s*:\s*(\d+)['"]?/.exec(response.data);
+ if (durationMatch) {
+ // 检查是否匹配到 HH:MM:SS 格式 (第1-3捕获组)
+ if (durationMatch[1] && durationMatch[2] && durationMatch[3]) {
+ const hours = parseInt(durationMatch[1]);
+ const minutes = parseInt(durationMatch[2]);
+ const seconds = parseInt(durationMatch[3]);
+ return hours * 3600 + minutes * 60 + seconds;
+ }
+ // 检查是否匹配到 MM:SS 格式 (第4-5捕获组)
+ else if (durationMatch[4] && durationMatch[5]) {
+ const minutes = parseInt(durationMatch[4]);
+ const seconds = parseInt(durationMatch[5]);
+ return minutes * 60 + seconds;
+ }
+ // 检查是否匹配到纯数字格式 (第6捕获组)
+ else if (durationMatch[6]) {
+ const seconds = parseInt(durationMatch[6]);
+ return seconds;
+ }
+ }
+
+ // 默认返回40分钟
+ return 2400;
+ } catch (e) {
+ log("warning", `获取视频时长失败: ${e}，使用默认值2400秒`);
+ return 2400;
+ }
+ }
+
+ formatComments(comments) {
+ return comments.map(comment => {
+ try {
+ // 位置转换
+ const position = this.positionMap[parseInt(comment.position)] || 1;
+
+ // 时间（秒）
+ const timeVal = parseFloat(comment.start || 0);
+
+ // 颜色（十六进制转十进制）
+ const colorHex = comment.color || 'FFFFFF';
+ const color = parseInt(colorHex, 16);
+
+ // 弹幕ID
+ const danmuId = comment.id || comment._id || '';
+
+ // 弹幕内容
+ const content = comment.txt || '';
+
+ // 构造p属性：时间,模式,字体大小,颜色,时间戳,池,用户ID,弹幕ID
+ const pString = `${timeVal.toFixed(2)},${position},25,${color},[${this.constructor.name.toLowerCase()}]`;
+
+ return {
+ cid: String(danmuId),
+ p: pString,
+ m: content,
+ t: Math.round(timeVal * 100) / 100
+ };
+ } catch (error) {
+ log("error", `格式化弹幕失败: ${error.message}, 弹幕数据:`, comment);
+ return null;
+ }
+ }).filter(comment => comment !== null);
+ }
+}
diff --git a/danmu_api/worker.test.js b/danmu_api/worker.test.js
index 634b083..8110f96 100644
--- a/danmu_api/worker.test.js
+++ b/danmu_api/worker.test.js
@@ -19,6 +19,7 @@ import MangoSource from "./sources/mango.js";
import BilibiliSource from "./sources/bilibili.js";
import YoukuSource from "./sources/youku.js";
import SohuSource from "./sources/sohu.js";
+import LeshiSource from "./sources/leshi.js";
import AnimekoSource from "./sources/animeko.js";
import OtherSource from "./sources/other.js";
import { NodeHandler } from "./configs/handlers/node-handler.js";
@@ -61,6 +62,7 @@ test('worker.js API endpoints', async (t) => {
const bilibiliSource = new BilibiliSource();
const youkuSource = new YoukuSource();
const sohuSource = new SohuSource();
+ const leshiSource = new LeshiSource();
const animekoSource = new AnimekoSource();
const otherSource = new OtherSource();
@@ -229,6 +231,28 @@ test('worker.js API endpoints', async (t) => {
// assert(res.length >= 0, `Expected res.length >= 0, but got ${res.length}`);
// });
+ // await t.test('GET leshi danmu', async () => {
+ // const res = await leshiSource.getComments("https://www.le.com/ptv/vplay/1578861.html");
+ // assert(res.length > 2, `Expected res.length > 2, but got ${res.length}`);
+ // });
+
+ // await t.test('GET leshi danmu segments', async () => {
+ // const res = await leshiSource.getComments("https://www.le.com/ptv/vplay/1578861.html", "leshi", true);
+ // assert(res.type === "leshi", `Expected res.type === "leshi", but got ${res.type === "leshi"}`);
+ // assert(res.segmentList.length >= 0, `Expected res.segmentList.length >= 0, but got ${res.segmentList.length}`);
+ // });
+
+ // await t.test('GET leshi segment danmu', async () => {
+ // const segment = Segment.fromJson({
+ // type: 'leshi',
+ // segment_start: 1800,
+ // segment_end: 2100,
+ // url: 'https://hd-my.le.com/danmu/list?vid=1578861&start=1800&end=2100&callback=vjs_1768494351290',
+ // });
+ // const res = await leshiSource.getSegmentComments(segment);
+ // assert(res.length >= 0, `Expected res.length >= 0, but got ${res.length}`);
+ // });
+
// await t.test('GET other_server danmu', async () => {
// const res = await otherSource.getComments("https://www.bilibili.com/bangumi/play/ep1231564");
// assert(res.length > 2, `Expected res.length > 2, but got ${res.length}`);
diff --git a/forward/forward-widget.js b/forward/forward-widget.js
index 2eb8fe4..b8e0dec 100644
--- a/forward/forward-widget.js
+++ b/forward/forward-widget.js
@@ -16,7 +16,7 @@ WidgetMetadata = {
// 源配置
{
name: "sourceOrder",
- title: "源排序配置，默认'360,vod,renren,hanjutv'，可选['360', 'vod', 'tmdb', 'douban', 'tencent', 'youku', 'iqiyi', 'imgo', 'bilibili', 'sohu', 'renren', 'hanjutv', 'bahamut', 'dandan', 'custom']",
+ title: "源排序配置，默认'360,vod,renren,hanjutv'，可选['360', 'vod', 'tmdb', 'douban', 'tencent', 'youku', 'iqiyi', 'imgo', 'bilibili', 'sohu', 'leshi', 'renren', 'hanjutv', 'bahamut', 'dandan', 'custom']",
type: "input",
placeholders: [
{
@@ -151,12 +151,12 @@ WidgetMetadata = {
// 匹配配置
{
name: "platformOrder",
- title: "平台优选配置，可选['qiyi', 'bilibili1', 'imgo', 'youku', 'qq', 'sohu', 'renren', 'hanjutv', 'bahamut', 'dandan', 'custom']",
+ title: "平台优选配置，可选['qiyi', 'bilibili1', 'imgo', 'youku', 'qq', 'sohu', 'leshi', 'renren', 'hanjutv', 'bahamut', 'dandan', 'custom']",
type: "input",
placeholders: [
{
title: "配置1",
- value: "qq,qiyi,imgo,bilibili1,youku,sohu,renren,hanjutv,bahamut,dandan,custom",
+ value: "qq,qiyi,imgo,bilibili1,youku,sohu,leshi,renren,hanjutv,bahamut,dandan,custom",
},
{
title: "配置2",