+
@@ -186,6 +213,7 @@ function loadApiParams() {
// 为参数输入框添加回车事件监听
attachEnterEventToParams();
+ bindCommentDurationFieldVisibility();
}
function testApi() {
@@ -429,12 +457,89 @@ function formatDuration(seconds) {
return m + ':' + String(sec).padStart(2,'0');
}
-// 用P99分位数计算有效时长，剔除异常时间点
-function getEffectiveDuration(comments) {
- const times = comments.map(c => c.t !== undefined ? c.t : parseDanmuTime(c.p)).sort((a, b) => a - b);
- if (times.length === 0) return 0;
- const idx = Math.floor(times.length * 0.99);
- return times[Math.min(idx, times.length - 1)];
+function getValidDanmuTimes(comments) {
+ return comments
+ .map(c => c.t !== undefined ? Number(c.t) : parseDanmuTime(c.p))
+ .filter(time => Number.isFinite(time) && time >= 0)
+ .sort((a, b) => a - b);
+}
+
+function getPercentileValue(sortedValues, percentile) {
+ if (!sortedValues.length) return 0;
+ const safePercentile = Math.min(Math.max(percentile, 0), 1);
+ const index = Math.floor((sortedValues.length - 1) * safePercentile);
+ return sortedValues[index] || 0;
+}
+
+function getMedian(values) {
+ if (!values.length) return 0;
+ const sorted = [...values].sort((a, b) => a - b);
+ const mid = Math.floor(sorted.length / 2);
+ return sorted.length % 2 === 0 ? (sorted[mid - 1] + sorted[mid]) / 2 : sorted[mid];
+}
+
+function buildTailGapThreshold(sortedValues) {
+ if (sortedValues.length < 2) return 45;
+
+ const gaps = [];
+ const startIndex = Math.max(1, sortedValues.length - 80);
+ for (let i = startIndex; i < sortedValues.length; i++) {
+ const gap = sortedValues[i] - sortedValues[i - 1];
+ if (gap > 0) {
+ gaps.push(gap);
+ }
+ }
+
+ if (!gaps.length) return 45;
+
+ const sortedGaps = [...gaps].sort((a, b) => a - b);
+ const medianGap = getMedian(sortedGaps);
+ const p90Gap = getPercentileValue(sortedGaps, 0.9);
+ return Math.min(240, Math.max(45, medianGap * 12, p90Gap * 3));
+}
+
+function estimateVideoDurationFromComments(comments) {
+ const validTimes = getValidDanmuTimes(comments);
+ if (!validTimes.length) return 0;
+ if (validTimes.length < 200) return validTimes[validTimes.length - 1];
+
+ const p995Time = getPercentileValue(validTimes, 0.995);
+ const p998Time = getPercentileValue(validTimes, 0.998);
+ const gapThreshold = buildTailGapThreshold(validTimes);
+ const trimBaseline = p998Time + Math.max(90, gapThreshold * 2);
+ let endIndex = validTimes.length - 1;
+
+ while (endIndex > 0) {
+ let tailStartIndex = endIndex;
+ while (tailStartIndex > 0) {
+ const gap = validTimes[tailStartIndex] - validTimes[tailStartIndex - 1];
+ if (gap > gapThreshold) break;
+ tailStartIndex--;
+ }
+
+ const tailClusterSize = endIndex - tailStartIndex + 1;
+ const tailClusterSpan = validTimes[endIndex] - validTimes[tailStartIndex];
+ const previousGap = tailStartIndex > 0 ? validTimes[tailStartIndex] - validTimes[tailStartIndex - 1] : 0;
+ const isIsolatedTail = tailStartIndex > 0
+ && tailClusterSize <= 2
+ && tailClusterSpan <= 15
+ && previousGap > gapThreshold;
+
+ if (!isIsolatedTail || validTimes[endIndex] <= trimBaseline) {
+ break;
+ }
+
+ endIndex = tailStartIndex - 1;
+ }
+
+ return Math.max(validTimes[Math.max(endIndex, 0)] || 0, p995Time);
+}
+
+function getEffectiveDuration(comments, explicitDuration) {
+ if (Number.isFinite(explicitDuration) && explicitDuration > 0) {
+ return explicitDuration;
+ }
+ return estimateVideoDurationFromComments(comments);
}
function setBtnLoading(btn, loading) {
@@ -646,6 +751,7 @@ async function fetchDanmuForTest(episodeId, title, source) {
addLog('获取弹幕: ' + episodeId + ' (' + title + ')', 'info');
danmuTestState.currentEpisodeId = episodeId;
danmuTestState.currentTitle = title;
+ danmuTestState.currentDuration = 0;
// 隐藏上级面板
if (source === 'manual') {
@@ -661,10 +767,13 @@ async function fetchDanmuForTest(episodeId, title, source) {
const startTime = performance.now();
try {
- const resp = await fetch(buildApiUrl('/api/v2/comment/' + episodeId + "?format=json"));
- if (!resp.ok) throw new Error('HTTP ' + resp.status);
- const data = await resp.json();
+ const data = await fetch(buildApiUrl('/api/v2/comment/' + episodeId + "?format=json&duration=true"))
+ .then(resp => {
+ if (!resp.ok) throw new Error('HTTP ' + resp.status);
+ return resp.json();
+ });
const elapsed = ((performance.now() - startTime) / 1000).toFixed(2);
+ const durationSeconds = Number((data && data.videoDuration) || 0);
if (!data.comments || data.comments.length === 0) {
customAlert('该剧集暂无弹幕数据');
@@ -679,6 +788,7 @@ async function fetchDanmuForTest(episodeId, title, source) {
danmuTestState.allComments = data.comments;
danmuTestState.currentFilter = 'all';
danmuTestState.displayedCount = 0;
+ danmuTestState.currentDuration = durationSeconds;
// 重建结果区内容：auto模式只有导出按钮，manual模式有返回+导出
let toolbarHtml = '
';
@@ -706,8 +816,8 @@ async function fetchDanmuForTest(episodeId, title, source) {
'
';
applyDanmuFilter();
- renderDanmuStats(data, elapsed, title);
- renderDanmuHeatmap(data.comments);
+ renderDanmuStats(data, elapsed, title, durationSeconds);
+ renderDanmuHeatmap(data.comments, durationSeconds);
renderDanmuList();
setTimeout(() => resultArea.scrollIntoView({ behavior: 'smooth', block: 'start' }), 10);
@@ -764,12 +874,11 @@ async function exportDanmu(format) {
// =====================
// 弹幕统计
// =====================
-function renderDanmuStats(data, elapsed, title) {
+function renderDanmuStats(data, elapsed, title, durationSeconds) {
const comments = data.comments;
const count = comments.length;
- // 用P99分位数作为有效时长
- const maxTime = getEffectiveDuration(comments);
+ const maxTime = getEffectiveDuration(comments, durationSeconds);
// 平均密度
const durationMin = maxTime / 60;
@@ -817,9 +926,9 @@ function renderDanmuStats(data, elapsed, title) {
// =====================
// 弹幕热力图
// =====================
-function renderDanmuHeatmap(comments) {
+function renderDanmuHeatmap(comments, durationSeconds) {
const container = document.getElementById('danmu-heatmap');
- const maxTime = getEffectiveDuration(comments);
+ const maxTime = getEffectiveDuration(comments, durationSeconds);
if (maxTime === 0) { container.innerHTML = '
无数据
'; return; }
const barCount = Math.min(60, Math.max(20, Math.ceil(maxTime / 30)));
diff --git a/danmu_api/worker.js b/danmu_api/worker.js
index 59cc4c1..a21c031 100644
--- a/danmu_api/worker.js
+++ b/danmu_api/worker.js
@@ -305,7 +305,9 @@ async function handleRequest(req, env, deployPlatform, clientIp) {
const queryFormat = url.searchParams.get('format');
const videoUrl = url.searchParams.get('url');
const segmentFlagParam = url.searchParams.get('segmentflag');
+ const durationParam = url.searchParams.get('duration');
const segmentFlag = segmentFlagParam === 'true' || segmentFlagParam === '1';
+ const includeDuration = durationParam === 'true' || durationParam === '1';
// ⚠️ 限流设计说明：
// 1. 先检查缓存，缓存命中时直接返回，不计入限流次数
@@ -318,8 +320,7 @@ async function handleRequest(req, env, deployPlatform, clientIp) {
const cachedComments = getCommentCache(videoUrl);
if (cachedComments !== null) {
log("info", `[Rate Limit] Cache hit for URL: ${videoUrl}, skipping rate limit check`);
- const responseData = { count: cachedComments.length, comments: cachedComments };
- return formatDanmuResponse(responseData, queryFormat);
+ return getCommentByUrl(videoUrl, queryFormat, segmentFlag, includeDuration);
}
// 缓存未命中，执行限流检查（如果 rateLimitMaxRequests > 0 则启用限流）
@@ -354,7 +355,7 @@ async function handleRequest(req, env, deployPlatform, clientIp) {
}
// 通过URL获取弹幕
- return getCommentByUrl(videoUrl, queryFormat, segmentFlag);
+ return getCommentByUrl(videoUrl, queryFormat, segmentFlag, includeDuration);
}
// 否则通过commentId获取弹幕
@@ -374,8 +375,7 @@ async function handleRequest(req, env, deployPlatform, clientIp) {
const cachedComments = getCommentCache(urlForComment);
if (cachedComments !== null) {
log("info", `[Rate Limit] Cache hit for URL: ${urlForComment}, skipping rate limit check`);
- const responseData = { count: cachedComments.length, comments: cachedComments };
- return formatDanmuResponse(responseData, queryFormat);
+ return getComment(path, queryFormat, segmentFlag, clientIp, includeDuration);
}
}
@@ -414,7 +414,7 @@ async function handleRequest(req, env, deployPlatform, clientIp) {
log("info", `[Rate Limit] IP ${clientIp} request count: ${recentRequests.length}/${globals.rateLimitMaxRequests}`);
}
- return getComment(path, queryFormat, segmentFlag, clientIp);
+ return getComment(path, queryFormat, segmentFlag, clientIp, includeDuration);
}
// POST /api/v2/segmentcomment - 接收segment类的JSON请求体
@@ -694,4 +694,4 @@ export async function netlifyHandler(event, context) {
}
// 为了测试导出 handleRequest
-export { handleRequest};
\ No newline at end of file
+export { handleRequest};
diff --git a/danmu_api/worker.test.js b/danmu_api/worker.test.js
index ee64f05..521cc1f 100644
--- a/danmu_api/worker.test.js
+++ b/danmu_api/worker.test.js
@@ -32,7 +32,9 @@ import { VercelHandler } from "./configs/handlers/vercel-handler.js";
import { NetlifyHandler } from "./configs/handlers/netlify-handler.js";
import { CloudflareHandler } from "./configs/handlers/cloudflare-handler.js";
import { EdgeoneHandler } from "./configs/handlers/edgeone-handler.js";
-import { Segment } from "./models/dandan-model.js"
+import { Globals } from "./configs/globals.js";
+import { addEpisode } from "./utils/cache-util.js";
+import { Segment, SegmentListResponse } from "./models/dandan-model.js"
// Mock Request class for testing
class MockRequest {
@@ -104,6 +106,179 @@ test('worker.js API endpoints', async (t) => {
assert(title === "宇宙Marry Me?" && season == 2 && episode == 8, `Expected title === "宇宙Marry Me?" && season == 2 && episode == 8, but got ${title} ${season} ${episode}`);
});
+ await t.test('GET /api/v2/comment/:id?format=json&duration=true should return segment duration and reuse comment cache', async () => {
+ Globals.init({});
+ Globals.animes = [];
+ Globals.episodeIds = [];
+ Globals.episodeNum = 10001;
+ Globals.commentCache = new Map();
+
+ const originalTencentGetComments = TencentSource.prototype.getComments;
+ let commentRequestCount = 0;
+ let durationRequestCount = 0;
+
+ TencentSource.prototype.getComments = async function(url, plat, segmentFlag) {
+ if (segmentFlag) {
+ durationRequestCount++;
+ return {
+ type: 'qq',
+ segmentList: [
+ { type: 'qq', segment_start: 0, segment_end: 60, url: 'mock-1' },
+ { type: 'qq', segment_start: 60, segment_end: 2760, url: 'mock-2' }
+ ]
+ };
+ }
+
+ commentRequestCount++;
+ return [
+ { p: '12.3,1,16777215,qq', m: '测试弹幕1' },
+ { p: '45.6,1,16777215,qq', m: '测试弹幕2' }
+ ];
+ };
+
+ try {
+ const episode = addEpisode('https://v.qq.com/x/cover/a/b.html', '【qq】测试样例');
+ const req = new MockRequest(urlPrefix + '/api/v2/comment/' + episode.id + '?format=json&duration=true', { method: 'GET' });
+ const res = await handleRequest(req);
+ const body = await parseResponse(res);
+ const cachedRes = await handleRequest(req);
+ const cachedBody = await parseResponse(cachedRes);
+
+ assert.equal(res.status, 200);
+ assert.equal(body.videoDuration, 2760);
+ assert.equal(body.count, 2);
+ assert.equal(body.comments.length, 2);
+ assert.equal(cachedRes.status, 200);
+ assert.equal(cachedBody.videoDuration, 2760);
+ assert.equal(commentRequestCount, 1);
+ assert.equal(durationRequestCount, 2);
+ assert.equal(Globals.commentCache.size, 1);
+ } finally {
+ TencentSource.prototype.getComments = originalTencentGetComments;
+ Globals.episodeIds = [];
+ Globals.commentCache = new Map();
+ }
+ });
+
+ await t.test('GET /api/v2/comment/:id?format=json&duration=true should use merged max duration', async () => {
+ Globals.init({});
+ Globals.animes = [];
+ Globals.episodeIds = [];
+ Globals.episodeNum = 10001;
+ Globals.commentCache = new Map();
+
+ const originalTencentGetComments = TencentSource.prototype.getComments;
+ const originalIqiyiGetComments = IqiyiSource.prototype.getComments;
+ const originalYoukuGetComments = YoukuSource.prototype.getComments;
+
+ TencentSource.prototype.getComments = async function(url, plat, segmentFlag) {
+ if (segmentFlag) {
+ return {
+ type: 'qq',
+ segmentList: [
+ { type: 'qq', segment_start: 0, segment_end: 2760, url: 'mock-qq' }
+ ]
+ };
+ }
+ return [
+ { p: '12.3,1,16777215,qq', m: '腾讯弹幕' }
+ ];
+ };
+
+ IqiyiSource.prototype.getComments = async function(url, plat, segmentFlag) {
+ if (segmentFlag) {
+ return {
+ type: 'qiyi',
+ segmentList: [
+ { type: 'qiyi', segment_start: 0, segment_end: 1200, url: 'mock-qiyi-1' },
+ { type: 'qiyi', segment_start: 1200, segment_end: 2682, url: 'mock-qiyi-2' }
+ ]
+ };
+ }
+ return [
+ { p: '15.0,1,16777215,qiyi', m: '爱奇艺弹幕' }
+ ];
+ };
+
+ YoukuSource.prototype.getComments = async function(url, plat, segmentFlag) {
+ if (segmentFlag) {
+ return {
+ type: 'youku',
+ segmentList: [
+ { type: 'youku', segment_start: 0, segment_end: 1800, url: 'mock-youku-1' },
+ { type: 'youku', segment_start: 1800, segment_end: 3000, url: 'mock-youku-2' }
+ ]
+ };
+ }
+ return [
+ { p: '18.0,1,16777215,youku', m: '优酷弹幕' }
+ ];
+ };
+
+ try {
+ const episode = addEpisode(
+ 'tencent:https://v.qq.com/x/cover/a/b.html$$$iqiyi:https://www.iqiyi.com/v_test.html$$$youku:https://v.youku.com/v_show/id_test.html',
+ '【qq＆qiyi＆youku】合并测试'
+ );
+ const req = new MockRequest(urlPrefix + '/api/v2/comment/' + episode.id + '?format=json&duration=true', { method: 'GET' });
+ const res = await handleRequest(req);
+ const body = await parseResponse(res);
+
+ assert.equal(res.status, 200);
+ assert.equal(body.videoDuration, 3000);
+ assert.ok(Array.isArray(body.comments));
+ } finally {
+ TencentSource.prototype.getComments = originalTencentGetComments;
+ IqiyiSource.prototype.getComments = originalIqiyiGetComments;
+ YoukuSource.prototype.getComments = originalYoukuGetComments;
+ Globals.episodeIds = [];
+ Globals.commentCache = new Map();
+ }
+ });
+
+ await t.test('GET /api/v2/comment/:id?format=json&duration=true should prefer explicit duration field', async () => {
+ Globals.init({});
+ Globals.animes = [];
+ Globals.episodeIds = [];
+ Globals.episodeNum = 10001;
+ Globals.commentCache = new Map();
+
+ const originalBilibiliGetComments = BilibiliSource.prototype.getComments;
+ BilibiliSource.prototype.getComments = async function(url, plat, segmentFlag) {
+ if (segmentFlag) {
+ return new SegmentListResponse({
+ type: 'bilibili1',
+ duration: 1312.76,
+ segmentList: [
+ { type: 'bilibili1', segment_start: 0, segment_end: 360, url: 'mock-bili-1' },
+ { type: 'bilibili1', segment_start: 360, segment_end: 720, url: 'mock-bili-2' },
+ { type: 'bilibili1', segment_start: 720, segment_end: 1080, url: 'mock-bili-3' },
+ { type: 'bilibili1', segment_start: 1080, segment_end: 1440, url: 'mock-bili-4' }
+ ]
+ });
+ }
+ return [
+ { p: '20.0,1,16777215,bilibili1', m: 'B站弹幕1' },
+ { p: '30.0,1,16777215,bilibili1', m: 'B站弹幕2' }
+ ];
+ };
+
+ try {
+ const episode = addEpisode('https://www.bilibili.com/bangumi/play/ep_test.html', '【bilibili】测试样例');
+ const req = new MockRequest(urlPrefix + '/api/v2/comment/' + episode.id + '?format=json&duration=true', { method: 'GET' });
+ const res = await handleRequest(req);
+ const body = await parseResponse(res);
+
+ assert.equal(res.status, 200);
+ assert.equal(body.videoDuration, 1312.76);
+ assert.equal(body.count, 2);
+ } finally {
+ BilibiliSource.prototype.getComments = originalBilibiliGetComments;
+ Globals.episodeIds = [];
+ Globals.commentCache = new Map();
+ }
+ });
+
// await t.test('Test ai cilent', async () => {
// const ai = new AIClient({
// apiKey: 'xxxxxxxxxxxxxxxxxxxxx',